本文整理汇总了Golang中github.com/golang/protobuf/proto.CompactTextString函数的典型用法代码示例。如果您正苦于以下问题:Golang CompactTextString函数的具体用法?Golang CompactTextString怎么用?Golang CompactTextString使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了CompactTextString函数的8个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Golang代码示例。
示例1: MySQLOnly
// MySQLOnly is used to launch only a mysqld instance, with the specified db name.
// Use it before Schema option.
// It cannot be used at the same as ProtoTopo.
func MySQLOnly(dbName string) VitessOption {
return VitessOption{
beforeRun: func(hdl *Handle) error {
// the way to pass the dbname for creation in
// is to provide a topology
topo := &vttestpb.VTTestTopology{
Keyspaces: []*vttestpb.Keyspace{
{
Name: dbName,
Shards: []*vttestpb.Shard{
{
Name: "0",
DbNameOverride: dbName,
},
},
},
},
}
hdl.dbname = dbName
hdl.cmd.Args = append(hdl.cmd.Args,
"--mysql_only",
"--proto_topo", proto.CompactTextString(topo))
return nil
},
}
}
开发者ID:jmptrader,项目名称:vitess,代码行数:30,代码来源:local_cluster.go
示例2: ProtoTopo
// ProtoTopo is used to pass in the topology as a vttest proto definition.
// See vttest.proto for more information.
// It cannot be used at the same time as MySQLOnly.
func ProtoTopo(topo *vttestpb.VTTestTopology) VitessOption {
return VitessOption{
beforeRun: func(hdl *Handle) error {
hdl.cmd.Args = append(hdl.cmd.Args, "--proto_topo", proto.CompactTextString(topo))
return nil
},
}
}
开发者ID:jmptrader,项目名称:vitess,代码行数:11,代码来源:local_cluster.go
示例3: TestGetDupSuppressProto
// tests that a Getter's Get method is only called once with two
// outstanding callers. This is the proto variant.
func TestGetDupSuppressProto(t *testing.T) {
once.Do(testSetup)
// Start two getters. The first should block (waiting reading
// from stringc) and the second should latch on to the first
// one.
resc := make(chan *testpb.TestMessage, 2)
for i := 0; i < 2; i++ {
go func() {
tm := new(testpb.TestMessage)
if err := protoGroup.Get(dummyCtx, fromChan, ProtoSink(tm)); err != nil {
tm.Name = proto.String("ERROR:" + err.Error())
}
resc <- tm
}()
}
// Wait a bit so both goroutines get merged together via
// singleflight.
// TODO(bradfitz): decide whether there are any non-offensive
// debug/test hooks that could be added to singleflight to
// make a sleep here unnecessary.
time.Sleep(250 * time.Millisecond)
// Unblock the first getter, which should unblock the second
// as well.
stringc <- "Fluffy"
want := &testpb.TestMessage{
Name: proto.String("ECHO:Fluffy"),
City: proto.String("SOME-CITY"),
}
for i := 0; i < 2; i++ {
select {
case v := <-resc:
if !reflect.DeepEqual(v, want) {
t.Errorf(" Got: %v\nWant: %v", proto.CompactTextString(v), proto.CompactTextString(want))
}
case <-time.After(5 * time.Second):
t.Errorf("timeout waiting on getter #%d of 2", i+1)
}
}
}
开发者ID:ChrisYangLiu,项目名称:fakewechat,代码行数:43,代码来源:groupcache_test.go
示例4: WritePB
// WritePB writes a proto message to the writer.
func WritePB(writer io.Writer, pb proto.Message) error {
payloadBytes, err := proto.Marshal(pb)
if err != nil {
return fmt.Errorf("Failed to marshal proto: %s", proto.CompactTextString(pb))
}
payloadSize := [4]byte{}
binary.BigEndian.PutUint32(payloadSize[:], uint32(len(payloadBytes)))
if _, err = writer.Write(payloadSize[:]); err != nil {
return fmt.Errorf("Failed to write 4 bytes for size: %s", err)
}
if _, err = writer.Write(payloadBytes); err != nil {
return fmt.Errorf("Failed to write %d bytes to payload: %s", payloadSize, err)
}
return nil
}
开发者ID:xinlaini,项目名称:golibs,代码行数:17,代码来源:recordio.go
示例5: commandGetThrottlerConfiguration
func commandGetThrottlerConfiguration(ctx context.Context, wr *wrangler.Wrangler, subFlags *flag.FlagSet, args []string) error {
server := subFlags.String("server", "", "vtworker or vttablet to connect to")
if err := subFlags.Parse(args); err != nil {
return err
}
if subFlags.NArg() > 1 {
return fmt.Errorf("the GetThrottlerConfiguration command accepts only <throttler name> as optional positional parameter")
}
var throttlerName string
if subFlags.NArg() == 1 {
throttlerName = subFlags.Arg(0)
}
// Connect to the server.
ctx, cancel := context.WithTimeout(ctx, shortTimeout)
defer cancel()
client, err := throttlerclient.New(*server)
if err != nil {
return fmt.Errorf("error creating a throttler client for server '%v': %v", *server, err)
}
defer client.Close()
configurations, err := client.GetConfiguration(ctx, throttlerName)
if err != nil {
return fmt.Errorf("failed to get the throttler configuration from server '%v': %v", *server, err)
}
if len(configurations) == 0 {
wr.Logger().Printf("There are no active throttlers on server '%v'.\n", *server)
return nil
}
table := tablewriter.NewWriter(loggerWriter{wr.Logger()})
table.SetAutoFormatHeaders(false)
// The full protobuf text will span more than one terminal line. Do not wrap
// it to make it easy to copy and paste it.
table.SetAutoWrapText(false)
table.SetHeader([]string{"Name", "Configuration (protobuf text, fields with a zero value are omitted)"})
for name, c := range configurations {
table.Append([]string{name, proto.CompactTextString(c)})
}
table.Render()
wr.Logger().Printf("%d active throttler(s) on server '%v'.\n", len(configurations), *server)
return nil
}
开发者ID:erzel,项目名称:vitess,代码行数:46,代码来源:throttler.go
示例6: String
func (m *UnsupportedApiMessageResponse) String() string { return proto.CompactTextString(m) }
开发者ID:krwhitney,项目名称:gauge,代码行数:1,代码来源:api.pb.go
示例7: String
func (m *UndeleteClusterMetadata) String() string { return proto.CompactTextString(m) }
开发者ID:bradfitz,项目名称:grpc-go16-demo,代码行数:1,代码来源:bigtable_cluster_service_messages.pb.go
示例8: String
func (m *URLFetchResponse_Header) String() string { return proto.CompactTextString(m) }
开发者ID:Celluliodio,项目名称:flannel,代码行数:1,代码来源:urlfetch_service.pb.go
注:本文中的github.com/golang/protobuf/proto.CompactTextString函数示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论