Documentation
¶
Index ¶
Constants ¶
View Source
const WorkflowGetApiPath = "/api/v1/workflow/get"
View Source
const WorkflowGetQueryAttributesApiPath = "/api/v1/workflow/queryattributes/get"
View Source
const WorkflowGetWithWaitApiPath = "/api/v1/workflow/getWithWait"
View Source
const WorkflowResetApiPath = "/api/v1/workflow/reset"
View Source
const WorkflowSearchApiPath = "/api/v1/workflow/search"
View Source
const WorkflowSignalApiPath = "/api/v1/workflow/signal"
View Source
const WorkflowStartApiPath = "/api/v1/workflow/start"
Variables ¶
This section is empty.
Functions ¶
func NewService ¶
func NewService(client UnifiedClient) *gin.Engine
NewService returns a new router.
Types ¶
type ApiService ¶
type ApiService interface {
ApiV1WorkflowStartPost(request iwfidl.WorkflowStartRequest) (*iwfidl.WorkflowStartResponse, *ErrorAndStatus)
ApiV1WorkflowSignalPost(request iwfidl.WorkflowSignalRequest) *ErrorAndStatus
ApiV1WorkflowGetQueryAttributesPost(request iwfidl.WorkflowGetQueryAttributesRequest) (*iwfidl.WorkflowGetQueryAttributesResponse, *ErrorAndStatus)
ApiV1WorkflowGetPost(request iwfidl.WorkflowGetRequest) (*iwfidl.WorkflowGetResponse, *ErrorAndStatus)
ApiV1WorkflowGetWithWaitPost(request iwfidl.WorkflowGetRequest) (*iwfidl.WorkflowGetResponse, *ErrorAndStatus)
ApiV1WorkflowSearchPost(request iwfidl.WorkflowSearchRequest) (*iwfidl.WorkflowSearchResponse, *ErrorAndStatus)
ApiV1WorkflowResetPost(request iwfidl.WorkflowResetRequest) (*iwfidl.WorkflowResetResponse, *ErrorAndStatus)
Close()
}
func NewApiService ¶
func NewApiService(client UnifiedClient) (ApiService, error)
type ErrorAndStatus ¶
type ErrorAndStatus struct {
StatusCode int
Error iwfidl.ErrorResponse
}
type ListWorkflowExecutionsResponse ¶
type ListWorkflowExecutionsResponse struct {
Executions []iwfidl.WorkflowSearchResponseEntry
}
type StartWorkflowOptions ¶
type UnifiedClient ¶
type UnifiedClient interface {
Close()
StartInterpreterWorkflow(ctx context.Context, options StartWorkflowOptions, args ...interface{}) (runId string, err error)
SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, arg interface{}) error
ListWorkflow(ctx context.Context, request *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
QueryWorkflow(ctx context.Context, valuePtr interface{}, workflowID string, runID string, queryType string, args ...interface{}) error
DescribeWorkflowExecution(ctx context.Context, workflowID, runID string) (*DescribeWorkflowExecutionResponse, error)
GetWorkflowResult(ctx context.Context, valuePtr interface{}, workflowID string, runID string) error
ResetWorkflow(ctx context.Context, request iwfidl.WorkflowResetRequest) (runId string, err error)
}
Click to show internal directories.
Click to hide internal directories.