Versions in this module Expand all Collapse all v2 v2.9.4 May 2, 2021 v2.9.3 Dec 24, 2020 Changes in this version + var SpanType_name = map[int32]string + var SpanType_value = map[string]int32 + func RegisterTraceHandler(s server.Server, hdlr TraceHandler, opts ...server.HandlerOption) error + type Node struct + Address string + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) GetAddress() string + func (m *Node) GetId() string + func (m *Node) Reset() + func (m *Node) String() string + func (m *Node) XXX_DiscardUnknown() + func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Node) XXX_Merge(src proto.Message) + func (m *Node) XXX_Size() int + func (m *Node) XXX_Unmarshal(b []byte) error + type ReadRequest struct + Limit int64 + Past bool + Service *Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetLimit() int64 + func (m *ReadRequest) GetPast() bool + func (m *ReadRequest) GetService() *Service + func (m *ReadRequest) Reset() + func (m *ReadRequest) String() string + func (m *ReadRequest) XXX_DiscardUnknown() + func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadRequest) XXX_Merge(src proto.Message) + func (m *ReadRequest) XXX_Size() int + func (m *ReadRequest) XXX_Unmarshal(b []byte) error + type ReadResponse struct + Spans []*Span + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetSpans() []*Span + func (m *ReadResponse) Reset() + func (m *ReadResponse) String() string + func (m *ReadResponse) XXX_DiscardUnknown() + func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadResponse) XXX_Merge(src proto.Message) + func (m *ReadResponse) XXX_Size() int + func (m *ReadResponse) XXX_Unmarshal(b []byte) error + type Service struct + Name string + Node *Node + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (m *Service) GetName() string + func (m *Service) GetNode() *Node + func (m *Service) GetVersion() string + func (m *Service) Reset() + func (m *Service) String() string + func (m *Service) XXX_DiscardUnknown() + func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Service) XXX_Merge(src proto.Message) + func (m *Service) XXX_Size() int + func (m *Service) XXX_Unmarshal(b []byte) error + type Snapshot struct + Service *Service + Spans []*Span + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Snapshot) Descriptor() ([]byte, []int) + func (*Snapshot) ProtoMessage() + func (m *Snapshot) GetService() *Service + func (m *Snapshot) GetSpans() []*Span + func (m *Snapshot) Reset() + func (m *Snapshot) String() string + func (m *Snapshot) XXX_DiscardUnknown() + func (m *Snapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Snapshot) XXX_Merge(src proto.Message) + func (m *Snapshot) XXX_Size() int + func (m *Snapshot) XXX_Unmarshal(b []byte) error + type Span struct + Duration uint64 + Id string + Metadata map[string]string + Name string + Parent string + Started uint64 + Trace string + Type SpanType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Span) Descriptor() ([]byte, []int) + func (*Span) ProtoMessage() + func (m *Span) GetDuration() uint64 + func (m *Span) GetId() string + func (m *Span) GetMetadata() map[string]string + func (m *Span) GetName() string + func (m *Span) GetParent() string + func (m *Span) GetStarted() uint64 + func (m *Span) GetTrace() string + func (m *Span) GetType() SpanType + func (m *Span) Reset() + func (m *Span) String() string + func (m *Span) XXX_DiscardUnknown() + func (m *Span) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Span) XXX_Merge(src proto.Message) + func (m *Span) XXX_Size() int + func (m *Span) XXX_Unmarshal(b []byte) error + type SpanType int32 + const SpanType_INBOUND + const SpanType_OUTBOUND + func (SpanType) EnumDescriptor() ([]byte, []int) + func (x SpanType) String() string + type StreamRequest struct + Namespace string + Service *Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamRequest) Descriptor() ([]byte, []int) + func (*StreamRequest) ProtoMessage() + func (m *StreamRequest) GetNamespace() string + func (m *StreamRequest) GetService() *Service + func (m *StreamRequest) Reset() + func (m *StreamRequest) String() string + func (m *StreamRequest) XXX_DiscardUnknown() + func (m *StreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamRequest) XXX_Merge(src proto.Message) + func (m *StreamRequest) XXX_Size() int + func (m *StreamRequest) XXX_Unmarshal(b []byte) error + type StreamResponse struct + Stats []*Snapshot + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamResponse) Descriptor() ([]byte, []int) + func (*StreamResponse) ProtoMessage() + func (m *StreamResponse) GetStats() []*Snapshot + func (m *StreamResponse) Reset() + func (m *StreamResponse) String() string + func (m *StreamResponse) XXX_DiscardUnknown() + func (m *StreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StreamResponse) XXX_Merge(src proto.Message) + func (m *StreamResponse) XXX_Size() int + func (m *StreamResponse) XXX_Unmarshal(b []byte) error + type TraceHandler interface + Read func(context.Context, *ReadRequest, *ReadResponse) error + Stream func(context.Context, *StreamRequest, Trace_StreamStream) error + Write func(context.Context, *WriteRequest, *WriteResponse) error + type TraceService interface + Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) + Stream func(ctx context.Context, in *StreamRequest, opts ...client.CallOption) (Trace_StreamService, error) + Write func(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*WriteResponse, error) + func NewTraceService(name string, c client.Client) TraceService + type Trace_StreamService interface + Close func() error + Context func() context.Context + Recv func() (*StreamResponse, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Trace_StreamStream interface + Close func() error + Context func() context.Context + RecvMsg func(interface{}) error + Send func(*StreamResponse) error + SendMsg func(interface{}) error + type WriteRequest struct + Service *Service + Stats *Snapshot + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (m *WriteRequest) GetService() *Service + func (m *WriteRequest) GetStats() *Snapshot + func (m *WriteRequest) Reset() + func (m *WriteRequest) String() string + func (m *WriteRequest) XXX_DiscardUnknown() + func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteRequest) XXX_Merge(src proto.Message) + func (m *WriteRequest) XXX_Size() int + func (m *WriteRequest) XXX_Unmarshal(b []byte) error + type WriteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (m *WriteResponse) Reset() + func (m *WriteResponse) String() string + func (m *WriteResponse) XXX_DiscardUnknown() + func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteResponse) XXX_Merge(src proto.Message) + func (m *WriteResponse) XXX_Size() int + func (m *WriteResponse) XXX_Unmarshal(b []byte) error