Versions in this module Expand all Collapse all v0 v0.6.3 Nov 12, 2018 v0.6.2 Nov 6, 2018 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