Documentation ¶
Overview ¶
Package mock_pb is a generated GoMock package.
Package mock_pb is a generated GoMock package.
Index ¶
- type MockGatewayClient
- func (m *MockGatewayClient) ActivateJobs(arg0 context.Context, arg1 *pb.ActivateJobsRequest, arg2 ...grpc.CallOption) (pb.Gateway_ActivateJobsClient, error)
- func (m *MockGatewayClient) CancelProcessInstance(arg0 context.Context, arg1 *pb.CancelProcessInstanceRequest, ...) (*pb.CancelProcessInstanceResponse, error)
- func (m *MockGatewayClient) CompleteJob(arg0 context.Context, arg1 *pb.CompleteJobRequest, arg2 ...grpc.CallOption) (*pb.CompleteJobResponse, error)
- func (m *MockGatewayClient) CreateProcessInstance(arg0 context.Context, arg1 *pb.CreateProcessInstanceRequest, ...) (*pb.CreateProcessInstanceResponse, error)
- func (m *MockGatewayClient) CreateProcessInstanceWithResult(arg0 context.Context, arg1 *pb.CreateProcessInstanceWithResultRequest, ...) (*pb.CreateProcessInstanceWithResultResponse, error)
- func (m *MockGatewayClient) DeployProcess(arg0 context.Context, arg1 *pb.DeployProcessRequest, arg2 ...grpc.CallOption) (*pb.DeployProcessResponse, error)
- func (m *MockGatewayClient) EXPECT() *MockGatewayClientMockRecorder
- func (m *MockGatewayClient) FailJob(arg0 context.Context, arg1 *pb.FailJobRequest, arg2 ...grpc.CallOption) (*pb.FailJobResponse, error)
- func (m *MockGatewayClient) PublishMessage(arg0 context.Context, arg1 *pb.PublishMessageRequest, arg2 ...grpc.CallOption) (*pb.PublishMessageResponse, error)
- func (m *MockGatewayClient) ResolveIncident(arg0 context.Context, arg1 *pb.ResolveIncidentRequest, arg2 ...grpc.CallOption) (*pb.ResolveIncidentResponse, error)
- func (m *MockGatewayClient) SetVariables(arg0 context.Context, arg1 *pb.SetVariablesRequest, arg2 ...grpc.CallOption) (*pb.SetVariablesResponse, error)
- func (m *MockGatewayClient) ThrowError(arg0 context.Context, arg1 *pb.ThrowErrorRequest, arg2 ...grpc.CallOption) (*pb.ThrowErrorResponse, error)
- func (m *MockGatewayClient) Topology(arg0 context.Context, arg1 *pb.TopologyRequest, arg2 ...grpc.CallOption) (*pb.TopologyResponse, error)
- func (m *MockGatewayClient) UpdateJobRetries(arg0 context.Context, arg1 *pb.UpdateJobRetriesRequest, ...) (*pb.UpdateJobRetriesResponse, error)
- type MockGatewayClientMockRecorder
- func (mr *MockGatewayClientMockRecorder) ActivateJobs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) CancelProcessInstance(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) CompleteJob(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) CreateProcessInstance(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) CreateProcessInstanceWithResult(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) DeployProcess(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) FailJob(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) PublishMessage(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) ResolveIncident(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) SetVariables(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) ThrowError(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) Topology(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockGatewayClientMockRecorder) UpdateJobRetries(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockGateway_ActivateJobsClient
- func (m *MockGateway_ActivateJobsClient) CloseSend() error
- func (m *MockGateway_ActivateJobsClient) Context() context.Context
- func (m *MockGateway_ActivateJobsClient) EXPECT() *MockGateway_ActivateJobsClientMockRecorder
- func (m *MockGateway_ActivateJobsClient) Header() (metadata.MD, error)
- func (m *MockGateway_ActivateJobsClient) Recv() (*pb.ActivateJobsResponse, error)
- func (m *MockGateway_ActivateJobsClient) RecvMsg(arg0 interface{}) error
- func (m *MockGateway_ActivateJobsClient) SendMsg(arg0 interface{}) error
- func (m *MockGateway_ActivateJobsClient) Trailer() metadata.MD
- type MockGateway_ActivateJobsClientMockRecorder
- func (mr *MockGateway_ActivateJobsClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockGateway_ActivateJobsClientMockRecorder) Context() *gomock.Call
- func (mr *MockGateway_ActivateJobsClientMockRecorder) Header() *gomock.Call
- func (mr *MockGateway_ActivateJobsClientMockRecorder) Recv() *gomock.Call
- func (mr *MockGateway_ActivateJobsClientMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGateway_ActivateJobsClientMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockGateway_ActivateJobsClientMockRecorder) Trailer() *gomock.Call
- type MockJobWorkerMetrics
- type MockJobWorkerMetricsMockRecorder
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(arg0 context.Context, arg1 *pb.ActivateJobsRequest, arg2 ...grpc.CallOption) (pb.Gateway_ActivateJobsClient, error)
ActivateJobs mocks base method
func (*MockGatewayClient) CancelProcessInstance ¶
func (m *MockGatewayClient) CancelProcessInstance(arg0 context.Context, arg1 *pb.CancelProcessInstanceRequest, arg2 ...grpc.CallOption) (*pb.CancelProcessInstanceResponse, error)
CancelProcessInstance mocks base method
func (*MockGatewayClient) CompleteJob ¶
func (m *MockGatewayClient) CompleteJob(arg0 context.Context, arg1 *pb.CompleteJobRequest, arg2 ...grpc.CallOption) (*pb.CompleteJobResponse, error)
CompleteJob mocks base method
func (*MockGatewayClient) CreateProcessInstance ¶
func (m *MockGatewayClient) CreateProcessInstance(arg0 context.Context, arg1 *pb.CreateProcessInstanceRequest, arg2 ...grpc.CallOption) (*pb.CreateProcessInstanceResponse, error)
CreateProcessInstance mocks base method
func (*MockGatewayClient) CreateProcessInstanceWithResult ¶
func (m *MockGatewayClient) CreateProcessInstanceWithResult(arg0 context.Context, arg1 *pb.CreateProcessInstanceWithResultRequest, arg2 ...grpc.CallOption) (*pb.CreateProcessInstanceWithResultResponse, error)
CreateProcessInstanceWithResult mocks base method
func (*MockGatewayClient) DeployProcess ¶
func (m *MockGatewayClient) DeployProcess(arg0 context.Context, arg1 *pb.DeployProcessRequest, arg2 ...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(arg0 context.Context, arg1 *pb.FailJobRequest, arg2 ...grpc.CallOption) (*pb.FailJobResponse, error)
FailJob mocks base method
func (*MockGatewayClient) PublishMessage ¶
func (m *MockGatewayClient) PublishMessage(arg0 context.Context, arg1 *pb.PublishMessageRequest, arg2 ...grpc.CallOption) (*pb.PublishMessageResponse, error)
PublishMessage mocks base method
func (*MockGatewayClient) ResolveIncident ¶
func (m *MockGatewayClient) ResolveIncident(arg0 context.Context, arg1 *pb.ResolveIncidentRequest, arg2 ...grpc.CallOption) (*pb.ResolveIncidentResponse, error)
ResolveIncident mocks base method
func (*MockGatewayClient) SetVariables ¶
func (m *MockGatewayClient) SetVariables(arg0 context.Context, arg1 *pb.SetVariablesRequest, arg2 ...grpc.CallOption) (*pb.SetVariablesResponse, error)
SetVariables mocks base method
func (*MockGatewayClient) ThrowError ¶
func (m *MockGatewayClient) ThrowError(arg0 context.Context, arg1 *pb.ThrowErrorRequest, arg2 ...grpc.CallOption) (*pb.ThrowErrorResponse, error)
ThrowError mocks base method
func (*MockGatewayClient) Topology ¶
func (m *MockGatewayClient) Topology(arg0 context.Context, arg1 *pb.TopologyRequest, arg2 ...grpc.CallOption) (*pb.TopologyResponse, error)
Topology mocks base method
func (*MockGatewayClient) UpdateJobRetries ¶
func (m *MockGatewayClient) UpdateJobRetries(arg0 context.Context, arg1 *pb.UpdateJobRetriesRequest, arg2 ...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(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ActivateJobs indicates an expected call of ActivateJobs
func (*MockGatewayClientMockRecorder) CancelProcessInstance ¶
func (mr *MockGatewayClientMockRecorder) CancelProcessInstance(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CancelProcessInstance indicates an expected call of CancelProcessInstance
func (*MockGatewayClientMockRecorder) CompleteJob ¶
func (mr *MockGatewayClientMockRecorder) CompleteJob(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CompleteJob indicates an expected call of CompleteJob
func (*MockGatewayClientMockRecorder) CreateProcessInstance ¶
func (mr *MockGatewayClientMockRecorder) CreateProcessInstance(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateProcessInstance indicates an expected call of CreateProcessInstance
func (*MockGatewayClientMockRecorder) CreateProcessInstanceWithResult ¶
func (mr *MockGatewayClientMockRecorder) CreateProcessInstanceWithResult(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateProcessInstanceWithResult indicates an expected call of CreateProcessInstanceWithResult
func (*MockGatewayClientMockRecorder) DeployProcess ¶
func (mr *MockGatewayClientMockRecorder) DeployProcess(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeployProcess indicates an expected call of DeployProcess
func (*MockGatewayClientMockRecorder) FailJob ¶
func (mr *MockGatewayClientMockRecorder) FailJob(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
FailJob indicates an expected call of FailJob
func (*MockGatewayClientMockRecorder) PublishMessage ¶
func (mr *MockGatewayClientMockRecorder) PublishMessage(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
PublishMessage indicates an expected call of PublishMessage
func (*MockGatewayClientMockRecorder) ResolveIncident ¶
func (mr *MockGatewayClientMockRecorder) ResolveIncident(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ResolveIncident indicates an expected call of ResolveIncident
func (*MockGatewayClientMockRecorder) SetVariables ¶
func (mr *MockGatewayClientMockRecorder) SetVariables(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
SetVariables indicates an expected call of SetVariables
func (*MockGatewayClientMockRecorder) ThrowError ¶
func (mr *MockGatewayClientMockRecorder) ThrowError(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
ThrowError indicates an expected call of ThrowError
func (*MockGatewayClientMockRecorder) Topology ¶
func (mr *MockGatewayClientMockRecorder) Topology(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Topology indicates an expected call of Topology
func (*MockGatewayClientMockRecorder) UpdateJobRetries ¶
func (mr *MockGatewayClientMockRecorder) UpdateJobRetries(arg0, arg1 interface{}, arg2 ...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 *MockGateway_ActivateJobsClient) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method
func (*MockGateway_ActivateJobsClient) SendMsg ¶
func (m *MockGateway_ActivateJobsClient) SendMsg(arg0 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(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg
func (*MockGateway_ActivateJobsClientMockRecorder) SendMsg ¶
func (mr *MockGateway_ActivateJobsClientMockRecorder) SendMsg(arg0 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 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