storage_v1

package
v1.18.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 14, 2020 License: Apache-2.0 Imports: 11 Imported by: 13

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthStorage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStorage   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterDependenciesReaderPluginServer

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

func RegisterSpanReaderPluginServer

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

func RegisterSpanWriterPluginServer

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

Types

type DependenciesReaderPluginClient

type DependenciesReaderPluginClient interface {
	// dependencystore/Reader
	GetDependencies(ctx context.Context, in *GetDependenciesRequest, opts ...grpc.CallOption) (*GetDependenciesResponse, error)
}

DependenciesReaderPluginClient is the client API for DependenciesReaderPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDependenciesReaderPluginClient

func NewDependenciesReaderPluginClient(cc *grpc.ClientConn) DependenciesReaderPluginClient

type DependenciesReaderPluginServer

type DependenciesReaderPluginServer interface {
	// dependencystore/Reader
	GetDependencies(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error)
}

DependenciesReaderPluginServer is the server API for DependenciesReaderPlugin service.

type FindTraceIDsRequest

type FindTraceIDsRequest struct {
	Query                *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*FindTraceIDsRequest) Descriptor

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

func (*FindTraceIDsRequest) GetQuery

func (*FindTraceIDsRequest) Marshal

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

func (*FindTraceIDsRequest) MarshalTo

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

func (*FindTraceIDsRequest) ProtoMessage

func (*FindTraceIDsRequest) ProtoMessage()

func (*FindTraceIDsRequest) Reset

func (m *FindTraceIDsRequest) Reset()

func (*FindTraceIDsRequest) Size

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

func (*FindTraceIDsRequest) String

func (m *FindTraceIDsRequest) String() string

func (*FindTraceIDsRequest) Unmarshal

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

func (*FindTraceIDsRequest) XXX_DiscardUnknown

func (m *FindTraceIDsRequest) XXX_DiscardUnknown()

func (*FindTraceIDsRequest) XXX_Marshal

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

func (*FindTraceIDsRequest) XXX_Merge

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

func (*FindTraceIDsRequest) XXX_Size

func (m *FindTraceIDsRequest) XXX_Size() int

func (*FindTraceIDsRequest) XXX_Unmarshal

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

type FindTraceIDsResponse

type FindTraceIDsResponse struct {
	TraceIDs             []github_com_jaegertracing_jaeger_model.TraceID `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                        `json:"-"`
	XXX_unrecognized     []byte                                          `json:"-"`
	XXX_sizecache        int32                                           `json:"-"`
}

func (*FindTraceIDsResponse) Descriptor

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

func (*FindTraceIDsResponse) Marshal

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

func (*FindTraceIDsResponse) MarshalTo

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

func (*FindTraceIDsResponse) ProtoMessage

func (*FindTraceIDsResponse) ProtoMessage()

func (*FindTraceIDsResponse) Reset

func (m *FindTraceIDsResponse) Reset()

func (*FindTraceIDsResponse) Size

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

func (*FindTraceIDsResponse) String

func (m *FindTraceIDsResponse) String() string

func (*FindTraceIDsResponse) Unmarshal

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

func (*FindTraceIDsResponse) XXX_DiscardUnknown

func (m *FindTraceIDsResponse) XXX_DiscardUnknown()

func (*FindTraceIDsResponse) XXX_Marshal

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

func (*FindTraceIDsResponse) XXX_Merge

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

func (*FindTraceIDsResponse) XXX_Size

func (m *FindTraceIDsResponse) XXX_Size() int

func (*FindTraceIDsResponse) XXX_Unmarshal

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

type FindTracesRequest

type FindTracesRequest struct {
	Query                *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*FindTracesRequest) Descriptor

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

func (*FindTracesRequest) GetQuery

func (m *FindTracesRequest) GetQuery() *TraceQueryParameters

func (*FindTracesRequest) Marshal

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

func (*FindTracesRequest) MarshalTo

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

func (*FindTracesRequest) ProtoMessage

func (*FindTracesRequest) ProtoMessage()

func (*FindTracesRequest) Reset

func (m *FindTracesRequest) Reset()

func (*FindTracesRequest) Size

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

func (*FindTracesRequest) String

func (m *FindTracesRequest) String() string

func (*FindTracesRequest) Unmarshal

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

func (*FindTracesRequest) XXX_DiscardUnknown

func (m *FindTracesRequest) XXX_DiscardUnknown()

func (*FindTracesRequest) XXX_Marshal

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

func (*FindTracesRequest) XXX_Merge

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

func (*FindTracesRequest) XXX_Size

func (m *FindTracesRequest) XXX_Size() int

func (*FindTracesRequest) XXX_Unmarshal

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

type GetDependenciesRequest

type GetDependenciesRequest struct {
	StartTime            time.Time `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time"`
	EndTime              time.Time `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3,stdtime" json:"end_time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GetDependenciesRequest) Descriptor

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

func (*GetDependenciesRequest) GetEndTime

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

func (*GetDependenciesRequest) GetStartTime

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

func (*GetDependenciesRequest) Marshal

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

func (*GetDependenciesRequest) MarshalTo

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

func (*GetDependenciesRequest) ProtoMessage

func (*GetDependenciesRequest) ProtoMessage()

func (*GetDependenciesRequest) Reset

func (m *GetDependenciesRequest) Reset()

func (*GetDependenciesRequest) Size

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

func (*GetDependenciesRequest) String

func (m *GetDependenciesRequest) String() string

func (*GetDependenciesRequest) Unmarshal

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

func (*GetDependenciesRequest) XXX_DiscardUnknown

func (m *GetDependenciesRequest) XXX_DiscardUnknown()

func (*GetDependenciesRequest) XXX_Marshal

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

func (*GetDependenciesRequest) XXX_Merge

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

func (*GetDependenciesRequest) XXX_Size

func (m *GetDependenciesRequest) XXX_Size() int

func (*GetDependenciesRequest) XXX_Unmarshal

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

type GetDependenciesResponse

type GetDependenciesResponse struct {
	Dependencies         []model.DependencyLink `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetDependenciesResponse) Descriptor

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

func (*GetDependenciesResponse) GetDependencies

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

func (*GetDependenciesResponse) Marshal

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

func (*GetDependenciesResponse) MarshalTo

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

func (*GetDependenciesResponse) ProtoMessage

func (*GetDependenciesResponse) ProtoMessage()

func (*GetDependenciesResponse) Reset

func (m *GetDependenciesResponse) Reset()

func (*GetDependenciesResponse) Size

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

func (*GetDependenciesResponse) String

func (m *GetDependenciesResponse) String() string

func (*GetDependenciesResponse) Unmarshal

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

func (*GetDependenciesResponse) XXX_DiscardUnknown

func (m *GetDependenciesResponse) XXX_DiscardUnknown()

func (*GetDependenciesResponse) XXX_Marshal

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

func (*GetDependenciesResponse) XXX_Merge

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

func (*GetDependenciesResponse) XXX_Size

func (m *GetDependenciesResponse) XXX_Size() int

func (*GetDependenciesResponse) XXX_Unmarshal

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

type GetOperationsRequest

type GetOperationsRequest struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	SpanKind             string   `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetOperationsRequest) Descriptor

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

func (*GetOperationsRequest) GetService

func (m *GetOperationsRequest) GetService() string

func (*GetOperationsRequest) GetSpanKind added in v1.16.0

func (m *GetOperationsRequest) GetSpanKind() string

func (*GetOperationsRequest) Marshal

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

func (*GetOperationsRequest) MarshalTo

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

func (*GetOperationsRequest) ProtoMessage

func (*GetOperationsRequest) ProtoMessage()

func (*GetOperationsRequest) Reset

func (m *GetOperationsRequest) Reset()

func (*GetOperationsRequest) Size

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

func (*GetOperationsRequest) String

func (m *GetOperationsRequest) String() string

func (*GetOperationsRequest) Unmarshal

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

func (*GetOperationsRequest) XXX_DiscardUnknown

func (m *GetOperationsRequest) XXX_DiscardUnknown()

func (*GetOperationsRequest) XXX_Marshal

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

func (*GetOperationsRequest) XXX_Merge

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

func (*GetOperationsRequest) XXX_Size

func (m *GetOperationsRequest) XXX_Size() int

func (*GetOperationsRequest) XXX_Unmarshal

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

type GetOperationsResponse

type GetOperationsResponse struct {
	OperationNames       []string     `protobuf:"bytes,1,rep,name=operationNames,proto3" json:"operationNames,omitempty"`
	Operations           []*Operation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*GetOperationsResponse) Descriptor

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

func (*GetOperationsResponse) GetOperationNames added in v1.16.0

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

func (*GetOperationsResponse) GetOperations

func (m *GetOperationsResponse) GetOperations() []*Operation

func (*GetOperationsResponse) Marshal

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

func (*GetOperationsResponse) MarshalTo

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

func (*GetOperationsResponse) ProtoMessage

func (*GetOperationsResponse) ProtoMessage()

func (*GetOperationsResponse) Reset

func (m *GetOperationsResponse) Reset()

func (*GetOperationsResponse) Size

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

func (*GetOperationsResponse) String

func (m *GetOperationsResponse) String() string

func (*GetOperationsResponse) Unmarshal

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

func (*GetOperationsResponse) XXX_DiscardUnknown

func (m *GetOperationsResponse) XXX_DiscardUnknown()

func (*GetOperationsResponse) XXX_Marshal

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

func (*GetOperationsResponse) XXX_Merge

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

func (*GetOperationsResponse) XXX_Size

func (m *GetOperationsResponse) XXX_Size() int

func (*GetOperationsResponse) XXX_Unmarshal

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

type GetServicesRequest

type GetServicesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServicesRequest) Descriptor

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

func (*GetServicesRequest) Marshal

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

func (*GetServicesRequest) MarshalTo

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

func (*GetServicesRequest) ProtoMessage

func (*GetServicesRequest) ProtoMessage()

func (*GetServicesRequest) Reset

func (m *GetServicesRequest) Reset()

func (*GetServicesRequest) Size

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

func (*GetServicesRequest) String

func (m *GetServicesRequest) String() string

func (*GetServicesRequest) Unmarshal

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

func (*GetServicesRequest) XXX_DiscardUnknown

func (m *GetServicesRequest) XXX_DiscardUnknown()

func (*GetServicesRequest) XXX_Marshal

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

func (*GetServicesRequest) XXX_Merge

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

func (*GetServicesRequest) XXX_Size

func (m *GetServicesRequest) XXX_Size() int

func (*GetServicesRequest) XXX_Unmarshal

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

type GetServicesResponse

type GetServicesResponse struct {
	Services             []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetServicesResponse) Descriptor

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

func (*GetServicesResponse) GetServices

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

func (*GetServicesResponse) Marshal

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

func (*GetServicesResponse) MarshalTo

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

func (*GetServicesResponse) ProtoMessage

func (*GetServicesResponse) ProtoMessage()

func (*GetServicesResponse) Reset

func (m *GetServicesResponse) Reset()

func (*GetServicesResponse) Size

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

func (*GetServicesResponse) String

func (m *GetServicesResponse) String() string

func (*GetServicesResponse) Unmarshal

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

func (*GetServicesResponse) XXX_DiscardUnknown

func (m *GetServicesResponse) XXX_DiscardUnknown()

func (*GetServicesResponse) XXX_Marshal

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

func (*GetServicesResponse) XXX_Merge

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

func (*GetServicesResponse) XXX_Size

func (m *GetServicesResponse) XXX_Size() int

func (*GetServicesResponse) XXX_Unmarshal

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

type GetTraceRequest

type GetTraceRequest struct {
	TraceID              github_com_jaegertracing_jaeger_model.TraceID `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                      `json:"-"`
	XXX_unrecognized     []byte                                        `json:"-"`
	XXX_sizecache        int32                                         `json:"-"`
}

func (*GetTraceRequest) Descriptor

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

func (*GetTraceRequest) Marshal

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

func (*GetTraceRequest) MarshalTo

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

func (*GetTraceRequest) ProtoMessage

func (*GetTraceRequest) ProtoMessage()

func (*GetTraceRequest) Reset

func (m *GetTraceRequest) Reset()

func (*GetTraceRequest) Size

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

func (*GetTraceRequest) String

func (m *GetTraceRequest) String() string

func (*GetTraceRequest) Unmarshal

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

func (*GetTraceRequest) XXX_DiscardUnknown

func (m *GetTraceRequest) XXX_DiscardUnknown()

func (*GetTraceRequest) XXX_Marshal

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

func (*GetTraceRequest) XXX_Merge

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

func (*GetTraceRequest) XXX_Size

func (m *GetTraceRequest) XXX_Size() int

func (*GetTraceRequest) XXX_Unmarshal

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

type Operation added in v1.16.0

type Operation struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SpanKind             string   `protobuf:"bytes,2,opt,name=span_kind,json=spanKind,proto3" json:"span_kind,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Operation) Descriptor added in v1.16.0

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

func (*Operation) GetName added in v1.16.0

func (m *Operation) GetName() string

func (*Operation) GetSpanKind added in v1.16.0

func (m *Operation) GetSpanKind() string

func (*Operation) Marshal added in v1.16.0

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

func (*Operation) MarshalTo added in v1.16.0

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

func (*Operation) ProtoMessage added in v1.16.0

func (*Operation) ProtoMessage()

func (*Operation) Reset added in v1.16.0

func (m *Operation) Reset()

func (*Operation) Size added in v1.16.0

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

func (*Operation) String added in v1.16.0

func (m *Operation) String() string

func (*Operation) Unmarshal added in v1.16.0

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

func (*Operation) XXX_DiscardUnknown added in v1.16.0

func (m *Operation) XXX_DiscardUnknown()

func (*Operation) XXX_Marshal added in v1.16.0

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

func (*Operation) XXX_Merge added in v1.16.0

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

func (*Operation) XXX_Size added in v1.16.0

func (m *Operation) XXX_Size() int

func (*Operation) XXX_Unmarshal added in v1.16.0

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

type SpanReaderPluginClient

type SpanReaderPluginClient interface {
	// spanstore/Reader
	GetTrace(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (SpanReaderPlugin_GetTraceClient, error)
	GetServices(ctx context.Context, in *GetServicesRequest, opts ...grpc.CallOption) (*GetServicesResponse, error)
	GetOperations(ctx context.Context, in *GetOperationsRequest, opts ...grpc.CallOption) (*GetOperationsResponse, error)
	FindTraces(ctx context.Context, in *FindTracesRequest, opts ...grpc.CallOption) (SpanReaderPlugin_FindTracesClient, error)
	FindTraceIDs(ctx context.Context, in *FindTraceIDsRequest, opts ...grpc.CallOption) (*FindTraceIDsResponse, error)
}

SpanReaderPluginClient is the client API for SpanReaderPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSpanReaderPluginClient

func NewSpanReaderPluginClient(cc *grpc.ClientConn) SpanReaderPluginClient

type SpanReaderPluginServer

SpanReaderPluginServer is the server API for SpanReaderPlugin service.

type SpanReaderPlugin_FindTracesClient

type SpanReaderPlugin_FindTracesClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type SpanReaderPlugin_FindTracesServer

type SpanReaderPlugin_FindTracesServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type SpanReaderPlugin_GetTraceClient

type SpanReaderPlugin_GetTraceClient interface {
	Recv() (*SpansResponseChunk, error)
	grpc.ClientStream
}

type SpanReaderPlugin_GetTraceServer

type SpanReaderPlugin_GetTraceServer interface {
	Send(*SpansResponseChunk) error
	grpc.ServerStream
}

type SpanWriterPluginClient

type SpanWriterPluginClient interface {
	// spanstore/Writer
	WriteSpan(ctx context.Context, in *WriteSpanRequest, opts ...grpc.CallOption) (*WriteSpanResponse, error)
}

SpanWriterPluginClient is the client API for SpanWriterPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSpanWriterPluginClient

func NewSpanWriterPluginClient(cc *grpc.ClientConn) SpanWriterPluginClient

type SpanWriterPluginServer

type SpanWriterPluginServer interface {
	// spanstore/Writer
	WriteSpan(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error)
}

SpanWriterPluginServer is the server API for SpanWriterPlugin service.

type SpansResponseChunk

type SpansResponseChunk struct {
	Spans                []model.Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SpansResponseChunk) Descriptor

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

func (*SpansResponseChunk) GetSpans

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

func (*SpansResponseChunk) Marshal

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

func (*SpansResponseChunk) MarshalTo

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

func (*SpansResponseChunk) ProtoMessage

func (*SpansResponseChunk) ProtoMessage()

func (*SpansResponseChunk) Reset

func (m *SpansResponseChunk) Reset()

func (*SpansResponseChunk) Size

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

func (*SpansResponseChunk) String

func (m *SpansResponseChunk) String() string

func (*SpansResponseChunk) Unmarshal

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

func (*SpansResponseChunk) XXX_DiscardUnknown

func (m *SpansResponseChunk) XXX_DiscardUnknown()

func (*SpansResponseChunk) XXX_Marshal

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

func (*SpansResponseChunk) XXX_Merge

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

func (*SpansResponseChunk) XXX_Size

func (m *SpansResponseChunk) XXX_Size() int

func (*SpansResponseChunk) XXX_Unmarshal

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

type TraceQueryParameters

type TraceQueryParameters struct {
	ServiceName          string            `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	OperationName        string            `protobuf:"bytes,2,opt,name=operation_name,json=operationName,proto3" json:"operation_name,omitempty"`
	Tags                 map[string]string `` /* 149-byte string literal not displayed */
	StartTimeMin         time.Time         `protobuf:"bytes,4,opt,name=start_time_min,json=startTimeMin,proto3,stdtime" json:"start_time_min"`
	StartTimeMax         time.Time         `protobuf:"bytes,5,opt,name=start_time_max,json=startTimeMax,proto3,stdtime" json:"start_time_max"`
	DurationMin          time.Duration     `protobuf:"bytes,6,opt,name=duration_min,json=durationMin,proto3,stdduration" json:"duration_min"`
	DurationMax          time.Duration     `protobuf:"bytes,7,opt,name=duration_max,json=durationMax,proto3,stdduration" json:"duration_max"`
	NumTraces            int32             `protobuf:"varint,8,opt,name=num_traces,json=numTraces,proto3" json:"num_traces,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*TraceQueryParameters) Descriptor

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

func (*TraceQueryParameters) GetDurationMax

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

func (*TraceQueryParameters) GetDurationMin

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

func (*TraceQueryParameters) GetNumTraces

func (m *TraceQueryParameters) GetNumTraces() int32

func (*TraceQueryParameters) GetOperationName

func (m *TraceQueryParameters) GetOperationName() string

func (*TraceQueryParameters) GetServiceName

func (m *TraceQueryParameters) GetServiceName() string

func (*TraceQueryParameters) GetStartTimeMax

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

func (*TraceQueryParameters) GetStartTimeMin

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

func (*TraceQueryParameters) GetTags

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

func (*TraceQueryParameters) Marshal

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

func (*TraceQueryParameters) MarshalTo

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

func (*TraceQueryParameters) ProtoMessage

func (*TraceQueryParameters) ProtoMessage()

func (*TraceQueryParameters) Reset

func (m *TraceQueryParameters) Reset()

func (*TraceQueryParameters) Size

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

func (*TraceQueryParameters) String

func (m *TraceQueryParameters) String() string

func (*TraceQueryParameters) Unmarshal

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

func (*TraceQueryParameters) XXX_DiscardUnknown

func (m *TraceQueryParameters) XXX_DiscardUnknown()

func (*TraceQueryParameters) XXX_Marshal

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

func (*TraceQueryParameters) XXX_Merge

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

func (*TraceQueryParameters) XXX_Size

func (m *TraceQueryParameters) XXX_Size() int

func (*TraceQueryParameters) XXX_Unmarshal

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

type WriteSpanRequest

type WriteSpanRequest struct {
	Span                 *model.Span `protobuf:"bytes,1,opt,name=span,proto3" json:"span,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WriteSpanRequest) Descriptor

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

func (*WriteSpanRequest) GetSpan

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

func (*WriteSpanRequest) Marshal

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

func (*WriteSpanRequest) MarshalTo

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

func (*WriteSpanRequest) ProtoMessage

func (*WriteSpanRequest) ProtoMessage()

func (*WriteSpanRequest) Reset

func (m *WriteSpanRequest) Reset()

func (*WriteSpanRequest) Size

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

func (*WriteSpanRequest) String

func (m *WriteSpanRequest) String() string

func (*WriteSpanRequest) Unmarshal

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

func (*WriteSpanRequest) XXX_DiscardUnknown

func (m *WriteSpanRequest) XXX_DiscardUnknown()

func (*WriteSpanRequest) XXX_Marshal

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

func (*WriteSpanRequest) XXX_Merge

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

func (*WriteSpanRequest) XXX_Size

func (m *WriteSpanRequest) XXX_Size() int

func (*WriteSpanRequest) XXX_Unmarshal

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

type WriteSpanResponse

type WriteSpanResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

empty; extensible in the future

func (*WriteSpanResponse) Descriptor

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

func (*WriteSpanResponse) Marshal

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

func (*WriteSpanResponse) MarshalTo

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

func (*WriteSpanResponse) ProtoMessage

func (*WriteSpanResponse) ProtoMessage()

func (*WriteSpanResponse) Reset

func (m *WriteSpanResponse) Reset()

func (*WriteSpanResponse) Size

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

func (*WriteSpanResponse) String

func (m *WriteSpanResponse) String() string

func (*WriteSpanResponse) Unmarshal

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

func (*WriteSpanResponse) XXX_DiscardUnknown

func (m *WriteSpanResponse) XXX_DiscardUnknown()

func (*WriteSpanResponse) XXX_Marshal

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

func (*WriteSpanResponse) XXX_Merge

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

func (*WriteSpanResponse) XXX_Size

func (m *WriteSpanResponse) XXX_Size() int

func (*WriteSpanResponse) XXX_Unmarshal

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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