diff --git a/docs/definitions.md b/docs/definitions.md index 077fcda5..5eaa0be5 100644 --- a/docs/definitions.md +++ b/docs/definitions.md @@ -186,6 +186,7 @@ |**Next**
*optional*|string| |**OutputPath**
*optional*|string| |**Resource**
*optional*|string| +|**Result**
*optional*|string| |**ResultPath**
*optional*|string| |**Retry**
*optional*|< [SLRetrier](#slretrier) > array| |**TimeoutSeconds**
*optional*|integer| diff --git a/docs/overview.md b/docs/overview.md index a63743bd..f59fbd17 100644 --- a/docs/overview.md +++ b/docs/overview.md @@ -7,7 +7,7 @@ Orchestrator for AWS Step Functions ### Version information -*Version* : 0.7.1 +*Version* : 0.7.2 ### URI scheme diff --git a/gen-go/client/mock_client.go b/gen-go/client/mock_client.go index c45b6d78..57302849 100644 --- a/gen-go/client/mock_client.go +++ b/gen-go/client/mock_client.go @@ -1,7 +1,6 @@ // Code generated by MockGen. DO NOT EDIT. // Source: interface.go -// Package client is a generated GoMock package. package client import ( @@ -30,225 +29,225 @@ func NewMockClient(ctrl *gomock.Controller) *MockClient { } // EXPECT returns an object that allows the caller to indicate expected use -func (m *MockClient) EXPECT() *MockClientMockRecorder { - return m.recorder +func (_m *MockClient) EXPECT() *MockClientMockRecorder { + return _m.recorder } // HealthCheck mocks base method -func (m *MockClient) HealthCheck(ctx context.Context) error { - ret := m.ctrl.Call(m, "HealthCheck", ctx) +func (_m *MockClient) HealthCheck(ctx context.Context) error { + ret := _m.ctrl.Call(_m, "HealthCheck", ctx) ret0, _ := ret[0].(error) return ret0 } // HealthCheck indicates an expected call of HealthCheck -func (mr *MockClientMockRecorder) HealthCheck(ctx interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "HealthCheck", reflect.TypeOf((*MockClient)(nil).HealthCheck), ctx) +func (_mr *MockClientMockRecorder) HealthCheck(arg0 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "HealthCheck", reflect.TypeOf((*MockClient)(nil).HealthCheck), arg0) } // PostStateResource mocks base method -func (m *MockClient) PostStateResource(ctx context.Context, i *models.NewStateResource) (*models.StateResource, error) { - ret := m.ctrl.Call(m, "PostStateResource", ctx, i) +func (_m *MockClient) PostStateResource(ctx context.Context, i *models.NewStateResource) (*models.StateResource, error) { + ret := _m.ctrl.Call(_m, "PostStateResource", ctx, i) ret0, _ := ret[0].(*models.StateResource) ret1, _ := ret[1].(error) return ret0, ret1 } // PostStateResource indicates an expected call of PostStateResource -func (mr *MockClientMockRecorder) PostStateResource(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PostStateResource", reflect.TypeOf((*MockClient)(nil).PostStateResource), ctx, i) +func (_mr *MockClientMockRecorder) PostStateResource(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "PostStateResource", reflect.TypeOf((*MockClient)(nil).PostStateResource), arg0, arg1) } // DeleteStateResource mocks base method -func (m *MockClient) DeleteStateResource(ctx context.Context, i *models.DeleteStateResourceInput) error { - ret := m.ctrl.Call(m, "DeleteStateResource", ctx, i) +func (_m *MockClient) DeleteStateResource(ctx context.Context, i *models.DeleteStateResourceInput) error { + ret := _m.ctrl.Call(_m, "DeleteStateResource", ctx, i) ret0, _ := ret[0].(error) return ret0 } // DeleteStateResource indicates an expected call of DeleteStateResource -func (mr *MockClientMockRecorder) DeleteStateResource(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteStateResource", reflect.TypeOf((*MockClient)(nil).DeleteStateResource), ctx, i) +func (_mr *MockClientMockRecorder) DeleteStateResource(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "DeleteStateResource", reflect.TypeOf((*MockClient)(nil).DeleteStateResource), arg0, arg1) } // GetStateResource mocks base method -func (m *MockClient) GetStateResource(ctx context.Context, i *models.GetStateResourceInput) (*models.StateResource, error) { - ret := m.ctrl.Call(m, "GetStateResource", ctx, i) +func (_m *MockClient) GetStateResource(ctx context.Context, i *models.GetStateResourceInput) (*models.StateResource, error) { + ret := _m.ctrl.Call(_m, "GetStateResource", ctx, i) ret0, _ := ret[0].(*models.StateResource) ret1, _ := ret[1].(error) return ret0, ret1 } // GetStateResource indicates an expected call of GetStateResource -func (mr *MockClientMockRecorder) GetStateResource(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetStateResource", reflect.TypeOf((*MockClient)(nil).GetStateResource), ctx, i) +func (_mr *MockClientMockRecorder) GetStateResource(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetStateResource", reflect.TypeOf((*MockClient)(nil).GetStateResource), arg0, arg1) } // PutStateResource mocks base method -func (m *MockClient) PutStateResource(ctx context.Context, i *models.PutStateResourceInput) (*models.StateResource, error) { - ret := m.ctrl.Call(m, "PutStateResource", ctx, i) +func (_m *MockClient) PutStateResource(ctx context.Context, i *models.PutStateResourceInput) (*models.StateResource, error) { + ret := _m.ctrl.Call(_m, "PutStateResource", ctx, i) ret0, _ := ret[0].(*models.StateResource) ret1, _ := ret[1].(error) return ret0, ret1 } // PutStateResource indicates an expected call of PutStateResource -func (mr *MockClientMockRecorder) PutStateResource(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PutStateResource", reflect.TypeOf((*MockClient)(nil).PutStateResource), ctx, i) +func (_mr *MockClientMockRecorder) PutStateResource(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "PutStateResource", reflect.TypeOf((*MockClient)(nil).PutStateResource), arg0, arg1) } // GetWorkflowDefinitions mocks base method -func (m *MockClient) GetWorkflowDefinitions(ctx context.Context) ([]models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "GetWorkflowDefinitions", ctx) +func (_m *MockClient) GetWorkflowDefinitions(ctx context.Context) ([]models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "GetWorkflowDefinitions", ctx) ret0, _ := ret[0].([]models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflowDefinitions indicates an expected call of GetWorkflowDefinitions -func (mr *MockClientMockRecorder) GetWorkflowDefinitions(ctx interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowDefinitions", reflect.TypeOf((*MockClient)(nil).GetWorkflowDefinitions), ctx) +func (_mr *MockClientMockRecorder) GetWorkflowDefinitions(arg0 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflowDefinitions", reflect.TypeOf((*MockClient)(nil).GetWorkflowDefinitions), arg0) } // NewWorkflowDefinition mocks base method -func (m *MockClient) NewWorkflowDefinition(ctx context.Context, i *models.NewWorkflowDefinitionRequest) (*models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "NewWorkflowDefinition", ctx, i) +func (_m *MockClient) NewWorkflowDefinition(ctx context.Context, i *models.NewWorkflowDefinitionRequest) (*models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "NewWorkflowDefinition", ctx, i) ret0, _ := ret[0].(*models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // NewWorkflowDefinition indicates an expected call of NewWorkflowDefinition -func (mr *MockClientMockRecorder) NewWorkflowDefinition(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "NewWorkflowDefinition", reflect.TypeOf((*MockClient)(nil).NewWorkflowDefinition), ctx, i) +func (_mr *MockClientMockRecorder) NewWorkflowDefinition(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "NewWorkflowDefinition", reflect.TypeOf((*MockClient)(nil).NewWorkflowDefinition), arg0, arg1) } // GetWorkflowDefinitionVersionsByName mocks base method -func (m *MockClient) GetWorkflowDefinitionVersionsByName(ctx context.Context, i *models.GetWorkflowDefinitionVersionsByNameInput) ([]models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "GetWorkflowDefinitionVersionsByName", ctx, i) +func (_m *MockClient) GetWorkflowDefinitionVersionsByName(ctx context.Context, i *models.GetWorkflowDefinitionVersionsByNameInput) ([]models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "GetWorkflowDefinitionVersionsByName", ctx, i) ret0, _ := ret[0].([]models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflowDefinitionVersionsByName indicates an expected call of GetWorkflowDefinitionVersionsByName -func (mr *MockClientMockRecorder) GetWorkflowDefinitionVersionsByName(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowDefinitionVersionsByName", reflect.TypeOf((*MockClient)(nil).GetWorkflowDefinitionVersionsByName), ctx, i) +func (_mr *MockClientMockRecorder) GetWorkflowDefinitionVersionsByName(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflowDefinitionVersionsByName", reflect.TypeOf((*MockClient)(nil).GetWorkflowDefinitionVersionsByName), arg0, arg1) } // UpdateWorkflowDefinition mocks base method -func (m *MockClient) UpdateWorkflowDefinition(ctx context.Context, i *models.UpdateWorkflowDefinitionInput) (*models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "UpdateWorkflowDefinition", ctx, i) +func (_m *MockClient) UpdateWorkflowDefinition(ctx context.Context, i *models.UpdateWorkflowDefinitionInput) (*models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "UpdateWorkflowDefinition", ctx, i) ret0, _ := ret[0].(*models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // UpdateWorkflowDefinition indicates an expected call of UpdateWorkflowDefinition -func (mr *MockClientMockRecorder) UpdateWorkflowDefinition(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkflowDefinition", reflect.TypeOf((*MockClient)(nil).UpdateWorkflowDefinition), ctx, i) +func (_mr *MockClientMockRecorder) UpdateWorkflowDefinition(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "UpdateWorkflowDefinition", reflect.TypeOf((*MockClient)(nil).UpdateWorkflowDefinition), arg0, arg1) } // GetWorkflowDefinitionByNameAndVersion mocks base method -func (m *MockClient) GetWorkflowDefinitionByNameAndVersion(ctx context.Context, i *models.GetWorkflowDefinitionByNameAndVersionInput) (*models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "GetWorkflowDefinitionByNameAndVersion", ctx, i) +func (_m *MockClient) GetWorkflowDefinitionByNameAndVersion(ctx context.Context, i *models.GetWorkflowDefinitionByNameAndVersionInput) (*models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "GetWorkflowDefinitionByNameAndVersion", ctx, i) ret0, _ := ret[0].(*models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflowDefinitionByNameAndVersion indicates an expected call of GetWorkflowDefinitionByNameAndVersion -func (mr *MockClientMockRecorder) GetWorkflowDefinitionByNameAndVersion(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowDefinitionByNameAndVersion", reflect.TypeOf((*MockClient)(nil).GetWorkflowDefinitionByNameAndVersion), ctx, i) +func (_mr *MockClientMockRecorder) GetWorkflowDefinitionByNameAndVersion(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflowDefinitionByNameAndVersion", reflect.TypeOf((*MockClient)(nil).GetWorkflowDefinitionByNameAndVersion), arg0, arg1) } // GetWorkflows mocks base method -func (m *MockClient) GetWorkflows(ctx context.Context, i *models.GetWorkflowsInput) ([]models.Workflow, error) { - ret := m.ctrl.Call(m, "GetWorkflows", ctx, i) +func (_m *MockClient) GetWorkflows(ctx context.Context, i *models.GetWorkflowsInput) ([]models.Workflow, error) { + ret := _m.ctrl.Call(_m, "GetWorkflows", ctx, i) ret0, _ := ret[0].([]models.Workflow) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflows indicates an expected call of GetWorkflows -func (mr *MockClientMockRecorder) GetWorkflows(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflows", reflect.TypeOf((*MockClient)(nil).GetWorkflows), ctx, i) +func (_mr *MockClientMockRecorder) GetWorkflows(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflows", reflect.TypeOf((*MockClient)(nil).GetWorkflows), arg0, arg1) } // NewGetWorkflowsIter mocks base method -func (m *MockClient) NewGetWorkflowsIter(ctx context.Context, i *models.GetWorkflowsInput) (GetWorkflowsIter, error) { - ret := m.ctrl.Call(m, "NewGetWorkflowsIter", ctx, i) +func (_m *MockClient) NewGetWorkflowsIter(ctx context.Context, i *models.GetWorkflowsInput) (GetWorkflowsIter, error) { + ret := _m.ctrl.Call(_m, "NewGetWorkflowsIter", ctx, i) ret0, _ := ret[0].(GetWorkflowsIter) ret1, _ := ret[1].(error) return ret0, ret1 } // NewGetWorkflowsIter indicates an expected call of NewGetWorkflowsIter -func (mr *MockClientMockRecorder) NewGetWorkflowsIter(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "NewGetWorkflowsIter", reflect.TypeOf((*MockClient)(nil).NewGetWorkflowsIter), ctx, i) +func (_mr *MockClientMockRecorder) NewGetWorkflowsIter(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "NewGetWorkflowsIter", reflect.TypeOf((*MockClient)(nil).NewGetWorkflowsIter), arg0, arg1) } // StartWorkflow mocks base method -func (m *MockClient) StartWorkflow(ctx context.Context, i *models.StartWorkflowRequest) (*models.Workflow, error) { - ret := m.ctrl.Call(m, "StartWorkflow", ctx, i) +func (_m *MockClient) StartWorkflow(ctx context.Context, i *models.StartWorkflowRequest) (*models.Workflow, error) { + ret := _m.ctrl.Call(_m, "StartWorkflow", ctx, i) ret0, _ := ret[0].(*models.Workflow) ret1, _ := ret[1].(error) return ret0, ret1 } // StartWorkflow indicates an expected call of StartWorkflow -func (mr *MockClientMockRecorder) StartWorkflow(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StartWorkflow", reflect.TypeOf((*MockClient)(nil).StartWorkflow), ctx, i) +func (_mr *MockClientMockRecorder) StartWorkflow(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "StartWorkflow", reflect.TypeOf((*MockClient)(nil).StartWorkflow), arg0, arg1) } // CancelWorkflow mocks base method -func (m *MockClient) CancelWorkflow(ctx context.Context, i *models.CancelWorkflowInput) error { - ret := m.ctrl.Call(m, "CancelWorkflow", ctx, i) +func (_m *MockClient) CancelWorkflow(ctx context.Context, i *models.CancelWorkflowInput) error { + ret := _m.ctrl.Call(_m, "CancelWorkflow", ctx, i) ret0, _ := ret[0].(error) return ret0 } // CancelWorkflow indicates an expected call of CancelWorkflow -func (mr *MockClientMockRecorder) CancelWorkflow(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CancelWorkflow", reflect.TypeOf((*MockClient)(nil).CancelWorkflow), ctx, i) +func (_mr *MockClientMockRecorder) CancelWorkflow(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "CancelWorkflow", reflect.TypeOf((*MockClient)(nil).CancelWorkflow), arg0, arg1) } // GetWorkflowByID mocks base method -func (m *MockClient) GetWorkflowByID(ctx context.Context, workflowID string) (*models.Workflow, error) { - ret := m.ctrl.Call(m, "GetWorkflowByID", ctx, workflowID) +func (_m *MockClient) GetWorkflowByID(ctx context.Context, workflowID string) (*models.Workflow, error) { + ret := _m.ctrl.Call(_m, "GetWorkflowByID", ctx, workflowID) ret0, _ := ret[0].(*models.Workflow) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflowByID indicates an expected call of GetWorkflowByID -func (mr *MockClientMockRecorder) GetWorkflowByID(ctx, workflowID interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowByID", reflect.TypeOf((*MockClient)(nil).GetWorkflowByID), ctx, workflowID) +func (_mr *MockClientMockRecorder) GetWorkflowByID(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflowByID", reflect.TypeOf((*MockClient)(nil).GetWorkflowByID), arg0, arg1) } // ResumeWorkflowByID mocks base method -func (m *MockClient) ResumeWorkflowByID(ctx context.Context, i *models.ResumeWorkflowByIDInput) (*models.Workflow, error) { - ret := m.ctrl.Call(m, "ResumeWorkflowByID", ctx, i) +func (_m *MockClient) ResumeWorkflowByID(ctx context.Context, i *models.ResumeWorkflowByIDInput) (*models.Workflow, error) { + ret := _m.ctrl.Call(_m, "ResumeWorkflowByID", ctx, i) ret0, _ := ret[0].(*models.Workflow) ret1, _ := ret[1].(error) return ret0, ret1 } // ResumeWorkflowByID indicates an expected call of ResumeWorkflowByID -func (mr *MockClientMockRecorder) ResumeWorkflowByID(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResumeWorkflowByID", reflect.TypeOf((*MockClient)(nil).ResumeWorkflowByID), ctx, i) +func (_mr *MockClientMockRecorder) ResumeWorkflowByID(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "ResumeWorkflowByID", reflect.TypeOf((*MockClient)(nil).ResumeWorkflowByID), arg0, arg1) } // ResolveWorkflowByID mocks base method -func (m *MockClient) ResolveWorkflowByID(ctx context.Context, workflowID string) error { - ret := m.ctrl.Call(m, "ResolveWorkflowByID", ctx, workflowID) +func (_m *MockClient) ResolveWorkflowByID(ctx context.Context, workflowID string) error { + ret := _m.ctrl.Call(_m, "ResolveWorkflowByID", ctx, workflowID) ret0, _ := ret[0].(error) return ret0 } // ResolveWorkflowByID indicates an expected call of ResolveWorkflowByID -func (mr *MockClientMockRecorder) ResolveWorkflowByID(ctx, workflowID interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResolveWorkflowByID", reflect.TypeOf((*MockClient)(nil).ResolveWorkflowByID), ctx, workflowID) +func (_mr *MockClientMockRecorder) ResolveWorkflowByID(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "ResolveWorkflowByID", reflect.TypeOf((*MockClient)(nil).ResolveWorkflowByID), arg0, arg1) } // MockGetWorkflowsIter is a mock of GetWorkflowsIter interface @@ -270,30 +269,30 @@ func NewMockGetWorkflowsIter(ctrl *gomock.Controller) *MockGetWorkflowsIter { } // EXPECT returns an object that allows the caller to indicate expected use -func (m *MockGetWorkflowsIter) EXPECT() *MockGetWorkflowsIterMockRecorder { - return m.recorder +func (_m *MockGetWorkflowsIter) EXPECT() *MockGetWorkflowsIterMockRecorder { + return _m.recorder } // Next mocks base method -func (m *MockGetWorkflowsIter) Next(arg0 *models.Workflow) bool { - ret := m.ctrl.Call(m, "Next", arg0) +func (_m *MockGetWorkflowsIter) Next(_param0 *models.Workflow) bool { + ret := _m.ctrl.Call(_m, "Next", _param0) ret0, _ := ret[0].(bool) return ret0 } // Next indicates an expected call of Next -func (mr *MockGetWorkflowsIterMockRecorder) Next(arg0 interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Next", reflect.TypeOf((*MockGetWorkflowsIter)(nil).Next), arg0) +func (_mr *MockGetWorkflowsIterMockRecorder) Next(arg0 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "Next", reflect.TypeOf((*MockGetWorkflowsIter)(nil).Next), arg0) } // Err mocks base method -func (m *MockGetWorkflowsIter) Err() error { - ret := m.ctrl.Call(m, "Err") +func (_m *MockGetWorkflowsIter) Err() error { + ret := _m.ctrl.Call(_m, "Err") ret0, _ := ret[0].(error) return ret0 } // Err indicates an expected call of Err -func (mr *MockGetWorkflowsIterMockRecorder) Err() *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Err", reflect.TypeOf((*MockGetWorkflowsIter)(nil).Err)) +func (_mr *MockGetWorkflowsIterMockRecorder) Err() *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "Err", reflect.TypeOf((*MockGetWorkflowsIter)(nil).Err)) } diff --git a/gen-go/models/s_l_state.go b/gen-go/models/s_l_state.go index f3db7c73..d5d49b4b 100644 --- a/gen-go/models/s_l_state.go +++ b/gen-go/models/s_l_state.go @@ -55,6 +55,9 @@ type SLState struct { // resource Resource string `json:"Resource,omitempty"` + // result + Result string `json:"Result,omitempty"` + // result path ResultPath string `json:"ResultPath,omitempty"` @@ -92,6 +95,8 @@ type SLState struct { /* polymorph SLState Resource false */ +/* polymorph SLState Result false */ + /* polymorph SLState ResultPath false */ /* polymorph SLState Retry false */ diff --git a/gen-go/server/mock_controller.go b/gen-go/server/mock_controller.go index fa021ae6..96a2d22f 100644 --- a/gen-go/server/mock_controller.go +++ b/gen-go/server/mock_controller.go @@ -1,7 +1,6 @@ // Code generated by MockGen. DO NOT EDIT. // Source: interface.go -// Package server is a generated GoMock package. package server import ( @@ -30,141 +29,141 @@ func NewMockController(ctrl *gomock.Controller) *MockController { } // EXPECT returns an object that allows the caller to indicate expected use -func (m *MockController) EXPECT() *MockControllerMockRecorder { - return m.recorder +func (_m *MockController) EXPECT() *MockControllerMockRecorder { + return _m.recorder } // HealthCheck mocks base method -func (m *MockController) HealthCheck(ctx context.Context) error { - ret := m.ctrl.Call(m, "HealthCheck", ctx) +func (_m *MockController) HealthCheck(ctx context.Context) error { + ret := _m.ctrl.Call(_m, "HealthCheck", ctx) ret0, _ := ret[0].(error) return ret0 } // HealthCheck indicates an expected call of HealthCheck -func (mr *MockControllerMockRecorder) HealthCheck(ctx interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "HealthCheck", reflect.TypeOf((*MockController)(nil).HealthCheck), ctx) +func (_mr *MockControllerMockRecorder) HealthCheck(arg0 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "HealthCheck", reflect.TypeOf((*MockController)(nil).HealthCheck), arg0) } // PostStateResource mocks base method -func (m *MockController) PostStateResource(ctx context.Context, i *models.NewStateResource) (*models.StateResource, error) { - ret := m.ctrl.Call(m, "PostStateResource", ctx, i) +func (_m *MockController) PostStateResource(ctx context.Context, i *models.NewStateResource) (*models.StateResource, error) { + ret := _m.ctrl.Call(_m, "PostStateResource", ctx, i) ret0, _ := ret[0].(*models.StateResource) ret1, _ := ret[1].(error) return ret0, ret1 } // PostStateResource indicates an expected call of PostStateResource -func (mr *MockControllerMockRecorder) PostStateResource(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PostStateResource", reflect.TypeOf((*MockController)(nil).PostStateResource), ctx, i) +func (_mr *MockControllerMockRecorder) PostStateResource(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "PostStateResource", reflect.TypeOf((*MockController)(nil).PostStateResource), arg0, arg1) } // DeleteStateResource mocks base method -func (m *MockController) DeleteStateResource(ctx context.Context, i *models.DeleteStateResourceInput) error { - ret := m.ctrl.Call(m, "DeleteStateResource", ctx, i) +func (_m *MockController) DeleteStateResource(ctx context.Context, i *models.DeleteStateResourceInput) error { + ret := _m.ctrl.Call(_m, "DeleteStateResource", ctx, i) ret0, _ := ret[0].(error) return ret0 } // DeleteStateResource indicates an expected call of DeleteStateResource -func (mr *MockControllerMockRecorder) DeleteStateResource(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteStateResource", reflect.TypeOf((*MockController)(nil).DeleteStateResource), ctx, i) +func (_mr *MockControllerMockRecorder) DeleteStateResource(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "DeleteStateResource", reflect.TypeOf((*MockController)(nil).DeleteStateResource), arg0, arg1) } // GetStateResource mocks base method -func (m *MockController) GetStateResource(ctx context.Context, i *models.GetStateResourceInput) (*models.StateResource, error) { - ret := m.ctrl.Call(m, "GetStateResource", ctx, i) +func (_m *MockController) GetStateResource(ctx context.Context, i *models.GetStateResourceInput) (*models.StateResource, error) { + ret := _m.ctrl.Call(_m, "GetStateResource", ctx, i) ret0, _ := ret[0].(*models.StateResource) ret1, _ := ret[1].(error) return ret0, ret1 } // GetStateResource indicates an expected call of GetStateResource -func (mr *MockControllerMockRecorder) GetStateResource(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetStateResource", reflect.TypeOf((*MockController)(nil).GetStateResource), ctx, i) +func (_mr *MockControllerMockRecorder) GetStateResource(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetStateResource", reflect.TypeOf((*MockController)(nil).GetStateResource), arg0, arg1) } // PutStateResource mocks base method -func (m *MockController) PutStateResource(ctx context.Context, i *models.PutStateResourceInput) (*models.StateResource, error) { - ret := m.ctrl.Call(m, "PutStateResource", ctx, i) +func (_m *MockController) PutStateResource(ctx context.Context, i *models.PutStateResourceInput) (*models.StateResource, error) { + ret := _m.ctrl.Call(_m, "PutStateResource", ctx, i) ret0, _ := ret[0].(*models.StateResource) ret1, _ := ret[1].(error) return ret0, ret1 } // PutStateResource indicates an expected call of PutStateResource -func (mr *MockControllerMockRecorder) PutStateResource(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "PutStateResource", reflect.TypeOf((*MockController)(nil).PutStateResource), ctx, i) +func (_mr *MockControllerMockRecorder) PutStateResource(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "PutStateResource", reflect.TypeOf((*MockController)(nil).PutStateResource), arg0, arg1) } // GetWorkflowDefinitions mocks base method -func (m *MockController) GetWorkflowDefinitions(ctx context.Context) ([]models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "GetWorkflowDefinitions", ctx) +func (_m *MockController) GetWorkflowDefinitions(ctx context.Context) ([]models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "GetWorkflowDefinitions", ctx) ret0, _ := ret[0].([]models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflowDefinitions indicates an expected call of GetWorkflowDefinitions -func (mr *MockControllerMockRecorder) GetWorkflowDefinitions(ctx interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowDefinitions", reflect.TypeOf((*MockController)(nil).GetWorkflowDefinitions), ctx) +func (_mr *MockControllerMockRecorder) GetWorkflowDefinitions(arg0 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflowDefinitions", reflect.TypeOf((*MockController)(nil).GetWorkflowDefinitions), arg0) } // NewWorkflowDefinition mocks base method -func (m *MockController) NewWorkflowDefinition(ctx context.Context, i *models.NewWorkflowDefinitionRequest) (*models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "NewWorkflowDefinition", ctx, i) +func (_m *MockController) NewWorkflowDefinition(ctx context.Context, i *models.NewWorkflowDefinitionRequest) (*models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "NewWorkflowDefinition", ctx, i) ret0, _ := ret[0].(*models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // NewWorkflowDefinition indicates an expected call of NewWorkflowDefinition -func (mr *MockControllerMockRecorder) NewWorkflowDefinition(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "NewWorkflowDefinition", reflect.TypeOf((*MockController)(nil).NewWorkflowDefinition), ctx, i) +func (_mr *MockControllerMockRecorder) NewWorkflowDefinition(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "NewWorkflowDefinition", reflect.TypeOf((*MockController)(nil).NewWorkflowDefinition), arg0, arg1) } // GetWorkflowDefinitionVersionsByName mocks base method -func (m *MockController) GetWorkflowDefinitionVersionsByName(ctx context.Context, i *models.GetWorkflowDefinitionVersionsByNameInput) ([]models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "GetWorkflowDefinitionVersionsByName", ctx, i) +func (_m *MockController) GetWorkflowDefinitionVersionsByName(ctx context.Context, i *models.GetWorkflowDefinitionVersionsByNameInput) ([]models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "GetWorkflowDefinitionVersionsByName", ctx, i) ret0, _ := ret[0].([]models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflowDefinitionVersionsByName indicates an expected call of GetWorkflowDefinitionVersionsByName -func (mr *MockControllerMockRecorder) GetWorkflowDefinitionVersionsByName(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowDefinitionVersionsByName", reflect.TypeOf((*MockController)(nil).GetWorkflowDefinitionVersionsByName), ctx, i) +func (_mr *MockControllerMockRecorder) GetWorkflowDefinitionVersionsByName(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflowDefinitionVersionsByName", reflect.TypeOf((*MockController)(nil).GetWorkflowDefinitionVersionsByName), arg0, arg1) } // UpdateWorkflowDefinition mocks base method -func (m *MockController) UpdateWorkflowDefinition(ctx context.Context, i *models.UpdateWorkflowDefinitionInput) (*models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "UpdateWorkflowDefinition", ctx, i) +func (_m *MockController) UpdateWorkflowDefinition(ctx context.Context, i *models.UpdateWorkflowDefinitionInput) (*models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "UpdateWorkflowDefinition", ctx, i) ret0, _ := ret[0].(*models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // UpdateWorkflowDefinition indicates an expected call of UpdateWorkflowDefinition -func (mr *MockControllerMockRecorder) UpdateWorkflowDefinition(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateWorkflowDefinition", reflect.TypeOf((*MockController)(nil).UpdateWorkflowDefinition), ctx, i) +func (_mr *MockControllerMockRecorder) UpdateWorkflowDefinition(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "UpdateWorkflowDefinition", reflect.TypeOf((*MockController)(nil).UpdateWorkflowDefinition), arg0, arg1) } // GetWorkflowDefinitionByNameAndVersion mocks base method -func (m *MockController) GetWorkflowDefinitionByNameAndVersion(ctx context.Context, i *models.GetWorkflowDefinitionByNameAndVersionInput) (*models.WorkflowDefinition, error) { - ret := m.ctrl.Call(m, "GetWorkflowDefinitionByNameAndVersion", ctx, i) +func (_m *MockController) GetWorkflowDefinitionByNameAndVersion(ctx context.Context, i *models.GetWorkflowDefinitionByNameAndVersionInput) (*models.WorkflowDefinition, error) { + ret := _m.ctrl.Call(_m, "GetWorkflowDefinitionByNameAndVersion", ctx, i) ret0, _ := ret[0].(*models.WorkflowDefinition) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflowDefinitionByNameAndVersion indicates an expected call of GetWorkflowDefinitionByNameAndVersion -func (mr *MockControllerMockRecorder) GetWorkflowDefinitionByNameAndVersion(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowDefinitionByNameAndVersion", reflect.TypeOf((*MockController)(nil).GetWorkflowDefinitionByNameAndVersion), ctx, i) +func (_mr *MockControllerMockRecorder) GetWorkflowDefinitionByNameAndVersion(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflowDefinitionByNameAndVersion", reflect.TypeOf((*MockController)(nil).GetWorkflowDefinitionByNameAndVersion), arg0, arg1) } // GetWorkflows mocks base method -func (m *MockController) GetWorkflows(ctx context.Context, i *models.GetWorkflowsInput) ([]models.Workflow, string, error) { - ret := m.ctrl.Call(m, "GetWorkflows", ctx, i) +func (_m *MockController) GetWorkflows(ctx context.Context, i *models.GetWorkflowsInput) ([]models.Workflow, string, error) { + ret := _m.ctrl.Call(_m, "GetWorkflows", ctx, i) ret0, _ := ret[0].([]models.Workflow) ret1, _ := ret[1].(string) ret2, _ := ret[2].(error) @@ -172,69 +171,69 @@ func (m *MockController) GetWorkflows(ctx context.Context, i *models.GetWorkflow } // GetWorkflows indicates an expected call of GetWorkflows -func (mr *MockControllerMockRecorder) GetWorkflows(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflows", reflect.TypeOf((*MockController)(nil).GetWorkflows), ctx, i) +func (_mr *MockControllerMockRecorder) GetWorkflows(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflows", reflect.TypeOf((*MockController)(nil).GetWorkflows), arg0, arg1) } // StartWorkflow mocks base method -func (m *MockController) StartWorkflow(ctx context.Context, i *models.StartWorkflowRequest) (*models.Workflow, error) { - ret := m.ctrl.Call(m, "StartWorkflow", ctx, i) +func (_m *MockController) StartWorkflow(ctx context.Context, i *models.StartWorkflowRequest) (*models.Workflow, error) { + ret := _m.ctrl.Call(_m, "StartWorkflow", ctx, i) ret0, _ := ret[0].(*models.Workflow) ret1, _ := ret[1].(error) return ret0, ret1 } // StartWorkflow indicates an expected call of StartWorkflow -func (mr *MockControllerMockRecorder) StartWorkflow(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "StartWorkflow", reflect.TypeOf((*MockController)(nil).StartWorkflow), ctx, i) +func (_mr *MockControllerMockRecorder) StartWorkflow(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "StartWorkflow", reflect.TypeOf((*MockController)(nil).StartWorkflow), arg0, arg1) } // CancelWorkflow mocks base method -func (m *MockController) CancelWorkflow(ctx context.Context, i *models.CancelWorkflowInput) error { - ret := m.ctrl.Call(m, "CancelWorkflow", ctx, i) +func (_m *MockController) CancelWorkflow(ctx context.Context, i *models.CancelWorkflowInput) error { + ret := _m.ctrl.Call(_m, "CancelWorkflow", ctx, i) ret0, _ := ret[0].(error) return ret0 } // CancelWorkflow indicates an expected call of CancelWorkflow -func (mr *MockControllerMockRecorder) CancelWorkflow(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CancelWorkflow", reflect.TypeOf((*MockController)(nil).CancelWorkflow), ctx, i) +func (_mr *MockControllerMockRecorder) CancelWorkflow(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "CancelWorkflow", reflect.TypeOf((*MockController)(nil).CancelWorkflow), arg0, arg1) } // GetWorkflowByID mocks base method -func (m *MockController) GetWorkflowByID(ctx context.Context, workflowID string) (*models.Workflow, error) { - ret := m.ctrl.Call(m, "GetWorkflowByID", ctx, workflowID) +func (_m *MockController) GetWorkflowByID(ctx context.Context, workflowID string) (*models.Workflow, error) { + ret := _m.ctrl.Call(_m, "GetWorkflowByID", ctx, workflowID) ret0, _ := ret[0].(*models.Workflow) ret1, _ := ret[1].(error) return ret0, ret1 } // GetWorkflowByID indicates an expected call of GetWorkflowByID -func (mr *MockControllerMockRecorder) GetWorkflowByID(ctx, workflowID interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetWorkflowByID", reflect.TypeOf((*MockController)(nil).GetWorkflowByID), ctx, workflowID) +func (_mr *MockControllerMockRecorder) GetWorkflowByID(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "GetWorkflowByID", reflect.TypeOf((*MockController)(nil).GetWorkflowByID), arg0, arg1) } // ResumeWorkflowByID mocks base method -func (m *MockController) ResumeWorkflowByID(ctx context.Context, i *models.ResumeWorkflowByIDInput) (*models.Workflow, error) { - ret := m.ctrl.Call(m, "ResumeWorkflowByID", ctx, i) +func (_m *MockController) ResumeWorkflowByID(ctx context.Context, i *models.ResumeWorkflowByIDInput) (*models.Workflow, error) { + ret := _m.ctrl.Call(_m, "ResumeWorkflowByID", ctx, i) ret0, _ := ret[0].(*models.Workflow) ret1, _ := ret[1].(error) return ret0, ret1 } // ResumeWorkflowByID indicates an expected call of ResumeWorkflowByID -func (mr *MockControllerMockRecorder) ResumeWorkflowByID(ctx, i interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResumeWorkflowByID", reflect.TypeOf((*MockController)(nil).ResumeWorkflowByID), ctx, i) +func (_mr *MockControllerMockRecorder) ResumeWorkflowByID(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "ResumeWorkflowByID", reflect.TypeOf((*MockController)(nil).ResumeWorkflowByID), arg0, arg1) } // ResolveWorkflowByID mocks base method -func (m *MockController) ResolveWorkflowByID(ctx context.Context, workflowID string) error { - ret := m.ctrl.Call(m, "ResolveWorkflowByID", ctx, workflowID) +func (_m *MockController) ResolveWorkflowByID(ctx context.Context, workflowID string) error { + ret := _m.ctrl.Call(_m, "ResolveWorkflowByID", ctx, workflowID) ret0, _ := ret[0].(error) return ret0 } // ResolveWorkflowByID indicates an expected call of ResolveWorkflowByID -func (mr *MockControllerMockRecorder) ResolveWorkflowByID(ctx, workflowID interface{}) *gomock.Call { - return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ResolveWorkflowByID", reflect.TypeOf((*MockController)(nil).ResolveWorkflowByID), ctx, workflowID) +func (_mr *MockControllerMockRecorder) ResolveWorkflowByID(arg0, arg1 interface{}) *gomock.Call { + return _mr.mock.ctrl.RecordCallWithMethodType(_mr.mock, "ResolveWorkflowByID", reflect.TypeOf((*MockController)(nil).ResolveWorkflowByID), arg0, arg1) } diff --git a/gen-js/package.json b/gen-js/package.json index bf21ed5f..fc1a7c5a 100644 --- a/gen-js/package.json +++ b/gen-js/package.json @@ -1,6 +1,6 @@ { "name": "workflow-manager", - "version": "0.7.1", + "version": "0.7.2", "description": "Orchestrator for AWS Step Functions", "main": "index.js", "dependencies": { diff --git a/swagger.yml b/swagger.yml index 40db4686..ab2d7e4a 100644 --- a/swagger.yml +++ b/swagger.yml @@ -4,7 +4,7 @@ info: description: Orchestrator for AWS Step Functions # when changing the version here, make sure to # re-run `make generate` to generate clients and server - version: 0.7.1 + version: 0.7.2 x-npm-package: workflow-manager schemes: - http @@ -653,6 +653,8 @@ definitions: type: string ResultPath: type: string + Result: + type: string Retry: x-omitempty: true type: array