mock_rpc

type MockAgentConfigurationClient ¶

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

MockAgentConfigurationClient is a mock of AgentConfigurationClient interface.

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 ¶ added in v16.8.0

type MockAgentConfigurationClientGetConfigurationCall struct {
	*gomock.Call
}

MockAgentConfigurationClientGetConfigurationCall wrap *gomock.Call

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

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

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

type MockAgentConfigurationClientMockRecorder ¶

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

MockAgentConfigurationClientMockRecorder is the mock recorder for MockAgentConfigurationClient.

func (mr *MockAgentConfigurationClientMockRecorder) GetConfiguration(arg0, arg1 any, arg2 ...any) *MockAgentConfigurationClientGetConfigurationCall

type MockAgentConfiguration_GetConfigurationClient ¶

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

MockAgentConfiguration_GetConfigurationClient is a mock of AgentConfiguration_GetConfigurationClient interface.

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationClientCloseSendCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientCloseSendCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationClientContextCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientContextCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationClientHeaderCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientHeaderCall wrap *gomock.Call

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 ¶

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

MockAgentConfiguration_GetConfigurationClientMockRecorder is the mock recorder for MockAgentConfiguration_GetConfigurationClient.

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationClientRecvCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientRecvCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationClientRecvMsgCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientRecvMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationClientSendMsgCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientSendMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationClientTrailerCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationClientTrailerCall wrap *gomock.Call

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 ¶

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

MockAgentConfiguration_GetConfigurationServer is a mock of AgentConfiguration_GetConfigurationServer interface.

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationServerContextCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerContextCall wrap *gomock.Call

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 ¶

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

MockAgentConfiguration_GetConfigurationServerMockRecorder is the mock recorder for MockAgentConfiguration_GetConfigurationServer.

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationServerRecvMsgCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerRecvMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationServerSendCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSendCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationServerSendHeaderCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSendHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationServerSendMsgCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSendMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationServerSetHeaderCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSetHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockAgentConfiguration_GetConfigurationServerSetTrailerCall struct {
	*gomock.Call
}

MockAgentConfiguration_GetConfigurationServerSetTrailerCall wrap *gomock.Call

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 ¶

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

MockClientConnInterface is a mock of ClientConnInterface interface.

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, arg3 ...grpc.CallOption) (grpc.ClientStream, error)

type MockClientConnInterfaceInvokeCall ¶ added in v16.8.0

type MockClientConnInterfaceInvokeCall struct {
	*gomock.Call
}

MockClientConnInterfaceInvokeCall wrap *gomock.Call

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 ¶

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

MockClientConnInterfaceMockRecorder is the mock recorder for MockClientConnInterface.

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 ¶ added in v16.8.0

type MockClientConnInterfaceNewStreamCall struct {
	*gomock.Call
}

MockClientConnInterfaceNewStreamCall wrap *gomock.Call

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

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

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

type MockClientStream ¶

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

MockClientStream is a mock of ClientStream interface.

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 ¶ added in v16.8.0

type MockClientStreamCloseSendCall struct {
	*gomock.Call
}

MockClientStreamCloseSendCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockClientStreamContextCall struct {
	*gomock.Call
}

MockClientStreamContextCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockClientStreamHeaderCall struct {
	*gomock.Call
}

MockClientStreamHeaderCall wrap *gomock.Call

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 ¶

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

MockClientStreamMockRecorder is the mock recorder for MockClientStream.

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 ¶ added in v16.8.0

type MockClientStreamRecvMsgCall struct {
	*gomock.Call
}

MockClientStreamRecvMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockClientStreamSendMsgCall struct {
	*gomock.Call
}

MockClientStreamSendMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockClientStreamTrailerCall struct {
	*gomock.Call
}

MockClientStreamTrailerCall wrap *gomock.Call

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 ¶

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

MockConfigurationWatcherInterface is a mock of ConfigurationWatcherInterface interface.

func NewMockConfigurationWatcherInterface(ctrl *gomock.Controller) *MockConfigurationWatcherInterface

func (m *MockConfigurationWatcherInterface) EXPECT() *MockConfigurationWatcherInterfaceMockRecorder

func (m *MockConfigurationWatcherInterface) Watch(arg0 context.Context, arg1 rpc.ConfigurationCallback)

type MockConfigurationWatcherInterfaceMockRecorder ¶

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

MockConfigurationWatcherInterfaceMockRecorder is the mock recorder for MockConfigurationWatcherInterface.

func (mr *MockConfigurationWatcherInterfaceMockRecorder) Watch(arg0, arg1 any) *MockConfigurationWatcherInterfaceWatchCall

type MockConfigurationWatcherInterfaceWatchCall ¶ added in v16.8.0

type MockConfigurationWatcherInterfaceWatchCall struct {
	*gomock.Call
}

MockConfigurationWatcherInterfaceWatchCall wrap *gomock.Call

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 ¶

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

MockGitlabAccess_MakeRequestServer is a mock of GitlabAccess_MakeRequestServer interface.

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 ¶ added in v16.8.0

type MockGitlabAccess_MakeRequestServerContextCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerContextCall wrap *gomock.Call

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 ¶

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

MockGitlabAccess_MakeRequestServerMockRecorder is the mock recorder for MockGitlabAccess_MakeRequestServer.

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 ¶ added in v16.8.0

type MockGitlabAccess_MakeRequestServerRecvCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerRecvCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitlabAccess_MakeRequestServerRecvMsgCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerRecvMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitlabAccess_MakeRequestServerSendCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSendCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitlabAccess_MakeRequestServerSendHeaderCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSendHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitlabAccess_MakeRequestServerSendMsgCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSendMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitlabAccess_MakeRequestServerSetHeaderCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSetHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitlabAccess_MakeRequestServerSetTrailerCall struct {
	*gomock.Call
}

MockGitlabAccess_MakeRequestServerSetTrailerCall wrap *gomock.Call

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 ¶

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

MockGitopsClient is a mock of GitopsClient interface.

func NewMockGitopsClient(ctrl *gomock.Controller) *MockGitopsClient

func (m *MockGitopsClient) EXPECT() *MockGitopsClientMockRecorder

func (m *MockGitopsClient) GetObjectsToSynchronize(arg0 context.Context, arg1 *rpc.ObjectsToSynchronizeRequest, arg2 ...grpc.CallOption) (rpc.Gitops_GetObjectsToSynchronizeClient, error)

type MockGitopsClientGetObjectsToSynchronizeCall ¶ added in v16.8.0

type MockGitopsClientGetObjectsToSynchronizeCall struct {
	*gomock.Call
}

MockGitopsClientGetObjectsToSynchronizeCall wrap *gomock.Call

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

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

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

type MockGitopsClientMockRecorder ¶

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

MockGitopsClientMockRecorder is the mock recorder for MockGitopsClient.

func (mr *MockGitopsClientMockRecorder) GetObjectsToSynchronize(arg0, arg1 any, arg2 ...any) *MockGitopsClientGetObjectsToSynchronizeCall

type MockGitops_GetObjectsToSynchronizeClient ¶

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

MockGitops_GetObjectsToSynchronizeClient is a mock of Gitops_GetObjectsToSynchronizeClient interface.

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeClientCloseSendCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientCloseSendCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeClientContextCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientContextCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeClientHeaderCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientHeaderCall wrap *gomock.Call

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 ¶

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

MockGitops_GetObjectsToSynchronizeClientMockRecorder is the mock recorder for MockGitops_GetObjectsToSynchronizeClient.

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeClientRecvCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientRecvCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeClientRecvMsgCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientRecvMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeClientSendMsgCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientSendMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeClientTrailerCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeClientTrailerCall wrap *gomock.Call

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 ¶

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

MockGitops_GetObjectsToSynchronizeServer is a mock of Gitops_GetObjectsToSynchronizeServer interface.

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeServerContextCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerContextCall wrap *gomock.Call

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 ¶

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

MockGitops_GetObjectsToSynchronizeServerMockRecorder is the mock recorder for MockGitops_GetObjectsToSynchronizeServer.

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeServerRecvMsgCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerRecvMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeServerSendCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSendCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeServerSendHeaderCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSendHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeServerSendMsgCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSendMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeServerSetHeaderCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSetHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockGitops_GetObjectsToSynchronizeServerSetTrailerCall struct {
	*gomock.Call
}

MockGitops_GetObjectsToSynchronizeServerSetTrailerCall wrap *gomock.Call

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 ¶

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

MockInboundGrpcToOutboundHttpStream is a mock of InboundGrpcToOutboundHttpStream interface.

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 ¶ added in v16.8.0

type MockInboundGrpcToOutboundHttpStreamContextCall struct {
	*gomock.Call
}

MockInboundGrpcToOutboundHttpStreamContextCall wrap *gomock.Call

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 ¶

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

MockInboundGrpcToOutboundHttpStreamMockRecorder is the mock recorder for MockInboundGrpcToOutboundHttpStream.

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 ¶ added in v16.8.0

type MockInboundGrpcToOutboundHttpStreamRecvMsgCall struct {
	*gomock.Call
}

MockInboundGrpcToOutboundHttpStreamRecvMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockInboundGrpcToOutboundHttpStreamSendCall struct {
	*gomock.Call
}

MockInboundGrpcToOutboundHttpStreamSendCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockInboundGrpcToOutboundHttpStreamSendHeaderCall struct {
	*gomock.Call
}

MockInboundGrpcToOutboundHttpStreamSendHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockInboundGrpcToOutboundHttpStreamSendMsgCall struct {
	*gomock.Call
}

MockInboundGrpcToOutboundHttpStreamSendMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockInboundGrpcToOutboundHttpStreamSetHeaderCall struct {
	*gomock.Call
}

MockInboundGrpcToOutboundHttpStreamSetHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockInboundGrpcToOutboundHttpStreamSetTrailerCall struct {
	*gomock.Call
}

MockInboundGrpcToOutboundHttpStreamSetTrailerCall wrap *gomock.Call

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 ¶

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

MockObjectsToSynchronizeWatcherInterface is a mock of ObjectsToSynchronizeWatcherInterface interface.

func NewMockObjectsToSynchronizeWatcherInterface(ctrl *gomock.Controller) *MockObjectsToSynchronizeWatcherInterface

func (m *MockObjectsToSynchronizeWatcherInterface) EXPECT() *MockObjectsToSynchronizeWatcherInterfaceMockRecorder

func (m *MockObjectsToSynchronizeWatcherInterface) Watch(arg0 context.Context, arg1 *rpc.ObjectsToSynchronizeRequest, arg2 rpc.ObjectsToSynchronizeCallback)

type MockObjectsToSynchronizeWatcherInterfaceMockRecorder ¶

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

MockObjectsToSynchronizeWatcherInterfaceMockRecorder is the mock recorder for MockObjectsToSynchronizeWatcherInterface.

func (mr *MockObjectsToSynchronizeWatcherInterfaceMockRecorder) Watch(arg0, arg1, arg2 any) *MockObjectsToSynchronizeWatcherInterfaceWatchCall

type MockObjectsToSynchronizeWatcherInterfaceWatchCall ¶ added in v16.8.0

type MockObjectsToSynchronizeWatcherInterfaceWatchCall struct {
	*gomock.Call
}

MockObjectsToSynchronizeWatcherInterfaceWatchCall wrap *gomock.Call

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

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

func (c *MockObjectsToSynchronizeWatcherInterfaceWatchCall) Return() *MockObjectsToSynchronizeWatcherInterfaceWatchCall

type MockPoolConn ¶

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

MockPoolConn is a mock of PoolConn interface.

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, arg3 ...grpc.CallOption) (grpc.ClientStream, error)

type MockPoolConnDoneCall ¶ added in v16.8.0

type MockPoolConnDoneCall struct {
	*gomock.Call
}

MockPoolConnDoneCall wrap *gomock.Call

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

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

func (c *MockPoolConnDoneCall) Return() *MockPoolConnDoneCall

type MockPoolConnInvokeCall ¶ added in v16.8.0

type MockPoolConnInvokeCall struct {
	*gomock.Call
}

MockPoolConnInvokeCall wrap *gomock.Call

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 ¶

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

MockPoolConnMockRecorder is the mock recorder for MockPoolConn.

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 ¶ added in v16.8.0

type MockPoolConnNewStreamCall struct {
	*gomock.Call
}

MockPoolConnNewStreamCall wrap *gomock.Call

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

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

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

type MockPoolInterface ¶

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

MockPoolInterface is a mock of PoolInterface interface.

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 ¶ added in v16.8.0

type MockPoolInterfaceCloseCall struct {
	*gomock.Call
}

MockPoolInterfaceCloseCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockPoolInterfaceDialCall struct {
	*gomock.Call
}

MockPoolInterfaceDialCall wrap *gomock.Call

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 ¶

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

MockPoolInterfaceMockRecorder is the mock recorder for MockPoolInterface.

func (mr *MockPoolInterfaceMockRecorder) Close() *MockPoolInterfaceCloseCall

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

type MockServerErrorReporter ¶ added in v16.3.0

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

MockServerErrorReporter is a mock of ServerErrorReporter interface.

func NewMockServerErrorReporter(ctrl *gomock.Controller) *MockServerErrorReporter

func (m *MockServerErrorReporter) EXPECT() *MockServerErrorReporterMockRecorder

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

type MockServerErrorReporterMockRecorder ¶ added in v16.3.0

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

MockServerErrorReporterMockRecorder is the mock recorder for MockServerErrorReporter.

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

type MockServerErrorReporterReportCall ¶ added in v16.8.0

type MockServerErrorReporterReportCall struct {
	*gomock.Call
}

MockServerErrorReporterReportCall wrap *gomock.Call

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 ¶

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

MockServerStream is a mock of ServerStream interface.

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 ¶ added in v16.8.0

type MockServerStreamContextCall struct {
	*gomock.Call
}

MockServerStreamContextCall wrap *gomock.Call

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 ¶

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

MockServerStreamMockRecorder is the mock recorder for MockServerStream.

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 ¶ added in v16.8.0

type MockServerStreamRecvMsgCall struct {
	*gomock.Call
}

MockServerStreamRecvMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockServerStreamSendHeaderCall struct {
	*gomock.Call
}

MockServerStreamSendHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockServerStreamSendMsgCall struct {
	*gomock.Call
}

MockServerStreamSendMsgCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockServerStreamSetHeaderCall struct {
	*gomock.Call
}

MockServerStreamSetHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0

type MockServerStreamSetTrailerCall struct {
	*gomock.Call
}

MockServerStreamSetTrailerCall wrap *gomock.Call

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 ¶

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

MockServerTransportStream is a mock of ServerTransportStream interface.

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 ¶ added in v16.8.0

type MockServerTransportStreamMethodCall struct {
	*gomock.Call
}

MockServerTransportStreamMethodCall wrap *gomock.Call

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 ¶

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

MockServerTransportStreamMockRecorder is the mock recorder for MockServerTransportStream.

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 ¶ added in v16.8.0

type MockServerTransportStreamSendHeaderCall struct {
	*gomock.Call
}

MockServerTransportStreamSendHeaderCall wrap *gomock.Call

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 ¶ added in v16.8.0