mock_rpc

package
v16.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 15, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/agent_configuration/rpc (interfaces: AgentConfigurationClient,AgentConfiguration_GetConfigurationClient,AgentConfiguration_GetConfigurationServer,ConfigurationWatcherInterface)

Generated by this command: 

mockgen -typed -destination agent_configuration.go -package mock_rpc gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/agent_configuration/rpc AgentConfigurationClient,AgentConfiguration_GetConfigurationClient,AgentConfiguration_GetConfigurationServer,ConfigurationWatcherInterface

Package mock_rpc is a generated GoMock package.

Package mock_rpc contains mocks for gRPC interfaces.

Code generated by MockGen. DO NOT EDIT. Source: gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/gitlab_access/rpc (interfaces: GitlabAccess_MakeRequestServer)

Generated by this command: 

mockgen -typed -destination gitlab_access.go -package mock_rpc gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/gitlab_access/rpc GitlabAccess_MakeRequestServer

Package mock_rpc is a generated GoMock package.

Code generated by MockGen. DO NOT EDIT. Source: gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/gitops/rpc (interfaces: GitopsClient,Gitops_GetObjectsToSynchronizeClient,Gitops_GetObjectsToSynchronizeServer,ObjectsToSynchronizeWatcherInterface)

Generated by this command: 

mockgen -typed -destination gitops.go -package mock_rpc gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/module/gitops/rpc GitopsClient,Gitops_GetObjectsToSynchronizeClient,Gitops_GetObjectsToSynchronizeServer,ObjectsToSynchronizeWatcherInterface

Package mock_rpc is a generated GoMock package.

Code generated by MockGen. DO NOT EDIT. Source: google.golang.org/grpc (interfaces: ServerStream,ClientStream,ClientConnInterface,ServerTransportStream)

Generated by this command: 

mockgen -typed -destination grpc.go -package mock_rpc google.golang.org/grpc ServerStream,ClientStream,ClientConnInterface,ServerTransportStream

Package mock_rpc is a generated GoMock package.

Code generated by MockGen. DO NOT EDIT. Source: gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/tool/grpctool (interfaces: InboundGrpcToOutboundHttpStream,PoolConn,PoolInterface,ServerErrorReporter)

Generated by this command: 

mockgen -typed -destination grpctool.go -package mock_rpc gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/tool/grpctool InboundGrpcToOutboundHttpStream,PoolConn,PoolInterface,ServerErrorReporter

Package mock_rpc is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AgentConfigurationClientGetConfigurationCall added in v16.5.0 

type AgentConfigurationClientGetConfigurationCall struct {
	*gomock.Call
}

AgentConfigurationClientGetConfigurationCall wrap *gomock.Call

func (*AgentConfigurationClientGetConfigurationCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfigurationClientGetConfigurationCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfigurationClientGetConfigurationCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationClientCloseSendCall added in v16.5.0 

type AgentConfiguration_GetConfigurationClientCloseSendCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationClientCloseSendCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationClientCloseSendCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationClientCloseSendCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationClientCloseSendCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationClientContextCall added in v16.5.0 

type AgentConfiguration_GetConfigurationClientContextCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationClientContextCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationClientContextCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationClientContextCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationClientContextCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationClientHeaderCall added in v16.5.0 

type AgentConfiguration_GetConfigurationClientHeaderCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationClientHeaderCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationClientHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationClientHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationClientHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationClientRecvCall added in v16.5.0 

type AgentConfiguration_GetConfigurationClientRecvCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationClientRecvCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationClientRecvCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationClientRecvCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationClientRecvCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationClientRecvMsgCall added in v16.5.0 

type AgentConfiguration_GetConfigurationClientRecvMsgCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationClientRecvMsgCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationClientRecvMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationClientRecvMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationClientRecvMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationClientSendMsgCall added in v16.5.0 

type AgentConfiguration_GetConfigurationClientSendMsgCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationClientSendMsgCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationClientSendMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationClientSendMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationClientSendMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationClientTrailerCall added in v16.5.0 

type AgentConfiguration_GetConfigurationClientTrailerCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationClientTrailerCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationClientTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationClientTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationClientTrailerCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationServerContextCall added in v16.5.0 

type AgentConfiguration_GetConfigurationServerContextCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationServerContextCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationServerContextCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationServerContextCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationServerContextCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationServerRecvMsgCall added in v16.5.0 

type AgentConfiguration_GetConfigurationServerRecvMsgCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationServerRecvMsgCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationServerRecvMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationServerRecvMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationServerRecvMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationServerSendCall added in v16.5.0 

type AgentConfiguration_GetConfigurationServerSendCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationServerSendCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationServerSendCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationServerSendCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationServerSendCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationServerSendHeaderCall added in v16.5.0 

type AgentConfiguration_GetConfigurationServerSendHeaderCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationServerSendHeaderCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationServerSendHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationServerSendHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationServerSendHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationServerSendMsgCall added in v16.5.0 

type AgentConfiguration_GetConfigurationServerSendMsgCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationServerSendMsgCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationServerSendMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationServerSendMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationServerSendMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationServerSetHeaderCall added in v16.5.0 

type AgentConfiguration_GetConfigurationServerSetHeaderCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationServerSetHeaderCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationServerSetHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationServerSetHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationServerSetHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type AgentConfiguration_GetConfigurationServerSetTrailerCall added in v16.5.0 

type AgentConfiguration_GetConfigurationServerSetTrailerCall struct {
	*gomock.Call
}

AgentConfiguration_GetConfigurationServerSetTrailerCall wrap *gomock.Call

func (*AgentConfiguration_GetConfigurationServerSetTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*AgentConfiguration_GetConfigurationServerSetTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*AgentConfiguration_GetConfigurationServerSetTrailerCall) Return added in v16.5.0 

func (c *AgentConfiguration_GetConfigurationServerSetTrailerCall) Return() *AgentConfiguration_GetConfigurationServerSetTrailerCall

Return rewrite *gomock.Call.Return

type ClientConnInterfaceInvokeCall added in v16.5.0 

type ClientConnInterfaceInvokeCall struct {
	*gomock.Call
}

ClientConnInterfaceInvokeCall wrap *gomock.Call

func (*ClientConnInterfaceInvokeCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ClientConnInterfaceInvokeCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ClientConnInterfaceInvokeCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ClientConnInterfaceNewStreamCall added in v16.5.0 

type ClientConnInterfaceNewStreamCall struct {
	*gomock.Call
}

ClientConnInterfaceNewStreamCall wrap *gomock.Call

func (*ClientConnInterfaceNewStreamCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ClientConnInterfaceNewStreamCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ClientConnInterfaceNewStreamCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ClientStreamCloseSendCall added in v16.5.0 

type ClientStreamCloseSendCall struct {
	*gomock.Call
}

ClientStreamCloseSendCall wrap *gomock.Call

func (*ClientStreamCloseSendCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ClientStreamCloseSendCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ClientStreamCloseSendCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ClientStreamContextCall added in v16.5.0 

type ClientStreamContextCall struct {
	*gomock.Call
}

ClientStreamContextCall wrap *gomock.Call

func (*ClientStreamContextCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ClientStreamContextCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ClientStreamContextCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ClientStreamHeaderCall added in v16.5.0 

type ClientStreamHeaderCall struct {
	*gomock.Call
}

ClientStreamHeaderCall wrap *gomock.Call

func (*ClientStreamHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ClientStreamHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ClientStreamHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ClientStreamRecvMsgCall added in v16.5.0 

type ClientStreamRecvMsgCall struct {
	*gomock.Call
}

ClientStreamRecvMsgCall wrap *gomock.Call

func (*ClientStreamRecvMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ClientStreamRecvMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ClientStreamRecvMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ClientStreamSendMsgCall added in v16.5.0 

type ClientStreamSendMsgCall struct {
	*gomock.Call
}

ClientStreamSendMsgCall wrap *gomock.Call

func (*ClientStreamSendMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ClientStreamSendMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ClientStreamSendMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ClientStreamTrailerCall added in v16.5.0 

type ClientStreamTrailerCall struct {
	*gomock.Call
}

ClientStreamTrailerCall wrap *gomock.Call

func (*ClientStreamTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ClientStreamTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ClientStreamTrailerCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ConfigurationWatcherInterfaceWatchCall added in v16.5.0 

type ConfigurationWatcherInterfaceWatchCall struct {
	*gomock.Call
}

ConfigurationWatcherInterfaceWatchCall wrap *gomock.Call

func (*ConfigurationWatcherInterfaceWatchCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ConfigurationWatcherInterfaceWatchCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConfigurationWatcherInterfaceWatchCall) Return added in v16.5.0 

func (c *ConfigurationWatcherInterfaceWatchCall) Return() *ConfigurationWatcherInterfaceWatchCall

Return rewrite *gomock.Call.Return

type GitlabAccess_MakeRequestServerContextCall added in v16.5.0 

type GitlabAccess_MakeRequestServerContextCall struct {
	*gomock.Call
}

GitlabAccess_MakeRequestServerContextCall wrap *gomock.Call

func (*GitlabAccess_MakeRequestServerContextCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitlabAccess_MakeRequestServerContextCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitlabAccess_MakeRequestServerContextCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type GitlabAccess_MakeRequestServerRecvCall added in v16.5.0 

type GitlabAccess_MakeRequestServerRecvCall struct {
	*gomock.Call
}

GitlabAccess_MakeRequestServerRecvCall wrap *gomock.Call

func (*GitlabAccess_MakeRequestServerRecvCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitlabAccess_MakeRequestServerRecvCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitlabAccess_MakeRequestServerRecvCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type GitlabAccess_MakeRequestServerRecvMsgCall added in v16.5.0 

type GitlabAccess_MakeRequestServerRecvMsgCall struct {
	*gomock.Call
}

GitlabAccess_MakeRequestServerRecvMsgCall wrap *gomock.Call

func (*GitlabAccess_MakeRequestServerRecvMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitlabAccess_MakeRequestServerRecvMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitlabAccess_MakeRequestServerRecvMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type GitlabAccess_MakeRequestServerSendCall added in v16.5.0 

type GitlabAccess_MakeRequestServerSendCall struct {
	*gomock.Call
}

GitlabAccess_MakeRequestServerSendCall wrap *gomock.Call

func (*GitlabAccess_MakeRequestServerSendCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitlabAccess_MakeRequestServerSendCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitlabAccess_MakeRequestServerSendCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type GitlabAccess_MakeRequestServerSendHeaderCall added in v16.5.0 

type GitlabAccess_MakeRequestServerSendHeaderCall struct {
	*gomock.Call
}

GitlabAccess_MakeRequestServerSendHeaderCall wrap *gomock.Call

func (*GitlabAccess_MakeRequestServerSendHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitlabAccess_MakeRequestServerSendHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitlabAccess_MakeRequestServerSendHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type GitlabAccess_MakeRequestServerSendMsgCall added in v16.5.0 

type GitlabAccess_MakeRequestServerSendMsgCall struct {
	*gomock.Call
}

GitlabAccess_MakeRequestServerSendMsgCall wrap *gomock.Call

func (*GitlabAccess_MakeRequestServerSendMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitlabAccess_MakeRequestServerSendMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitlabAccess_MakeRequestServerSendMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type GitlabAccess_MakeRequestServerSetHeaderCall added in v16.5.0 

type GitlabAccess_MakeRequestServerSetHeaderCall struct {
	*gomock.Call
}

GitlabAccess_MakeRequestServerSetHeaderCall wrap *gomock.Call

func (*GitlabAccess_MakeRequestServerSetHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitlabAccess_MakeRequestServerSetHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitlabAccess_MakeRequestServerSetHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type GitlabAccess_MakeRequestServerSetTrailerCall added in v16.5.0 

type GitlabAccess_MakeRequestServerSetTrailerCall struct {
	*gomock.Call
}

GitlabAccess_MakeRequestServerSetTrailerCall wrap *gomock.Call

func (*GitlabAccess_MakeRequestServerSetTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitlabAccess_MakeRequestServerSetTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitlabAccess_MakeRequestServerSetTrailerCall) Return added in v16.5.0 

func (c *GitlabAccess_MakeRequestServerSetTrailerCall) Return() *GitlabAccess_MakeRequestServerSetTrailerCall

Return rewrite *gomock.Call.Return

type GitopsClientGetObjectsToSynchronizeCall added in v16.5.0 

type GitopsClientGetObjectsToSynchronizeCall struct {
	*gomock.Call
}

GitopsClientGetObjectsToSynchronizeCall wrap *gomock.Call

func (*GitopsClientGetObjectsToSynchronizeCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*GitopsClientGetObjectsToSynchronizeCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*GitopsClientGetObjectsToSynchronizeCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeClientCloseSendCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeClientCloseSendCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeClientCloseSendCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeClientCloseSendCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeClientCloseSendCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeClientCloseSendCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeClientContextCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeClientContextCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeClientContextCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeClientContextCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeClientContextCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeClientContextCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeClientHeaderCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeClientHeaderCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeClientHeaderCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeClientHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeClientHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeClientHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeClientRecvCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeClientRecvCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeClientRecvCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeClientRecvCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeClientRecvCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeClientRecvCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeClientRecvMsgCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeClientRecvMsgCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeClientRecvMsgCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeClientRecvMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeClientRecvMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeClientRecvMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeClientSendMsgCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeClientSendMsgCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeClientSendMsgCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeClientSendMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeClientSendMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeClientSendMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeClientTrailerCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeClientTrailerCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeClientTrailerCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeClientTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeClientTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeClientTrailerCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeServerContextCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeServerContextCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeServerContextCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeServerContextCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeServerContextCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeServerContextCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeServerRecvMsgCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeServerRecvMsgCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeServerRecvMsgCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeServerRecvMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeServerRecvMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeServerRecvMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeServerSendCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeServerSendCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeServerSendCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeServerSendCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeServerSendCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeServerSendCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeServerSendHeaderCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeServerSendHeaderCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeServerSendHeaderCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeServerSendHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeServerSendHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeServerSendHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeServerSendMsgCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeServerSendMsgCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeServerSendMsgCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeServerSendMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeServerSendMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeServerSendMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeServerSetHeaderCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeServerSetHeaderCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeServerSetHeaderCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeServerSetHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeServerSetHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeServerSetHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type Gitops_GetObjectsToSynchronizeServerSetTrailerCall added in v16.5.0 

type Gitops_GetObjectsToSynchronizeServerSetTrailerCall struct {
	*gomock.Call
}

Gitops_GetObjectsToSynchronizeServerSetTrailerCall wrap *gomock.Call

func (*Gitops_GetObjectsToSynchronizeServerSetTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*Gitops_GetObjectsToSynchronizeServerSetTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*Gitops_GetObjectsToSynchronizeServerSetTrailerCall) Return added in v16.5.0 

func (c *Gitops_GetObjectsToSynchronizeServerSetTrailerCall) Return() *Gitops_GetObjectsToSynchronizeServerSetTrailerCall

Return rewrite *gomock.Call.Return

type InboundGrpcToOutboundHttpStreamContextCall added in v16.5.0 

type InboundGrpcToOutboundHttpStreamContextCall struct {
	*gomock.Call
}

InboundGrpcToOutboundHttpStreamContextCall wrap *gomock.Call

func (*InboundGrpcToOutboundHttpStreamContextCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*InboundGrpcToOutboundHttpStreamContextCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*InboundGrpcToOutboundHttpStreamContextCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type InboundGrpcToOutboundHttpStreamRecvMsgCall added in v16.5.0 

type InboundGrpcToOutboundHttpStreamRecvMsgCall struct {
	*gomock.Call
}

InboundGrpcToOutboundHttpStreamRecvMsgCall wrap *gomock.Call

func (*InboundGrpcToOutboundHttpStreamRecvMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*InboundGrpcToOutboundHttpStreamRecvMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*InboundGrpcToOutboundHttpStreamRecvMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type InboundGrpcToOutboundHttpStreamSendCall added in v16.5.0 

type InboundGrpcToOutboundHttpStreamSendCall struct {
	*gomock.Call
}

InboundGrpcToOutboundHttpStreamSendCall wrap *gomock.Call

func (*InboundGrpcToOutboundHttpStreamSendCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*InboundGrpcToOutboundHttpStreamSendCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*InboundGrpcToOutboundHttpStreamSendCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type InboundGrpcToOutboundHttpStreamSendHeaderCall added in v16.5.0 

type InboundGrpcToOutboundHttpStreamSendHeaderCall struct {
	*gomock.Call
}

InboundGrpcToOutboundHttpStreamSendHeaderCall wrap *gomock.Call

func (*InboundGrpcToOutboundHttpStreamSendHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*InboundGrpcToOutboundHttpStreamSendHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*InboundGrpcToOutboundHttpStreamSendHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type InboundGrpcToOutboundHttpStreamSendMsgCall added in v16.5.0 

type InboundGrpcToOutboundHttpStreamSendMsgCall struct {
	*gomock.Call
}

InboundGrpcToOutboundHttpStreamSendMsgCall wrap *gomock.Call

func (*InboundGrpcToOutboundHttpStreamSendMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*InboundGrpcToOutboundHttpStreamSendMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*InboundGrpcToOutboundHttpStreamSendMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type InboundGrpcToOutboundHttpStreamSetHeaderCall added in v16.5.0 

type InboundGrpcToOutboundHttpStreamSetHeaderCall struct {
	*gomock.Call
}

InboundGrpcToOutboundHttpStreamSetHeaderCall wrap *gomock.Call

func (*InboundGrpcToOutboundHttpStreamSetHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*InboundGrpcToOutboundHttpStreamSetHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*InboundGrpcToOutboundHttpStreamSetHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type InboundGrpcToOutboundHttpStreamSetTrailerCall added in v16.5.0 

type InboundGrpcToOutboundHttpStreamSetTrailerCall struct {
	*gomock.Call
}

InboundGrpcToOutboundHttpStreamSetTrailerCall wrap *gomock.Call

func (*InboundGrpcToOutboundHttpStreamSetTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*InboundGrpcToOutboundHttpStreamSetTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*InboundGrpcToOutboundHttpStreamSetTrailerCall) Return added in v16.5.0 

func (c *InboundGrpcToOutboundHttpStreamSetTrailerCall) Return() *InboundGrpcToOutboundHttpStreamSetTrailerCall

Return rewrite *gomock.Call.Return

type MockAgentConfigurationClient 

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

MockAgentConfigurationClient is a mock of AgentConfigurationClient interface.

func NewMockAgentConfigurationClient 

func NewMockAgentConfigurationClient(ctrl *gomock.Controller) *MockAgentConfigurationClient

NewMockAgentConfigurationClient creates a new mock instance.

func (*MockAgentConfigurationClient) EXPECT 

func (m *MockAgentConfigurationClient) EXPECT() *MockAgentConfigurationClientMockRecorder

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

func (*MockAgentConfigurationClient) GetConfiguration 

func (m *MockAgentConfigurationClient) GetConfiguration(arg0 context.Context, arg1 *rpc.ConfigurationRequest, arg2 ...grpc.CallOption) (rpc.AgentConfiguration_GetConfigurationClient, error)

GetConfiguration mocks base method.

type MockAgentConfigurationClientMockRecorder 

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

MockAgentConfigurationClientMockRecorder is the mock recorder for MockAgentConfigurationClient.

func (*MockAgentConfigurationClientMockRecorder) GetConfiguration 

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

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_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() *AgentConfiguration_GetConfigurationClientCloseSendCall

CloseSend indicates an expected call of CloseSend.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Context 

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Context() *AgentConfiguration_GetConfigurationClientContextCall

Context indicates an expected call of Context.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Header 

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Header() *AgentConfiguration_GetConfigurationClientHeaderCall

Header indicates an expected call of Header.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Recv 

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Recv() *AgentConfiguration_GetConfigurationClientRecvCall

Recv indicates an expected call of Recv.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockAgentConfiguration_GetConfigurationClientMockRecorder) Trailer 

func (mr *MockAgentConfiguration_GetConfigurationClientMockRecorder) Trailer() *AgentConfiguration_GetConfigurationClientTrailerCall

Trailer indicates an expected call of Trailer.

type MockAgentConfiguration_GetConfigurationServer 

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

MockAgentConfiguration_GetConfigurationServer is a mock of AgentConfiguration_GetConfigurationServer interface.

func NewMockAgentConfiguration_GetConfigurationServer 

func NewMockAgentConfiguration_GetConfigurationServer(ctrl *gomock.Controller) *MockAgentConfiguration_GetConfigurationServer

NewMockAgentConfiguration_GetConfigurationServer creates a new mock instance.

func (*MockAgentConfiguration_GetConfigurationServer) Context 

func (m *MockAgentConfiguration_GetConfigurationServer) Context() context.Context

Context mocks base method.

func (*MockAgentConfiguration_GetConfigurationServer) EXPECT 

func (m *MockAgentConfiguration_GetConfigurationServer) EXPECT() *MockAgentConfiguration_GetConfigurationServerMockRecorder

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

func (*MockAgentConfiguration_GetConfigurationServer) RecvMsg 

func (m *MockAgentConfiguration_GetConfigurationServer) RecvMsg(arg0 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_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() *AgentConfiguration_GetConfigurationServerContextCall

Context indicates an expected call of Context.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockAgentConfiguration_GetConfigurationServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type MockClientConnInterface 

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

MockClientConnInterface is a mock of ClientConnInterface interface.

func NewMockClientConnInterface 

func NewMockClientConnInterface(ctrl *gomock.Controller) *MockClientConnInterface

NewMockClientConnInterface creates a new mock instance.

func (*MockClientConnInterface) EXPECT 

func (m *MockClientConnInterface) EXPECT() *MockClientConnInterfaceMockRecorder

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

func (*MockClientConnInterface) Invoke 

func (m *MockClientConnInterface) Invoke(arg0 context.Context, arg1 string, arg2, arg3 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 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) *ClientConnInterfaceInvokeCall

Invoke indicates an expected call of Invoke.

func (*MockClientConnInterfaceMockRecorder) NewStream 

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

NewStream indicates an expected call of NewStream.

type MockClientStream 

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

MockClientStream is a mock of ClientStream interface.

func InitMockClientStream 

func InitMockClientStream(ctrl *gomock.Controller, eof bool, msgs ...proto.Message) (*MockClientStream, []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 MockClientStreamMockRecorder 

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

MockClientStreamMockRecorder is the mock recorder for MockClientStream.

func (*MockClientStreamMockRecorder) CloseSend 

func (mr *MockClientStreamMockRecorder) CloseSend() *ClientStreamCloseSendCall

CloseSend indicates an expected call of CloseSend.

func (*MockClientStreamMockRecorder) Context 

func (mr *MockClientStreamMockRecorder) Context() *ClientStreamContextCall

Context indicates an expected call of Context.

func (*MockClientStreamMockRecorder) Header 

func (mr *MockClientStreamMockRecorder) Header() *ClientStreamHeaderCall

Header indicates an expected call of Header.

func (*MockClientStreamMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockClientStreamMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockClientStreamMockRecorder) Trailer 

func (mr *MockClientStreamMockRecorder) Trailer() *ClientStreamTrailerCall

Trailer indicates an expected call of Trailer.

type MockConfigurationWatcherInterface 

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

MockConfigurationWatcherInterface is a mock of ConfigurationWatcherInterface interface.

func NewMockConfigurationWatcherInterface 

func NewMockConfigurationWatcherInterface(ctrl *gomock.Controller) *MockConfigurationWatcherInterface

NewMockConfigurationWatcherInterface creates a new mock instance.

func (*MockConfigurationWatcherInterface) EXPECT 

func (m *MockConfigurationWatcherInterface) EXPECT() *MockConfigurationWatcherInterfaceMockRecorder

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

func (*MockConfigurationWatcherInterface) Watch 

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

Watch mocks base method.

type MockConfigurationWatcherInterfaceMockRecorder 

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

MockConfigurationWatcherInterfaceMockRecorder is the mock recorder for MockConfigurationWatcherInterface.

func (*MockConfigurationWatcherInterfaceMockRecorder) Watch 

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

Watch indicates an expected call of Watch.

type MockGitlabAccess_MakeRequestServer 

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

MockGitlabAccess_MakeRequestServer is a mock of GitlabAccess_MakeRequestServer interface.

func NewMockGitlabAccess_MakeRequestServer 

func NewMockGitlabAccess_MakeRequestServer(ctrl *gomock.Controller) *MockGitlabAccess_MakeRequestServer

NewMockGitlabAccess_MakeRequestServer creates a new mock instance.

func (*MockGitlabAccess_MakeRequestServer) Context 

func (m *MockGitlabAccess_MakeRequestServer) Context() context.Context

Context mocks base method.

func (*MockGitlabAccess_MakeRequestServer) EXPECT 

func (m *MockGitlabAccess_MakeRequestServer) EXPECT() *MockGitlabAccess_MakeRequestServerMockRecorder

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

func (*MockGitlabAccess_MakeRequestServer) Recv 

func (m *MockGitlabAccess_MakeRequestServer) Recv() (*grpctool.HttpRequest, error)

Recv mocks base method.

func (*MockGitlabAccess_MakeRequestServer) RecvMsg 

func (m *MockGitlabAccess_MakeRequestServer) RecvMsg(arg0 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_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() *GitlabAccess_MakeRequestServerContextCall

Context indicates an expected call of Context.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) Recv 

func (mr *MockGitlabAccess_MakeRequestServerMockRecorder) Recv() *GitlabAccess_MakeRequestServerRecvCall

Recv indicates an expected call of Recv.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockGitlabAccess_MakeRequestServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type MockGitopsClient 

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

MockGitopsClient is a mock of GitopsClient interface.

func NewMockGitopsClient 

func NewMockGitopsClient(ctrl *gomock.Controller) *MockGitopsClient

NewMockGitopsClient creates a new mock instance.

func (*MockGitopsClient) EXPECT 

func (m *MockGitopsClient) EXPECT() *MockGitopsClientMockRecorder

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

func (*MockGitopsClient) GetObjectsToSynchronize 

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

GetObjectsToSynchronize mocks base method.

type MockGitopsClientMockRecorder 

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

MockGitopsClientMockRecorder is the mock recorder for MockGitopsClient.

func (*MockGitopsClientMockRecorder) GetObjectsToSynchronize 

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

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_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() *Gitops_GetObjectsToSynchronizeClientCloseSendCall

CloseSend indicates an expected call of CloseSend.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Context 

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Context() *Gitops_GetObjectsToSynchronizeClientContextCall

Context indicates an expected call of Context.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Header 

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Header() *Gitops_GetObjectsToSynchronizeClientHeaderCall

Header indicates an expected call of Header.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Recv 

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Recv() *Gitops_GetObjectsToSynchronizeClientRecvCall

Recv indicates an expected call of Recv.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockGitops_GetObjectsToSynchronizeClientMockRecorder) Trailer 

func (mr *MockGitops_GetObjectsToSynchronizeClientMockRecorder) Trailer() *Gitops_GetObjectsToSynchronizeClientTrailerCall

Trailer indicates an expected call of Trailer.

type MockGitops_GetObjectsToSynchronizeServer 

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

MockGitops_GetObjectsToSynchronizeServer is a mock of Gitops_GetObjectsToSynchronizeServer interface.

func NewMockGitops_GetObjectsToSynchronizeServer 

func NewMockGitops_GetObjectsToSynchronizeServer(ctrl *gomock.Controller) *MockGitops_GetObjectsToSynchronizeServer

NewMockGitops_GetObjectsToSynchronizeServer creates a new mock instance.

func (*MockGitops_GetObjectsToSynchronizeServer) Context 

func (m *MockGitops_GetObjectsToSynchronizeServer) Context() context.Context

Context mocks base method.

func (*MockGitops_GetObjectsToSynchronizeServer) EXPECT 

func (m *MockGitops_GetObjectsToSynchronizeServer) EXPECT() *MockGitops_GetObjectsToSynchronizeServerMockRecorder

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

func (*MockGitops_GetObjectsToSynchronizeServer) RecvMsg 

func (m *MockGitops_GetObjectsToSynchronizeServer) RecvMsg(arg0 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_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() *Gitops_GetObjectsToSynchronizeServerContextCall

Context indicates an expected call of Context.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockGitops_GetObjectsToSynchronizeServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type MockInboundGrpcToOutboundHttpStream 

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

MockInboundGrpcToOutboundHttpStream is a mock of InboundGrpcToOutboundHttpStream interface.

func NewMockInboundGrpcToOutboundHttpStream 

func NewMockInboundGrpcToOutboundHttpStream(ctrl *gomock.Controller) *MockInboundGrpcToOutboundHttpStream

NewMockInboundGrpcToOutboundHttpStream creates a new mock instance.

func (*MockInboundGrpcToOutboundHttpStream) Context 

func (m *MockInboundGrpcToOutboundHttpStream) Context() context.Context

Context mocks base method.

func (*MockInboundGrpcToOutboundHttpStream) EXPECT 

func (m *MockInboundGrpcToOutboundHttpStream) EXPECT() *MockInboundGrpcToOutboundHttpStreamMockRecorder

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

func (*MockInboundGrpcToOutboundHttpStream) RecvMsg 

func (m *MockInboundGrpcToOutboundHttpStream) RecvMsg(arg0 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 MockInboundGrpcToOutboundHttpStreamMockRecorder 

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

MockInboundGrpcToOutboundHttpStreamMockRecorder is the mock recorder for MockInboundGrpcToOutboundHttpStream.

func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) Context 

func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) Context() *InboundGrpcToOutboundHttpStreamContextCall

Context indicates an expected call of Context.

func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) RecvMsg 

func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) RecvMsg(arg0 any) *InboundGrpcToOutboundHttpStreamRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) Send 

func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) Send(arg0 any) *InboundGrpcToOutboundHttpStreamSendCall

Send indicates an expected call of Send.

func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) SendHeader 

func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SendHeader(arg0 any) *InboundGrpcToOutboundHttpStreamSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) SendMsg 

func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SendMsg(arg0 any) *InboundGrpcToOutboundHttpStreamSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) SetHeader 

func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SetHeader(arg0 any) *InboundGrpcToOutboundHttpStreamSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*MockInboundGrpcToOutboundHttpStreamMockRecorder) SetTrailer 

func (mr *MockInboundGrpcToOutboundHttpStreamMockRecorder) SetTrailer(arg0 any) *InboundGrpcToOutboundHttpStreamSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type MockObjectsToSynchronizeWatcherInterface 

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

MockObjectsToSynchronizeWatcherInterface is a mock of ObjectsToSynchronizeWatcherInterface interface.

func NewMockObjectsToSynchronizeWatcherInterface 

func NewMockObjectsToSynchronizeWatcherInterface(ctrl *gomock.Controller) *MockObjectsToSynchronizeWatcherInterface

NewMockObjectsToSynchronizeWatcherInterface creates a new mock instance.

func (*MockObjectsToSynchronizeWatcherInterface) EXPECT 

func (m *MockObjectsToSynchronizeWatcherInterface) EXPECT() *MockObjectsToSynchronizeWatcherInterfaceMockRecorder

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

func (*MockObjectsToSynchronizeWatcherInterface) Watch 

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

Watch mocks base method.

type MockObjectsToSynchronizeWatcherInterfaceMockRecorder 

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

MockObjectsToSynchronizeWatcherInterfaceMockRecorder is the mock recorder for MockObjectsToSynchronizeWatcherInterface.

func (*MockObjectsToSynchronizeWatcherInterfaceMockRecorder) Watch 

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

Watch indicates an expected call of Watch.

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 MockPoolConnMockRecorder 

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

MockPoolConnMockRecorder is the mock recorder for MockPoolConn.

func (*MockPoolConnMockRecorder) Done 

func (mr *MockPoolConnMockRecorder) Done() *PoolConnDoneCall

Done indicates an expected call of Done.

func (*MockPoolConnMockRecorder) Invoke 

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

Invoke indicates an expected call of Invoke.

func (*MockPoolConnMockRecorder) NewStream 

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

NewStream indicates an expected call of NewStream.

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 MockPoolInterfaceMockRecorder 

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

MockPoolInterfaceMockRecorder is the mock recorder for MockPoolInterface.

func (*MockPoolInterfaceMockRecorder) Close 

func (mr *MockPoolInterfaceMockRecorder) Close() *PoolInterfaceCloseCall

Close indicates an expected call of Close.

func (*MockPoolInterfaceMockRecorder) Dial 

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

Dial indicates an expected call of Dial.

type MockServerErrorReporter added in v16.3.0 

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

MockServerErrorReporter is a mock of ServerErrorReporter interface.

func NewMockServerErrorReporter added in v16.3.0 

func NewMockServerErrorReporter(ctrl *gomock.Controller) *MockServerErrorReporter

NewMockServerErrorReporter creates a new mock instance.

func (*MockServerErrorReporter) EXPECT added in v16.3.0 

func (m *MockServerErrorReporter) EXPECT() *MockServerErrorReporterMockRecorder

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

func (*MockServerErrorReporter) Report added in v16.3.0 

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

Report mocks base method.

type MockServerErrorReporterMockRecorder added in v16.3.0 

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

MockServerErrorReporterMockRecorder is the mock recorder for MockServerErrorReporter.

func (*MockServerErrorReporterMockRecorder) Report added in v16.3.0 

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

Report indicates an expected call of Report.

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 MockServerStreamMockRecorder 

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

MockServerStreamMockRecorder is the mock recorder for MockServerStream.

func (*MockServerStreamMockRecorder) Context 

func (mr *MockServerStreamMockRecorder) Context() *ServerStreamContextCall

Context indicates an expected call of Context.

func (*MockServerStreamMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*MockServerStreamMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockServerStreamMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*MockServerStreamMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockServerStreamMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type MockServerTransportStream 

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

MockServerTransportStream is a mock of ServerTransportStream interface.

func NewMockServerTransportStream 

func NewMockServerTransportStream(ctrl *gomock.Controller) *MockServerTransportStream

NewMockServerTransportStream creates a new mock instance.

func (*MockServerTransportStream) EXPECT 

func (m *MockServerTransportStream) EXPECT() *MockServerTransportStreamMockRecorder

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

func (*MockServerTransportStream) Method 

func (m *MockServerTransportStream) Method() string

Method mocks base method.

func (*MockServerTransportStream) SendHeader 

func (m *MockServerTransportStream) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockServerTransportStream) SetHeader 

func (m *MockServerTransportStream) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockServerTransportStream) SetTrailer 

func (m *MockServerTransportStream) SetTrailer(arg0 metadata.MD) error

SetTrailer mocks base method.

type MockServerTransportStreamMockRecorder 

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

MockServerTransportStreamMockRecorder is the mock recorder for MockServerTransportStream.

func (*MockServerTransportStreamMockRecorder) Method 

func (mr *MockServerTransportStreamMockRecorder) Method() *ServerTransportStreamMethodCall

Method indicates an expected call of Method.

func (*MockServerTransportStreamMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*MockServerTransportStreamMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*MockServerTransportStreamMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type ObjectsToSynchronizeWatcherInterfaceWatchCall added in v16.5.0 

type ObjectsToSynchronizeWatcherInterfaceWatchCall struct {
	*gomock.Call
}

ObjectsToSynchronizeWatcherInterfaceWatchCall wrap *gomock.Call

func (*ObjectsToSynchronizeWatcherInterfaceWatchCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ObjectsToSynchronizeWatcherInterfaceWatchCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ObjectsToSynchronizeWatcherInterfaceWatchCall) Return added in v16.5.0 

func (c *ObjectsToSynchronizeWatcherInterfaceWatchCall) Return() *ObjectsToSynchronizeWatcherInterfaceWatchCall

Return rewrite *gomock.Call.Return

type PoolConnDoneCall added in v16.5.0 

type PoolConnDoneCall struct {
	*gomock.Call
}

PoolConnDoneCall wrap *gomock.Call

func (*PoolConnDoneCall) Do added in v16.5.0 

func (c *PoolConnDoneCall) Do(f func()) *PoolConnDoneCall

Do rewrite *gomock.Call.Do

func (*PoolConnDoneCall) DoAndReturn added in v16.5.0 

func (c *PoolConnDoneCall) DoAndReturn(f func()) *PoolConnDoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PoolConnDoneCall) Return added in v16.5.0 

func (c *PoolConnDoneCall) Return() *PoolConnDoneCall

Return rewrite *gomock.Call.Return

type PoolConnInvokeCall added in v16.5.0 

type PoolConnInvokeCall struct {
	*gomock.Call
}

PoolConnInvokeCall wrap *gomock.Call

func (*PoolConnInvokeCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*PoolConnInvokeCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PoolConnInvokeCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type PoolConnNewStreamCall added in v16.5.0 

type PoolConnNewStreamCall struct {
	*gomock.Call
}

PoolConnNewStreamCall wrap *gomock.Call

func (*PoolConnNewStreamCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*PoolConnNewStreamCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PoolConnNewStreamCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type PoolInterfaceCloseCall added in v16.5.0 

type PoolInterfaceCloseCall struct {
	*gomock.Call
}

PoolInterfaceCloseCall wrap *gomock.Call

func (*PoolInterfaceCloseCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*PoolInterfaceCloseCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PoolInterfaceCloseCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type PoolInterfaceDialCall added in v16.5.0 

type PoolInterfaceDialCall struct {
	*gomock.Call
}

PoolInterfaceDialCall wrap *gomock.Call

func (*PoolInterfaceDialCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*PoolInterfaceDialCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PoolInterfaceDialCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerErrorReporterReportCall added in v16.5.0 

type ServerErrorReporterReportCall struct {
	*gomock.Call
}

ServerErrorReporterReportCall wrap *gomock.Call

func (*ServerErrorReporterReportCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerErrorReporterReportCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerErrorReporterReportCall) Return added in v16.5.0 

func (c *ServerErrorReporterReportCall) Return() *ServerErrorReporterReportCall

Return rewrite *gomock.Call.Return

type ServerStreamContextCall added in v16.5.0 

type ServerStreamContextCall struct {
	*gomock.Call
}

ServerStreamContextCall wrap *gomock.Call

func (*ServerStreamContextCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerStreamContextCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerStreamContextCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerStreamRecvMsgCall added in v16.5.0 

type ServerStreamRecvMsgCall struct {
	*gomock.Call
}

ServerStreamRecvMsgCall wrap *gomock.Call

func (*ServerStreamRecvMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerStreamRecvMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerStreamRecvMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerStreamSendHeaderCall added in v16.5.0 

type ServerStreamSendHeaderCall struct {
	*gomock.Call
}

ServerStreamSendHeaderCall wrap *gomock.Call

func (*ServerStreamSendHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerStreamSendHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerStreamSendHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerStreamSendMsgCall added in v16.5.0 

type ServerStreamSendMsgCall struct {
	*gomock.Call
}

ServerStreamSendMsgCall wrap *gomock.Call

func (*ServerStreamSendMsgCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerStreamSendMsgCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerStreamSendMsgCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerStreamSetHeaderCall added in v16.5.0 

type ServerStreamSetHeaderCall struct {
	*gomock.Call
}

ServerStreamSetHeaderCall wrap *gomock.Call

func (*ServerStreamSetHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerStreamSetHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerStreamSetHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerStreamSetTrailerCall added in v16.5.0 

type ServerStreamSetTrailerCall struct {
	*gomock.Call
}

ServerStreamSetTrailerCall wrap *gomock.Call

func (*ServerStreamSetTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerStreamSetTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerStreamSetTrailerCall) Return added in v16.5.0 

func (c *ServerStreamSetTrailerCall) Return() *ServerStreamSetTrailerCall

Return rewrite *gomock.Call.Return

type ServerTransportStreamMethodCall added in v16.5.0 

type ServerTransportStreamMethodCall struct {
	*gomock.Call
}

ServerTransportStreamMethodCall wrap *gomock.Call

func (*ServerTransportStreamMethodCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerTransportStreamMethodCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerTransportStreamMethodCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerTransportStreamSendHeaderCall added in v16.5.0 

type ServerTransportStreamSendHeaderCall struct {
	*gomock.Call
}

ServerTransportStreamSendHeaderCall wrap *gomock.Call

func (*ServerTransportStreamSendHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerTransportStreamSendHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerTransportStreamSendHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerTransportStreamSetHeaderCall added in v16.5.0 

type ServerTransportStreamSetHeaderCall struct {
	*gomock.Call
}

ServerTransportStreamSetHeaderCall wrap *gomock.Call

func (*ServerTransportStreamSetHeaderCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerTransportStreamSetHeaderCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerTransportStreamSetHeaderCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

type ServerTransportStreamSetTrailerCall added in v16.5.0 

type ServerTransportStreamSetTrailerCall struct {
	*gomock.Call
}

ServerTransportStreamSetTrailerCall wrap *gomock.Call

func (*ServerTransportStreamSetTrailerCall) Do added in v16.5.0 

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

Do rewrite *gomock.Call.Do

func (*ServerTransportStreamSetTrailerCall) DoAndReturn added in v16.5.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ServerTransportStreamSetTrailerCall) Return added in v16.5.0 

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

Return rewrite *gomock.Call.Return

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.