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 ¶
ArchiveSpanReaderPluginClient is an autogenerated mock type for the ArchiveSpanReaderPluginClient type
func (*ArchiveSpanReaderPluginClient) GetArchiveTrace ¶
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 ¶
ArchiveSpanReaderPluginServer is an autogenerated mock type for the ArchiveSpanReaderPluginServer type
func (*ArchiveSpanReaderPluginServer) GetArchiveTrace ¶
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 ¶
ArchiveSpanReaderPlugin_GetArchiveTraceClient is an autogenerated mock type for the ArchiveSpanReaderPlugin_GetArchiveTraceClient type
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) CloseSend ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) Context ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Context() context.Context
Context provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) Header ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) Recv ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Recv() (*storage_v1.SpansResponseChunk, error)
Recv provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) RecvMsg ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) SendMsg ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*ArchiveSpanReaderPlugin_GetArchiveTraceClient) Trailer ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type ArchiveSpanReaderPlugin_GetArchiveTraceServer ¶
ArchiveSpanReaderPlugin_GetArchiveTraceServer is an autogenerated mock type for the ArchiveSpanReaderPlugin_GetArchiveTraceServer type
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) Context ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) Context() context.Context
Context provides a mock function with given fields:
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) RecvMsg ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) Send ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) Send(_a0 *storage_v1.SpansResponseChunk) error
Send provides a mock function with given fields: _a0
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendHeader ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendMsg ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetHeader ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetTrailer ¶
func (_m *ArchiveSpanReaderPlugin_GetArchiveTraceServer) SetTrailer(_a0 metadata.MD)
SetTrailer provides a mock function with given fields: _a0
type ArchiveSpanWriterPluginClient ¶
ArchiveSpanWriterPluginClient is an autogenerated mock type for the ArchiveSpanWriterPluginClient type
func (*ArchiveSpanWriterPluginClient) WriteArchiveSpan ¶
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 ¶
ArchiveSpanWriterPluginServer is an autogenerated mock type for the ArchiveSpanWriterPluginServer type
func (*ArchiveSpanWriterPluginServer) WriteArchiveSpan ¶
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 (*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 (*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 ¶
PluginCapabilitiesClient is an autogenerated mock type for the PluginCapabilitiesClient type
func (*PluginCapabilitiesClient) Capabilities ¶
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 ¶
PluginCapabilitiesServer is an autogenerated mock type for the PluginCapabilitiesServer type
func (*PluginCapabilitiesServer) Capabilities ¶
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 (*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 (*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 (*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 (*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 (*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 (*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 (*SpanWriterPluginClient) Close ¶
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 (*SpanWriterPluginServer) Close ¶
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 ¶
StreamingSpanWriterPluginClient is an autogenerated mock type for the StreamingSpanWriterPluginClient type
func (*StreamingSpanWriterPluginClient) WriteSpanStream ¶
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 ¶
StreamingSpanWriterPluginServer is an autogenerated mock type for the StreamingSpanWriterPluginServer type
func (*StreamingSpanWriterPluginServer) WriteSpanStream ¶
func (_m *StreamingSpanWriterPluginServer) WriteSpanStream(_a0 storage_v1.StreamingSpanWriterPlugin_WriteSpanStreamServer) error
WriteSpanStream provides a mock function with given fields: _a0
type StreamingSpanWriterPlugin_WriteSpanStreamClient ¶
StreamingSpanWriterPlugin_WriteSpanStreamClient is an autogenerated mock type for the StreamingSpanWriterPlugin_WriteSpanStreamClient type
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseAndRecv ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseAndRecv() (*storage_v1.WriteSpanResponse, error)
CloseAndRecv provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseSend ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) CloseSend() error
CloseSend provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) Context ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Context() context.Context
Context provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) Header ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Header() (metadata.MD, error)
Header provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) RecvMsg ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) Send ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Send(_a0 *storage_v1.WriteSpanRequest) error
Send provides a mock function with given fields: _a0
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) SendMsg ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*StreamingSpanWriterPlugin_WriteSpanStreamClient) Trailer ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamClient) Trailer() metadata.MD
Trailer provides a mock function with given fields:
type StreamingSpanWriterPlugin_WriteSpanStreamServer ¶
StreamingSpanWriterPlugin_WriteSpanStreamServer is an autogenerated mock type for the StreamingSpanWriterPlugin_WriteSpanStreamServer type
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) Context ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) Context() context.Context
Context provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) Recv ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) Recv() (*storage_v1.WriteSpanRequest, error)
Recv provides a mock function with given fields:
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) RecvMsg ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) RecvMsg(m interface{}) error
RecvMsg provides a mock function with given fields: m
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SendAndClose ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendAndClose(_a0 *storage_v1.WriteSpanResponse) error
SendAndClose provides a mock function with given fields: _a0
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SendHeader ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendHeader(_a0 metadata.MD) error
SendHeader provides a mock function with given fields: _a0
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SendMsg ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SendMsg(m interface{}) error
SendMsg provides a mock function with given fields: m
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SetHeader ¶
func (_m *StreamingSpanWriterPlugin_WriteSpanStreamServer) SetHeader(_a0 metadata.MD) error
SetHeader provides a mock function with given fields: _a0
func (*StreamingSpanWriterPlugin_WriteSpanStreamServer) SetTrailer ¶
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