Documentation ¶
Overview ¶
Package mock_rpc is a generated GoMock package.
Mocks for gRPC services.
Package mock_rpc is a generated GoMock package.
Package mock_rpc is a generated GoMock package.
Package mock_rpc is a generated GoMock package.
Package mock_rpc is a generated GoMock package.
Package mock_rpc is a generated GoMock package.
Index ¶
- type MockAgentConfigurationClient
- type MockAgentConfigurationClientMockRecorder
- type MockAgentConfiguration_GetConfigurationClient
- func (m *MockAgentConfiguration_GetConfigurationClient) CloseSend() error
- func (m *MockAgentConfiguration_GetConfigurationClient) Context() context.Context
- func (m *MockAgentConfiguration_GetConfigurationClient) EXPECT() *MockAgentConfiguration_GetConfigurationClientMockRecorder
- func (m *MockAgentConfiguration_GetConfigurationClient) Header() (metadata.MD, error)
- func (m *MockAgentConfiguration_GetConfigurationClient) Recv() (*rpc.ConfigurationResponse, error)
- func (m *MockAgentConfiguration_GetConfigurationClient) RecvMsg(arg0 interface{}) error
- func (m *MockAgentConfiguration_GetConfigurationClient) SendMsg(arg0 interface{}) error
- func (m *MockAgentConfiguration_GetConfigurationClient) Trailer() metadata.MD
- type MockAgentConfiguration_GetConfigurationClientMockRecorder
- func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Context() *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Header() *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Recv() *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Trailer() *gomock.Call
- type MockAgentConfiguration_GetConfigurationServer
- func (m *MockAgentConfiguration_GetConfigurationServer) Context() context.Context
- func (m *MockAgentConfiguration_GetConfigurationServer) EXPECT() *MockAgentConfiguration_GetConfigurationServerMockRecorder
- func (m *MockAgentConfiguration_GetConfigurationServer) RecvMsg(arg0 interface{}) error
- func (m *MockAgentConfiguration_GetConfigurationServer) Send(arg0 *rpc.ConfigurationResponse) error
- func (m *MockAgentConfiguration_GetConfigurationServer) SendHeader(arg0 metadata.MD) error
- func (m *MockAgentConfiguration_GetConfigurationServer) SendMsg(arg0 interface{}) error
- func (m *MockAgentConfiguration_GetConfigurationServer) SetHeader(arg0 metadata.MD) error
- func (m *MockAgentConfiguration_GetConfigurationServer) SetTrailer(arg0 metadata.MD)
- type MockAgentConfiguration_GetConfigurationServerMockRecorder
- func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) Context() *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockClientConnInterface
- func (m *MockClientConnInterface) EXPECT() *MockClientConnInterfaceMockRecorder
- func (m *MockClientConnInterface) Invoke(arg0 context.Context, arg1 string, arg2, arg3 interface{}, ...) error
- func (m *MockClientConnInterface) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, ...) (grpc.ClientStream, error)
- type MockClientConnInterfaceMockRecorder
- type MockClientStream
- func (m *MockClientStream) CloseSend() error
- func (m *MockClientStream) Context() context.Context
- func (m *MockClientStream) EXPECT() *MockClientStreamMockRecorder
- func (m *MockClientStream) Header() (metadata.MD, error)
- func (m *MockClientStream) RecvMsg(arg0 interface{}) error
- func (m *MockClientStream) SendMsg(arg0 interface{}) error
- func (m *MockClientStream) Trailer() metadata.MD
- type MockClientStreamMockRecorder
- func (mr *MockClientStreamMockRecorder) CloseSend() *gomock.Call
- func (mr *MockClientStreamMockRecorder) Context() *gomock.Call
- func (mr *MockClientStreamMockRecorder) Header() *gomock.Call
- func (mr *MockClientStreamMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockClientStreamMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockClientStreamMockRecorder) Trailer() *gomock.Call
- type MockConfigurationWatcherInterface
- type MockConfigurationWatcherInterfaceMockRecorder
- type MockGitlabAccess_MakeRequestServer
- func (m *MockGitlabAccess_MakeRequestServer) Context() context.Context
- func (m *MockGitlabAccess_MakeRequestServer) EXPECT() *MockGitlabAccess_MakeRequestServerMockRecorder
- func (m *MockGitlabAccess_MakeRequestServer) Recv() (*grpctool.HttpRequest, error)
- func (m *MockGitlabAccess_MakeRequestServer) RecvMsg(arg0 interface{}) error
- func (m *MockGitlabAccess_MakeRequestServer) Send(arg0 *grpctool.HttpResponse) error
- func (m *MockGitlabAccess_MakeRequestServer) SendHeader(arg0 metadata.MD) error
- func (m *MockGitlabAccess_MakeRequestServer) SendMsg(arg0 interface{}) error
- func (m *MockGitlabAccess_MakeRequestServer) SetHeader(arg0 metadata.MD) error
- func (m *MockGitlabAccess_MakeRequestServer) SetTrailer(arg0 metadata.MD)
- type MockGitlabAccess_MakeRequestServerMockRecorder
- func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Context() *gomock.Call
- func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Recv() *gomock.Call
- func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockGitopsClient
- type MockGitopsClientMockRecorder
- type MockGitops_GetObjectsToSynchronizeClient
- func (m *MockGitops_GetObjectsToSynchronizeClient) CloseSend() error
- func (m *MockGitops_GetObjectsToSynchronizeClient) Context() context.Context
- func (m *MockGitops_GetObjectsToSynchronizeClient) EXPECT() *MockGitops_GetObjectsToSynchronizeClientMockRecorder
- func (m *MockGitops_GetObjectsToSynchronizeClient) Header() (metadata.MD, error)
- func (m *MockGitops_GetObjectsToSynchronizeClient) Recv() (*rpc.ObjectsToSynchronizeResponse, error)
- func (m *MockGitops_GetObjectsToSynchronizeClient) RecvMsg(arg0 interface{}) error
- func (m *MockGitops_GetObjectsToSynchronizeClient) SendMsg(arg0 interface{}) error
- func (m *MockGitops_GetObjectsToSynchronizeClient) Trailer() metadata.MD
- type MockGitops_GetObjectsToSynchronizeClientMockRecorder
- func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Context() *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Header() *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Recv() *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Trailer() *gomock.Call
- type MockGitops_GetObjectsToSynchronizeServer
- func (m *MockGitops_GetObjectsToSynchronizeServer) Context() context.Context
- func (m *MockGitops_GetObjectsToSynchronizeServer) EXPECT() *MockGitops_GetObjectsToSynchronizeServerMockRecorder
- func (m *MockGitops_GetObjectsToSynchronizeServer) RecvMsg(arg0 interface{}) error
- func (m *MockGitops_GetObjectsToSynchronizeServer) Send(arg0 *rpc.ObjectsToSynchronizeResponse) error
- func (m *MockGitops_GetObjectsToSynchronizeServer) SendHeader(arg0 metadata.MD) error
- func (m *MockGitops_GetObjectsToSynchronizeServer) SendMsg(arg0 interface{}) error
- func (m *MockGitops_GetObjectsToSynchronizeServer) SetHeader(arg0 metadata.MD) error
- func (m *MockGitops_GetObjectsToSynchronizeServer) SetTrailer(arg0 metadata.MD)
- type MockGitops_GetObjectsToSynchronizeServerMockRecorder
- func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) Context() *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockInboundGrpcToOutboundHttpStream
- func (m *MockInboundGrpcToOutboundHttpStream) Context() context.Context
- func (m *MockInboundGrpcToOutboundHttpStream) EXPECT() *MockInboundGrpcToOutboundHttpStreamMockRecorder
- func (m *MockInboundGrpcToOutboundHttpStream) RecvMsg(arg0 interface{}) error
- func (m *MockInboundGrpcToOutboundHttpStream) Send(arg0 *grpctool.HttpResponse) error
- func (m *MockInboundGrpcToOutboundHttpStream) SendHeader(arg0 metadata.MD) error
- func (m *MockInboundGrpcToOutboundHttpStream) SendMsg(arg0 interface{}) error
- func (m *MockInboundGrpcToOutboundHttpStream) SetHeader(arg0 metadata.MD) error
- func (m *MockInboundGrpcToOutboundHttpStream) SetTrailer(arg0 metadata.MD)
- type MockInboundGrpcToOutboundHttpStreamMockRecorder
- func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) Context() *gomock.Call
- func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockObjectsToSynchronizeWatcherInterface
- type MockObjectsToSynchronizeWatcherInterfaceMockRecorder
- type MockPoolConn
- func (m *MockPoolConn) Done()
- func (m *MockPoolConn) EXPECT() *MockPoolConnMockRecorder
- func (m *MockPoolConn) Invoke(arg0 context.Context, arg1 string, arg2, arg3 interface{}, ...) error
- func (m *MockPoolConn) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, ...) (grpc.ClientStream, error)
- type MockPoolConnMockRecorder
- type MockResponseWriterFlusher
- func (m *MockResponseWriterFlusher) EXPECT() *MockResponseWriterFlusherMockRecorder
- func (m *MockResponseWriterFlusher) Flush()
- func (m *MockResponseWriterFlusher) Header() http.Header
- func (m *MockResponseWriterFlusher) Write(arg0 []byte) (int, error)
- func (m *MockResponseWriterFlusher) WriteHeader(arg0 int)
- type MockResponseWriterFlusherMockRecorder
- func (mr *MockResponseWriterFlusherMockRecorder) Flush() *gomock.Call
- func (mr *MockResponseWriterFlusherMockRecorder) Header() *gomock.Call
- func (mr *MockResponseWriterFlusherMockRecorder) Write(arg0 interface{}) *gomock.Call
- func (mr *MockResponseWriterFlusherMockRecorder) WriteHeader(arg0 interface{}) *gomock.Call
- type MockServerStream
- func (m *MockServerStream) Context() context.Context
- func (m *MockServerStream) EXPECT() *MockServerStreamMockRecorder
- func (m *MockServerStream) RecvMsg(arg0 interface{}) error
- func (m *MockServerStream) SendHeader(arg0 metadata.MD) error
- func (m *MockServerStream) SendMsg(arg0 interface{}) error
- func (m *MockServerStream) SetHeader(arg0 metadata.MD) error
- func (m *MockServerStream) SetTrailer(arg0 metadata.MD)
- type MockServerStreamMockRecorder
- func (mr *MockServerStreamMockRecorder) Context() *gomock.Call
- func (mr *MockServerStreamMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockServerStreamMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockServerStreamMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockServerStreamMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockServerStreamMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type MockServerTransportStream
- func (m *MockServerTransportStream) EXPECT() *MockServerTransportStreamMockRecorder
- func (m *MockServerTransportStream) Method() string
- func (m *MockServerTransportStream) SendHeader(arg0 metadata.MD) error
- func (m *MockServerTransportStream) SetHeader(arg0 metadata.MD) error
- func (m *MockServerTransportStream) SetTrailer(arg0 metadata.MD) error
- type MockServerTransportStreamMockRecorder
- func (mr *MockServerTransportStreamMockRecorder) Method() *gomock.Call
- func (mr *MockServerTransportStreamMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockServerTransportStreamMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockServerTransportStreamMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type ResponseWriterFlusher
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAgentConfigurationClient ¶
type MockAgentConfigurationClient struct {
// contains filtered or unexported fields
}
MockAgentConfigurationClient is a mock of AgentConfigurationClient interface.
func NewMockAgentConfigurationClient ¶
func NewMockAgentConfigurationClient(ctrl *gomock.Controller) *MockAgentConfigurationClient
NewMockAgentConfigurationClient creates a new mock instance.
func (*MockAgentConfigurationClient) EXPECT ¶
func (m *MockAgentConfigurationClient) EXPECT() *MockAgentConfigurationClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentConfigurationClient) GetConfiguration ¶
func (m *MockAgentConfigurationClient) GetConfiguration(arg0 context.Context, arg1 *rpc.ConfigurationRequest, arg2 ...grpc.CallOption) (rpc.AgentConfiguration_GetConfigurationClient, error)
GetConfiguration mocks base method.
type MockAgentConfigurationClientMockRecorder ¶
type MockAgentConfigurationClientMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentConfigurationClientMockRecorder is the mock recorder for MockAgentConfigurationClient.
func (*MockAgentConfigurationClientMockRecorder) GetConfiguration ¶
func (mr *MockAgentConfigurationClientMockRecorder) GetConfiguration(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetConfiguration indicates an expected call of GetConfiguration.
type MockAgentConfiguration_GetConfigurationClient ¶
type MockAgentConfiguration_GetConfigurationClient struct {
// contains filtered or unexported fields
}
MockAgentConfiguration_GetConfigurationClient is a mock of AgentConfiguration_GetConfigurationClient interface.
func NewMockAgentConfiguration_GetConfigurationClient ¶
func NewMockAgentConfiguration_GetConfigurationClient(ctrl *gomock.Controller) *MockAgentConfiguration_GetConfigurationClient
NewMockAgentConfiguration_GetConfigurationClient creates a new mock instance.
func (*MockAgentConfiguration_GetConfigurationClient) CloseSend ¶
func (m *MockAgentConfiguration_GetConfigurationClient) CloseSend() error
CloseSend mocks base method.
func (*MockAgentConfiguration_GetConfigurationClient) Context ¶
func (m *MockAgentConfiguration_GetConfigurationClient) Context() context.Context
Context mocks base method.
func (*MockAgentConfiguration_GetConfigurationClient) EXPECT ¶
func (m *MockAgentConfiguration_GetConfigurationClient) EXPECT() *MockAgentConfiguration_GetConfigurationClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentConfiguration_GetConfigurationClient) Header ¶
func (m *MockAgentConfiguration_GetConfigurationClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockAgentConfiguration_GetConfigurationClient) Recv ¶
func (m *MockAgentConfiguration_GetConfigurationClient) Recv() (*rpc.ConfigurationResponse, error)
Recv mocks base method.
func (*MockAgentConfiguration_GetConfigurationClient) RecvMsg ¶
func (m *MockAgentConfiguration_GetConfigurationClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockAgentConfiguration_GetConfigurationClient) SendMsg ¶
func (m *MockAgentConfiguration_GetConfigurationClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockAgentConfiguration_GetConfigurationClient) Trailer ¶
func (m *MockAgentConfiguration_GetConfigurationClient) Trailer() metadata.MD
Trailer mocks base method.
type MockAgentConfiguration_GetConfigurationClientMockRecorder ¶
type MockAgentConfiguration_GetConfigurationClientMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentConfiguration_GetConfigurationClientMockRecorder is the mock recorder for MockAgentConfiguration_GetConfigurationClient.
func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) CloseSend ¶
func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Context ¶
func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Header ¶
func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Recv ¶
func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) RecvMsg ¶
func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) SendMsg ¶
func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Trailer ¶
func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockAgentConfiguration_GetConfigurationServer ¶
type MockAgentConfiguration_GetConfigurationServer struct {
// contains filtered or unexported fields
}
MockAgentConfiguration_GetConfigurationServer is a mock of AgentConfiguration_GetConfigurationServer interface.
func NewMockAgentConfiguration_GetConfigurationServer ¶
func NewMockAgentConfiguration_GetConfigurationServer(ctrl *gomock.Controller) *MockAgentConfiguration_GetConfigurationServer
NewMockAgentConfiguration_GetConfigurationServer creates a new mock instance.
func (*MockAgentConfiguration_GetConfigurationServer) Context ¶
func (m *MockAgentConfiguration_GetConfigurationServer) Context() context.Context
Context mocks base method.
func (*MockAgentConfiguration_GetConfigurationServer) EXPECT ¶
func (m *MockAgentConfiguration_GetConfigurationServer) EXPECT() *MockAgentConfiguration_GetConfigurationServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAgentConfiguration_GetConfigurationServer) RecvMsg ¶
func (m *MockAgentConfiguration_GetConfigurationServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockAgentConfiguration_GetConfigurationServer) Send ¶
func (m *MockAgentConfiguration_GetConfigurationServer) Send(arg0 *rpc.ConfigurationResponse) error
Send mocks base method.
func (*MockAgentConfiguration_GetConfigurationServer) SendHeader ¶
func (m *MockAgentConfiguration_GetConfigurationServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockAgentConfiguration_GetConfigurationServer) SendMsg ¶
func (m *MockAgentConfiguration_GetConfigurationServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockAgentConfiguration_GetConfigurationServer) SetHeader ¶
func (m *MockAgentConfiguration_GetConfigurationServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockAgentConfiguration_GetConfigurationServer) SetTrailer ¶
func (m *MockAgentConfiguration_GetConfigurationServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockAgentConfiguration_GetConfigurationServerMockRecorder ¶
type MockAgentConfiguration_GetConfigurationServerMockRecorder struct {
// contains filtered or unexported fields
}
MockAgentConfiguration_GetConfigurationServerMockRecorder is the mock recorder for MockAgentConfiguration_GetConfigurationServer.
func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) Context ¶
func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) RecvMsg ¶
func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) Send ¶
func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SendHeader ¶
func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SendMsg ¶
func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SetHeader ¶
func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SetTrailer ¶
func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockClientConnInterface ¶
type MockClientConnInterface struct {
// contains filtered or unexported fields
}
MockClientConnInterface is a mock of ClientConnInterface interface.
func NewMockClientConnInterface ¶
func NewMockClientConnInterface(ctrl *gomock.Controller) *MockClientConnInterface
NewMockClientConnInterface creates a new mock instance.
func (*MockClientConnInterface) EXPECT ¶
func (m *MockClientConnInterface) EXPECT() *MockClientConnInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClientConnInterface) Invoke ¶
func (m *MockClientConnInterface) Invoke(arg0 context.Context, arg1 string, arg2, arg3 interface{}, arg4 ...grpc.CallOption) error
Invoke mocks base method.
func (*MockClientConnInterface) NewStream ¶
func (m *MockClientConnInterface) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, arg3 ...grpc.CallOption) (grpc.ClientStream, error)
NewStream mocks base method.
type MockClientConnInterfaceMockRecorder ¶
type MockClientConnInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockClientConnInterfaceMockRecorder is the mock recorder for MockClientConnInterface.
func (*MockClientConnInterfaceMockRecorder) Invoke ¶
func (mr *MockClientConnInterfaceMockRecorder) Invoke(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
Invoke indicates an expected call of Invoke.
func (*MockClientConnInterfaceMockRecorder) NewStream ¶
func (mr *MockClientConnInterfaceMockRecorder) NewStream(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
NewStream indicates an expected call of NewStream.
type MockClientStream ¶
type MockClientStream struct {
// contains filtered or unexported fields
}
MockClientStream is a mock of ClientStream interface.
func InitMockClientStream ¶
func InitMockClientStream(ctrl *gomock.Controller, eof bool, msgs ...proto.Message) (*MockClientStream, []*gomock.Call)
func NewMockClientStream ¶
func NewMockClientStream(ctrl *gomock.Controller) *MockClientStream
NewMockClientStream creates a new mock instance.
func (*MockClientStream) CloseSend ¶
func (m *MockClientStream) CloseSend() error
CloseSend mocks base method.
func (*MockClientStream) Context ¶
func (m *MockClientStream) Context() context.Context
Context mocks base method.
func (*MockClientStream) EXPECT ¶
func (m *MockClientStream) EXPECT() *MockClientStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClientStream) Header ¶
func (m *MockClientStream) Header() (metadata.MD, error)
Header mocks base method.
func (*MockClientStream) RecvMsg ¶
func (m *MockClientStream) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockClientStream) SendMsg ¶
func (m *MockClientStream) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockClientStream) Trailer ¶
func (m *MockClientStream) Trailer() metadata.MD
Trailer mocks base method.
type MockClientStreamMockRecorder ¶
type MockClientStreamMockRecorder struct {
// contains filtered or unexported fields
}
MockClientStreamMockRecorder is the mock recorder for MockClientStream.
func (*MockClientStreamMockRecorder) CloseSend ¶
func (mr *MockClientStreamMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockClientStreamMockRecorder) Context ¶
func (mr *MockClientStreamMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockClientStreamMockRecorder) Header ¶
func (mr *MockClientStreamMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockClientStreamMockRecorder) RecvMsg ¶
func (mr *MockClientStreamMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockClientStreamMockRecorder) SendMsg ¶
func (mr *MockClientStreamMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockClientStreamMockRecorder) Trailer ¶
func (mr *MockClientStreamMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockConfigurationWatcherInterface ¶
type MockConfigurationWatcherInterface struct {
// contains filtered or unexported fields
}
MockConfigurationWatcherInterface is a mock of ConfigurationWatcherInterface interface.
func NewMockConfigurationWatcherInterface ¶
func NewMockConfigurationWatcherInterface(ctrl *gomock.Controller) *MockConfigurationWatcherInterface
NewMockConfigurationWatcherInterface creates a new mock instance.
func (*MockConfigurationWatcherInterface) EXPECT ¶
func (m *MockConfigurationWatcherInterface) EXPECT() *MockConfigurationWatcherInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConfigurationWatcherInterface) Watch ¶
func (m *MockConfigurationWatcherInterface) Watch(arg0 context.Context, arg1 rpc.ConfigurationCallback)
Watch mocks base method.
type MockConfigurationWatcherInterfaceMockRecorder ¶
type MockConfigurationWatcherInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockConfigurationWatcherInterfaceMockRecorder is the mock recorder for MockConfigurationWatcherInterface.
func (*MockConfigurationWatcherInterfaceMockRecorder) Watch ¶
func (mr *MockConfigurationWatcherInterfaceMockRecorder) Watch(arg0, arg1 interface{}) *gomock.Call
Watch indicates an expected call of Watch.
type MockGitlabAccess_MakeRequestServer ¶
type MockGitlabAccess_MakeRequestServer struct {
// contains filtered or unexported fields
}
MockGitlabAccess_MakeRequestServer is a mock of GitlabAccess_MakeRequestServer interface.
func NewMockGitlabAccess_MakeRequestServer ¶
func NewMockGitlabAccess_MakeRequestServer(ctrl *gomock.Controller) *MockGitlabAccess_MakeRequestServer
NewMockGitlabAccess_MakeRequestServer creates a new mock instance.
func (*MockGitlabAccess_MakeRequestServer) Context ¶
func (m *MockGitlabAccess_MakeRequestServer) Context() context.Context
Context mocks base method.
func (*MockGitlabAccess_MakeRequestServer) EXPECT ¶
func (m *MockGitlabAccess_MakeRequestServer) EXPECT() *MockGitlabAccess_MakeRequestServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockGitlabAccess_MakeRequestServer) Recv ¶
func (m *MockGitlabAccess_MakeRequestServer) Recv() (*grpctool.HttpRequest, error)
Recv mocks base method.
func (*MockGitlabAccess_MakeRequestServer) RecvMsg ¶
func (m *MockGitlabAccess_MakeRequestServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockGitlabAccess_MakeRequestServer) Send ¶
func (m *MockGitlabAccess_MakeRequestServer) Send(arg0 *grpctool.HttpResponse) error
Send mocks base method.
func (*MockGitlabAccess_MakeRequestServer) SendHeader ¶
func (m *MockGitlabAccess_MakeRequestServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockGitlabAccess_MakeRequestServer) SendMsg ¶
func (m *MockGitlabAccess_MakeRequestServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockGitlabAccess_MakeRequestServer) SetHeader ¶
func (m *MockGitlabAccess_MakeRequestServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockGitlabAccess_MakeRequestServer) SetTrailer ¶
func (m *MockGitlabAccess_MakeRequestServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockGitlabAccess_MakeRequestServerMockRecorder ¶
type MockGitlabAccess_MakeRequestServerMockRecorder struct {
// contains filtered or unexported fields
}
MockGitlabAccess_MakeRequestServerMockRecorder is the mock recorder for MockGitlabAccess_MakeRequestServer.
func (*MockGitlabAccess_MakeRequestServerMockRecorder) Context ¶
func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockGitlabAccess_MakeRequestServerMockRecorder) Recv ¶
func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockGitlabAccess_MakeRequestServerMockRecorder) RecvMsg ¶
func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockGitlabAccess_MakeRequestServerMockRecorder) Send ¶
func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockGitlabAccess_MakeRequestServerMockRecorder) SendHeader ¶
func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockGitlabAccess_MakeRequestServerMockRecorder) SendMsg ¶
func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockGitlabAccess_MakeRequestServerMockRecorder) SetHeader ¶
func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockGitlabAccess_MakeRequestServerMockRecorder) SetTrailer ¶
func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockGitopsClient ¶
type MockGitopsClient struct {
// contains filtered or unexported fields
}
MockGitopsClient is a mock of GitopsClient interface.
func NewMockGitopsClient ¶
func NewMockGitopsClient(ctrl *gomock.Controller) *MockGitopsClient
NewMockGitopsClient creates a new mock instance.
func (*MockGitopsClient) EXPECT ¶
func (m *MockGitopsClient) EXPECT() *MockGitopsClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockGitopsClient) GetObjectsToSynchronize ¶
func (m *MockGitopsClient) GetObjectsToSynchronize(arg0 context.Context, arg1 *rpc.ObjectsToSynchronizeRequest, arg2 ...grpc.CallOption) (rpc.Gitops_GetObjectsToSynchronizeClient, error)
GetObjectsToSynchronize mocks base method.
type MockGitopsClientMockRecorder ¶
type MockGitopsClientMockRecorder struct {
// contains filtered or unexported fields
}
MockGitopsClientMockRecorder is the mock recorder for MockGitopsClient.
func (*MockGitopsClientMockRecorder) GetObjectsToSynchronize ¶
func (mr *MockGitopsClientMockRecorder) GetObjectsToSynchronize(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
GetObjectsToSynchronize indicates an expected call of GetObjectsToSynchronize.
type MockGitops_GetObjectsToSynchronizeClient ¶
type MockGitops_GetObjectsToSynchronizeClient struct {
// contains filtered or unexported fields
}
MockGitops_GetObjectsToSynchronizeClient is a mock of Gitops_GetObjectsToSynchronizeClient interface.
func NewMockGitops_GetObjectsToSynchronizeClient ¶
func NewMockGitops_GetObjectsToSynchronizeClient(ctrl *gomock.Controller) *MockGitops_GetObjectsToSynchronizeClient
NewMockGitops_GetObjectsToSynchronizeClient creates a new mock instance.
func (*MockGitops_GetObjectsToSynchronizeClient) CloseSend ¶
func (m *MockGitops_GetObjectsToSynchronizeClient) CloseSend() error
CloseSend mocks base method.
func (*MockGitops_GetObjectsToSynchronizeClient) Context ¶
func (m *MockGitops_GetObjectsToSynchronizeClient) Context() context.Context
Context mocks base method.
func (*MockGitops_GetObjectsToSynchronizeClient) EXPECT ¶
func (m *MockGitops_GetObjectsToSynchronizeClient) EXPECT() *MockGitops_GetObjectsToSynchronizeClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockGitops_GetObjectsToSynchronizeClient) Header ¶
func (m *MockGitops_GetObjectsToSynchronizeClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockGitops_GetObjectsToSynchronizeClient) Recv ¶
func (m *MockGitops_GetObjectsToSynchronizeClient) Recv() (*rpc.ObjectsToSynchronizeResponse, error)
Recv mocks base method.
func (*MockGitops_GetObjectsToSynchronizeClient) RecvMsg ¶
func (m *MockGitops_GetObjectsToSynchronizeClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockGitops_GetObjectsToSynchronizeClient) SendMsg ¶
func (m *MockGitops_GetObjectsToSynchronizeClient) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockGitops_GetObjectsToSynchronizeClient) Trailer ¶
func (m *MockGitops_GetObjectsToSynchronizeClient) Trailer() metadata.MD
Trailer mocks base method.
type MockGitops_GetObjectsToSynchronizeClientMockRecorder ¶
type MockGitops_GetObjectsToSynchronizeClientMockRecorder struct {
// contains filtered or unexported fields
}
MockGitops_GetObjectsToSynchronizeClientMockRecorder is the mock recorder for MockGitops_GetObjectsToSynchronizeClient.
func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) CloseSend ¶
func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Context ¶
func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Header ¶
func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Recv ¶
func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) RecvMsg ¶
func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) SendMsg ¶
func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Trailer ¶
func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockGitops_GetObjectsToSynchronizeServer ¶
type MockGitops_GetObjectsToSynchronizeServer struct {
// contains filtered or unexported fields
}
MockGitops_GetObjectsToSynchronizeServer is a mock of Gitops_GetObjectsToSynchronizeServer interface.
func NewMockGitops_GetObjectsToSynchronizeServer ¶
func NewMockGitops_GetObjectsToSynchronizeServer(ctrl *gomock.Controller) *MockGitops_GetObjectsToSynchronizeServer
NewMockGitops_GetObjectsToSynchronizeServer creates a new mock instance.
func (*MockGitops_GetObjectsToSynchronizeServer) Context ¶
func (m *MockGitops_GetObjectsToSynchronizeServer) Context() context.Context
Context mocks base method.
func (*MockGitops_GetObjectsToSynchronizeServer) EXPECT ¶
func (m *MockGitops_GetObjectsToSynchronizeServer) EXPECT() *MockGitops_GetObjectsToSynchronizeServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockGitops_GetObjectsToSynchronizeServer) RecvMsg ¶
func (m *MockGitops_GetObjectsToSynchronizeServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockGitops_GetObjectsToSynchronizeServer) Send ¶
func (m *MockGitops_GetObjectsToSynchronizeServer) Send(arg0 *rpc.ObjectsToSynchronizeResponse) error
Send mocks base method.
func (*MockGitops_GetObjectsToSynchronizeServer) SendHeader ¶
func (m *MockGitops_GetObjectsToSynchronizeServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockGitops_GetObjectsToSynchronizeServer) SendMsg ¶
func (m *MockGitops_GetObjectsToSynchronizeServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockGitops_GetObjectsToSynchronizeServer) SetHeader ¶
func (m *MockGitops_GetObjectsToSynchronizeServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockGitops_GetObjectsToSynchronizeServer) SetTrailer ¶
func (m *MockGitops_GetObjectsToSynchronizeServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockGitops_GetObjectsToSynchronizeServerMockRecorder ¶
type MockGitops_GetObjectsToSynchronizeServerMockRecorder struct {
// contains filtered or unexported fields
}
MockGitops_GetObjectsToSynchronizeServerMockRecorder is the mock recorder for MockGitops_GetObjectsToSynchronizeServer.
func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) Context ¶
func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) RecvMsg ¶
func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) Send ¶
func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendHeader ¶
func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendMsg ¶
func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetHeader ¶
func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetTrailer ¶
func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockInboundGrpcToOutboundHttpStream ¶
type MockInboundGrpcToOutboundHttpStream struct {
// contains filtered or unexported fields
}
MockInboundGrpcToOutboundHttpStream is a mock of InboundGrpcToOutboundHttpStream interface.
func NewMockInboundGrpcToOutboundHttpStream ¶
func NewMockInboundGrpcToOutboundHttpStream(ctrl *gomock.Controller) *MockInboundGrpcToOutboundHttpStream
NewMockInboundGrpcToOutboundHttpStream creates a new mock instance.
func (*MockInboundGrpcToOutboundHttpStream) Context ¶
func (m *MockInboundGrpcToOutboundHttpStream) Context() context.Context
Context mocks base method.
func (*MockInboundGrpcToOutboundHttpStream) EXPECT ¶
func (m *MockInboundGrpcToOutboundHttpStream) EXPECT() *MockInboundGrpcToOutboundHttpStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockInboundGrpcToOutboundHttpStream) RecvMsg ¶
func (m *MockInboundGrpcToOutboundHttpStream) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockInboundGrpcToOutboundHttpStream) Send ¶
func (m *MockInboundGrpcToOutboundHttpStream) Send(arg0 *grpctool.HttpResponse) error
Send mocks base method.
func (*MockInboundGrpcToOutboundHttpStream) SendHeader ¶
func (m *MockInboundGrpcToOutboundHttpStream) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockInboundGrpcToOutboundHttpStream) SendMsg ¶
func (m *MockInboundGrpcToOutboundHttpStream) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockInboundGrpcToOutboundHttpStream) SetHeader ¶
func (m *MockInboundGrpcToOutboundHttpStream) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockInboundGrpcToOutboundHttpStream) SetTrailer ¶
func (m *MockInboundGrpcToOutboundHttpStream) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockInboundGrpcToOutboundHttpStreamMockRecorder ¶
type MockInboundGrpcToOutboundHttpStreamMockRecorder struct {
// contains filtered or unexported fields
}
MockInboundGrpcToOutboundHttpStreamMockRecorder is the mock recorder for MockInboundGrpcToOutboundHttpStream.
func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) Context ¶
func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) RecvMsg ¶
func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) Send ¶
func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) SendHeader ¶
func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) SendMsg ¶
func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) SetHeader ¶
func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) SetTrailer ¶
func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockObjectsToSynchronizeWatcherInterface ¶
type MockObjectsToSynchronizeWatcherInterface struct {
// contains filtered or unexported fields
}
MockObjectsToSynchronizeWatcherInterface is a mock of ObjectsToSynchronizeWatcherInterface interface.
func NewMockObjectsToSynchronizeWatcherInterface ¶
func NewMockObjectsToSynchronizeWatcherInterface(ctrl *gomock.Controller) *MockObjectsToSynchronizeWatcherInterface
NewMockObjectsToSynchronizeWatcherInterface creates a new mock instance.
func (*MockObjectsToSynchronizeWatcherInterface) EXPECT ¶
func (m *MockObjectsToSynchronizeWatcherInterface) EXPECT() *MockObjectsToSynchronizeWatcherInterfaceMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockObjectsToSynchronizeWatcherInterface) Watch ¶
func (m *MockObjectsToSynchronizeWatcherInterface) Watch(arg0 context.Context, arg1 *rpc.ObjectsToSynchronizeRequest, arg2 rpc.ObjectsToSynchronizeCallback)
Watch mocks base method.
type MockObjectsToSynchronizeWatcherInterfaceMockRecorder ¶
type MockObjectsToSynchronizeWatcherInterfaceMockRecorder struct {
// contains filtered or unexported fields
}
MockObjectsToSynchronizeWatcherInterfaceMockRecorder is the mock recorder for MockObjectsToSynchronizeWatcherInterface.
func (*MockObjectsToSynchronizeWatcherInterfaceMockRecorder) Watch ¶
func (mr *MockObjectsToSynchronizeWatcherInterfaceMockRecorder) Watch(arg0, arg1, arg2 interface{}) *gomock.Call
Watch indicates an expected call of Watch.
type MockPoolConn ¶ added in v14.5.0
type MockPoolConn struct {
// contains filtered or unexported fields
}
MockPoolConn is a mock of PoolConn interface.
func NewMockPoolConn ¶ added in v14.5.0
func NewMockPoolConn(ctrl *gomock.Controller) *MockPoolConn
NewMockPoolConn creates a new mock instance.
func (*MockPoolConn) EXPECT ¶ added in v14.5.0
func (m *MockPoolConn) EXPECT() *MockPoolConnMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockPoolConn) Invoke ¶ added in v14.5.0
func (m *MockPoolConn) Invoke(arg0 context.Context, arg1 string, arg2, arg3 interface{}, arg4 ...grpc.CallOption) error
Invoke mocks base method.
func (*MockPoolConn) NewStream ¶ added in v14.5.0
func (m *MockPoolConn) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, arg3 ...grpc.CallOption) (grpc.ClientStream, error)
NewStream mocks base method.
type MockPoolConnMockRecorder ¶ added in v14.5.0
type MockPoolConnMockRecorder struct {
// contains filtered or unexported fields
}
MockPoolConnMockRecorder is the mock recorder for MockPoolConn.
func (*MockPoolConnMockRecorder) Done ¶ added in v14.5.0
func (mr *MockPoolConnMockRecorder) Done() *gomock.Call
Done indicates an expected call of Done.
func (*MockPoolConnMockRecorder) Invoke ¶ added in v14.5.0
func (mr *MockPoolConnMockRecorder) Invoke(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
Invoke indicates an expected call of Invoke.
func (*MockPoolConnMockRecorder) NewStream ¶ added in v14.5.0
func (mr *MockPoolConnMockRecorder) NewStream(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
NewStream indicates an expected call of NewStream.
type MockResponseWriterFlusher ¶ added in v14.5.0
type MockResponseWriterFlusher struct {
// contains filtered or unexported fields
}
MockResponseWriterFlusher is a mock of ResponseWriterFlusher interface.
func NewMockResponseWriterFlusher ¶ added in v14.5.0
func NewMockResponseWriterFlusher(ctrl *gomock.Controller) *MockResponseWriterFlusher
NewMockResponseWriterFlusher creates a new mock instance.
func (*MockResponseWriterFlusher) EXPECT ¶ added in v14.5.0
func (m *MockResponseWriterFlusher) EXPECT() *MockResponseWriterFlusherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockResponseWriterFlusher) Flush ¶ added in v14.5.0
func (m *MockResponseWriterFlusher) Flush()
Flush mocks base method.
func (*MockResponseWriterFlusher) Header ¶ added in v14.5.0
func (m *MockResponseWriterFlusher) Header() http.Header
Header mocks base method.
func (*MockResponseWriterFlusher) Write ¶ added in v14.5.0
func (m *MockResponseWriterFlusher) Write(arg0 []byte) (int, error)
Write mocks base method.
func (*MockResponseWriterFlusher) WriteHeader ¶ added in v14.5.0
func (m *MockResponseWriterFlusher) WriteHeader(arg0 int)
WriteHeader mocks base method.
type MockResponseWriterFlusherMockRecorder ¶ added in v14.5.0
type MockResponseWriterFlusherMockRecorder struct {
// contains filtered or unexported fields
}
MockResponseWriterFlusherMockRecorder is the mock recorder for MockResponseWriterFlusher.
func (*MockResponseWriterFlusherMockRecorder) Flush ¶ added in v14.5.0
func (mr *MockResponseWriterFlusherMockRecorder) Flush() *gomock.Call
Flush indicates an expected call of Flush.
func (*MockResponseWriterFlusherMockRecorder) Header ¶ added in v14.5.0
func (mr *MockResponseWriterFlusherMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockResponseWriterFlusherMockRecorder) Write ¶ added in v14.5.0
func (mr *MockResponseWriterFlusherMockRecorder) Write(arg0 interface{}) *gomock.Call
Write indicates an expected call of Write.
func (*MockResponseWriterFlusherMockRecorder) WriteHeader ¶ added in v14.5.0
func (mr *MockResponseWriterFlusherMockRecorder) WriteHeader(arg0 interface{}) *gomock.Call
WriteHeader indicates an expected call of WriteHeader.
type MockServerStream ¶
type MockServerStream struct {
// contains filtered or unexported fields
}
MockServerStream is a mock of ServerStream interface.
func NewMockServerStream ¶
func NewMockServerStream(ctrl *gomock.Controller) *MockServerStream
NewMockServerStream creates a new mock instance.
func (*MockServerStream) Context ¶
func (m *MockServerStream) Context() context.Context
Context mocks base method.
func (*MockServerStream) EXPECT ¶
func (m *MockServerStream) EXPECT() *MockServerStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockServerStream) RecvMsg ¶
func (m *MockServerStream) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockServerStream) SendHeader ¶
func (m *MockServerStream) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockServerStream) SendMsg ¶
func (m *MockServerStream) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockServerStream) SetHeader ¶
func (m *MockServerStream) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockServerStream) SetTrailer ¶
func (m *MockServerStream) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockServerStreamMockRecorder ¶
type MockServerStreamMockRecorder struct {
// contains filtered or unexported fields
}
MockServerStreamMockRecorder is the mock recorder for MockServerStream.
func (*MockServerStreamMockRecorder) Context ¶
func (mr *MockServerStreamMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockServerStreamMockRecorder) RecvMsg ¶
func (mr *MockServerStreamMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockServerStreamMockRecorder) SendHeader ¶
func (mr *MockServerStreamMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockServerStreamMockRecorder) SendMsg ¶
func (mr *MockServerStreamMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockServerStreamMockRecorder) SetHeader ¶
func (mr *MockServerStreamMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockServerStreamMockRecorder) SetTrailer ¶
func (mr *MockServerStreamMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type MockServerTransportStream ¶
type MockServerTransportStream struct {
// contains filtered or unexported fields
}
MockServerTransportStream is a mock of ServerTransportStream interface.
func NewMockServerTransportStream ¶
func NewMockServerTransportStream(ctrl *gomock.Controller) *MockServerTransportStream
NewMockServerTransportStream creates a new mock instance.
func (*MockServerTransportStream) EXPECT ¶
func (m *MockServerTransportStream) EXPECT() *MockServerTransportStreamMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockServerTransportStream) Method ¶
func (m *MockServerTransportStream) Method() string
Method mocks base method.
func (*MockServerTransportStream) SendHeader ¶
func (m *MockServerTransportStream) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockServerTransportStream) SetHeader ¶
func (m *MockServerTransportStream) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockServerTransportStream) SetTrailer ¶
func (m *MockServerTransportStream) SetTrailer(arg0 metadata.MD) error
SetTrailer mocks base method.
type MockServerTransportStreamMockRecorder ¶
type MockServerTransportStreamMockRecorder struct {
// contains filtered or unexported fields
}
MockServerTransportStreamMockRecorder is the mock recorder for MockServerTransportStream.
func (*MockServerTransportStreamMockRecorder) Method ¶
func (mr *MockServerTransportStreamMockRecorder) Method() *gomock.Call
Method indicates an expected call of Method.
func (*MockServerTransportStreamMockRecorder) SendHeader ¶
func (mr *MockServerTransportStreamMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockServerTransportStreamMockRecorder) SetHeader ¶
func (mr *MockServerTransportStreamMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockServerTransportStreamMockRecorder) SetTrailer ¶
func (mr *MockServerTransportStreamMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type ResponseWriterFlusher ¶ added in v14.5.0
type ResponseWriterFlusher interface { http.ResponseWriter http.Flusher }