Versions in this module Expand all Collapse all v1 v1.0.0 May 31, 2023 Changes in this version + const DefaultBasePath + const DefaultEndpoint + const DefaultRetry + const DefaultTimeout + func IsBadRequest(err error) bool + func IsNotFound(err error) bool + type CancelRunRequest struct + RunID string + type CancelRunResponse struct + RunID string + type Client interface + CancelRun func(ctx context.Context, req *CancelRunRequest) (*CancelRunResponse, error) + GetRunLog func(ctx context.Context, req *GetRunLogRequest) (*GetRunLogResponse, error) + ListRuns func(ctx context.Context, req *ListRunsRequest) (*ListRunsResponse, error) + RunWorkflow func(ctx context.Context, req *RunWorkflowRequest) (*RunWorkflowResponse, error) + func NewClient(options *Options) Client + type ErrorResp struct + Msg string + StatusCode int32 + func (e ErrorResp) Error() string + type GetRunLogRequest struct + RunID string + type GetRunLogResponse struct + Outputs map[string]interface{} + Request RunRequest + RunID string + RunLog Log + State RunState + TaskLogs []Log + type ListRunsRequest struct + PageSize *int64 + PageToken *string + TagFilter *string + type ListRunsResponse struct + NextPageToken string + Runs []RunStatus + type Log struct + Cmd []string + EndTime *Time + ExitCode *int32 + Log string + Name string + StartTime *Time + Stderr string + Stdout string + type Options struct + BasePath string + Endpoint string + Retry int + Timeout int + func NewOptions() *Options + func (o *Options) AddFlags(fs *pflag.FlagSet) + func (o Options) Validate() error + type RunRequest struct + Tags map[string]interface{} + WorkflowEngineParameters map[string]interface{} + WorkflowParams map[string]interface{} + WorkflowType string + WorkflowTypeVersion string + type RunState string + const RunStateCanceled + const RunStateCanceling + const RunStateComplete + const RunStateExecutorError + const RunStateInitializing + const RunStatePaused + const RunStateQueued + const RunStateRunning + const RunStateSystemError + const RunStateUnknown + type RunStatus struct + RunID string + State RunState + type RunWorkflowRequest struct + WorkflowAttachment map[string]string + type RunWorkflowResponse struct + RunID string + type Time time.Time + func (t *Time) MarshalJSON() ([]byte, error) + func (t *Time) PointTime() *time.Time + func (t *Time) String() string + func (t *Time) Time() time.Time + func (t *Time) UnmarshalJSON(data []byte) (err error)
Go to main page