mock_rpc

Documentation

Overview

Package mock_rpc is a generated GoMock package.

Package mock_rpc contains mocks for gRPC interfaces.

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
  • func NewMockAgentConfigurationClient(ctrl *gomock.Controller) *MockAgentConfigurationClient
  • func (m *MockAgentConfigurationClient) EXPECT() *MockAgentConfigurationClientMockRecorder
  • func (m *MockAgentConfigurationClient) GetConfiguration(arg0 context.Context, arg1 *rpc.ConfigurationRequest, arg2 ...grpc.CallOption) (rpc.AgentConfiguration_GetConfigurationClient, error)
• type MockAgentConfigurationClientGetConfigurationCall
  • func (c *MockAgentConfigurationClientGetConfigurationCall) Do(...) *MockAgentConfigurationClientGetConfigurationCall
  • func (c *MockAgentConfigurationClientGetConfigurationCall) DoAndReturn(...) *MockAgentConfigurationClientGetConfigurationCall
  • func (c *MockAgentConfigurationClientGetConfigurationCall) Return(arg0 rpc.AgentConfiguration_GetConfigurationClient, arg1 error) *MockAgentConfigurationClientGetConfigurationCall
• type MockAgentConfigurationClientMockRecorder
  • func (mr *MockAgentConfigurationClientMockRecorder) GetConfiguration(arg0, arg1 any, arg2 ...any) *MockAgentConfigurationClientGetConfigurationCall
• type MockAgentConfiguration_GetConfigurationClient
  • func NewMockAgentConfiguration_GetConfigurationClient(ctrl *gomock.Controller) *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 any) error
  • func (m *MockAgentConfiguration_GetConfigurationClient) SendMsg(arg0 any) error
  • func (m *MockAgentConfiguration_GetConfigurationClient) Trailer() metadata.MD
• type MockAgentConfiguration_GetConfigurationClientCloseSendCall
  • func (c *MockAgentConfiguration_GetConfigurationClientCloseSendCall) Do(f func() error) *MockAgentConfiguration_GetConfigurationClientCloseSendCall
  • func (c *MockAgentConfiguration_GetConfigurationClientCloseSendCall) DoAndReturn(f func() error) *MockAgentConfiguration_GetConfigurationClientCloseSendCall
  • func (c *MockAgentConfiguration_GetConfigurationClientCloseSendCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationClientCloseSendCall
• type MockAgentConfiguration_GetConfigurationClientContextCall
  • func (c *MockAgentConfiguration_GetConfigurationClientContextCall) Do(f func() context.Context) *MockAgentConfiguration_GetConfigurationClientContextCall
  • func (c *MockAgentConfiguration_GetConfigurationClientContextCall) DoAndReturn(f func() context.Context) *MockAgentConfiguration_GetConfigurationClientContextCall
  • func (c *MockAgentConfiguration_GetConfigurationClientContextCall) Return(arg0 context.Context) *MockAgentConfiguration_GetConfigurationClientContextCall
• type MockAgentConfiguration_GetConfigurationClientHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationClientHeaderCall) Do(f func() (metadata.MD, error)) *MockAgentConfiguration_GetConfigurationClientHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationClientHeaderCall) DoAndReturn(f func() (metadata.MD, error)) *MockAgentConfiguration_GetConfigurationClientHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationClientHeaderCall) Return(arg0 metadata.MD, arg1 error) *MockAgentConfiguration_GetConfigurationClientHeaderCall
• type MockAgentConfiguration_GetConfigurationClientMockRecorder
  • func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) CloseSend() *MockAgentConfiguration_GetConfigurationClientCloseSendCall
  • func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Context() *MockAgentConfiguration_GetConfigurationClientContextCall
  • func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Header() *MockAgentConfiguration_GetConfigurationClientHeaderCall
  • func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Recv() *MockAgentConfiguration_GetConfigurationClientRecvCall
  • func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) RecvMsg(arg0 any) *MockAgentConfiguration_GetConfigurationClientRecvMsgCall
  • func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) SendMsg(arg0 any) *MockAgentConfiguration_GetConfigurationClientSendMsgCall
  • func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Trailer() *MockAgentConfiguration_GetConfigurationClientTrailerCall
• type MockAgentConfiguration_GetConfigurationClientRecvCall
  • func (c *MockAgentConfiguration_GetConfigurationClientRecvCall) Do(f func() (*rpc.ConfigurationResponse, error)) *MockAgentConfiguration_GetConfigurationClientRecvCall
  • func (c *MockAgentConfiguration_GetConfigurationClientRecvCall) DoAndReturn(f func() (*rpc.ConfigurationResponse, error)) *MockAgentConfiguration_GetConfigurationClientRecvCall
  • func (c *MockAgentConfiguration_GetConfigurationClientRecvCall) Return(arg0 *rpc.ConfigurationResponse, arg1 error) *MockAgentConfiguration_GetConfigurationClientRecvCall
• type MockAgentConfiguration_GetConfigurationClientRecvMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationClientRecvMsgCall) Do(f func(any) error) *MockAgentConfiguration_GetConfigurationClientRecvMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationClientRecvMsgCall) DoAndReturn(f func(any) error) *MockAgentConfiguration_GetConfigurationClientRecvMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationClientRecvMsgCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationClientRecvMsgCall
• type MockAgentConfiguration_GetConfigurationClientSendMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationClientSendMsgCall) Do(f func(any) error) *MockAgentConfiguration_GetConfigurationClientSendMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationClientSendMsgCall) DoAndReturn(f func(any) error) *MockAgentConfiguration_GetConfigurationClientSendMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationClientSendMsgCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationClientSendMsgCall
• type MockAgentConfiguration_GetConfigurationClientTrailerCall
  • func (c *MockAgentConfiguration_GetConfigurationClientTrailerCall) Do(f func() metadata.MD) *MockAgentConfiguration_GetConfigurationClientTrailerCall
  • func (c *MockAgentConfiguration_GetConfigurationClientTrailerCall) DoAndReturn(f func() metadata.MD) *MockAgentConfiguration_GetConfigurationClientTrailerCall
  • func (c *MockAgentConfiguration_GetConfigurationClientTrailerCall) Return(arg0 metadata.MD) *MockAgentConfiguration_GetConfigurationClientTrailerCall
• type MockAgentConfiguration_GetConfigurationServer
  • func NewMockAgentConfiguration_GetConfigurationServer(ctrl *gomock.Controller) *MockAgentConfiguration_GetConfigurationServer
  • func (m *MockAgentConfiguration_GetConfigurationServer) Context() context.Context
  • func (m *MockAgentConfiguration_GetConfigurationServer) EXPECT() *MockAgentConfiguration_GetConfigurationServerMockRecorder
  • func (m *MockAgentConfiguration_GetConfigurationServer) RecvMsg(arg0 any) 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 any) error
  • func (m *MockAgentConfiguration_GetConfigurationServer) SetHeader(arg0 metadata.MD) error
  • func (m *MockAgentConfiguration_GetConfigurationServer) SetTrailer(arg0 metadata.MD)
• type MockAgentConfiguration_GetConfigurationServerContextCall
  • func (c *MockAgentConfiguration_GetConfigurationServerContextCall) Do(f func() context.Context) *MockAgentConfiguration_GetConfigurationServerContextCall
  • func (c *MockAgentConfiguration_GetConfigurationServerContextCall) DoAndReturn(f func() context.Context) *MockAgentConfiguration_GetConfigurationServerContextCall
  • func (c *MockAgentConfiguration_GetConfigurationServerContextCall) Return(arg0 context.Context) *MockAgentConfiguration_GetConfigurationServerContextCall
• type MockAgentConfiguration_GetConfigurationServerMockRecorder
  • func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) Context() *MockAgentConfiguration_GetConfigurationServerContextCall
  • func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) RecvMsg(arg0 any) *MockAgentConfiguration_GetConfigurationServerRecvMsgCall
  • func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) Send(arg0 any) *MockAgentConfiguration_GetConfigurationServerSendCall
  • func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SendHeader(arg0 any) *MockAgentConfiguration_GetConfigurationServerSendHeaderCall
  • func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SendMsg(arg0 any) *MockAgentConfiguration_GetConfigurationServerSendMsgCall
  • func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SetHeader(arg0 any) *MockAgentConfiguration_GetConfigurationServerSetHeaderCall
  • func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SetTrailer(arg0 any) *MockAgentConfiguration_GetConfigurationServerSetTrailerCall
• type MockAgentConfiguration_GetConfigurationServerRecvMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationServerRecvMsgCall) Do(f func(any) error) *MockAgentConfiguration_GetConfigurationServerRecvMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationServerRecvMsgCall) DoAndReturn(f func(any) error) *MockAgentConfiguration_GetConfigurationServerRecvMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationServerRecvMsgCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerRecvMsgCall
• type MockAgentConfiguration_GetConfigurationServerSendCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendCall) Do(f func(*rpc.ConfigurationResponse) error) *MockAgentConfiguration_GetConfigurationServerSendCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendCall) DoAndReturn(f func(*rpc.ConfigurationResponse) error) *MockAgentConfiguration_GetConfigurationServerSendCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerSendCall
• type MockAgentConfiguration_GetConfigurationServerSendHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendHeaderCall) Do(f func(metadata.MD) error) *MockAgentConfiguration_GetConfigurationServerSendHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockAgentConfiguration_GetConfigurationServerSendHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendHeaderCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerSendHeaderCall
• type MockAgentConfiguration_GetConfigurationServerSendMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendMsgCall) Do(f func(any) error) *MockAgentConfiguration_GetConfigurationServerSendMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendMsgCall) DoAndReturn(f func(any) error) *MockAgentConfiguration_GetConfigurationServerSendMsgCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSendMsgCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerSendMsgCall
• type MockAgentConfiguration_GetConfigurationServerSetHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSetHeaderCall) Do(f func(metadata.MD) error) *MockAgentConfiguration_GetConfigurationServerSetHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockAgentConfiguration_GetConfigurationServerSetHeaderCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSetHeaderCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerSetHeaderCall
• type MockAgentConfiguration_GetConfigurationServerSetTrailerCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSetTrailerCall) Do(f func(metadata.MD)) *MockAgentConfiguration_GetConfigurationServerSetTrailerCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockAgentConfiguration_GetConfigurationServerSetTrailerCall
  • func (c *MockAgentConfiguration_GetConfigurationServerSetTrailerCall) Return() *MockAgentConfiguration_GetConfigurationServerSetTrailerCall
• type MockClientConnInterface
  • func NewMockClientConnInterface(ctrl *gomock.Controller) *MockClientConnInterface
  • func (m *MockClientConnInterface) EXPECT() *MockClientConnInterfaceMockRecorder
  • func (m *MockClientConnInterface) Invoke(arg0 context.Context, arg1 string, arg2, arg3 any, arg4 ...grpc.CallOption) error
  • func (m *MockClientConnInterface) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, ...) (grpc.ClientStream, error)
• type MockClientConnInterfaceInvokeCall
  • func (c *MockClientConnInterfaceInvokeCall) Do(f func(context.Context, string, any, any, ...grpc.CallOption) error) *MockClientConnInterfaceInvokeCall
  • func (c *MockClientConnInterfaceInvokeCall) DoAndReturn(f func(context.Context, string, any, any, ...grpc.CallOption) error) *MockClientConnInterfaceInvokeCall
  • func (c *MockClientConnInterfaceInvokeCall) Return(arg0 error) *MockClientConnInterfaceInvokeCall
• type MockClientConnInterfaceMockRecorder
  • func (mr *MockClientConnInterfaceMockRecorder) Invoke(arg0, arg1, arg2, arg3 any, arg4 ...any) *MockClientConnInterfaceInvokeCall
  • func (mr *MockClientConnInterfaceMockRecorder) NewStream(arg0, arg1, arg2 any, arg3 ...any) *MockClientConnInterfaceNewStreamCall
• type MockClientConnInterfaceNewStreamCall
  • func (c *MockClientConnInterfaceNewStreamCall) Do(...) *MockClientConnInterfaceNewStreamCall
  • func (c *MockClientConnInterfaceNewStreamCall) DoAndReturn(...) *MockClientConnInterfaceNewStreamCall
  • func (c *MockClientConnInterfaceNewStreamCall) Return(arg0 grpc.ClientStream, arg1 error) *MockClientConnInterfaceNewStreamCall
• type MockClientStream
  • func InitMockClientStream(ctrl *gomock.Controller, eof bool, msgs ...proto.Message) (*MockClientStream, []any)
  • func NewMockClientStream(ctrl *gomock.Controller) *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 any) error
  • func (m *MockClientStream) SendMsg(arg0 any) error
  • func (m *MockClientStream) Trailer() metadata.MD
• type MockClientStreamCloseSendCall
  • func (c *MockClientStreamCloseSendCall) Do(f func() error) *MockClientStreamCloseSendCall
  • func (c *MockClientStreamCloseSendCall) DoAndReturn(f func() error) *MockClientStreamCloseSendCall
  • func (c *MockClientStreamCloseSendCall) Return(arg0 error) *MockClientStreamCloseSendCall
• type MockClientStreamContextCall
  • func (c *MockClientStreamContextCall) Do(f func() context.Context) *MockClientStreamContextCall
  • func (c *MockClientStreamContextCall) DoAndReturn(f func() context.Context) *MockClientStreamContextCall
  • func (c *MockClientStreamContextCall) Return(arg0 context.Context) *MockClientStreamContextCall
• type MockClientStreamHeaderCall
  • func (c *MockClientStreamHeaderCall) Do(f func() (metadata.MD, error)) *MockClientStreamHeaderCall
  • func (c *MockClientStreamHeaderCall) DoAndReturn(f func() (metadata.MD, error)) *MockClientStreamHeaderCall
  • func (c *MockClientStreamHeaderCall) Return(arg0 metadata.MD, arg1 error) *MockClientStreamHeaderCall
• type MockClientStreamMockRecorder
  • func (mr *MockClientStreamMockRecorder) CloseSend() *MockClientStreamCloseSendCall
  • func (mr *MockClientStreamMockRecorder) Context() *MockClientStreamContextCall
  • func (mr *MockClientStreamMockRecorder) Header() *MockClientStreamHeaderCall
  • func (mr *MockClientStreamMockRecorder) RecvMsg(arg0 any) *MockClientStreamRecvMsgCall
  • func (mr *MockClientStreamMockRecorder) SendMsg(arg0 any) *MockClientStreamSendMsgCall
  • func (mr *MockClientStreamMockRecorder) Trailer() *MockClientStreamTrailerCall
• type MockClientStreamRecvMsgCall
  • func (c *MockClientStreamRecvMsgCall) Do(f func(any) error) *MockClientStreamRecvMsgCall
  • func (c *MockClientStreamRecvMsgCall) DoAndReturn(f func(any) error) *MockClientStreamRecvMsgCall
  • func (c *MockClientStreamRecvMsgCall) Return(arg0 error) *MockClientStreamRecvMsgCall
• type MockClientStreamSendMsgCall
  • func (c *MockClientStreamSendMsgCall) Do(f func(any) error) *MockClientStreamSendMsgCall
  • func (c *MockClientStreamSendMsgCall) DoAndReturn(f func(any) error) *MockClientStreamSendMsgCall
  • func (c *MockClientStreamSendMsgCall) Return(arg0 error) *MockClientStreamSendMsgCall
• type MockClientStreamTrailerCall
  • func (c *MockClientStreamTrailerCall) Do(f func() metadata.MD) *MockClientStreamTrailerCall
  • func (c *MockClientStreamTrailerCall) DoAndReturn(f func() metadata.MD) *MockClientStreamTrailerCall
  • func (c *MockClientStreamTrailerCall) Return(arg0 metadata.MD) *MockClientStreamTrailerCall
• type MockConfigurationWatcherInterface
  • func NewMockConfigurationWatcherInterface(ctrl *gomock.Controller) *MockConfigurationWatcherInterface
  • func (m *MockConfigurationWatcherInterface) EXPECT() *MockConfigurationWatcherInterfaceMockRecorder
  • func (m *MockConfigurationWatcherInterface) Watch(arg0 context.Context, arg1 rpc.ConfigurationCallback)
• type MockConfigurationWatcherInterfaceMockRecorder
  • func (mr *MockConfigurationWatcherInterfaceMockRecorder) Watch(arg0, arg1 any) *MockConfigurationWatcherInterfaceWatchCall
• type MockConfigurationWatcherInterfaceWatchCall
  • func (c *MockConfigurationWatcherInterfaceWatchCall) Do(f func(context.Context, rpc.ConfigurationCallback)) *MockConfigurationWatcherInterfaceWatchCall
  • func (c *MockConfigurationWatcherInterfaceWatchCall) DoAndReturn(f func(context.Context, rpc.ConfigurationCallback)) *MockConfigurationWatcherInterfaceWatchCall
  • func (c *MockConfigurationWatcherInterfaceWatchCall) Return() *MockConfigurationWatcherInterfaceWatchCall
• type MockGitlabAccess_MakeRequestServer
  • func NewMockGitlabAccess_MakeRequestServer(ctrl *gomock.Controller) *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 any) 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 any) error
  • func (m *MockGitlabAccess_MakeRequestServer) SetHeader(arg0 metadata.MD) error
  • func (m *MockGitlabAccess_MakeRequestServer) SetTrailer(arg0 metadata.MD)
• type MockGitlabAccess_MakeRequestServerContextCall
  • func (c *MockGitlabAccess_MakeRequestServerContextCall) Do(f func() context.Context) *MockGitlabAccess_MakeRequestServerContextCall
  • func (c *MockGitlabAccess_MakeRequestServerContextCall) DoAndReturn(f func() context.Context) *MockGitlabAccess_MakeRequestServerContextCall
  • func (c *MockGitlabAccess_MakeRequestServerContextCall) Return(arg0 context.Context) *MockGitlabAccess_MakeRequestServerContextCall
• type MockGitlabAccess_MakeRequestServerMockRecorder
  • func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Context() *MockGitlabAccess_MakeRequestServerContextCall
  • func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Recv() *MockGitlabAccess_MakeRequestServerRecvCall
  • func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) RecvMsg(arg0 any) *MockGitlabAccess_MakeRequestServerRecvMsgCall
  • func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Send(arg0 any) *MockGitlabAccess_MakeRequestServerSendCall
  • func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SendHeader(arg0 any) *MockGitlabAccess_MakeRequestServerSendHeaderCall
  • func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SendMsg(arg0 any) *MockGitlabAccess_MakeRequestServerSendMsgCall
  • func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SetHeader(arg0 any) *MockGitlabAccess_MakeRequestServerSetHeaderCall
  • func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SetTrailer(arg0 any) *MockGitlabAccess_MakeRequestServerSetTrailerCall
• type MockGitlabAccess_MakeRequestServerRecvCall
  • func (c *MockGitlabAccess_MakeRequestServerRecvCall) Do(f func() (*grpctool.HttpRequest, error)) *MockGitlabAccess_MakeRequestServerRecvCall
  • func (c *MockGitlabAccess_MakeRequestServerRecvCall) DoAndReturn(f func() (*grpctool.HttpRequest, error)) *MockGitlabAccess_MakeRequestServerRecvCall
  • func (c *MockGitlabAccess_MakeRequestServerRecvCall) Return(arg0 *grpctool.HttpRequest, arg1 error) *MockGitlabAccess_MakeRequestServerRecvCall
• type MockGitlabAccess_MakeRequestServerRecvMsgCall
  • func (c *MockGitlabAccess_MakeRequestServerRecvMsgCall) Do(f func(any) error) *MockGitlabAccess_MakeRequestServerRecvMsgCall
  • func (c *MockGitlabAccess_MakeRequestServerRecvMsgCall) DoAndReturn(f func(any) error) *MockGitlabAccess_MakeRequestServerRecvMsgCall
  • func (c *MockGitlabAccess_MakeRequestServerRecvMsgCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerRecvMsgCall
• type MockGitlabAccess_MakeRequestServerSendCall
  • func (c *MockGitlabAccess_MakeRequestServerSendCall) Do(f func(*grpctool.HttpResponse) error) *MockGitlabAccess_MakeRequestServerSendCall
  • func (c *MockGitlabAccess_MakeRequestServerSendCall) DoAndReturn(f func(*grpctool.HttpResponse) error) *MockGitlabAccess_MakeRequestServerSendCall
  • func (c *MockGitlabAccess_MakeRequestServerSendCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerSendCall
• type MockGitlabAccess_MakeRequestServerSendHeaderCall
  • func (c *MockGitlabAccess_MakeRequestServerSendHeaderCall) Do(f func(metadata.MD) error) *MockGitlabAccess_MakeRequestServerSendHeaderCall
  • func (c *MockGitlabAccess_MakeRequestServerSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockGitlabAccess_MakeRequestServerSendHeaderCall
  • func (c *MockGitlabAccess_MakeRequestServerSendHeaderCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerSendHeaderCall
• type MockGitlabAccess_MakeRequestServerSendMsgCall
  • func (c *MockGitlabAccess_MakeRequestServerSendMsgCall) Do(f func(any) error) *MockGitlabAccess_MakeRequestServerSendMsgCall
  • func (c *MockGitlabAccess_MakeRequestServerSendMsgCall) DoAndReturn(f func(any) error) *MockGitlabAccess_MakeRequestServerSendMsgCall
  • func (c *MockGitlabAccess_MakeRequestServerSendMsgCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerSendMsgCall
• type MockGitlabAccess_MakeRequestServerSetHeaderCall
  • func (c *MockGitlabAccess_MakeRequestServerSetHeaderCall) Do(f func(metadata.MD) error) *MockGitlabAccess_MakeRequestServerSetHeaderCall
  • func (c *MockGitlabAccess_MakeRequestServerSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockGitlabAccess_MakeRequestServerSetHeaderCall
  • func (c *MockGitlabAccess_MakeRequestServerSetHeaderCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerSetHeaderCall
• type MockGitlabAccess_MakeRequestServerSetTrailerCall
  • func (c *MockGitlabAccess_MakeRequestServerSetTrailerCall) Do(f func(metadata.MD)) *MockGitlabAccess_MakeRequestServerSetTrailerCall
  • func (c *MockGitlabAccess_MakeRequestServerSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockGitlabAccess_MakeRequestServerSetTrailerCall
  • func (c *MockGitlabAccess_MakeRequestServerSetTrailerCall) Return() *MockGitlabAccess_MakeRequestServerSetTrailerCall
• type MockGitopsClient
  • func NewMockGitopsClient(ctrl *gomock.Controller) *MockGitopsClient
  • func (m *MockGitopsClient) EXPECT() *MockGitopsClientMockRecorder
  • func (m *MockGitopsClient) GetObjectsToSynchronize(arg0 context.Context, arg1 *rpc.ObjectsToSynchronizeRequest, ...) (rpc.Gitops_GetObjectsToSynchronizeClient, error)
• type MockGitopsClientGetObjectsToSynchronizeCall
  • func (c *MockGitopsClientGetObjectsToSynchronizeCall) Do(...) *MockGitopsClientGetObjectsToSynchronizeCall
  • func (c *MockGitopsClientGetObjectsToSynchronizeCall) DoAndReturn(...) *MockGitopsClientGetObjectsToSynchronizeCall
  • func (c *MockGitopsClientGetObjectsToSynchronizeCall) Return(arg0 rpc.Gitops_GetObjectsToSynchronizeClient, arg1 error) *MockGitopsClientGetObjectsToSynchronizeCall
• type MockGitopsClientMockRecorder
  • func (mr *MockGitopsClientMockRecorder) GetObjectsToSynchronize(arg0, arg1 any, arg2 ...any) *MockGitopsClientGetObjectsToSynchronizeCall
• type MockGitops_GetObjectsToSynchronizeClient
  • func NewMockGitops_GetObjectsToSynchronizeClient(ctrl *gomock.Controller) *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 any) error
  • func (m *MockGitops_GetObjectsToSynchronizeClient) SendMsg(arg0 any) error
  • func (m *MockGitops_GetObjectsToSynchronizeClient) Trailer() metadata.MD
• type MockGitops_GetObjectsToSynchronizeClientCloseSendCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientCloseSendCall) Do(f func() error) *MockGitops_GetObjectsToSynchronizeClientCloseSendCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientCloseSendCall) DoAndReturn(f func() error) *MockGitops_GetObjectsToSynchronizeClientCloseSendCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientCloseSendCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeClientCloseSendCall
• type MockGitops_GetObjectsToSynchronizeClientContextCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientContextCall) Do(f func() context.Context) *MockGitops_GetObjectsToSynchronizeClientContextCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientContextCall) DoAndReturn(f func() context.Context) *MockGitops_GetObjectsToSynchronizeClientContextCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientContextCall) Return(arg0 context.Context) *MockGitops_GetObjectsToSynchronizeClientContextCall
• type MockGitops_GetObjectsToSynchronizeClientHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientHeaderCall) Do(f func() (metadata.MD, error)) *MockGitops_GetObjectsToSynchronizeClientHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientHeaderCall) DoAndReturn(f func() (metadata.MD, error)) *MockGitops_GetObjectsToSynchronizeClientHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientHeaderCall) Return(arg0 metadata.MD, arg1 error) *MockGitops_GetObjectsToSynchronizeClientHeaderCall
• type MockGitops_GetObjectsToSynchronizeClientMockRecorder
  • func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) CloseSend() *MockGitops_GetObjectsToSynchronizeClientCloseSendCall
  • func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Context() *MockGitops_GetObjectsToSynchronizeClientContextCall
  • func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Header() *MockGitops_GetObjectsToSynchronizeClientHeaderCall
  • func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Recv() *MockGitops_GetObjectsToSynchronizeClientRecvCall
  • func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) RecvMsg(arg0 any) *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall
  • func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) SendMsg(arg0 any) *MockGitops_GetObjectsToSynchronizeClientSendMsgCall
  • func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Trailer() *MockGitops_GetObjectsToSynchronizeClientTrailerCall
• type MockGitops_GetObjectsToSynchronizeClientRecvCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientRecvCall) Do(f func() (*rpc.ObjectsToSynchronizeResponse, error)) *MockGitops_GetObjectsToSynchronizeClientRecvCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientRecvCall) DoAndReturn(f func() (*rpc.ObjectsToSynchronizeResponse, error)) *MockGitops_GetObjectsToSynchronizeClientRecvCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientRecvCall) Return(arg0 *rpc.ObjectsToSynchronizeResponse, arg1 error) *MockGitops_GetObjectsToSynchronizeClientRecvCall
• type MockGitops_GetObjectsToSynchronizeClientRecvMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) Do(f func(any) error) *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) DoAndReturn(f func(any) error) *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall
• type MockGitops_GetObjectsToSynchronizeClientSendMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientSendMsgCall) Do(f func(any) error) *MockGitops_GetObjectsToSynchronizeClientSendMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientSendMsgCall) DoAndReturn(f func(any) error) *MockGitops_GetObjectsToSynchronizeClientSendMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientSendMsgCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeClientSendMsgCall
• type MockGitops_GetObjectsToSynchronizeClientTrailerCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientTrailerCall) Do(f func() metadata.MD) *MockGitops_GetObjectsToSynchronizeClientTrailerCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientTrailerCall) DoAndReturn(f func() metadata.MD) *MockGitops_GetObjectsToSynchronizeClientTrailerCall
  • func (c *MockGitops_GetObjectsToSynchronizeClientTrailerCall) Return(arg0 metadata.MD) *MockGitops_GetObjectsToSynchronizeClientTrailerCall
• type MockGitops_GetObjectsToSynchronizeServer
  • func NewMockGitops_GetObjectsToSynchronizeServer(ctrl *gomock.Controller) *MockGitops_GetObjectsToSynchronizeServer
  • func (m *MockGitops_GetObjectsToSynchronizeServer) Context() context.Context
  • func (m *MockGitops_GetObjectsToSynchronizeServer) EXPECT() *MockGitops_GetObjectsToSynchronizeServerMockRecorder
  • func (m *MockGitops_GetObjectsToSynchronizeServer) RecvMsg(arg0 any) 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 any) error
  • func (m *MockGitops_GetObjectsToSynchronizeServer) SetHeader(arg0 metadata.MD) error
  • func (m *MockGitops_GetObjectsToSynchronizeServer) SetTrailer(arg0 metadata.MD)
• type MockGitops_GetObjectsToSynchronizeServerContextCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerContextCall) Do(f func() context.Context) *MockGitops_GetObjectsToSynchronizeServerContextCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerContextCall) DoAndReturn(f func() context.Context) *MockGitops_GetObjectsToSynchronizeServerContextCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerContextCall) Return(arg0 context.Context) *MockGitops_GetObjectsToSynchronizeServerContextCall
• type MockGitops_GetObjectsToSynchronizeServerMockRecorder
  • func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) Context() *MockGitops_GetObjectsToSynchronizeServerContextCall
  • func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) RecvMsg(arg0 any) *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall
  • func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) Send(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSendCall
  • func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendHeader(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall
  • func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendMsg(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSendMsgCall
  • func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetHeader(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall
  • func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetTrailer(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall
• type MockGitops_GetObjectsToSynchronizeServerRecvMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) Do(f func(any) error) *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) DoAndReturn(f func(any) error) *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall
• type MockGitops_GetObjectsToSynchronizeServerSendCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendCall) Do(f func(*rpc.ObjectsToSynchronizeResponse) error) *MockGitops_GetObjectsToSynchronizeServerSendCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendCall) DoAndReturn(f func(*rpc.ObjectsToSynchronizeResponse) error) *MockGitops_GetObjectsToSynchronizeServerSendCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerSendCall
• type MockGitops_GetObjectsToSynchronizeServerSendHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) Do(f func(metadata.MD) error) *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall
• type MockGitops_GetObjectsToSynchronizeServerSendMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendMsgCall) Do(f func(any) error) *MockGitops_GetObjectsToSynchronizeServerSendMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendMsgCall) DoAndReturn(f func(any) error) *MockGitops_GetObjectsToSynchronizeServerSendMsgCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSendMsgCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerSendMsgCall
• type MockGitops_GetObjectsToSynchronizeServerSetHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) Do(f func(metadata.MD) error) *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall
• type MockGitops_GetObjectsToSynchronizeServerSetTrailerCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) Do(f func(metadata.MD)) *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall
  • func (c *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) Return() *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall
• type MockInboundGRPCToOutboundHTTPStream
  • func NewMockInboundGRPCToOutboundHTTPStream(ctrl *gomock.Controller) *MockInboundGRPCToOutboundHTTPStream
  • func (m *MockInboundGRPCToOutboundHTTPStream) Context() context.Context
  • func (m *MockInboundGRPCToOutboundHTTPStream) EXPECT() *MockInboundGRPCToOutboundHTTPStreamMockRecorder
  • func (m *MockInboundGRPCToOutboundHTTPStream) RecvMsg(arg0 any) error
  • func (m *MockInboundGRPCToOutboundHTTPStream) Send(arg0 *grpctool.HttpResponse) error
  • func (m *MockInboundGRPCToOutboundHTTPStream) SendHeader(arg0 metadata.MD) error
  • func (m *MockInboundGRPCToOutboundHTTPStream) SendMsg(arg0 any) error
  • func (m *MockInboundGRPCToOutboundHTTPStream) SetHeader(arg0 metadata.MD) error
  • func (m *MockInboundGRPCToOutboundHTTPStream) SetTrailer(arg0 metadata.MD)
• type MockInboundGRPCToOutboundHTTPStreamContextCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamContextCall) Do(f func() context.Context) *MockInboundGRPCToOutboundHTTPStreamContextCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamContextCall) DoAndReturn(f func() context.Context) *MockInboundGRPCToOutboundHTTPStreamContextCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamContextCall) Return(arg0 context.Context) *MockInboundGRPCToOutboundHTTPStreamContextCall
• type MockInboundGRPCToOutboundHTTPStreamMockRecorder
  • func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) Context() *MockInboundGRPCToOutboundHTTPStreamContextCall
  • func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) RecvMsg(arg0 any) *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall
  • func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) Send(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSendCall
  • func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) SendHeader(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall
  • func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) SendMsg(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSendMsgCall
  • func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) SetHeader(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall
  • func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) SetTrailer(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall
• type MockInboundGRPCToOutboundHTTPStreamRecvMsgCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) Do(f func(any) error) *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) DoAndReturn(f func(any) error) *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall
• type MockInboundGRPCToOutboundHTTPStreamSendCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendCall) Do(f func(*grpctool.HttpResponse) error) *MockInboundGRPCToOutboundHTTPStreamSendCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendCall) DoAndReturn(f func(*grpctool.HttpResponse) error) *MockInboundGRPCToOutboundHTTPStreamSendCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamSendCall
• type MockInboundGRPCToOutboundHTTPStreamSendHeaderCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) Do(f func(metadata.MD) error) *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall
• type MockInboundGRPCToOutboundHTTPStreamSendMsgCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendMsgCall) Do(f func(any) error) *MockInboundGRPCToOutboundHTTPStreamSendMsgCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendMsgCall) DoAndReturn(f func(any) error) *MockInboundGRPCToOutboundHTTPStreamSendMsgCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSendMsgCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamSendMsgCall
• type MockInboundGRPCToOutboundHTTPStreamSetHeaderCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) Do(f func(metadata.MD) error) *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall
• type MockInboundGRPCToOutboundHTTPStreamSetTrailerCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) Do(f func(metadata.MD)) *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall
  • func (c *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) Return() *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall
• type MockObjectsToSynchronizeWatcherInterface
  • func NewMockObjectsToSynchronizeWatcherInterface(ctrl *gomock.Controller) *MockObjectsToSynchronizeWatcherInterface
  • func (m *MockObjectsToSynchronizeWatcherInterface) EXPECT() *MockObjectsToSynchronizeWatcherInterfaceMockRecorder
  • func (m *MockObjectsToSynchronizeWatcherInterface) Watch(arg0 context.Context, arg1 *rpc.ObjectsToSynchronizeRequest, ...)
• type MockObjectsToSynchronizeWatcherInterfaceMockRecorder
  • func (mr *MockObjectsToSynchronizeWatcherInterfaceMockRecorder) Watch(arg0, arg1, arg2 any) *MockObjectsToSynchronizeWatcherInterfaceWatchCall
• type MockObjectsToSynchronizeWatcherInterfaceWatchCall
  • func (c *MockObjectsToSynchronizeWatcherInterfaceWatchCall) Do(f func(context.Context, *rpc.ObjectsToSynchronizeRequest, ...)) *MockObjectsToSynchronizeWatcherInterfaceWatchCall
  • func (c *MockObjectsToSynchronizeWatcherInterfaceWatchCall) DoAndReturn(f func(context.Context, *rpc.ObjectsToSynchronizeRequest, ...)) *MockObjectsToSynchronizeWatcherInterfaceWatchCall
  • func (c *MockObjectsToSynchronizeWatcherInterfaceWatchCall) Return() *MockObjectsToSynchronizeWatcherInterfaceWatchCall
• type MockPoolConn
  • func NewMockPoolConn(ctrl *gomock.Controller) *MockPoolConn
  • func (m *MockPoolConn) Done()
  • func (m *MockPoolConn) EXPECT() *MockPoolConnMockRecorder
  • func (m *MockPoolConn) Invoke(arg0 context.Context, arg1 string, arg2, arg3 any, arg4 ...grpc.CallOption) error
  • func (m *MockPoolConn) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, ...) (grpc.ClientStream, error)
• type MockPoolConnDoneCall
  • func (c *MockPoolConnDoneCall) Do(f func()) *MockPoolConnDoneCall
  • func (c *MockPoolConnDoneCall) DoAndReturn(f func()) *MockPoolConnDoneCall
  • func (c *MockPoolConnDoneCall) Return() *MockPoolConnDoneCall
• type MockPoolConnInvokeCall
  • func (c *MockPoolConnInvokeCall) Do(f func(context.Context, string, any, any, ...grpc.CallOption) error) *MockPoolConnInvokeCall
  • func (c *MockPoolConnInvokeCall) DoAndReturn(f func(context.Context, string, any, any, ...grpc.CallOption) error) *MockPoolConnInvokeCall
  • func (c *MockPoolConnInvokeCall) Return(arg0 error) *MockPoolConnInvokeCall
• type MockPoolConnMockRecorder
  • func (mr *MockPoolConnMockRecorder) Done() *MockPoolConnDoneCall
  • func (mr *MockPoolConnMockRecorder) Invoke(arg0, arg1, arg2, arg3 any, arg4 ...any) *MockPoolConnInvokeCall
  • func (mr *MockPoolConnMockRecorder) NewStream(arg0, arg1, arg2 any, arg3 ...any) *MockPoolConnNewStreamCall
• type MockPoolConnNewStreamCall
  • func (c *MockPoolConnNewStreamCall) Do(...) *MockPoolConnNewStreamCall
  • func (c *MockPoolConnNewStreamCall) DoAndReturn(...) *MockPoolConnNewStreamCall
  • func (c *MockPoolConnNewStreamCall) Return(arg0 grpc.ClientStream, arg1 error) *MockPoolConnNewStreamCall
• type MockPoolInterface
  • func NewMockPoolInterface(ctrl *gomock.Controller) *MockPoolInterface
  • func (m *MockPoolInterface) Close() error
  • func (m *MockPoolInterface) Dial(arg0 context.Context, arg1 string) (grpctool.PoolConn, error)
  • func (m *MockPoolInterface) EXPECT() *MockPoolInterfaceMockRecorder
• type MockPoolInterfaceCloseCall
  • func (c *MockPoolInterfaceCloseCall) Do(f func() error) *MockPoolInterfaceCloseCall
  • func (c *MockPoolInterfaceCloseCall) DoAndReturn(f func() error) *MockPoolInterfaceCloseCall
  • func (c *MockPoolInterfaceCloseCall) Return(arg0 error) *MockPoolInterfaceCloseCall
• type MockPoolInterfaceDialCall
  • func (c *MockPoolInterfaceDialCall) Do(f func(context.Context, string) (grpctool.PoolConn, error)) *MockPoolInterfaceDialCall
  • func (c *MockPoolInterfaceDialCall) DoAndReturn(f func(context.Context, string) (grpctool.PoolConn, error)) *MockPoolInterfaceDialCall
  • func (c *MockPoolInterfaceDialCall) Return(arg0 grpctool.PoolConn, arg1 error) *MockPoolInterfaceDialCall
• type MockPoolInterfaceMockRecorder
  • func (mr *MockPoolInterfaceMockRecorder) Close() *MockPoolInterfaceCloseCall
  • func (mr *MockPoolInterfaceMockRecorder) Dial(arg0, arg1 any) *MockPoolInterfaceDialCall
• type MockServerErrorReporter
  • func NewMockServerErrorReporter(ctrl *gomock.Controller) *MockServerErrorReporter
  • func (m *MockServerErrorReporter) EXPECT() *MockServerErrorReporterMockRecorder
  • func (m *MockServerErrorReporter) Report(arg0 context.Context, arg1 string, arg2 error)
• type MockServerErrorReporterMockRecorder
  • func (mr *MockServerErrorReporterMockRecorder) Report(arg0, arg1, arg2 any) *MockServerErrorReporterReportCall
• type MockServerErrorReporterReportCall
  • func (c *MockServerErrorReporterReportCall) Do(f func(context.Context, string, error)) *MockServerErrorReporterReportCall
  • func (c *MockServerErrorReporterReportCall) DoAndReturn(f func(context.Context, string, error)) *MockServerErrorReporterReportCall
  • func (c *MockServerErrorReporterReportCall) Return() *MockServerErrorReporterReportCall
• type MockServerStream
  • func NewMockServerStream(ctrl *gomock.Controller) *MockServerStream
  • func (m *MockServerStream) Context() context.Context
  • func (m *MockServerStream) EXPECT() *MockServerStreamMockRecorder
  • func (m *MockServerStream) RecvMsg(arg0 any) error
  • func (m *MockServerStream) SendHeader(arg0 metadata.MD) error
  • func (m *MockServerStream) SendMsg(arg0 any) error
  • func (m *MockServerStream) SetHeader(arg0 metadata.MD) error
  • func (m *MockServerStream) SetTrailer(arg0 metadata.MD)
• type MockServerStreamContextCall
  • func (c *MockServerStreamContextCall) Do(f func() context.Context) *MockServerStreamContextCall
  • func (c *MockServerStreamContextCall) DoAndReturn(f func() context.Context) *MockServerStreamContextCall
  • func (c *MockServerStreamContextCall) Return(arg0 context.Context) *MockServerStreamContextCall
• type MockServerStreamMockRecorder
  • func (mr *MockServerStreamMockRecorder) Context() *MockServerStreamContextCall
  • func (mr *MockServerStreamMockRecorder) RecvMsg(arg0 any) *MockServerStreamRecvMsgCall
  • func (mr *MockServerStreamMockRecorder) SendHeader(arg0 any) *MockServerStreamSendHeaderCall
  • func (mr *MockServerStreamMockRecorder) SendMsg(arg0 any) *MockServerStreamSendMsgCall
  • func (mr *MockServerStreamMockRecorder) SetHeader(arg0 any) *MockServerStreamSetHeaderCall
  • func (mr *MockServerStreamMockRecorder) SetTrailer(arg0 any) *MockServerStreamSetTrailerCall
• type MockServerStreamRecvMsgCall
  • func (c *MockServerStreamRecvMsgCall) Do(f func(any) error) *MockServerStreamRecvMsgCall
  • func (c *MockServerStreamRecvMsgCall) DoAndReturn(f func(any) error) *MockServerStreamRecvMsgCall
  • func (c *MockServerStreamRecvMsgCall) Return(arg0 error) *MockServerStreamRecvMsgCall
• type MockServerStreamSendHeaderCall
  • func (c *MockServerStreamSendHeaderCall) Do(f func(metadata.MD) error) *MockServerStreamSendHeaderCall
  • func (c *MockServerStreamSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockServerStreamSendHeaderCall
  • func (c *MockServerStreamSendHeaderCall) Return(arg0 error) *MockServerStreamSendHeaderCall
• type MockServerStreamSendMsgCall
  • func (c *MockServerStreamSendMsgCall) Do(f func(any) error) *MockServerStreamSendMsgCall
  • func (c *MockServerStreamSendMsgCall) DoAndReturn(f func(any) error) *MockServerStreamSendMsgCall
  • func (c *MockServerStreamSendMsgCall) Return(arg0 error) *MockServerStreamSendMsgCall
• type MockServerStreamSetHeaderCall
  • func (c *MockServerStreamSetHeaderCall) Do(f func(metadata.MD) error) *MockServerStreamSetHeaderCall
  • func (c *MockServerStreamSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockServerStreamSetHeaderCall
  • func (c *MockServerStreamSetHeaderCall) Return(arg0 error) *MockServerStreamSetHeaderCall
• type MockServerStreamSetTrailerCall
  • func (c *MockServerStreamSetTrailerCall) Do(f func(metadata.MD)) *MockServerStreamSetTrailerCall
  • func (c *MockServerStreamSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockServerStreamSetTrailerCall
  • func (c *MockServerStreamSetTrailerCall) Return() *MockServerStreamSetTrailerCall
• type MockServerTransportStream
  • func NewMockServerTransportStream(ctrl *gomock.Controller) *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 MockServerTransportStreamMethodCall
  • func (c *MockServerTransportStreamMethodCall) Do(f func() string) *MockServerTransportStreamMethodCall
  • func (c *MockServerTransportStreamMethodCall) DoAndReturn(f func() string) *MockServerTransportStreamMethodCall
  • func (c *MockServerTransportStreamMethodCall) Return(arg0 string) *MockServerTransportStreamMethodCall
• type MockServerTransportStreamMockRecorder
  • func (mr *MockServerTransportStreamMockRecorder) Method() *MockServerTransportStreamMethodCall
  • func (mr *MockServerTransportStreamMockRecorder) SendHeader(arg0 any) *MockServerTransportStreamSendHeaderCall
  • func (mr *MockServerTransportStreamMockRecorder) SetHeader(arg0 any) *MockServerTransportStreamSetHeaderCall
  • func (mr *MockServerTransportStreamMockRecorder) SetTrailer(arg0 any) *MockServerTransportStreamSetTrailerCall
• type MockServerTransportStreamSendHeaderCall
  • func (c *MockServerTransportStreamSendHeaderCall) Do(f func(metadata.MD) error) *MockServerTransportStreamSendHeaderCall
  • func (c *MockServerTransportStreamSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockServerTransportStreamSendHeaderCall
  • func (c *MockServerTransportStreamSendHeaderCall) Return(arg0 error) *MockServerTransportStreamSendHeaderCall
• type MockServerTransportStreamSetHeaderCall
  • func (c *MockServerTransportStreamSetHeaderCall) Do(f func(metadata.MD) error) *MockServerTransportStreamSetHeaderCall
  • func (c *MockServerTransportStreamSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockServerTransportStreamSetHeaderCall
  • func (c *MockServerTransportStreamSetHeaderCall) Return(arg0 error) *MockServerTransportStreamSetHeaderCall
• type MockServerTransportStreamSetTrailerCall
  • func (c *MockServerTransportStreamSetTrailerCall) Do(f func(metadata.MD) error) *MockServerTransportStreamSetTrailerCall
  • func (c *MockServerTransportStreamSetTrailerCall) DoAndReturn(f func(metadata.MD) error) *MockServerTransportStreamSetTrailerCall
  • func (c *MockServerTransportStreamSetTrailerCall) Return(arg0 error) *MockServerTransportStreamSetTrailerCall

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 MockAgentConfigurationClientGetConfigurationCall

type MockAgentConfigurationClientGetConfigurationCall struct {
	*gomock.Call
}

MockAgentConfigurationClientGetConfigurationCall wrap *gomock.Call

func (*MockAgentConfigurationClientGetConfigurationCall) Do

func (c *MockAgentConfigurationClientGetConfigurationCall) Do(f func(context.Context, *rpc.ConfigurationRequest, ...grpc.CallOption) (rpc.AgentConfiguration_GetConfigurationClient, error)) *MockAgentConfigurationClientGetConfigurationCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfigurationClientGetConfigurationCall) DoAndReturn

func (c *MockAgentConfigurationClientGetConfigurationCall) DoAndReturn(f func(context.Context, *rpc.ConfigurationRequest, ...grpc.CallOption) (rpc.AgentConfiguration_GetConfigurationClient, error)) *MockAgentConfigurationClientGetConfigurationCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfigurationClientGetConfigurationCall) Return

func (c *MockAgentConfigurationClientGetConfigurationCall) Return(arg0 rpc.AgentConfiguration_GetConfigurationClient, arg1 error) *MockAgentConfigurationClientGetConfigurationCall

Return rewrite *gomock.Call.Return

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 any, arg2 ...any) *MockAgentConfigurationClientGetConfigurationCall

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 any) error

RecvMsg mocks base method.

func (*MockAgentConfiguration_GetConfigurationClient) SendMsg

func (m *MockAgentConfiguration_GetConfigurationClient) SendMsg(arg0 any) error

SendMsg mocks base method.

func (*MockAgentConfiguration_GetConfigurationClient) Trailer

func (m *MockAgentConfiguration_GetConfigurationClient) Trailer() metadata.MD

Trailer mocks base method.

type MockAgentConfiguration_GetConfigurationClientCloseSendCall

type MockAgentConfiguration_GetConfigurationClientCloseSendCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientCloseSendCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationClientCloseSendCall) Do

func (c *MockAgentConfiguration_GetConfigurationClientCloseSendCall) Do(f func() error) *MockAgentConfiguration_GetConfigurationClientCloseSendCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationClientCloseSendCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationClientCloseSendCall) DoAndReturn(f func() error) *MockAgentConfiguration_GetConfigurationClientCloseSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationClientCloseSendCall) Return

func (c *MockAgentConfiguration_GetConfigurationClientCloseSendCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationClientCloseSendCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationClientContextCall

type MockAgentConfiguration_GetConfigurationClientContextCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientContextCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationClientContextCall) Do

func (c *MockAgentConfiguration_GetConfigurationClientContextCall) Do(f func() context.Context) *MockAgentConfiguration_GetConfigurationClientContextCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationClientContextCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationClientContextCall) DoAndReturn(f func() context.Context) *MockAgentConfiguration_GetConfigurationClientContextCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationClientContextCall) Return

func (c *MockAgentConfiguration_GetConfigurationClientContextCall) Return(arg0 context.Context) *MockAgentConfiguration_GetConfigurationClientContextCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationClientHeaderCall

type MockAgentConfiguration_GetConfigurationClientHeaderCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientHeaderCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationClientHeaderCall) Do

func (c *MockAgentConfiguration_GetConfigurationClientHeaderCall) Do(f func() (metadata.MD, error)) *MockAgentConfiguration_GetConfigurationClientHeaderCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationClientHeaderCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationClientHeaderCall) DoAndReturn(f func() (metadata.MD, error)) *MockAgentConfiguration_GetConfigurationClientHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationClientHeaderCall) Return

func (c *MockAgentConfiguration_GetConfigurationClientHeaderCall) Return(arg0 metadata.MD, arg1 error) *MockAgentConfiguration_GetConfigurationClientHeaderCall

Return rewrite *gomock.Call.Return

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() *MockAgentConfiguration_GetConfigurationClientCloseSendCall

CloseSend indicates an expected call of CloseSend.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Context

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Context() *MockAgentConfiguration_GetConfigurationClientContextCall

Context indicates an expected call of Context.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Header

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Header() *MockAgentConfiguration_GetConfigurationClientHeaderCall

Header indicates an expected call of Header.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Recv

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Recv() *MockAgentConfiguration_GetConfigurationClientRecvCall

Recv indicates an expected call of Recv.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) RecvMsg

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) RecvMsg(arg0 any) *MockAgentConfiguration_GetConfigurationClientRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) SendMsg

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) SendMsg(arg0 any) *MockAgentConfiguration_GetConfigurationClientSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Trailer

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Trailer() *MockAgentConfiguration_GetConfigurationClientTrailerCall

Trailer indicates an expected call of Trailer.

type MockAgentConfiguration_GetConfigurationClientRecvCall

type MockAgentConfiguration_GetConfigurationClientRecvCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientRecvCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationClientRecvCall) Do

func (c *MockAgentConfiguration_GetConfigurationClientRecvCall) Do(f func() (*rpc.ConfigurationResponse, error)) *MockAgentConfiguration_GetConfigurationClientRecvCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationClientRecvCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationClientRecvCall) DoAndReturn(f func() (*rpc.ConfigurationResponse, error)) *MockAgentConfiguration_GetConfigurationClientRecvCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationClientRecvCall) Return

func (c *MockAgentConfiguration_GetConfigurationClientRecvCall) Return(arg0 *rpc.ConfigurationResponse, arg1 error) *MockAgentConfiguration_GetConfigurationClientRecvCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationClientRecvMsgCall

type MockAgentConfiguration_GetConfigurationClientRecvMsgCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientRecvMsgCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationClientRecvMsgCall) Do

func (c *MockAgentConfiguration_GetConfigurationClientRecvMsgCall) Do(f func(any) error) *MockAgentConfiguration_GetConfigurationClientRecvMsgCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationClientRecvMsgCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationClientRecvMsgCall) DoAndReturn(f func(any) error) *MockAgentConfiguration_GetConfigurationClientRecvMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationClientRecvMsgCall) Return

func (c *MockAgentConfiguration_GetConfigurationClientRecvMsgCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationClientRecvMsgCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationClientSendMsgCall

type MockAgentConfiguration_GetConfigurationClientSendMsgCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientSendMsgCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationClientSendMsgCall) Do

func (c *MockAgentConfiguration_GetConfigurationClientSendMsgCall) Do(f func(any) error) *MockAgentConfiguration_GetConfigurationClientSendMsgCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationClientSendMsgCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationClientSendMsgCall) DoAndReturn(f func(any) error) *MockAgentConfiguration_GetConfigurationClientSendMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationClientSendMsgCall) Return

func (c *MockAgentConfiguration_GetConfigurationClientSendMsgCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationClientSendMsgCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationClientTrailerCall

type MockAgentConfiguration_GetConfigurationClientTrailerCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientTrailerCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationClientTrailerCall) Do

func (c *MockAgentConfiguration_GetConfigurationClientTrailerCall) Do(f func() metadata.MD) *MockAgentConfiguration_GetConfigurationClientTrailerCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationClientTrailerCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationClientTrailerCall) DoAndReturn(f func() metadata.MD) *MockAgentConfiguration_GetConfigurationClientTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationClientTrailerCall) Return

func (c *MockAgentConfiguration_GetConfigurationClientTrailerCall) Return(arg0 metadata.MD) *MockAgentConfiguration_GetConfigurationClientTrailerCall

Return rewrite *gomock.Call.Return

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 any) 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 any) 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_GetConfigurationServerContextCall

type MockAgentConfiguration_GetConfigurationServerContextCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerContextCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationServerContextCall) Do

func (c *MockAgentConfiguration_GetConfigurationServerContextCall) Do(f func() context.Context) *MockAgentConfiguration_GetConfigurationServerContextCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationServerContextCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationServerContextCall) DoAndReturn(f func() context.Context) *MockAgentConfiguration_GetConfigurationServerContextCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationServerContextCall) Return

func (c *MockAgentConfiguration_GetConfigurationServerContextCall) Return(arg0 context.Context) *MockAgentConfiguration_GetConfigurationServerContextCall

Return rewrite *gomock.Call.Return

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() *MockAgentConfiguration_GetConfigurationServerContextCall

Context indicates an expected call of Context.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) RecvMsg

func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) RecvMsg(arg0 any) *MockAgentConfiguration_GetConfigurationServerRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) Send

func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) Send(arg0 any) *MockAgentConfiguration_GetConfigurationServerSendCall

Send indicates an expected call of Send.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SendHeader

func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SendHeader(arg0 any) *MockAgentConfiguration_GetConfigurationServerSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SendMsg

func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SendMsg(arg0 any) *MockAgentConfiguration_GetConfigurationServerSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SetHeader

func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SetHeader(arg0 any) *MockAgentConfiguration_GetConfigurationServerSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SetTrailer

func (mr *MockAgentConfiguration_GetConfigurationServerMockRecorder) SetTrailer(arg0 any) *MockAgentConfiguration_GetConfigurationServerSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type MockAgentConfiguration_GetConfigurationServerRecvMsgCall

type MockAgentConfiguration_GetConfigurationServerRecvMsgCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerRecvMsgCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationServerRecvMsgCall) Do

func (c *MockAgentConfiguration_GetConfigurationServerRecvMsgCall) Do(f func(any) error) *MockAgentConfiguration_GetConfigurationServerRecvMsgCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationServerRecvMsgCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationServerRecvMsgCall) DoAndReturn(f func(any) error) *MockAgentConfiguration_GetConfigurationServerRecvMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationServerRecvMsgCall) Return

func (c *MockAgentConfiguration_GetConfigurationServerRecvMsgCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerRecvMsgCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationServerSendCall

type MockAgentConfiguration_GetConfigurationServerSendCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSendCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationServerSendCall) Do

func (c *MockAgentConfiguration_GetConfigurationServerSendCall) Do(f func(*rpc.ConfigurationResponse) error) *MockAgentConfiguration_GetConfigurationServerSendCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationServerSendCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationServerSendCall) DoAndReturn(f func(*rpc.ConfigurationResponse) error) *MockAgentConfiguration_GetConfigurationServerSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationServerSendCall) Return

func (c *MockAgentConfiguration_GetConfigurationServerSendCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerSendCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationServerSendHeaderCall

type MockAgentConfiguration_GetConfigurationServerSendHeaderCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSendHeaderCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationServerSendHeaderCall) Do

func (c *MockAgentConfiguration_GetConfigurationServerSendHeaderCall) Do(f func(metadata.MD) error) *MockAgentConfiguration_GetConfigurationServerSendHeaderCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationServerSendHeaderCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationServerSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockAgentConfiguration_GetConfigurationServerSendHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationServerSendHeaderCall) Return

func (c *MockAgentConfiguration_GetConfigurationServerSendHeaderCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerSendHeaderCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationServerSendMsgCall

type MockAgentConfiguration_GetConfigurationServerSendMsgCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSendMsgCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationServerSendMsgCall) Do

func (c *MockAgentConfiguration_GetConfigurationServerSendMsgCall) Do(f func(any) error) *MockAgentConfiguration_GetConfigurationServerSendMsgCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationServerSendMsgCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationServerSendMsgCall) DoAndReturn(f func(any) error) *MockAgentConfiguration_GetConfigurationServerSendMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationServerSendMsgCall) Return

func (c *MockAgentConfiguration_GetConfigurationServerSendMsgCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerSendMsgCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationServerSetHeaderCall

type MockAgentConfiguration_GetConfigurationServerSetHeaderCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSetHeaderCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationServerSetHeaderCall) Do

func (c *MockAgentConfiguration_GetConfigurationServerSetHeaderCall) Do(f func(metadata.MD) error) *MockAgentConfiguration_GetConfigurationServerSetHeaderCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationServerSetHeaderCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationServerSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockAgentConfiguration_GetConfigurationServerSetHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationServerSetHeaderCall) Return

func (c *MockAgentConfiguration_GetConfigurationServerSetHeaderCall) Return(arg0 error) *MockAgentConfiguration_GetConfigurationServerSetHeaderCall

Return rewrite *gomock.Call.Return

type MockAgentConfiguration_GetConfigurationServerSetTrailerCall

type MockAgentConfiguration_GetConfigurationServerSetTrailerCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSetTrailerCall wrap *gomock.Call

func (*MockAgentConfiguration_GetConfigurationServerSetTrailerCall) Do

func (c *MockAgentConfiguration_GetConfigurationServerSetTrailerCall) Do(f func(metadata.MD)) *MockAgentConfiguration_GetConfigurationServerSetTrailerCall

Do rewrite *gomock.Call.Do

func (*MockAgentConfiguration_GetConfigurationServerSetTrailerCall) DoAndReturn

func (c *MockAgentConfiguration_GetConfigurationServerSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockAgentConfiguration_GetConfigurationServerSetTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockAgentConfiguration_GetConfigurationServerSetTrailerCall) Return

func (c *MockAgentConfiguration_GetConfigurationServerSetTrailerCall) Return() *MockAgentConfiguration_GetConfigurationServerSetTrailerCall

Return rewrite *gomock.Call.Return

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 any, 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 MockClientConnInterfaceInvokeCall

type MockClientConnInterfaceInvokeCall struct {
	*gomock.Call
}

MockClientConnInterfaceInvokeCall wrap *gomock.Call

func (*MockClientConnInterfaceInvokeCall) Do

func (c *MockClientConnInterfaceInvokeCall) Do(f func(context.Context, string, any, any, ...grpc.CallOption) error) *MockClientConnInterfaceInvokeCall

Do rewrite *gomock.Call.Do

func (*MockClientConnInterfaceInvokeCall) DoAndReturn

func (c *MockClientConnInterfaceInvokeCall) DoAndReturn(f func(context.Context, string, any, any, ...grpc.CallOption) error) *MockClientConnInterfaceInvokeCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientConnInterfaceInvokeCall) Return

func (c *MockClientConnInterfaceInvokeCall) Return(arg0 error) *MockClientConnInterfaceInvokeCall

Return rewrite *gomock.Call.Return

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 any, arg4 ...any) *MockClientConnInterfaceInvokeCall

Invoke indicates an expected call of Invoke.

func (*MockClientConnInterfaceMockRecorder) NewStream

func (mr *MockClientConnInterfaceMockRecorder) NewStream(arg0, arg1, arg2 any, arg3 ...any) *MockClientConnInterfaceNewStreamCall

NewStream indicates an expected call of NewStream.

type MockClientConnInterfaceNewStreamCall

type MockClientConnInterfaceNewStreamCall struct {
	*gomock.Call
}

MockClientConnInterfaceNewStreamCall wrap *gomock.Call

func (*MockClientConnInterfaceNewStreamCall) Do

func (c *MockClientConnInterfaceNewStreamCall) Do(f func(context.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error)) *MockClientConnInterfaceNewStreamCall

Do rewrite *gomock.Call.Do

func (*MockClientConnInterfaceNewStreamCall) DoAndReturn

func (c *MockClientConnInterfaceNewStreamCall) DoAndReturn(f func(context.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error)) *MockClientConnInterfaceNewStreamCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientConnInterfaceNewStreamCall) Return

func (c *MockClientConnInterfaceNewStreamCall) Return(arg0 grpc.ClientStream, arg1 error) *MockClientConnInterfaceNewStreamCall

Return rewrite *gomock.Call.Return

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, []any)

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 any) error

RecvMsg mocks base method.

func (*MockClientStream) SendMsg

func (m *MockClientStream) SendMsg(arg0 any) error

SendMsg mocks base method.

func (*MockClientStream) Trailer

func (m *MockClientStream) Trailer() metadata.MD

Trailer mocks base method.

type MockClientStreamCloseSendCall

type MockClientStreamCloseSendCall struct {
	*gomock.Call
}

MockClientStreamCloseSendCall wrap *gomock.Call

func (*MockClientStreamCloseSendCall) Do

func (c *MockClientStreamCloseSendCall) Do(f func() error) *MockClientStreamCloseSendCall

Do rewrite *gomock.Call.Do

func (*MockClientStreamCloseSendCall) DoAndReturn

func (c *MockClientStreamCloseSendCall) DoAndReturn(f func() error) *MockClientStreamCloseSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientStreamCloseSendCall) Return

func (c *MockClientStreamCloseSendCall) Return(arg0 error) *MockClientStreamCloseSendCall

Return rewrite *gomock.Call.Return

type MockClientStreamContextCall

type MockClientStreamContextCall struct {
	*gomock.Call
}

MockClientStreamContextCall wrap *gomock.Call

func (*MockClientStreamContextCall) Do

func (c *MockClientStreamContextCall) Do(f func() context.Context) *MockClientStreamContextCall

Do rewrite *gomock.Call.Do

func (*MockClientStreamContextCall) DoAndReturn

func (c *MockClientStreamContextCall) DoAndReturn(f func() context.Context) *MockClientStreamContextCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientStreamContextCall) Return

func (c *MockClientStreamContextCall) Return(arg0 context.Context) *MockClientStreamContextCall

Return rewrite *gomock.Call.Return

type MockClientStreamHeaderCall

type MockClientStreamHeaderCall struct {
	*gomock.Call
}

MockClientStreamHeaderCall wrap *gomock.Call

func (*MockClientStreamHeaderCall) Do

func (c *MockClientStreamHeaderCall) Do(f func() (metadata.MD, error)) *MockClientStreamHeaderCall

Do rewrite *gomock.Call.Do

func (*MockClientStreamHeaderCall) DoAndReturn

func (c *MockClientStreamHeaderCall) DoAndReturn(f func() (metadata.MD, error)) *MockClientStreamHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientStreamHeaderCall) Return

func (c *MockClientStreamHeaderCall) Return(arg0 metadata.MD, arg1 error) *MockClientStreamHeaderCall

Return rewrite *gomock.Call.Return

type MockClientStreamMockRecorder

type MockClientStreamMockRecorder struct {
	// contains filtered or unexported fields
}

MockClientStreamMockRecorder is the mock recorder for MockClientStream.

func (*MockClientStreamMockRecorder) CloseSend

func (mr *MockClientStreamMockRecorder) CloseSend() *MockClientStreamCloseSendCall

CloseSend indicates an expected call of CloseSend.

func (*MockClientStreamMockRecorder) Context

func (mr *MockClientStreamMockRecorder) Context() *MockClientStreamContextCall

Context indicates an expected call of Context.

func (*MockClientStreamMockRecorder) Header

func (mr *MockClientStreamMockRecorder) Header() *MockClientStreamHeaderCall

Header indicates an expected call of Header.

func (*MockClientStreamMockRecorder) RecvMsg

func (mr *MockClientStreamMockRecorder) RecvMsg(arg0 any) *MockClientStreamRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockClientStreamMockRecorder) SendMsg

func (mr *MockClientStreamMockRecorder) SendMsg(arg0 any) *MockClientStreamSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockClientStreamMockRecorder) Trailer

func (mr *MockClientStreamMockRecorder) Trailer() *MockClientStreamTrailerCall

Trailer indicates an expected call of Trailer.

type MockClientStreamRecvMsgCall

type MockClientStreamRecvMsgCall struct {
	*gomock.Call
}

MockClientStreamRecvMsgCall wrap *gomock.Call

func (*MockClientStreamRecvMsgCall) Do

func (c *MockClientStreamRecvMsgCall) Do(f func(any) error) *MockClientStreamRecvMsgCall

Do rewrite *gomock.Call.Do

func (*MockClientStreamRecvMsgCall) DoAndReturn

func (c *MockClientStreamRecvMsgCall) DoAndReturn(f func(any) error) *MockClientStreamRecvMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientStreamRecvMsgCall) Return

func (c *MockClientStreamRecvMsgCall) Return(arg0 error) *MockClientStreamRecvMsgCall

Return rewrite *gomock.Call.Return

type MockClientStreamSendMsgCall

type MockClientStreamSendMsgCall struct {
	*gomock.Call
}

MockClientStreamSendMsgCall wrap *gomock.Call

func (*MockClientStreamSendMsgCall) Do

func (c *MockClientStreamSendMsgCall) Do(f func(any) error) *MockClientStreamSendMsgCall

Do rewrite *gomock.Call.Do

func (*MockClientStreamSendMsgCall) DoAndReturn

func (c *MockClientStreamSendMsgCall) DoAndReturn(f func(any) error) *MockClientStreamSendMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientStreamSendMsgCall) Return

func (c *MockClientStreamSendMsgCall) Return(arg0 error) *MockClientStreamSendMsgCall

Return rewrite *gomock.Call.Return

type MockClientStreamTrailerCall

type MockClientStreamTrailerCall struct {
	*gomock.Call
}

MockClientStreamTrailerCall wrap *gomock.Call

func (*MockClientStreamTrailerCall) Do

func (c *MockClientStreamTrailerCall) Do(f func() metadata.MD) *MockClientStreamTrailerCall

Do rewrite *gomock.Call.Do

func (*MockClientStreamTrailerCall) DoAndReturn

func (c *MockClientStreamTrailerCall) DoAndReturn(f func() metadata.MD) *MockClientStreamTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockClientStreamTrailerCall) Return

func (c *MockClientStreamTrailerCall) Return(arg0 metadata.MD) *MockClientStreamTrailerCall

Return rewrite *gomock.Call.Return

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 any) *MockConfigurationWatcherInterfaceWatchCall

Watch indicates an expected call of Watch.

type MockConfigurationWatcherInterfaceWatchCall

type MockConfigurationWatcherInterfaceWatchCall struct {
	*gomock.Call
}

MockConfigurationWatcherInterfaceWatchCall wrap *gomock.Call

func (*MockConfigurationWatcherInterfaceWatchCall) Do

func (c *MockConfigurationWatcherInterfaceWatchCall) Do(f func(context.Context, rpc.ConfigurationCallback)) *MockConfigurationWatcherInterfaceWatchCall

Do rewrite *gomock.Call.Do

func (*MockConfigurationWatcherInterfaceWatchCall) DoAndReturn

func (c *MockConfigurationWatcherInterfaceWatchCall) DoAndReturn(f func(context.Context, rpc.ConfigurationCallback)) *MockConfigurationWatcherInterfaceWatchCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockConfigurationWatcherInterfaceWatchCall) Return

func (c *MockConfigurationWatcherInterfaceWatchCall) Return() *MockConfigurationWatcherInterfaceWatchCall

Return rewrite *gomock.Call.Return

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 any) 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 any) 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_MakeRequestServerContextCall

type MockGitlabAccess_MakeRequestServerContextCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerContextCall wrap *gomock.Call

func (*MockGitlabAccess_MakeRequestServerContextCall) Do

func (c *MockGitlabAccess_MakeRequestServerContextCall) Do(f func() context.Context) *MockGitlabAccess_MakeRequestServerContextCall

Do rewrite *gomock.Call.Do

func (*MockGitlabAccess_MakeRequestServerContextCall) DoAndReturn

func (c *MockGitlabAccess_MakeRequestServerContextCall) DoAndReturn(f func() context.Context) *MockGitlabAccess_MakeRequestServerContextCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitlabAccess_MakeRequestServerContextCall) Return

func (c *MockGitlabAccess_MakeRequestServerContextCall) Return(arg0 context.Context) *MockGitlabAccess_MakeRequestServerContextCall

Return rewrite *gomock.Call.Return

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() *MockGitlabAccess_MakeRequestServerContextCall

Context indicates an expected call of Context.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) Recv

func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Recv() *MockGitlabAccess_MakeRequestServerRecvCall

Recv indicates an expected call of Recv.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) RecvMsg

func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) RecvMsg(arg0 any) *MockGitlabAccess_MakeRequestServerRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) Send

func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Send(arg0 any) *MockGitlabAccess_MakeRequestServerSendCall

Send indicates an expected call of Send.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) SendHeader

func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SendHeader(arg0 any) *MockGitlabAccess_MakeRequestServerSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) SendMsg

func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SendMsg(arg0 any) *MockGitlabAccess_MakeRequestServerSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) SetHeader

func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SetHeader(arg0 any) *MockGitlabAccess_MakeRequestServerSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) SetTrailer

func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) SetTrailer(arg0 any) *MockGitlabAccess_MakeRequestServerSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type MockGitlabAccess_MakeRequestServerRecvCall

type MockGitlabAccess_MakeRequestServerRecvCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerRecvCall wrap *gomock.Call

func (*MockGitlabAccess_MakeRequestServerRecvCall) Do

func (c *MockGitlabAccess_MakeRequestServerRecvCall) Do(f func() (*grpctool.HttpRequest, error)) *MockGitlabAccess_MakeRequestServerRecvCall

Do rewrite *gomock.Call.Do

func (*MockGitlabAccess_MakeRequestServerRecvCall) DoAndReturn

func (c *MockGitlabAccess_MakeRequestServerRecvCall) DoAndReturn(f func() (*grpctool.HttpRequest, error)) *MockGitlabAccess_MakeRequestServerRecvCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitlabAccess_MakeRequestServerRecvCall) Return

func (c *MockGitlabAccess_MakeRequestServerRecvCall) Return(arg0 *grpctool.HttpRequest, arg1 error) *MockGitlabAccess_MakeRequestServerRecvCall

Return rewrite *gomock.Call.Return

type MockGitlabAccess_MakeRequestServerRecvMsgCall

type MockGitlabAccess_MakeRequestServerRecvMsgCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerRecvMsgCall wrap *gomock.Call

func (*MockGitlabAccess_MakeRequestServerRecvMsgCall) Do

func (c *MockGitlabAccess_MakeRequestServerRecvMsgCall) Do(f func(any) error) *MockGitlabAccess_MakeRequestServerRecvMsgCall

Do rewrite *gomock.Call.Do

func (*MockGitlabAccess_MakeRequestServerRecvMsgCall) DoAndReturn

func (c *MockGitlabAccess_MakeRequestServerRecvMsgCall) DoAndReturn(f func(any) error) *MockGitlabAccess_MakeRequestServerRecvMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitlabAccess_MakeRequestServerRecvMsgCall) Return

func (c *MockGitlabAccess_MakeRequestServerRecvMsgCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerRecvMsgCall

Return rewrite *gomock.Call.Return

type MockGitlabAccess_MakeRequestServerSendCall

type MockGitlabAccess_MakeRequestServerSendCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSendCall wrap *gomock.Call

func (*MockGitlabAccess_MakeRequestServerSendCall) Do

func (c *MockGitlabAccess_MakeRequestServerSendCall) Do(f func(*grpctool.HttpResponse) error) *MockGitlabAccess_MakeRequestServerSendCall

Do rewrite *gomock.Call.Do

func (*MockGitlabAccess_MakeRequestServerSendCall) DoAndReturn

func (c *MockGitlabAccess_MakeRequestServerSendCall) DoAndReturn(f func(*grpctool.HttpResponse) error) *MockGitlabAccess_MakeRequestServerSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitlabAccess_MakeRequestServerSendCall) Return

func (c *MockGitlabAccess_MakeRequestServerSendCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerSendCall

Return rewrite *gomock.Call.Return

type MockGitlabAccess_MakeRequestServerSendHeaderCall

type MockGitlabAccess_MakeRequestServerSendHeaderCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSendHeaderCall wrap *gomock.Call

func (*MockGitlabAccess_MakeRequestServerSendHeaderCall) Do

func (c *MockGitlabAccess_MakeRequestServerSendHeaderCall) Do(f func(metadata.MD) error) *MockGitlabAccess_MakeRequestServerSendHeaderCall

Do rewrite *gomock.Call.Do

func (*MockGitlabAccess_MakeRequestServerSendHeaderCall) DoAndReturn

func (c *MockGitlabAccess_MakeRequestServerSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockGitlabAccess_MakeRequestServerSendHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitlabAccess_MakeRequestServerSendHeaderCall) Return

func (c *MockGitlabAccess_MakeRequestServerSendHeaderCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerSendHeaderCall

Return rewrite *gomock.Call.Return

type MockGitlabAccess_MakeRequestServerSendMsgCall

type MockGitlabAccess_MakeRequestServerSendMsgCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSendMsgCall wrap *gomock.Call

func (*MockGitlabAccess_MakeRequestServerSendMsgCall) Do

func (c *MockGitlabAccess_MakeRequestServerSendMsgCall) Do(f func(any) error) *MockGitlabAccess_MakeRequestServerSendMsgCall

Do rewrite *gomock.Call.Do

func (*MockGitlabAccess_MakeRequestServerSendMsgCall) DoAndReturn

func (c *MockGitlabAccess_MakeRequestServerSendMsgCall) DoAndReturn(f func(any) error) *MockGitlabAccess_MakeRequestServerSendMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitlabAccess_MakeRequestServerSendMsgCall) Return

func (c *MockGitlabAccess_MakeRequestServerSendMsgCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerSendMsgCall

Return rewrite *gomock.Call.Return

type MockGitlabAccess_MakeRequestServerSetHeaderCall

type MockGitlabAccess_MakeRequestServerSetHeaderCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSetHeaderCall wrap *gomock.Call

func (*MockGitlabAccess_MakeRequestServerSetHeaderCall) Do

func (c *MockGitlabAccess_MakeRequestServerSetHeaderCall) Do(f func(metadata.MD) error) *MockGitlabAccess_MakeRequestServerSetHeaderCall

Do rewrite *gomock.Call.Do

func (*MockGitlabAccess_MakeRequestServerSetHeaderCall) DoAndReturn

func (c *MockGitlabAccess_MakeRequestServerSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockGitlabAccess_MakeRequestServerSetHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitlabAccess_MakeRequestServerSetHeaderCall) Return

func (c *MockGitlabAccess_MakeRequestServerSetHeaderCall) Return(arg0 error) *MockGitlabAccess_MakeRequestServerSetHeaderCall

Return rewrite *gomock.Call.Return

type MockGitlabAccess_MakeRequestServerSetTrailerCall

type MockGitlabAccess_MakeRequestServerSetTrailerCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSetTrailerCall wrap *gomock.Call

func (*MockGitlabAccess_MakeRequestServerSetTrailerCall) Do

func (c *MockGitlabAccess_MakeRequestServerSetTrailerCall) Do(f func(metadata.MD)) *MockGitlabAccess_MakeRequestServerSetTrailerCall

Do rewrite *gomock.Call.Do

func (*MockGitlabAccess_MakeRequestServerSetTrailerCall) DoAndReturn

func (c *MockGitlabAccess_MakeRequestServerSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockGitlabAccess_MakeRequestServerSetTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitlabAccess_MakeRequestServerSetTrailerCall) Return

func (c *MockGitlabAccess_MakeRequestServerSetTrailerCall) Return() *MockGitlabAccess_MakeRequestServerSetTrailerCall

Return rewrite *gomock.Call.Return

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 MockGitopsClientGetObjectsToSynchronizeCall

type MockGitopsClientGetObjectsToSynchronizeCall struct {
	*gomock.Call
}

MockGitopsClientGetObjectsToSynchronizeCall wrap *gomock.Call

func (*MockGitopsClientGetObjectsToSynchronizeCall) Do

func (c *MockGitopsClientGetObjectsToSynchronizeCall) Do(f func(context.Context, *rpc.ObjectsToSynchronizeRequest, ...grpc.CallOption) (rpc.Gitops_GetObjectsToSynchronizeClient, error)) *MockGitopsClientGetObjectsToSynchronizeCall

Do rewrite *gomock.Call.Do

func (*MockGitopsClientGetObjectsToSynchronizeCall) DoAndReturn

func (c *MockGitopsClientGetObjectsToSynchronizeCall) DoAndReturn(f func(context.Context, *rpc.ObjectsToSynchronizeRequest, ...grpc.CallOption) (rpc.Gitops_GetObjectsToSynchronizeClient, error)) *MockGitopsClientGetObjectsToSynchronizeCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitopsClientGetObjectsToSynchronizeCall) Return

func (c *MockGitopsClientGetObjectsToSynchronizeCall) Return(arg0 rpc.Gitops_GetObjectsToSynchronizeClient, arg1 error) *MockGitopsClientGetObjectsToSynchronizeCall

Return rewrite *gomock.Call.Return

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 any, arg2 ...any) *MockGitopsClientGetObjectsToSynchronizeCall

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 any) error

RecvMsg mocks base method.

func (*MockGitops_GetObjectsToSynchronizeClient) SendMsg

func (m *MockGitops_GetObjectsToSynchronizeClient) SendMsg(arg0 any) error

SendMsg mocks base method.

func (*MockGitops_GetObjectsToSynchronizeClient) Trailer

func (m *MockGitops_GetObjectsToSynchronizeClient) Trailer() metadata.MD

Trailer mocks base method.

type MockGitops_GetObjectsToSynchronizeClientCloseSendCall

type MockGitops_GetObjectsToSynchronizeClientCloseSendCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientCloseSendCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeClientCloseSendCall) Do

func (c *MockGitops_GetObjectsToSynchronizeClientCloseSendCall) Do(f func() error) *MockGitops_GetObjectsToSynchronizeClientCloseSendCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeClientCloseSendCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeClientCloseSendCall) DoAndReturn(f func() error) *MockGitops_GetObjectsToSynchronizeClientCloseSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeClientCloseSendCall) Return

func (c *MockGitops_GetObjectsToSynchronizeClientCloseSendCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeClientCloseSendCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeClientContextCall

type MockGitops_GetObjectsToSynchronizeClientContextCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientContextCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeClientContextCall) Do

func (c *MockGitops_GetObjectsToSynchronizeClientContextCall) Do(f func() context.Context) *MockGitops_GetObjectsToSynchronizeClientContextCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeClientContextCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeClientContextCall) DoAndReturn(f func() context.Context) *MockGitops_GetObjectsToSynchronizeClientContextCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeClientContextCall) Return

func (c *MockGitops_GetObjectsToSynchronizeClientContextCall) Return(arg0 context.Context) *MockGitops_GetObjectsToSynchronizeClientContextCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeClientHeaderCall

type MockGitops_GetObjectsToSynchronizeClientHeaderCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientHeaderCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeClientHeaderCall) Do

func (c *MockGitops_GetObjectsToSynchronizeClientHeaderCall) Do(f func() (metadata.MD, error)) *MockGitops_GetObjectsToSynchronizeClientHeaderCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeClientHeaderCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeClientHeaderCall) DoAndReturn(f func() (metadata.MD, error)) *MockGitops_GetObjectsToSynchronizeClientHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeClientHeaderCall) Return

func (c *MockGitops_GetObjectsToSynchronizeClientHeaderCall) Return(arg0 metadata.MD, arg1 error) *MockGitops_GetObjectsToSynchronizeClientHeaderCall

Return rewrite *gomock.Call.Return

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() *MockGitops_GetObjectsToSynchronizeClientCloseSendCall

CloseSend indicates an expected call of CloseSend.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Context

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Context() *MockGitops_GetObjectsToSynchronizeClientContextCall

Context indicates an expected call of Context.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Header

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Header() *MockGitops_GetObjectsToSynchronizeClientHeaderCall

Header indicates an expected call of Header.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Recv

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Recv() *MockGitops_GetObjectsToSynchronizeClientRecvCall

Recv indicates an expected call of Recv.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) RecvMsg

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) RecvMsg(arg0 any) *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) SendMsg

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) SendMsg(arg0 any) *MockGitops_GetObjectsToSynchronizeClientSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Trailer

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Trailer() *MockGitops_GetObjectsToSynchronizeClientTrailerCall

Trailer indicates an expected call of Trailer.

type MockGitops_GetObjectsToSynchronizeClientRecvCall

type MockGitops_GetObjectsToSynchronizeClientRecvCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientRecvCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeClientRecvCall) Do

func (c *MockGitops_GetObjectsToSynchronizeClientRecvCall) Do(f func() (*rpc.ObjectsToSynchronizeResponse, error)) *MockGitops_GetObjectsToSynchronizeClientRecvCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeClientRecvCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeClientRecvCall) DoAndReturn(f func() (*rpc.ObjectsToSynchronizeResponse, error)) *MockGitops_GetObjectsToSynchronizeClientRecvCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeClientRecvCall) Return

func (c *MockGitops_GetObjectsToSynchronizeClientRecvCall) Return(arg0 *rpc.ObjectsToSynchronizeResponse, arg1 error) *MockGitops_GetObjectsToSynchronizeClientRecvCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeClientRecvMsgCall

type MockGitops_GetObjectsToSynchronizeClientRecvMsgCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientRecvMsgCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) Do

func (c *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) Do(f func(any) error) *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) DoAndReturn(f func(any) error) *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) Return

func (c *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeClientRecvMsgCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeClientSendMsgCall

type MockGitops_GetObjectsToSynchronizeClientSendMsgCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientSendMsgCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeClientSendMsgCall) Do

func (c *MockGitops_GetObjectsToSynchronizeClientSendMsgCall) Do(f func(any) error) *MockGitops_GetObjectsToSynchronizeClientSendMsgCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeClientSendMsgCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeClientSendMsgCall) DoAndReturn(f func(any) error) *MockGitops_GetObjectsToSynchronizeClientSendMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeClientSendMsgCall) Return

func (c *MockGitops_GetObjectsToSynchronizeClientSendMsgCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeClientSendMsgCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeClientTrailerCall

type MockGitops_GetObjectsToSynchronizeClientTrailerCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientTrailerCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeClientTrailerCall) Do

func (c *MockGitops_GetObjectsToSynchronizeClientTrailerCall) Do(f func() metadata.MD) *MockGitops_GetObjectsToSynchronizeClientTrailerCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeClientTrailerCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeClientTrailerCall) DoAndReturn(f func() metadata.MD) *MockGitops_GetObjectsToSynchronizeClientTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeClientTrailerCall) Return

func (c *MockGitops_GetObjectsToSynchronizeClientTrailerCall) Return(arg0 metadata.MD) *MockGitops_GetObjectsToSynchronizeClientTrailerCall

Return rewrite *gomock.Call.Return

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 any) 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 any) 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_GetObjectsToSynchronizeServerContextCall

type MockGitops_GetObjectsToSynchronizeServerContextCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerContextCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeServerContextCall) Do

func (c *MockGitops_GetObjectsToSynchronizeServerContextCall) Do(f func() context.Context) *MockGitops_GetObjectsToSynchronizeServerContextCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeServerContextCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeServerContextCall) DoAndReturn(f func() context.Context) *MockGitops_GetObjectsToSynchronizeServerContextCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeServerContextCall) Return

func (c *MockGitops_GetObjectsToSynchronizeServerContextCall) Return(arg0 context.Context) *MockGitops_GetObjectsToSynchronizeServerContextCall

Return rewrite *gomock.Call.Return

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() *MockGitops_GetObjectsToSynchronizeServerContextCall

Context indicates an expected call of Context.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) RecvMsg

func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) RecvMsg(arg0 any) *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) Send

func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) Send(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSendCall

Send indicates an expected call of Send.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendHeader

func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendHeader(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendMsg

func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendMsg(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetHeader

func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetHeader(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetTrailer

func (mr *MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetTrailer(arg0 any) *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type MockGitops_GetObjectsToSynchronizeServerRecvMsgCall

type MockGitops_GetObjectsToSynchronizeServerRecvMsgCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerRecvMsgCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) Do

func (c *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) Do(f func(any) error) *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) DoAndReturn(f func(any) error) *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) Return

func (c *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerRecvMsgCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeServerSendCall

type MockGitops_GetObjectsToSynchronizeServerSendCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSendCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeServerSendCall) Do

func (c *MockGitops_GetObjectsToSynchronizeServerSendCall) Do(f func(*rpc.ObjectsToSynchronizeResponse) error) *MockGitops_GetObjectsToSynchronizeServerSendCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeServerSendCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeServerSendCall) DoAndReturn(f func(*rpc.ObjectsToSynchronizeResponse) error) *MockGitops_GetObjectsToSynchronizeServerSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeServerSendCall) Return

func (c *MockGitops_GetObjectsToSynchronizeServerSendCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerSendCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeServerSendHeaderCall

type MockGitops_GetObjectsToSynchronizeServerSendHeaderCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSendHeaderCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) Do

func (c *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) Do(f func(metadata.MD) error) *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) Return

func (c *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerSendHeaderCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeServerSendMsgCall

type MockGitops_GetObjectsToSynchronizeServerSendMsgCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSendMsgCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeServerSendMsgCall) Do

func (c *MockGitops_GetObjectsToSynchronizeServerSendMsgCall) Do(f func(any) error) *MockGitops_GetObjectsToSynchronizeServerSendMsgCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeServerSendMsgCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeServerSendMsgCall) DoAndReturn(f func(any) error) *MockGitops_GetObjectsToSynchronizeServerSendMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeServerSendMsgCall) Return

func (c *MockGitops_GetObjectsToSynchronizeServerSendMsgCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerSendMsgCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeServerSetHeaderCall

type MockGitops_GetObjectsToSynchronizeServerSetHeaderCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSetHeaderCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) Do

func (c *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) Do(f func(metadata.MD) error) *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) Return

func (c *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall) Return(arg0 error) *MockGitops_GetObjectsToSynchronizeServerSetHeaderCall

Return rewrite *gomock.Call.Return

type MockGitops_GetObjectsToSynchronizeServerSetTrailerCall

type MockGitops_GetObjectsToSynchronizeServerSetTrailerCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSetTrailerCall wrap *gomock.Call

func (*MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) Do

func (c *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) Do(f func(metadata.MD)) *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall

Do rewrite *gomock.Call.Do

func (*MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) DoAndReturn

func (c *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) Return

func (c *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall) Return() *MockGitops_GetObjectsToSynchronizeServerSetTrailerCall

Return rewrite *gomock.Call.Return

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 any) 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 any) 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 MockInboundGRPCToOutboundHTTPStreamContextCall

type MockInboundGRPCToOutboundHTTPStreamContextCall struct {
	*gomock.Call
}

MockInboundGRPCToOutboundHTTPStreamContextCall wrap *gomock.Call

func (*MockInboundGRPCToOutboundHTTPStreamContextCall) Do

func (c *MockInboundGRPCToOutboundHTTPStreamContextCall) Do(f func() context.Context) *MockInboundGRPCToOutboundHTTPStreamContextCall

Do rewrite *gomock.Call.Do

func (*MockInboundGRPCToOutboundHTTPStreamContextCall) DoAndReturn

func (c *MockInboundGRPCToOutboundHTTPStreamContextCall) DoAndReturn(f func() context.Context) *MockInboundGRPCToOutboundHTTPStreamContextCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockInboundGRPCToOutboundHTTPStreamContextCall) Return

func (c *MockInboundGRPCToOutboundHTTPStreamContextCall) Return(arg0 context.Context) *MockInboundGRPCToOutboundHTTPStreamContextCall

Return rewrite *gomock.Call.Return

type MockInboundGRPCToOutboundHTTPStreamMockRecorder

type MockInboundGRPCToOutboundHTTPStreamMockRecorder struct {
	// contains filtered or unexported fields
}

MockInboundGRPCToOutboundHTTPStreamMockRecorder is the mock recorder for MockInboundGRPCToOutboundHTTPStream.

func (*MockInboundGRPCToOutboundHTTPStreamMockRecorder) Context

func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) Context() *MockInboundGRPCToOutboundHTTPStreamContextCall

Context indicates an expected call of Context.

func (*MockInboundGRPCToOutboundHTTPStreamMockRecorder) RecvMsg

func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) RecvMsg(arg0 any) *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockInboundGRPCToOutboundHTTPStreamMockRecorder) Send

func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) Send(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSendCall

Send indicates an expected call of Send.

func (*MockInboundGRPCToOutboundHTTPStreamMockRecorder) SendHeader

func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) SendHeader(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*MockInboundGRPCToOutboundHTTPStreamMockRecorder) SendMsg

func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) SendMsg(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockInboundGRPCToOutboundHTTPStreamMockRecorder) SetHeader

func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) SetHeader(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*MockInboundGRPCToOutboundHTTPStreamMockRecorder) SetTrailer

func (mr *MockInboundGRPCToOutboundHTTPStreamMockRecorder) SetTrailer(arg0 any) *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type MockInboundGRPCToOutboundHTTPStreamRecvMsgCall

type MockInboundGRPCToOutboundHTTPStreamRecvMsgCall struct {
	*gomock.Call
}

MockInboundGRPCToOutboundHTTPStreamRecvMsgCall wrap *gomock.Call

func (*MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) Do

func (c *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) Do(f func(any) error) *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall

Do rewrite *gomock.Call.Do

func (*MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) DoAndReturn

func (c *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) DoAndReturn(f func(any) error) *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) Return

func (c *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamRecvMsgCall

Return rewrite *gomock.Call.Return

type MockInboundGRPCToOutboundHTTPStreamSendCall

type MockInboundGRPCToOutboundHTTPStreamSendCall struct {
	*gomock.Call
}

MockInboundGRPCToOutboundHTTPStreamSendCall wrap *gomock.Call

func (*MockInboundGRPCToOutboundHTTPStreamSendCall) Do

func (c *MockInboundGRPCToOutboundHTTPStreamSendCall) Do(f func(*grpctool.HttpResponse) error) *MockInboundGRPCToOutboundHTTPStreamSendCall

Do rewrite *gomock.Call.Do

func (*MockInboundGRPCToOutboundHTTPStreamSendCall) DoAndReturn

func (c *MockInboundGRPCToOutboundHTTPStreamSendCall) DoAndReturn(f func(*grpctool.HttpResponse) error) *MockInboundGRPCToOutboundHTTPStreamSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockInboundGRPCToOutboundHTTPStreamSendCall) Return

func (c *MockInboundGRPCToOutboundHTTPStreamSendCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamSendCall

Return rewrite *gomock.Call.Return

type MockInboundGRPCToOutboundHTTPStreamSendHeaderCall

type MockInboundGRPCToOutboundHTTPStreamSendHeaderCall struct {
	*gomock.Call
}

MockInboundGRPCToOutboundHTTPStreamSendHeaderCall wrap *gomock.Call

func (*MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) Do

func (c *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) Do(f func(metadata.MD) error) *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall

Do rewrite *gomock.Call.Do

func (*MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) DoAndReturn

func (c *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) Return

func (c *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamSendHeaderCall

Return rewrite *gomock.Call.Return

type MockInboundGRPCToOutboundHTTPStreamSendMsgCall

type MockInboundGRPCToOutboundHTTPStreamSendMsgCall struct {
	*gomock.Call
}

MockInboundGRPCToOutboundHTTPStreamSendMsgCall wrap *gomock.Call

func (*MockInboundGRPCToOutboundHTTPStreamSendMsgCall) Do

func (c *MockInboundGRPCToOutboundHTTPStreamSendMsgCall) Do(f func(any) error) *MockInboundGRPCToOutboundHTTPStreamSendMsgCall

Do rewrite *gomock.Call.Do

func (*MockInboundGRPCToOutboundHTTPStreamSendMsgCall) DoAndReturn

func (c *MockInboundGRPCToOutboundHTTPStreamSendMsgCall) DoAndReturn(f func(any) error) *MockInboundGRPCToOutboundHTTPStreamSendMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockInboundGRPCToOutboundHTTPStreamSendMsgCall) Return

func (c *MockInboundGRPCToOutboundHTTPStreamSendMsgCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamSendMsgCall

Return rewrite *gomock.Call.Return

type MockInboundGRPCToOutboundHTTPStreamSetHeaderCall

type MockInboundGRPCToOutboundHTTPStreamSetHeaderCall struct {
	*gomock.Call
}

MockInboundGRPCToOutboundHTTPStreamSetHeaderCall wrap *gomock.Call

func (*MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) Do

func (c *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) Do(f func(metadata.MD) error) *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall

Do rewrite *gomock.Call.Do

func (*MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) DoAndReturn

func (c *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) Return

func (c *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall) Return(arg0 error) *MockInboundGRPCToOutboundHTTPStreamSetHeaderCall

Return rewrite *gomock.Call.Return

type MockInboundGRPCToOutboundHTTPStreamSetTrailerCall

type MockInboundGRPCToOutboundHTTPStreamSetTrailerCall struct {
	*gomock.Call
}

MockInboundGRPCToOutboundHTTPStreamSetTrailerCall wrap *gomock.Call

func (*MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) Do

func (c *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) Do(f func(metadata.MD)) *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall

Do rewrite *gomock.Call.Do

func (*MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) DoAndReturn

func (c *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) Return

func (c *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall) Return() *MockInboundGRPCToOutboundHTTPStreamSetTrailerCall

Return rewrite *gomock.Call.Return

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 any) *MockObjectsToSynchronizeWatcherInterfaceWatchCall

Watch indicates an expected call of Watch.

type MockObjectsToSynchronizeWatcherInterfaceWatchCall

type MockObjectsToSynchronizeWatcherInterfaceWatchCall struct {
	*gomock.Call
}

MockObjectsToSynchronizeWatcherInterfaceWatchCall wrap *gomock.Call

func (*MockObjectsToSynchronizeWatcherInterfaceWatchCall) Do

func (c *MockObjectsToSynchronizeWatcherInterfaceWatchCall) Do(f func(context.Context, *rpc.ObjectsToSynchronizeRequest, rpc.ObjectsToSynchronizeCallback)) *MockObjectsToSynchronizeWatcherInterfaceWatchCall

Do rewrite *gomock.Call.Do

func (*MockObjectsToSynchronizeWatcherInterfaceWatchCall) DoAndReturn

func (c *MockObjectsToSynchronizeWatcherInterfaceWatchCall) DoAndReturn(f func(context.Context, *rpc.ObjectsToSynchronizeRequest, rpc.ObjectsToSynchronizeCallback)) *MockObjectsToSynchronizeWatcherInterfaceWatchCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockObjectsToSynchronizeWatcherInterfaceWatchCall) Return

func (c *MockObjectsToSynchronizeWatcherInterfaceWatchCall) Return() *MockObjectsToSynchronizeWatcherInterfaceWatchCall

Return rewrite *gomock.Call.Return

type MockPoolConn

type MockPoolConn struct {
	// contains filtered or unexported fields
}

MockPoolConn is a mock of PoolConn interface.

func NewMockPoolConn

func NewMockPoolConn(ctrl *gomock.Controller) *MockPoolConn

NewMockPoolConn creates a new mock instance.

func (*MockPoolConn) Done

func (m *MockPoolConn) Done()

Done mocks base method.

func (*MockPoolConn) EXPECT

func (m *MockPoolConn) EXPECT() *MockPoolConnMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockPoolConn) Invoke

func (m *MockPoolConn) Invoke(arg0 context.Context, arg1 string, arg2, arg3 any, arg4 ...grpc.CallOption) error

Invoke mocks base method.

func (*MockPoolConn) NewStream

func (m *MockPoolConn) NewStream(arg0 context.Context, arg1 *grpc.StreamDesc, arg2 string, arg3 ...grpc.CallOption) (grpc.ClientStream, error)

NewStream mocks base method.

type MockPoolConnDoneCall

type MockPoolConnDoneCall struct {
	*gomock.Call
}

MockPoolConnDoneCall wrap *gomock.Call

func (*MockPoolConnDoneCall) Do

func (c *MockPoolConnDoneCall) Do(f func()) *MockPoolConnDoneCall

Do rewrite *gomock.Call.Do

func (*MockPoolConnDoneCall) DoAndReturn

func (c *MockPoolConnDoneCall) DoAndReturn(f func()) *MockPoolConnDoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockPoolConnDoneCall) Return

func (c *MockPoolConnDoneCall) Return() *MockPoolConnDoneCall

Return rewrite *gomock.Call.Return

type MockPoolConnInvokeCall

type MockPoolConnInvokeCall struct {
	*gomock.Call
}

MockPoolConnInvokeCall wrap *gomock.Call

func (*MockPoolConnInvokeCall) Do

func (c *MockPoolConnInvokeCall) Do(f func(context.Context, string, any, any, ...grpc.CallOption) error) *MockPoolConnInvokeCall

Do rewrite *gomock.Call.Do

func (*MockPoolConnInvokeCall) DoAndReturn

func (c *MockPoolConnInvokeCall) DoAndReturn(f func(context.Context, string, any, any, ...grpc.CallOption) error) *MockPoolConnInvokeCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockPoolConnInvokeCall) Return

func (c *MockPoolConnInvokeCall) Return(arg0 error) *MockPoolConnInvokeCall

Return rewrite *gomock.Call.Return

type MockPoolConnMockRecorder

type MockPoolConnMockRecorder struct {
	// contains filtered or unexported fields
}

MockPoolConnMockRecorder is the mock recorder for MockPoolConn.

func (*MockPoolConnMockRecorder) Done

func (mr *MockPoolConnMockRecorder) Done() *MockPoolConnDoneCall

Done indicates an expected call of Done.

func (*MockPoolConnMockRecorder) Invoke

func (mr *MockPoolConnMockRecorder) Invoke(arg0, arg1, arg2, arg3 any, arg4 ...any) *MockPoolConnInvokeCall

Invoke indicates an expected call of Invoke.

func (*MockPoolConnMockRecorder) NewStream

func (mr *MockPoolConnMockRecorder) NewStream(arg0, arg1, arg2 any, arg3 ...any) *MockPoolConnNewStreamCall

NewStream indicates an expected call of NewStream.

type MockPoolConnNewStreamCall

type MockPoolConnNewStreamCall struct {
	*gomock.Call
}

MockPoolConnNewStreamCall wrap *gomock.Call

func (*MockPoolConnNewStreamCall) Do

func (c *MockPoolConnNewStreamCall) Do(f func(context.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error)) *MockPoolConnNewStreamCall

Do rewrite *gomock.Call.Do

func (*MockPoolConnNewStreamCall) DoAndReturn

func (c *MockPoolConnNewStreamCall) DoAndReturn(f func(context.Context, *grpc.StreamDesc, string, ...grpc.CallOption) (grpc.ClientStream, error)) *MockPoolConnNewStreamCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockPoolConnNewStreamCall) Return

func (c *MockPoolConnNewStreamCall) Return(arg0 grpc.ClientStream, arg1 error) *MockPoolConnNewStreamCall

Return rewrite *gomock.Call.Return

type MockPoolInterface

type MockPoolInterface struct {
	// contains filtered or unexported fields
}

MockPoolInterface is a mock of PoolInterface interface.

func NewMockPoolInterface

func NewMockPoolInterface(ctrl *gomock.Controller) *MockPoolInterface

NewMockPoolInterface creates a new mock instance.

func (*MockPoolInterface) Close

func (m *MockPoolInterface) Close() error

Close mocks base method.

func (*MockPoolInterface) Dial

func (m *MockPoolInterface) Dial(arg0 context.Context, arg1 string) (grpctool.PoolConn, error)

Dial mocks base method.

func (*MockPoolInterface) EXPECT

func (m *MockPoolInterface) EXPECT() *MockPoolInterfaceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockPoolInterfaceCloseCall

type MockPoolInterfaceCloseCall struct {
	*gomock.Call
}

MockPoolInterfaceCloseCall wrap *gomock.Call

func (*MockPoolInterfaceCloseCall) Do

func (c *MockPoolInterfaceCloseCall) Do(f func() error) *MockPoolInterfaceCloseCall

Do rewrite *gomock.Call.Do

func (*MockPoolInterfaceCloseCall) DoAndReturn

func (c *MockPoolInterfaceCloseCall) DoAndReturn(f func() error) *MockPoolInterfaceCloseCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockPoolInterfaceCloseCall) Return

func (c *MockPoolInterfaceCloseCall) Return(arg0 error) *MockPoolInterfaceCloseCall

Return rewrite *gomock.Call.Return

type MockPoolInterfaceDialCall

type MockPoolInterfaceDialCall struct {
	*gomock.Call
}

MockPoolInterfaceDialCall wrap *gomock.Call

func (*MockPoolInterfaceDialCall) Do

func (c *MockPoolInterfaceDialCall) Do(f func(context.Context, string) (grpctool.PoolConn, error)) *MockPoolInterfaceDialCall

Do rewrite *gomock.Call.Do

func (*MockPoolInterfaceDialCall) DoAndReturn

func (c *MockPoolInterfaceDialCall) DoAndReturn(f func(context.Context, string) (grpctool.PoolConn, error)) *MockPoolInterfaceDialCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockPoolInterfaceDialCall) Return

func (c *MockPoolInterfaceDialCall) Return(arg0 grpctool.PoolConn, arg1 error) *MockPoolInterfaceDialCall

Return rewrite *gomock.Call.Return

type MockPoolInterfaceMockRecorder

type MockPoolInterfaceMockRecorder struct {
	// contains filtered or unexported fields
}

MockPoolInterfaceMockRecorder is the mock recorder for MockPoolInterface.

func (*MockPoolInterfaceMockRecorder) Close

func (mr *MockPoolInterfaceMockRecorder) Close() *MockPoolInterfaceCloseCall

Close indicates an expected call of Close.

func (*MockPoolInterfaceMockRecorder) Dial

func (mr *MockPoolInterfaceMockRecorder) Dial(arg0, arg1 any) *MockPoolInterfaceDialCall

Dial indicates an expected call of Dial.

type MockServerErrorReporter

type MockServerErrorReporter struct {
	// contains filtered or unexported fields
}

MockServerErrorReporter is a mock of ServerErrorReporter interface.

func NewMockServerErrorReporter

func NewMockServerErrorReporter(ctrl *gomock.Controller) *MockServerErrorReporter

NewMockServerErrorReporter creates a new mock instance.

func (*MockServerErrorReporter) EXPECT

func (m *MockServerErrorReporter) EXPECT() *MockServerErrorReporterMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockServerErrorReporter) Report

func (m *MockServerErrorReporter) Report(arg0 context.Context, arg1 string, arg2 error)

Report mocks base method.

type MockServerErrorReporterMockRecorder

type MockServerErrorReporterMockRecorder struct {
	// contains filtered or unexported fields
}

MockServerErrorReporterMockRecorder is the mock recorder for MockServerErrorReporter.

func (*MockServerErrorReporterMockRecorder) Report

func (mr *MockServerErrorReporterMockRecorder) Report(arg0, arg1, arg2 any) *MockServerErrorReporterReportCall

Report indicates an expected call of Report.

type MockServerErrorReporterReportCall

type MockServerErrorReporterReportCall struct {
	*gomock.Call
}

MockServerErrorReporterReportCall wrap *gomock.Call

func (*MockServerErrorReporterReportCall) Do

func (c *MockServerErrorReporterReportCall) Do(f func(context.Context, string, error)) *MockServerErrorReporterReportCall

Do rewrite *gomock.Call.Do

func (*MockServerErrorReporterReportCall) DoAndReturn

func (c *MockServerErrorReporterReportCall) DoAndReturn(f func(context.Context, string, error)) *MockServerErrorReporterReportCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerErrorReporterReportCall) Return

func (c *MockServerErrorReporterReportCall) Return() *MockServerErrorReporterReportCall

Return rewrite *gomock.Call.Return

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 any) 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 any) 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 MockServerStreamContextCall

type MockServerStreamContextCall struct {
	*gomock.Call
}

MockServerStreamContextCall wrap *gomock.Call

func (*MockServerStreamContextCall) Do

func (c *MockServerStreamContextCall) Do(f func() context.Context) *MockServerStreamContextCall

Do rewrite *gomock.Call.Do

func (*MockServerStreamContextCall) DoAndReturn

func (c *MockServerStreamContextCall) DoAndReturn(f func() context.Context) *MockServerStreamContextCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerStreamContextCall) Return

func (c *MockServerStreamContextCall) Return(arg0 context.Context) *MockServerStreamContextCall

Return rewrite *gomock.Call.Return

type MockServerStreamMockRecorder

type MockServerStreamMockRecorder struct {
	// contains filtered or unexported fields
}

MockServerStreamMockRecorder is the mock recorder for MockServerStream.

func (*MockServerStreamMockRecorder) Context

func (mr *MockServerStreamMockRecorder) Context() *MockServerStreamContextCall

Context indicates an expected call of Context.

func (*MockServerStreamMockRecorder) RecvMsg

func (mr *MockServerStreamMockRecorder) RecvMsg(arg0 any) *MockServerStreamRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockServerStreamMockRecorder) SendHeader

func (mr *MockServerStreamMockRecorder) SendHeader(arg0 any) *MockServerStreamSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*MockServerStreamMockRecorder) SendMsg

func (mr *MockServerStreamMockRecorder) SendMsg(arg0 any) *MockServerStreamSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockServerStreamMockRecorder) SetHeader

func (mr *MockServerStreamMockRecorder) SetHeader(arg0 any) *MockServerStreamSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*MockServerStreamMockRecorder) SetTrailer

func (mr *MockServerStreamMockRecorder) SetTrailer(arg0 any) *MockServerStreamSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type MockServerStreamRecvMsgCall

type MockServerStreamRecvMsgCall struct {
	*gomock.Call
}

MockServerStreamRecvMsgCall wrap *gomock.Call

func (*MockServerStreamRecvMsgCall) Do

func (c *MockServerStreamRecvMsgCall) Do(f func(any) error) *MockServerStreamRecvMsgCall

Do rewrite *gomock.Call.Do

func (*MockServerStreamRecvMsgCall) DoAndReturn

func (c *MockServerStreamRecvMsgCall) DoAndReturn(f func(any) error) *MockServerStreamRecvMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerStreamRecvMsgCall) Return

func (c *MockServerStreamRecvMsgCall) Return(arg0 error) *MockServerStreamRecvMsgCall

Return rewrite *gomock.Call.Return

type MockServerStreamSendHeaderCall

type MockServerStreamSendHeaderCall struct {
	*gomock.Call
}

MockServerStreamSendHeaderCall wrap *gomock.Call

func (*MockServerStreamSendHeaderCall) Do

func (c *MockServerStreamSendHeaderCall) Do(f func(metadata.MD) error) *MockServerStreamSendHeaderCall

Do rewrite *gomock.Call.Do

func (*MockServerStreamSendHeaderCall) DoAndReturn

func (c *MockServerStreamSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockServerStreamSendHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerStreamSendHeaderCall) Return

func (c *MockServerStreamSendHeaderCall) Return(arg0 error) *MockServerStreamSendHeaderCall

Return rewrite *gomock.Call.Return

type MockServerStreamSendMsgCall

type MockServerStreamSendMsgCall struct {
	*gomock.Call
}

MockServerStreamSendMsgCall wrap *gomock.Call

func (*MockServerStreamSendMsgCall) Do

func (c *MockServerStreamSendMsgCall) Do(f func(any) error) *MockServerStreamSendMsgCall

Do rewrite *gomock.Call.Do

func (*MockServerStreamSendMsgCall) DoAndReturn

func (c *MockServerStreamSendMsgCall) DoAndReturn(f func(any) error) *MockServerStreamSendMsgCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerStreamSendMsgCall) Return

func (c *MockServerStreamSendMsgCall) Return(arg0 error) *MockServerStreamSendMsgCall

Return rewrite *gomock.Call.Return

type MockServerStreamSetHeaderCall

type MockServerStreamSetHeaderCall struct {
	*gomock.Call
}

MockServerStreamSetHeaderCall wrap *gomock.Call

func (*MockServerStreamSetHeaderCall) Do

func (c *MockServerStreamSetHeaderCall) Do(f func(metadata.MD) error) *MockServerStreamSetHeaderCall

Do rewrite *gomock.Call.Do

func (*MockServerStreamSetHeaderCall) DoAndReturn

func (c *MockServerStreamSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockServerStreamSetHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerStreamSetHeaderCall) Return

func (c *MockServerStreamSetHeaderCall) Return(arg0 error) *MockServerStreamSetHeaderCall

Return rewrite *gomock.Call.Return

type MockServerStreamSetTrailerCall

type MockServerStreamSetTrailerCall struct {
	*gomock.Call
}

MockServerStreamSetTrailerCall wrap *gomock.Call

func (*MockServerStreamSetTrailerCall) Do

func (c *MockServerStreamSetTrailerCall) Do(f func(metadata.MD)) *MockServerStreamSetTrailerCall

Do rewrite *gomock.Call.Do

func (*MockServerStreamSetTrailerCall) DoAndReturn

func (c *MockServerStreamSetTrailerCall) DoAndReturn(f func(metadata.MD)) *MockServerStreamSetTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerStreamSetTrailerCall) Return

func (c *MockServerStreamSetTrailerCall) Return() *MockServerStreamSetTrailerCall

Return rewrite *gomock.Call.Return

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 MockServerTransportStreamMethodCall

type MockServerTransportStreamMethodCall struct {
	*gomock.Call
}

MockServerTransportStreamMethodCall wrap *gomock.Call

func (*MockServerTransportStreamMethodCall) Do

func (c *MockServerTransportStreamMethodCall) Do(f func() string) *MockServerTransportStreamMethodCall

Do rewrite *gomock.Call.Do

func (*MockServerTransportStreamMethodCall) DoAndReturn

func (c *MockServerTransportStreamMethodCall) DoAndReturn(f func() string) *MockServerTransportStreamMethodCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerTransportStreamMethodCall) Return

func (c *MockServerTransportStreamMethodCall) Return(arg0 string) *MockServerTransportStreamMethodCall

Return rewrite *gomock.Call.Return

type MockServerTransportStreamMockRecorder

type MockServerTransportStreamMockRecorder struct {
	// contains filtered or unexported fields
}

MockServerTransportStreamMockRecorder is the mock recorder for MockServerTransportStream.

func (*MockServerTransportStreamMockRecorder) Method

func (mr *MockServerTransportStreamMockRecorder) Method() *MockServerTransportStreamMethodCall

Method indicates an expected call of Method.

func (*MockServerTransportStreamMockRecorder) SendHeader

func (mr *MockServerTransportStreamMockRecorder) SendHeader(arg0 any) *MockServerTransportStreamSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*MockServerTransportStreamMockRecorder) SetHeader

func (mr *MockServerTransportStreamMockRecorder) SetHeader(arg0 any) *MockServerTransportStreamSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*MockServerTransportStreamMockRecorder) SetTrailer

func (mr *MockServerTransportStreamMockRecorder) SetTrailer(arg0 any) *MockServerTransportStreamSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type MockServerTransportStreamSendHeaderCall

type MockServerTransportStreamSendHeaderCall struct {
	*gomock.Call
}

MockServerTransportStreamSendHeaderCall wrap *gomock.Call

func (*MockServerTransportStreamSendHeaderCall) Do

func (c *MockServerTransportStreamSendHeaderCall) Do(f func(metadata.MD) error) *MockServerTransportStreamSendHeaderCall

Do rewrite *gomock.Call.Do

func (*MockServerTransportStreamSendHeaderCall) DoAndReturn

func (c *MockServerTransportStreamSendHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockServerTransportStreamSendHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerTransportStreamSendHeaderCall) Return

func (c *MockServerTransportStreamSendHeaderCall) Return(arg0 error) *MockServerTransportStreamSendHeaderCall

Return rewrite *gomock.Call.Return

type MockServerTransportStreamSetHeaderCall

type MockServerTransportStreamSetHeaderCall struct {
	*gomock.Call
}

MockServerTransportStreamSetHeaderCall wrap *gomock.Call

func (*MockServerTransportStreamSetHeaderCall) Do

func (c *MockServerTransportStreamSetHeaderCall) Do(f func(metadata.MD) error) *MockServerTransportStreamSetHeaderCall

Do rewrite *gomock.Call.Do

func (*MockServerTransportStreamSetHeaderCall) DoAndReturn

func (c *MockServerTransportStreamSetHeaderCall) DoAndReturn(f func(metadata.MD) error) *MockServerTransportStreamSetHeaderCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerTransportStreamSetHeaderCall) Return

func (c *MockServerTransportStreamSetHeaderCall) Return(arg0 error) *MockServerTransportStreamSetHeaderCall

Return rewrite *gomock.Call.Return

type MockServerTransportStreamSetTrailerCall

type MockServerTransportStreamSetTrailerCall struct {
	*gomock.Call
}

MockServerTransportStreamSetTrailerCall wrap *gomock.Call

func (*MockServerTransportStreamSetTrailerCall) Do

func (c *MockServerTransportStreamSetTrailerCall) Do(f func(metadata.MD) error) *MockServerTransportStreamSetTrailerCall

Do rewrite *gomock.Call.Do

func (*MockServerTransportStreamSetTrailerCall) DoAndReturn

func (c *MockServerTransportStreamSetTrailerCall) DoAndReturn(f func(metadata.MD) error) *MockServerTransportStreamSetTrailerCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*MockServerTransportStreamSetTrailerCall) Return

func (c *MockServerTransportStreamSetTrailerCall) Return(arg0 error) *MockServerTransportStreamSetTrailerCall

Return rewrite *gomock.Call.Return