mock

package
v0.13.0-nightly.20241116 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectorOrchestrator 

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

ConnectorOrchestrator is a mock of ConnectorOrchestrator interface.

func NewConnectorOrchestrator 

func NewConnectorOrchestrator(ctrl *gomock.Controller) *ConnectorOrchestrator

NewConnectorOrchestrator creates a new mock instance.

func (*ConnectorOrchestrator) Create 

func (m *ConnectorOrchestrator) Create(ctx context.Context, t connector.Type, plugin, pipelineID string, config connector.Config) (*connector.Instance, error)

Create mocks base method.

func (*ConnectorOrchestrator) Delete 

func (m *ConnectorOrchestrator) Delete(ctx context.Context, id string) error

Delete mocks base method.

func (*ConnectorOrchestrator) EXPECT 

func (m *ConnectorOrchestrator) EXPECT() *ConnectorOrchestratorMockRecorder

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

func (*ConnectorOrchestrator) Get 

func (m *ConnectorOrchestrator) Get(ctx context.Context, id string) (*connector.Instance, error)

Get mocks base method.

func (*ConnectorOrchestrator) Inspect added in v0.4.0 

func (m *ConnectorOrchestrator) Inspect(ctx context.Context, id string) (*inspector.Session, error)

Inspect mocks base method.

func (*ConnectorOrchestrator) List 

func (m *ConnectorOrchestrator) List(ctx context.Context) map[string]*connector.Instance

List mocks base method.

func (*ConnectorOrchestrator) Update 

func (m *ConnectorOrchestrator) Update(ctx context.Context, id, plugin string, config connector.Config) (*connector.Instance, error)

Update mocks base method.

func (*ConnectorOrchestrator) Validate added in v0.2.1 

func (m *ConnectorOrchestrator) Validate(ctx context.Context, t connector.Type, plugin string, config connector.Config) error

Validate mocks base method.

type ConnectorOrchestratorCreateCall added in v0.11.0 

type ConnectorOrchestratorCreateCall struct {
	*gomock.Call
}

ConnectorOrchestratorCreateCall wrap *gomock.Call

func (*ConnectorOrchestratorCreateCall) Do added in v0.11.0 

func (c *ConnectorOrchestratorCreateCall) Do(f func(context.Context, connector.Type, string, string, connector.Config) (*connector.Instance, error)) *ConnectorOrchestratorCreateCall

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorCreateCall) DoAndReturn added in v0.11.0 

func (c *ConnectorOrchestratorCreateCall) DoAndReturn(f func(context.Context, connector.Type, string, string, connector.Config) (*connector.Instance, error)) *ConnectorOrchestratorCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorCreateCall) Return added in v0.11.0 

func (c *ConnectorOrchestratorCreateCall) Return(arg0 *connector.Instance, arg1 error) *ConnectorOrchestratorCreateCall

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorDeleteCall added in v0.11.0 

type ConnectorOrchestratorDeleteCall struct {
	*gomock.Call
}

ConnectorOrchestratorDeleteCall wrap *gomock.Call

func (*ConnectorOrchestratorDeleteCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorDeleteCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorDeleteCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorGetCall added in v0.11.0 

type ConnectorOrchestratorGetCall struct {
	*gomock.Call
}

ConnectorOrchestratorGetCall wrap *gomock.Call

func (*ConnectorOrchestratorGetCall) Do added in v0.11.0 

func (c *ConnectorOrchestratorGetCall) Do(f func(context.Context, string) (*connector.Instance, error)) *ConnectorOrchestratorGetCall

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorGetCall) DoAndReturn added in v0.11.0 

func (c *ConnectorOrchestratorGetCall) DoAndReturn(f func(context.Context, string) (*connector.Instance, error)) *ConnectorOrchestratorGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorGetCall) Return added in v0.11.0 

func (c *ConnectorOrchestratorGetCall) Return(arg0 *connector.Instance, arg1 error) *ConnectorOrchestratorGetCall

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorInspectCall added in v0.11.0 

type ConnectorOrchestratorInspectCall struct {
	*gomock.Call
}

ConnectorOrchestratorInspectCall wrap *gomock.Call

func (*ConnectorOrchestratorInspectCall) Do added in v0.11.0 

func (c *ConnectorOrchestratorInspectCall) Do(f func(context.Context, string) (*inspector.Session, error)) *ConnectorOrchestratorInspectCall

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorInspectCall) DoAndReturn added in v0.11.0 

func (c *ConnectorOrchestratorInspectCall) DoAndReturn(f func(context.Context, string) (*inspector.Session, error)) *ConnectorOrchestratorInspectCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorInspectCall) Return added in v0.11.0 

func (c *ConnectorOrchestratorInspectCall) Return(arg0 *inspector.Session, arg1 error) *ConnectorOrchestratorInspectCall

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorListCall added in v0.11.0 

type ConnectorOrchestratorListCall struct {
	*gomock.Call
}

ConnectorOrchestratorListCall wrap *gomock.Call

func (*ConnectorOrchestratorListCall) Do added in v0.11.0 

func (c *ConnectorOrchestratorListCall) Do(f func(context.Context) map[string]*connector.Instance) *ConnectorOrchestratorListCall

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorListCall) DoAndReturn added in v0.11.0 

func (c *ConnectorOrchestratorListCall) DoAndReturn(f func(context.Context) map[string]*connector.Instance) *ConnectorOrchestratorListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorListCall) Return added in v0.11.0 

func (c *ConnectorOrchestratorListCall) Return(arg0 map[string]*connector.Instance) *ConnectorOrchestratorListCall

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorMockRecorder 

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

ConnectorOrchestratorMockRecorder is the mock recorder for ConnectorOrchestrator.

func (*ConnectorOrchestratorMockRecorder) Create 

func (mr *ConnectorOrchestratorMockRecorder) Create(ctx, t, plugin, pipelineID, config any) *ConnectorOrchestratorCreateCall

Create indicates an expected call of Create.

func (*ConnectorOrchestratorMockRecorder) Delete 

func (mr *ConnectorOrchestratorMockRecorder) Delete(ctx, id any) *ConnectorOrchestratorDeleteCall

Delete indicates an expected call of Delete.

func (*ConnectorOrchestratorMockRecorder) Get 

func (mr *ConnectorOrchestratorMockRecorder) Get(ctx, id any) *ConnectorOrchestratorGetCall

Get indicates an expected call of Get.

func (*ConnectorOrchestratorMockRecorder) Inspect added in v0.4.0 

func (mr *ConnectorOrchestratorMockRecorder) Inspect(ctx, id any) *ConnectorOrchestratorInspectCall

Inspect indicates an expected call of Inspect.

func (*ConnectorOrchestratorMockRecorder) List 

func (mr *ConnectorOrchestratorMockRecorder) List(ctx any) *ConnectorOrchestratorListCall

List indicates an expected call of List.

func (*ConnectorOrchestratorMockRecorder) Update 

func (mr *ConnectorOrchestratorMockRecorder) Update(ctx, id, plugin, config any) *ConnectorOrchestratorUpdateCall

Update indicates an expected call of Update.

func (*ConnectorOrchestratorMockRecorder) Validate added in v0.2.1 

func (mr *ConnectorOrchestratorMockRecorder) Validate(ctx, t, plugin, config any) *ConnectorOrchestratorValidateCall

Validate indicates an expected call of Validate.

type ConnectorOrchestratorUpdateCall added in v0.11.0 

type ConnectorOrchestratorUpdateCall struct {
	*gomock.Call
}

ConnectorOrchestratorUpdateCall wrap *gomock.Call

func (*ConnectorOrchestratorUpdateCall) Do added in v0.11.0 

func (c *ConnectorOrchestratorUpdateCall) Do(f func(context.Context, string, string, connector.Config) (*connector.Instance, error)) *ConnectorOrchestratorUpdateCall

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorUpdateCall) DoAndReturn added in v0.11.0 

func (c *ConnectorOrchestratorUpdateCall) DoAndReturn(f func(context.Context, string, string, connector.Config) (*connector.Instance, error)) *ConnectorOrchestratorUpdateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorUpdateCall) Return added in v0.11.0 

func (c *ConnectorOrchestratorUpdateCall) Return(arg0 *connector.Instance, arg1 error) *ConnectorOrchestratorUpdateCall

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorValidateCall added in v0.11.0 

type ConnectorOrchestratorValidateCall struct {
	*gomock.Call
}

ConnectorOrchestratorValidateCall wrap *gomock.Call

func (*ConnectorOrchestratorValidateCall) Do added in v0.11.0 

func (c *ConnectorOrchestratorValidateCall) Do(f func(context.Context, connector.Type, string, connector.Config) error) *ConnectorOrchestratorValidateCall

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorValidateCall) DoAndReturn added in v0.11.0 

func (c *ConnectorOrchestratorValidateCall) DoAndReturn(f func(context.Context, connector.Type, string, connector.Config) error) *ConnectorOrchestratorValidateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorValidateCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorPluginOrchestrator added in v0.9.0 

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

ConnectorPluginOrchestrator is a mock of ConnectorPluginOrchestrator interface.

func NewConnectorPluginOrchestrator added in v0.9.0 

func NewConnectorPluginOrchestrator(ctrl *gomock.Controller) *ConnectorPluginOrchestrator

NewConnectorPluginOrchestrator creates a new mock instance.

func (*ConnectorPluginOrchestrator) EXPECT added in v0.9.0 

func (m *ConnectorPluginOrchestrator) EXPECT() *ConnectorPluginOrchestratorMockRecorder

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

func (*ConnectorPluginOrchestrator) List added in v0.9.0 

func (m *ConnectorPluginOrchestrator) List(ctx context.Context) (map[string]pconnector.Specification, error)

List mocks base method.

type ConnectorPluginOrchestratorListCall added in v0.11.0 

type ConnectorPluginOrchestratorListCall struct {
	*gomock.Call
}

ConnectorPluginOrchestratorListCall wrap *gomock.Call

func (*ConnectorPluginOrchestratorListCall) Do added in v0.11.0 

func (c *ConnectorPluginOrchestratorListCall) Do(f func(context.Context) (map[string]pconnector.Specification, error)) *ConnectorPluginOrchestratorListCall

Do rewrite *gomock.Call.Do

func (*ConnectorPluginOrchestratorListCall) DoAndReturn added in v0.11.0 

func (c *ConnectorPluginOrchestratorListCall) DoAndReturn(f func(context.Context) (map[string]pconnector.Specification, error)) *ConnectorPluginOrchestratorListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorPluginOrchestratorListCall) Return added in v0.11.0 

func (c *ConnectorPluginOrchestratorListCall) Return(arg0 map[string]pconnector.Specification, arg1 error) *ConnectorPluginOrchestratorListCall

Return rewrite *gomock.Call.Return

type ConnectorPluginOrchestratorMockRecorder added in v0.9.0 

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

ConnectorPluginOrchestratorMockRecorder is the mock recorder for ConnectorPluginOrchestrator.

func (*ConnectorPluginOrchestratorMockRecorder) List added in v0.9.0 

func (mr *ConnectorPluginOrchestratorMockRecorder) List(ctx any) *ConnectorPluginOrchestratorListCall

List indicates an expected call of List.

type ConnectorService_InspectConnectorServer added in v0.4.0 

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

ConnectorService_InspectConnectorServer is a mock of ConnectorService_InspectConnectorServer interface.

func NewConnectorService_InspectConnectorServer added in v0.4.0 

func NewConnectorService_InspectConnectorServer(ctrl *gomock.Controller) *ConnectorService_InspectConnectorServer

NewConnectorService_InspectConnectorServer creates a new mock instance.

func (*ConnectorService_InspectConnectorServer) Context added in v0.4.0 

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

Context mocks base method.

func (*ConnectorService_InspectConnectorServer) EXPECT added in v0.4.0 

func (m *ConnectorService_InspectConnectorServer) EXPECT() *ConnectorService_InspectConnectorServerMockRecorder

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

func (*ConnectorService_InspectConnectorServer) RecvMsg added in v0.4.0 

func (m_2 *ConnectorService_InspectConnectorServer) RecvMsg(m any) error

RecvMsg mocks base method.

func (*ConnectorService_InspectConnectorServer) Send added in v0.4.0 

func (m *ConnectorService_InspectConnectorServer) Send(arg0 *apiv1.InspectConnectorResponse) error

Send mocks base method.

func (*ConnectorService_InspectConnectorServer) SendHeader added in v0.4.0 

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

SendHeader mocks base method.

func (*ConnectorService_InspectConnectorServer) SendMsg added in v0.4.0 

func (m_2 *ConnectorService_InspectConnectorServer) SendMsg(m any) error

SendMsg mocks base method.

func (*ConnectorService_InspectConnectorServer) SetHeader added in v0.4.0 

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

SetHeader mocks base method.

func (*ConnectorService_InspectConnectorServer) SetTrailer added in v0.4.0 

func (m *ConnectorService_InspectConnectorServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type ConnectorService_InspectConnectorServerContextCall added in v0.11.0 

type ConnectorService_InspectConnectorServerContextCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerContextCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerContextCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerContextCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerContextCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerMockRecorder added in v0.4.0 

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

ConnectorService_InspectConnectorServerMockRecorder is the mock recorder for ConnectorService_InspectConnectorServer.

func (*ConnectorService_InspectConnectorServerMockRecorder) Context added in v0.4.0 

func (mr *ConnectorService_InspectConnectorServerMockRecorder) Context() *ConnectorService_InspectConnectorServerContextCall

Context indicates an expected call of Context.

func (*ConnectorService_InspectConnectorServerMockRecorder) RecvMsg added in v0.4.0 

func (mr *ConnectorService_InspectConnectorServerMockRecorder) RecvMsg(m any) *ConnectorService_InspectConnectorServerRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*ConnectorService_InspectConnectorServerMockRecorder) Send added in v0.4.0 

func (mr *ConnectorService_InspectConnectorServerMockRecorder) Send(arg0 any) *ConnectorService_InspectConnectorServerSendCall

Send indicates an expected call of Send.

func (*ConnectorService_InspectConnectorServerMockRecorder) SendHeader added in v0.4.0 

func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendHeader(arg0 any) *ConnectorService_InspectConnectorServerSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*ConnectorService_InspectConnectorServerMockRecorder) SendMsg added in v0.4.0 

func (mr *ConnectorService_InspectConnectorServerMockRecorder) SendMsg(m any) *ConnectorService_InspectConnectorServerSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*ConnectorService_InspectConnectorServerMockRecorder) SetHeader added in v0.4.0 

func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetHeader(arg0 any) *ConnectorService_InspectConnectorServerSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*ConnectorService_InspectConnectorServerMockRecorder) SetTrailer added in v0.4.0 

func (mr *ConnectorService_InspectConnectorServerMockRecorder) SetTrailer(arg0 any) *ConnectorService_InspectConnectorServerSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type ConnectorService_InspectConnectorServerRecvMsgCall added in v0.11.0 

type ConnectorService_InspectConnectorServerRecvMsgCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerRecvMsgCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerRecvMsgCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerRecvMsgCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerRecvMsgCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSendCall added in v0.11.0 

type ConnectorService_InspectConnectorServerSendCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSendCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSendCall) Do added in v0.11.0 

func (c *ConnectorService_InspectConnectorServerSendCall) Do(f func(*apiv1.InspectConnectorResponse) error) *ConnectorService_InspectConnectorServerSendCall

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSendCall) DoAndReturn added in v0.11.0 

func (c *ConnectorService_InspectConnectorServerSendCall) DoAndReturn(f func(*apiv1.InspectConnectorResponse) error) *ConnectorService_InspectConnectorServerSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSendCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSendHeaderCall added in v0.11.0 

type ConnectorService_InspectConnectorServerSendHeaderCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSendHeaderCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSendHeaderCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSendHeaderCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSendHeaderCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSendMsgCall added in v0.11.0 

type ConnectorService_InspectConnectorServerSendMsgCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSendMsgCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSendMsgCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSendMsgCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSendMsgCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSetHeaderCall added in v0.11.0 

type ConnectorService_InspectConnectorServerSetHeaderCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSetHeaderCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSetHeaderCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSetHeaderCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSetHeaderCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSetTrailerCall added in v0.11.0 

type ConnectorService_InspectConnectorServerSetTrailerCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSetTrailerCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSetTrailerCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSetTrailerCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSetTrailerCall) Return added in v0.11.0 

func (c *ConnectorService_InspectConnectorServerSetTrailerCall) Return() *ConnectorService_InspectConnectorServerSetTrailerCall

Return rewrite *gomock.Call.Return

type PipelineOrchestrator 

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

PipelineOrchestrator is a mock of PipelineOrchestrator interface.

func NewPipelineOrchestrator 

func NewPipelineOrchestrator(ctrl *gomock.Controller) *PipelineOrchestrator

NewPipelineOrchestrator creates a new mock instance.

func (*PipelineOrchestrator) Create 

func (m *PipelineOrchestrator) Create(ctx context.Context, cfg pipeline.Config) (*pipeline.Instance, error)

Create mocks base method.

func (*PipelineOrchestrator) Delete 

func (m *PipelineOrchestrator) Delete(ctx context.Context, id string) error

Delete mocks base method.

func (*PipelineOrchestrator) EXPECT 

func (m *PipelineOrchestrator) EXPECT() *PipelineOrchestratorMockRecorder

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

func (*PipelineOrchestrator) Get 

func (m *PipelineOrchestrator) Get(ctx context.Context, id string) (*pipeline.Instance, error)

Get mocks base method.

func (*PipelineOrchestrator) List 

func (m *PipelineOrchestrator) List(ctx context.Context) map[string]*pipeline.Instance

List mocks base method.

func (*PipelineOrchestrator) Start 

func (m *PipelineOrchestrator) Start(ctx context.Context, id string) error

Start mocks base method.

func (*PipelineOrchestrator) Stop 

func (m *PipelineOrchestrator) Stop(ctx context.Context, id string, force bool) error

Stop mocks base method.

func (*PipelineOrchestrator) Update 

func (m *PipelineOrchestrator) Update(ctx context.Context, id string, cfg pipeline.Config) (*pipeline.Instance, error)

Update mocks base method.

func (*PipelineOrchestrator) UpdateDLQ added in v0.5.0 

func (m *PipelineOrchestrator) UpdateDLQ(ctx context.Context, id string, dlq pipeline.DLQ) (*pipeline.Instance, error)

UpdateDLQ mocks base method.

type PipelineOrchestratorCreateCall added in v0.11.0 

type PipelineOrchestratorCreateCall struct {
	*gomock.Call
}

PipelineOrchestratorCreateCall wrap *gomock.Call

func (*PipelineOrchestratorCreateCall) Do added in v0.11.0 

func (c *PipelineOrchestratorCreateCall) Do(f func(context.Context, pipeline.Config) (*pipeline.Instance, error)) *PipelineOrchestratorCreateCall

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorCreateCall) DoAndReturn added in v0.11.0 

func (c *PipelineOrchestratorCreateCall) DoAndReturn(f func(context.Context, pipeline.Config) (*pipeline.Instance, error)) *PipelineOrchestratorCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorCreateCall) Return added in v0.11.0 

func (c *PipelineOrchestratorCreateCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineOrchestratorCreateCall

Return rewrite *gomock.Call.Return

type PipelineOrchestratorDeleteCall added in v0.11.0 

type PipelineOrchestratorDeleteCall struct {
	*gomock.Call
}

PipelineOrchestratorDeleteCall wrap *gomock.Call

func (*PipelineOrchestratorDeleteCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorDeleteCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorDeleteCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorGetCall added in v0.11.0 

type PipelineOrchestratorGetCall struct {
	*gomock.Call
}

PipelineOrchestratorGetCall wrap *gomock.Call

func (*PipelineOrchestratorGetCall) Do added in v0.11.0 

func (c *PipelineOrchestratorGetCall) Do(f func(context.Context, string) (*pipeline.Instance, error)) *PipelineOrchestratorGetCall

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorGetCall) DoAndReturn added in v0.11.0 

func (c *PipelineOrchestratorGetCall) DoAndReturn(f func(context.Context, string) (*pipeline.Instance, error)) *PipelineOrchestratorGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorGetCall) Return added in v0.11.0 

func (c *PipelineOrchestratorGetCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineOrchestratorGetCall

Return rewrite *gomock.Call.Return

type PipelineOrchestratorListCall added in v0.11.0 

type PipelineOrchestratorListCall struct {
	*gomock.Call
}

PipelineOrchestratorListCall wrap *gomock.Call

func (*PipelineOrchestratorListCall) Do added in v0.11.0 

func (c *PipelineOrchestratorListCall) Do(f func(context.Context) map[string]*pipeline.Instance) *PipelineOrchestratorListCall

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorListCall) DoAndReturn added in v0.11.0 

func (c *PipelineOrchestratorListCall) DoAndReturn(f func(context.Context) map[string]*pipeline.Instance) *PipelineOrchestratorListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorListCall) Return added in v0.11.0 

func (c *PipelineOrchestratorListCall) Return(arg0 map[string]*pipeline.Instance) *PipelineOrchestratorListCall

Return rewrite *gomock.Call.Return

type PipelineOrchestratorMockRecorder 

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

PipelineOrchestratorMockRecorder is the mock recorder for PipelineOrchestrator.

func (*PipelineOrchestratorMockRecorder) Create 

func (mr *PipelineOrchestratorMockRecorder) Create(ctx, cfg any) *PipelineOrchestratorCreateCall

Create indicates an expected call of Create.

func (*PipelineOrchestratorMockRecorder) Delete 

func (mr *PipelineOrchestratorMockRecorder) Delete(ctx, id any) *PipelineOrchestratorDeleteCall

Delete indicates an expected call of Delete.

func (*PipelineOrchestratorMockRecorder) Get 

func (mr *PipelineOrchestratorMockRecorder) Get(ctx, id any) *PipelineOrchestratorGetCall

Get indicates an expected call of Get.

func (*PipelineOrchestratorMockRecorder) List 

func (mr *PipelineOrchestratorMockRecorder) List(ctx any) *PipelineOrchestratorListCall

List indicates an expected call of List.

func (*PipelineOrchestratorMockRecorder) Start 

func (mr *PipelineOrchestratorMockRecorder) Start(ctx, id any) *PipelineOrchestratorStartCall

Start indicates an expected call of Start.

func (*PipelineOrchestratorMockRecorder) Stop 

func (mr *PipelineOrchestratorMockRecorder) Stop(ctx, id, force any) *PipelineOrchestratorStopCall

Stop indicates an expected call of Stop.

func (*PipelineOrchestratorMockRecorder) Update 

func (mr *PipelineOrchestratorMockRecorder) Update(ctx, id, cfg any) *PipelineOrchestratorUpdateCall

Update indicates an expected call of Update.

func (*PipelineOrchestratorMockRecorder) UpdateDLQ added in v0.5.0 

func (mr *PipelineOrchestratorMockRecorder) UpdateDLQ(ctx, id, dlq any) *PipelineOrchestratorUpdateDLQCall

UpdateDLQ indicates an expected call of UpdateDLQ.

type PipelineOrchestratorStartCall added in v0.11.0 

type PipelineOrchestratorStartCall struct {
	*gomock.Call
}

PipelineOrchestratorStartCall wrap *gomock.Call

func (*PipelineOrchestratorStartCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorStartCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorStartCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorStopCall added in v0.11.0 

type PipelineOrchestratorStopCall struct {
	*gomock.Call
}

PipelineOrchestratorStopCall wrap *gomock.Call

func (*PipelineOrchestratorStopCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorStopCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorStopCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorUpdateCall added in v0.11.0 

type PipelineOrchestratorUpdateCall struct {
	*gomock.Call
}

PipelineOrchestratorUpdateCall wrap *gomock.Call

func (*PipelineOrchestratorUpdateCall) Do added in v0.11.0 

func (c *PipelineOrchestratorUpdateCall) Do(f func(context.Context, string, pipeline.Config) (*pipeline.Instance, error)) *PipelineOrchestratorUpdateCall

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorUpdateCall) DoAndReturn added in v0.11.0 

func (c *PipelineOrchestratorUpdateCall) DoAndReturn(f func(context.Context, string, pipeline.Config) (*pipeline.Instance, error)) *PipelineOrchestratorUpdateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorUpdateCall) Return added in v0.11.0 

func (c *PipelineOrchestratorUpdateCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineOrchestratorUpdateCall

Return rewrite *gomock.Call.Return

type PipelineOrchestratorUpdateDLQCall added in v0.11.0 

type PipelineOrchestratorUpdateDLQCall struct {
	*gomock.Call
}

PipelineOrchestratorUpdateDLQCall wrap *gomock.Call

func (*PipelineOrchestratorUpdateDLQCall) Do added in v0.11.0 

func (c *PipelineOrchestratorUpdateDLQCall) Do(f func(context.Context, string, pipeline.DLQ) (*pipeline.Instance, error)) *PipelineOrchestratorUpdateDLQCall

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorUpdateDLQCall) DoAndReturn added in v0.11.0 

func (c *PipelineOrchestratorUpdateDLQCall) DoAndReturn(f func(context.Context, string, pipeline.DLQ) (*pipeline.Instance, error)) *PipelineOrchestratorUpdateDLQCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorUpdateDLQCall) Return added in v0.11.0 

func (c *PipelineOrchestratorUpdateDLQCall) Return(arg0 *pipeline.Instance, arg1 error) *PipelineOrchestratorUpdateDLQCall

Return rewrite *gomock.Call.Return

type ProcessorOrchestrator 

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

ProcessorOrchestrator is a mock of ProcessorOrchestrator interface.

func NewProcessorOrchestrator 

func NewProcessorOrchestrator(ctrl *gomock.Controller) *ProcessorOrchestrator

NewProcessorOrchestrator creates a new mock instance.

func (*ProcessorOrchestrator) Create 

func (m *ProcessorOrchestrator) Create(ctx context.Context, procType string, parent processor.Parent, cfg processor.Config, condition string) (*processor.Instance, error)

Create mocks base method.

func (*ProcessorOrchestrator) Delete 

func (m *ProcessorOrchestrator) Delete(ctx context.Context, id string) error

Delete mocks base method.

func (*ProcessorOrchestrator) EXPECT 

func (m *ProcessorOrchestrator) EXPECT() *ProcessorOrchestratorMockRecorder

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

func (*ProcessorOrchestrator) Get 

func (m *ProcessorOrchestrator) Get(ctx context.Context, id string) (*processor.Instance, error)

Get mocks base method.

func (*ProcessorOrchestrator) InspectIn added in v0.5.0 

func (m *ProcessorOrchestrator) InspectIn(ctx context.Context, id string) (*inspector.Session, error)

InspectIn mocks base method.

func (*ProcessorOrchestrator) InspectOut added in v0.5.0 

func (m *ProcessorOrchestrator) InspectOut(ctx context.Context, id string) (*inspector.Session, error)

InspectOut mocks base method.

func (*ProcessorOrchestrator) List 

func (m *ProcessorOrchestrator) List(ctx context.Context) map[string]*processor.Instance

List mocks base method.

func (*ProcessorOrchestrator) Update 

func (m *ProcessorOrchestrator) Update(ctx context.Context, id, plugin string, cfg processor.Config) (*processor.Instance, error)

Update mocks base method.

type ProcessorOrchestratorCreateCall added in v0.11.0 

type ProcessorOrchestratorCreateCall struct {
	*gomock.Call
}

ProcessorOrchestratorCreateCall wrap *gomock.Call

func (*ProcessorOrchestratorCreateCall) Do added in v0.11.0 

func (c *ProcessorOrchestratorCreateCall) Do(f func(context.Context, string, processor.Parent, processor.Config, string) (*processor.Instance, error)) *ProcessorOrchestratorCreateCall

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorCreateCall) DoAndReturn added in v0.11.0 

func (c *ProcessorOrchestratorCreateCall) DoAndReturn(f func(context.Context, string, processor.Parent, processor.Config, string) (*processor.Instance, error)) *ProcessorOrchestratorCreateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorCreateCall) Return added in v0.11.0 

func (c *ProcessorOrchestratorCreateCall) Return(arg0 *processor.Instance, arg1 error) *ProcessorOrchestratorCreateCall

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorDeleteCall added in v0.11.0 

type ProcessorOrchestratorDeleteCall struct {
	*gomock.Call
}

ProcessorOrchestratorDeleteCall wrap *gomock.Call

func (*ProcessorOrchestratorDeleteCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorDeleteCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorDeleteCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorGetCall added in v0.11.0 

type ProcessorOrchestratorGetCall struct {
	*gomock.Call
}

ProcessorOrchestratorGetCall wrap *gomock.Call

func (*ProcessorOrchestratorGetCall) Do added in v0.11.0 

func (c *ProcessorOrchestratorGetCall) Do(f func(context.Context, string) (*processor.Instance, error)) *ProcessorOrchestratorGetCall

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorGetCall) DoAndReturn added in v0.11.0 

func (c *ProcessorOrchestratorGetCall) DoAndReturn(f func(context.Context, string) (*processor.Instance, error)) *ProcessorOrchestratorGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorGetCall) Return added in v0.11.0 

func (c *ProcessorOrchestratorGetCall) Return(arg0 *processor.Instance, arg1 error) *ProcessorOrchestratorGetCall

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorInspectInCall added in v0.11.0 

type ProcessorOrchestratorInspectInCall struct {
	*gomock.Call
}

ProcessorOrchestratorInspectInCall wrap *gomock.Call

func (*ProcessorOrchestratorInspectInCall) Do added in v0.11.0 

func (c *ProcessorOrchestratorInspectInCall) Do(f func(context.Context, string) (*inspector.Session, error)) *ProcessorOrchestratorInspectInCall

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorInspectInCall) DoAndReturn added in v0.11.0 

func (c *ProcessorOrchestratorInspectInCall) DoAndReturn(f func(context.Context, string) (*inspector.Session, error)) *ProcessorOrchestratorInspectInCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorInspectInCall) Return added in v0.11.0 

func (c *ProcessorOrchestratorInspectInCall) Return(arg0 *inspector.Session, arg1 error) *ProcessorOrchestratorInspectInCall

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorInspectOutCall added in v0.11.0 

type ProcessorOrchestratorInspectOutCall struct {
	*gomock.Call
}

ProcessorOrchestratorInspectOutCall wrap *gomock.Call

func (*ProcessorOrchestratorInspectOutCall) Do added in v0.11.0 

func (c *ProcessorOrchestratorInspectOutCall) Do(f func(context.Context, string) (*inspector.Session, error)) *ProcessorOrchestratorInspectOutCall

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorInspectOutCall) DoAndReturn added in v0.11.0 

func (c *ProcessorOrchestratorInspectOutCall) DoAndReturn(f func(context.Context, string) (*inspector.Session, error)) *ProcessorOrchestratorInspectOutCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorInspectOutCall) Return added in v0.11.0 

func (c *ProcessorOrchestratorInspectOutCall) Return(arg0 *inspector.Session, arg1 error) *ProcessorOrchestratorInspectOutCall

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorListCall added in v0.11.0 

type ProcessorOrchestratorListCall struct {
	*gomock.Call
}

ProcessorOrchestratorListCall wrap *gomock.Call

func (*ProcessorOrchestratorListCall) Do added in v0.11.0 

func (c *ProcessorOrchestratorListCall) Do(f func(context.Context) map[string]*processor.Instance) *ProcessorOrchestratorListCall

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorListCall) DoAndReturn added in v0.11.0 

func (c *ProcessorOrchestratorListCall) DoAndReturn(f func(context.Context) map[string]*processor.Instance) *ProcessorOrchestratorListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorListCall) Return added in v0.11.0 

func (c *ProcessorOrchestratorListCall) Return(arg0 map[string]*processor.Instance) *ProcessorOrchestratorListCall

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorMockRecorder 

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

ProcessorOrchestratorMockRecorder is the mock recorder for ProcessorOrchestrator.

func (*ProcessorOrchestratorMockRecorder) Create 

func (mr *ProcessorOrchestratorMockRecorder) Create(ctx, procType, parent, cfg, condition any) *ProcessorOrchestratorCreateCall

Create indicates an expected call of Create.

func (*ProcessorOrchestratorMockRecorder) Delete 

func (mr *ProcessorOrchestratorMockRecorder) Delete(ctx, id any) *ProcessorOrchestratorDeleteCall

Delete indicates an expected call of Delete.

func (*ProcessorOrchestratorMockRecorder) Get 

func (mr *ProcessorOrchestratorMockRecorder) Get(ctx, id any) *ProcessorOrchestratorGetCall

Get indicates an expected call of Get.

func (*ProcessorOrchestratorMockRecorder) InspectIn added in v0.5.0 

func (mr *ProcessorOrchestratorMockRecorder) InspectIn(ctx, id any) *ProcessorOrchestratorInspectInCall

InspectIn indicates an expected call of InspectIn.

func (*ProcessorOrchestratorMockRecorder) InspectOut added in v0.5.0 

func (mr *ProcessorOrchestratorMockRecorder) InspectOut(ctx, id any) *ProcessorOrchestratorInspectOutCall

InspectOut indicates an expected call of InspectOut.

func (*ProcessorOrchestratorMockRecorder) List 

func (mr *ProcessorOrchestratorMockRecorder) List(ctx any) *ProcessorOrchestratorListCall

List indicates an expected call of List.

func (*ProcessorOrchestratorMockRecorder) Update 

func (mr *ProcessorOrchestratorMockRecorder) Update(ctx, id, plugin, cfg any) *ProcessorOrchestratorUpdateCall

Update indicates an expected call of Update.

type ProcessorOrchestratorUpdateCall added in v0.11.0 

type ProcessorOrchestratorUpdateCall struct {
	*gomock.Call
}

ProcessorOrchestratorUpdateCall wrap *gomock.Call

func (*ProcessorOrchestratorUpdateCall) Do added in v0.11.0 

func (c *ProcessorOrchestratorUpdateCall) Do(f func(context.Context, string, string, processor.Config) (*processor.Instance, error)) *ProcessorOrchestratorUpdateCall

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorUpdateCall) DoAndReturn added in v0.11.0 

func (c *ProcessorOrchestratorUpdateCall) DoAndReturn(f func(context.Context, string, string, processor.Config) (*processor.Instance, error)) *ProcessorOrchestratorUpdateCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorUpdateCall) Return added in v0.11.0 

func (c *ProcessorOrchestratorUpdateCall) Return(arg0 *processor.Instance, arg1 error) *ProcessorOrchestratorUpdateCall

Return rewrite *gomock.Call.Return

type ProcessorPluginOrchestrator added in v0.9.0 

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

ProcessorPluginOrchestrator is a mock of ProcessorPluginOrchestrator interface.

func NewProcessorPluginOrchestrator added in v0.9.0 

func NewProcessorPluginOrchestrator(ctrl *gomock.Controller) *ProcessorPluginOrchestrator

NewProcessorPluginOrchestrator creates a new mock instance.

func (*ProcessorPluginOrchestrator) EXPECT added in v0.9.0 

func (m *ProcessorPluginOrchestrator) EXPECT() *ProcessorPluginOrchestratorMockRecorder

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

func (*ProcessorPluginOrchestrator) List added in v0.9.0 

func (m *ProcessorPluginOrchestrator) List(ctx context.Context) (map[string]sdk.Specification, error)

List mocks base method.

type ProcessorPluginOrchestratorListCall added in v0.11.0 

type ProcessorPluginOrchestratorListCall struct {
	*gomock.Call
}

ProcessorPluginOrchestratorListCall wrap *gomock.Call

func (*ProcessorPluginOrchestratorListCall) Do added in v0.11.0 

func (c *ProcessorPluginOrchestratorListCall) Do(f func(context.Context) (map[string]sdk.Specification, error)) *ProcessorPluginOrchestratorListCall

Do rewrite *gomock.Call.Do

func (*ProcessorPluginOrchestratorListCall) DoAndReturn added in v0.11.0 

func (c *ProcessorPluginOrchestratorListCall) DoAndReturn(f func(context.Context) (map[string]sdk.Specification, error)) *ProcessorPluginOrchestratorListCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorPluginOrchestratorListCall) Return added in v0.11.0 

func (c *ProcessorPluginOrchestratorListCall) Return(arg0 map[string]sdk.Specification, arg1 error) *ProcessorPluginOrchestratorListCall

Return rewrite *gomock.Call.Return

type ProcessorPluginOrchestratorMockRecorder added in v0.9.0 

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

ProcessorPluginOrchestratorMockRecorder is the mock recorder for ProcessorPluginOrchestrator.

func (*ProcessorPluginOrchestratorMockRecorder) List added in v0.9.0 

func (mr *ProcessorPluginOrchestratorMockRecorder) List(ctx any) *ProcessorPluginOrchestratorListCall

List indicates an expected call of List.

type ProcessorService_InspectProcessorInServer added in v0.5.0 

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

ProcessorService_InspectProcessorInServer is a mock of ProcessorService_InspectProcessorInServer interface.

func NewProcessorService_InspectProcessorInServer added in v0.5.0 

func NewProcessorService_InspectProcessorInServer(ctrl *gomock.Controller) *ProcessorService_InspectProcessorInServer

NewProcessorService_InspectProcessorInServer creates a new mock instance.

func (*ProcessorService_InspectProcessorInServer) Context added in v0.5.0 

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

Context mocks base method.

func (*ProcessorService_InspectProcessorInServer) EXPECT added in v0.5.0 

func (m *ProcessorService_InspectProcessorInServer) EXPECT() *ProcessorService_InspectProcessorInServerMockRecorder

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

func (*ProcessorService_InspectProcessorInServer) RecvMsg added in v0.5.0 

func (m_2 *ProcessorService_InspectProcessorInServer) RecvMsg(m any) error

RecvMsg mocks base method.

func (*ProcessorService_InspectProcessorInServer) Send added in v0.5.0 

func (m *ProcessorService_InspectProcessorInServer) Send(arg0 *apiv1.InspectProcessorInResponse) error

Send mocks base method.

func (*ProcessorService_InspectProcessorInServer) SendHeader added in v0.5.0 

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

SendHeader mocks base method.

func (*ProcessorService_InspectProcessorInServer) SendMsg added in v0.5.0 

func (m_2 *ProcessorService_InspectProcessorInServer) SendMsg(m any) error

SendMsg mocks base method.

func (*ProcessorService_InspectProcessorInServer) SetHeader added in v0.5.0 

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

SetHeader mocks base method.

func (*ProcessorService_InspectProcessorInServer) SetTrailer added in v0.5.0 

func (m *ProcessorService_InspectProcessorInServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type ProcessorService_InspectProcessorInServerContextCall added in v0.11.0 

type ProcessorService_InspectProcessorInServerContextCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerContextCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerContextCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerContextCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerContextCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerMockRecorder added in v0.5.0 

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

ProcessorService_InspectProcessorInServerMockRecorder is the mock recorder for ProcessorService_InspectProcessorInServer.

func (*ProcessorService_InspectProcessorInServerMockRecorder) Context added in v0.5.0 

func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Context() *ProcessorService_InspectProcessorInServerContextCall

Context indicates an expected call of Context.

func (*ProcessorService_InspectProcessorInServerMockRecorder) RecvMsg added in v0.5.0 

func (mr *ProcessorService_InspectProcessorInServerMockRecorder) RecvMsg(m any) *ProcessorService_InspectProcessorInServerRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*ProcessorService_InspectProcessorInServerMockRecorder) Send added in v0.5.0 

func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Send(arg0 any) *ProcessorService_InspectProcessorInServerSendCall

Send indicates an expected call of Send.

func (*ProcessorService_InspectProcessorInServerMockRecorder) SendHeader added in v0.5.0 

func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendHeader(arg0 any) *ProcessorService_InspectProcessorInServerSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*ProcessorService_InspectProcessorInServerMockRecorder) SendMsg added in v0.5.0 

func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SendMsg(m any) *ProcessorService_InspectProcessorInServerSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*ProcessorService_InspectProcessorInServerMockRecorder) SetHeader added in v0.5.0 

func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetHeader(arg0 any) *ProcessorService_InspectProcessorInServerSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*ProcessorService_InspectProcessorInServerMockRecorder) SetTrailer added in v0.5.0 

func (mr *ProcessorService_InspectProcessorInServerMockRecorder) SetTrailer(arg0 any) *ProcessorService_InspectProcessorInServerSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type ProcessorService_InspectProcessorInServerRecvMsgCall added in v0.11.0 

type ProcessorService_InspectProcessorInServerRecvMsgCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerRecvMsgCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerRecvMsgCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerRecvMsgCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerRecvMsgCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSendCall added in v0.11.0 

type ProcessorService_InspectProcessorInServerSendCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSendCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSendCall) Do added in v0.11.0 

func (c *ProcessorService_InspectProcessorInServerSendCall) Do(f func(*apiv1.InspectProcessorInResponse) error) *ProcessorService_InspectProcessorInServerSendCall

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSendCall) DoAndReturn added in v0.11.0 

func (c *ProcessorService_InspectProcessorInServerSendCall) DoAndReturn(f func(*apiv1.InspectProcessorInResponse) error) *ProcessorService_InspectProcessorInServerSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSendCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSendHeaderCall added in v0.11.0 

type ProcessorService_InspectProcessorInServerSendHeaderCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSendHeaderCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSendHeaderCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSendHeaderCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSendHeaderCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSendMsgCall added in v0.11.0 

type ProcessorService_InspectProcessorInServerSendMsgCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSendMsgCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSendMsgCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSendMsgCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSendMsgCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSetHeaderCall added in v0.11.0 

type ProcessorService_InspectProcessorInServerSetHeaderCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSetHeaderCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSetHeaderCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSetHeaderCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSetHeaderCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSetTrailerCall added in v0.11.0 

type ProcessorService_InspectProcessorInServerSetTrailerCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSetTrailerCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSetTrailerCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSetTrailerCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSetTrailerCall) Return added in v0.11.0 

func (c *ProcessorService_InspectProcessorInServerSetTrailerCall) Return() *ProcessorService_InspectProcessorInServerSetTrailerCall

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServer added in v0.5.0 

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

ProcessorService_InspectProcessorOutServer is a mock of ProcessorService_InspectProcessorOutServer interface.

func NewProcessorService_InspectProcessorOutServer added in v0.5.0 

func NewProcessorService_InspectProcessorOutServer(ctrl *gomock.Controller) *ProcessorService_InspectProcessorOutServer

NewProcessorService_InspectProcessorOutServer creates a new mock instance.

func (*ProcessorService_InspectProcessorOutServer) Context added in v0.5.0 

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

Context mocks base method.

func (*ProcessorService_InspectProcessorOutServer) EXPECT added in v0.5.0 

func (m *ProcessorService_InspectProcessorOutServer) EXPECT() *ProcessorService_InspectProcessorOutServerMockRecorder

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

func (*ProcessorService_InspectProcessorOutServer) RecvMsg added in v0.5.0 

func (m_2 *ProcessorService_InspectProcessorOutServer) RecvMsg(m any) error

RecvMsg mocks base method.

func (*ProcessorService_InspectProcessorOutServer) Send added in v0.5.0 

func (m *ProcessorService_InspectProcessorOutServer) Send(arg0 *apiv1.InspectProcessorOutResponse) error

Send mocks base method.

func (*ProcessorService_InspectProcessorOutServer) SendHeader added in v0.5.0 

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

SendHeader mocks base method.

func (*ProcessorService_InspectProcessorOutServer) SendMsg added in v0.5.0 

func (m_2 *ProcessorService_InspectProcessorOutServer) SendMsg(m any) error

SendMsg mocks base method.

func (*ProcessorService_InspectProcessorOutServer) SetHeader added in v0.5.0 

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

SetHeader mocks base method.

func (*ProcessorService_InspectProcessorOutServer) SetTrailer added in v0.5.0 

func (m *ProcessorService_InspectProcessorOutServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type ProcessorService_InspectProcessorOutServerContextCall added in v0.11.0 

type ProcessorService_InspectProcessorOutServerContextCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerContextCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerContextCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerContextCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerContextCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerMockRecorder added in v0.5.0 

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

ProcessorService_InspectProcessorOutServerMockRecorder is the mock recorder for ProcessorService_InspectProcessorOutServer.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) Context added in v0.5.0 

func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Context() *ProcessorService_InspectProcessorOutServerContextCall

Context indicates an expected call of Context.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) RecvMsg added in v0.5.0 

func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) RecvMsg(m any) *ProcessorService_InspectProcessorOutServerRecvMsgCall

RecvMsg indicates an expected call of RecvMsg.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) Send added in v0.5.0 

func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Send(arg0 any) *ProcessorService_InspectProcessorOutServerSendCall

Send indicates an expected call of Send.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) SendHeader added in v0.5.0 

func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendHeader(arg0 any) *ProcessorService_InspectProcessorOutServerSendHeaderCall

SendHeader indicates an expected call of SendHeader.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) SendMsg added in v0.5.0 

func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SendMsg(m any) *ProcessorService_InspectProcessorOutServerSendMsgCall

SendMsg indicates an expected call of SendMsg.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) SetHeader added in v0.5.0 

func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetHeader(arg0 any) *ProcessorService_InspectProcessorOutServerSetHeaderCall

SetHeader indicates an expected call of SetHeader.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) SetTrailer added in v0.5.0 

func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) SetTrailer(arg0 any) *ProcessorService_InspectProcessorOutServerSetTrailerCall

SetTrailer indicates an expected call of SetTrailer.

type ProcessorService_InspectProcessorOutServerRecvMsgCall added in v0.11.0 

type ProcessorService_InspectProcessorOutServerRecvMsgCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerRecvMsgCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerRecvMsgCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerRecvMsgCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerRecvMsgCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSendCall added in v0.11.0 

type ProcessorService_InspectProcessorOutServerSendCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSendCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSendCall) Do added in v0.11.0 

func (c *ProcessorService_InspectProcessorOutServerSendCall) Do(f func(*apiv1.InspectProcessorOutResponse) error) *ProcessorService_InspectProcessorOutServerSendCall

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSendCall) DoAndReturn added in v0.11.0 

func (c *ProcessorService_InspectProcessorOutServerSendCall) DoAndReturn(f func(*apiv1.InspectProcessorOutResponse) error) *ProcessorService_InspectProcessorOutServerSendCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSendCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSendHeaderCall added in v0.11.0 

type ProcessorService_InspectProcessorOutServerSendHeaderCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSendHeaderCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSendHeaderCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSendHeaderCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSendHeaderCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSendMsgCall added in v0.11.0 

type ProcessorService_InspectProcessorOutServerSendMsgCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSendMsgCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSendMsgCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSendMsgCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSendMsgCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSetHeaderCall added in v0.11.0 

type ProcessorService_InspectProcessorOutServerSetHeaderCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSetHeaderCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSetHeaderCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSetHeaderCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSetHeaderCall) Return added in v0.11.0 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSetTrailerCall added in v0.11.0 

type ProcessorService_InspectProcessorOutServerSetTrailerCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSetTrailerCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSetTrailerCall) Do added in v0.11.0 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSetTrailerCall) DoAndReturn added in v0.11.0 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSetTrailerCall) Return added in v0.11.0 

func (c *ProcessorService_InspectProcessorOutServerSetTrailerCall) Return() *ProcessorService_InspectProcessorOutServerSetTrailerCall

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.