storage_v1

package

Go to main page

Versions in this module

v1

v1.17.0

Feb 24, 2020

v1.16.0

Dec 17, 2019

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

v1.15.1

Nov 7, 2019

v1.15.0

Nov 7, 2019

v1.14.0

Sep 2, 2019

v1.13.1

Jun 28, 2019

v1.13.0

Jun 27, 2019

v1.12.0

May 16, 2019

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL