Task Types

type TaskList struct {
    Name string
    Kind *TaskListKind
}

type TaskListKind int32

const (
    TaskListKindNormal TaskListKind = iota
    TaskListKindSticky
)

type TaskListType int32

const (
    TaskListTypeDecision TaskListType = iota
    TaskListTypeActivity
)

type TaskListMetadata struct {
    MaxTasksPerSecond *float64
}

type TaskListStatus struct {
    BacklogCountHint int64
    ReadLevel        int64
    AckLevel         int64
    RatePerSecond    float64
    TaskIDBlock      *TaskIDBlock
}

type TaskIDBlock struct {
    StartID int64
    EndID   int64
}

type TaskListPartitionMetadata struct {
    Key          string
    OwnerHostName string
}

type TaskListPartitionConfig struct {
    Version            int32
    NumReadPartitions  int32
    NumWritePartitions int32
}

type PollForDecisionTaskRequest struct {
    Domain         string
    TaskList       *TaskList
    Identity       string
    BinaryChecksum string
}

type PollForDecisionTaskResponse struct {
    TaskToken                       []byte
    WorkflowExecution               *WorkflowExecution
    WorkflowType                    *WorkflowType
    PreviousStartedEventID          *int64
    StartedEventID                  int64
    Attempt                         int64
    BacklogCountHint                int64
    History                         *History
    NextPageToken                   []byte
    Query                           *WorkflowQuery
    WorkflowExecutionTaskList       *TaskList
    ScheduledTimestamp              *int64
    StartedTimestamp                *int64
    Queries                         map[string]*WorkflowQuery
    NextEventID                     int64
}

type RespondDecisionTaskCompletedRequest struct {
    TaskToken                  []byte
    Decisions                  []*Decision
    ExecutionContext           []byte
    Identity                   string
    StickyAttributes           *StickyExecutionAttributes
    ReturnNewDecisionTask      bool
    ForceCreateNewDecisionTask bool
    BinaryChecksum             string
    QueryResults               map[string]*WorkflowQueryResult
}

type RespondDecisionTaskCompletedResponse struct {
    DecisionTask                *PollForDecisionTaskResponse
    ActivitiesToDispatchLocally map[string]*ActivityLocalDispatchInfo
}

type RespondDecisionTaskFailedRequest struct {
    TaskToken      []byte
    Cause          *DecisionTaskFailedCause
    Details        []byte
    Identity       string
    BinaryChecksum string
}

type StickyExecutionAttributes struct {
    WorkerTaskList                *TaskList
    ScheduleToStartTimeoutSeconds *int32
}

type PollForActivityTaskRequest struct {
    Domain           string
    TaskList         *TaskList
    Identity         string
    TaskListMetadata *TaskListMetadata
}

type PollForActivityTaskResponse struct {
    TaskToken                       []byte
    WorkflowExecution               *WorkflowExecution
    ActivityID                      string
    ActivityType                    *ActivityType
    Input                           []byte
    ScheduledTimestamp              *int64
    ScheduleToCloseTimeoutSeconds   *int32
    StartedTimestamp                *int64
    StartToCloseTimeoutSeconds      *int32
    HeartbeatTimeoutSeconds         *int32
    Attempt                         int32
    ScheduledTimestampOfThisAttempt *int64
    HeartbeatDetails                []byte
    WorkflowType                    *WorkflowType
    WorkflowDomain                  string
    Header                          *Header
}

type RespondActivityTaskCompletedRequest struct {
    TaskToken []byte
    Result    []byte
    Identity  string
}

type RespondActivityTaskCompletedByIDRequest struct {
    Domain     string
    WorkflowID string
    RunID      string
    ActivityID string
    Result     []byte
    Identity   string
}

type RespondActivityTaskFailedRequest struct {
    TaskToken []byte
    Reason    *string
    Details   []byte
    Identity  string
}

type RespondActivityTaskFailedByIDRequest struct {
    Domain     string
    WorkflowID string
    RunID      string
    ActivityID string
    Reason     *string
    Details    []byte
    Identity   string
}

type RespondActivityTaskCanceledRequest struct {
    TaskToken []byte
    Details   []byte
    Identity  string
}

type RecordActivityTaskHeartbeatRequest struct {
    TaskToken []byte
    Details   []byte
    Identity  string
}

type RecordActivityTaskHeartbeatResponse struct {
    CancelRequested bool
}

type TaskSource int32

const (
    TaskSourceHistory TaskSource = iota
    TaskSourceDbBacklog
)

type PollerInfo struct {
    LastAccessTime *int64
    Identity       string
    RatePerSecond  float64
}

type DescribeTaskListRequest struct {
    Domain                string
    TaskList              *TaskList
    TaskListType          *TaskListType
    IncludeTaskListStatus bool
}

type DescribeTaskListResponse struct {
    Pollers        []*PollerInfo
    TaskListStatus *TaskListStatus
}

type ActivityLocalDispatchInfo struct {
    ActivityID                      string
    ScheduledTimestamp              *int64
    StartedTimestamp                *int64
    ScheduledTimestampOfThisAttempt *int64
    TaskToken                       []byte
}

type ActivityTaskDispatchInfo struct {
    ScheduledEvent                  *HistoryEvent
    StartedTimestamp                *int64
    Attempt                         *int64
    ScheduledTimestampOfThisAttempt *int64
    HeartbeatDetails                []byte
    WorkflowType                    *WorkflowType
    WorkflowDomain                  string
}