Documentation ¶
Index ¶
- Variables
- func RegisterArchiveSpanReaderPluginServer(s grpc.ServiceRegistrar, srv ArchiveSpanReaderPluginServer)
- func RegisterArchiveSpanWriterPluginServer(s grpc.ServiceRegistrar, srv ArchiveSpanWriterPluginServer)
- func RegisterDependenciesReaderPluginServer(s grpc.ServiceRegistrar, srv DependenciesReaderPluginServer)
- func RegisterPluginCapabilitiesServer(s grpc.ServiceRegistrar, srv PluginCapabilitiesServer)
- func RegisterSpanReaderPluginServer(s grpc.ServiceRegistrar, srv SpanReaderPluginServer)
- func RegisterSpanWriterPluginServer(s grpc.ServiceRegistrar, srv SpanWriterPluginServer)
- func RegisterStreamingSpanWriterPluginServer(s grpc.ServiceRegistrar, srv StreamingSpanWriterPluginServer)
- type ArchiveSpanReaderPluginClient
- type ArchiveSpanReaderPluginServer
- type ArchiveSpanReaderPlugin_GetArchiveTraceClient
- type ArchiveSpanReaderPlugin_GetArchiveTraceServer
- type ArchiveSpanWriterPluginClient
- type ArchiveSpanWriterPluginServer
- type CapabilitiesRequest
- type CapabilitiesResponse
- func (*CapabilitiesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CapabilitiesResponse) GetArchiveSpanReader() bool
- func (x *CapabilitiesResponse) GetArchiveSpanWriter() bool
- func (x *CapabilitiesResponse) GetStreamingSpanWriter() bool
- func (*CapabilitiesResponse) ProtoMessage()
- func (x *CapabilitiesResponse) ProtoReflect() protoreflect.Message
- func (x *CapabilitiesResponse) Reset()
- func (x *CapabilitiesResponse) String() string
- type CloseWriterRequest
- type CloseWriterResponse
- type DependenciesReaderPluginClient
- type DependenciesReaderPluginServer
- type FindTraceIDsRequest
- func (*FindTraceIDsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FindTraceIDsRequest) GetQuery() *TraceQueryParameters
- func (*FindTraceIDsRequest) ProtoMessage()
- func (x *FindTraceIDsRequest) ProtoReflect() protoreflect.Message
- func (x *FindTraceIDsRequest) Reset()
- func (x *FindTraceIDsRequest) String() string
- type FindTraceIDsResponse
- func (*FindTraceIDsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FindTraceIDsResponse) GetTraceIds() [][]byte
- func (*FindTraceIDsResponse) ProtoMessage()
- func (x *FindTraceIDsResponse) ProtoReflect() protoreflect.Message
- func (x *FindTraceIDsResponse) Reset()
- func (x *FindTraceIDsResponse) String() string
- type FindTracesRequest
- func (*FindTracesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FindTracesRequest) GetQuery() *TraceQueryParameters
- func (*FindTracesRequest) ProtoMessage()
- func (x *FindTracesRequest) ProtoReflect() protoreflect.Message
- func (x *FindTracesRequest) Reset()
- func (x *FindTracesRequest) String() string
- type GetDependenciesRequest
- func (*GetDependenciesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDependenciesRequest) GetEndTime() *timestamppb.Timestamp
- func (x *GetDependenciesRequest) GetStartTime() *timestamppb.Timestamp
- func (*GetDependenciesRequest) ProtoMessage()
- func (x *GetDependenciesRequest) ProtoReflect() protoreflect.Message
- func (x *GetDependenciesRequest) Reset()
- func (x *GetDependenciesRequest) String() string
- type GetDependenciesResponse
- func (*GetDependenciesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDependenciesResponse) GetDependencies() []*v2.DependencyLink
- func (*GetDependenciesResponse) ProtoMessage()
- func (x *GetDependenciesResponse) ProtoReflect() protoreflect.Message
- func (x *GetDependenciesResponse) Reset()
- func (x *GetDependenciesResponse) String() string
- type GetOperationsRequest
- func (*GetOperationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetOperationsRequest) GetService() string
- func (x *GetOperationsRequest) GetSpanKind() string
- func (*GetOperationsRequest) ProtoMessage()
- func (x *GetOperationsRequest) ProtoReflect() protoreflect.Message
- func (x *GetOperationsRequest) Reset()
- func (x *GetOperationsRequest) String() string
- type GetOperationsResponse
- func (*GetOperationsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetOperationsResponse) GetOperationNames() []string
- func (x *GetOperationsResponse) GetOperations() []*Operation
- func (*GetOperationsResponse) ProtoMessage()
- func (x *GetOperationsResponse) ProtoReflect() protoreflect.Message
- func (x *GetOperationsResponse) Reset()
- func (x *GetOperationsResponse) String() string
- type GetServicesRequest
- type GetServicesResponse
- func (*GetServicesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetServicesResponse) GetServices() []string
- func (*GetServicesResponse) ProtoMessage()
- func (x *GetServicesResponse) ProtoReflect() protoreflect.Message
- func (x *GetServicesResponse) Reset()
- func (x *GetServicesResponse) String() string
- type GetTraceRequest
- type Operation
- type PluginCapabilitiesClient
- type PluginCapabilitiesServer
- type SpanReaderPluginClient
- type SpanReaderPluginServer
- type SpanReaderPlugin_FindTracesClient
- type SpanReaderPlugin_FindTracesServer
- type SpanReaderPlugin_GetTraceClient
- type SpanReaderPlugin_GetTraceServer
- type SpanWriterPluginClient
- type SpanWriterPluginServer
- type SpansResponseChunk
- func (*SpansResponseChunk) Descriptor() ([]byte, []int)deprecated
- func (x *SpansResponseChunk) GetSpans() []*v2.Span
- func (*SpansResponseChunk) ProtoMessage()
- func (x *SpansResponseChunk) ProtoReflect() protoreflect.Message
- func (x *SpansResponseChunk) Reset()
- func (x *SpansResponseChunk) String() string
- type StreamingSpanWriterPluginClient
- type StreamingSpanWriterPluginServer
- type StreamingSpanWriterPlugin_WriteSpanStreamClient
- type StreamingSpanWriterPlugin_WriteSpanStreamServer
- type TraceQueryParameters
- func (*TraceQueryParameters) Descriptor() ([]byte, []int)deprecated
- func (x *TraceQueryParameters) GetDurationMax() *durationpb.Duration
- func (x *TraceQueryParameters) GetDurationMin() *durationpb.Duration
- func (x *TraceQueryParameters) GetNumTraces() int32
- func (x *TraceQueryParameters) GetOperationName() string
- func (x *TraceQueryParameters) GetServiceName() string
- func (x *TraceQueryParameters) GetStartTimeMax() *timestamppb.Timestamp
- func (x *TraceQueryParameters) GetStartTimeMin() *timestamppb.Timestamp
- func (x *TraceQueryParameters) GetTags() map[string]string
- func (*TraceQueryParameters) ProtoMessage()
- func (x *TraceQueryParameters) ProtoReflect() protoreflect.Message
- func (x *TraceQueryParameters) Reset()
- func (x *TraceQueryParameters) String() string
- type UnimplementedArchiveSpanReaderPluginServer
- type UnimplementedArchiveSpanWriterPluginServer
- type UnimplementedDependenciesReaderPluginServer
- type UnimplementedPluginCapabilitiesServer
- type UnimplementedSpanReaderPluginServer
- func (UnimplementedSpanReaderPluginServer) FindTraceIDs(context.Context, *FindTraceIDsRequest) (*FindTraceIDsResponse, error)
- func (UnimplementedSpanReaderPluginServer) FindTraces(*FindTracesRequest, SpanReaderPlugin_FindTracesServer) error
- func (UnimplementedSpanReaderPluginServer) GetOperations(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error)
- func (UnimplementedSpanReaderPluginServer) GetServices(context.Context, *GetServicesRequest) (*GetServicesResponse, error)
- func (UnimplementedSpanReaderPluginServer) GetTrace(*GetTraceRequest, SpanReaderPlugin_GetTraceServer) error
- type UnimplementedSpanWriterPluginServer
- type UnimplementedStreamingSpanWriterPluginServer
- type UnsafeArchiveSpanReaderPluginServer
- type UnsafeArchiveSpanWriterPluginServer
- type UnsafeDependenciesReaderPluginServer
- type UnsafePluginCapabilitiesServer
- type UnsafeSpanReaderPluginServer
- type UnsafeSpanWriterPluginServer
- type UnsafeStreamingSpanWriterPluginServer
- type WriteSpanRequest
- type WriteSpanResponse
Constants ¶
This section is empty.
Variables ¶
var ArchiveSpanReaderPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jaeger.storage.v1.ArchiveSpanReaderPlugin", HandlerType: (*ArchiveSpanReaderPluginServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "GetArchiveTrace", Handler: _ArchiveSpanReaderPlugin_GetArchiveTrace_Handler, ServerStreams: true, }, }, Metadata: "jaeger/storage/v1/storage.proto", }
ArchiveSpanReaderPlugin_ServiceDesc is the grpc.ServiceDesc for ArchiveSpanReaderPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ArchiveSpanWriterPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jaeger.storage.v1.ArchiveSpanWriterPlugin", HandlerType: (*ArchiveSpanWriterPluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "WriteArchiveSpan", Handler: _ArchiveSpanWriterPlugin_WriteArchiveSpan_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "jaeger/storage/v1/storage.proto", }
ArchiveSpanWriterPlugin_ServiceDesc is the grpc.ServiceDesc for ArchiveSpanWriterPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var DependenciesReaderPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jaeger.storage.v1.DependenciesReaderPlugin", HandlerType: (*DependenciesReaderPluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetDependencies", Handler: _DependenciesReaderPlugin_GetDependencies_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "jaeger/storage/v1/storage.proto", }
DependenciesReaderPlugin_ServiceDesc is the grpc.ServiceDesc for DependenciesReaderPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_jaeger_storage_v1_storage_proto protoreflect.FileDescriptor
var PluginCapabilities_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jaeger.storage.v1.PluginCapabilities", HandlerType: (*PluginCapabilitiesServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Capabilities", Handler: _PluginCapabilities_Capabilities_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "jaeger/storage/v1/storage.proto", }
PluginCapabilities_ServiceDesc is the grpc.ServiceDesc for PluginCapabilities service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SpanReaderPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jaeger.storage.v1.SpanReaderPlugin", HandlerType: (*SpanReaderPluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetServices", Handler: _SpanReaderPlugin_GetServices_Handler, }, { MethodName: "GetOperations", Handler: _SpanReaderPlugin_GetOperations_Handler, }, { MethodName: "FindTraceIDs", Handler: _SpanReaderPlugin_FindTraceIDs_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetTrace", Handler: _SpanReaderPlugin_GetTrace_Handler, ServerStreams: true, }, { StreamName: "FindTraces", Handler: _SpanReaderPlugin_FindTraces_Handler, ServerStreams: true, }, }, Metadata: "jaeger/storage/v1/storage.proto", }
SpanReaderPlugin_ServiceDesc is the grpc.ServiceDesc for SpanReaderPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SpanWriterPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jaeger.storage.v1.SpanWriterPlugin", HandlerType: (*SpanWriterPluginServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "WriteSpan", Handler: _SpanWriterPlugin_WriteSpan_Handler, }, { MethodName: "Close", Handler: _SpanWriterPlugin_Close_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "jaeger/storage/v1/storage.proto", }
SpanWriterPlugin_ServiceDesc is the grpc.ServiceDesc for SpanWriterPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var StreamingSpanWriterPlugin_ServiceDesc = grpc.ServiceDesc{ ServiceName: "jaeger.storage.v1.StreamingSpanWriterPlugin", HandlerType: (*StreamingSpanWriterPluginServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "WriteSpanStream", Handler: _StreamingSpanWriterPlugin_WriteSpanStream_Handler, ClientStreams: true, }, }, Metadata: "jaeger/storage/v1/storage.proto", }
StreamingSpanWriterPlugin_ServiceDesc is the grpc.ServiceDesc for StreamingSpanWriterPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterArchiveSpanReaderPluginServer ¶
func RegisterArchiveSpanReaderPluginServer(s grpc.ServiceRegistrar, srv ArchiveSpanReaderPluginServer)
func RegisterArchiveSpanWriterPluginServer ¶
func RegisterArchiveSpanWriterPluginServer(s grpc.ServiceRegistrar, srv ArchiveSpanWriterPluginServer)
func RegisterDependenciesReaderPluginServer ¶
func RegisterDependenciesReaderPluginServer(s grpc.ServiceRegistrar, srv DependenciesReaderPluginServer)
func RegisterPluginCapabilitiesServer ¶
func RegisterPluginCapabilitiesServer(s grpc.ServiceRegistrar, srv PluginCapabilitiesServer)
func RegisterSpanReaderPluginServer ¶
func RegisterSpanReaderPluginServer(s grpc.ServiceRegistrar, srv SpanReaderPluginServer)
func RegisterSpanWriterPluginServer ¶
func RegisterSpanWriterPluginServer(s grpc.ServiceRegistrar, srv SpanWriterPluginServer)
func RegisterStreamingSpanWriterPluginServer ¶
func RegisterStreamingSpanWriterPluginServer(s grpc.ServiceRegistrar, srv StreamingSpanWriterPluginServer)
Types ¶
type ArchiveSpanReaderPluginClient ¶
type ArchiveSpanReaderPluginClient interface { // spanstore/Reader GetArchiveTrace(ctx context.Context, in *GetTraceRequest, opts ...grpc.CallOption) (ArchiveSpanReaderPlugin_GetArchiveTraceClient, error) }
ArchiveSpanReaderPluginClient is the client API for ArchiveSpanReaderPlugin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewArchiveSpanReaderPluginClient ¶
func NewArchiveSpanReaderPluginClient(cc grpc.ClientConnInterface) ArchiveSpanReaderPluginClient
type ArchiveSpanReaderPluginServer ¶
type ArchiveSpanReaderPluginServer interface { // spanstore/Reader GetArchiveTrace(*GetTraceRequest, ArchiveSpanReaderPlugin_GetArchiveTraceServer) error // contains filtered or unexported methods }
ArchiveSpanReaderPluginServer is the server API for ArchiveSpanReaderPlugin service. All implementations must embed UnimplementedArchiveSpanReaderPluginServer for forward compatibility
type ArchiveSpanReaderPlugin_GetArchiveTraceClient ¶
type ArchiveSpanReaderPlugin_GetArchiveTraceClient interface { Recv() (*SpansResponseChunk, error) grpc.ClientStream }
type ArchiveSpanReaderPlugin_GetArchiveTraceServer ¶
type ArchiveSpanReaderPlugin_GetArchiveTraceServer interface { Send(*SpansResponseChunk) error grpc.ServerStream }
type ArchiveSpanWriterPluginClient ¶
type ArchiveSpanWriterPluginClient interface { // spanstore/Writer WriteArchiveSpan(ctx context.Context, in *WriteSpanRequest, opts ...grpc.CallOption) (*WriteSpanResponse, error) }
ArchiveSpanWriterPluginClient is the client API for ArchiveSpanWriterPlugin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewArchiveSpanWriterPluginClient ¶
func NewArchiveSpanWriterPluginClient(cc grpc.ClientConnInterface) ArchiveSpanWriterPluginClient
type ArchiveSpanWriterPluginServer ¶
type ArchiveSpanWriterPluginServer interface { // spanstore/Writer WriteArchiveSpan(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error) // contains filtered or unexported methods }
ArchiveSpanWriterPluginServer is the server API for ArchiveSpanWriterPlugin service. All implementations must embed UnimplementedArchiveSpanWriterPluginServer for forward compatibility
type CapabilitiesRequest ¶
type CapabilitiesRequest struct {
// contains filtered or unexported fields
}
empty; extensible in the future
func (*CapabilitiesRequest) Descriptor
deprecated
func (*CapabilitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use CapabilitiesRequest.ProtoReflect.Descriptor instead.
func (*CapabilitiesRequest) ProtoMessage ¶
func (*CapabilitiesRequest) ProtoMessage()
func (*CapabilitiesRequest) ProtoReflect ¶
func (x *CapabilitiesRequest) ProtoReflect() protoreflect.Message
func (*CapabilitiesRequest) Reset ¶
func (x *CapabilitiesRequest) Reset()
func (*CapabilitiesRequest) String ¶
func (x *CapabilitiesRequest) String() string
type CapabilitiesResponse ¶
type CapabilitiesResponse struct { ArchiveSpanReader bool `protobuf:"varint,1,opt,name=archiveSpanReader,proto3" json:"archiveSpanReader,omitempty"` ArchiveSpanWriter bool `protobuf:"varint,2,opt,name=archiveSpanWriter,proto3" json:"archiveSpanWriter,omitempty"` StreamingSpanWriter bool `protobuf:"varint,3,opt,name=streamingSpanWriter,proto3" json:"streamingSpanWriter,omitempty"` // contains filtered or unexported fields }
func (*CapabilitiesResponse) Descriptor
deprecated
func (*CapabilitiesResponse) Descriptor() ([]byte, []int)
Deprecated: Use CapabilitiesResponse.ProtoReflect.Descriptor instead.
func (*CapabilitiesResponse) GetArchiveSpanReader ¶
func (x *CapabilitiesResponse) GetArchiveSpanReader() bool
func (*CapabilitiesResponse) GetArchiveSpanWriter ¶
func (x *CapabilitiesResponse) GetArchiveSpanWriter() bool
func (*CapabilitiesResponse) GetStreamingSpanWriter ¶
func (x *CapabilitiesResponse) GetStreamingSpanWriter() bool
func (*CapabilitiesResponse) ProtoMessage ¶
func (*CapabilitiesResponse) ProtoMessage()
func (*CapabilitiesResponse) ProtoReflect ¶
func (x *CapabilitiesResponse) ProtoReflect() protoreflect.Message
func (*CapabilitiesResponse) Reset ¶
func (x *CapabilitiesResponse) Reset()
func (*CapabilitiesResponse) String ¶
func (x *CapabilitiesResponse) String() string
type CloseWriterRequest ¶
type CloseWriterRequest struct {
// contains filtered or unexported fields
}
empty; extensible in the future
func (*CloseWriterRequest) Descriptor
deprecated
func (*CloseWriterRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseWriterRequest.ProtoReflect.Descriptor instead.
func (*CloseWriterRequest) ProtoMessage ¶
func (*CloseWriterRequest) ProtoMessage()
func (*CloseWriterRequest) ProtoReflect ¶
func (x *CloseWriterRequest) ProtoReflect() protoreflect.Message
func (*CloseWriterRequest) Reset ¶
func (x *CloseWriterRequest) Reset()
func (*CloseWriterRequest) String ¶
func (x *CloseWriterRequest) String() string
type CloseWriterResponse ¶
type CloseWriterResponse struct {
// contains filtered or unexported fields
}
empty; extensible in the future
func (*CloseWriterResponse) Descriptor
deprecated
func (*CloseWriterResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseWriterResponse.ProtoReflect.Descriptor instead.
func (*CloseWriterResponse) ProtoMessage ¶
func (*CloseWriterResponse) ProtoMessage()
func (*CloseWriterResponse) ProtoReflect ¶
func (x *CloseWriterResponse) ProtoReflect() protoreflect.Message
func (*CloseWriterResponse) Reset ¶
func (x *CloseWriterResponse) Reset()
func (*CloseWriterResponse) String ¶
func (x *CloseWriterResponse) String() string
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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewDependenciesReaderPluginClient ¶
func NewDependenciesReaderPluginClient(cc grpc.ClientConnInterface) DependenciesReaderPluginClient
type DependenciesReaderPluginServer ¶
type DependenciesReaderPluginServer interface { // dependencystore/Reader GetDependencies(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error) // contains filtered or unexported methods }
DependenciesReaderPluginServer is the server API for DependenciesReaderPlugin service. All implementations must embed UnimplementedDependenciesReaderPluginServer for forward compatibility
type FindTraceIDsRequest ¶
type FindTraceIDsRequest struct { Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*FindTraceIDsRequest) Descriptor
deprecated
func (*FindTraceIDsRequest) Descriptor() ([]byte, []int)
Deprecated: Use FindTraceIDsRequest.ProtoReflect.Descriptor instead.
func (*FindTraceIDsRequest) GetQuery ¶
func (x *FindTraceIDsRequest) GetQuery() *TraceQueryParameters
func (*FindTraceIDsRequest) ProtoMessage ¶
func (*FindTraceIDsRequest) ProtoMessage()
func (*FindTraceIDsRequest) ProtoReflect ¶
func (x *FindTraceIDsRequest) ProtoReflect() protoreflect.Message
func (*FindTraceIDsRequest) Reset ¶
func (x *FindTraceIDsRequest) Reset()
func (*FindTraceIDsRequest) String ¶
func (x *FindTraceIDsRequest) String() string
type FindTraceIDsResponse ¶
type FindTraceIDsResponse struct { TraceIds [][]byte `protobuf:"bytes,1,rep,name=trace_ids,json=traceIds,proto3" json:"trace_ids,omitempty"` // contains filtered or unexported fields }
func (*FindTraceIDsResponse) Descriptor
deprecated
func (*FindTraceIDsResponse) Descriptor() ([]byte, []int)
Deprecated: Use FindTraceIDsResponse.ProtoReflect.Descriptor instead.
func (*FindTraceIDsResponse) GetTraceIds ¶
func (x *FindTraceIDsResponse) GetTraceIds() [][]byte
func (*FindTraceIDsResponse) ProtoMessage ¶
func (*FindTraceIDsResponse) ProtoMessage()
func (*FindTraceIDsResponse) ProtoReflect ¶
func (x *FindTraceIDsResponse) ProtoReflect() protoreflect.Message
func (*FindTraceIDsResponse) Reset ¶
func (x *FindTraceIDsResponse) Reset()
func (*FindTraceIDsResponse) String ¶
func (x *FindTraceIDsResponse) String() string
type FindTracesRequest ¶
type FindTracesRequest struct { Query *TraceQueryParameters `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*FindTracesRequest) Descriptor
deprecated
func (*FindTracesRequest) Descriptor() ([]byte, []int)
Deprecated: Use FindTracesRequest.ProtoReflect.Descriptor instead.
func (*FindTracesRequest) GetQuery ¶
func (x *FindTracesRequest) GetQuery() *TraceQueryParameters
func (*FindTracesRequest) ProtoMessage ¶
func (*FindTracesRequest) ProtoMessage()
func (*FindTracesRequest) ProtoReflect ¶
func (x *FindTracesRequest) ProtoReflect() protoreflect.Message
func (*FindTracesRequest) Reset ¶
func (x *FindTracesRequest) Reset()
func (*FindTracesRequest) String ¶
func (x *FindTracesRequest) String() string
type GetDependenciesRequest ¶
type GetDependenciesRequest struct { StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` // contains filtered or unexported fields }
func (*GetDependenciesRequest) Descriptor
deprecated
func (*GetDependenciesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDependenciesRequest.ProtoReflect.Descriptor instead.
func (*GetDependenciesRequest) GetEndTime ¶
func (x *GetDependenciesRequest) GetEndTime() *timestamppb.Timestamp
func (*GetDependenciesRequest) GetStartTime ¶
func (x *GetDependenciesRequest) GetStartTime() *timestamppb.Timestamp
func (*GetDependenciesRequest) ProtoMessage ¶
func (*GetDependenciesRequest) ProtoMessage()
func (*GetDependenciesRequest) ProtoReflect ¶
func (x *GetDependenciesRequest) ProtoReflect() protoreflect.Message
func (*GetDependenciesRequest) Reset ¶
func (x *GetDependenciesRequest) Reset()
func (*GetDependenciesRequest) String ¶
func (x *GetDependenciesRequest) String() string
type GetDependenciesResponse ¶
type GetDependenciesResponse struct { Dependencies []*v2.DependencyLink `protobuf:"bytes,1,rep,name=dependencies,proto3" json:"dependencies,omitempty"` // contains filtered or unexported fields }
func (*GetDependenciesResponse) Descriptor
deprecated
func (*GetDependenciesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDependenciesResponse.ProtoReflect.Descriptor instead.
func (*GetDependenciesResponse) GetDependencies ¶
func (x *GetDependenciesResponse) GetDependencies() []*v2.DependencyLink
func (*GetDependenciesResponse) ProtoMessage ¶
func (*GetDependenciesResponse) ProtoMessage()
func (*GetDependenciesResponse) ProtoReflect ¶
func (x *GetDependenciesResponse) ProtoReflect() protoreflect.Message
func (*GetDependenciesResponse) Reset ¶
func (x *GetDependenciesResponse) Reset()
func (*GetDependenciesResponse) String ¶
func (x *GetDependenciesResponse) String() string
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"` // contains filtered or unexported fields }
func (*GetOperationsRequest) Descriptor
deprecated
func (*GetOperationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetOperationsRequest.ProtoReflect.Descriptor instead.
func (*GetOperationsRequest) GetService ¶
func (x *GetOperationsRequest) GetService() string
func (*GetOperationsRequest) GetSpanKind ¶
func (x *GetOperationsRequest) GetSpanKind() string
func (*GetOperationsRequest) ProtoMessage ¶
func (*GetOperationsRequest) ProtoMessage()
func (*GetOperationsRequest) ProtoReflect ¶
func (x *GetOperationsRequest) ProtoReflect() protoreflect.Message
func (*GetOperationsRequest) Reset ¶
func (x *GetOperationsRequest) Reset()
func (*GetOperationsRequest) String ¶
func (x *GetOperationsRequest) String() string
type GetOperationsResponse ¶
type GetOperationsResponse struct { OperationNames []string `protobuf:"bytes,1,rep,name=operationNames,proto3" json:"operationNames,omitempty"` // deprecated Operations []*Operation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"` // contains filtered or unexported fields }
func (*GetOperationsResponse) Descriptor
deprecated
func (*GetOperationsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetOperationsResponse.ProtoReflect.Descriptor instead.
func (*GetOperationsResponse) GetOperationNames ¶
func (x *GetOperationsResponse) GetOperationNames() []string
func (*GetOperationsResponse) GetOperations ¶
func (x *GetOperationsResponse) GetOperations() []*Operation
func (*GetOperationsResponse) ProtoMessage ¶
func (*GetOperationsResponse) ProtoMessage()
func (*GetOperationsResponse) ProtoReflect ¶
func (x *GetOperationsResponse) ProtoReflect() protoreflect.Message
func (*GetOperationsResponse) Reset ¶
func (x *GetOperationsResponse) Reset()
func (*GetOperationsResponse) String ¶
func (x *GetOperationsResponse) String() string
type GetServicesRequest ¶
type GetServicesRequest struct {
// contains filtered or unexported fields
}
func (*GetServicesRequest) Descriptor
deprecated
func (*GetServicesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetServicesRequest.ProtoReflect.Descriptor instead.
func (*GetServicesRequest) ProtoMessage ¶
func (*GetServicesRequest) ProtoMessage()
func (*GetServicesRequest) ProtoReflect ¶
func (x *GetServicesRequest) ProtoReflect() protoreflect.Message
func (*GetServicesRequest) Reset ¶
func (x *GetServicesRequest) Reset()
func (*GetServicesRequest) String ¶
func (x *GetServicesRequest) String() string
type GetServicesResponse ¶
type GetServicesResponse struct { Services []string `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*GetServicesResponse) Descriptor
deprecated
func (*GetServicesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetServicesResponse.ProtoReflect.Descriptor instead.
func (*GetServicesResponse) GetServices ¶
func (x *GetServicesResponse) GetServices() []string
func (*GetServicesResponse) ProtoMessage ¶
func (*GetServicesResponse) ProtoMessage()
func (*GetServicesResponse) ProtoReflect ¶
func (x *GetServicesResponse) ProtoReflect() protoreflect.Message
func (*GetServicesResponse) Reset ¶
func (x *GetServicesResponse) Reset()
func (*GetServicesResponse) String ¶
func (x *GetServicesResponse) String() string
type GetTraceRequest ¶
type GetTraceRequest struct { TraceId []byte `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty"` // contains filtered or unexported fields }
func (*GetTraceRequest) Descriptor
deprecated
func (*GetTraceRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTraceRequest.ProtoReflect.Descriptor instead.
func (*GetTraceRequest) GetTraceId ¶
func (x *GetTraceRequest) GetTraceId() []byte
func (*GetTraceRequest) ProtoMessage ¶
func (*GetTraceRequest) ProtoMessage()
func (*GetTraceRequest) ProtoReflect ¶
func (x *GetTraceRequest) ProtoReflect() protoreflect.Message
func (*GetTraceRequest) Reset ¶
func (x *GetTraceRequest) Reset()
func (*GetTraceRequest) String ¶
func (x *GetTraceRequest) String() string
type Operation ¶
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"` // contains filtered or unexported fields }
func (*Operation) Descriptor
deprecated
func (*Operation) GetSpanKind ¶
func (*Operation) ProtoMessage ¶
func (*Operation) ProtoMessage()
func (*Operation) ProtoReflect ¶
func (x *Operation) ProtoReflect() protoreflect.Message
type PluginCapabilitiesClient ¶
type PluginCapabilitiesClient interface {
Capabilities(ctx context.Context, in *CapabilitiesRequest, opts ...grpc.CallOption) (*CapabilitiesResponse, error)
}
PluginCapabilitiesClient is the client API for PluginCapabilities service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPluginCapabilitiesClient ¶
func NewPluginCapabilitiesClient(cc grpc.ClientConnInterface) PluginCapabilitiesClient
type PluginCapabilitiesServer ¶
type PluginCapabilitiesServer interface { Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error) // contains filtered or unexported methods }
PluginCapabilitiesServer is the server API for PluginCapabilities service. All implementations must embed UnimplementedPluginCapabilitiesServer for forward compatibility
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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSpanReaderPluginClient ¶
func NewSpanReaderPluginClient(cc grpc.ClientConnInterface) 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) // contains filtered or unexported methods }
SpanReaderPluginServer is the server API for SpanReaderPlugin service. All implementations must embed UnimplementedSpanReaderPluginServer for forward compatibility
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) Close(ctx context.Context, in *CloseWriterRequest, opts ...grpc.CallOption) (*CloseWriterResponse, error) }
SpanWriterPluginClient is the client API for SpanWriterPlugin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSpanWriterPluginClient ¶
func NewSpanWriterPluginClient(cc grpc.ClientConnInterface) SpanWriterPluginClient
type SpanWriterPluginServer ¶
type SpanWriterPluginServer interface { // spanstore/Writer WriteSpan(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error) Close(context.Context, *CloseWriterRequest) (*CloseWriterResponse, error) // contains filtered or unexported methods }
SpanWriterPluginServer is the server API for SpanWriterPlugin service. All implementations must embed UnimplementedSpanWriterPluginServer for forward compatibility
type SpansResponseChunk ¶
type SpansResponseChunk struct { Spans []*v2.Span `protobuf:"bytes,1,rep,name=spans,proto3" json:"spans,omitempty"` // contains filtered or unexported fields }
func (*SpansResponseChunk) Descriptor
deprecated
func (*SpansResponseChunk) Descriptor() ([]byte, []int)
Deprecated: Use SpansResponseChunk.ProtoReflect.Descriptor instead.
func (*SpansResponseChunk) GetSpans ¶
func (x *SpansResponseChunk) GetSpans() []*v2.Span
func (*SpansResponseChunk) ProtoMessage ¶
func (*SpansResponseChunk) ProtoMessage()
func (*SpansResponseChunk) ProtoReflect ¶
func (x *SpansResponseChunk) ProtoReflect() protoreflect.Message
func (*SpansResponseChunk) Reset ¶
func (x *SpansResponseChunk) Reset()
func (*SpansResponseChunk) String ¶
func (x *SpansResponseChunk) String() string
type StreamingSpanWriterPluginClient ¶
type StreamingSpanWriterPluginClient interface {
WriteSpanStream(ctx context.Context, opts ...grpc.CallOption) (StreamingSpanWriterPlugin_WriteSpanStreamClient, error)
}
StreamingSpanWriterPluginClient is the client API for StreamingSpanWriterPlugin service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewStreamingSpanWriterPluginClient ¶
func NewStreamingSpanWriterPluginClient(cc grpc.ClientConnInterface) StreamingSpanWriterPluginClient
type StreamingSpanWriterPluginServer ¶
type StreamingSpanWriterPluginServer interface { WriteSpanStream(StreamingSpanWriterPlugin_WriteSpanStreamServer) error // contains filtered or unexported methods }
StreamingSpanWriterPluginServer is the server API for StreamingSpanWriterPlugin service. All implementations must embed UnimplementedStreamingSpanWriterPluginServer for forward compatibility
type StreamingSpanWriterPlugin_WriteSpanStreamClient ¶
type StreamingSpanWriterPlugin_WriteSpanStreamClient interface { Send(*WriteSpanRequest) error CloseAndRecv() (*WriteSpanResponse, error) grpc.ClientStream }
type StreamingSpanWriterPlugin_WriteSpanStreamServer ¶
type StreamingSpanWriterPlugin_WriteSpanStreamServer interface { SendAndClose(*WriteSpanResponse) error Recv() (*WriteSpanRequest, error) grpc.ServerStream }
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 *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time_min,json=startTimeMin,proto3" json:"start_time_min,omitempty"` StartTimeMax *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start_time_max,json=startTimeMax,proto3" json:"start_time_max,omitempty"` DurationMin *durationpb.Duration `protobuf:"bytes,6,opt,name=duration_min,json=durationMin,proto3" json:"duration_min,omitempty"` DurationMax *durationpb.Duration `protobuf:"bytes,7,opt,name=duration_max,json=durationMax,proto3" json:"duration_max,omitempty"` NumTraces int32 `protobuf:"varint,8,opt,name=num_traces,json=numTraces,proto3" json:"num_traces,omitempty"` // contains filtered or unexported fields }
func (*TraceQueryParameters) Descriptor
deprecated
func (*TraceQueryParameters) Descriptor() ([]byte, []int)
Deprecated: Use TraceQueryParameters.ProtoReflect.Descriptor instead.
func (*TraceQueryParameters) GetDurationMax ¶
func (x *TraceQueryParameters) GetDurationMax() *durationpb.Duration
func (*TraceQueryParameters) GetDurationMin ¶
func (x *TraceQueryParameters) GetDurationMin() *durationpb.Duration
func (*TraceQueryParameters) GetNumTraces ¶
func (x *TraceQueryParameters) GetNumTraces() int32
func (*TraceQueryParameters) GetOperationName ¶
func (x *TraceQueryParameters) GetOperationName() string
func (*TraceQueryParameters) GetServiceName ¶
func (x *TraceQueryParameters) GetServiceName() string
func (*TraceQueryParameters) GetStartTimeMax ¶
func (x *TraceQueryParameters) GetStartTimeMax() *timestamppb.Timestamp
func (*TraceQueryParameters) GetStartTimeMin ¶
func (x *TraceQueryParameters) GetStartTimeMin() *timestamppb.Timestamp
func (*TraceQueryParameters) GetTags ¶
func (x *TraceQueryParameters) GetTags() map[string]string
func (*TraceQueryParameters) ProtoMessage ¶
func (*TraceQueryParameters) ProtoMessage()
func (*TraceQueryParameters) ProtoReflect ¶
func (x *TraceQueryParameters) ProtoReflect() protoreflect.Message
func (*TraceQueryParameters) Reset ¶
func (x *TraceQueryParameters) Reset()
func (*TraceQueryParameters) String ¶
func (x *TraceQueryParameters) String() string
type UnimplementedArchiveSpanReaderPluginServer ¶
type UnimplementedArchiveSpanReaderPluginServer struct { }
UnimplementedArchiveSpanReaderPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedArchiveSpanReaderPluginServer) GetArchiveTrace ¶
func (UnimplementedArchiveSpanReaderPluginServer) GetArchiveTrace(*GetTraceRequest, ArchiveSpanReaderPlugin_GetArchiveTraceServer) error
type UnimplementedArchiveSpanWriterPluginServer ¶
type UnimplementedArchiveSpanWriterPluginServer struct { }
UnimplementedArchiveSpanWriterPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedArchiveSpanWriterPluginServer) WriteArchiveSpan ¶
func (UnimplementedArchiveSpanWriterPluginServer) WriteArchiveSpan(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error)
type UnimplementedDependenciesReaderPluginServer ¶
type UnimplementedDependenciesReaderPluginServer struct { }
UnimplementedDependenciesReaderPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedDependenciesReaderPluginServer) GetDependencies ¶
func (UnimplementedDependenciesReaderPluginServer) GetDependencies(context.Context, *GetDependenciesRequest) (*GetDependenciesResponse, error)
type UnimplementedPluginCapabilitiesServer ¶
type UnimplementedPluginCapabilitiesServer struct { }
UnimplementedPluginCapabilitiesServer must be embedded to have forward compatible implementations.
func (UnimplementedPluginCapabilitiesServer) Capabilities ¶
func (UnimplementedPluginCapabilitiesServer) Capabilities(context.Context, *CapabilitiesRequest) (*CapabilitiesResponse, error)
type UnimplementedSpanReaderPluginServer ¶
type UnimplementedSpanReaderPluginServer struct { }
UnimplementedSpanReaderPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedSpanReaderPluginServer) FindTraceIDs ¶
func (UnimplementedSpanReaderPluginServer) FindTraceIDs(context.Context, *FindTraceIDsRequest) (*FindTraceIDsResponse, error)
func (UnimplementedSpanReaderPluginServer) FindTraces ¶
func (UnimplementedSpanReaderPluginServer) FindTraces(*FindTracesRequest, SpanReaderPlugin_FindTracesServer) error
func (UnimplementedSpanReaderPluginServer) GetOperations ¶
func (UnimplementedSpanReaderPluginServer) GetOperations(context.Context, *GetOperationsRequest) (*GetOperationsResponse, error)
func (UnimplementedSpanReaderPluginServer) GetServices ¶
func (UnimplementedSpanReaderPluginServer) GetServices(context.Context, *GetServicesRequest) (*GetServicesResponse, error)
func (UnimplementedSpanReaderPluginServer) GetTrace ¶
func (UnimplementedSpanReaderPluginServer) GetTrace(*GetTraceRequest, SpanReaderPlugin_GetTraceServer) error
type UnimplementedSpanWriterPluginServer ¶
type UnimplementedSpanWriterPluginServer struct { }
UnimplementedSpanWriterPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedSpanWriterPluginServer) Close ¶
func (UnimplementedSpanWriterPluginServer) Close(context.Context, *CloseWriterRequest) (*CloseWriterResponse, error)
func (UnimplementedSpanWriterPluginServer) WriteSpan ¶
func (UnimplementedSpanWriterPluginServer) WriteSpan(context.Context, *WriteSpanRequest) (*WriteSpanResponse, error)
type UnimplementedStreamingSpanWriterPluginServer ¶
type UnimplementedStreamingSpanWriterPluginServer struct { }
UnimplementedStreamingSpanWriterPluginServer must be embedded to have forward compatible implementations.
func (UnimplementedStreamingSpanWriterPluginServer) WriteSpanStream ¶
func (UnimplementedStreamingSpanWriterPluginServer) WriteSpanStream(StreamingSpanWriterPlugin_WriteSpanStreamServer) error
type UnsafeArchiveSpanReaderPluginServer ¶
type UnsafeArchiveSpanReaderPluginServer interface {
// contains filtered or unexported methods
}
UnsafeArchiveSpanReaderPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ArchiveSpanReaderPluginServer will result in compilation errors.
type UnsafeArchiveSpanWriterPluginServer ¶
type UnsafeArchiveSpanWriterPluginServer interface {
// contains filtered or unexported methods
}
UnsafeArchiveSpanWriterPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ArchiveSpanWriterPluginServer will result in compilation errors.
type UnsafeDependenciesReaderPluginServer ¶
type UnsafeDependenciesReaderPluginServer interface {
// contains filtered or unexported methods
}
UnsafeDependenciesReaderPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DependenciesReaderPluginServer will result in compilation errors.
type UnsafePluginCapabilitiesServer ¶
type UnsafePluginCapabilitiesServer interface {
// contains filtered or unexported methods
}
UnsafePluginCapabilitiesServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginCapabilitiesServer will result in compilation errors.
type UnsafeSpanReaderPluginServer ¶
type UnsafeSpanReaderPluginServer interface {
// contains filtered or unexported methods
}
UnsafeSpanReaderPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SpanReaderPluginServer will result in compilation errors.
type UnsafeSpanWriterPluginServer ¶
type UnsafeSpanWriterPluginServer interface {
// contains filtered or unexported methods
}
UnsafeSpanWriterPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SpanWriterPluginServer will result in compilation errors.
type UnsafeStreamingSpanWriterPluginServer ¶
type UnsafeStreamingSpanWriterPluginServer interface {
// contains filtered or unexported methods
}
UnsafeStreamingSpanWriterPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingSpanWriterPluginServer will result in compilation errors.
type WriteSpanRequest ¶
type WriteSpanRequest struct { Span *v2.Span `protobuf:"bytes,1,opt,name=span,proto3" json:"span,omitempty"` // contains filtered or unexported fields }
func (*WriteSpanRequest) Descriptor
deprecated
func (*WriteSpanRequest) Descriptor() ([]byte, []int)
Deprecated: Use WriteSpanRequest.ProtoReflect.Descriptor instead.
func (*WriteSpanRequest) GetSpan ¶
func (x *WriteSpanRequest) GetSpan() *v2.Span
func (*WriteSpanRequest) ProtoMessage ¶
func (*WriteSpanRequest) ProtoMessage()
func (*WriteSpanRequest) ProtoReflect ¶
func (x *WriteSpanRequest) ProtoReflect() protoreflect.Message
func (*WriteSpanRequest) Reset ¶
func (x *WriteSpanRequest) Reset()
func (*WriteSpanRequest) String ¶
func (x *WriteSpanRequest) String() string
type WriteSpanResponse ¶
type WriteSpanResponse struct {
// contains filtered or unexported fields
}
empty; extensible in the future
func (*WriteSpanResponse) Descriptor
deprecated
func (*WriteSpanResponse) Descriptor() ([]byte, []int)
Deprecated: Use WriteSpanResponse.ProtoReflect.Descriptor instead.
func (*WriteSpanResponse) ProtoMessage ¶
func (*WriteSpanResponse) ProtoMessage()
func (*WriteSpanResponse) ProtoReflect ¶
func (x *WriteSpanResponse) ProtoReflect() protoreflect.Message
func (*WriteSpanResponse) Reset ¶
func (x *WriteSpanResponse) Reset()
func (*WriteSpanResponse) String ¶
func (x *WriteSpanResponse) String() string