Documentation ¶
Index ¶
- type MockGatewayClient
- func (_m *MockGatewayClient) ActivateJobs(_param0 context.Context, _param1 *pb.ActivateJobsRequest, ...) (pb.Gateway_ActivateJobsClient, error)
- func (_m *MockGatewayClient) CancelWorkflowInstance(_param0 context.Context, _param1 *pb.CancelWorkflowInstanceRequest, ...) (*pb.CancelWorkflowInstanceResponse, error)
- func (_m *MockGatewayClient) CompleteJob(_param0 context.Context, _param1 *pb.CompleteJobRequest, ...) (*pb.CompleteJobResponse, error)
- func (_m *MockGatewayClient) CreateWorkflowInstance(_param0 context.Context, _param1 *pb.CreateWorkflowInstanceRequest, ...) (*pb.CreateWorkflowInstanceResponse, error)
- func (_m *MockGatewayClient) DeployWorkflow(_param0 context.Context, _param1 *pb.DeployWorkflowRequest, ...) (*pb.DeployWorkflowResponse, error)
- func (_m *MockGatewayClient) EXPECT() *MockGatewayClientMockRecorder
- func (_m *MockGatewayClient) FailJob(_param0 context.Context, _param1 *pb.FailJobRequest, ...) (*pb.FailJobResponse, error)
- func (_m *MockGatewayClient) PublishMessage(_param0 context.Context, _param1 *pb.PublishMessageRequest, ...) (*pb.PublishMessageResponse, error)
- func (_m *MockGatewayClient) ResolveIncident(_param0 context.Context, _param1 *pb.ResolveIncidentRequest, ...) (*pb.ResolveIncidentResponse, error)
- func (_m *MockGatewayClient) SetVariables(_param0 context.Context, _param1 *pb.SetVariablesRequest, ...) (*pb.SetVariablesResponse, error)
- func (_m *MockGatewayClient) Topology(_param0 context.Context, _param1 *pb.TopologyRequest, ...) (*pb.TopologyResponse, error)
- func (_m *MockGatewayClient) UpdateJobRetries(_param0 context.Context, _param1 *pb.UpdateJobRetriesRequest, ...) (*pb.UpdateJobRetriesResponse, error)
- type MockGatewayClientMockRecorder
- func (_mr *MockGatewayClientMockRecorder) ActivateJobs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (_mr *MockGatewayClientMockRecorder) CancelWorkflowInstance(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (_mr *MockGatewayClientMockRecorder) CompleteJob(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (_mr *MockGatewayClientMockRecorder) CreateWorkflowInstance(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (_mr *MockGatewayClientMockRecorder) DeployWorkflow(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) 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(_param0 interface{}) error
- func (_m *MockGateway_ActivateJobsClient) SendMsg(_param0 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
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(_param0 context.Context, _param1 *pb.ActivateJobsRequest, _param2 ...grpc.CallOption) (pb.Gateway_ActivateJobsClient, error)
ActivateJobs mocks base method
func (*MockGatewayClient) CancelWorkflowInstance ¶
func (_m *MockGatewayClient) CancelWorkflowInstance(_param0 context.Context, _param1 *pb.CancelWorkflowInstanceRequest, _param2 ...grpc.CallOption) (*pb.CancelWorkflowInstanceResponse, error)
CancelWorkflowInstance mocks base method
func (*MockGatewayClient) CompleteJob ¶
func (_m *MockGatewayClient) CompleteJob(_param0 context.Context, _param1 *pb.CompleteJobRequest, _param2 ...grpc.CallOption) (*pb.CompleteJobResponse, error)
CompleteJob mocks base method
func (*MockGatewayClient) CreateWorkflowInstance ¶
func (_m *MockGatewayClient) CreateWorkflowInstance(_param0 context.Context, _param1 *pb.CreateWorkflowInstanceRequest, _param2 ...grpc.CallOption) (*pb.CreateWorkflowInstanceResponse, error)
CreateWorkflowInstance mocks base method
func (*MockGatewayClient) DeployWorkflow ¶
func (_m *MockGatewayClient) DeployWorkflow(_param0 context.Context, _param1 *pb.DeployWorkflowRequest, _param2 ...grpc.CallOption) (*pb.DeployWorkflowResponse, error)
DeployWorkflow 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(_param0 context.Context, _param1 *pb.FailJobRequest, _param2 ...grpc.CallOption) (*pb.FailJobResponse, error)
FailJob mocks base method
func (*MockGatewayClient) PublishMessage ¶
func (_m *MockGatewayClient) PublishMessage(_param0 context.Context, _param1 *pb.PublishMessageRequest, _param2 ...grpc.CallOption) (*pb.PublishMessageResponse, error)
PublishMessage mocks base method
func (*MockGatewayClient) ResolveIncident ¶
func (_m *MockGatewayClient) ResolveIncident(_param0 context.Context, _param1 *pb.ResolveIncidentRequest, _param2 ...grpc.CallOption) (*pb.ResolveIncidentResponse, error)
ResolveIncident mocks base method
func (*MockGatewayClient) SetVariables ¶
func (_m *MockGatewayClient) SetVariables(_param0 context.Context, _param1 *pb.SetVariablesRequest, _param2 ...grpc.CallOption) (*pb.SetVariablesResponse, error)
SetVariables mocks base method
func (*MockGatewayClient) Topology ¶
func (_m *MockGatewayClient) Topology(_param0 context.Context, _param1 *pb.TopologyRequest, _param2 ...grpc.CallOption) (*pb.TopologyResponse, error)
Topology mocks base method
func (*MockGatewayClient) UpdateJobRetries ¶
func (_m *MockGatewayClient) UpdateJobRetries(_param0 context.Context, _param1 *pb.UpdateJobRetriesRequest, _param2 ...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) CancelWorkflowInstance ¶
func (_mr *MockGatewayClientMockRecorder) CancelWorkflowInstance(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CancelWorkflowInstance indicates an expected call of CancelWorkflowInstance
func (*MockGatewayClientMockRecorder) CompleteJob ¶
func (_mr *MockGatewayClientMockRecorder) CompleteJob(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CompleteJob indicates an expected call of CompleteJob
func (*MockGatewayClientMockRecorder) CreateWorkflowInstance ¶
func (_mr *MockGatewayClientMockRecorder) CreateWorkflowInstance(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
CreateWorkflowInstance indicates an expected call of CreateWorkflowInstance
func (*MockGatewayClientMockRecorder) DeployWorkflow ¶
func (_mr *MockGatewayClientMockRecorder) DeployWorkflow(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeployWorkflow indicates an expected call of DeployWorkflow
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) 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(_param0 interface{}) error
RecvMsg mocks base method
func (*MockGateway_ActivateJobsClient) SendMsg ¶
func (_m *MockGateway_ActivateJobsClient) SendMsg(_param0 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