Documentation ¶
Index ¶
- type ArchiveSpanReaderPluginClient
- type ArchiveSpanReaderPluginServer
- type ArchiveSpanReaderPlugin_GetArchiveTraceClient
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) CloseSend() error
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Context() context.Context
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Header() (metadata.MD, error)
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Recv() (*storage_v1.SpansResponseChunk, error)
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) RecvMsg(m interface{}) error
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) SendMsg(m interface{}) error
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Trailer() metadata.MD
- type ArchiveSpanReaderPlugin_GetArchiveTraceServer
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) Context() context.Context
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) RecvMsg(m interface{}) error
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) Send(_a0 *storage_v1.SpansResponseChunk) error
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendHeader(_a0 metadata.MD) error
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendMsg(m interface{}) error
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetHeader(_a0 metadata.MD) error
- func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetTrailer(_a0 metadata.MD)
- type ArchiveSpanWriterPluginClient
- type ArchiveSpanWriterPluginServer
- type DependenciesReaderPluginClient
- type DependenciesReaderPluginServer
- type PluginCapabilitiesClient
- type PluginCapabilitiesServer
- type SpanReaderPluginClient
- func (_m *SpanReaderPluginClient) FindTraceIDs(ctx context.Context, in *storage_v1.FindTraceIDsRequest, ...) (*storage_v1.FindTraceIDsResponse, error)
- func (_m *SpanReaderPluginClient) FindTraces(ctx context.Context, in *storage_v1.FindTracesRequest, opts ...grpc.CallOption) (storage_v1.SpanReaderPlugin_FindTracesClient, error)
- func (_m *SpanReaderPluginClient) GetOperations(ctx context.Context, in *storage_v1.GetOperationsRequest, ...) (*storage_v1.GetOperationsResponse, error)
- func (_m *SpanReaderPluginClient) GetServices(ctx context.Context, in *storage_v1.GetServicesRequest, ...) (*storage_v1.GetServicesResponse, error)
- func (_m *SpanReaderPluginClient) GetTrace(ctx context.Context, in *storage_v1.GetTraceRequest, opts ...grpc.CallOption) (storage_v1.SpanReaderPlugin_GetTraceClient, error)
- type SpanReaderPluginServer
- func (_m *SpanReaderPluginServer) FindTraceIDs(_a0 context.Context, _a1 *storage_v1.FindTraceIDsRequest) (*storage_v1.FindTraceIDsResponse, error)
- func (_m *SpanReaderPluginServer) FindTraces(_a0 *storage_v1.FindTracesRequest, ...) error
- func (_m *SpanReaderPluginServer) GetOperations(_a0 context.Context, _a1 *storage_v1.GetOperationsRequest) (*storage_v1.GetOperationsResponse, error)
- func (_m *SpanReaderPluginServer) GetServices(_a0 context.Context, _a1 *storage_v1.GetServicesRequest) (*storage_v1.GetServicesResponse, error)
- func (_m *SpanReaderPluginServer) GetTrace(_a0 *storage_v1.GetTraceRequest, ...) error
- type SpanReaderPlugin_FindTracesClient
- func (_m *SpanReaderPlugin_FindTracesClient) CloseSend() error
- func (_m *SpanReaderPlugin_FindTracesClient) Context() context.Context
- func (_m *SpanReaderPlugin_FindTracesClient) Header() (metadata.MD, error)
- func (_m *SpanReaderPlugin_FindTracesClient) Recv() (*storage_v1.SpansResponseChunk, error)
- func (_m *SpanReaderPlugin_FindTracesClient) RecvMsg(m interface{}) error
- func (_m *SpanReaderPlugin_FindTracesClient) SendMsg(m interface{}) error
- func (_m *SpanReaderPlugin_FindTracesClient) Trailer() metadata.MD
- type SpanReaderPlugin_FindTracesServer
- func (_m *SpanReaderPlugin_FindTracesServer) Context() context.Context
- func (_m *SpanReaderPlugin_FindTracesServer) RecvMsg(m interface{}) error
- func (_m *SpanReaderPlugin_FindTracesServer) Send(_a0 *storage_v1.SpansResponseChunk) error
- func (_m *SpanReaderPlugin_FindTracesServer) SendHeader(_a0 metadata.MD) error
- func (_m *SpanReaderPlugin_FindTracesServer) SendMsg(m interface{}) error
- func (_m *SpanReaderPlugin_FindTracesServer) SetHeader(_a0 metadata.MD) error
- func (_m *SpanReaderPlugin_FindTracesServer) SetTrailer(_a0 metadata.MD)
- type SpanReaderPlugin_GetTraceClient
- func (_m *SpanReaderPlugin_GetTraceClient) CloseSend() error
- func (_m *SpanReaderPlugin_GetTraceClient) Context() context.Context
- func (_m *SpanReaderPlugin_GetTraceClient) Header() (metadata.MD, error)
- func (_m *SpanReaderPlugin_GetTraceClient) Recv() (*storage_v1.SpansResponseChunk, error)
- func (_m *SpanReaderPlugin_GetTraceClient) RecvMsg(m interface{}) error
- func (_m *SpanReaderPlugin_GetTraceClient) SendMsg(m interface{}) error
- func (_m *SpanReaderPlugin_GetTraceClient) Trailer() metadata.MD
- type SpanReaderPlugin_GetTraceServer
- func (_m *SpanReaderPlugin_GetTraceServer) Context() context.Context
- func (_m *SpanReaderPlugin_GetTraceServer) RecvMsg(m interface{}) error
- func (_m *SpanReaderPlugin_GetTraceServer) Send(_a0 *storage_v1.SpansResponseChunk) error
- func (_m *SpanReaderPlugin_GetTraceServer) SendHeader(_a0 metadata.MD) error
- func (_m *SpanReaderPlugin_GetTraceServer) SendMsg(m interface{}) error
- func (_m *SpanReaderPlugin_GetTraceServer) SetHeader(_a0 metadata.MD) error
- func (_m *SpanReaderPlugin_GetTraceServer) SetTrailer(_a0 metadata.MD)
- type SpanWriterPluginClient
- func (_m *SpanWriterPluginClient) Close(ctx context.Context, in *storage_v1.CloseWriterRequest, ...) (*storage_v1.CloseWriterResponse, error)
- func (_m *SpanWriterPluginClient) WriteSpan(ctx context.Context, in *storage_v1.WriteSpanRequest, opts ...grpc.CallOption) (*storage_v1.WriteSpanResponse, error)
- type SpanWriterPluginServer
- type StreamingSpanWriterPluginClient
- type StreamingSpanWriterPluginServer
- type StreamingSpanWriterPlugin_WriteSpanStreamClient
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseAndRecv() (*storage_v1.WriteSpanResponse, error)
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseSend() error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Context() context.Context
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Header() (metadata.MD, error)
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) RecvMsg(m interface{}) error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Send(_a0 *storage_v1.WriteSpanRequest) error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) SendMsg(m interface{}) error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Trailer() metadata.MD
- type StreamingSpanWriterPlugin_WriteSpanStreamServer
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) Context() context.Context
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) Recv() (*storage_v1.WriteSpanRequest, error)
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) RecvMsg(m interface{}) error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendAndClose(_a0 *storage_v1.WriteSpanResponse) error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendHeader(_a0 metadata.MD) error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendMsg(m interface{}) error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SetHeader(_a0 metadata.MD) error
- func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SetTrailer(_a0 metadata.MD)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ArchiveSpanReaderPluginClient ¶ added in v1.20.0
ArchiveSpanReaderPluginClient is an autogenerated mock type for the ArchiveSpanReaderPluginClient type
func NewArchiveSpanReaderPluginClient ¶ added in v1.57.0
func NewArchiveSpanReaderPluginClient(t interface { mock.TestingT Cleanup(func()) }) *ArchiveSpanReaderPluginClient
NewArchiveSpanReaderPluginClient creates a new instance of ArchiveSpanReaderPluginClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ArchiveSpanReaderPluginClient) GetArchiveTrace ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPluginClient) GetArchiveTrace(ctx context.Context, in *storage_v1.GetTraceRequest, opts ...grpc.CallOption) (storage_v1.ArchiveSpanReaderPlugin_GetArchiveTraceClient, error)
GetArchiveTrace provides a mock function with given fields: ctx, in, opts
type ArchiveSpanReaderPluginServer ¶ added in v1.20.0
ArchiveSpanReaderPluginServer is an autogenerated mock type for the ArchiveSpanReaderPluginServer type
func NewArchiveSpanReaderPluginServer ¶ added in v1.57.0
func NewArchiveSpanReaderPluginServer(t interface { mock.TestingT Cleanup(func()) }) *ArchiveSpanReaderPluginServer
NewArchiveSpanReaderPluginServer creates a new instance of ArchiveSpanReaderPluginServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ArchiveSpanReaderPluginServer) GetArchiveTrace ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPluginServer) GetArchiveTrace(_a0 *storage_v1.GetTraceRequest, _a1 storage_v1.ArchiveSpanReaderPlugin_GetArchiveTraceServer) error
GetArchiveTrace provides a mock function with given fields: _a0, _a1
type ArchiveSpanReaderPlugin_GetArchiveTraceClient ¶ added in v1.20.0
ArchiveSpanReaderPlugin_GetArchiveTraceClient is an autogenerated mock type for the ArchiveSpanReaderPlugin_GetArchiveTraceClient type
func NewArchiveSpanReaderPlugin_GetArchiveTraceClient ¶ added in v1.57.0
func NewArchiveSpanReaderPlugin_GetArchiveTraceClient(t interface { mock.TestingT Cleanup(func()) }) *ArchiveSpanReaderPlugin_GetArchiveTraceClient
NewArchiveSpanReaderPlugin_GetArchiveTraceClient creates a new instance of ArchiveSpanReaderPlugin_GetArchiveTraceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) CloseSend ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) Context ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Context() context.Context
Context provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) Header ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) Recv ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Recv() (*storage_v1.SpansResponseChunk, error)
Recv provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) RecvMsg ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) SendMsg ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) Trailer ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type ArchiveSpanReaderPlugin_GetArchiveTraceServer ¶ added in v1.20.0
ArchiveSpanReaderPlugin_GetArchiveTraceServer is an autogenerated mock type for the ArchiveSpanReaderPlugin_GetArchiveTraceServer type
func NewArchiveSpanReaderPlugin_GetArchiveTraceServer ¶ added in v1.57.0
func NewArchiveSpanReaderPlugin_GetArchiveTraceServer(t interface { mock.TestingT Cleanup(func()) }) *ArchiveSpanReaderPlugin_GetArchiveTraceServer
NewArchiveSpanReaderPlugin_GetArchiveTraceServer creates a new instance of ArchiveSpanReaderPlugin_GetArchiveTraceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) Context ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) Context() context.Context
Context provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) RecvMsg ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) Send ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) Send(_a0 *storage_v1.SpansResponseChunk) error
Send provides a mock function with given fields: _a0
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendHeader ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendMsg ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetHeader ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetTrailer ¶ added in v1.20.0
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type ArchiveSpanWriterPluginClient ¶ added in v1.20.0
ArchiveSpanWriterPluginClient is an autogenerated mock type for the ArchiveSpanWriterPluginClient type
func NewArchiveSpanWriterPluginClient ¶ added in v1.57.0
func NewArchiveSpanWriterPluginClient(t interface { mock.TestingT Cleanup(func()) }) *ArchiveSpanWriterPluginClient
NewArchiveSpanWriterPluginClient creates a new instance of ArchiveSpanWriterPluginClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ArchiveSpanWriterPluginClient) WriteArchiveSpan ¶ added in v1.20.0
func (_m *ArchiveSpanWriterPluginClient) WriteArchiveSpan(ctx context.Context, in *storage_v1.WriteSpanRequest, opts ...grpc.CallOption) (*storage_v1.WriteSpanResponse, error)
WriteArchiveSpan provides a mock function with given fields: ctx, in, opts
type ArchiveSpanWriterPluginServer ¶ added in v1.20.0
ArchiveSpanWriterPluginServer is an autogenerated mock type for the ArchiveSpanWriterPluginServer type
func NewArchiveSpanWriterPluginServer ¶ added in v1.57.0
func NewArchiveSpanWriterPluginServer(t interface { mock.TestingT Cleanup(func()) }) *ArchiveSpanWriterPluginServer
NewArchiveSpanWriterPluginServer creates a new instance of ArchiveSpanWriterPluginServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ArchiveSpanWriterPluginServer) WriteArchiveSpan ¶ added in v1.20.0
func (_m *ArchiveSpanWriterPluginServer) WriteArchiveSpan(_a0 context.Context, _a1 *storage_v1.WriteSpanRequest) (*storage_v1.WriteSpanResponse, error)
WriteArchiveSpan provides a mock function with given fields: _a0, _a1
type DependenciesReaderPluginClient ¶
DependenciesReaderPluginClient is an autogenerated mock type for the DependenciesReaderPluginClient type
func NewDependenciesReaderPluginClient ¶ added in v1.57.0
func NewDependenciesReaderPluginClient(t interface { mock.TestingT Cleanup(func()) }) *DependenciesReaderPluginClient
NewDependenciesReaderPluginClient creates a new instance of DependenciesReaderPluginClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*DependenciesReaderPluginClient) GetDependencies ¶
func (_m *DependenciesReaderPluginClient) GetDependencies(ctx context.Context, in *storage_v1.GetDependenciesRequest, opts ...grpc.CallOption) (*storage_v1.GetDependenciesResponse, error)
GetDependencies provides a mock function with given fields: ctx, in, opts
type DependenciesReaderPluginServer ¶
DependenciesReaderPluginServer is an autogenerated mock type for the DependenciesReaderPluginServer type
func NewDependenciesReaderPluginServer ¶ added in v1.57.0
func NewDependenciesReaderPluginServer(t interface { mock.TestingT Cleanup(func()) }) *DependenciesReaderPluginServer
NewDependenciesReaderPluginServer creates a new instance of DependenciesReaderPluginServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*DependenciesReaderPluginServer) GetDependencies ¶
func (_m *DependenciesReaderPluginServer) GetDependencies(_a0 context.Context, _a1 *storage_v1.GetDependenciesRequest) (*storage_v1.GetDependenciesResponse, error)
GetDependencies provides a mock function with given fields: _a0, _a1
type PluginCapabilitiesClient ¶ added in v1.20.0
PluginCapabilitiesClient is an autogenerated mock type for the PluginCapabilitiesClient type
func NewPluginCapabilitiesClient ¶ added in v1.57.0
func NewPluginCapabilitiesClient(t interface { mock.TestingT Cleanup(func()) }) *PluginCapabilitiesClient
NewPluginCapabilitiesClient creates a new instance of PluginCapabilitiesClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PluginCapabilitiesClient) Capabilities ¶ added in v1.20.0
func (_m *PluginCapabilitiesClient) Capabilities(ctx context.Context, in *storage_v1.CapabilitiesRequest, opts ...grpc.CallOption) (*storage_v1.CapabilitiesResponse, error)
Capabilities provides a mock function with given fields: ctx, in, opts
type PluginCapabilitiesServer ¶ added in v1.20.0
PluginCapabilitiesServer is an autogenerated mock type for the PluginCapabilitiesServer type
func NewPluginCapabilitiesServer ¶ added in v1.57.0
func NewPluginCapabilitiesServer(t interface { mock.TestingT Cleanup(func()) }) *PluginCapabilitiesServer
NewPluginCapabilitiesServer creates a new instance of PluginCapabilitiesServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*PluginCapabilitiesServer) Capabilities ¶ added in v1.20.0
func (_m *PluginCapabilitiesServer) Capabilities(_a0 context.Context, _a1 *storage_v1.CapabilitiesRequest) (*storage_v1.CapabilitiesResponse, error)
Capabilities provides a mock function with given fields: _a0, _a1
type SpanReaderPluginClient ¶
SpanReaderPluginClient is an autogenerated mock type for the SpanReaderPluginClient type
func NewSpanReaderPluginClient ¶ added in v1.57.0
func NewSpanReaderPluginClient(t interface { mock.TestingT Cleanup(func()) }) *SpanReaderPluginClient
NewSpanReaderPluginClient creates a new instance of SpanReaderPluginClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SpanReaderPluginClient) FindTraceIDs ¶
func (_m *SpanReaderPluginClient) FindTraceIDs(ctx context.Context, in *storage_v1.FindTraceIDsRequest, opts ...grpc.CallOption) (*storage_v1.FindTraceIDsResponse, error)
FindTraceIDs provides a mock function with given fields: ctx, in, opts
func (*SpanReaderPluginClient) FindTraces ¶
func (_m *SpanReaderPluginClient) FindTraces(ctx context.Context, in *storage_v1.FindTracesRequest, opts ...grpc.CallOption) (storage_v1.SpanReaderPlugin_FindTracesClient, error)
FindTraces provides a mock function with given fields: ctx, in, opts
func (*SpanReaderPluginClient) GetOperations ¶
func (_m *SpanReaderPluginClient) GetOperations(ctx context.Context, in *storage_v1.GetOperationsRequest, opts ...grpc.CallOption) (*storage_v1.GetOperationsResponse, error)
GetOperations provides a mock function with given fields: ctx, in, opts
func (*SpanReaderPluginClient) GetServices ¶
func (_m *SpanReaderPluginClient) GetServices(ctx context.Context, in *storage_v1.GetServicesRequest, opts ...grpc.CallOption) (*storage_v1.GetServicesResponse, error)
GetServices provides a mock function with given fields: ctx, in, opts
func (*SpanReaderPluginClient) GetTrace ¶
func (_m *SpanReaderPluginClient) GetTrace(ctx context.Context, in *storage_v1.GetTraceRequest, opts ...grpc.CallOption) (storage_v1.SpanReaderPlugin_GetTraceClient, error)
GetTrace provides a mock function with given fields: ctx, in, opts
type SpanReaderPluginServer ¶
SpanReaderPluginServer is an autogenerated mock type for the SpanReaderPluginServer type
func NewSpanReaderPluginServer ¶ added in v1.57.0
func NewSpanReaderPluginServer(t interface { mock.TestingT Cleanup(func()) }) *SpanReaderPluginServer
NewSpanReaderPluginServer creates a new instance of SpanReaderPluginServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SpanReaderPluginServer) FindTraceIDs ¶
func (_m *SpanReaderPluginServer) FindTraceIDs(_a0 context.Context, _a1 *storage_v1.FindTraceIDsRequest) (*storage_v1.FindTraceIDsResponse, error)
FindTraceIDs provides a mock function with given fields: _a0, _a1
func (*SpanReaderPluginServer) FindTraces ¶
func (_m *SpanReaderPluginServer) FindTraces(_a0 *storage_v1.FindTracesRequest, _a1 storage_v1.SpanReaderPlugin_FindTracesServer) error
FindTraces provides a mock function with given fields: _a0, _a1
func (*SpanReaderPluginServer) GetOperations ¶
func (_m *SpanReaderPluginServer) GetOperations(_a0 context.Context, _a1 *storage_v1.GetOperationsRequest) (*storage_v1.GetOperationsResponse, error)
GetOperations provides a mock function with given fields: _a0, _a1
func (*SpanReaderPluginServer) GetServices ¶
func (_m *SpanReaderPluginServer) GetServices(_a0 context.Context, _a1 *storage_v1.GetServicesRequest) (*storage_v1.GetServicesResponse, error)
GetServices provides a mock function with given fields: _a0, _a1
func (*SpanReaderPluginServer) GetTrace ¶
func (_m *SpanReaderPluginServer) GetTrace(_a0 *storage_v1.GetTraceRequest, _a1 storage_v1.SpanReaderPlugin_GetTraceServer) error
GetTrace provides a mock function with given fields: _a0, _a1
type SpanReaderPlugin_FindTracesClient ¶
SpanReaderPlugin_FindTracesClient is an autogenerated mock type for the SpanReaderPlugin_FindTracesClient type
func NewSpanReaderPlugin_FindTracesClient ¶ added in v1.57.0
func NewSpanReaderPlugin_FindTracesClient(t interface { mock.TestingT Cleanup(func()) }) *SpanReaderPlugin_FindTracesClient
NewSpanReaderPlugin_FindTracesClient creates a new instance of SpanReaderPlugin_FindTracesClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SpanReaderPlugin_FindTracesClient) CloseSend ¶
func (_m *SpanReaderPlugin_FindTracesClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*SpanReaderPlugin_FindTracesClient) Context ¶
func (_m *SpanReaderPlugin_FindTracesClient) Context() context.Context
Context provides a mock function with given fields:
func (*SpanReaderPlugin_FindTracesClient) Header ¶
func (_m *SpanReaderPlugin_FindTracesClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*SpanReaderPlugin_FindTracesClient) Recv ¶
func (_m *SpanReaderPlugin_FindTracesClient) Recv() (*storage_v1.SpansResponseChunk, error)
Recv provides a mock function with given fields:
func (*SpanReaderPlugin_FindTracesClient) RecvMsg ¶
func (_m *SpanReaderPlugin_FindTracesClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*SpanReaderPlugin_FindTracesClient) SendMsg ¶
func (_m *SpanReaderPlugin_FindTracesClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*SpanReaderPlugin_FindTracesClient) Trailer ¶
func (_m *SpanReaderPlugin_FindTracesClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type SpanReaderPlugin_FindTracesServer ¶
SpanReaderPlugin_FindTracesServer is an autogenerated mock type for the SpanReaderPlugin_FindTracesServer type
func NewSpanReaderPlugin_FindTracesServer ¶ added in v1.57.0
func NewSpanReaderPlugin_FindTracesServer(t interface { mock.TestingT Cleanup(func()) }) *SpanReaderPlugin_FindTracesServer
NewSpanReaderPlugin_FindTracesServer creates a new instance of SpanReaderPlugin_FindTracesServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SpanReaderPlugin_FindTracesServer) Context ¶
func (_m *SpanReaderPlugin_FindTracesServer) Context() context.Context
Context provides a mock function with given fields:
func (*SpanReaderPlugin_FindTracesServer) RecvMsg ¶
func (_m *SpanReaderPlugin_FindTracesServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*SpanReaderPlugin_FindTracesServer) Send ¶
func (_m *SpanReaderPlugin_FindTracesServer) Send(_a0 *storage_v1.SpansResponseChunk) error
Send provides a mock function with given fields: _a0
func (*SpanReaderPlugin_FindTracesServer) SendHeader ¶
func (_m *SpanReaderPlugin_FindTracesServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*SpanReaderPlugin_FindTracesServer) SendMsg ¶
func (_m *SpanReaderPlugin_FindTracesServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*SpanReaderPlugin_FindTracesServer) SetHeader ¶
func (_m *SpanReaderPlugin_FindTracesServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*SpanReaderPlugin_FindTracesServer) SetTrailer ¶
func (_m *SpanReaderPlugin_FindTracesServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type SpanReaderPlugin_GetTraceClient ¶
SpanReaderPlugin_GetTraceClient is an autogenerated mock type for the SpanReaderPlugin_GetTraceClient type
func NewSpanReaderPlugin_GetTraceClient ¶ added in v1.57.0
func NewSpanReaderPlugin_GetTraceClient(t interface { mock.TestingT Cleanup(func()) }) *SpanReaderPlugin_GetTraceClient
NewSpanReaderPlugin_GetTraceClient creates a new instance of SpanReaderPlugin_GetTraceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SpanReaderPlugin_GetTraceClient) CloseSend ¶
func (_m *SpanReaderPlugin_GetTraceClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*SpanReaderPlugin_GetTraceClient) Context ¶
func (_m *SpanReaderPlugin_GetTraceClient) Context() context.Context
Context provides a mock function with given fields:
func (*SpanReaderPlugin_GetTraceClient) Header ¶
func (_m *SpanReaderPlugin_GetTraceClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*SpanReaderPlugin_GetTraceClient) Recv ¶
func (_m *SpanReaderPlugin_GetTraceClient) Recv() (*storage_v1.SpansResponseChunk, error)
Recv provides a mock function with given fields:
func (*SpanReaderPlugin_GetTraceClient) RecvMsg ¶
func (_m *SpanReaderPlugin_GetTraceClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*SpanReaderPlugin_GetTraceClient) SendMsg ¶
func (_m *SpanReaderPlugin_GetTraceClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*SpanReaderPlugin_GetTraceClient) Trailer ¶
func (_m *SpanReaderPlugin_GetTraceClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type SpanReaderPlugin_GetTraceServer ¶
SpanReaderPlugin_GetTraceServer is an autogenerated mock type for the SpanReaderPlugin_GetTraceServer type
func NewSpanReaderPlugin_GetTraceServer ¶ added in v1.57.0
func NewSpanReaderPlugin_GetTraceServer(t interface { mock.TestingT Cleanup(func()) }) *SpanReaderPlugin_GetTraceServer
NewSpanReaderPlugin_GetTraceServer creates a new instance of SpanReaderPlugin_GetTraceServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SpanReaderPlugin_GetTraceServer) Context ¶
func (_m *SpanReaderPlugin_GetTraceServer) Context() context.Context
Context provides a mock function with given fields:
func (*SpanReaderPlugin_GetTraceServer) RecvMsg ¶
func (_m *SpanReaderPlugin_GetTraceServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*SpanReaderPlugin_GetTraceServer) Send ¶
func (_m *SpanReaderPlugin_GetTraceServer) Send(_a0 *storage_v1.SpansResponseChunk) error
Send provides a mock function with given fields: _a0
func (*SpanReaderPlugin_GetTraceServer) SendHeader ¶
func (_m *SpanReaderPlugin_GetTraceServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*SpanReaderPlugin_GetTraceServer) SendMsg ¶
func (_m *SpanReaderPlugin_GetTraceServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*SpanReaderPlugin_GetTraceServer) SetHeader ¶
func (_m *SpanReaderPlugin_GetTraceServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*SpanReaderPlugin_GetTraceServer) SetTrailer ¶
func (_m *SpanReaderPlugin_GetTraceServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type SpanWriterPluginClient ¶
SpanWriterPluginClient is an autogenerated mock type for the SpanWriterPluginClient type
func NewSpanWriterPluginClient ¶ added in v1.57.0
func NewSpanWriterPluginClient(t interface { mock.TestingT Cleanup(func()) }) *SpanWriterPluginClient
NewSpanWriterPluginClient creates a new instance of SpanWriterPluginClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SpanWriterPluginClient) Close ¶ added in v1.27.0
func (_m *SpanWriterPluginClient) Close(ctx context.Context, in *storage_v1.CloseWriterRequest, opts ...grpc.CallOption) (*storage_v1.CloseWriterResponse, error)
Close provides a mock function with given fields: ctx, in, opts
func (*SpanWriterPluginClient) WriteSpan ¶
func (_m *SpanWriterPluginClient) WriteSpan(ctx context.Context, in *storage_v1.WriteSpanRequest, opts ...grpc.CallOption) (*storage_v1.WriteSpanResponse, error)
WriteSpan provides a mock function with given fields: ctx, in, opts
type SpanWriterPluginServer ¶
SpanWriterPluginServer is an autogenerated mock type for the SpanWriterPluginServer type
func NewSpanWriterPluginServer ¶ added in v1.57.0
func NewSpanWriterPluginServer(t interface { mock.TestingT Cleanup(func()) }) *SpanWriterPluginServer
NewSpanWriterPluginServer creates a new instance of SpanWriterPluginServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*SpanWriterPluginServer) Close ¶ added in v1.27.0
func (_m *SpanWriterPluginServer) Close(_a0 context.Context, _a1 *storage_v1.CloseWriterRequest) (*storage_v1.CloseWriterResponse, error)
Close provides a mock function with given fields: _a0, _a1
func (*SpanWriterPluginServer) WriteSpan ¶
func (_m *SpanWriterPluginServer) WriteSpan(_a0 context.Context, _a1 *storage_v1.WriteSpanRequest) (*storage_v1.WriteSpanResponse, error)
WriteSpan provides a mock function with given fields: _a0, _a1
type StreamingSpanWriterPluginClient ¶ added in v1.34.0
StreamingSpanWriterPluginClient is an autogenerated mock type for the StreamingSpanWriterPluginClient type
func NewStreamingSpanWriterPluginClient ¶ added in v1.57.0
func NewStreamingSpanWriterPluginClient(t interface { mock.TestingT Cleanup(func()) }) *StreamingSpanWriterPluginClient
NewStreamingSpanWriterPluginClient creates a new instance of StreamingSpanWriterPluginClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*StreamingSpanWriterPluginClient) WriteSpanStream ¶ added in v1.34.0
func (_m *StreamingSpanWriterPluginClient) WriteSpanStream(ctx context.Context, opts ...grpc.CallOption) (storage_v1.StreamingSpanWriterPlugin_WriteSpanStreamClient, error)
WriteSpanStream provides a mock function with given fields: ctx, opts
type StreamingSpanWriterPluginServer ¶ added in v1.34.0
StreamingSpanWriterPluginServer is an autogenerated mock type for the StreamingSpanWriterPluginServer type
func NewStreamingSpanWriterPluginServer ¶ added in v1.57.0
func NewStreamingSpanWriterPluginServer(t interface { mock.TestingT Cleanup(func()) }) *StreamingSpanWriterPluginServer
NewStreamingSpanWriterPluginServer creates a new instance of StreamingSpanWriterPluginServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*StreamingSpanWriterPluginServer) WriteSpanStream ¶ added in v1.34.0
func (_m *StreamingSpanWriterPluginServer) WriteSpanStream(_a0 storage_v1.StreamingSpanWriterPlugin_WriteSpanStreamServer) error
WriteSpanStream provides a mock function with given fields: _a0
type StreamingSpanWriterPlugin_WriteSpanStreamClient ¶ added in v1.34.0
StreamingSpanWriterPlugin_WriteSpanStreamClient is an autogenerated mock type for the StreamingSpanWriterPlugin_WriteSpanStreamClient type
func NewStreamingSpanWriterPlugin_WriteSpanStreamClient ¶ added in v1.57.0
func NewStreamingSpanWriterPlugin_WriteSpanStreamClient(t interface { mock.TestingT Cleanup(func()) }) *StreamingSpanWriterPlugin_WriteSpanStreamClient
NewStreamingSpanWriterPlugin_WriteSpanStreamClient creates a new instance of StreamingSpanWriterPlugin_WriteSpanStreamClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseAndRecv ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseAndRecv() (*storage_v1.WriteSpanResponse, error)
CloseAndRecv provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseSend ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) Context ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Context() context.Context
Context provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) Header ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) RecvMsg ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) Send ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Send(_a0 *storage_v1.WriteSpanRequest) error
Send provides a mock function with given fields: _a0
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) SendMsg ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) Trailer ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type StreamingSpanWriterPlugin_WriteSpanStreamServer ¶ added in v1.34.0
StreamingSpanWriterPlugin_WriteSpanStreamServer is an autogenerated mock type for the StreamingSpanWriterPlugin_WriteSpanStreamServer type
func NewStreamingSpanWriterPlugin_WriteSpanStreamServer ¶ added in v1.57.0
func NewStreamingSpanWriterPlugin_WriteSpanStreamServer(t interface { mock.TestingT Cleanup(func()) }) *StreamingSpanWriterPlugin_WriteSpanStreamServer
NewStreamingSpanWriterPlugin_WriteSpanStreamServer creates a new instance of StreamingSpanWriterPlugin_WriteSpanStreamServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) Context ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) Context() context.Context
Context provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) Recv ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) Recv() (*storage_v1.WriteSpanRequest, error)
Recv provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) RecvMsg ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SendAndClose ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendAndClose(_a0 *storage_v1.WriteSpanResponse) error
SendAndClose provides a mock function with given fields: _a0
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SendHeader ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SendMsg ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SetHeader ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SetTrailer ¶ added in v1.34.0
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
Source Files ¶
- ArchiveSpanReaderPluginClient.go
- ArchiveSpanReaderPluginServer.go
- ArchiveSpanReaderPlugin_GetArchiveTraceClient.go
- ArchiveSpanReaderPlugin_GetArchiveTraceServer.go
- ArchiveSpanWriterPluginClient.go
- ArchiveSpanWriterPluginServer.go
- DependenciesReaderPluginClient.go
- DependenciesReaderPluginServer.go
- PluginCapabilitiesClient.go
- PluginCapabilitiesServer.go
- SpanReaderPluginClient.go
- SpanReaderPluginServer.go
- SpanReaderPlugin_FindTracesClient.go
- SpanReaderPlugin_FindTracesServer.go
- SpanReaderPlugin_GetTraceClient.go
- SpanReaderPlugin_GetTraceServer.go
- SpanWriterPluginClient.go
- SpanWriterPluginServer.go
- StreamingSpanWriterPluginClient.go
- StreamingSpanWriterPluginServer.go
- StreamingSpanWriterPlugin_WriteSpanStreamClient.go
- StreamingSpanWriterPlugin_WriteSpanStreamServer.go