storage_v1

package
v1.13.0 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

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 (m *FindTraceIDsRequest) GetQuery() *TraceQueryParameters

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"`
	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) 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 {
	Operations           []string `protobuf:"bytes,1,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) GetOperations 

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

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 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 

type SpanReaderPluginServer interface {
	// spanstore/Reader
	GetTrace(*GetTraceRequest, SpanReaderPlugin_GetTraceServer) error
	GetServices(context.Context, *GetServicesRequest) (*GetServicesResponse, error)
	GetOperations(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error)
	FindTraces(*FindTracesRequest, SpanReaderPlugin_FindTracesServer) error
	FindTraceIDs(context.Context, *FindTraceIDsRequest) (*FindTraceIDsResponse, error)
}

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.