Versions in this module Expand all Collapse all v1 v1.3.1 Mar 25, 2022 v1.3.0 Aug 27, 2021 v1.2.7 May 18, 2021 v1.2.6 Feb 26, 2021 v1.2.5 Feb 26, 2021 v1.2.4 Feb 26, 2021 v1.2.3 Feb 25, 2021 v1.2.2 Feb 18, 2021 v1.2.1 Feb 4, 2021 v1.2.0 Jan 5, 2021 v1.1.0 Dec 22, 2020 Changes in this version type Job + MaxTaskExecution *int + Timeout *int type Status + const StatusOverload v1.0.2 Dec 18, 2020 v1.0.1 Dec 18, 2020 v1.0.0 Dec 16, 2020 Changes in this version + var AllCause = []Cause + var AllChoiceHelper = []ChoiceHelper + var AllErrorCode = []ErrorCode + var AllHTTPMethod = []HTTPMethod + var AllProtocol = []Protocol + var AllStatus = []Status + var AllTaskType = []TaskType + type Catch struct + ErrorOn []*ErrorCode + ExcludeErrorMessage []*string + Next string + type Cause string + const CauseCatch + const CauseExecute + const CauseRetry + func (e *Cause) UnmarshalGQL(v interface{}) error + func (e Cause) IsValid() bool + func (e Cause) MarshalGQL(w io.Writer) + func (e Cause) String() string + type Choice struct + And []*ChoiceOperation + Float *float64 + Helper *ChoiceHelper + Int *int + Next *string + Not *ChoiceOperation + Or []*ChoiceOperation + String *string + Variable *string + type ChoiceHelper string + const ChoiceHelperFloatEquals + const ChoiceHelperFloatGreaterThan + const ChoiceHelperFloatGreaterThanEquals + const ChoiceHelperFloatLessThan + const ChoiceHelperFloatLessThanEquals + const ChoiceHelperIntEquals + const ChoiceHelperIntGreaterThan + const ChoiceHelperIntGreaterThanEquals + const ChoiceHelperIntLessThan + const ChoiceHelperIntLessThanEquals + const ChoiceHelperStringEquals + func (e *ChoiceHelper) UnmarshalGQL(v interface{}) error + func (e ChoiceHelper) IsValid() bool + func (e ChoiceHelper) MarshalGQL(w io.Writer) + func (e ChoiceHelper) String() string + type ChoiceOperation struct + Float *float64 + Helper ChoiceHelper + Int *int + String *string + Variable string + type Endpoint struct + AddHeaders []string + Body *string + ClusterName *string + ConnectTimeout *string + Credential *string + Db *int + DetectedErrorFromHeader []*KVItemInput + Format *string + Headers []*KVItemInput + Insecure *bool + Method *HTTPMethod + Password *string + ProjectID *string + Protocol Protocol + Proxy *string + Queue *string + RPCHeaders []string + ReflHeaders []string + Subject *string + Symbol *string + Token *string + TopicID *string + URL *string + User *string + type ErrorCode string + const ErrorCodeAll + const ErrorCodePermissions + const ErrorCodeRuntime + const ErrorCodeTaskfailed + const ErrorCodeTimeout + func (e *ErrorCode) UnmarshalGQL(v interface{}) error + func (e ErrorCode) IsValid() bool + func (e ErrorCode) MarshalGQL(w io.Writer) + func (e ErrorCode) String() string + type HTTPMethod string + const HTTPMethodDelete + const HTTPMethodGet + const HTTPMethodPatch + const HTTPMethodPost + const HTTPMethodPut + func (e *HTTPMethod) UnmarshalGQL(v interface{}) error + func (e HTTPMethod) IsValid() bool + func (e HTTPMethod) MarshalGQL(w io.Writer) + func (e HTTPMethod) String() string + type Job struct + Comment string + ConsistentTaskNums *int + Parameters *string + StartAt string + Tasks []*Task + type JobStatus struct + JobID string + Status Status + TaskHistory []*TaskHistory + Timestamp time.Time + type KVItemInput struct + Key string + Value string + type Protocol string + const ProtocolGrpc + const ProtocolHTTP + const ProtocolNats + const ProtocolPubsub + const ProtocolRedisStream + func (e *Protocol) UnmarshalGQL(v interface{}) error + func (e Protocol) IsValid() bool + func (e Protocol) MarshalGQL(w io.Writer) + func (e Protocol) String() string + type Retry struct + ErrorOn []*ErrorCode + ExcludeErrorMessage []*string + Interval *int + MaxAttempts *string + type Status string + const StatusFailed + const StatusPending + const StatusSuccess + const StatusTimeout + const StatusWorking + func (e *Status) UnmarshalGQL(v interface{}) error + func (e Status) IsValid() bool + func (e Status) MarshalGQL(w io.Writer) + func (e Status) String() string + type Task struct + Branches []*Job + Catch *Catch + Choices []*Choice + Default *string + End *bool + Endpoint *Endpoint + ErrorPath *string + HeaderPath *string + InputPath *string + Name string + Next *string + OutputPath *string + ResultPath *string + Retry *Retry + Seconds *int + Timeout *int + Type TaskType + Until *time.Time + type TaskHistory struct + CancelledAt *time.Time + Cause Cause + CompletedAt *time.Time + ExecutedAt *time.Time + From string + Input map[string]interface{} + Output map[string]interface{} + RetryCount *int + Status Status + TaskID string + type TaskType string + const TaskTypeChoice + const TaskTypeParallel + const TaskTypePass + const TaskTypeTask + const TaskTypeWait + func (e *TaskType) UnmarshalGQL(v interface{}) error + func (e TaskType) IsValid() bool + func (e TaskType) MarshalGQL(w io.Writer) + func (e TaskType) String() string
Go to main page