storage_v1

May 11, 2022

Changes in this version

+ func RegisterStreamingSpanWriterPluginServer(s *grpc.Server, srv StreamingSpanWriterPluginServer)

type CapabilitiesResponse

+ StreamingSpanWriter bool

+ func (m *CapabilitiesResponse) GetStreamingSpanWriter() bool

+ type StreamingSpanWriterPluginClient interface

+ WriteSpanStream func(ctx context.Context, opts ...grpc.CallOption) (StreamingSpanWriterPlugin_WriteSpanStreamClient, error)

+ func NewStreamingSpanWriterPluginClient(cc *grpc.ClientConn) StreamingSpanWriterPluginClient

+ type StreamingSpanWriterPluginServer interface

+ WriteSpanStream func(StreamingSpanWriterPlugin_WriteSpanStreamServer) error

+ type StreamingSpanWriterPlugin_WriteSpanStreamClient interface

+ CloseAndRecv func() (*WriteSpanResponse, error)

+ Send func(*WriteSpanRequest) error

+ type StreamingSpanWriterPlugin_WriteSpanStreamServer interface

+ Recv func() (*WriteSpanRequest, error)

+ SendAndClose func(*WriteSpanResponse) error

+ type UnimplementedStreamingSpanWriterPluginServer struct

+ func (*UnimplementedStreamingSpanWriterPluginServer) WriteSpanStream(srv StreamingSpanWriterPlugin_WriteSpanStreamServer) error

Oct 6, 2021

Changes in this version

+ type CloseWriterRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CloseWriterRequest) Descriptor() ([]byte, []int)

+ func (*CloseWriterRequest) ProtoMessage()

+ func (m *CloseWriterRequest) Marshal() (dAtA []byte, err error)

+ func (m *CloseWriterRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CloseWriterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CloseWriterRequest) Reset()

+ func (m *CloseWriterRequest) Size() (n int)

+ func (m *CloseWriterRequest) String() string

+ func (m *CloseWriterRequest) Unmarshal(dAtA []byte) error

+ func (m *CloseWriterRequest) XXX_DiscardUnknown()

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

+ func (m *CloseWriterRequest) XXX_Merge(src proto.Message)

+ func (m *CloseWriterRequest) XXX_Size() int

+ func (m *CloseWriterRequest) XXX_Unmarshal(b []byte) error

+ type CloseWriterResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CloseWriterResponse) Descriptor() ([]byte, []int)

+ func (*CloseWriterResponse) ProtoMessage()

+ func (m *CloseWriterResponse) Marshal() (dAtA []byte, err error)

+ func (m *CloseWriterResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *CloseWriterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CloseWriterResponse) Reset()

+ func (m *CloseWriterResponse) Size() (n int)

+ func (m *CloseWriterResponse) String() string

+ func (m *CloseWriterResponse) Unmarshal(dAtA []byte) error

+ func (m *CloseWriterResponse) XXX_DiscardUnknown()

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

+ func (m *CloseWriterResponse) XXX_Merge(src proto.Message)

+ func (m *CloseWriterResponse) XXX_Size() int

+ func (m *CloseWriterResponse) XXX_Unmarshal(b []byte) error

type SpanWriterPluginClient

+ Close func(ctx context.Context, in *CloseWriterRequest, opts ...grpc.CallOption) (*CloseWriterResponse, error)

type SpanWriterPluginServer

+ Close func(context.Context, *CloseWriterRequest) (*CloseWriterResponse, error)

type UnimplementedSpanWriterPluginServer

+ func (*UnimplementedSpanWriterPluginServer) Close(ctx context.Context, req *CloseWriterRequest) (*CloseWriterResponse, error)

Jul 7, 2021

Changes in this version

+ var ErrUnexpectedEndOfGroupStorage = fmt.Errorf("proto: unexpected end of group")

type CapabilitiesRequest

+ func (m *CapabilitiesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type CapabilitiesResponse

+ func (m *CapabilitiesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type FindTraceIDsRequest

+ func (m *FindTraceIDsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type FindTraceIDsResponse

+ func (m *FindTraceIDsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type FindTracesRequest

+ func (m *FindTracesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetDependenciesRequest

+ func (m *GetDependenciesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetDependenciesResponse

+ func (m *GetDependenciesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetOperationsRequest

+ func (m *GetOperationsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetOperationsResponse

+ func (m *GetOperationsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetServicesRequest

+ func (m *GetServicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetServicesResponse

+ func (m *GetServicesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

type GetTraceRequest

+ func (m *GetTraceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type Operation

+ func (m *Operation) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SpansResponseChunk

+ func (m *SpansResponseChunk) MarshalToSizedBuffer(dAtA []byte) (int, error)

type TraceQueryParameters

+ func (m *TraceQueryParameters) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ type UnimplementedArchiveSpanReaderPluginServer struct

+ func (*UnimplementedArchiveSpanReaderPluginServer) GetArchiveTrace(req *GetTraceRequest, srv ArchiveSpanReaderPlugin_GetArchiveTraceServer) error

+ type UnimplementedArchiveSpanWriterPluginServer struct

+ func (*UnimplementedArchiveSpanWriterPluginServer) WriteArchiveSpan(ctx context.Context, req *WriteSpanRequest) (*WriteSpanResponse, error)

+ type UnimplementedDependenciesReaderPluginServer struct

+ func (*UnimplementedDependenciesReaderPluginServer) GetDependencies(ctx context.Context, req *GetDependenciesRequest) (*GetDependenciesResponse, error)

+ type UnimplementedPluginCapabilitiesServer struct

+ func (*UnimplementedPluginCapabilitiesServer) Capabilities(ctx context.Context, req *CapabilitiesRequest) (*CapabilitiesResponse, error)

+ type UnimplementedSpanReaderPluginServer struct

+ func (*UnimplementedSpanReaderPluginServer) FindTraceIDs(ctx context.Context, req *FindTraceIDsRequest) (*FindTraceIDsResponse, error)

+ func (*UnimplementedSpanReaderPluginServer) FindTraces(req *FindTracesRequest, srv SpanReaderPlugin_FindTracesServer) error

+ func (*UnimplementedSpanReaderPluginServer) GetOperations(ctx context.Context, req *GetOperationsRequest) (*GetOperationsResponse, error)

+ func (*UnimplementedSpanReaderPluginServer) GetServices(ctx context.Context, req *GetServicesRequest) (*GetServicesResponse, error)

+ func (*UnimplementedSpanReaderPluginServer) GetTrace(req *GetTraceRequest, srv SpanReaderPlugin_GetTraceServer) error

+ type UnimplementedSpanWriterPluginServer struct

+ func (*UnimplementedSpanWriterPluginServer) WriteSpan(ctx context.Context, req *WriteSpanRequest) (*WriteSpanResponse, error)

type WriteSpanRequest

+ func (m *WriteSpanRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

type WriteSpanResponse

+ func (m *WriteSpanResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

Sep 29, 2020

Changes in this version

+ func RegisterArchiveSpanReaderPluginServer(s *grpc.Server, srv ArchiveSpanReaderPluginServer)

+ func RegisterArchiveSpanWriterPluginServer(s *grpc.Server, srv ArchiveSpanWriterPluginServer)

+ func RegisterPluginCapabilitiesServer(s *grpc.Server, srv PluginCapabilitiesServer)

+ type ArchiveSpanReaderPluginClient interface

+ GetArchiveTrace func(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (ArchiveSpanReaderPlugin_GetArchiveTraceClient, error)

+ func NewArchiveSpanReaderPluginClient(cc *grpc.ClientConn) ArchiveSpanReaderPluginClient

+ type ArchiveSpanReaderPluginServer interface

+ GetArchiveTrace func(*GetTraceRequest, ArchiveSpanReaderPlugin_GetArchiveTraceServer) error

+ type ArchiveSpanReaderPlugin_GetArchiveTraceClient interface

+ Recv func() (*SpansResponseChunk, error)

+ type ArchiveSpanReaderPlugin_GetArchiveTraceServer interface

+ Send func(*SpansResponseChunk) error

+ type ArchiveSpanWriterPluginClient interface

+ WriteArchiveSpan func(ctx context.Context, in *WriteSpanRequest, opts ...grpc.CallOption) (*WriteSpanResponse, error)

+ func NewArchiveSpanWriterPluginClient(cc *grpc.ClientConn) ArchiveSpanWriterPluginClient

+ type ArchiveSpanWriterPluginServer interface

+ WriteArchiveSpan func(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error)

+ type CapabilitiesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CapabilitiesRequest) Descriptor() ([]byte, []int)

+ func (*CapabilitiesRequest) ProtoMessage()

+ func (m *CapabilitiesRequest) Marshal() (dAtA []byte, err error)

+ func (m *CapabilitiesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *CapabilitiesRequest) Reset()

+ func (m *CapabilitiesRequest) Size() (n int)

+ func (m *CapabilitiesRequest) String() string

+ func (m *CapabilitiesRequest) Unmarshal(dAtA []byte) error

+ func (m *CapabilitiesRequest) XXX_DiscardUnknown()

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

+ func (m *CapabilitiesRequest) XXX_Merge(src proto.Message)

+ func (m *CapabilitiesRequest) XXX_Size() int

+ func (m *CapabilitiesRequest) XXX_Unmarshal(b []byte) error

+ type CapabilitiesResponse struct

+ ArchiveSpanReader bool

+ ArchiveSpanWriter bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CapabilitiesResponse) Descriptor() ([]byte, []int)

+ func (*CapabilitiesResponse) ProtoMessage()

+ func (m *CapabilitiesResponse) GetArchiveSpanReader() bool

+ func (m *CapabilitiesResponse) GetArchiveSpanWriter() bool

+ func (m *CapabilitiesResponse) Marshal() (dAtA []byte, err error)

+ func (m *CapabilitiesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *CapabilitiesResponse) Reset()

+ func (m *CapabilitiesResponse) Size() (n int)

+ func (m *CapabilitiesResponse) String() string

+ func (m *CapabilitiesResponse) Unmarshal(dAtA []byte) error

+ func (m *CapabilitiesResponse) XXX_DiscardUnknown()

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

+ func (m *CapabilitiesResponse) XXX_Merge(src proto.Message)

+ func (m *CapabilitiesResponse) XXX_Size() int

+ func (m *CapabilitiesResponse) XXX_Unmarshal(b []byte) error

+ type PluginCapabilitiesClient interface

+ Capabilities func(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error)

+ func NewPluginCapabilitiesClient(cc *grpc.ClientConn) PluginCapabilitiesClient

+ type PluginCapabilitiesServer interface

+ Capabilities func(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)

May 14, 2020 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Mar 13, 2020 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Feb 24, 2020 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Dec 17, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Changes in this version

type GetOperationsRequest

+ SpanKind string

+ func (m *GetOperationsRequest) GetSpanKind() string

type GetOperationsResponse

+ OperationNames []string

+ func (m *GetOperationsResponse) GetOperationNames() []string

+ type Operation struct

+ Name string

+ SpanKind string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Operation) Descriptor() ([]byte, []int)

+ func (*Operation) ProtoMessage()

+ func (m *Operation) GetName() string

+ func (m *Operation) GetSpanKind() string

+ func (m *Operation) Marshal() (dAtA []byte, err error)

+ func (m *Operation) MarshalTo(dAtA []byte) (int, error)

+ func (m *Operation) Reset()

+ func (m *Operation) Size() (n int)

+ func (m *Operation) String() string

+ func (m *Operation) Unmarshal(dAtA []byte) error

+ func (m *Operation) XXX_DiscardUnknown()

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

+ func (m *Operation) XXX_Merge(src proto.Message)

+ func (m *Operation) XXX_Size() int

+ func (m *Operation) XXX_Unmarshal(b []byte) error

Nov 7, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Nov 7, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Sep 2, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Jun 28, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Jun 27, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

May 16, 2019 GO-2022-0834

  GO-2022-0834: Information Exposure in jaeger in github.com/jaegertracing/jaeger

Changes in this version

+ var ErrIntOverflowStorage = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthStorage = fmt.Errorf("proto: negative length found during unmarshaling")

+ func RegisterDependenciesReaderPluginServer(s *grpc.Server, srv DependenciesReaderPluginServer)

+ func RegisterSpanReaderPluginServer(s *grpc.Server, srv SpanReaderPluginServer)

+ func RegisterSpanWriterPluginServer(s *grpc.Server, srv SpanWriterPluginServer)

+ type DependenciesReaderPluginClient interface

+ GetDependencies func(ctx context.Context, in *GetDependenciesRequest, opts ...grpc.CallOption) (*GetDependenciesResponse, error)

+ func NewDependenciesReaderPluginClient(cc *grpc.ClientConn) DependenciesReaderPluginClient

+ type DependenciesReaderPluginServer interface

+ GetDependencies func(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error)

+ type FindTraceIDsRequest struct

+ Query *TraceQueryParameters

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindTraceIDsRequest) Descriptor() ([]byte, []int)

+ func (*FindTraceIDsRequest) ProtoMessage()

+ func (m *FindTraceIDsRequest) GetQuery() *TraceQueryParameters

+ func (m *FindTraceIDsRequest) Marshal() (dAtA []byte, err error)

+ func (m *FindTraceIDsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *FindTraceIDsRequest) Reset()

+ func (m *FindTraceIDsRequest) Size() (n int)

+ func (m *FindTraceIDsRequest) String() string

+ func (m *FindTraceIDsRequest) Unmarshal(dAtA []byte) error

+ func (m *FindTraceIDsRequest) XXX_DiscardUnknown()

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

+ func (m *FindTraceIDsRequest) XXX_Merge(src proto.Message)

+ func (m *FindTraceIDsRequest) XXX_Size() int

+ func (m *FindTraceIDsRequest) XXX_Unmarshal(b []byte) error

+ type FindTraceIDsResponse struct

+ TraceIDs []github_com_jaegertracing_jaeger_model.TraceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindTraceIDsResponse) Descriptor() ([]byte, []int)

+ func (*FindTraceIDsResponse) ProtoMessage()

+ func (m *FindTraceIDsResponse) Marshal() (dAtA []byte, err error)

+ func (m *FindTraceIDsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *FindTraceIDsResponse) Reset()

+ func (m *FindTraceIDsResponse) Size() (n int)

+ func (m *FindTraceIDsResponse) String() string

+ func (m *FindTraceIDsResponse) Unmarshal(dAtA []byte) error

+ func (m *FindTraceIDsResponse) XXX_DiscardUnknown()

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

+ func (m *FindTraceIDsResponse) XXX_Merge(src proto.Message)

+ func (m *FindTraceIDsResponse) XXX_Size() int

+ func (m *FindTraceIDsResponse) XXX_Unmarshal(b []byte) error

+ type FindTracesRequest struct

+ Query *TraceQueryParameters

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindTracesRequest) Descriptor() ([]byte, []int)

+ func (*FindTracesRequest) ProtoMessage()

+ func (m *FindTracesRequest) GetQuery() *TraceQueryParameters

+ func (m *FindTracesRequest) Marshal() (dAtA []byte, err error)

+ func (m *FindTracesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *FindTracesRequest) Reset()

+ func (m *FindTracesRequest) Size() (n int)

+ func (m *FindTracesRequest) String() string

+ func (m *FindTracesRequest) Unmarshal(dAtA []byte) error

+ func (m *FindTracesRequest) XXX_DiscardUnknown()

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

+ func (m *FindTracesRequest) XXX_Merge(src proto.Message)

+ func (m *FindTracesRequest) XXX_Size() int

+ func (m *FindTracesRequest) XXX_Unmarshal(b []byte) error

+ type GetDependenciesRequest struct

+ EndTime time.Time

+ StartTime time.Time

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetDependenciesRequest) Descriptor() ([]byte, []int)

+ func (*GetDependenciesRequest) ProtoMessage()

+ func (m *GetDependenciesRequest) GetEndTime() time.Time

+ func (m *GetDependenciesRequest) GetStartTime() time.Time

+ func (m *GetDependenciesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetDependenciesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetDependenciesRequest) Reset()

+ func (m *GetDependenciesRequest) Size() (n int)

+ func (m *GetDependenciesRequest) String() string

+ func (m *GetDependenciesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetDependenciesRequest) XXX_DiscardUnknown()

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

+ func (m *GetDependenciesRequest) XXX_Merge(src proto.Message)

+ func (m *GetDependenciesRequest) XXX_Size() int

+ func (m *GetDependenciesRequest) XXX_Unmarshal(b []byte) error

+ type GetDependenciesResponse struct

+ Dependencies []model.DependencyLink

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetDependenciesResponse) Descriptor() ([]byte, []int)

+ func (*GetDependenciesResponse) ProtoMessage()

+ func (m *GetDependenciesResponse) GetDependencies() []model.DependencyLink

+ func (m *GetDependenciesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetDependenciesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetDependenciesResponse) Reset()

+ func (m *GetDependenciesResponse) Size() (n int)

+ func (m *GetDependenciesResponse) String() string

+ func (m *GetDependenciesResponse) Unmarshal(dAtA []byte) error

+ func (m *GetDependenciesResponse) XXX_DiscardUnknown()

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

+ func (m *GetDependenciesResponse) XXX_Merge(src proto.Message)

+ func (m *GetDependenciesResponse) XXX_Size() int

+ func (m *GetDependenciesResponse) XXX_Unmarshal(b []byte) error

+ type GetOperationsRequest struct

+ Service string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetOperationsRequest) Descriptor() ([]byte, []int)

+ func (*GetOperationsRequest) ProtoMessage()

+ func (m *GetOperationsRequest) GetService() string

+ func (m *GetOperationsRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetOperationsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetOperationsRequest) Reset()

+ func (m *GetOperationsRequest) Size() (n int)

+ func (m *GetOperationsRequest) String() string

+ func (m *GetOperationsRequest) Unmarshal(dAtA []byte) error

+ func (m *GetOperationsRequest) XXX_DiscardUnknown()

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

+ func (m *GetOperationsRequest) XXX_Merge(src proto.Message)

+ func (m *GetOperationsRequest) XXX_Size() int

+ func (m *GetOperationsRequest) XXX_Unmarshal(b []byte) error

+ type GetOperationsResponse struct

+ Operations []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetOperationsResponse) Descriptor() ([]byte, []int)

+ func (*GetOperationsResponse) ProtoMessage()

+ func (m *GetOperationsResponse) GetOperations() []string

+ func (m *GetOperationsResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetOperationsResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetOperationsResponse) Reset()

+ func (m *GetOperationsResponse) Size() (n int)

+ func (m *GetOperationsResponse) String() string

+ func (m *GetOperationsResponse) Unmarshal(dAtA []byte) error

+ func (m *GetOperationsResponse) XXX_DiscardUnknown()

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

+ func (m *GetOperationsResponse) XXX_Merge(src proto.Message)

+ func (m *GetOperationsResponse) XXX_Size() int

+ func (m *GetOperationsResponse) XXX_Unmarshal(b []byte) error

+ type GetServicesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetServicesRequest) Descriptor() ([]byte, []int)

+ func (*GetServicesRequest) ProtoMessage()

+ func (m *GetServicesRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetServicesRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetServicesRequest) Reset()

+ func (m *GetServicesRequest) Size() (n int)

+ func (m *GetServicesRequest) String() string

+ func (m *GetServicesRequest) Unmarshal(dAtA []byte) error

+ func (m *GetServicesRequest) XXX_DiscardUnknown()

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

+ func (m *GetServicesRequest) XXX_Merge(src proto.Message)

+ func (m *GetServicesRequest) XXX_Size() int

+ func (m *GetServicesRequest) XXX_Unmarshal(b []byte) error

+ type GetServicesResponse struct

+ Services []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetServicesResponse) Descriptor() ([]byte, []int)

+ func (*GetServicesResponse) ProtoMessage()

+ func (m *GetServicesResponse) GetServices() []string

+ func (m *GetServicesResponse) Marshal() (dAtA []byte, err error)

+ func (m *GetServicesResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetServicesResponse) Reset()

+ func (m *GetServicesResponse) Size() (n int)

+ func (m *GetServicesResponse) String() string

+ func (m *GetServicesResponse) Unmarshal(dAtA []byte) error

+ func (m *GetServicesResponse) XXX_DiscardUnknown()

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

+ func (m *GetServicesResponse) XXX_Merge(src proto.Message)

+ func (m *GetServicesResponse) XXX_Size() int

+ func (m *GetServicesResponse) XXX_Unmarshal(b []byte) error

+ type GetTraceRequest struct

+ TraceID github_com_jaegertracing_jaeger_model.TraceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTraceRequest) Descriptor() ([]byte, []int)

+ func (*GetTraceRequest) ProtoMessage()

+ func (m *GetTraceRequest) Marshal() (dAtA []byte, err error)

+ func (m *GetTraceRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *GetTraceRequest) Reset()

+ func (m *GetTraceRequest) Size() (n int)

+ func (m *GetTraceRequest) String() string

+ func (m *GetTraceRequest) Unmarshal(dAtA []byte) error

+ func (m *GetTraceRequest) XXX_DiscardUnknown()

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

+ func (m *GetTraceRequest) XXX_Merge(src proto.Message)

+ func (m *GetTraceRequest) XXX_Size() int

+ func (m *GetTraceRequest) XXX_Unmarshal(b []byte) error

+ type SpanReaderPluginClient interface

+ FindTraceIDs func(ctx context.Context, in *FindTraceIDsRequest, opts ...grpc.CallOption) (*FindTraceIDsResponse, error)

+ FindTraces func(ctx context.Context, in *FindTracesRequest, opts ...grpc.CallOption) (SpanReaderPlugin_FindTracesClient, error)

+ GetOperations func(ctx context.Context, in *GetOperationsRequest, opts ...grpc.CallOption) (*GetOperationsResponse, error)

+ GetServices func(ctx context.Context, in *GetServicesRequest, opts ...grpc.CallOption) (*GetServicesResponse, error)

+ GetTrace func(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (SpanReaderPlugin_GetTraceClient, error)

+ func NewSpanReaderPluginClient(cc *grpc.ClientConn) SpanReaderPluginClient

+ type SpanReaderPluginServer interface

+ FindTraceIDs func(context.Context, *FindTraceIDsRequest) (*FindTraceIDsResponse, error)

+ FindTraces func(*FindTracesRequest, SpanReaderPlugin_FindTracesServer) error

+ GetOperations func(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error)

+ GetServices func(context.Context, *GetServicesRequest) (*GetServicesResponse, error)

+ GetTrace func(*GetTraceRequest, SpanReaderPlugin_GetTraceServer) error

+ type SpanReaderPlugin_FindTracesClient interface

+ Recv func() (*SpansResponseChunk, error)

+ type SpanReaderPlugin_FindTracesServer interface

+ Send func(*SpansResponseChunk) error

+ type SpanReaderPlugin_GetTraceClient interface

+ Recv func() (*SpansResponseChunk, error)

+ type SpanReaderPlugin_GetTraceServer interface

+ Send func(*SpansResponseChunk) error

+ type SpanWriterPluginClient interface

+ WriteSpan func(ctx context.Context, in *WriteSpanRequest, opts ...grpc.CallOption) (*WriteSpanResponse, error)

+ func NewSpanWriterPluginClient(cc *grpc.ClientConn) SpanWriterPluginClient

+ type SpanWriterPluginServer interface

+ WriteSpan func(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error)

+ type SpansResponseChunk struct

+ Spans []model.Span

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SpansResponseChunk) Descriptor() ([]byte, []int)

+ func (*SpansResponseChunk) ProtoMessage()

+ func (m *SpansResponseChunk) GetSpans() []model.Span

+ func (m *SpansResponseChunk) Marshal() (dAtA []byte, err error)

+ func (m *SpansResponseChunk) MarshalTo(dAtA []byte) (int, error)

+ func (m *SpansResponseChunk) Reset()

+ func (m *SpansResponseChunk) Size() (n int)

+ func (m *SpansResponseChunk) String() string

+ func (m *SpansResponseChunk) Unmarshal(dAtA []byte) error

+ func (m *SpansResponseChunk) XXX_DiscardUnknown()

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

+ func (m *SpansResponseChunk) XXX_Merge(src proto.Message)

+ func (m *SpansResponseChunk) XXX_Size() int

+ func (m *SpansResponseChunk) XXX_Unmarshal(b []byte) error

+ type TraceQueryParameters struct

+ DurationMax time.Duration

+ DurationMin time.Duration

+ NumTraces int32

+ OperationName string

+ ServiceName string

+ StartTimeMax time.Time

+ StartTimeMin time.Time

+ Tags map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TraceQueryParameters) Descriptor() ([]byte, []int)

+ func (*TraceQueryParameters) ProtoMessage()

+ func (m *TraceQueryParameters) GetDurationMax() time.Duration

+ func (m *TraceQueryParameters) GetDurationMin() time.Duration

+ func (m *TraceQueryParameters) GetNumTraces() int32

+ func (m *TraceQueryParameters) GetOperationName() string

+ func (m *TraceQueryParameters) GetServiceName() string

+ func (m *TraceQueryParameters) GetStartTimeMax() time.Time

+ func (m *TraceQueryParameters) GetStartTimeMin() time.Time

+ func (m *TraceQueryParameters) GetTags() map[string]string

+ func (m *TraceQueryParameters) Marshal() (dAtA []byte, err error)

+ func (m *TraceQueryParameters) MarshalTo(dAtA []byte) (int, error)

+ func (m *TraceQueryParameters) Reset()

+ func (m *TraceQueryParameters) Size() (n int)

+ func (m *TraceQueryParameters) String() string

+ func (m *TraceQueryParameters) Unmarshal(dAtA []byte) error

+ func (m *TraceQueryParameters) XXX_DiscardUnknown()

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

+ func (m *TraceQueryParameters) XXX_Merge(src proto.Message)

+ func (m *TraceQueryParameters) XXX_Size() int

+ func (m *TraceQueryParameters) XXX_Unmarshal(b []byte) error

+ type WriteSpanRequest struct

+ Span *model.Span

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteSpanRequest) Descriptor() ([]byte, []int)

+ func (*WriteSpanRequest) ProtoMessage()

+ func (m *WriteSpanRequest) GetSpan() *model.Span

+ func (m *WriteSpanRequest) Marshal() (dAtA []byte, err error)

+ func (m *WriteSpanRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *WriteSpanRequest) Reset()

+ func (m *WriteSpanRequest) Size() (n int)

+ func (m *WriteSpanRequest) String() string

+ func (m *WriteSpanRequest) Unmarshal(dAtA []byte) error

+ func (m *WriteSpanRequest) XXX_DiscardUnknown()

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

+ func (m *WriteSpanRequest) XXX_Merge(src proto.Message)

+ func (m *WriteSpanRequest) XXX_Size() int

+ func (m *WriteSpanRequest) XXX_Unmarshal(b []byte) error

+ type WriteSpanResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*WriteSpanResponse) Descriptor() ([]byte, []int)

+ func (*WriteSpanResponse) ProtoMessage()

+ func (m *WriteSpanResponse) Marshal() (dAtA []byte, err error)

+ func (m *WriteSpanResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *WriteSpanResponse) Reset()

+ func (m *WriteSpanResponse) Size() (n int)

+ func (m *WriteSpanResponse) String() string

+ func (m *WriteSpanResponse) Unmarshal(dAtA []byte) error

+ func (m *WriteSpanResponse) XXX_DiscardUnknown()

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

+ func (m *WriteSpanResponse) XXX_Merge(src proto.Message)

+ func (m *WriteSpanResponse) XXX_Size() int

+ func (m *WriteSpanResponse) XXX_Unmarshal(b []byte) error