mock

package
v0.13.1 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2025 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 

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 

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

Validate mocks base method.

type ConnectorOrchestratorCreateCall 

type ConnectorOrchestratorCreateCall struct {
	*gomock.Call
}

ConnectorOrchestratorCreateCall wrap *gomock.Call

func (*ConnectorOrchestratorCreateCall) Do 

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 

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 

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

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorDeleteCall 

type ConnectorOrchestratorDeleteCall struct {
	*gomock.Call
}

ConnectorOrchestratorDeleteCall wrap *gomock.Call

func (*ConnectorOrchestratorDeleteCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorDeleteCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorDeleteCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorGetCall 

type ConnectorOrchestratorGetCall struct {
	*gomock.Call
}

ConnectorOrchestratorGetCall wrap *gomock.Call

func (*ConnectorOrchestratorGetCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorGetCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorGetCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorInspectCall 

type ConnectorOrchestratorInspectCall struct {
	*gomock.Call
}

ConnectorOrchestratorInspectCall wrap *gomock.Call

func (*ConnectorOrchestratorInspectCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorInspectCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorInspectCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorListCall 

type ConnectorOrchestratorListCall struct {
	*gomock.Call
}

ConnectorOrchestratorListCall wrap *gomock.Call

func (*ConnectorOrchestratorListCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorListCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorListCall) Return 

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 

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 

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

Validate indicates an expected call of Validate.

type ConnectorOrchestratorUpdateCall 

type ConnectorOrchestratorUpdateCall struct {
	*gomock.Call
}

ConnectorOrchestratorUpdateCall wrap *gomock.Call

func (*ConnectorOrchestratorUpdateCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorUpdateCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorUpdateCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorOrchestratorValidateCall 

type ConnectorOrchestratorValidateCall struct {
	*gomock.Call
}

ConnectorOrchestratorValidateCall wrap *gomock.Call

func (*ConnectorOrchestratorValidateCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorOrchestratorValidateCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorOrchestratorValidateCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorPluginOrchestrator 

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

ConnectorPluginOrchestrator is a mock of ConnectorPluginOrchestrator interface.

func NewConnectorPluginOrchestrator 

func NewConnectorPluginOrchestrator(ctrl *gomock.Controller) *ConnectorPluginOrchestrator

NewConnectorPluginOrchestrator creates a new mock instance.

func (*ConnectorPluginOrchestrator) EXPECT 

func (m *ConnectorPluginOrchestrator) EXPECT() *ConnectorPluginOrchestratorMockRecorder

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

func (*ConnectorPluginOrchestrator) List 

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

List mocks base method.

type ConnectorPluginOrchestratorListCall 

type ConnectorPluginOrchestratorListCall struct {
	*gomock.Call
}

ConnectorPluginOrchestratorListCall wrap *gomock.Call

func (*ConnectorPluginOrchestratorListCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorPluginOrchestratorListCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorPluginOrchestratorListCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorPluginOrchestratorMockRecorder 

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

ConnectorPluginOrchestratorMockRecorder is the mock recorder for ConnectorPluginOrchestrator.

func (*ConnectorPluginOrchestratorMockRecorder) List 

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

List indicates an expected call of List.

type ConnectorService_InspectConnectorServer 

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

ConnectorService_InspectConnectorServer is a mock of ConnectorService_InspectConnectorServer interface.

func NewConnectorService_InspectConnectorServer 

func NewConnectorService_InspectConnectorServer(ctrl *gomock.Controller) *ConnectorService_InspectConnectorServer

NewConnectorService_InspectConnectorServer creates a new mock instance.

func (*ConnectorService_InspectConnectorServer) Context 

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

Context mocks base method.

func (*ConnectorService_InspectConnectorServer) EXPECT 

func (m *ConnectorService_InspectConnectorServer) EXPECT() *ConnectorService_InspectConnectorServerMockRecorder

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

func (*ConnectorService_InspectConnectorServer) RecvMsg 

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

RecvMsg mocks base method.

func (*ConnectorService_InspectConnectorServer) Send 

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

Send mocks base method.

func (*ConnectorService_InspectConnectorServer) SendHeader 

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

SendHeader mocks base method.

func (*ConnectorService_InspectConnectorServer) SendMsg 

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

SendMsg mocks base method.

func (*ConnectorService_InspectConnectorServer) SetHeader 

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

SetHeader mocks base method.

func (*ConnectorService_InspectConnectorServer) SetTrailer 

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

SetTrailer mocks base method.

type ConnectorService_InspectConnectorServerContextCall 

type ConnectorService_InspectConnectorServerContextCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerContextCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerContextCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerContextCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerContextCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerMockRecorder 

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

ConnectorService_InspectConnectorServerMockRecorder is the mock recorder for ConnectorService_InspectConnectorServer.

func (*ConnectorService_InspectConnectorServerMockRecorder) Context 

func (mr *ConnectorService_InspectConnectorServerMockRecorder) Context() *ConnectorService_InspectConnectorServerContextCall

Context indicates an expected call of Context.

func (*ConnectorService_InspectConnectorServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*ConnectorService_InspectConnectorServerMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*ConnectorService_InspectConnectorServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*ConnectorService_InspectConnectorServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*ConnectorService_InspectConnectorServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*ConnectorService_InspectConnectorServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type ConnectorService_InspectConnectorServerRecvMsgCall 

type ConnectorService_InspectConnectorServerRecvMsgCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerRecvMsgCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerRecvMsgCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerRecvMsgCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerRecvMsgCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSendCall 

type ConnectorService_InspectConnectorServerSendCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSendCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSendCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSendCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSendCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSendHeaderCall 

type ConnectorService_InspectConnectorServerSendHeaderCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSendHeaderCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSendHeaderCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSendHeaderCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSendHeaderCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSendMsgCall 

type ConnectorService_InspectConnectorServerSendMsgCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSendMsgCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSendMsgCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSendMsgCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSendMsgCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSetHeaderCall 

type ConnectorService_InspectConnectorServerSetHeaderCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSetHeaderCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSetHeaderCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSetHeaderCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSetHeaderCall) Return 

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

Return rewrite *gomock.Call.Return

type ConnectorService_InspectConnectorServerSetTrailerCall 

type ConnectorService_InspectConnectorServerSetTrailerCall struct {
	*gomock.Call
}

ConnectorService_InspectConnectorServerSetTrailerCall wrap *gomock.Call

func (*ConnectorService_InspectConnectorServerSetTrailerCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ConnectorService_InspectConnectorServerSetTrailerCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ConnectorService_InspectConnectorServerSetTrailerCall) Return 

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 

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

UpdateDLQ mocks base method.

type PipelineOrchestratorCreateCall 

type PipelineOrchestratorCreateCall struct {
	*gomock.Call
}

PipelineOrchestratorCreateCall wrap *gomock.Call

func (*PipelineOrchestratorCreateCall) Do 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorCreateCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorCreateCall) Return 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorDeleteCall 

type PipelineOrchestratorDeleteCall struct {
	*gomock.Call
}

PipelineOrchestratorDeleteCall wrap *gomock.Call

func (*PipelineOrchestratorDeleteCall) Do 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorDeleteCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorDeleteCall) Return 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorGetCall 

type PipelineOrchestratorGetCall struct {
	*gomock.Call
}

PipelineOrchestratorGetCall wrap *gomock.Call

func (*PipelineOrchestratorGetCall) Do 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorGetCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorGetCall) Return 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorListCall 

type PipelineOrchestratorListCall struct {
	*gomock.Call
}

PipelineOrchestratorListCall wrap *gomock.Call

func (*PipelineOrchestratorListCall) Do 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorListCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorListCall) Return 

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 

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

UpdateDLQ indicates an expected call of UpdateDLQ.

type PipelineOrchestratorStartCall 

type PipelineOrchestratorStartCall struct {
	*gomock.Call
}

PipelineOrchestratorStartCall wrap *gomock.Call

func (*PipelineOrchestratorStartCall) Do 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorStartCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorStartCall) Return 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorStopCall 

type PipelineOrchestratorStopCall struct {
	*gomock.Call
}

PipelineOrchestratorStopCall wrap *gomock.Call

func (*PipelineOrchestratorStopCall) Do 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorStopCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorStopCall) Return 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorUpdateCall 

type PipelineOrchestratorUpdateCall struct {
	*gomock.Call
}

PipelineOrchestratorUpdateCall wrap *gomock.Call

func (*PipelineOrchestratorUpdateCall) Do 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorUpdateCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorUpdateCall) Return 

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

Return rewrite *gomock.Call.Return

type PipelineOrchestratorUpdateDLQCall 

type PipelineOrchestratorUpdateDLQCall struct {
	*gomock.Call
}

PipelineOrchestratorUpdateDLQCall wrap *gomock.Call

func (*PipelineOrchestratorUpdateDLQCall) Do 

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

Do rewrite *gomock.Call.Do

func (*PipelineOrchestratorUpdateDLQCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PipelineOrchestratorUpdateDLQCall) Return 

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 

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

InspectIn mocks base method.

func (*ProcessorOrchestrator) InspectOut 

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 

type ProcessorOrchestratorCreateCall struct {
	*gomock.Call
}

ProcessorOrchestratorCreateCall wrap *gomock.Call

func (*ProcessorOrchestratorCreateCall) Do 

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 

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 

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

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorDeleteCall 

type ProcessorOrchestratorDeleteCall struct {
	*gomock.Call
}

ProcessorOrchestratorDeleteCall wrap *gomock.Call

func (*ProcessorOrchestratorDeleteCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorDeleteCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorDeleteCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorGetCall 

type ProcessorOrchestratorGetCall struct {
	*gomock.Call
}

ProcessorOrchestratorGetCall wrap *gomock.Call

func (*ProcessorOrchestratorGetCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorGetCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorGetCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorInspectInCall 

type ProcessorOrchestratorInspectInCall struct {
	*gomock.Call
}

ProcessorOrchestratorInspectInCall wrap *gomock.Call

func (*ProcessorOrchestratorInspectInCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorInspectInCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorInspectInCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorInspectOutCall 

type ProcessorOrchestratorInspectOutCall struct {
	*gomock.Call
}

ProcessorOrchestratorInspectOutCall wrap *gomock.Call

func (*ProcessorOrchestratorInspectOutCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorInspectOutCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorInspectOutCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorOrchestratorListCall 

type ProcessorOrchestratorListCall struct {
	*gomock.Call
}

ProcessorOrchestratorListCall wrap *gomock.Call

func (*ProcessorOrchestratorListCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorListCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorListCall) Return 

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 

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

InspectIn indicates an expected call of InspectIn.

func (*ProcessorOrchestratorMockRecorder) InspectOut 

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 

type ProcessorOrchestratorUpdateCall struct {
	*gomock.Call
}

ProcessorOrchestratorUpdateCall wrap *gomock.Call

func (*ProcessorOrchestratorUpdateCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorOrchestratorUpdateCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorOrchestratorUpdateCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorPluginOrchestrator 

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

ProcessorPluginOrchestrator is a mock of ProcessorPluginOrchestrator interface.

func NewProcessorPluginOrchestrator 

func NewProcessorPluginOrchestrator(ctrl *gomock.Controller) *ProcessorPluginOrchestrator

NewProcessorPluginOrchestrator creates a new mock instance.

func (*ProcessorPluginOrchestrator) EXPECT 

func (m *ProcessorPluginOrchestrator) EXPECT() *ProcessorPluginOrchestratorMockRecorder

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

func (*ProcessorPluginOrchestrator) List 

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

List mocks base method.

type ProcessorPluginOrchestratorListCall 

type ProcessorPluginOrchestratorListCall struct {
	*gomock.Call
}

ProcessorPluginOrchestratorListCall wrap *gomock.Call

func (*ProcessorPluginOrchestratorListCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorPluginOrchestratorListCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorPluginOrchestratorListCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorPluginOrchestratorMockRecorder 

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

ProcessorPluginOrchestratorMockRecorder is the mock recorder for ProcessorPluginOrchestrator.

func (*ProcessorPluginOrchestratorMockRecorder) List 

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

List indicates an expected call of List.

type ProcessorService_InspectProcessorInServer 

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

ProcessorService_InspectProcessorInServer is a mock of ProcessorService_InspectProcessorInServer interface.

func NewProcessorService_InspectProcessorInServer 

func NewProcessorService_InspectProcessorInServer(ctrl *gomock.Controller) *ProcessorService_InspectProcessorInServer

NewProcessorService_InspectProcessorInServer creates a new mock instance.

func (*ProcessorService_InspectProcessorInServer) Context 

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

Context mocks base method.

func (*ProcessorService_InspectProcessorInServer) EXPECT 

func (m *ProcessorService_InspectProcessorInServer) EXPECT() *ProcessorService_InspectProcessorInServerMockRecorder

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

func (*ProcessorService_InspectProcessorInServer) RecvMsg 

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

RecvMsg mocks base method.

func (*ProcessorService_InspectProcessorInServer) Send 

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

Send mocks base method.

func (*ProcessorService_InspectProcessorInServer) SendHeader 

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

SendHeader mocks base method.

func (*ProcessorService_InspectProcessorInServer) SendMsg 

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

SendMsg mocks base method.

func (*ProcessorService_InspectProcessorInServer) SetHeader 

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

SetHeader mocks base method.

func (*ProcessorService_InspectProcessorInServer) SetTrailer 

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

SetTrailer mocks base method.

type ProcessorService_InspectProcessorInServerContextCall 

type ProcessorService_InspectProcessorInServerContextCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerContextCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerContextCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerContextCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerContextCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerMockRecorder 

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

ProcessorService_InspectProcessorInServerMockRecorder is the mock recorder for ProcessorService_InspectProcessorInServer.

func (*ProcessorService_InspectProcessorInServerMockRecorder) Context 

func (mr *ProcessorService_InspectProcessorInServerMockRecorder) Context() *ProcessorService_InspectProcessorInServerContextCall

Context indicates an expected call of Context.

func (*ProcessorService_InspectProcessorInServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*ProcessorService_InspectProcessorInServerMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*ProcessorService_InspectProcessorInServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*ProcessorService_InspectProcessorInServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*ProcessorService_InspectProcessorInServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*ProcessorService_InspectProcessorInServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type ProcessorService_InspectProcessorInServerRecvMsgCall 

type ProcessorService_InspectProcessorInServerRecvMsgCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerRecvMsgCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerRecvMsgCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerRecvMsgCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerRecvMsgCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSendCall 

type ProcessorService_InspectProcessorInServerSendCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSendCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSendCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSendCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSendCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSendHeaderCall 

type ProcessorService_InspectProcessorInServerSendHeaderCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSendHeaderCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSendHeaderCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSendHeaderCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSendHeaderCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSendMsgCall 

type ProcessorService_InspectProcessorInServerSendMsgCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSendMsgCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSendMsgCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSendMsgCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSendMsgCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSetHeaderCall 

type ProcessorService_InspectProcessorInServerSetHeaderCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSetHeaderCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSetHeaderCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSetHeaderCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSetHeaderCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorInServerSetTrailerCall 

type ProcessorService_InspectProcessorInServerSetTrailerCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorInServerSetTrailerCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorInServerSetTrailerCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorInServerSetTrailerCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorInServerSetTrailerCall) Return 

func (c *ProcessorService_InspectProcessorInServerSetTrailerCall) Return() *ProcessorService_InspectProcessorInServerSetTrailerCall

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServer 

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

ProcessorService_InspectProcessorOutServer is a mock of ProcessorService_InspectProcessorOutServer interface.

func NewProcessorService_InspectProcessorOutServer 

func NewProcessorService_InspectProcessorOutServer(ctrl *gomock.Controller) *ProcessorService_InspectProcessorOutServer

NewProcessorService_InspectProcessorOutServer creates a new mock instance.

func (*ProcessorService_InspectProcessorOutServer) Context 

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

Context mocks base method.

func (*ProcessorService_InspectProcessorOutServer) EXPECT 

func (m *ProcessorService_InspectProcessorOutServer) EXPECT() *ProcessorService_InspectProcessorOutServerMockRecorder

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

func (*ProcessorService_InspectProcessorOutServer) RecvMsg 

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

RecvMsg mocks base method.

func (*ProcessorService_InspectProcessorOutServer) Send 

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

Send mocks base method.

func (*ProcessorService_InspectProcessorOutServer) SendHeader 

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

SendHeader mocks base method.

func (*ProcessorService_InspectProcessorOutServer) SendMsg 

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

SendMsg mocks base method.

func (*ProcessorService_InspectProcessorOutServer) SetHeader 

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

SetHeader mocks base method.

func (*ProcessorService_InspectProcessorOutServer) SetTrailer 

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

SetTrailer mocks base method.

type ProcessorService_InspectProcessorOutServerContextCall 

type ProcessorService_InspectProcessorOutServerContextCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerContextCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerContextCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerContextCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerContextCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerMockRecorder 

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

ProcessorService_InspectProcessorOutServerMockRecorder is the mock recorder for ProcessorService_InspectProcessorOutServer.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) Context 

func (mr *ProcessorService_InspectProcessorOutServerMockRecorder) Context() *ProcessorService_InspectProcessorOutServerContextCall

Context indicates an expected call of Context.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) RecvMsg 

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

RecvMsg indicates an expected call of RecvMsg.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) Send 

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

Send indicates an expected call of Send.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) SendHeader 

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

SendHeader indicates an expected call of SendHeader.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) SendMsg 

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

SendMsg indicates an expected call of SendMsg.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) SetHeader 

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

SetHeader indicates an expected call of SetHeader.

func (*ProcessorService_InspectProcessorOutServerMockRecorder) SetTrailer 

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

SetTrailer indicates an expected call of SetTrailer.

type ProcessorService_InspectProcessorOutServerRecvMsgCall 

type ProcessorService_InspectProcessorOutServerRecvMsgCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerRecvMsgCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerRecvMsgCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerRecvMsgCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerRecvMsgCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSendCall 

type ProcessorService_InspectProcessorOutServerSendCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSendCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSendCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSendCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSendCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSendHeaderCall 

type ProcessorService_InspectProcessorOutServerSendHeaderCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSendHeaderCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSendHeaderCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSendHeaderCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSendHeaderCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSendMsgCall 

type ProcessorService_InspectProcessorOutServerSendMsgCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSendMsgCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSendMsgCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSendMsgCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSendMsgCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSetHeaderCall 

type ProcessorService_InspectProcessorOutServerSetHeaderCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSetHeaderCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSetHeaderCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSetHeaderCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSetHeaderCall) Return 

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

Return rewrite *gomock.Call.Return

type ProcessorService_InspectProcessorOutServerSetTrailerCall 

type ProcessorService_InspectProcessorOutServerSetTrailerCall struct {
	*gomock.Call
}

ProcessorService_InspectProcessorOutServerSetTrailerCall wrap *gomock.Call

func (*ProcessorService_InspectProcessorOutServerSetTrailerCall) Do 

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

Do rewrite *gomock.Call.Do

func (*ProcessorService_InspectProcessorOutServerSetTrailerCall) DoAndReturn 

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

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*ProcessorService_InspectProcessorOutServerSetTrailerCall) Return 

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.