mock_pb

package
v8.5.10 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package mock_pb is a generated GoMock package.

Package mock_pb is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockGatewayClient 

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

MockGatewayClient is a mock of GatewayClient interface.

func NewMockGatewayClient 

func NewMockGatewayClient(ctrl *gomock.Controller) *MockGatewayClient

NewMockGatewayClient creates a new mock instance.

func (*MockGatewayClient) ActivateJobs 

func (m *MockGatewayClient) ActivateJobs(ctx context.Context, in *pb.ActivateJobsRequest, opts ...grpc.CallOption) (pb.Gateway_ActivateJobsClient, error)

ActivateJobs mocks base method.

func (*MockGatewayClient) BroadcastSignal added in v8.2.0 

func (m *MockGatewayClient) BroadcastSignal(ctx context.Context, in *pb.BroadcastSignalRequest, opts ...grpc.CallOption) (*pb.BroadcastSignalResponse, error)

BroadcastSignal mocks base method.

func (*MockGatewayClient) CancelProcessInstance 

func (m *MockGatewayClient) CancelProcessInstance(ctx context.Context, in *pb.CancelProcessInstanceRequest, opts ...grpc.CallOption) (*pb.CancelProcessInstanceResponse, error)

CancelProcessInstance mocks base method.

func (*MockGatewayClient) CompleteJob 

func (m *MockGatewayClient) CompleteJob(ctx context.Context, in *pb.CompleteJobRequest, opts ...grpc.CallOption) (*pb.CompleteJobResponse, error)

CompleteJob mocks base method.

func (*MockGatewayClient) CreateProcessInstance 

func (m *MockGatewayClient) CreateProcessInstance(ctx context.Context, in *pb.CreateProcessInstanceRequest, opts ...grpc.CallOption) (*pb.CreateProcessInstanceResponse, error)

CreateProcessInstance mocks base method.

func (*MockGatewayClient) CreateProcessInstanceWithResult 

func (m *MockGatewayClient) CreateProcessInstanceWithResult(ctx context.Context, in *pb.CreateProcessInstanceWithResultRequest, opts ...grpc.CallOption) (*pb.CreateProcessInstanceWithResultResponse, error)

CreateProcessInstanceWithResult mocks base method.

func (*MockGatewayClient) DeleteResource added in v8.2.0 

func (m *MockGatewayClient) DeleteResource(ctx context.Context, in *pb.DeleteResourceRequest, opts ...grpc.CallOption) (*pb.DeleteResourceResponse, error)

DeleteResource mocks base method.

func (*MockGatewayClient) DeployProcess 

func (m *MockGatewayClient) DeployProcess(ctx context.Context, in *pb.DeployProcessRequest, opts ...grpc.CallOption) (*pb.DeployProcessResponse, error)

DeployProcess mocks base method.

func (*MockGatewayClient) DeployResource 

func (m *MockGatewayClient) DeployResource(ctx context.Context, in *pb.DeployResourceRequest, opts ...grpc.CallOption) (*pb.DeployResourceResponse, error)

DeployResource mocks base method.

func (*MockGatewayClient) EXPECT 

func (m *MockGatewayClient) EXPECT() *MockGatewayClientMockRecorder

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

func (*MockGatewayClient) EvaluateDecision added in v8.2.0 

func (m *MockGatewayClient) EvaluateDecision(ctx context.Context, in *pb.EvaluateDecisionRequest, opts ...grpc.CallOption) (*pb.EvaluateDecisionResponse, error)

EvaluateDecision mocks base method.

func (*MockGatewayClient) FailJob 

func (m *MockGatewayClient) FailJob(ctx context.Context, in *pb.FailJobRequest, opts ...grpc.CallOption) (*pb.FailJobResponse, error)

FailJob mocks base method.

func (*MockGatewayClient) MigrateProcessInstance added in v8.4.0 

func (m *MockGatewayClient) MigrateProcessInstance(ctx context.Context, in *pb.MigrateProcessInstanceRequest, opts ...grpc.CallOption) (*pb.MigrateProcessInstanceResponse, error)

MigrateProcessInstance mocks base method.

func (*MockGatewayClient) ModifyProcessInstance added in v8.2.0 

func (m *MockGatewayClient) ModifyProcessInstance(ctx context.Context, in *pb.ModifyProcessInstanceRequest, opts ...grpc.CallOption) (*pb.ModifyProcessInstanceResponse, error)

ModifyProcessInstance mocks base method.

func (*MockGatewayClient) PublishMessage 

func (m *MockGatewayClient) PublishMessage(ctx context.Context, in *pb.PublishMessageRequest, opts ...grpc.CallOption) (*pb.PublishMessageResponse, error)

PublishMessage mocks base method.

func (*MockGatewayClient) ResolveIncident 

func (m *MockGatewayClient) ResolveIncident(ctx context.Context, in *pb.ResolveIncidentRequest, opts ...grpc.CallOption) (*pb.ResolveIncidentResponse, error)

ResolveIncident mocks base method.

func (*MockGatewayClient) SetVariables 

func (m *MockGatewayClient) SetVariables(ctx context.Context, in *pb.SetVariablesRequest, opts ...grpc.CallOption) (*pb.SetVariablesResponse, error)

SetVariables mocks base method.

func (*MockGatewayClient) StreamActivatedJobs added in v8.4.0 

func (m *MockGatewayClient) StreamActivatedJobs(ctx context.Context, in *pb.StreamActivatedJobsRequest, opts ...grpc.CallOption) (pb.Gateway_StreamActivatedJobsClient, error)

StreamActivatedJobs mocks base method.

func (*MockGatewayClient) ThrowError 

func (m *MockGatewayClient) ThrowError(ctx context.Context, in *pb.ThrowErrorRequest, opts ...grpc.CallOption) (*pb.ThrowErrorResponse, error)

ThrowError mocks base method.

func (*MockGatewayClient) Topology 

func (m *MockGatewayClient) Topology(ctx context.Context, in *pb.TopologyRequest, opts ...grpc.CallOption) (*pb.TopologyResponse, error)

Topology mocks base method.

func (*MockGatewayClient) UpdateJobRetries 

func (m *MockGatewayClient) UpdateJobRetries(ctx context.Context, in *pb.UpdateJobRetriesRequest, opts ...grpc.CallOption) (*pb.UpdateJobRetriesResponse, error)

UpdateJobRetries mocks base method.

func (*MockGatewayClient) UpdateJobTimeout added in v8.4.0 

func (m *MockGatewayClient) UpdateJobTimeout(ctx context.Context, in *pb.UpdateJobTimeoutRequest, opts ...grpc.CallOption) (*pb.UpdateJobTimeoutResponse, error)

UpdateJobTimeout mocks base method.

type MockGatewayClientMockRecorder 

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

MockGatewayClientMockRecorder is the mock recorder for MockGatewayClient.

func (*MockGatewayClientMockRecorder) ActivateJobs 

func (mr *MockGatewayClientMockRecorder) ActivateJobs(ctx, in interface{}, opts ...interface{}) *gomock.Call

ActivateJobs indicates an expected call of ActivateJobs.

func (*MockGatewayClientMockRecorder) BroadcastSignal added in v8.2.0 

func (mr *MockGatewayClientMockRecorder) BroadcastSignal(ctx, in interface{}, opts ...interface{}) *gomock.Call

BroadcastSignal indicates an expected call of BroadcastSignal.

func (*MockGatewayClientMockRecorder) CancelProcessInstance 

func (mr *MockGatewayClientMockRecorder) CancelProcessInstance(ctx, in interface{}, opts ...interface{}) *gomock.Call

CancelProcessInstance indicates an expected call of CancelProcessInstance.

func (*MockGatewayClientMockRecorder) CompleteJob 

func (mr *MockGatewayClientMockRecorder) CompleteJob(ctx, in interface{}, opts ...interface{}) *gomock.Call

CompleteJob indicates an expected call of CompleteJob.

func (*MockGatewayClientMockRecorder) CreateProcessInstance 

func (mr *MockGatewayClientMockRecorder) CreateProcessInstance(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateProcessInstance indicates an expected call of CreateProcessInstance.

func (*MockGatewayClientMockRecorder) CreateProcessInstanceWithResult 

func (mr *MockGatewayClientMockRecorder) CreateProcessInstanceWithResult(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateProcessInstanceWithResult indicates an expected call of CreateProcessInstanceWithResult.

func (*MockGatewayClientMockRecorder) DeleteResource added in v8.2.0 

func (mr *MockGatewayClientMockRecorder) DeleteResource(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteResource indicates an expected call of DeleteResource.

func (*MockGatewayClientMockRecorder) DeployProcess 

func (mr *MockGatewayClientMockRecorder) DeployProcess(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeployProcess indicates an expected call of DeployProcess.

func (*MockGatewayClientMockRecorder) DeployResource 

func (mr *MockGatewayClientMockRecorder) DeployResource(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeployResource indicates an expected call of DeployResource.

func (*MockGatewayClientMockRecorder) EvaluateDecision added in v8.2.0 

func (mr *MockGatewayClientMockRecorder) EvaluateDecision(ctx, in interface{}, opts ...interface{}) *gomock.Call

EvaluateDecision indicates an expected call of EvaluateDecision.

func (*MockGatewayClientMockRecorder) FailJob 

func (mr *MockGatewayClientMockRecorder) FailJob(ctx, in interface{}, opts ...interface{}) *gomock.Call

FailJob indicates an expected call of FailJob.

func (*MockGatewayClientMockRecorder) MigrateProcessInstance added in v8.4.0 

func (mr *MockGatewayClientMockRecorder) MigrateProcessInstance(ctx, in interface{}, opts ...interface{}) *gomock.Call

MigrateProcessInstance indicates an expected call of MigrateProcessInstance.

func (*MockGatewayClientMockRecorder) ModifyProcessInstance added in v8.2.0 

func (mr *MockGatewayClientMockRecorder) ModifyProcessInstance(ctx, in interface{}, opts ...interface{}) *gomock.Call

ModifyProcessInstance indicates an expected call of ModifyProcessInstance.

func (*MockGatewayClientMockRecorder) PublishMessage 

func (mr *MockGatewayClientMockRecorder) PublishMessage(ctx, in interface{}, opts ...interface{}) *gomock.Call

PublishMessage indicates an expected call of PublishMessage.

func (*MockGatewayClientMockRecorder) ResolveIncident 

func (mr *MockGatewayClientMockRecorder) ResolveIncident(ctx, in interface{}, opts ...interface{}) *gomock.Call

ResolveIncident indicates an expected call of ResolveIncident.

func (*MockGatewayClientMockRecorder) SetVariables 

func (mr *MockGatewayClientMockRecorder) SetVariables(ctx, in interface{}, opts ...interface{}) *gomock.Call

SetVariables indicates an expected call of SetVariables.

func (*MockGatewayClientMockRecorder) StreamActivatedJobs added in v8.4.0 

func (mr *MockGatewayClientMockRecorder) StreamActivatedJobs(ctx, in interface{}, opts ...interface{}) *gomock.Call

StreamActivatedJobs indicates an expected call of StreamActivatedJobs.

func (*MockGatewayClientMockRecorder) ThrowError 

func (mr *MockGatewayClientMockRecorder) ThrowError(ctx, in interface{}, opts ...interface{}) *gomock.Call

ThrowError indicates an expected call of ThrowError.

func (*MockGatewayClientMockRecorder) Topology 

func (mr *MockGatewayClientMockRecorder) Topology(ctx, in interface{}, opts ...interface{}) *gomock.Call

Topology indicates an expected call of Topology.

func (*MockGatewayClientMockRecorder) UpdateJobRetries 

func (mr *MockGatewayClientMockRecorder) UpdateJobRetries(ctx, in interface{}, opts ...interface{}) *gomock.Call

UpdateJobRetries indicates an expected call of UpdateJobRetries.

func (*MockGatewayClientMockRecorder) UpdateJobTimeout added in v8.4.0 

func (mr *MockGatewayClientMockRecorder) UpdateJobTimeout(ctx, in interface{}, opts ...interface{}) *gomock.Call

UpdateJobTimeout indicates an expected call of UpdateJobTimeout.

type MockGatewayServer 

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

MockGatewayServer is a mock of GatewayServer interface.

func NewMockGatewayServer 

func NewMockGatewayServer(ctrl *gomock.Controller) *MockGatewayServer

NewMockGatewayServer creates a new mock instance.

func (*MockGatewayServer) ActivateJobs 

func (m *MockGatewayServer) ActivateJobs(arg0 *pb.ActivateJobsRequest, arg1 pb.Gateway_ActivateJobsServer) error

ActivateJobs mocks base method.

func (*MockGatewayServer) BroadcastSignal added in v8.2.0 

func (m *MockGatewayServer) BroadcastSignal(arg0 context.Context, arg1 *pb.BroadcastSignalRequest) (*pb.BroadcastSignalResponse, error)

BroadcastSignal mocks base method.

func (*MockGatewayServer) CancelProcessInstance 

func (m *MockGatewayServer) CancelProcessInstance(arg0 context.Context, arg1 *pb.CancelProcessInstanceRequest) (*pb.CancelProcessInstanceResponse, error)

CancelProcessInstance mocks base method.

func (*MockGatewayServer) CompleteJob 

func (m *MockGatewayServer) CompleteJob(arg0 context.Context, arg1 *pb.CompleteJobRequest) (*pb.CompleteJobResponse, error)

CompleteJob mocks base method.

func (*MockGatewayServer) CreateProcessInstance 

func (m *MockGatewayServer) CreateProcessInstance(arg0 context.Context, arg1 *pb.CreateProcessInstanceRequest) (*pb.CreateProcessInstanceResponse, error)

CreateProcessInstance mocks base method.

func (*MockGatewayServer) CreateProcessInstanceWithResult 

func (m *MockGatewayServer) CreateProcessInstanceWithResult(arg0 context.Context, arg1 *pb.CreateProcessInstanceWithResultRequest) (*pb.CreateProcessInstanceWithResultResponse, error)

CreateProcessInstanceWithResult mocks base method.

func (*MockGatewayServer) DeleteResource added in v8.2.0 

func (m *MockGatewayServer) DeleteResource(arg0 context.Context, arg1 *pb.DeleteResourceRequest) (*pb.DeleteResourceResponse, error)

DeleteResource mocks base method.

func (*MockGatewayServer) DeployProcess 

func (m *MockGatewayServer) DeployProcess(arg0 context.Context, arg1 *pb.DeployProcessRequest) (*pb.DeployProcessResponse, error)

DeployProcess mocks base method.

func (*MockGatewayServer) DeployResource 

func (m *MockGatewayServer) DeployResource(arg0 context.Context, arg1 *pb.DeployResourceRequest) (*pb.DeployResourceResponse, error)

DeployResource mocks base method.

func (*MockGatewayServer) EXPECT 

func (m *MockGatewayServer) EXPECT() *MockGatewayServerMockRecorder

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

func (*MockGatewayServer) EvaluateDecision added in v8.2.0 

func (m *MockGatewayServer) EvaluateDecision(arg0 context.Context, arg1 *pb.EvaluateDecisionRequest) (*pb.EvaluateDecisionResponse, error)

EvaluateDecision mocks base method.

func (*MockGatewayServer) FailJob 

func (m *MockGatewayServer) FailJob(arg0 context.Context, arg1 *pb.FailJobRequest) (*pb.FailJobResponse, error)

FailJob mocks base method.

func (*MockGatewayServer) MigrateProcessInstance added in v8.4.0 

func (m *MockGatewayServer) MigrateProcessInstance(arg0 context.Context, arg1 *pb.MigrateProcessInstanceRequest) (*pb.MigrateProcessInstanceResponse, error)

MigrateProcessInstance mocks base method.

func (*MockGatewayServer) ModifyProcessInstance added in v8.2.0 

func (m *MockGatewayServer) ModifyProcessInstance(arg0 context.Context, arg1 *pb.ModifyProcessInstanceRequest) (*pb.ModifyProcessInstanceResponse, error)

ModifyProcessInstance mocks base method.

func (*MockGatewayServer) PublishMessage 

func (m *MockGatewayServer) PublishMessage(arg0 context.Context, arg1 *pb.PublishMessageRequest) (*pb.PublishMessageResponse, error)

PublishMessage mocks base method.

func (*MockGatewayServer) ResolveIncident 

func (m *MockGatewayServer) ResolveIncident(arg0 context.Context, arg1 *pb.ResolveIncidentRequest) (*pb.ResolveIncidentResponse, error)

ResolveIncident mocks base method.

func (*MockGatewayServer) SetVariables 

func (m *MockGatewayServer) SetVariables(arg0 context.Context, arg1 *pb.SetVariablesRequest) (*pb.SetVariablesResponse, error)

SetVariables mocks base method.

func (*MockGatewayServer) StreamActivatedJobs added in v8.4.0 

func (m *MockGatewayServer) StreamActivatedJobs(arg0 *pb.StreamActivatedJobsRequest, arg1 pb.Gateway_StreamActivatedJobsServer) error

StreamActivatedJobs mocks base method.

func (*MockGatewayServer) ThrowError 

func (m *MockGatewayServer) ThrowError(arg0 context.Context, arg1 *pb.ThrowErrorRequest) (*pb.ThrowErrorResponse, error)

ThrowError mocks base method.

func (*MockGatewayServer) Topology 

func (m *MockGatewayServer) Topology(arg0 context.Context, arg1 *pb.TopologyRequest) (*pb.TopologyResponse, error)

Topology mocks base method.

func (*MockGatewayServer) UpdateJobRetries 

func (m *MockGatewayServer) UpdateJobRetries(arg0 context.Context, arg1 *pb.UpdateJobRetriesRequest) (*pb.UpdateJobRetriesResponse, error)

UpdateJobRetries mocks base method.

func (*MockGatewayServer) UpdateJobTimeout added in v8.4.0 

func (m *MockGatewayServer) UpdateJobTimeout(arg0 context.Context, arg1 *pb.UpdateJobTimeoutRequest) (*pb.UpdateJobTimeoutResponse, error)

UpdateJobTimeout mocks base method.

type MockGatewayServerMockRecorder 

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

MockGatewayServerMockRecorder is the mock recorder for MockGatewayServer.

func (*MockGatewayServerMockRecorder) ActivateJobs 

func (mr *MockGatewayServerMockRecorder) ActivateJobs(arg0, arg1 interface{}) *gomock.Call

ActivateJobs indicates an expected call of ActivateJobs.

func (*MockGatewayServerMockRecorder) BroadcastSignal added in v8.2.0 

func (mr *MockGatewayServerMockRecorder) BroadcastSignal(arg0, arg1 interface{}) *gomock.Call

BroadcastSignal indicates an expected call of BroadcastSignal.

func (*MockGatewayServerMockRecorder) CancelProcessInstance 

func (mr *MockGatewayServerMockRecorder) CancelProcessInstance(arg0, arg1 interface{}) *gomock.Call

CancelProcessInstance indicates an expected call of CancelProcessInstance.

func (*MockGatewayServerMockRecorder) CompleteJob 

func (mr *MockGatewayServerMockRecorder) CompleteJob(arg0, arg1 interface{}) *gomock.Call

CompleteJob indicates an expected call of CompleteJob.

func (*MockGatewayServerMockRecorder) CreateProcessInstance 

func (mr *MockGatewayServerMockRecorder) CreateProcessInstance(arg0, arg1 interface{}) *gomock.Call

CreateProcessInstance indicates an expected call of CreateProcessInstance.

func (*MockGatewayServerMockRecorder) CreateProcessInstanceWithResult 

func (mr *MockGatewayServerMockRecorder) CreateProcessInstanceWithResult(arg0, arg1 interface{}) *gomock.Call

CreateProcessInstanceWithResult indicates an expected call of CreateProcessInstanceWithResult.

func (*MockGatewayServerMockRecorder) DeleteResource added in v8.2.0 

func (mr *MockGatewayServerMockRecorder) DeleteResource(arg0, arg1 interface{}) *gomock.Call

DeleteResource indicates an expected call of DeleteResource.

func (*MockGatewayServerMockRecorder) DeployProcess 

func (mr *MockGatewayServerMockRecorder) DeployProcess(arg0, arg1 interface{}) *gomock.Call

DeployProcess indicates an expected call of DeployProcess.

func (*MockGatewayServerMockRecorder) DeployResource 

func (mr *MockGatewayServerMockRecorder) DeployResource(arg0, arg1 interface{}) *gomock.Call

DeployResource indicates an expected call of DeployResource.

func (*MockGatewayServerMockRecorder) EvaluateDecision added in v8.2.0 

func (mr *MockGatewayServerMockRecorder) EvaluateDecision(arg0, arg1 interface{}) *gomock.Call

EvaluateDecision indicates an expected call of EvaluateDecision.

func (*MockGatewayServerMockRecorder) FailJob 

func (mr *MockGatewayServerMockRecorder) FailJob(arg0, arg1 interface{}) *gomock.Call

FailJob indicates an expected call of FailJob.

func (*MockGatewayServerMockRecorder) MigrateProcessInstance added in v8.4.0 

func (mr *MockGatewayServerMockRecorder) MigrateProcessInstance(arg0, arg1 interface{}) *gomock.Call

MigrateProcessInstance indicates an expected call of MigrateProcessInstance.

func (*MockGatewayServerMockRecorder) ModifyProcessInstance added in v8.2.0 

func (mr *MockGatewayServerMockRecorder) ModifyProcessInstance(arg0, arg1 interface{}) *gomock.Call

ModifyProcessInstance indicates an expected call of ModifyProcessInstance.

func (*MockGatewayServerMockRecorder) PublishMessage 

func (mr *MockGatewayServerMockRecorder) PublishMessage(arg0, arg1 interface{}) *gomock.Call

PublishMessage indicates an expected call of PublishMessage.

func (*MockGatewayServerMockRecorder) ResolveIncident 

func (mr *MockGatewayServerMockRecorder) ResolveIncident(arg0, arg1 interface{}) *gomock.Call

ResolveIncident indicates an expected call of ResolveIncident.

func (*MockGatewayServerMockRecorder) SetVariables 

func (mr *MockGatewayServerMockRecorder) SetVariables(arg0, arg1 interface{}) *gomock.Call

SetVariables indicates an expected call of SetVariables.

func (*MockGatewayServerMockRecorder) StreamActivatedJobs added in v8.4.0 

func (mr *MockGatewayServerMockRecorder) StreamActivatedJobs(arg0, arg1 interface{}) *gomock.Call

StreamActivatedJobs indicates an expected call of StreamActivatedJobs.

func (*MockGatewayServerMockRecorder) ThrowError 

func (mr *MockGatewayServerMockRecorder) ThrowError(arg0, arg1 interface{}) *gomock.Call

ThrowError indicates an expected call of ThrowError.

func (*MockGatewayServerMockRecorder) Topology 

func (mr *MockGatewayServerMockRecorder) Topology(arg0, arg1 interface{}) *gomock.Call

Topology indicates an expected call of Topology.

func (*MockGatewayServerMockRecorder) UpdateJobRetries 

func (mr *MockGatewayServerMockRecorder) UpdateJobRetries(arg0, arg1 interface{}) *gomock.Call

UpdateJobRetries indicates an expected call of UpdateJobRetries.

func (*MockGatewayServerMockRecorder) UpdateJobTimeout added in v8.4.0 

func (mr *MockGatewayServerMockRecorder) UpdateJobTimeout(arg0, arg1 interface{}) *gomock.Call

UpdateJobTimeout indicates an expected call of UpdateJobTimeout.

type MockGateway_ActivateJobsClient 

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

MockGateway_ActivateJobsClient is a mock of Gateway_ActivateJobsClient interface.

func NewMockGateway_ActivateJobsClient 

func NewMockGateway_ActivateJobsClient(ctrl *gomock.Controller) *MockGateway_ActivateJobsClient

NewMockGateway_ActivateJobsClient creates a new mock instance.

func (*MockGateway_ActivateJobsClient) CloseSend 

func (m *MockGateway_ActivateJobsClient) CloseSend() error

CloseSend mocks base method.

func (*MockGateway_ActivateJobsClient) Context 

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

Context mocks base method.

func (*MockGateway_ActivateJobsClient) EXPECT 

func (m *MockGateway_ActivateJobsClient) EXPECT() *MockGateway_ActivateJobsClientMockRecorder

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

func (*MockGateway_ActivateJobsClient) Header 

func (m *MockGateway_ActivateJobsClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockGateway_ActivateJobsClient) Recv 

func (m *MockGateway_ActivateJobsClient) Recv() (*pb.ActivateJobsResponse, error)

Recv mocks base method.

func (*MockGateway_ActivateJobsClient) RecvMsg 

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

RecvMsg mocks base method.

func (*MockGateway_ActivateJobsClient) SendMsg 

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

SendMsg mocks base method.

func (*MockGateway_ActivateJobsClient) Trailer 

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

Trailer mocks base method.

type MockGateway_ActivateJobsClientMockRecorder 

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

MockGateway_ActivateJobsClientMockRecorder is the mock recorder for MockGateway_ActivateJobsClient.

func (*MockGateway_ActivateJobsClientMockRecorder) CloseSend 

func (mr *MockGateway_ActivateJobsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockGateway_ActivateJobsClientMockRecorder) Context 

func (mr *MockGateway_ActivateJobsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockGateway_ActivateJobsClientMockRecorder) Header 

func (mr *MockGateway_ActivateJobsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockGateway_ActivateJobsClientMockRecorder) Recv 

func (mr *MockGateway_ActivateJobsClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockGateway_ActivateJobsClientMockRecorder) RecvMsg 

func (mr *MockGateway_ActivateJobsClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockGateway_ActivateJobsClientMockRecorder) SendMsg 

func (mr *MockGateway_ActivateJobsClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockGateway_ActivateJobsClientMockRecorder) Trailer 

func (mr *MockGateway_ActivateJobsClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockGateway_ActivateJobsServer 

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

MockGateway_ActivateJobsServer is a mock of Gateway_ActivateJobsServer interface.

func NewMockGateway_ActivateJobsServer 

func NewMockGateway_ActivateJobsServer(ctrl *gomock.Controller) *MockGateway_ActivateJobsServer

NewMockGateway_ActivateJobsServer creates a new mock instance.

func (*MockGateway_ActivateJobsServer) Context 

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

Context mocks base method.

func (*MockGateway_ActivateJobsServer) EXPECT 

func (m *MockGateway_ActivateJobsServer) EXPECT() *MockGateway_ActivateJobsServerMockRecorder

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

func (*MockGateway_ActivateJobsServer) RecvMsg 

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

RecvMsg mocks base method.

func (*MockGateway_ActivateJobsServer) Send 

func (m *MockGateway_ActivateJobsServer) Send(arg0 *pb.ActivateJobsResponse) error

Send mocks base method.

func (*MockGateway_ActivateJobsServer) SendHeader 

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

SendHeader mocks base method.

func (*MockGateway_ActivateJobsServer) SendMsg 

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

SendMsg mocks base method.

func (*MockGateway_ActivateJobsServer) SetHeader 

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

SetHeader mocks base method.

func (*MockGateway_ActivateJobsServer) SetTrailer 

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

SetTrailer mocks base method.

type MockGateway_ActivateJobsServerMockRecorder 

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

MockGateway_ActivateJobsServerMockRecorder is the mock recorder for MockGateway_ActivateJobsServer.

func (*MockGateway_ActivateJobsServerMockRecorder) Context 

func (mr *MockGateway_ActivateJobsServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockGateway_ActivateJobsServerMockRecorder) RecvMsg 

func (mr *MockGateway_ActivateJobsServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockGateway_ActivateJobsServerMockRecorder) Send 

func (mr *MockGateway_ActivateJobsServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockGateway_ActivateJobsServerMockRecorder) SendHeader 

func (mr *MockGateway_ActivateJobsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockGateway_ActivateJobsServerMockRecorder) SendMsg 

func (mr *MockGateway_ActivateJobsServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockGateway_ActivateJobsServerMockRecorder) SetHeader 

func (mr *MockGateway_ActivateJobsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockGateway_ActivateJobsServerMockRecorder) SetTrailer 

func (mr *MockGateway_ActivateJobsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockGateway_StreamActivatedJobsClient added in v8.4.0 

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

MockGateway_StreamActivatedJobsClient is a mock of Gateway_StreamActivatedJobsClient interface.

func NewMockGateway_StreamActivatedJobsClient added in v8.4.0 

func NewMockGateway_StreamActivatedJobsClient(ctrl *gomock.Controller) *MockGateway_StreamActivatedJobsClient

NewMockGateway_StreamActivatedJobsClient creates a new mock instance.

func (*MockGateway_StreamActivatedJobsClient) CloseSend added in v8.4.0 

func (m *MockGateway_StreamActivatedJobsClient) CloseSend() error

CloseSend mocks base method.

func (*MockGateway_StreamActivatedJobsClient) Context added in v8.4.0 

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

Context mocks base method.

func (*MockGateway_StreamActivatedJobsClient) EXPECT added in v8.4.0 

func (m *MockGateway_StreamActivatedJobsClient) EXPECT() *MockGateway_StreamActivatedJobsClientMockRecorder

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

func (*MockGateway_StreamActivatedJobsClient) Header added in v8.4.0 

func (m *MockGateway_StreamActivatedJobsClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockGateway_StreamActivatedJobsClient) Recv added in v8.4.0 

func (m *MockGateway_StreamActivatedJobsClient) Recv() (*pb.ActivatedJob, error)

Recv mocks base method.

func (*MockGateway_StreamActivatedJobsClient) RecvMsg added in v8.4.0 

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

RecvMsg mocks base method.

func (*MockGateway_StreamActivatedJobsClient) SendMsg added in v8.4.0 

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

SendMsg mocks base method.

func (*MockGateway_StreamActivatedJobsClient) Trailer added in v8.4.0 

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

Trailer mocks base method.

type MockGateway_StreamActivatedJobsClientMockRecorder added in v8.4.0 

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

MockGateway_StreamActivatedJobsClientMockRecorder is the mock recorder for MockGateway_StreamActivatedJobsClient.

func (*MockGateway_StreamActivatedJobsClientMockRecorder) CloseSend added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockGateway_StreamActivatedJobsClientMockRecorder) Context added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockGateway_StreamActivatedJobsClientMockRecorder) Header added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockGateway_StreamActivatedJobsClientMockRecorder) Recv added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockGateway_StreamActivatedJobsClientMockRecorder) RecvMsg added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockGateway_StreamActivatedJobsClientMockRecorder) SendMsg added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockGateway_StreamActivatedJobsClientMockRecorder) Trailer added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockGateway_StreamActivatedJobsServer added in v8.4.0 

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

MockGateway_StreamActivatedJobsServer is a mock of Gateway_StreamActivatedJobsServer interface.

func NewMockGateway_StreamActivatedJobsServer added in v8.4.0 

func NewMockGateway_StreamActivatedJobsServer(ctrl *gomock.Controller) *MockGateway_StreamActivatedJobsServer

NewMockGateway_StreamActivatedJobsServer creates a new mock instance.

func (*MockGateway_StreamActivatedJobsServer) Context added in v8.4.0 

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

Context mocks base method.

func (*MockGateway_StreamActivatedJobsServer) EXPECT added in v8.4.0 

func (m *MockGateway_StreamActivatedJobsServer) EXPECT() *MockGateway_StreamActivatedJobsServerMockRecorder

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

func (*MockGateway_StreamActivatedJobsServer) RecvMsg added in v8.4.0 

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

RecvMsg mocks base method.

func (*MockGateway_StreamActivatedJobsServer) Send added in v8.4.0 

func (m *MockGateway_StreamActivatedJobsServer) Send(arg0 *pb.ActivatedJob) error

Send mocks base method.

func (*MockGateway_StreamActivatedJobsServer) SendHeader added in v8.4.0 

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

SendHeader mocks base method.

func (*MockGateway_StreamActivatedJobsServer) SendMsg added in v8.4.0 

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

SendMsg mocks base method.

func (*MockGateway_StreamActivatedJobsServer) SetHeader added in v8.4.0 

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

SetHeader mocks base method.

func (*MockGateway_StreamActivatedJobsServer) SetTrailer added in v8.4.0 

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

SetTrailer mocks base method.

type MockGateway_StreamActivatedJobsServerMockRecorder added in v8.4.0 

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

MockGateway_StreamActivatedJobsServerMockRecorder is the mock recorder for MockGateway_StreamActivatedJobsServer.

func (*MockGateway_StreamActivatedJobsServerMockRecorder) Context added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockGateway_StreamActivatedJobsServerMockRecorder) RecvMsg added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockGateway_StreamActivatedJobsServerMockRecorder) Send added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockGateway_StreamActivatedJobsServerMockRecorder) SendHeader added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockGateway_StreamActivatedJobsServerMockRecorder) SendMsg added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockGateway_StreamActivatedJobsServerMockRecorder) SetHeader added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockGateway_StreamActivatedJobsServerMockRecorder) SetTrailer added in v8.4.0 

func (mr *MockGateway_StreamActivatedJobsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockJobWorkerMetrics 

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

MockJobWorkerMetrics is a mock of JobWorkerMetrics interface

func NewMockJobWorkerMetrics 

func NewMockJobWorkerMetrics(ctrl *gomock.Controller) *MockJobWorkerMetrics

NewMockJobWorkerMetrics creates a new mock instance

func (*MockJobWorkerMetrics) EXPECT 

func (m *MockJobWorkerMetrics) EXPECT() *MockJobWorkerMetricsMockRecorder

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

func (*MockJobWorkerMetrics) SetJobsRemainingCount 

func (m *MockJobWorkerMetrics) SetJobsRemainingCount(arg0 string, arg1 int)

SetJobsRemainingCount mocks base method

type MockJobWorkerMetricsMockRecorder 

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

MockJobWorkerMetricsMockRecorder is the mock recorder for MockJobWorkerMetrics

func (*MockJobWorkerMetricsMockRecorder) SetJobsRemainingCount 

func (mr *MockJobWorkerMetricsMockRecorder) SetJobsRemainingCount(arg0, arg1 interface{}) *gomock.Call

SetJobsRemainingCount indicates an expected call of SetJobsRemainingCount

type MockisDeployment_Metadata 

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

MockisDeployment_Metadata is a mock of isDeployment_Metadata interface.

func NewMockisDeployment_Metadata 

func NewMockisDeployment_Metadata(ctrl *gomock.Controller) *MockisDeployment_Metadata

NewMockisDeployment_Metadata creates a new mock instance.

func (*MockisDeployment_Metadata) EXPECT 

func (m *MockisDeployment_Metadata) EXPECT() *MockisDeployment_MetadataMockRecorder

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

type MockisDeployment_MetadataMockRecorder 

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

MockisDeployment_MetadataMockRecorder is the mock recorder for MockisDeployment_Metadata.

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.