Versions in this module Expand all Collapse all v0 v0.6.1 Oct 15, 2018 v0.6.0 Sep 25, 2018 v0.5.0 Aug 14, 2018 Changes in this version + var ErrIntOverflowTraceService = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthTraceService = fmt.Errorf("proto: negative length found during unmarshaling") + func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) + type StreamTracesMessage struct + Identifier *StreamTracesMessage_Identifier + Spans []*trace.Span + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamTracesMessage) Descriptor() ([]byte, []int) + func (*StreamTracesMessage) ProtoMessage() + func (dst *StreamTracesMessage) XXX_Merge(src proto.Message) + func (m *StreamTracesMessage) GetIdentifier() *StreamTracesMessage_Identifier + func (m *StreamTracesMessage) GetSpans() []*trace.Span + func (m *StreamTracesMessage) Marshal() (dAtA []byte, err error) + func (m *StreamTracesMessage) MarshalTo(dAtA []byte) (int, error) + func (m *StreamTracesMessage) Reset() + func (m *StreamTracesMessage) Size() (n int) + func (m *StreamTracesMessage) String() string + func (m *StreamTracesMessage) Unmarshal(dAtA []byte) error + func (m *StreamTracesMessage) Validate() error + func (m *StreamTracesMessage) XXX_DiscardUnknown() + func (m *StreamTracesMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamTracesMessage) XXX_Size() int + func (m *StreamTracesMessage) XXX_Unmarshal(b []byte) error + type StreamTracesMessageValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamTracesMessageValidationError) Error() string + type StreamTracesMessage_Identifier struct + Node *core.Node + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamTracesMessage_Identifier) Descriptor() ([]byte, []int) + func (*StreamTracesMessage_Identifier) ProtoMessage() + func (dst *StreamTracesMessage_Identifier) XXX_Merge(src proto.Message) + func (m *StreamTracesMessage_Identifier) GetNode() *core.Node + func (m *StreamTracesMessage_Identifier) Marshal() (dAtA []byte, err error) + func (m *StreamTracesMessage_Identifier) MarshalTo(dAtA []byte) (int, error) + func (m *StreamTracesMessage_Identifier) Reset() + func (m *StreamTracesMessage_Identifier) Size() (n int) + func (m *StreamTracesMessage_Identifier) String() string + func (m *StreamTracesMessage_Identifier) Unmarshal(dAtA []byte) error + func (m *StreamTracesMessage_Identifier) Validate() error + func (m *StreamTracesMessage_Identifier) XXX_DiscardUnknown() + func (m *StreamTracesMessage_Identifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamTracesMessage_Identifier) XXX_Size() int + func (m *StreamTracesMessage_Identifier) XXX_Unmarshal(b []byte) error + type StreamTracesMessage_IdentifierValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamTracesMessage_IdentifierValidationError) Error() string + type StreamTracesResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamTracesResponse) Descriptor() ([]byte, []int) + func (*StreamTracesResponse) ProtoMessage() + func (dst *StreamTracesResponse) XXX_Merge(src proto.Message) + func (m *StreamTracesResponse) Marshal() (dAtA []byte, err error) + func (m *StreamTracesResponse) MarshalTo(dAtA []byte) (int, error) + func (m *StreamTracesResponse) Reset() + func (m *StreamTracesResponse) Size() (n int) + func (m *StreamTracesResponse) String() string + func (m *StreamTracesResponse) Unmarshal(dAtA []byte) error + func (m *StreamTracesResponse) Validate() error + func (m *StreamTracesResponse) XXX_DiscardUnknown() + func (m *StreamTracesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamTracesResponse) XXX_Size() int + func (m *StreamTracesResponse) XXX_Unmarshal(b []byte) error + type StreamTracesResponseValidationError struct + Cause error + Field string + Key bool + Reason string + func (e StreamTracesResponseValidationError) Error() string + type TraceServiceClient interface + StreamTraces func(ctx context.Context, opts ...grpc.CallOption) (TraceService_StreamTracesClient, error) + func NewTraceServiceClient(cc *grpc.ClientConn) TraceServiceClient + type TraceServiceServer interface + StreamTraces func(TraceService_StreamTracesServer) error + type TraceService_StreamTracesClient interface + CloseAndRecv func() (*StreamTracesResponse, error) + Send func(*StreamTracesMessage) error + type TraceService_StreamTracesServer interface + Recv func() (*StreamTracesMessage, error) + SendAndClose func(*StreamTracesResponse) error