本文整理汇总了Golang中github.com/gogo/protobuf/proto.Uint64函数的典型用法代码示例。如果您正苦于以下问题:Golang Uint64函数的具体用法?Golang Uint64怎么用?Golang Uint64使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了Uint64函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: newLogEntry
// Creates a new log entry associated with a log.
func newLogEntry(log *Log, event *ev, index uint64, term uint64, command Command) (*LogEntry, error) {
var buf bytes.Buffer
var commandName string
if command != nil {
commandName = command.CommandName()
if encoder, ok := command.(CommandEncoder); ok {
if err := encoder.Encode(&buf); err != nil {
return nil, err
}
} else {
if err := json.NewEncoder(&buf).Encode(command); err != nil {
return nil, err
}
}
}
pb := &protobuf.LogEntry{
Index: proto.Uint64(index),
Term: proto.Uint64(term),
CommandName: proto.String(commandName),
Command: buf.Bytes(),
}
e := &LogEntry{
pb: pb,
log: log,
event: event,
}
return e, nil
}
开发者ID:tnextday,项目名称:seaweedfs,代码行数:32,代码来源:log_entry.go
示例2: createStartStopMessage
func createStartStopMessage(requestId uint64, peerType events.PeerType) *events.Envelope {
return &events.Envelope{
Origin: proto.String("fake-origin-2"),
EventType: events.Envelope_HttpStartStop.Enum(),
HttpStartStop: &events.HttpStartStop{
StartTimestamp: proto.Int64(1),
StopTimestamp: proto.Int64(100),
RequestId: &events.UUID{
Low: proto.Uint64(requestId),
High: proto.Uint64(requestId + 1),
},
PeerType: &peerType,
Method: events.Method_GET.Enum(),
Uri: proto.String("fake-uri-1"),
RemoteAddress: proto.String("fake-remote-addr-1"),
UserAgent: proto.String("fake-user-agent-1"),
StatusCode: proto.Int32(103),
ContentLength: proto.Int64(104),
ApplicationId: &events.UUID{
Low: proto.Uint64(105),
High: proto.Uint64(106),
},
InstanceIndex: proto.Int32(6),
InstanceId: proto.String("fake-instance-id-1"),
},
}
}
开发者ID:yingkitw,项目名称:loggregator,代码行数:27,代码来源:message_aggregator_test.go
示例3: generateCounterEvent
func generateCounterEvent(delta, total uint64) *events.CounterEvent {
return &events.CounterEvent{
Name: proto.String("TruncatingBuffer.DroppedMessages"),
Delta: proto.Uint64(delta),
Total: proto.Uint64(total),
}
}
开发者ID:kei-yamazaki,项目名称:loggregator,代码行数:7,代码来源:truncating_buffer.go
示例4: encodeCounterEvent
func (d *DroppedCounter) encodeCounterEvent(droppedCount, totalDropped int64) []byte {
message := &events.Envelope{
Origin: proto.String(d.origin),
Timestamp: proto.Int64(time.Now().UnixNano()),
Ip: proto.String(d.ip),
Deployment: proto.String(d.conf.Deployment),
Index: proto.String(d.conf.Index),
Job: proto.String(d.conf.Job),
EventType: events.Envelope_CounterEvent.Enum(),
CounterEvent: &events.CounterEvent{
Name: proto.String("DroppedCounter.droppedMessageCount"),
Delta: proto.Uint64(uint64(droppedCount)),
Total: proto.Uint64(uint64(totalDropped)),
},
}
bytes, err := message.Marshal()
if err != nil {
d.incrementer.BatchIncrementCounter("droppedCounter.sendErrors")
d.timer.Reset(time.Millisecond)
return nil
}
return prefixMessage(bytes)
}
开发者ID:kei-yamazaki,项目名称:loggregator,代码行数:25,代码来源:dropped_counter.go
示例5: handleFetchData
// handleFetchData handles a request for the current nodes meta data
func (r *rpc) handleFetchData(req *internal.FetchDataRequest) (*internal.FetchDataResponse, error) {
var (
b []byte
data *Data
err error
)
for {
data = r.store.cachedData()
if data.Index != req.GetIndex() {
b, err = data.MarshalBinary()
if err != nil {
return nil, err
}
break
}
if !req.GetBlocking() {
break
}
if err := r.store.WaitForDataChanged(); err != nil {
return nil, err
}
}
return &internal.FetchDataResponse{
Header: &internal.ResponseHeader{
OK: proto.Bool(true),
},
Index: proto.Uint64(data.Index),
Term: proto.Uint64(data.Term),
Data: b}, nil
}
开发者ID:kfitzpatrick,项目名称:influxdb,代码行数:35,代码来源:rpc.go
示例6: TestUnmarshalPartiallyPopulatedOptionalFieldsFails
func TestUnmarshalPartiallyPopulatedOptionalFieldsFails(t *testing.T) {
// Fill in all fields, then randomly remove one.
dataOut := &test.NinOptNative{
Field1: proto.Float64(0),
Field2: proto.Float32(0),
Field3: proto.Int32(0),
Field4: proto.Int64(0),
Field5: proto.Uint32(0),
Field6: proto.Uint64(0),
Field7: proto.Int32(0),
Field8: proto.Int64(0),
Field9: proto.Uint32(0),
Field10: proto.Int32(0),
Field11: proto.Uint64(0),
Field12: proto.Int64(0),
Field13: proto.Bool(false),
Field14: proto.String("0"),
Field15: []byte("0"),
}
r := rand.New(rand.NewSource(time.Now().UnixNano()))
fieldName := "Field" + strconv.Itoa(r.Intn(15)+1)
field := reflect.ValueOf(dataOut).Elem().FieldByName(fieldName)
fieldType := field.Type()
field.Set(reflect.Zero(fieldType))
encodedMessage, err := proto.Marshal(dataOut)
if err != nil {
t.Fatalf("Unexpected error when marshalling dataOut: %v", err)
}
dataIn := NidOptNative{}
err = proto.Unmarshal(encodedMessage, &dataIn)
if err.Error() != `proto: required field "`+fieldName+`" not set` {
t.Fatalf(`err.Error() != "proto: required field "`+fieldName+`" not set"; was "%s" instead`, err.Error())
}
}
开发者ID:nolenroyalty,项目名称:bangarang,代码行数:34,代码来源:requiredexamplepb_test.go
示例7: Encode
// Encodes the SnapshotRecoveryRequest to a buffer. Returns the number of bytes
// written and any error that may have occurred.
func (req *SnapshotRecoveryRequest) Encode(w io.Writer) (int, error) {
protoPeers := make([]*protobuf.SnapshotRecoveryRequest_Peer, len(req.Peers))
for i, peer := range req.Peers {
protoPeers[i] = &protobuf.SnapshotRecoveryRequest_Peer{
Name: proto.String(peer.Name),
ConnectionString: proto.String(peer.ConnectionString),
}
}
pb := &protobuf.SnapshotRecoveryRequest{
LeaderName: proto.String(req.LeaderName),
LastIndex: proto.Uint64(req.LastIndex),
LastTerm: proto.Uint64(req.LastTerm),
Peers: protoPeers,
State: req.State,
}
p, err := proto.Marshal(pb)
if err != nil {
return -1, err
}
return w.Write(p)
}
开发者ID:shaleman,项目名称:raft,代码行数:27,代码来源:snapshot.go
示例8: NewHeartbeat
func NewHeartbeat(sentCount, receivedCount, errorCount uint64) *events.Heartbeat {
return &events.Heartbeat{
SentCount: proto.Uint64(sentCount),
ReceivedCount: proto.Uint64(receivedCount),
ErrorCount: proto.Uint64(errorCount),
}
}
开发者ID:jungle0755,项目名称:gorouter,代码行数:7,代码来源:factories.go
示例9: ParseRanges
func ParseRanges(text string) (*mesosproto.Value_Ranges, error) {
reg := regexp.MustCompile(`([\d]+)`)
ports := reg.FindAllString(text, -1)
ranges := &mesosproto.Value_Ranges{}
if len(ports)%2 != 0 {
return nil, errors.New("Cannot parse range string: " + text)
}
for i := 0; i < len(ports)-1; i += 2 {
i64Begin, err := strconv.Atoi(ports[i])
if err != nil {
return nil, errors.New("Cannot parse range string: " + text)
}
i64End, err := strconv.Atoi(ports[i+1])
if err != nil {
return nil, errors.New("Cannot parse range string: " + text)
}
ranges.Range = append(ranges.Range, &mesosproto.Value_Range{
Begin: proto.Uint64(uint64(i64Begin)),
End: proto.Uint64(uint64(i64End)),
})
}
return ranges, nil
}
开发者ID:icsnju,项目名称:apt-mesos,代码行数:26,代码来源:range.go
示例10: terminate
func (d *LauncherData) terminate(row *RunQueueEntry, action string) {
if d.killedRecently[row.Id] {
return
}
if action == KILL_ACTION_NO_ACTION {
d.call(&badoo_phproxyd.RequestTerminate{Hash: proto.Uint64(row.Id)})
} else {
params := []string{
`\ScriptFramework\Script_Kill`,
fmt.Sprintf("--force-sf-db=%s", db.GetDbName()),
fmt.Sprintf("--kill-run-id=%d", row.Id),
fmt.Sprintf("--kill-action=%s", action),
fmt.Sprintf("--kill-class-name=%s", row.ClassName),
fmt.Sprintf("--kill-timetable-id=%d", row.timetable_id.Int64),
}
d.call(&badoo_phproxyd.RequestRun{
Script: proto.String(getScriptPath(row.settings)),
Hash: proto.Uint64(0),
Tag: proto.String(PHPROXY_TAG),
Force: proto.Int32(1),
Params: params,
Store: badoo_phproxyd.StoreT_MEMORY.Enum(),
FreeAfterRun: proto.Bool(true),
})
}
d.killedRecently[row.Id] = true
}
开发者ID:badoo,项目名称:thunder,代码行数:30,代码来源:launcher.go
示例11: BasicCounterEvent
func BasicCounterEvent(origin string) *events.Envelope {
return &events.Envelope{
Origin: proto.String(origin),
EventType: events.Envelope_CounterEvent.Enum(),
CounterEvent: &events.CounterEvent{
Name: proto.String("fake-counter-event"),
Delta: proto.Uint64(1),
Total: proto.Uint64(2),
},
}
}
开发者ID:kei-yamazaki,项目名称:loggregator,代码行数:11,代码来源:message_generator.go
示例12: basicCounterEventEnvelope
func basicCounterEventEnvelope() *events.Envelope {
return &events.Envelope{
Origin: proto.String("fake-origin-2"),
EventType: events.Envelope_CounterEvent.Enum(),
CounterEvent: &events.CounterEvent{
Name: proto.String("fake-metric-name"),
Delta: proto.Uint64(3),
Total: proto.Uint64(3),
},
}
}
开发者ID:nagyistoce,项目名称:cloudfoundry-loggregator,代码行数:11,代码来源:metrics_suite_test.go
示例13: newAppendEntriesResponse
// Creates a new AppendEntries response.
func newAppendEntriesResponse(term uint64, success bool, index uint64, commitIndex uint64) *AppendEntriesResponse {
pb := &protobuf.AppendEntriesResponse{
Term: proto.Uint64(term),
Index: proto.Uint64(index),
Success: proto.Bool(success),
CommitIndex: proto.Uint64(commitIndex),
}
return &AppendEntriesResponse{
pb: pb,
}
}
开发者ID:shaleman,项目名称:raft,代码行数:13,代码来源:append_entries.go
示例14: createCounterEvent
func createCounterEvent() *events.Envelope {
return &events.Envelope{
Origin: proto.String(helpers.ORIGIN_NAME),
EventType: events.Envelope_CounterEvent.Enum(),
Timestamp: proto.Int64(time.Now().UnixNano()),
CounterEvent: &events.CounterEvent{
Name: proto.String("LATs-Counter"),
Delta: proto.Uint64(5),
Total: proto.Uint64(5),
},
}
}
开发者ID:kei-yamazaki,项目名称:loggregator,代码行数:12,代码来源:metrics_test.go
示例15: createContainerMetric
func createContainerMetric(appId string) *events.Envelope {
return &events.Envelope{
Origin: proto.String(helpers.ORIGIN_NAME),
EventType: events.Envelope_ContainerMetric.Enum(),
Timestamp: proto.Int64(time.Now().UnixNano()),
ContainerMetric: &events.ContainerMetric{
ApplicationId: proto.String(appId),
InstanceIndex: proto.Int32(1),
CpuPercentage: proto.Float64(20.0),
MemoryBytes: proto.Uint64(10),
DiskBytes: proto.Uint64(20),
},
}
}
开发者ID:kei-yamazaki,项目名称:loggregator,代码行数:14,代码来源:metrics_test.go
示例16: metricFor
func metricFor(instanceId int32, timestamp time.Time, cpu float64, mem uint64, disk uint64) *events.Envelope {
unixTimestamp := timestamp.UnixNano()
return &events.Envelope{
EventType: events.Envelope_ContainerMetric.Enum(),
Timestamp: proto.Int64(unixTimestamp),
ContainerMetric: &events.ContainerMetric{
ApplicationId: proto.String("myApp"),
InstanceIndex: proto.Int32(instanceId),
CpuPercentage: proto.Float64(cpu),
MemoryBytes: proto.Uint64(mem),
DiskBytes: proto.Uint64(disk),
},
}
}
开发者ID:kei-yamazaki,项目名称:loggregator,代码行数:14,代码来源:container_metric_sink_test.go
示例17: Encode
// Encodes the RequestVoteRequest to a buffer. Returns the number of bytes
// written and any error that may have occurred.
func (req *RequestVoteRequest) Encode(w io.Writer) (int, error) {
pb := &protobuf.RequestVoteRequest{
Term: proto.Uint64(req.Term),
LastLogIndex: proto.Uint64(req.LastLogIndex),
LastLogTerm: proto.Uint64(req.LastLogTerm),
CandidateName: proto.String(req.CandidateName),
}
p, err := proto.Marshal(pb)
if err != nil {
return -1, err
}
return w.Write(p)
}
开发者ID:tnextday,项目名称:seaweedfs,代码行数:16,代码来源:request_vote.go
示例18: BuildBasicResources
// BuildBasicResources build basic resources
// including cpus, mem, disk, ports
func BuildBasicResources(task *registry.Task) {
if task.Build {
return
}
if task.Cpus > 0 {
task.Resources = append(task.Resources, &mesosproto.Resource{
Name: proto.String("cpus"),
Type: mesosproto.Value_SCALAR.Enum(),
Scalar: &mesosproto.Value_Scalar{Value: proto.Float64(task.Cpus)},
})
}
if task.Mem > 0 {
task.Resources = append(task.Resources, &mesosproto.Resource{
Name: proto.String("mem"),
Type: mesosproto.Value_SCALAR.Enum(),
Scalar: &mesosproto.Value_Scalar{Value: proto.Float64(task.Mem)},
})
}
if task.Disk > 0 {
task.Resources = append(task.Resources, &mesosproto.Resource{
Name: proto.String("disk"),
Type: mesosproto.Value_SCALAR.Enum(),
Scalar: &mesosproto.Value_Scalar{Value: proto.Float64(task.Disk)},
})
}
if len(task.Ports) > 0 {
ranges := &mesosproto.Value_Ranges{}
for _, port := range task.Ports {
if port.HostPort == 0 {
continue
}
ranges.Range = append(ranges.Range, &mesosproto.Value_Range{
Begin: proto.Uint64(uint64(port.HostPort)),
End: proto.Uint64(uint64(port.HostPort)),
})
}
task.Resources = append(task.Resources, &mesosproto.Resource{
Name: proto.String("ports"),
Type: mesosproto.Value_RANGES.Enum(),
Ranges: ranges,
})
}
task.Build = true
}
开发者ID:icsnju,项目名称:apt-mesos,代码行数:50,代码来源:resource.go
示例19: TestShardInfo_UnmarshalBinary_OwnerIDs
// Ensure shards with deprecated "OwnerIDs" can be decoded.
func TestShardInfo_UnmarshalBinary_OwnerIDs(t *testing.T) {
// Encode deprecated form to bytes.
buf, err := proto.Marshal(&internal.ShardInfo{
ID: proto.Uint64(1),
OwnerIDs: []uint64{10, 20, 30},
})
if err != nil {
t.Fatal(err)
}
// Decode deprecated form.
var si meta.ShardInfo
if err := si.UnmarshalBinary(buf); err != nil {
t.Fatal(err)
}
// Verify data is migrated correctly.
if !reflect.DeepEqual(si, meta.ShardInfo{
ID: 1,
Owners: []meta.ShardOwner{
{NodeID: 10},
{NodeID: 20},
{NodeID: 30},
},
}) {
t.Fatalf("unexpected shard info: %s", spew.Sdump(si))
}
}
开发者ID:rhyolight,项目名称:influxdb,代码行数:29,代码来源:data_test.go
示例20: DeleteNode
// DeleteNode removes a node from the metastore by id.
func (s *Store) DeleteNode(id uint64) error {
return s.exec(internal.Command_DeleteNodeCommand, internal.E_DeleteNodeCommand_Command,
&internal.DeleteNodeCommand{
ID: proto.Uint64(id),
},
)
}
开发者ID:radcheb,项目名称:influxdb,代码行数:8,代码来源:store.go
注:本文中的github.com/gogo/protobuf/proto.Uint64函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论