本文整理汇总了Golang中github.com/golang/protobuf/proto.Message类的典型用法代码示例。如果您正苦于以下问题：Golang Message类的具体用法？Golang Message怎么用？Golang Message使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了Message类的6个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: event
func event(serviceName string, methodName string, request proto.Message, response proto.Message, err error, duration time.Duration) *Call {
call := &Call{
Service: serviceName,
Method: methodName,
Duration: prototime.DurationToProto(duration),
}
if request != nil {
call.Request = request.String()
}
if response != nil {
call.Response = response.String()
}
if err != nil {
call.Error = err.Error()
}
return call
}
开发者ID:angelabier1，项目名称:pachyderm，代码行数:17，代码来源:protorpclog.go
示例2: namespaceMod
func namespaceMod(m proto.Message, namespace string) {
// pb.Query is the only type that has a name_space field.
// All other namespace support in datastore is in the keys.
switch m := m.(type) {
case *pb.Query:
if m.NameSpace == nil {
m.NameSpace = &namespace
}
}
}
开发者ID:Celluliodio，项目名称:flannel，代码行数:10，代码来源:datastore.go
示例3: override
func override(ctx context.Context, service, method string, in, out proto.Message) error {
stats := ctx.Value(statsKey).(*requestStats)
stats.wg.Add(1)
defer stats.wg.Done()
if service == "__go__" {
return appengine.APICall(ctx, service, method, in, out)
}
// NOTE: This limits size of stack traces to 65KiB.
b := make([]byte, 65536)
i := runtime.Stack(b, false)
stat := rpcStat{
Service: service,
Method: method,
Start: time.Now(),
Offset: time.Since(stats.Start),
StackData: string(b[0:i]),
}
err := appengine.APICall(ctx, service, method, in, out)
stat.Duration = time.Since(stat.Start)
stat.In = in.String()
stat.Out = out.String()
stat.Cost = getCost(out)
if len(stat.In) > ProtoMaxBytes {
stat.In = stat.In[:ProtoMaxBytes] + "..."
}
if len(stat.Out) > ProtoMaxBytes {
stat.Out = stat.Out[:ProtoMaxBytes] + "..."
}
stats.lock.Lock()
stats.RPCStats = append(stats.RPCStats, stat)
stats.Cost += stat.Cost
stats.lock.Unlock()
return err
}
开发者ID:flowlo，项目名称:appstats，代码行数:42，代码来源:appstats.go
示例4: namespaceMod
func namespaceMod(m proto.Message, namespace string) {
switch m := m.(type) {
case *pb.MemcacheDeleteRequest:
if m.NameSpace == nil {
m.NameSpace = &namespace
}
case *pb.MemcacheGetRequest:
if m.NameSpace == nil {
m.NameSpace = &namespace
}
case *pb.MemcacheIncrementRequest:
if m.NameSpace == nil {
m.NameSpace = &namespace
}
case *pb.MemcacheSetRequest:
if m.NameSpace == nil {
m.NameSpace = &namespace
}
// MemcacheFlushRequest, MemcacheStatsRequest do not apply namespace.
}
}
开发者ID:Celluliodio，项目名称:flannel，代码行数:21，代码来源:memcache.go
示例5: override
func override(ctx context.Context, service, method string, in, out proto.Message) error {
stats := stats(ctx)
stats.wg.Add(1)
defer stats.wg.Done()
if service == "__go__" {
return appengine.APICall(ctx, service, method, in, out)
}
stat := rpcStat{
Service: service,
Method: method,
Start: time.Now(),
Offset: time.Since(stats.Start),
StackData: string(debug.Stack()),
}
err := appengine.APICall(ctx, service, method, in, out)
stat.Duration = time.Since(stat.Start)
stat.In = in.String()
stat.Out = out.String()
stat.Cost = getCost(out)
if len(stat.In) > ProtoMaxBytes {
stat.In = stat.In[:ProtoMaxBytes] + "..."
}
if len(stat.Out) > ProtoMaxBytes {
stat.Out = stat.Out[:ProtoMaxBytes] + "..."
}
stats.lock.Lock()
stats.RPCStats = append(stats.RPCStats, stat)
stats.Cost += stat.Cost
stats.lock.Unlock()
return err
}
开发者ID:skkoobb，项目名称:appstats，代码行数:36，代码来源:appstats.go
示例6: returnProtoToPool
func returnProtoToPool(pool sync.Pool, p proto.Message) {
p.Reset()
pool.Put(p)
}
开发者ID:jmptrader，项目名称:tcpez，代码行数:4，代码来源:proto_server.go
注：本文中的github.com/golang/protobuf/proto.Message类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论