traceflatbuffers

Documentation

Index

• func RegisterTracerServer(s *grpc.Server, srv TracerServer)
• type BatchRequest
  • func (*BatchRequest) Descriptor() ([]byte, []int)
  • func (m *BatchRequest) GetEncodedSpans() []byte
  • func (*BatchRequest) ProtoMessage()
  • func (m *BatchRequest) Reset()
  • func (m *BatchRequest) String() string
  • func (m *BatchRequest) XXX_DiscardUnknown()
  • func (m *BatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *BatchRequest) XXX_Merge(src proto.Message)
  • func (m *BatchRequest) XXX_Size() int
  • func (m *BatchRequest) XXX_Unmarshal(b []byte) error
• type BatchResponse
  • func (*BatchResponse) Descriptor() ([]byte, []int)
  • func (m *BatchResponse) GetMessage() string
  • func (*BatchResponse) ProtoMessage()
  • func (m *BatchResponse) Reset()
  • func (m *BatchResponse) String() string
  • func (m *BatchResponse) XXX_DiscardUnknown()
  • func (m *BatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *BatchResponse) XXX_Merge(src proto.Message)
  • func (m *BatchResponse) XXX_Size() int
  • func (m *BatchResponse) XXX_Unmarshal(b []byte) error
• type TracerClient
  • func NewTracerClient(cc *grpc.ClientConn) TracerClient
• type TracerServer
• type UnimplementedTracerServer
  • func (*UnimplementedTracerServer) SendBatch(ctx context.Context, req *BatchRequest) (*BatchResponse, error)

Functions

func RegisterTracerServer

func RegisterTracerServer(s *grpc.Server, srv TracerServer)

Types

type BatchRequest

type BatchRequest struct {
	EncodedSpans         []byte   `protobuf:"bytes,1,opt,name=encodedSpans,proto3" json:"encodedSpans,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchRequest) Descriptor

func (*BatchRequest) Descriptor() ([]byte, []int)

func (*BatchRequest) GetEncodedSpans

func (m *BatchRequest) GetEncodedSpans() []byte

func (*BatchRequest) ProtoMessage

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) Reset

func (m *BatchRequest) Reset()

func (*BatchRequest) String

func (m *BatchRequest) String() string

func (*BatchRequest) XXX_DiscardUnknown

func (m *BatchRequest) XXX_DiscardUnknown()

func (*BatchRequest) XXX_Marshal

func (m *BatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchRequest) XXX_Merge

func (m *BatchRequest) XXX_Merge(src proto.Message)

func (*BatchRequest) XXX_Size

func (m *BatchRequest) XXX_Size() int

func (*BatchRequest) XXX_Unmarshal

func (m *BatchRequest) XXX_Unmarshal(b []byte) error

type BatchResponse

type BatchResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchResponse) Descriptor

func (*BatchResponse) Descriptor() ([]byte, []int)

func (*BatchResponse) GetMessage

func (m *BatchResponse) GetMessage() string

func (*BatchResponse) ProtoMessage

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) Reset

func (m *BatchResponse) Reset()

func (*BatchResponse) String

func (m *BatchResponse) String() string

func (*BatchResponse) XXX_DiscardUnknown

func (m *BatchResponse) XXX_DiscardUnknown()

func (*BatchResponse) XXX_Marshal

func (m *BatchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BatchResponse) XXX_Merge

func (m *BatchResponse) XXX_Merge(src proto.Message)

func (*BatchResponse) XXX_Size

func (m *BatchResponse) XXX_Size() int

func (*BatchResponse) XXX_Unmarshal

func (m *BatchResponse) XXX_Unmarshal(b []byte) error

type TracerClient

type TracerClient interface {
	// Sends a batch
	SendBatch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
}

TracerClient is the client API for Tracer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTracerClient

func NewTracerClient(cc *grpc.ClientConn) TracerClient

type TracerServer

type TracerServer interface {
	// Sends a batch
	SendBatch(context.Context, *BatchRequest) (*BatchResponse, error)
}

TracerServer is the server API for Tracer service.

type UnimplementedTracerServer

type UnimplementedTracerServer struct {
}

UnimplementedTracerServer can be embedded to have forward compatible implementations.

func (*UnimplementedTracerServer) SendBatch

func (*UnimplementedTracerServer) SendBatch(ctx context.Context, req *BatchRequest) (*BatchResponse, error)