Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockArrowLogsServiceClient
- type MockArrowLogsServiceClientMockRecorder
- type MockArrowLogsServiceServer
- type MockArrowLogsServiceServerMockRecorder
- type MockArrowLogsService_ArrowLogsClient
- func (m *MockArrowLogsService_ArrowLogsClient) CloseSend() error
- func (m *MockArrowLogsService_ArrowLogsClient) Context() context.Context
- func (m *MockArrowLogsService_ArrowLogsClient) EXPECT() *MockArrowLogsService_ArrowLogsClientMockRecorder
- func (m *MockArrowLogsService_ArrowLogsClient) Header() (metadata.MD, error)
- func (m *MockArrowLogsService_ArrowLogsClient) Recv() (*v1.BatchStatus, error)
- func (m *MockArrowLogsService_ArrowLogsClient) RecvMsg(arg0 interface{}) error
- func (m *MockArrowLogsService_ArrowLogsClient) Send(arg0 *v1.BatchArrowRecords) error
- func (m *MockArrowLogsService_ArrowLogsClient) SendMsg(arg0 interface{}) error
- func (m *MockArrowLogsService_ArrowLogsClient) Trailer() metadata.MD
- type MockArrowLogsService_ArrowLogsClientMockRecorder
- func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Context() *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Header() *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Recv() *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Trailer() *gomock.Call
- type MockArrowLogsService_ArrowLogsServer
- func (m *MockArrowLogsService_ArrowLogsServer) Context() context.Context
- func (m *MockArrowLogsService_ArrowLogsServer) EXPECT() *MockArrowLogsService_ArrowLogsServerMockRecorder
- func (m *MockArrowLogsService_ArrowLogsServer) Recv() (*v1.BatchArrowRecords, error)
- func (m *MockArrowLogsService_ArrowLogsServer) RecvMsg(arg0 interface{}) error
- func (m *MockArrowLogsService_ArrowLogsServer) Send(arg0 *v1.BatchStatus) error
- func (m *MockArrowLogsService_ArrowLogsServer) SendHeader(arg0 metadata.MD) error
- func (m *MockArrowLogsService_ArrowLogsServer) SendMsg(arg0 interface{}) error
- func (m *MockArrowLogsService_ArrowLogsServer) SetHeader(arg0 metadata.MD) error
- func (m *MockArrowLogsService_ArrowLogsServer) SetTrailer(arg0 metadata.MD)
- type MockArrowLogsService_ArrowLogsServerMockRecorder
- func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) Context() *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) Recv() *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockArrowMetricsServiceClient
- type MockArrowMetricsServiceClientMockRecorder
- type MockArrowMetricsServiceServer
- type MockArrowMetricsServiceServerMockRecorder
- type MockArrowMetricsService_ArrowMetricsClient
- func (m *MockArrowMetricsService_ArrowMetricsClient) CloseSend() error
- func (m *MockArrowMetricsService_ArrowMetricsClient) Context() context.Context
- func (m *MockArrowMetricsService_ArrowMetricsClient) EXPECT() *MockArrowMetricsService_ArrowMetricsClientMockRecorder
- func (m *MockArrowMetricsService_ArrowMetricsClient) Header() (metadata.MD, error)
- func (m *MockArrowMetricsService_ArrowMetricsClient) Recv() (*v1.BatchStatus, error)
- func (m *MockArrowMetricsService_ArrowMetricsClient) RecvMsg(arg0 interface{}) error
- func (m *MockArrowMetricsService_ArrowMetricsClient) Send(arg0 *v1.BatchArrowRecords) error
- func (m *MockArrowMetricsService_ArrowMetricsClient) SendMsg(arg0 interface{}) error
- func (m *MockArrowMetricsService_ArrowMetricsClient) Trailer() metadata.MD
- type MockArrowMetricsService_ArrowMetricsClientMockRecorder
- func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Context() *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Header() *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Recv() *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Trailer() *gomock.Call
- type MockArrowMetricsService_ArrowMetricsServer
- func (m *MockArrowMetricsService_ArrowMetricsServer) Context() context.Context
- func (m *MockArrowMetricsService_ArrowMetricsServer) EXPECT() *MockArrowMetricsService_ArrowMetricsServerMockRecorder
- func (m *MockArrowMetricsService_ArrowMetricsServer) Recv() (*v1.BatchArrowRecords, error)
- func (m *MockArrowMetricsService_ArrowMetricsServer) RecvMsg(arg0 interface{}) error
- func (m *MockArrowMetricsService_ArrowMetricsServer) Send(arg0 *v1.BatchStatus) error
- func (m *MockArrowMetricsService_ArrowMetricsServer) SendHeader(arg0 metadata.MD) error
- func (m *MockArrowMetricsService_ArrowMetricsServer) SendMsg(arg0 interface{}) error
- func (m *MockArrowMetricsService_ArrowMetricsServer) SetHeader(arg0 metadata.MD) error
- func (m *MockArrowMetricsService_ArrowMetricsServer) SetTrailer(arg0 metadata.MD)
- type MockArrowMetricsService_ArrowMetricsServerMockRecorder
- func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) Context() *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) Recv() *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockArrowStreamServiceClient
- type MockArrowStreamServiceClientMockRecorder
- type MockArrowStreamServiceServer
- type MockArrowStreamServiceServerMockRecorder
- type MockArrowStreamService_ArrowStreamClient
- func (m *MockArrowStreamService_ArrowStreamClient) CloseSend() error
- func (m *MockArrowStreamService_ArrowStreamClient) Context() context.Context
- func (m *MockArrowStreamService_ArrowStreamClient) EXPECT() *MockArrowStreamService_ArrowStreamClientMockRecorder
- func (m *MockArrowStreamService_ArrowStreamClient) Header() (metadata.MD, error)
- func (m *MockArrowStreamService_ArrowStreamClient) Recv() (*v1.BatchStatus, error)
- func (m *MockArrowStreamService_ArrowStreamClient) RecvMsg(arg0 interface{}) error
- func (m *MockArrowStreamService_ArrowStreamClient) Send(arg0 *v1.BatchArrowRecords) error
- func (m *MockArrowStreamService_ArrowStreamClient) SendMsg(arg0 interface{}) error
- func (m *MockArrowStreamService_ArrowStreamClient) Trailer() metadata.MD
- type MockArrowStreamService_ArrowStreamClientMockRecorder
- func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Context() *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Header() *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Recv() *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Trailer() *gomock.Call
- type MockArrowStreamService_ArrowStreamServer
- func (m *MockArrowStreamService_ArrowStreamServer) Context() context.Context
- func (m *MockArrowStreamService_ArrowStreamServer) EXPECT() *MockArrowStreamService_ArrowStreamServerMockRecorder
- func (m *MockArrowStreamService_ArrowStreamServer) Recv() (*v1.BatchArrowRecords, error)
- func (m *MockArrowStreamService_ArrowStreamServer) RecvMsg(arg0 interface{}) error
- func (m *MockArrowStreamService_ArrowStreamServer) Send(arg0 *v1.BatchStatus) error
- func (m *MockArrowStreamService_ArrowStreamServer) SendHeader(arg0 metadata.MD) error
- func (m *MockArrowStreamService_ArrowStreamServer) SendMsg(arg0 interface{}) error
- func (m *MockArrowStreamService_ArrowStreamServer) SetHeader(arg0 metadata.MD) error
- func (m *MockArrowStreamService_ArrowStreamServer) SetTrailer(arg0 metadata.MD)
- type MockArrowStreamService_ArrowStreamServerMockRecorder
- func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) Context() *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) Recv() *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockArrowTracesServiceClient
- type MockArrowTracesServiceClientMockRecorder
- type MockArrowTracesServiceServer
- type MockArrowTracesServiceServerMockRecorder
- type MockArrowTracesService_ArrowTracesClient
- func (m *MockArrowTracesService_ArrowTracesClient) CloseSend() error
- func (m *MockArrowTracesService_ArrowTracesClient) Context() context.Context
- func (m *MockArrowTracesService_ArrowTracesClient) EXPECT() *MockArrowTracesService_ArrowTracesClientMockRecorder
- func (m *MockArrowTracesService_ArrowTracesClient) Header() (metadata.MD, error)
- func (m *MockArrowTracesService_ArrowTracesClient) Recv() (*v1.BatchStatus, error)
- func (m *MockArrowTracesService_ArrowTracesClient) RecvMsg(arg0 interface{}) error
- func (m *MockArrowTracesService_ArrowTracesClient) Send(arg0 *v1.BatchArrowRecords) error
- func (m *MockArrowTracesService_ArrowTracesClient) SendMsg(arg0 interface{}) error
- func (m *MockArrowTracesService_ArrowTracesClient) Trailer() metadata.MD
- type MockArrowTracesService_ArrowTracesClientMockRecorder
- func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Context() *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Header() *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Recv() *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Trailer() *gomock.Call
- type MockArrowTracesService_ArrowTracesServer
- func (m *MockArrowTracesService_ArrowTracesServer) Context() context.Context
- func (m *MockArrowTracesService_ArrowTracesServer) EXPECT() *MockArrowTracesService_ArrowTracesServerMockRecorder
- func (m *MockArrowTracesService_ArrowTracesServer) Recv() (*v1.BatchArrowRecords, error)
- func (m *MockArrowTracesService_ArrowTracesServer) RecvMsg(arg0 interface{}) error
- func (m *MockArrowTracesService_ArrowTracesServer) Send(arg0 *v1.BatchStatus) error
- func (m *MockArrowTracesService_ArrowTracesServer) SendHeader(arg0 metadata.MD) error
- func (m *MockArrowTracesService_ArrowTracesServer) SendMsg(arg0 interface{}) error
- func (m *MockArrowTracesService_ArrowTracesServer) SetHeader(arg0 metadata.MD) error
- func (m *MockArrowTracesService_ArrowTracesServer) SetTrailer(arg0 metadata.MD)
- type MockArrowTracesService_ArrowTracesServerMockRecorder
- func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) Context() *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) Recv() *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockArrowLogsServiceClient ¶
type MockArrowLogsServiceClient struct {
// contains filtered or unexported fields
}
MockArrowLogsServiceClient is a mock of ArrowLogsServiceClient interface.
func NewMockArrowLogsServiceClient ¶
func NewMockArrowLogsServiceClient(ctrl *gomock.Controller) *MockArrowLogsServiceClient
NewMockArrowLogsServiceClient creates a new mock instance.
func (*MockArrowLogsServiceClient) ArrowLogs ¶
func (m *MockArrowLogsServiceClient) ArrowLogs(arg0 context.Context, arg1 ...grpc.CallOption) (v1.ArrowLogsService_ArrowLogsClient, error)
ArrowLogs mocks base method.
func (*MockArrowLogsServiceClient) EXPECT ¶
func (m *MockArrowLogsServiceClient) EXPECT() *MockArrowLogsServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockArrowLogsServiceClientMockRecorder ¶
type MockArrowLogsServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowLogsServiceClientMockRecorder is the mock recorder for MockArrowLogsServiceClient.
func (*MockArrowLogsServiceClientMockRecorder) ArrowLogs ¶
func (mr *MockArrowLogsServiceClientMockRecorder) ArrowLogs(arg0 interface{}, arg1 ...interface{}) *gomock.Call
ArrowLogs indicates an expected call of ArrowLogs.
type MockArrowLogsServiceServer ¶
type MockArrowLogsServiceServer struct {
// contains filtered or unexported fields
}
MockArrowLogsServiceServer is a mock of ArrowLogsServiceServer interface.
func NewMockArrowLogsServiceServer ¶
func NewMockArrowLogsServiceServer(ctrl *gomock.Controller) *MockArrowLogsServiceServer
NewMockArrowLogsServiceServer creates a new mock instance.
func (*MockArrowLogsServiceServer) ArrowLogs ¶
func (m *MockArrowLogsServiceServer) ArrowLogs(arg0 v1.ArrowLogsService_ArrowLogsServer) error
ArrowLogs mocks base method.
func (*MockArrowLogsServiceServer) EXPECT ¶
func (m *MockArrowLogsServiceServer) EXPECT() *MockArrowLogsServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockArrowLogsServiceServerMockRecorder ¶
type MockArrowLogsServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowLogsServiceServerMockRecorder is the mock recorder for MockArrowLogsServiceServer.
func (*MockArrowLogsServiceServerMockRecorder) ArrowLogs ¶
func (mr *MockArrowLogsServiceServerMockRecorder) ArrowLogs(arg0 interface{}) *gomock.Call
ArrowLogs indicates an expected call of ArrowLogs.
type MockArrowLogsService_ArrowLogsClient ¶
type MockArrowLogsService_ArrowLogsClient struct {
// contains filtered or unexported fields
}
MockArrowLogsService_ArrowLogsClient is a mock of ArrowLogsService_ArrowLogsClient interface.
func NewMockArrowLogsService_ArrowLogsClient ¶
func NewMockArrowLogsService_ArrowLogsClient(ctrl *gomock.Controller) *MockArrowLogsService_ArrowLogsClient
NewMockArrowLogsService_ArrowLogsClient creates a new mock instance.
func (*MockArrowLogsService_ArrowLogsClient) CloseSend ¶
func (m *MockArrowLogsService_ArrowLogsClient) CloseSend() error
CloseSend mocks base method.
func (*MockArrowLogsService_ArrowLogsClient) Context ¶
func (m *MockArrowLogsService_ArrowLogsClient) Context() context.Context
Context mocks base method.
func (*MockArrowLogsService_ArrowLogsClient) EXPECT ¶
func (m *MockArrowLogsService_ArrowLogsClient) EXPECT() *MockArrowLogsService_ArrowLogsClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockArrowLogsService_ArrowLogsClient) Header ¶
func (m *MockArrowLogsService_ArrowLogsClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockArrowLogsService_ArrowLogsClient) Recv ¶
func (m *MockArrowLogsService_ArrowLogsClient) Recv() (*v1.BatchStatus, error)
Recv mocks base method.
func (*MockArrowLogsService_ArrowLogsClient) RecvMsg ¶
func (m *MockArrowLogsService_ArrowLogsClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockArrowLogsService_ArrowLogsClient) Send ¶
func (m *MockArrowLogsService_ArrowLogsClient) Send(arg0 *v1.BatchArrowRecords) error
Send mocks base method.
func (*MockArrowLogsService_ArrowLogsClient) SendMsg ¶
func (m *MockArrowLogsService_ArrowLogsClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockArrowLogsService_ArrowLogsClient) Trailer ¶
func (m *MockArrowLogsService_ArrowLogsClient) Trailer() metadata.MD
Trailer mocks base method.
type MockArrowLogsService_ArrowLogsClientMockRecorder ¶
type MockArrowLogsService_ArrowLogsClientMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowLogsService_ArrowLogsClientMockRecorder is the mock recorder for MockArrowLogsService_ArrowLogsClient.
func (*MockArrowLogsService_ArrowLogsClientMockRecorder) CloseSend ¶
func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockArrowLogsService_ArrowLogsClientMockRecorder) Context ¶
func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockArrowLogsService_ArrowLogsClientMockRecorder) Header ¶
func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockArrowLogsService_ArrowLogsClientMockRecorder) Recv ¶
func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockArrowLogsService_ArrowLogsClientMockRecorder) RecvMsg ¶
func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockArrowLogsService_ArrowLogsClientMockRecorder) Send ¶
func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockArrowLogsService_ArrowLogsClientMockRecorder) SendMsg ¶
func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockArrowLogsService_ArrowLogsClientMockRecorder) Trailer ¶
func (mr *MockArrowLogsService_ArrowLogsClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockArrowLogsService_ArrowLogsServer ¶
type MockArrowLogsService_ArrowLogsServer struct {
// contains filtered or unexported fields
}
MockArrowLogsService_ArrowLogsServer is a mock of ArrowLogsService_ArrowLogsServer interface.
func NewMockArrowLogsService_ArrowLogsServer ¶
func NewMockArrowLogsService_ArrowLogsServer(ctrl *gomock.Controller) *MockArrowLogsService_ArrowLogsServer
NewMockArrowLogsService_ArrowLogsServer creates a new mock instance.
func (*MockArrowLogsService_ArrowLogsServer) Context ¶
func (m *MockArrowLogsService_ArrowLogsServer) Context() context.Context
Context mocks base method.
func (*MockArrowLogsService_ArrowLogsServer) EXPECT ¶
func (m *MockArrowLogsService_ArrowLogsServer) EXPECT() *MockArrowLogsService_ArrowLogsServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockArrowLogsService_ArrowLogsServer) Recv ¶
func (m *MockArrowLogsService_ArrowLogsServer) Recv() (*v1.BatchArrowRecords, error)
Recv mocks base method.
func (*MockArrowLogsService_ArrowLogsServer) RecvMsg ¶
func (m *MockArrowLogsService_ArrowLogsServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockArrowLogsService_ArrowLogsServer) Send ¶
func (m *MockArrowLogsService_ArrowLogsServer) Send(arg0 *v1.BatchStatus) error
Send mocks base method.
func (*MockArrowLogsService_ArrowLogsServer) SendHeader ¶
func (m *MockArrowLogsService_ArrowLogsServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockArrowLogsService_ArrowLogsServer) SendMsg ¶
func (m *MockArrowLogsService_ArrowLogsServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockArrowLogsService_ArrowLogsServer) SetHeader ¶
func (m *MockArrowLogsService_ArrowLogsServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockArrowLogsService_ArrowLogsServer) SetTrailer ¶
func (m *MockArrowLogsService_ArrowLogsServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockArrowLogsService_ArrowLogsServerMockRecorder ¶
type MockArrowLogsService_ArrowLogsServerMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowLogsService_ArrowLogsServerMockRecorder is the mock recorder for MockArrowLogsService_ArrowLogsServer.
func (*MockArrowLogsService_ArrowLogsServerMockRecorder) Context ¶
func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockArrowLogsService_ArrowLogsServerMockRecorder) Recv ¶
func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockArrowLogsService_ArrowLogsServerMockRecorder) RecvMsg ¶
func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockArrowLogsService_ArrowLogsServerMockRecorder) Send ¶
func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockArrowLogsService_ArrowLogsServerMockRecorder) SendHeader ¶
func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockArrowLogsService_ArrowLogsServerMockRecorder) SendMsg ¶
func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockArrowLogsService_ArrowLogsServerMockRecorder) SetHeader ¶
func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockArrowLogsService_ArrowLogsServerMockRecorder) SetTrailer ¶
func (mr *MockArrowLogsService_ArrowLogsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockArrowMetricsServiceClient ¶
type MockArrowMetricsServiceClient struct {
// contains filtered or unexported fields
}
MockArrowMetricsServiceClient is a mock of ArrowMetricsServiceClient interface.
func NewMockArrowMetricsServiceClient ¶
func NewMockArrowMetricsServiceClient(ctrl *gomock.Controller) *MockArrowMetricsServiceClient
NewMockArrowMetricsServiceClient creates a new mock instance.
func (*MockArrowMetricsServiceClient) ArrowMetrics ¶
func (m *MockArrowMetricsServiceClient) ArrowMetrics(arg0 context.Context, arg1 ...grpc.CallOption) (v1.ArrowMetricsService_ArrowMetricsClient, error)
ArrowMetrics mocks base method.
func (*MockArrowMetricsServiceClient) EXPECT ¶
func (m *MockArrowMetricsServiceClient) EXPECT() *MockArrowMetricsServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockArrowMetricsServiceClientMockRecorder ¶
type MockArrowMetricsServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowMetricsServiceClientMockRecorder is the mock recorder for MockArrowMetricsServiceClient.
func (*MockArrowMetricsServiceClientMockRecorder) ArrowMetrics ¶
func (mr *MockArrowMetricsServiceClientMockRecorder) ArrowMetrics(arg0 interface{}, arg1 ...interface{}) *gomock.Call
ArrowMetrics indicates an expected call of ArrowMetrics.
type MockArrowMetricsServiceServer ¶
type MockArrowMetricsServiceServer struct {
// contains filtered or unexported fields
}
MockArrowMetricsServiceServer is a mock of ArrowMetricsServiceServer interface.
func NewMockArrowMetricsServiceServer ¶
func NewMockArrowMetricsServiceServer(ctrl *gomock.Controller) *MockArrowMetricsServiceServer
NewMockArrowMetricsServiceServer creates a new mock instance.
func (*MockArrowMetricsServiceServer) ArrowMetrics ¶
func (m *MockArrowMetricsServiceServer) ArrowMetrics(arg0 v1.ArrowMetricsService_ArrowMetricsServer) error
ArrowMetrics mocks base method.
func (*MockArrowMetricsServiceServer) EXPECT ¶
func (m *MockArrowMetricsServiceServer) EXPECT() *MockArrowMetricsServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockArrowMetricsServiceServerMockRecorder ¶
type MockArrowMetricsServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowMetricsServiceServerMockRecorder is the mock recorder for MockArrowMetricsServiceServer.
func (*MockArrowMetricsServiceServerMockRecorder) ArrowMetrics ¶
func (mr *MockArrowMetricsServiceServerMockRecorder) ArrowMetrics(arg0 interface{}) *gomock.Call
ArrowMetrics indicates an expected call of ArrowMetrics.
type MockArrowMetricsService_ArrowMetricsClient ¶
type MockArrowMetricsService_ArrowMetricsClient struct {
// contains filtered or unexported fields
}
MockArrowMetricsService_ArrowMetricsClient is a mock of ArrowMetricsService_ArrowMetricsClient interface.
func NewMockArrowMetricsService_ArrowMetricsClient ¶
func NewMockArrowMetricsService_ArrowMetricsClient(ctrl *gomock.Controller) *MockArrowMetricsService_ArrowMetricsClient
NewMockArrowMetricsService_ArrowMetricsClient creates a new mock instance.
func (*MockArrowMetricsService_ArrowMetricsClient) CloseSend ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) CloseSend() error
CloseSend mocks base method.
func (*MockArrowMetricsService_ArrowMetricsClient) Context ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) Context() context.Context
Context mocks base method.
func (*MockArrowMetricsService_ArrowMetricsClient) EXPECT ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) EXPECT() *MockArrowMetricsService_ArrowMetricsClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockArrowMetricsService_ArrowMetricsClient) Header ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockArrowMetricsService_ArrowMetricsClient) Recv ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) Recv() (*v1.BatchStatus, error)
Recv mocks base method.
func (*MockArrowMetricsService_ArrowMetricsClient) RecvMsg ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockArrowMetricsService_ArrowMetricsClient) Send ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) Send(arg0 *v1.BatchArrowRecords) error
Send mocks base method.
func (*MockArrowMetricsService_ArrowMetricsClient) SendMsg ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockArrowMetricsService_ArrowMetricsClient) Trailer ¶
func (m *MockArrowMetricsService_ArrowMetricsClient) Trailer() metadata.MD
Trailer mocks base method.
type MockArrowMetricsService_ArrowMetricsClientMockRecorder ¶
type MockArrowMetricsService_ArrowMetricsClientMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowMetricsService_ArrowMetricsClientMockRecorder is the mock recorder for MockArrowMetricsService_ArrowMetricsClient.
func (*MockArrowMetricsService_ArrowMetricsClientMockRecorder) CloseSend ¶
func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockArrowMetricsService_ArrowMetricsClientMockRecorder) Context ¶
func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockArrowMetricsService_ArrowMetricsClientMockRecorder) Header ¶
func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockArrowMetricsService_ArrowMetricsClientMockRecorder) Recv ¶
func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockArrowMetricsService_ArrowMetricsClientMockRecorder) RecvMsg ¶
func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockArrowMetricsService_ArrowMetricsClientMockRecorder) Send ¶
func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockArrowMetricsService_ArrowMetricsClientMockRecorder) SendMsg ¶
func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockArrowMetricsService_ArrowMetricsClientMockRecorder) Trailer ¶
func (mr *MockArrowMetricsService_ArrowMetricsClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockArrowMetricsService_ArrowMetricsServer ¶
type MockArrowMetricsService_ArrowMetricsServer struct {
// contains filtered or unexported fields
}
MockArrowMetricsService_ArrowMetricsServer is a mock of ArrowMetricsService_ArrowMetricsServer interface.
func NewMockArrowMetricsService_ArrowMetricsServer ¶
func NewMockArrowMetricsService_ArrowMetricsServer(ctrl *gomock.Controller) *MockArrowMetricsService_ArrowMetricsServer
NewMockArrowMetricsService_ArrowMetricsServer creates a new mock instance.
func (*MockArrowMetricsService_ArrowMetricsServer) Context ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) Context() context.Context
Context mocks base method.
func (*MockArrowMetricsService_ArrowMetricsServer) EXPECT ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) EXPECT() *MockArrowMetricsService_ArrowMetricsServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockArrowMetricsService_ArrowMetricsServer) Recv ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) Recv() (*v1.BatchArrowRecords, error)
Recv mocks base method.
func (*MockArrowMetricsService_ArrowMetricsServer) RecvMsg ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockArrowMetricsService_ArrowMetricsServer) Send ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) Send(arg0 *v1.BatchStatus) error
Send mocks base method.
func (*MockArrowMetricsService_ArrowMetricsServer) SendHeader ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockArrowMetricsService_ArrowMetricsServer) SendMsg ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockArrowMetricsService_ArrowMetricsServer) SetHeader ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockArrowMetricsService_ArrowMetricsServer) SetTrailer ¶
func (m *MockArrowMetricsService_ArrowMetricsServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockArrowMetricsService_ArrowMetricsServerMockRecorder ¶
type MockArrowMetricsService_ArrowMetricsServerMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowMetricsService_ArrowMetricsServerMockRecorder is the mock recorder for MockArrowMetricsService_ArrowMetricsServer.
func (*MockArrowMetricsService_ArrowMetricsServerMockRecorder) Context ¶
func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockArrowMetricsService_ArrowMetricsServerMockRecorder) Recv ¶
func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockArrowMetricsService_ArrowMetricsServerMockRecorder) RecvMsg ¶
func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockArrowMetricsService_ArrowMetricsServerMockRecorder) Send ¶
func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockArrowMetricsService_ArrowMetricsServerMockRecorder) SendHeader ¶
func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockArrowMetricsService_ArrowMetricsServerMockRecorder) SendMsg ¶
func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockArrowMetricsService_ArrowMetricsServerMockRecorder) SetHeader ¶
func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockArrowMetricsService_ArrowMetricsServerMockRecorder) SetTrailer ¶
func (mr *MockArrowMetricsService_ArrowMetricsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockArrowStreamServiceClient ¶
type MockArrowStreamServiceClient struct {
// contains filtered or unexported fields
}
MockArrowStreamServiceClient is a mock of ArrowStreamServiceClient interface.
func NewMockArrowStreamServiceClient ¶
func NewMockArrowStreamServiceClient(ctrl *gomock.Controller) *MockArrowStreamServiceClient
NewMockArrowStreamServiceClient creates a new mock instance.
func (*MockArrowStreamServiceClient) ArrowStream ¶
func (m *MockArrowStreamServiceClient) ArrowStream(arg0 context.Context, arg1 ...grpc.CallOption) (v1.ArrowStreamService_ArrowStreamClient, error)
ArrowStream mocks base method.
func (*MockArrowStreamServiceClient) EXPECT ¶
func (m *MockArrowStreamServiceClient) EXPECT() *MockArrowStreamServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockArrowStreamServiceClientMockRecorder ¶
type MockArrowStreamServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowStreamServiceClientMockRecorder is the mock recorder for MockArrowStreamServiceClient.
func (*MockArrowStreamServiceClientMockRecorder) ArrowStream ¶
func (mr *MockArrowStreamServiceClientMockRecorder) ArrowStream(arg0 interface{}, arg1 ...interface{}) *gomock.Call
ArrowStream indicates an expected call of ArrowStream.
type MockArrowStreamServiceServer ¶
type MockArrowStreamServiceServer struct {
// contains filtered or unexported fields
}
MockArrowStreamServiceServer is a mock of ArrowStreamServiceServer interface.
func NewMockArrowStreamServiceServer ¶
func NewMockArrowStreamServiceServer(ctrl *gomock.Controller) *MockArrowStreamServiceServer
NewMockArrowStreamServiceServer creates a new mock instance.
func (*MockArrowStreamServiceServer) ArrowStream ¶
func (m *MockArrowStreamServiceServer) ArrowStream(arg0 v1.ArrowStreamService_ArrowStreamServer) error
ArrowStream mocks base method.
func (*MockArrowStreamServiceServer) EXPECT ¶
func (m *MockArrowStreamServiceServer) EXPECT() *MockArrowStreamServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockArrowStreamServiceServerMockRecorder ¶
type MockArrowStreamServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowStreamServiceServerMockRecorder is the mock recorder for MockArrowStreamServiceServer.
func (*MockArrowStreamServiceServerMockRecorder) ArrowStream ¶
func (mr *MockArrowStreamServiceServerMockRecorder) ArrowStream(arg0 interface{}) *gomock.Call
ArrowStream indicates an expected call of ArrowStream.
type MockArrowStreamService_ArrowStreamClient ¶
type MockArrowStreamService_ArrowStreamClient struct {
// contains filtered or unexported fields
}
MockArrowStreamService_ArrowStreamClient is a mock of ArrowStreamService_ArrowStreamClient interface.
func NewMockArrowStreamService_ArrowStreamClient ¶
func NewMockArrowStreamService_ArrowStreamClient(ctrl *gomock.Controller) *MockArrowStreamService_ArrowStreamClient
NewMockArrowStreamService_ArrowStreamClient creates a new mock instance.
func (*MockArrowStreamService_ArrowStreamClient) CloseSend ¶
func (m *MockArrowStreamService_ArrowStreamClient) CloseSend() error
CloseSend mocks base method.
func (*MockArrowStreamService_ArrowStreamClient) Context ¶
func (m *MockArrowStreamService_ArrowStreamClient) Context() context.Context
Context mocks base method.
func (*MockArrowStreamService_ArrowStreamClient) EXPECT ¶
func (m *MockArrowStreamService_ArrowStreamClient) EXPECT() *MockArrowStreamService_ArrowStreamClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockArrowStreamService_ArrowStreamClient) Header ¶
func (m *MockArrowStreamService_ArrowStreamClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockArrowStreamService_ArrowStreamClient) Recv ¶
func (m *MockArrowStreamService_ArrowStreamClient) Recv() (*v1.BatchStatus, error)
Recv mocks base method.
func (*MockArrowStreamService_ArrowStreamClient) RecvMsg ¶
func (m *MockArrowStreamService_ArrowStreamClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockArrowStreamService_ArrowStreamClient) Send ¶
func (m *MockArrowStreamService_ArrowStreamClient) Send(arg0 *v1.BatchArrowRecords) error
Send mocks base method.
func (*MockArrowStreamService_ArrowStreamClient) SendMsg ¶
func (m *MockArrowStreamService_ArrowStreamClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockArrowStreamService_ArrowStreamClient) Trailer ¶
func (m *MockArrowStreamService_ArrowStreamClient) Trailer() metadata.MD
Trailer mocks base method.
type MockArrowStreamService_ArrowStreamClientMockRecorder ¶
type MockArrowStreamService_ArrowStreamClientMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowStreamService_ArrowStreamClientMockRecorder is the mock recorder for MockArrowStreamService_ArrowStreamClient.
func (*MockArrowStreamService_ArrowStreamClientMockRecorder) CloseSend ¶
func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockArrowStreamService_ArrowStreamClientMockRecorder) Context ¶
func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockArrowStreamService_ArrowStreamClientMockRecorder) Header ¶
func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockArrowStreamService_ArrowStreamClientMockRecorder) Recv ¶
func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockArrowStreamService_ArrowStreamClientMockRecorder) RecvMsg ¶
func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockArrowStreamService_ArrowStreamClientMockRecorder) Send ¶
func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockArrowStreamService_ArrowStreamClientMockRecorder) SendMsg ¶
func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockArrowStreamService_ArrowStreamClientMockRecorder) Trailer ¶
func (mr *MockArrowStreamService_ArrowStreamClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockArrowStreamService_ArrowStreamServer ¶
type MockArrowStreamService_ArrowStreamServer struct {
// contains filtered or unexported fields
}
MockArrowStreamService_ArrowStreamServer is a mock of ArrowStreamService_ArrowStreamServer interface.
func NewMockArrowStreamService_ArrowStreamServer ¶
func NewMockArrowStreamService_ArrowStreamServer(ctrl *gomock.Controller) *MockArrowStreamService_ArrowStreamServer
NewMockArrowStreamService_ArrowStreamServer creates a new mock instance.
func (*MockArrowStreamService_ArrowStreamServer) Context ¶
func (m *MockArrowStreamService_ArrowStreamServer) Context() context.Context
Context mocks base method.
func (*MockArrowStreamService_ArrowStreamServer) EXPECT ¶
func (m *MockArrowStreamService_ArrowStreamServer) EXPECT() *MockArrowStreamService_ArrowStreamServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockArrowStreamService_ArrowStreamServer) Recv ¶
func (m *MockArrowStreamService_ArrowStreamServer) Recv() (*v1.BatchArrowRecords, error)
Recv mocks base method.
func (*MockArrowStreamService_ArrowStreamServer) RecvMsg ¶
func (m *MockArrowStreamService_ArrowStreamServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockArrowStreamService_ArrowStreamServer) Send ¶
func (m *MockArrowStreamService_ArrowStreamServer) Send(arg0 *v1.BatchStatus) error
Send mocks base method.
func (*MockArrowStreamService_ArrowStreamServer) SendHeader ¶
func (m *MockArrowStreamService_ArrowStreamServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockArrowStreamService_ArrowStreamServer) SendMsg ¶
func (m *MockArrowStreamService_ArrowStreamServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockArrowStreamService_ArrowStreamServer) SetHeader ¶
func (m *MockArrowStreamService_ArrowStreamServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockArrowStreamService_ArrowStreamServer) SetTrailer ¶
func (m *MockArrowStreamService_ArrowStreamServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockArrowStreamService_ArrowStreamServerMockRecorder ¶
type MockArrowStreamService_ArrowStreamServerMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowStreamService_ArrowStreamServerMockRecorder is the mock recorder for MockArrowStreamService_ArrowStreamServer.
func (*MockArrowStreamService_ArrowStreamServerMockRecorder) Context ¶
func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockArrowStreamService_ArrowStreamServerMockRecorder) Recv ¶
func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockArrowStreamService_ArrowStreamServerMockRecorder) RecvMsg ¶
func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockArrowStreamService_ArrowStreamServerMockRecorder) Send ¶
func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockArrowStreamService_ArrowStreamServerMockRecorder) SendHeader ¶
func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockArrowStreamService_ArrowStreamServerMockRecorder) SendMsg ¶
func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockArrowStreamService_ArrowStreamServerMockRecorder) SetHeader ¶
func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockArrowStreamService_ArrowStreamServerMockRecorder) SetTrailer ¶
func (mr *MockArrowStreamService_ArrowStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockArrowTracesServiceClient ¶
type MockArrowTracesServiceClient struct {
// contains filtered or unexported fields
}
MockArrowTracesServiceClient is a mock of ArrowTracesServiceClient interface.
func NewMockArrowTracesServiceClient ¶
func NewMockArrowTracesServiceClient(ctrl *gomock.Controller) *MockArrowTracesServiceClient
NewMockArrowTracesServiceClient creates a new mock instance.
func (*MockArrowTracesServiceClient) ArrowTraces ¶
func (m *MockArrowTracesServiceClient) ArrowTraces(arg0 context.Context, arg1 ...grpc.CallOption) (v1.ArrowTracesService_ArrowTracesClient, error)
ArrowTraces mocks base method.
func (*MockArrowTracesServiceClient) EXPECT ¶
func (m *MockArrowTracesServiceClient) EXPECT() *MockArrowTracesServiceClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockArrowTracesServiceClientMockRecorder ¶
type MockArrowTracesServiceClientMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowTracesServiceClientMockRecorder is the mock recorder for MockArrowTracesServiceClient.
func (*MockArrowTracesServiceClientMockRecorder) ArrowTraces ¶
func (mr *MockArrowTracesServiceClientMockRecorder) ArrowTraces(arg0 interface{}, arg1 ...interface{}) *gomock.Call
ArrowTraces indicates an expected call of ArrowTraces.
type MockArrowTracesServiceServer ¶
type MockArrowTracesServiceServer struct {
// contains filtered or unexported fields
}
MockArrowTracesServiceServer is a mock of ArrowTracesServiceServer interface.
func NewMockArrowTracesServiceServer ¶
func NewMockArrowTracesServiceServer(ctrl *gomock.Controller) *MockArrowTracesServiceServer
NewMockArrowTracesServiceServer creates a new mock instance.
func (*MockArrowTracesServiceServer) ArrowTraces ¶
func (m *MockArrowTracesServiceServer) ArrowTraces(arg0 v1.ArrowTracesService_ArrowTracesServer) error
ArrowTraces mocks base method.
func (*MockArrowTracesServiceServer) EXPECT ¶
func (m *MockArrowTracesServiceServer) EXPECT() *MockArrowTracesServiceServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockArrowTracesServiceServerMockRecorder ¶
type MockArrowTracesServiceServerMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowTracesServiceServerMockRecorder is the mock recorder for MockArrowTracesServiceServer.
func (*MockArrowTracesServiceServerMockRecorder) ArrowTraces ¶
func (mr *MockArrowTracesServiceServerMockRecorder) ArrowTraces(arg0 interface{}) *gomock.Call
ArrowTraces indicates an expected call of ArrowTraces.
type MockArrowTracesService_ArrowTracesClient ¶
type MockArrowTracesService_ArrowTracesClient struct {
// contains filtered or unexported fields
}
MockArrowTracesService_ArrowTracesClient is a mock of ArrowTracesService_ArrowTracesClient interface.
func NewMockArrowTracesService_ArrowTracesClient ¶
func NewMockArrowTracesService_ArrowTracesClient(ctrl *gomock.Controller) *MockArrowTracesService_ArrowTracesClient
NewMockArrowTracesService_ArrowTracesClient creates a new mock instance.
func (*MockArrowTracesService_ArrowTracesClient) CloseSend ¶
func (m *MockArrowTracesService_ArrowTracesClient) CloseSend() error
CloseSend mocks base method.
func (*MockArrowTracesService_ArrowTracesClient) Context ¶
func (m *MockArrowTracesService_ArrowTracesClient) Context() context.Context
Context mocks base method.
func (*MockArrowTracesService_ArrowTracesClient) EXPECT ¶
func (m *MockArrowTracesService_ArrowTracesClient) EXPECT() *MockArrowTracesService_ArrowTracesClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockArrowTracesService_ArrowTracesClient) Header ¶
func (m *MockArrowTracesService_ArrowTracesClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockArrowTracesService_ArrowTracesClient) Recv ¶
func (m *MockArrowTracesService_ArrowTracesClient) Recv() (*v1.BatchStatus, error)
Recv mocks base method.
func (*MockArrowTracesService_ArrowTracesClient) RecvMsg ¶
func (m *MockArrowTracesService_ArrowTracesClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockArrowTracesService_ArrowTracesClient) Send ¶
func (m *MockArrowTracesService_ArrowTracesClient) Send(arg0 *v1.BatchArrowRecords) error
Send mocks base method.
func (*MockArrowTracesService_ArrowTracesClient) SendMsg ¶
func (m *MockArrowTracesService_ArrowTracesClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockArrowTracesService_ArrowTracesClient) Trailer ¶
func (m *MockArrowTracesService_ArrowTracesClient) Trailer() metadata.MD
Trailer mocks base method.
type MockArrowTracesService_ArrowTracesClientMockRecorder ¶
type MockArrowTracesService_ArrowTracesClientMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowTracesService_ArrowTracesClientMockRecorder is the mock recorder for MockArrowTracesService_ArrowTracesClient.
func (*MockArrowTracesService_ArrowTracesClientMockRecorder) CloseSend ¶
func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockArrowTracesService_ArrowTracesClientMockRecorder) Context ¶
func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockArrowTracesService_ArrowTracesClientMockRecorder) Header ¶
func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockArrowTracesService_ArrowTracesClientMockRecorder) Recv ¶
func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockArrowTracesService_ArrowTracesClientMockRecorder) RecvMsg ¶
func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockArrowTracesService_ArrowTracesClientMockRecorder) Send ¶
func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockArrowTracesService_ArrowTracesClientMockRecorder) SendMsg ¶
func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockArrowTracesService_ArrowTracesClientMockRecorder) Trailer ¶
func (mr *MockArrowTracesService_ArrowTracesClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockArrowTracesService_ArrowTracesServer ¶
type MockArrowTracesService_ArrowTracesServer struct {
// contains filtered or unexported fields
}
MockArrowTracesService_ArrowTracesServer is a mock of ArrowTracesService_ArrowTracesServer interface.
func NewMockArrowTracesService_ArrowTracesServer ¶
func NewMockArrowTracesService_ArrowTracesServer(ctrl *gomock.Controller) *MockArrowTracesService_ArrowTracesServer
NewMockArrowTracesService_ArrowTracesServer creates a new mock instance.
func (*MockArrowTracesService_ArrowTracesServer) Context ¶
func (m *MockArrowTracesService_ArrowTracesServer) Context() context.Context
Context mocks base method.
func (*MockArrowTracesService_ArrowTracesServer) EXPECT ¶
func (m *MockArrowTracesService_ArrowTracesServer) EXPECT() *MockArrowTracesService_ArrowTracesServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockArrowTracesService_ArrowTracesServer) Recv ¶
func (m *MockArrowTracesService_ArrowTracesServer) Recv() (*v1.BatchArrowRecords, error)
Recv mocks base method.
func (*MockArrowTracesService_ArrowTracesServer) RecvMsg ¶
func (m *MockArrowTracesService_ArrowTracesServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockArrowTracesService_ArrowTracesServer) Send ¶
func (m *MockArrowTracesService_ArrowTracesServer) Send(arg0 *v1.BatchStatus) error
Send mocks base method.
func (*MockArrowTracesService_ArrowTracesServer) SendHeader ¶
func (m *MockArrowTracesService_ArrowTracesServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockArrowTracesService_ArrowTracesServer) SendMsg ¶
func (m *MockArrowTracesService_ArrowTracesServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockArrowTracesService_ArrowTracesServer) SetHeader ¶
func (m *MockArrowTracesService_ArrowTracesServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockArrowTracesService_ArrowTracesServer) SetTrailer ¶
func (m *MockArrowTracesService_ArrowTracesServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockArrowTracesService_ArrowTracesServerMockRecorder ¶
type MockArrowTracesService_ArrowTracesServerMockRecorder struct {
// contains filtered or unexported fields
}
MockArrowTracesService_ArrowTracesServerMockRecorder is the mock recorder for MockArrowTracesService_ArrowTracesServer.
func (*MockArrowTracesService_ArrowTracesServerMockRecorder) Context ¶
func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockArrowTracesService_ArrowTracesServerMockRecorder) Recv ¶
func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockArrowTracesService_ArrowTracesServerMockRecorder) RecvMsg ¶
func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockArrowTracesService_ArrowTracesServerMockRecorder) Send ¶
func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockArrowTracesService_ArrowTracesServerMockRecorder) SendHeader ¶
func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockArrowTracesService_ArrowTracesServerMockRecorder) SendMsg ¶
func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockArrowTracesService_ArrowTracesServerMockRecorder) SetHeader ¶
func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockArrowTracesService_ArrowTracesServerMockRecorder) SetTrailer ¶
func (mr *MockArrowTracesService_ArrowTracesServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.