mock_pb

package
v1.3.14 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2022 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) 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) DeployProcess 

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

DeployProcess 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) FailJob 

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

FailJob 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) 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.

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) 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) DeployProcess 

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

DeployProcess indicates an expected call of DeployProcess.

func (*MockGatewayClientMockRecorder) FailJob 

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

FailJob indicates an expected call of FailJob.

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) 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.

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) 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) DeployProcess 

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

DeployProcess 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) FailJob 

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

FailJob 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) 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.

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) 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) DeployProcess 

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

DeployProcess indicates an expected call of DeployProcess.

func (*MockGatewayServerMockRecorder) FailJob 

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

FailJob indicates an expected call of FailJob.

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) 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.

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 interface{}) error

RecvMsg mocks base method.

func (*MockGateway_ActivateJobsClient) SendMsg 

func (m_2 *MockGateway_ActivateJobsClient) SendMsg(m interface{}) 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 interface{}) 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 interface{}) 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 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

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.