cmd/bpa-operator/vendor/github.com/census-instrumentation/opencensus-proto/gen-go/agent/trace/v1/trace_service.pb.go

   1 // Code generated by protoc-gen-go. DO NOT EDIT.
   2 // source: opencensus/proto/agent/trace/v1/trace_service.proto
   3
   4 package v1
   5
   6 import (
   7         context "context"
   8         fmt "fmt"
   9         v1 "github.com/census-instrumentation/opencensus-proto/gen-go/agent/common/v1"
  10         v12 "github.com/census-instrumentation/opencensus-proto/gen-go/resource/v1"
  11         v11 "github.com/census-instrumentation/opencensus-proto/gen-go/trace/v1"
  12         proto "github.com/golang/protobuf/proto"
  13         grpc "google.golang.org/grpc"
  14         math "math"
  15 )
  16
  17 // Reference imports to suppress errors if they are not otherwise used.
  18 var _ = proto.Marshal
  19 var _ = fmt.Errorf
  20 var _ = math.Inf
  21
  22 // This is a compile-time assertion to ensure that this generated file
  23 // is compatible with the proto package it is being compiled against.
  24 // A compilation error at this line likely means your copy of the
  25 // proto package needs to be updated.
  26 const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
  27
  28 type CurrentLibraryConfig struct {
  29         // This is required only in the first message on the stream or if the
  30         // previous sent CurrentLibraryConfig message has a different Node (e.g.
  31         // when the same RPC is used to configure multiple Applications).
  32         Node *v1.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
  33         // Current configuration.
  34         Config               *v11.TraceConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
  35         XXX_NoUnkeyedLiteral struct{}         `json:"-"`
  36         XXX_unrecognized     []byte           `json:"-"`
  37         XXX_sizecache        int32            `json:"-"`
  38 }
  39
  40 func (m *CurrentLibraryConfig) Reset()         { *m = CurrentLibraryConfig{} }
  41 func (m *CurrentLibraryConfig) String() string { return proto.CompactTextString(m) }
  42 func (*CurrentLibraryConfig) ProtoMessage()    {}
  43 func (*CurrentLibraryConfig) Descriptor() ([]byte, []int) {
  44         return fileDescriptor_7027f99caf7ac6a5, []int{0}
  45 }
  46
  47 func (m *CurrentLibraryConfig) XXX_Unmarshal(b []byte) error {
  48         return xxx_messageInfo_CurrentLibraryConfig.Unmarshal(m, b)
  49 }
  50 func (m *CurrentLibraryConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
  51         return xxx_messageInfo_CurrentLibraryConfig.Marshal(b, m, deterministic)
  52 }
  53 func (m *CurrentLibraryConfig) XXX_Merge(src proto.Message) {
  54         xxx_messageInfo_CurrentLibraryConfig.Merge(m, src)
  55 }
  56 func (m *CurrentLibraryConfig) XXX_Size() int {
  57         return xxx_messageInfo_CurrentLibraryConfig.Size(m)
  58 }
  59 func (m *CurrentLibraryConfig) XXX_DiscardUnknown() {
  60         xxx_messageInfo_CurrentLibraryConfig.DiscardUnknown(m)
  61 }
  62
  63 var xxx_messageInfo_CurrentLibraryConfig proto.InternalMessageInfo
  64
  65 func (m *CurrentLibraryConfig) GetNode() *v1.Node {
  66         if m != nil {
  67                 return m.Node
  68         }
  69         return nil
  70 }
  71
  72 func (m *CurrentLibraryConfig) GetConfig() *v11.TraceConfig {
  73         if m != nil {
  74                 return m.Config
  75         }
  76         return nil
  77 }
  78
  79 type UpdatedLibraryConfig struct {
  80         // This field is ignored when the RPC is used to configure only one Application.
  81         // This is required only in the first message on the stream or if the
  82         // previous sent UpdatedLibraryConfig message has a different Node.
  83         Node *v1.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
  84         // Requested updated configuration.
  85         Config               *v11.TraceConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
  86         XXX_NoUnkeyedLiteral struct{}         `json:"-"`
  87         XXX_unrecognized     []byte           `json:"-"`
  88         XXX_sizecache        int32            `json:"-"`
  89 }
  90
  91 func (m *UpdatedLibraryConfig) Reset()         { *m = UpdatedLibraryConfig{} }
  92 func (m *UpdatedLibraryConfig) String() string { return proto.CompactTextString(m) }
  93 func (*UpdatedLibraryConfig) ProtoMessage()    {}
  94 func (*UpdatedLibraryConfig) Descriptor() ([]byte, []int) {
  95         return fileDescriptor_7027f99caf7ac6a5, []int{1}
  96 }
  97
  98 func (m *UpdatedLibraryConfig) XXX_Unmarshal(b []byte) error {
  99         return xxx_messageInfo_UpdatedLibraryConfig.Unmarshal(m, b)
 100 }
 101 func (m *UpdatedLibraryConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 102         return xxx_messageInfo_UpdatedLibraryConfig.Marshal(b, m, deterministic)
 103 }
 104 func (m *UpdatedLibraryConfig) XXX_Merge(src proto.Message) {
 105         xxx_messageInfo_UpdatedLibraryConfig.Merge(m, src)
 106 }
 107 func (m *UpdatedLibraryConfig) XXX_Size() int {
 108         return xxx_messageInfo_UpdatedLibraryConfig.Size(m)
 109 }
 110 func (m *UpdatedLibraryConfig) XXX_DiscardUnknown() {
 111         xxx_messageInfo_UpdatedLibraryConfig.DiscardUnknown(m)
 112 }
 113
 114 var xxx_messageInfo_UpdatedLibraryConfig proto.InternalMessageInfo
 115
 116 func (m *UpdatedLibraryConfig) GetNode() *v1.Node {
 117         if m != nil {
 118                 return m.Node
 119         }
 120         return nil
 121 }
 122
 123 func (m *UpdatedLibraryConfig) GetConfig() *v11.TraceConfig {
 124         if m != nil {
 125                 return m.Config
 126         }
 127         return nil
 128 }
 129
 130 type ExportTraceServiceRequest struct {
 131         // This is required only in the first message on the stream or if the
 132         // previous sent ExportTraceServiceRequest message has a different Node (e.g.
 133         // when the same RPC is used to send Spans from multiple Applications).
 134         Node *v1.Node `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
 135         // A list of Spans that belong to the last received Node.
 136         Spans []*v11.Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
 137         // The resource for the spans in this message that do not have an explicit
 138         // resource set.
 139         // If unset, the most recently set resource in the RPC stream applies. It is
 140         // valid to never be set within a stream, e.g. when no resource info is known.
 141         Resource             *v12.Resource `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
 142         XXX_NoUnkeyedLiteral struct{}      `json:"-"`
 143         XXX_unrecognized     []byte        `json:"-"`
 144         XXX_sizecache        int32         `json:"-"`
 145 }
 146
 147 func (m *ExportTraceServiceRequest) Reset()         { *m = ExportTraceServiceRequest{} }
 148 func (m *ExportTraceServiceRequest) String() string { return proto.CompactTextString(m) }
 149 func (*ExportTraceServiceRequest) ProtoMessage()    {}
 150 func (*ExportTraceServiceRequest) Descriptor() ([]byte, []int) {
 151         return fileDescriptor_7027f99caf7ac6a5, []int{2}
 152 }
 153
 154 func (m *ExportTraceServiceRequest) XXX_Unmarshal(b []byte) error {
 155         return xxx_messageInfo_ExportTraceServiceRequest.Unmarshal(m, b)
 156 }
 157 func (m *ExportTraceServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 158         return xxx_messageInfo_ExportTraceServiceRequest.Marshal(b, m, deterministic)
 159 }
 160 func (m *ExportTraceServiceRequest) XXX_Merge(src proto.Message) {
 161         xxx_messageInfo_ExportTraceServiceRequest.Merge(m, src)
 162 }
 163 func (m *ExportTraceServiceRequest) XXX_Size() int {
 164         return xxx_messageInfo_ExportTraceServiceRequest.Size(m)
 165 }
 166 func (m *ExportTraceServiceRequest) XXX_DiscardUnknown() {
 167         xxx_messageInfo_ExportTraceServiceRequest.DiscardUnknown(m)
 168 }
 169
 170 var xxx_messageInfo_ExportTraceServiceRequest proto.InternalMessageInfo
 171
 172 func (m *ExportTraceServiceRequest) GetNode() *v1.Node {
 173         if m != nil {
 174                 return m.Node
 175         }
 176         return nil
 177 }
 178
 179 func (m *ExportTraceServiceRequest) GetSpans() []*v11.Span {
 180         if m != nil {
 181                 return m.Spans
 182         }
 183         return nil
 184 }
 185
 186 func (m *ExportTraceServiceRequest) GetResource() *v12.Resource {
 187         if m != nil {
 188                 return m.Resource
 189         }
 190         return nil
 191 }
 192
 193 type ExportTraceServiceResponse struct {
 194         XXX_NoUnkeyedLiteral struct{} `json:"-"`
 195         XXX_unrecognized     []byte   `json:"-"`
 196         XXX_sizecache        int32    `json:"-"`
 197 }
 198
 199 func (m *ExportTraceServiceResponse) Reset()         { *m = ExportTraceServiceResponse{} }
 200 func (m *ExportTraceServiceResponse) String() string { return proto.CompactTextString(m) }
 201 func (*ExportTraceServiceResponse) ProtoMessage()    {}
 202 func (*ExportTraceServiceResponse) Descriptor() ([]byte, []int) {
 203         return fileDescriptor_7027f99caf7ac6a5, []int{3}
 204 }
 205
 206 func (m *ExportTraceServiceResponse) XXX_Unmarshal(b []byte) error {
 207         return xxx_messageInfo_ExportTraceServiceResponse.Unmarshal(m, b)
 208 }
 209 func (m *ExportTraceServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 210         return xxx_messageInfo_ExportTraceServiceResponse.Marshal(b, m, deterministic)
 211 }
 212 func (m *ExportTraceServiceResponse) XXX_Merge(src proto.Message) {
 213         xxx_messageInfo_ExportTraceServiceResponse.Merge(m, src)
 214 }
 215 func (m *ExportTraceServiceResponse) XXX_Size() int {
 216         return xxx_messageInfo_ExportTraceServiceResponse.Size(m)
 217 }
 218 func (m *ExportTraceServiceResponse) XXX_DiscardUnknown() {
 219         xxx_messageInfo_ExportTraceServiceResponse.DiscardUnknown(m)
 220 }
 221
 222 var xxx_messageInfo_ExportTraceServiceResponse proto.InternalMessageInfo
 223
 224 func init() {
 225         proto.RegisterType((*CurrentLibraryConfig)(nil), "opencensus.proto.agent.trace.v1.CurrentLibraryConfig")
 226         proto.RegisterType((*UpdatedLibraryConfig)(nil), "opencensus.proto.agent.trace.v1.UpdatedLibraryConfig")
 227         proto.RegisterType((*ExportTraceServiceRequest)(nil), "opencensus.proto.agent.trace.v1.ExportTraceServiceRequest")
 228         proto.RegisterType((*ExportTraceServiceResponse)(nil), "opencensus.proto.agent.trace.v1.ExportTraceServiceResponse")
 229 }
 230
 231 func init() {
 232         proto.RegisterFile("opencensus/proto/agent/trace/v1/trace_service.proto", fileDescriptor_7027f99caf7ac6a5)
 233 }
 234
 235 var fileDescriptor_7027f99caf7ac6a5 = []byte{
 236         // 423 bytes of a gzipped FileDescriptorProto
 237         0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x54, 0xbf, 0x6b, 0xdb, 0x40,
 238         0x14, 0xee, 0xd9, 0xad, 0x28, 0xe7, 0x2e, 0x15, 0x1d, 0x54, 0x51, 0xb0, 0x11, 0xb4, 0x18, 0x5a,
 239         0x9d, 0x2a, 0x1b, 0x2f, 0x2e, 0x74, 0xb0, 0x29, 0x74, 0x28, 0xc5, 0xc8, 0xed, 0x92, 0xc5, 0xc8,
 240         0xd2, 0x8b, 0xa2, 0xc1, 0x77, 0xca, 0xdd, 0x49, 0x24, 0x90, 0x2d, 0x43, 0xf6, 0x0c, 0xf9, 0xc3,
 241         0xf2, 0x17, 0x05, 0xdd, 0xc9, 0x3f, 0x12, 0x5b, 0x11, 0x24, 0x4b, 0xb6, 0x87, 0xde, 0xf7, 0x7d,
 242         0xf7, 0xbd, 0x7b, 0xdf, 0x09, 0x0f, 0x59, 0x06, 0x34, 0x02, 0x2a, 0x72, 0xe1, 0x65, 0x9c, 0x49,
 243         0xe6, 0x85, 0x09, 0x50, 0xe9, 0x49, 0x1e, 0x46, 0xe0, 0x15, 0xbe, 0x2e, 0x16, 0x02, 0x78, 0x91,
 244         0x46, 0x40, 0x14, 0xc4, 0xec, 0x6e, 0x49, 0xfa, 0x0b, 0x51, 0x24, 0xa2, 0xb0, 0xa4, 0xf0, 0x6d,
 245         0xb7, 0x46, 0x35, 0x62, 0xab, 0x15, 0xa3, 0xa5, 0xac, 0xae, 0x34, 0xdb, 0xfe, 0xba, 0x07, 0xe7,
 246         0x20, 0x58, 0xce, 0xb5, 0x83, 0x75, 0x5d, 0x81, 0x3f, 0xef, 0x81, 0xef, 0x7b, 0xad, 0x60, 0xdf,
 247         0x1a, 0x60, 0x8b, 0x88, 0xd1, 0xe3, 0x34, 0xd1, 0x68, 0xe7, 0x1a, 0xe1, 0x0f, 0xd3, 0x9c, 0x73,
 248         0xa0, 0xf2, 0x4f, 0xba, 0xe4, 0x21, 0x3f, 0x9f, 0xaa, 0xb6, 0x39, 0xc6, 0xaf, 0x29, 0x8b, 0xc1,
 249         0x42, 0x3d, 0xd4, 0xef, 0x0c, 0xbe, 0x90, 0x9a, 0xc9, 0xab, 0x71, 0x0a, 0x9f, 0xfc, 0x65, 0x31,
 250         0x04, 0x8a, 0x63, 0xfe, 0xc4, 0x86, 0x3e, 0xc4, 0x6a, 0xd5, 0xb1, 0xd7, 0x37, 0x46, 0xfe, 0x95,
 251         0x85, 0x3e, 0x33, 0xa8, 0x58, 0xca, 0xd4, 0xff, 0x2c, 0x0e, 0x25, 0xc4, 0x2f, 0xc7, 0xd4, 0x2d,
 252         0xc2, 0x1f, 0x7f, 0x9d, 0x65, 0x8c, 0x4b, 0xd5, 0x9d, 0xeb, 0x60, 0x04, 0x70, 0x9a, 0x83, 0x90,
 253         0xcf, 0x72, 0x36, 0xc2, 0x6f, 0x44, 0x16, 0x52, 0x61, 0xb5, 0x7a, 0xed, 0x7e, 0x67, 0xd0, 0x7d,
 254         0xc4, 0xd8, 0x3c, 0x0b, 0x69, 0xa0, 0xd1, 0xe6, 0x04, 0xbf, 0x5d, 0x27, 0xc4, 0x6a, 0xd7, 0x1d,
 255         0xbb, 0xc9, 0x50, 0xe1, 0x93, 0xa0, 0xaa, 0x83, 0x0d, 0xcf, 0xf9, 0x84, 0xed, 0x43, 0x33, 0x89,
 256         0x8c, 0x51, 0x01, 0x83, 0x9b, 0x16, 0x7e, 0xb7, 0xdb, 0x30, 0x2f, 0xb0, 0x51, 0x6d, 0x62, 0x44,
 257         0x1a, 0x9e, 0x02, 0x39, 0x94, 0x2a, 0xbb, 0x99, 0x76, 0x68, 0xef, 0xce, 0xab, 0x3e, 0xfa, 0x8e,
 258         0xcc, 0x2b, 0x84, 0x0d, 0xed, 0xd6, 0x1c, 0x37, 0xea, 0xd4, 0xae, 0xca, 0xfe, 0xf1, 0x24, 0xae,
 259         0xbe, 0x12, 0xed, 0x64, 0x72, 0x89, 0xb0, 0x93, 0xb2, 0x26, 0x9d, 0xc9, 0xfb, 0x5d, 0x89, 0x59,
 260         0x89, 0x98, 0xa1, 0xa3, 0xdf, 0x49, 0x2a, 0x4f, 0xf2, 0x65, 0x19, 0x05, 0x4f, 0x93, 0xdd, 0x94,
 261         0x0a, 0xc9, 0xf3, 0x15, 0x50, 0x19, 0xca, 0x94, 0x51, 0x6f, 0xab, 0xeb, 0xea, 0x17, 0x9c, 0x00,
 262         0x75, 0x93, 0x87, 0x7f, 0xa8, 0xa5, 0xa1, 0x9a, 0xc3, 0xbb, 0x00, 0x00, 0x00, 0xff, 0xff, 0xcf,
 263         0x9c, 0x9b, 0xf7, 0xcb, 0x04, 0x00, 0x00,
 264 }
 265
 266 // Reference imports to suppress errors if they are not otherwise used.
 267 var _ context.Context
 268 var _ grpc.ClientConn
 269
 270 // This is a compile-time assertion to ensure that this generated file
 271 // is compatible with the grpc package it is being compiled against.
 272 const _ = grpc.SupportPackageIsVersion4
 273
 274 // TraceServiceClient is the client API for TraceService service.
 275 //
 276 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
 277 type TraceServiceClient interface {
 278         // After initialization, this RPC must be kept alive for the entire life of
 279         // the application. The agent pushes configs down to applications via a
 280         // stream.
 281         Config(ctx context.Context, opts ...grpc.CallOption) (TraceService_ConfigClient, error)
 282         // For performance reasons, it is recommended to keep this RPC
 283         // alive for the entire life of the application.
 284         Export(ctx context.Context, opts ...grpc.CallOption) (TraceService_ExportClient, error)
 285 }
 286
 287 type traceServiceClient struct {
 288         cc *grpc.ClientConn
 289 }
 290
 291 func NewTraceServiceClient(cc *grpc.ClientConn) TraceServiceClient {
 292         return &traceServiceClient{cc}
 293 }
 294
 295 func (c *traceServiceClient) Config(ctx context.Context, opts ...grpc.CallOption) (TraceService_ConfigClient, error) {
 296         stream, err := c.cc.NewStream(ctx, &_TraceService_serviceDesc.Streams[0], "/opencensus.proto.agent.trace.v1.TraceService/Config", opts...)
 297         if err != nil {
 298                 return nil, err
 299         }
 300         x := &traceServiceConfigClient{stream}
 301         return x, nil
 302 }
 303
 304 type TraceService_ConfigClient interface {
 305         Send(*CurrentLibraryConfig) error
 306         Recv() (*UpdatedLibraryConfig, error)
 307         grpc.ClientStream
 308 }
 309
 310 type traceServiceConfigClient struct {
 311         grpc.ClientStream
 312 }
 313
 314 func (x *traceServiceConfigClient) Send(m *CurrentLibraryConfig) error {
 315         return x.ClientStream.SendMsg(m)
 316 }
 317
 318 func (x *traceServiceConfigClient) Recv() (*UpdatedLibraryConfig, error) {
 319         m := new(UpdatedLibraryConfig)
 320         if err := x.ClientStream.RecvMsg(m); err != nil {
 321                 return nil, err
 322         }
 323         return m, nil
 324 }
 325
 326 func (c *traceServiceClient) Export(ctx context.Context, opts ...grpc.CallOption) (TraceService_ExportClient, error) {
 327         stream, err := c.cc.NewStream(ctx, &_TraceService_serviceDesc.Streams[1], "/opencensus.proto.agent.trace.v1.TraceService/Export", opts...)
 328         if err != nil {
 329                 return nil, err
 330         }
 331         x := &traceServiceExportClient{stream}
 332         return x, nil
 333 }
 334
 335 type TraceService_ExportClient interface {
 336         Send(*ExportTraceServiceRequest) error
 337         Recv() (*ExportTraceServiceResponse, error)
 338         grpc.ClientStream
 339 }
 340
 341 type traceServiceExportClient struct {
 342         grpc.ClientStream
 343 }
 344
 345 func (x *traceServiceExportClient) Send(m *ExportTraceServiceRequest) error {
 346         return x.ClientStream.SendMsg(m)
 347 }
 348
 349 func (x *traceServiceExportClient) Recv() (*ExportTraceServiceResponse, error) {
 350         m := new(ExportTraceServiceResponse)
 351         if err := x.ClientStream.RecvMsg(m); err != nil {
 352                 return nil, err
 353         }
 354         return m, nil
 355 }
 356
 357 // TraceServiceServer is the server API for TraceService service.
 358 type TraceServiceServer interface {
 359         // After initialization, this RPC must be kept alive for the entire life of
 360         // the application. The agent pushes configs down to applications via a
 361         // stream.
 362         Config(TraceService_ConfigServer) error
 363         // For performance reasons, it is recommended to keep this RPC
 364         // alive for the entire life of the application.
 365         Export(TraceService_ExportServer) error
 366 }
 367
 368 func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) {
 369         s.RegisterService(&_TraceService_serviceDesc, srv)
 370 }
 371
 372 func _TraceService_Config_Handler(srv interface{}, stream grpc.ServerStream) error {
 373         return srv.(TraceServiceServer).Config(&traceServiceConfigServer{stream})
 374 }
 375
 376 type TraceService_ConfigServer interface {
 377         Send(*UpdatedLibraryConfig) error
 378         Recv() (*CurrentLibraryConfig, error)
 379         grpc.ServerStream
 380 }
 381
 382 type traceServiceConfigServer struct {
 383         grpc.ServerStream
 384 }
 385
 386 func (x *traceServiceConfigServer) Send(m *UpdatedLibraryConfig) error {
 387         return x.ServerStream.SendMsg(m)
 388 }
 389
 390 func (x *traceServiceConfigServer) Recv() (*CurrentLibraryConfig, error) {
 391         m := new(CurrentLibraryConfig)
 392         if err := x.ServerStream.RecvMsg(m); err != nil {
 393                 return nil, err
 394         }
 395         return m, nil
 396 }
 397
 398 func _TraceService_Export_Handler(srv interface{}, stream grpc.ServerStream) error {
 399         return srv.(TraceServiceServer).Export(&traceServiceExportServer{stream})
 400 }
 401
 402 type TraceService_ExportServer interface {
 403         Send(*ExportTraceServiceResponse) error
 404         Recv() (*ExportTraceServiceRequest, error)
 405         grpc.ServerStream
 406 }
 407
 408 type traceServiceExportServer struct {
 409         grpc.ServerStream
 410 }
 411
 412 func (x *traceServiceExportServer) Send(m *ExportTraceServiceResponse) error {
 413         return x.ServerStream.SendMsg(m)
 414 }
 415
 416 func (x *traceServiceExportServer) Recv() (*ExportTraceServiceRequest, error) {
 417         m := new(ExportTraceServiceRequest)
 418         if err := x.ServerStream.RecvMsg(m); err != nil {
 419                 return nil, err
 420         }
 421         return m, nil
 422 }
 423
 424 var _TraceService_serviceDesc = grpc.ServiceDesc{
 425         ServiceName: "opencensus.proto.agent.trace.v1.TraceService",
 426         HandlerType: (*TraceServiceServer)(nil),
 427         Methods:     []grpc.MethodDesc{},
 428         Streams: []grpc.StreamDesc{
 429                 {
 430                         StreamName:    "Config",
 431                         Handler:       _TraceService_Config_Handler,
 432                         ServerStreams: true,
 433                         ClientStreams: true,
 434                 },
 435                 {
 436                         StreamName:    "Export",
 437                         Handler:       _TraceService_Export_Handler,
 438                         ServerStreams: true,
 439                         ClientStreams: true,
 440                 },
 441         },
 442         Metadata: "opencensus/proto/agent/trace/v1/trace_service.proto",
 443 }