common/types/shared.go (6,303 lines of code) (raw):
// Copyright (c) 2017-2020 Uber Technologies Inc.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all
// copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
// SOFTWARE.
package types
import (
"encoding/json"
"fmt"
"strconv"
"strings"
"time"
)
// AccessDeniedError is an internal type (TBD...)
type AccessDeniedError struct {
Message string `json:"message,required"`
}
// ActivityLocalDispatchInfo is an internal type (TBD...)
type ActivityLocalDispatchInfo struct {
ActivityID string `json:"activityId,omitempty"`
ScheduledTimestamp *int64 `json:"scheduledTimestamp,omitempty"`
StartedTimestamp *int64 `json:"startedTimestamp,omitempty"`
ScheduledTimestampOfThisAttempt *int64 `json:"scheduledTimestampOfThisAttempt,omitempty"`
TaskToken []byte `json:"taskToken,omitempty"`
}
// GetScheduledTimestamp is an internal getter (TBD...)
func (v *ActivityLocalDispatchInfo) GetScheduledTimestamp() (o int64) {
if v != nil && v.ScheduledTimestamp != nil {
return *v.ScheduledTimestamp
}
return
}
// ActivityTaskCancelRequestedEventAttributes is an internal type (TBD...)
type ActivityTaskCancelRequestedEventAttributes struct {
ActivityID string `json:"activityId,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
}
// GetActivityID is an internal getter (TBD...)
func (v *ActivityTaskCancelRequestedEventAttributes) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// ActivityTaskCanceledEventAttributes is an internal type (TBD...)
type ActivityTaskCanceledEventAttributes struct {
Details []byte `json:"details,omitempty"`
LatestCancelRequestedEventID int64 `json:"latestCancelRequestedEventId,omitempty"`
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetScheduledEventID is an internal getter (TBD...)
func (v *ActivityTaskCanceledEventAttributes) GetScheduledEventID() (o int64) {
if v != nil {
return v.ScheduledEventID
}
return
}
// ActivityTaskCompletedEventAttributes is an internal type (TBD...)
type ActivityTaskCompletedEventAttributes struct {
Result []byte `json:"result,omitempty"`
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetScheduledEventID is an internal getter (TBD...)
func (v *ActivityTaskCompletedEventAttributes) GetScheduledEventID() (o int64) {
if v != nil {
return v.ScheduledEventID
}
return
}
// GetStartedEventID is an internal getter (TBD...)
func (v *ActivityTaskCompletedEventAttributes) GetStartedEventID() (o int64) {
if v != nil {
return v.StartedEventID
}
return
}
// ActivityTaskFailedEventAttributes is an internal type (TBD...)
type ActivityTaskFailedEventAttributes struct {
Reason *string `json:"reason,omitempty"`
Details []byte `json:"details,omitempty"`
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetScheduledEventID is an internal getter (TBD...)
func (v *ActivityTaskFailedEventAttributes) GetScheduledEventID() (o int64) {
if v != nil {
return v.ScheduledEventID
}
return
}
// GetStartedEventID is an internal getter (TBD...)
func (v *ActivityTaskFailedEventAttributes) GetStartedEventID() (o int64) {
if v != nil {
return v.StartedEventID
}
return
}
// ActivityTaskScheduledEventAttributes is an internal type (TBD...)
type ActivityTaskScheduledEventAttributes struct {
ActivityID string `json:"activityId,omitempty"`
ActivityType *ActivityType `json:"activityType,omitempty"`
Domain *string `json:"domain,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"input,omitempty"`
ScheduleToCloseTimeoutSeconds *int32 `json:"scheduleToCloseTimeoutSeconds,omitempty"`
ScheduleToStartTimeoutSeconds *int32 `json:"scheduleToStartTimeoutSeconds,omitempty"`
StartToCloseTimeoutSeconds *int32 `json:"startToCloseTimeoutSeconds,omitempty"`
HeartbeatTimeoutSeconds *int32 `json:"heartbeatTimeoutSeconds,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
Header *Header `json:"header,omitempty"`
}
// GetActivityID is an internal getter (TBD...)
func (v *ActivityTaskScheduledEventAttributes) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// GetActivityType is an internal getter (TBD...)
func (v *ActivityTaskScheduledEventAttributes) GetActivityType() (o *ActivityType) {
if v != nil && v.ActivityType != nil {
return v.ActivityType
}
return
}
// GetDomain is an internal getter (TBD...)
func (v *ActivityTaskScheduledEventAttributes) GetDomain() (o string) {
if v != nil && v.Domain != nil {
return *v.Domain
}
return
}
// GetTaskList is an internal getter (TBD...)
func (v *ActivityTaskScheduledEventAttributes) GetTaskList() (o *TaskList) {
if v != nil && v.TaskList != nil {
return v.TaskList
}
return
}
// GetScheduleToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *ActivityTaskScheduledEventAttributes) GetScheduleToCloseTimeoutSeconds() (o int32) {
if v != nil && v.ScheduleToCloseTimeoutSeconds != nil {
return *v.ScheduleToCloseTimeoutSeconds
}
return
}
// GetScheduleToStartTimeoutSeconds is an internal getter (TBD...)
func (v *ActivityTaskScheduledEventAttributes) GetScheduleToStartTimeoutSeconds() (o int32) {
if v != nil && v.ScheduleToStartTimeoutSeconds != nil {
return *v.ScheduleToStartTimeoutSeconds
}
return
}
// GetStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *ActivityTaskScheduledEventAttributes) GetStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.StartToCloseTimeoutSeconds != nil {
return *v.StartToCloseTimeoutSeconds
}
return
}
// GetHeartbeatTimeoutSeconds is an internal getter (TBD...)
func (v *ActivityTaskScheduledEventAttributes) GetHeartbeatTimeoutSeconds() (o int32) {
if v != nil && v.HeartbeatTimeoutSeconds != nil {
return *v.HeartbeatTimeoutSeconds
}
return
}
// ActivityTaskStartedEventAttributes is an internal type (TBD...)
type ActivityTaskStartedEventAttributes struct {
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
Attempt int32 `json:"attempt,omitempty"`
LastFailureReason *string `json:"lastFailureReason,omitempty"`
LastFailureDetails []byte `json:"lastFailureDetails,omitempty"`
}
// GetScheduledEventID is an internal getter (TBD...)
func (v *ActivityTaskStartedEventAttributes) GetScheduledEventID() (o int64) {
if v != nil {
return v.ScheduledEventID
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *ActivityTaskStartedEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// ActivityTaskTimedOutEventAttributes is an internal type (TBD...)
type ActivityTaskTimedOutEventAttributes struct {
Details []byte `json:"details,omitempty"`
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
TimeoutType *TimeoutType `json:"timeoutType,omitempty"`
LastFailureReason *string `json:"lastFailureReason,omitempty"`
LastFailureDetails []byte `json:"lastFailureDetails,omitempty"`
}
// GetScheduledEventID is an internal getter (TBD...)
func (v *ActivityTaskTimedOutEventAttributes) GetScheduledEventID() (o int64) {
if v != nil {
return v.ScheduledEventID
}
return
}
// GetTimeoutType is an internal getter (TBD...)
func (v *ActivityTaskTimedOutEventAttributes) GetTimeoutType() (o TimeoutType) {
if v != nil && v.TimeoutType != nil {
return *v.TimeoutType
}
return
}
// ActivityType is an internal type (TBD...)
type ActivityType struct {
Name string `json:"name,omitempty"`
}
// GetName is an internal getter (TBD...)
func (v *ActivityType) GetName() (o string) {
if v != nil {
return v.Name
}
return
}
// ArchivalStatus is an internal type (TBD...)
type ArchivalStatus int32
// Ptr is a helper function for getting pointer value
func (e ArchivalStatus) Ptr() *ArchivalStatus {
return &e
}
// String returns a readable string representation of ArchivalStatus.
func (e ArchivalStatus) String() string {
w := int32(e)
switch w {
case 0:
return "DISABLED"
case 1:
return "ENABLED"
}
return fmt.Sprintf("ArchivalStatus(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *ArchivalStatus) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "DISABLED":
*e = ArchivalStatusDisabled
return nil
case "ENABLED":
*e = ArchivalStatusEnabled
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "ArchivalStatus", err)
}
*e = ArchivalStatus(val)
return nil
}
}
// MarshalText encodes ArchivalStatus to text.
func (e ArchivalStatus) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// ArchivalStatusDisabled is an option for ArchivalStatus
ArchivalStatusDisabled ArchivalStatus = iota
// ArchivalStatusEnabled is an option for ArchivalStatus
ArchivalStatusEnabled
)
// BadBinaries is an internal type (TBD...)
type BadBinaries struct {
Binaries map[string]*BadBinaryInfo `json:"binaries,omitempty"`
}
// BadBinaryInfo is an internal type (TBD...)
type BadBinaryInfo struct {
Reason string `json:"reason,omitempty"`
Operator string `json:"operator,omitempty"`
CreatedTimeNano *int64 `json:"createdTimeNano,omitempty"`
}
// GetReason is an internal getter (TBD...)
func (v *BadBinaryInfo) GetReason() (o string) {
if v != nil {
return v.Reason
}
return
}
// GetOperator is an internal getter (TBD...)
func (v *BadBinaryInfo) GetOperator() (o string) {
if v != nil {
return v.Operator
}
return
}
// GetCreatedTimeNano is an internal getter (TBD...)
func (v *BadBinaryInfo) GetCreatedTimeNano() (o int64) {
if v != nil && v.CreatedTimeNano != nil {
return *v.CreatedTimeNano
}
return
}
// BadRequestError is an internal type (TBD...)
type BadRequestError struct {
Message string `json:"message,required"`
}
// CancelExternalWorkflowExecutionFailedCause is an internal type (TBD...)
type CancelExternalWorkflowExecutionFailedCause int32
// Ptr is a helper function for getting pointer value
func (e CancelExternalWorkflowExecutionFailedCause) Ptr() *CancelExternalWorkflowExecutionFailedCause {
return &e
}
// String returns a readable string representation of CancelExternalWorkflowExecutionFailedCause.
func (e CancelExternalWorkflowExecutionFailedCause) String() string {
w := int32(e)
switch w {
case 0:
return "UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION"
}
return fmt.Sprintf("CancelExternalWorkflowExecutionFailedCause(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *CancelExternalWorkflowExecutionFailedCause) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION":
*e = CancelExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "CancelExternalWorkflowExecutionFailedCause", err)
}
*e = CancelExternalWorkflowExecutionFailedCause(val)
return nil
}
}
// MarshalText encodes CancelExternalWorkflowExecutionFailedCause to text.
func (e CancelExternalWorkflowExecutionFailedCause) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// CancelExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution is an option for CancelExternalWorkflowExecutionFailedCause
CancelExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution CancelExternalWorkflowExecutionFailedCause = iota
)
// CancelTimerDecisionAttributes is an internal type (TBD...)
type CancelTimerDecisionAttributes struct {
TimerID string `json:"timerId,omitempty"`
}
// GetTimerID is an internal getter (TBD...)
func (v *CancelTimerDecisionAttributes) GetTimerID() (o string) {
if v != nil {
return v.TimerID
}
return
}
// CancelTimerFailedEventAttributes is an internal type (TBD...)
type CancelTimerFailedEventAttributes struct {
TimerID string `json:"timerId,omitempty"`
Cause string `json:"cause,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
Identity string `json:"identity,omitempty"`
}
// CancelWorkflowExecutionDecisionAttributes is an internal type (TBD...)
type CancelWorkflowExecutionDecisionAttributes struct {
Details []byte `json:"details,omitempty"`
}
// CancellationAlreadyRequestedError is an internal type (TBD...)
type CancellationAlreadyRequestedError struct {
Message string `json:"message,required"`
}
// ChildWorkflowExecutionCanceledEventAttributes is an internal type (TBD...)
type ChildWorkflowExecutionCanceledEventAttributes struct {
Details []byte `json:"details,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *ChildWorkflowExecutionCanceledEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// ChildWorkflowExecutionCompletedEventAttributes is an internal type (TBD...)
type ChildWorkflowExecutionCompletedEventAttributes struct {
Result []byte `json:"result,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *ChildWorkflowExecutionCompletedEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// ChildWorkflowExecutionFailedCause is an internal type (TBD...)
type ChildWorkflowExecutionFailedCause int32
// Ptr is a helper function for getting pointer value
func (e ChildWorkflowExecutionFailedCause) Ptr() *ChildWorkflowExecutionFailedCause {
return &e
}
// String returns a readable string representation of ChildWorkflowExecutionFailedCause.
func (e ChildWorkflowExecutionFailedCause) String() string {
w := int32(e)
switch w {
case 0:
return "WORKFLOW_ALREADY_RUNNING"
}
return fmt.Sprintf("ChildWorkflowExecutionFailedCause(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *ChildWorkflowExecutionFailedCause) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "WORKFLOW_ALREADY_RUNNING":
*e = ChildWorkflowExecutionFailedCauseWorkflowAlreadyRunning
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "ChildWorkflowExecutionFailedCause", err)
}
*e = ChildWorkflowExecutionFailedCause(val)
return nil
}
}
// MarshalText encodes ChildWorkflowExecutionFailedCause to text.
func (e ChildWorkflowExecutionFailedCause) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// ChildWorkflowExecutionFailedCauseWorkflowAlreadyRunning is an option for ChildWorkflowExecutionFailedCause
ChildWorkflowExecutionFailedCauseWorkflowAlreadyRunning ChildWorkflowExecutionFailedCause = iota
)
// ChildWorkflowExecutionFailedEventAttributes is an internal type (TBD...)
type ChildWorkflowExecutionFailedEventAttributes struct {
Reason *string `json:"reason,omitempty"`
Details []byte `json:"details,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *ChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// ChildWorkflowExecutionStartedEventAttributes is an internal type (TBD...)
type ChildWorkflowExecutionStartedEventAttributes struct {
Domain string `json:"domain,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
Header *Header `json:"header,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *ChildWorkflowExecutionStartedEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *ChildWorkflowExecutionStartedEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *ChildWorkflowExecutionStartedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// ChildWorkflowExecutionTerminatedEventAttributes is an internal type (TBD...)
type ChildWorkflowExecutionTerminatedEventAttributes struct {
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *ChildWorkflowExecutionTerminatedEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// ChildWorkflowExecutionTimedOutEventAttributes is an internal type (TBD...)
type ChildWorkflowExecutionTimedOutEventAttributes struct {
TimeoutType *TimeoutType `json:"timeoutType,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *ChildWorkflowExecutionTimedOutEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// ClientVersionNotSupportedError is an internal type (TBD...)
type ClientVersionNotSupportedError struct {
FeatureVersion string `json:"featureVersion,required"`
ClientImpl string `json:"clientImpl,required"`
SupportedVersions string `json:"supportedVersions,required"`
}
// FeatureNotEnabledError is an internal type (TBD...)
type FeatureNotEnabledError struct {
FeatureFlag string `json:"featureFlag,required"`
}
// CloseShardRequest is an internal type (TBD...)
type CloseShardRequest struct {
ShardID int32 `json:"shardID,omitempty"`
}
func (v *CloseShardRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetShardID is an internal getter (TBD...)
func (v *CloseShardRequest) GetShardID() (o int32) {
if v != nil {
return v.ShardID
}
return
}
// ClusterInfo is an internal type (TBD...)
type ClusterInfo struct {
SupportedClientVersions *SupportedClientVersions `json:"supportedClientVersions,omitempty"`
}
// ClusterReplicationConfiguration is an internal type (TBD...)
type ClusterReplicationConfiguration struct {
ClusterName string `json:"clusterName,omitempty"`
}
// GetClusterName is an internal getter (TBD...)
func (v *ClusterReplicationConfiguration) GetClusterName() (o string) {
if v != nil {
return v.ClusterName
}
return
}
// CompleteWorkflowExecutionDecisionAttributes is an internal type (TBD...)
type CompleteWorkflowExecutionDecisionAttributes struct {
Result []byte `json:"result,omitempty"`
}
// ContinueAsNewInitiator is an internal type (TBD...)
type ContinueAsNewInitiator int32
// Ptr is a helper function for getting pointer value
func (e ContinueAsNewInitiator) Ptr() *ContinueAsNewInitiator {
return &e
}
// String returns a readable string representation of ContinueAsNewInitiator.
func (e ContinueAsNewInitiator) String() string {
w := int32(e)
switch w {
case 0:
return "Decider"
case 1:
return "RetryPolicy"
case 2:
return "CronSchedule"
}
return fmt.Sprintf("ContinueAsNewInitiator(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *ContinueAsNewInitiator) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "DECIDER":
*e = ContinueAsNewInitiatorDecider
return nil
case "RETRYPOLICY":
*e = ContinueAsNewInitiatorRetryPolicy
return nil
case "CRONSCHEDULE":
*e = ContinueAsNewInitiatorCronSchedule
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "ContinueAsNewInitiator", err)
}
*e = ContinueAsNewInitiator(val)
return nil
}
}
// MarshalText encodes ContinueAsNewInitiator to text.
func (e ContinueAsNewInitiator) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// ContinueAsNewInitiatorDecider is an option for ContinueAsNewInitiator
ContinueAsNewInitiatorDecider ContinueAsNewInitiator = iota
// ContinueAsNewInitiatorRetryPolicy is an option for ContinueAsNewInitiator
ContinueAsNewInitiatorRetryPolicy
// ContinueAsNewInitiatorCronSchedule is an option for ContinueAsNewInitiator
ContinueAsNewInitiatorCronSchedule
)
// ContinueAsNewWorkflowExecutionDecisionAttributes is an internal type (TBD...)
type ContinueAsNewWorkflowExecutionDecisionAttributes struct {
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"input,omitempty"`
ExecutionStartToCloseTimeoutSeconds *int32 `json:"executionStartToCloseTimeoutSeconds,omitempty"`
TaskStartToCloseTimeoutSeconds *int32 `json:"taskStartToCloseTimeoutSeconds,omitempty"`
BackoffStartIntervalInSeconds *int32 `json:"backoffStartIntervalInSeconds,omitempty"`
RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
Initiator *ContinueAsNewInitiator `json:"initiator,omitempty"`
FailureReason *string `json:"failureReason,omitempty"`
FailureDetails []byte `json:"failureDetails,omitempty"`
LastCompletionResult []byte `json:"lastCompletionResult,omitempty"`
CronSchedule string `json:"cronSchedule,omitempty"`
Header *Header `json:"header,omitempty"`
Memo *Memo `json:"memo,omitempty"`
SearchAttributes *SearchAttributes `json:"searchAttributes,omitempty"`
JitterStartSeconds *int32 `json:"jitterStartSeconds,omitempty"`
}
// GetExecutionStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetExecutionStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.ExecutionStartToCloseTimeoutSeconds != nil {
return *v.ExecutionStartToCloseTimeoutSeconds
}
return
}
// GetTaskStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetTaskStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.TaskStartToCloseTimeoutSeconds != nil {
return *v.TaskStartToCloseTimeoutSeconds
}
return
}
// GetBackoffStartIntervalInSeconds is an internal getter (TBD...)
func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetBackoffStartIntervalInSeconds() (o int32) {
if v != nil && v.BackoffStartIntervalInSeconds != nil {
return *v.BackoffStartIntervalInSeconds
}
return
}
// GetJitterStartSeconds is an internal getter (TBD...)
func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetJitterStartSeconds() (o int32) {
if v != nil && v.JitterStartSeconds != nil {
return *v.JitterStartSeconds
}
return
}
// GetInitiator is an internal getter (TBD...)
func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetInitiator() (o ContinueAsNewInitiator) {
if v != nil && v.Initiator != nil {
return *v.Initiator
}
return
}
// GetSearchAttributes is an internal getter (TBD...)
func (v *ContinueAsNewWorkflowExecutionDecisionAttributes) GetSearchAttributes() (o *SearchAttributes) {
if v != nil && v.SearchAttributes != nil {
return v.SearchAttributes
}
return
}
// CountWorkflowExecutionsRequest is an internal type (TBD...)
type CountWorkflowExecutionsRequest struct {
Domain string `json:"domain,omitempty"`
Query string `json:"query,omitempty"`
}
func (v *CountWorkflowExecutionsRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *CountWorkflowExecutionsRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetQuery is an internal getter (TBD...)
func (v *CountWorkflowExecutionsRequest) GetQuery() (o string) {
if v != nil {
return v.Query
}
return
}
// CountWorkflowExecutionsResponse is an internal type (TBD...)
type CountWorkflowExecutionsResponse struct {
Count int64 `json:"count,omitempty"`
}
// GetCount is an internal getter (TBD...)
func (v *CountWorkflowExecutionsResponse) GetCount() (o int64) {
if v != nil {
return v.Count
}
return
}
// CurrentBranchChangedError is an internal type (TBD...)
type CurrentBranchChangedError struct {
Message string `json:"message,required"`
CurrentBranchToken []byte `json:"currentBranchToken,required"`
}
// GetCurrentBranchToken is an internal getter (TBD...)
func (v *CurrentBranchChangedError) GetCurrentBranchToken() (o []byte) {
if v != nil && v.CurrentBranchToken != nil {
return v.CurrentBranchToken
}
return
}
// DataBlob is an internal type (TBD...)
type DataBlob struct {
EncodingType *EncodingType `json:"EncodingType,omitempty"`
Data []byte `json:"Data,omitempty"`
}
// GetEncodingType is an internal getter (TBD...)
func (v *DataBlob) GetEncodingType() (o EncodingType) {
if v != nil && v.EncodingType != nil {
return *v.EncodingType
}
return
}
// GetData is an internal getter (TBD...)
func (v *DataBlob) GetData() (o []byte) {
if v != nil && v.Data != nil {
return v.Data
}
return
}
func (v *DataBlob) DeepCopy() *DataBlob {
if v == nil {
return nil
}
res := &DataBlob{
EncodingType: v.EncodingType,
}
if v.Data != nil {
res.Data = make([]byte, len(v.Data))
copy(res.Data, v.Data)
}
return res
}
// Decision is an internal type (TBD...)
type Decision struct {
DecisionType *DecisionType `json:"decisionType,omitempty"`
ScheduleActivityTaskDecisionAttributes *ScheduleActivityTaskDecisionAttributes `json:"scheduleActivityTaskDecisionAttributes,omitempty"`
StartTimerDecisionAttributes *StartTimerDecisionAttributes `json:"startTimerDecisionAttributes,omitempty"`
CompleteWorkflowExecutionDecisionAttributes *CompleteWorkflowExecutionDecisionAttributes `json:"completeWorkflowExecutionDecisionAttributes,omitempty"`
FailWorkflowExecutionDecisionAttributes *FailWorkflowExecutionDecisionAttributes `json:"failWorkflowExecutionDecisionAttributes,omitempty"`
RequestCancelActivityTaskDecisionAttributes *RequestCancelActivityTaskDecisionAttributes `json:"requestCancelActivityTaskDecisionAttributes,omitempty"`
CancelTimerDecisionAttributes *CancelTimerDecisionAttributes `json:"cancelTimerDecisionAttributes,omitempty"`
CancelWorkflowExecutionDecisionAttributes *CancelWorkflowExecutionDecisionAttributes `json:"cancelWorkflowExecutionDecisionAttributes,omitempty"`
RequestCancelExternalWorkflowExecutionDecisionAttributes *RequestCancelExternalWorkflowExecutionDecisionAttributes `json:"requestCancelExternalWorkflowExecutionDecisionAttributes,omitempty"`
RecordMarkerDecisionAttributes *RecordMarkerDecisionAttributes `json:"recordMarkerDecisionAttributes,omitempty"`
ContinueAsNewWorkflowExecutionDecisionAttributes *ContinueAsNewWorkflowExecutionDecisionAttributes `json:"continueAsNewWorkflowExecutionDecisionAttributes,omitempty"`
StartChildWorkflowExecutionDecisionAttributes *StartChildWorkflowExecutionDecisionAttributes `json:"startChildWorkflowExecutionDecisionAttributes,omitempty"`
SignalExternalWorkflowExecutionDecisionAttributes *SignalExternalWorkflowExecutionDecisionAttributes `json:"signalExternalWorkflowExecutionDecisionAttributes,omitempty"`
UpsertWorkflowSearchAttributesDecisionAttributes *UpsertWorkflowSearchAttributesDecisionAttributes `json:"upsertWorkflowSearchAttributesDecisionAttributes,omitempty"`
}
// GetDecisionType is an internal getter (TBD...)
func (v *Decision) GetDecisionType() (o DecisionType) {
if v != nil && v.DecisionType != nil {
return *v.DecisionType
}
return
}
// DecisionTaskCompletedEventAttributes is an internal type (TBD...)
type DecisionTaskCompletedEventAttributes struct {
ExecutionContext []byte `json:"executionContext,omitempty"`
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
Identity string `json:"identity,omitempty"`
BinaryChecksum string `json:"binaryChecksum,omitempty"`
}
// GetStartedEventID is an internal getter (TBD...)
func (v *DecisionTaskCompletedEventAttributes) GetStartedEventID() (o int64) {
if v != nil {
return v.StartedEventID
}
return
}
// GetBinaryChecksum is an internal getter (TBD...)
func (v *DecisionTaskCompletedEventAttributes) GetBinaryChecksum() (o string) {
if v != nil {
return v.BinaryChecksum
}
return
}
// DecisionTaskFailedCause is an internal type (TBD...)
type DecisionTaskFailedCause int32
// Ptr is a helper function for getting pointer value
func (e DecisionTaskFailedCause) Ptr() *DecisionTaskFailedCause {
return &e
}
// String returns a readable string representation of DecisionTaskFailedCause.
func (e DecisionTaskFailedCause) String() string {
w := int32(e)
switch w {
case 0:
return "UNHANDLED_DECISION"
case 1:
return "BAD_SCHEDULE_ACTIVITY_ATTRIBUTES"
case 2:
return "BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES"
case 3:
return "BAD_START_TIMER_ATTRIBUTES"
case 4:
return "BAD_CANCEL_TIMER_ATTRIBUTES"
case 5:
return "BAD_RECORD_MARKER_ATTRIBUTES"
case 6:
return "BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES"
case 7:
return "BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES"
case 8:
return "BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES"
case 9:
return "BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES"
case 10:
return "BAD_CONTINUE_AS_NEW_ATTRIBUTES"
case 11:
return "START_TIMER_DUPLICATE_I_D"
case 12:
return "RESET_STICKY_TASKLIST"
case 13:
return "WORKFLOW_WORKER_UNHANDLED_FAILURE"
case 14:
return "BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES"
case 15:
return "BAD_START_CHILD_EXECUTION_ATTRIBUTES"
case 16:
return "FORCE_CLOSE_DECISION"
case 17:
return "FAILOVER_CLOSE_DECISION"
case 18:
return "BAD_SIGNAL_INPUT_SIZE"
case 19:
return "RESET_WORKFLOW"
case 20:
return "BAD_BINARY"
case 21:
return "SCHEDULE_ACTIVITY_DUPLICATE_I_D"
case 22:
return "BAD_SEARCH_ATTRIBUTES"
}
return fmt.Sprintf("DecisionTaskFailedCause(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *DecisionTaskFailedCause) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "UNHANDLED_DECISION":
*e = DecisionTaskFailedCauseUnhandledDecision
return nil
case "BAD_SCHEDULE_ACTIVITY_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadScheduleActivityAttributes
return nil
case "BAD_REQUEST_CANCEL_ACTIVITY_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadRequestCancelActivityAttributes
return nil
case "BAD_START_TIMER_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadStartTimerAttributes
return nil
case "BAD_CANCEL_TIMER_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadCancelTimerAttributes
return nil
case "BAD_RECORD_MARKER_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadRecordMarkerAttributes
return nil
case "BAD_COMPLETE_WORKFLOW_EXECUTION_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadCompleteWorkflowExecutionAttributes
return nil
case "BAD_FAIL_WORKFLOW_EXECUTION_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadFailWorkflowExecutionAttributes
return nil
case "BAD_CANCEL_WORKFLOW_EXECUTION_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadCancelWorkflowExecutionAttributes
return nil
case "BAD_REQUEST_CANCEL_EXTERNAL_WORKFLOW_EXECUTION_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadRequestCancelExternalWorkflowExecutionAttributes
return nil
case "BAD_CONTINUE_AS_NEW_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadContinueAsNewAttributes
return nil
case "START_TIMER_DUPLICATE_I_D":
*e = DecisionTaskFailedCauseStartTimerDuplicateID
return nil
case "RESET_STICKY_TASKLIST":
*e = DecisionTaskFailedCauseResetStickyTasklist
return nil
case "WORKFLOW_WORKER_UNHANDLED_FAILURE":
*e = DecisionTaskFailedCauseWorkflowWorkerUnhandledFailure
return nil
case "BAD_SIGNAL_WORKFLOW_EXECUTION_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadSignalWorkflowExecutionAttributes
return nil
case "BAD_START_CHILD_EXECUTION_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadStartChildExecutionAttributes
return nil
case "FORCE_CLOSE_DECISION":
*e = DecisionTaskFailedCauseForceCloseDecision
return nil
case "FAILOVER_CLOSE_DECISION":
*e = DecisionTaskFailedCauseFailoverCloseDecision
return nil
case "BAD_SIGNAL_INPUT_SIZE":
*e = DecisionTaskFailedCauseBadSignalInputSize
return nil
case "RESET_WORKFLOW":
*e = DecisionTaskFailedCauseResetWorkflow
return nil
case "BAD_BINARY":
*e = DecisionTaskFailedCauseBadBinary
return nil
case "SCHEDULE_ACTIVITY_DUPLICATE_I_D":
*e = DecisionTaskFailedCauseScheduleActivityDuplicateID
return nil
case "BAD_SEARCH_ATTRIBUTES":
*e = DecisionTaskFailedCauseBadSearchAttributes
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "DecisionTaskFailedCause", err)
}
*e = DecisionTaskFailedCause(val)
return nil
}
}
// MarshalText encodes DecisionTaskFailedCause to text.
func (e DecisionTaskFailedCause) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// DecisionTaskFailedCauseUnhandledDecision is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseUnhandledDecision DecisionTaskFailedCause = iota
// DecisionTaskFailedCauseBadScheduleActivityAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadScheduleActivityAttributes
// DecisionTaskFailedCauseBadRequestCancelActivityAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadRequestCancelActivityAttributes
// DecisionTaskFailedCauseBadStartTimerAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadStartTimerAttributes
// DecisionTaskFailedCauseBadCancelTimerAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadCancelTimerAttributes
// DecisionTaskFailedCauseBadRecordMarkerAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadRecordMarkerAttributes
// DecisionTaskFailedCauseBadCompleteWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadCompleteWorkflowExecutionAttributes
// DecisionTaskFailedCauseBadFailWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadFailWorkflowExecutionAttributes
// DecisionTaskFailedCauseBadCancelWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadCancelWorkflowExecutionAttributes
// DecisionTaskFailedCauseBadRequestCancelExternalWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadRequestCancelExternalWorkflowExecutionAttributes
// DecisionTaskFailedCauseBadContinueAsNewAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadContinueAsNewAttributes
// DecisionTaskFailedCauseStartTimerDuplicateID is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseStartTimerDuplicateID
// DecisionTaskFailedCauseResetStickyTasklist is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseResetStickyTasklist
// DecisionTaskFailedCauseWorkflowWorkerUnhandledFailure is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseWorkflowWorkerUnhandledFailure
// DecisionTaskFailedCauseBadSignalWorkflowExecutionAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadSignalWorkflowExecutionAttributes
// DecisionTaskFailedCauseBadStartChildExecutionAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadStartChildExecutionAttributes
// DecisionTaskFailedCauseForceCloseDecision is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseForceCloseDecision
// DecisionTaskFailedCauseFailoverCloseDecision is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseFailoverCloseDecision
// DecisionTaskFailedCauseBadSignalInputSize is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadSignalInputSize
// DecisionTaskFailedCauseResetWorkflow is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseResetWorkflow
// DecisionTaskFailedCauseBadBinary is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadBinary
// DecisionTaskFailedCauseScheduleActivityDuplicateID is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseScheduleActivityDuplicateID
// DecisionTaskFailedCauseBadSearchAttributes is an option for DecisionTaskFailedCause
DecisionTaskFailedCauseBadSearchAttributes
)
// DecisionTaskFailedEventAttributes is an internal type (TBD...)
type DecisionTaskFailedEventAttributes struct {
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
Cause *DecisionTaskFailedCause `json:"cause,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
Reason *string `json:"reason,omitempty"`
BaseRunID string `json:"baseRunId,omitempty"`
NewRunID string `json:"newRunId,omitempty"`
ForkEventVersion int64 `json:"forkEventVersion,omitempty"`
BinaryChecksum string `json:"binaryChecksum,omitempty"`
RequestID string `json:"requestId,omitempty"`
}
// GetCause is an internal getter (TBD...)
func (v *DecisionTaskFailedEventAttributes) GetCause() (o DecisionTaskFailedCause) {
if v != nil && v.Cause != nil {
return *v.Cause
}
return
}
// GetDetails is an internal getter (TBD...)
func (v *DecisionTaskFailedEventAttributes) GetDetails() (o []byte) {
if v != nil && v.Details != nil {
return v.Details
}
return
}
// GetBaseRunID is an internal getter (TBD...)
func (v *DecisionTaskFailedEventAttributes) GetBaseRunID() (o string) {
if v != nil {
return v.BaseRunID
}
return
}
// GetNewRunID is an internal getter (TBD...)
func (v *DecisionTaskFailedEventAttributes) GetNewRunID() (o string) {
if v != nil {
return v.NewRunID
}
return
}
// GetForkEventVersion is an internal getter (TBD...)
func (v *DecisionTaskFailedEventAttributes) GetForkEventVersion() (o int64) {
if v != nil {
return v.ForkEventVersion
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *DecisionTaskFailedEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// DecisionTaskScheduledEventAttributes is an internal type (TBD...)
type DecisionTaskScheduledEventAttributes struct {
TaskList *TaskList `json:"taskList,omitempty"`
StartToCloseTimeoutSeconds *int32 `json:"startToCloseTimeoutSeconds,omitempty"`
Attempt int64 `json:"attempt,omitempty"`
}
// GetTaskList is an internal getter (TBD...)
func (v *DecisionTaskScheduledEventAttributes) GetTaskList() (o *TaskList) {
if v != nil && v.TaskList != nil {
return v.TaskList
}
return
}
// GetStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *DecisionTaskScheduledEventAttributes) GetStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.StartToCloseTimeoutSeconds != nil {
return *v.StartToCloseTimeoutSeconds
}
return
}
// GetAttempt is an internal getter (TBD...)
func (v *DecisionTaskScheduledEventAttributes) GetAttempt() (o int64) {
if v != nil {
return v.Attempt
}
return
}
// DecisionTaskStartedEventAttributes is an internal type (TBD...)
type DecisionTaskStartedEventAttributes struct {
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
}
// GetScheduledEventID is an internal getter (TBD...)
func (v *DecisionTaskStartedEventAttributes) GetScheduledEventID() (o int64) {
if v != nil {
return v.ScheduledEventID
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *DecisionTaskStartedEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// DecisionTaskTimedOutCause is an internal type (TBD...)
type DecisionTaskTimedOutCause int32
// Ptr is a helper function for getting pointer value
func (e DecisionTaskTimedOutCause) Ptr() *DecisionTaskTimedOutCause {
return &e
}
// String returns a readable string representation of DecisionTaskTimedOutCause.
func (e DecisionTaskTimedOutCause) String() string {
w := int32(e)
switch w {
case 0:
return "Timeout"
case 1:
return "Reset"
}
return fmt.Sprintf("DecisionTaskTimedOutCause(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *DecisionTaskTimedOutCause) UnmarshalText(value []byte) error {
switch s := strings.ToLower(string(value)); s {
case "timeout":
*e = DecisionTaskTimedOutCauseTimeout
return nil
case "reset":
*e = DecisionTaskTimedOutCauseReset
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "DecisionTaskTimedOutCause", err)
}
*e = DecisionTaskTimedOutCause(val)
return nil
}
}
// MarshalText encodes DecisionTaskFailedCause to text.
func (e DecisionTaskTimedOutCause) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// DecisionTaskTimedOutCauseTimeout is an option for DecisionTaskTimedOutCause
DecisionTaskTimedOutCauseTimeout DecisionTaskTimedOutCause = iota
// DecisionTaskTimedOutCauseReset is an option for DecisionTaskTimedOutCause
DecisionTaskTimedOutCauseReset
)
// DecisionTaskTimedOutEventAttributes is an internal type (TBD...)
type DecisionTaskTimedOutEventAttributes struct {
ScheduledEventID int64 `json:"scheduledEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
TimeoutType *TimeoutType `json:"timeoutType,omitempty"`
BaseRunID string `json:"baseRunId,omitempty"`
NewRunID string `json:"newRunId,omitempty"`
ForkEventVersion int64 `json:"forkEventVersion,omitempty"`
Reason string `json:"reason,omitempty"`
Cause *DecisionTaskTimedOutCause `json:"cause,omitempty"`
RequestID string `json:"requestId,omitempty"`
}
// GetScheduledEventID is an internal getter (TBD...)
func (v *DecisionTaskTimedOutEventAttributes) GetScheduledEventID() (o int64) {
if v != nil {
return v.ScheduledEventID
}
return
}
// GetTimeoutType is an internal getter (TBD...)
func (v *DecisionTaskTimedOutEventAttributes) GetTimeoutType() (o TimeoutType) {
if v != nil && v.TimeoutType != nil {
return *v.TimeoutType
}
return
}
// GetBaseRunID is an internal getter (TBD...)
func (v *DecisionTaskTimedOutEventAttributes) GetBaseRunID() (o string) {
if v != nil {
return v.BaseRunID
}
return
}
// GetNewRunID is an internal getter (TBD...)
func (v *DecisionTaskTimedOutEventAttributes) GetNewRunID() (o string) {
if v != nil {
return v.NewRunID
}
return
}
// GetForkEventVersion is an internal getter (TBD...)
func (v *DecisionTaskTimedOutEventAttributes) GetForkEventVersion() (o int64) {
if v != nil {
return v.ForkEventVersion
}
return
}
// GetCause is an internal getter (TBD...)
func (v *DecisionTaskTimedOutEventAttributes) GetCause() (o DecisionTaskTimedOutCause) {
if v != nil && v.Cause != nil {
return *v.Cause
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *DecisionTaskTimedOutEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// DecisionType is an internal type (TBD...)
type DecisionType int32
// Ptr is a helper function for getting pointer value
func (e DecisionType) Ptr() *DecisionType {
return &e
}
// String returns a readable string representation of DecisionType.
func (e DecisionType) String() string {
w := int32(e)
switch w {
case 0:
return "ScheduleActivityTask"
case 1:
return "RequestCancelActivityTask"
case 2:
return "StartTimer"
case 3:
return "CompleteWorkflowExecution"
case 4:
return "FailWorkflowExecution"
case 5:
return "CancelTimer"
case 6:
return "CancelWorkflowExecution"
case 7:
return "RequestCancelExternalWorkflowExecution"
case 8:
return "RecordMarker"
case 9:
return "ContinueAsNewWorkflowExecution"
case 10:
return "StartChildWorkflowExecution"
case 11:
return "SignalExternalWorkflowExecution"
case 12:
return "UpsertWorkflowSearchAttributes"
}
return fmt.Sprintf("DecisionType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *DecisionType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "SCHEDULEACTIVITYTASK":
*e = DecisionTypeScheduleActivityTask
return nil
case "REQUESTCANCELACTIVITYTASK":
*e = DecisionTypeRequestCancelActivityTask
return nil
case "STARTTIMER":
*e = DecisionTypeStartTimer
return nil
case "COMPLETEWORKFLOWEXECUTION":
*e = DecisionTypeCompleteWorkflowExecution
return nil
case "FAILWORKFLOWEXECUTION":
*e = DecisionTypeFailWorkflowExecution
return nil
case "CANCELTIMER":
*e = DecisionTypeCancelTimer
return nil
case "CANCELWORKFLOWEXECUTION":
*e = DecisionTypeCancelWorkflowExecution
return nil
case "REQUESTCANCELEXTERNALWORKFLOWEXECUTION":
*e = DecisionTypeRequestCancelExternalWorkflowExecution
return nil
case "RECORDMARKER":
*e = DecisionTypeRecordMarker
return nil
case "CONTINUEASNEWWORKFLOWEXECUTION":
*e = DecisionTypeContinueAsNewWorkflowExecution
return nil
case "STARTCHILDWORKFLOWEXECUTION":
*e = DecisionTypeStartChildWorkflowExecution
return nil
case "SIGNALEXTERNALWORKFLOWEXECUTION":
*e = DecisionTypeSignalExternalWorkflowExecution
return nil
case "UPSERTWORKFLOWSEARCHATTRIBUTES":
*e = DecisionTypeUpsertWorkflowSearchAttributes
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "DecisionType", err)
}
*e = DecisionType(val)
return nil
}
}
// MarshalText encodes DecisionType to text.
func (e DecisionType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// DecisionTypeScheduleActivityTask is an option for DecisionType
DecisionTypeScheduleActivityTask DecisionType = iota
// DecisionTypeRequestCancelActivityTask is an option for DecisionType
DecisionTypeRequestCancelActivityTask
// DecisionTypeStartTimer is an option for DecisionType
DecisionTypeStartTimer
// DecisionTypeCompleteWorkflowExecution is an option for DecisionType
DecisionTypeCompleteWorkflowExecution
// DecisionTypeFailWorkflowExecution is an option for DecisionType
DecisionTypeFailWorkflowExecution
// DecisionTypeCancelTimer is an option for DecisionType
DecisionTypeCancelTimer
// DecisionTypeCancelWorkflowExecution is an option for DecisionType
DecisionTypeCancelWorkflowExecution
// DecisionTypeRequestCancelExternalWorkflowExecution is an option for DecisionType
DecisionTypeRequestCancelExternalWorkflowExecution
// DecisionTypeRecordMarker is an option for DecisionType
DecisionTypeRecordMarker
// DecisionTypeContinueAsNewWorkflowExecution is an option for DecisionType
DecisionTypeContinueAsNewWorkflowExecution
// DecisionTypeStartChildWorkflowExecution is an option for DecisionType
DecisionTypeStartChildWorkflowExecution
// DecisionTypeSignalExternalWorkflowExecution is an option for DecisionType
DecisionTypeSignalExternalWorkflowExecution
// DecisionTypeUpsertWorkflowSearchAttributes is an option for DecisionType
DecisionTypeUpsertWorkflowSearchAttributes
)
// DeprecateDomainRequest is an internal type (TBD...)
type DeprecateDomainRequest struct {
Name string `json:"name,omitempty"`
SecurityToken string `json:"securityToken,omitempty"`
}
func (v *DeprecateDomainRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetName is an internal getter (TBD...)
func (v *DeprecateDomainRequest) GetName() (o string) {
if v != nil {
return v.Name
}
return
}
// DescribeDomainRequest is an internal type (TBD...)
type DescribeDomainRequest struct {
Name *string `json:"name,omitempty"`
UUID *string `json:"uuid,omitempty"`
}
func (v *DescribeDomainRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetName is an internal getter (TBD...)
func (v *DescribeDomainRequest) GetName() (o string) {
if v != nil && v.Name != nil {
return *v.Name
}
return
}
// GetUUID is an internal getter (TBD...)
func (v *DescribeDomainRequest) GetUUID() (o string) {
if v != nil && v.UUID != nil {
return *v.UUID
}
return
}
// DescribeDomainResponse is an internal type (TBD...)
type DescribeDomainResponse struct {
DomainInfo *DomainInfo `json:"domainInfo,omitempty"`
Configuration *DomainConfiguration `json:"configuration,omitempty"`
ReplicationConfiguration *DomainReplicationConfiguration `json:"replicationConfiguration,omitempty"`
FailoverVersion int64 `json:"failoverVersion,omitempty"`
IsGlobalDomain bool `json:"isGlobalDomain,omitempty"`
FailoverInfo *FailoverInfo `json:"failoverInfo,omitempty"`
}
// GetDomainInfo is an internal getter (TBD...)
func (v *DescribeDomainResponse) GetDomainInfo() (o *DomainInfo) {
if v != nil && v.DomainInfo != nil {
return v.DomainInfo
}
return
}
// GetFailoverVersion is an internal getter (TBD...)
func (v *DescribeDomainResponse) GetFailoverVersion() (o int64) {
if v != nil {
return v.FailoverVersion
}
return
}
// GetIsGlobalDomain is an internal getter (TBD...)
func (v *DescribeDomainResponse) GetIsGlobalDomain() (o bool) {
if v != nil {
return v.IsGlobalDomain
}
return
}
// GetFailoverInfo is an internal getter (TBD...)
func (v *DescribeDomainResponse) GetFailoverInfo() (o *FailoverInfo) {
if v != nil {
return v.FailoverInfo
}
return
}
// DescribeHistoryHostRequest is an internal type (TBD...)
type DescribeHistoryHostRequest struct {
HostAddress *string `json:"hostAddress,omitempty"`
ShardIDForHost *int32 `json:"shardIdForHost,omitempty"`
ExecutionForHost *WorkflowExecution `json:"executionForHost,omitempty"`
}
func (v *DescribeHistoryHostRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// DescribeShardDistributionRequest is an internal type (TBD...)
type DescribeShardDistributionRequest struct {
PageSize int32 `json:"pageSize,omitempty"`
PageID int32 `json:"pageID,omitempty"`
}
func (v *DescribeShardDistributionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetHostAddress is an internal getter (TBD...)
func (v *DescribeHistoryHostRequest) GetHostAddress() (o string) {
if v != nil && v.HostAddress != nil {
return *v.HostAddress
}
return
}
// GetShardIDForHost is an internal getter (TBD...)
func (v *DescribeHistoryHostRequest) GetShardIDForHost() (o int32) {
if v != nil && v.ShardIDForHost != nil {
return *v.ShardIDForHost
}
return
}
// DescribeShardDistributionResponse is an internal type (TBD...)
type DescribeShardDistributionResponse struct {
NumberOfShards int32 `json:"numberOfShards,omitempty"`
Shards map[int32]string `json:"shardIDs,omitempty"`
}
// DescribeHistoryHostResponse is an internal type (TBD...)
type DescribeHistoryHostResponse struct {
NumberOfShards int32 `json:"numberOfShards,omitempty"`
ShardIDs []int32 `json:"shardIDs,omitempty"`
DomainCache *DomainCacheInfo `json:"domainCache,omitempty"`
ShardControllerStatus string `json:"shardControllerStatus,omitempty"`
Address string `json:"address,omitempty"`
}
// DescribeQueueRequest is an internal type (TBD...)
type DescribeQueueRequest struct {
ShardID int32 `json:"shardID,omitempty"`
ClusterName string `json:"clusterName,omitempty"`
Type *int32 `json:"type,omitempty"`
}
func (v *DescribeQueueRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetShardID is an internal getter (TBD...)
func (v *DescribeQueueRequest) GetShardID() (o int32) {
if v != nil {
return v.ShardID
}
return
}
// GetClusterName is an internal getter (TBD...)
func (v *DescribeQueueRequest) GetClusterName() (o string) {
if v != nil {
return v.ClusterName
}
return
}
// GetType is an internal getter (TBD...)
func (v *DescribeQueueRequest) GetType() (o int32) {
if v != nil && v.Type != nil {
return *v.Type
}
return
}
// DescribeQueueResponse is an internal type (TBD...)
type DescribeQueueResponse struct {
ProcessingQueueStates []string `json:"processingQueueStates,omitempty"`
}
// DescribeTaskListRequest is an internal type (TBD...)
type DescribeTaskListRequest struct {
Domain string `json:"domain,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
TaskListType *TaskListType `json:"taskListType,omitempty"`
IncludeTaskListStatus bool `json:"includeTaskListStatus,omitempty"`
}
func (v *DescribeTaskListRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *DescribeTaskListRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetTaskList is an internal getter (TBD...)
func (v *DescribeTaskListRequest) GetTaskList() (o *TaskList) {
if v != nil && v.TaskList != nil {
return v.TaskList
}
return
}
// GetTaskListType is an internal getter (TBD...)
func (v *DescribeTaskListRequest) GetTaskListType() (o TaskListType) {
if v != nil && v.TaskListType != nil {
return *v.TaskListType
}
return
}
// GetIncludeTaskListStatus is an internal getter (TBD...)
func (v *DescribeTaskListRequest) GetIncludeTaskListStatus() (o bool) {
if v != nil {
return v.IncludeTaskListStatus
}
return
}
// DescribeTaskListResponse is an internal type (TBD...)
type DescribeTaskListResponse struct {
Pollers []*PollerInfo `json:"pollers,omitempty"`
TaskListStatus *TaskListStatus `json:"taskListStatus,omitempty"`
}
// GetPollers is an internal getter (TBD...)
func (v *DescribeTaskListResponse) GetPollers() (o []*PollerInfo) {
if v != nil && v.Pollers != nil {
return v.Pollers
}
return
}
// GetTaskListStatus is an internal getter (TBD...)
func (v *DescribeTaskListResponse) GetTaskListStatus() (o *TaskListStatus) {
if v != nil && v.TaskListStatus != nil {
return v.TaskListStatus
}
return
}
// DescribeWorkflowExecutionRequest is an internal type (TBD...)
type DescribeWorkflowExecutionRequest struct {
Domain string `json:"domain,omitempty"`
Execution *WorkflowExecution `json:"execution,omitempty"`
}
func (v *DescribeWorkflowExecutionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *DescribeWorkflowExecutionRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetExecution is an internal getter (TBD...)
func (v *DescribeWorkflowExecutionRequest) GetExecution() (o *WorkflowExecution) {
if v != nil && v.Execution != nil {
return v.Execution
}
return
}
// DescribeWorkflowExecutionResponse is an internal type (TBD...)
type DescribeWorkflowExecutionResponse struct {
ExecutionConfiguration *WorkflowExecutionConfiguration `json:"executionConfiguration,omitempty"`
WorkflowExecutionInfo *WorkflowExecutionInfo `json:"workflowExecutionInfo,omitempty"`
PendingActivities []*PendingActivityInfo `json:"pendingActivities,omitempty"`
PendingChildren []*PendingChildExecutionInfo `json:"pendingChildren,omitempty"`
PendingDecision *PendingDecisionInfo `json:"pendingDecision,omitempty"`
}
// GetWorkflowExecutionInfo is an internal getter (TBD...)
func (v *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() (o *WorkflowExecutionInfo) {
if v != nil && v.WorkflowExecutionInfo != nil {
return v.WorkflowExecutionInfo
}
return
}
// GetPendingActivities is an internal getter (TBD...)
func (v *DescribeWorkflowExecutionResponse) GetPendingActivities() (o []*PendingActivityInfo) {
if v != nil && v.PendingActivities != nil {
return v.PendingActivities
}
return
}
// DomainAlreadyExistsError is an internal type (TBD...)
type DomainAlreadyExistsError struct {
Message string `json:"message,required"`
}
// DomainCacheInfo is an internal type (TBD...)
type DomainCacheInfo struct {
NumOfItemsInCacheByID int64 `json:"numOfItemsInCacheByID,omitempty"`
NumOfItemsInCacheByName int64 `json:"numOfItemsInCacheByName,omitempty"`
}
// DomainConfiguration is an internal type (TBD...)
type DomainConfiguration struct {
WorkflowExecutionRetentionPeriodInDays int32 `json:"workflowExecutionRetentionPeriodInDays,omitempty"`
EmitMetric bool `json:"emitMetric,omitempty"`
BadBinaries *BadBinaries `json:"badBinaries,omitempty"`
HistoryArchivalStatus *ArchivalStatus `json:"historyArchivalStatus,omitempty"`
HistoryArchivalURI string `json:"historyArchivalURI,omitempty"`
VisibilityArchivalStatus *ArchivalStatus `json:"visibilityArchivalStatus,omitempty"`
VisibilityArchivalURI string `json:"visibilityArchivalURI,omitempty"`
IsolationGroups *IsolationGroupConfiguration `json:"isolationGroupConfiguration,omitempty"`
AsyncWorkflowConfig *AsyncWorkflowConfiguration `json:"asyncWorkflowConfiguration,omitempty"`
}
// GetWorkflowExecutionRetentionPeriodInDays is an internal getter (TBD...)
func (v *DomainConfiguration) GetWorkflowExecutionRetentionPeriodInDays() (o int32) {
if v != nil {
return v.WorkflowExecutionRetentionPeriodInDays
}
return
}
// GetEmitMetric is an internal getter (TBD...)
func (v *DomainConfiguration) GetEmitMetric() (o bool) {
if v != nil {
return v.EmitMetric
}
return
}
// GetBadBinaries is an internal getter (TBD...)
func (v *DomainConfiguration) GetBadBinaries() (o *BadBinaries) {
if v != nil && v.BadBinaries != nil {
return v.BadBinaries
}
return
}
// GetHistoryArchivalStatus is an internal getter (TBD...)
func (v *DomainConfiguration) GetHistoryArchivalStatus() (o ArchivalStatus) {
if v != nil && v.HistoryArchivalStatus != nil {
return *v.HistoryArchivalStatus
}
return
}
// GetHistoryArchivalURI is an internal getter (TBD...)
func (v *DomainConfiguration) GetHistoryArchivalURI() (o string) {
if v != nil {
return v.HistoryArchivalURI
}
return
}
// GetVisibilityArchivalStatus is an internal getter (TBD...)
func (v *DomainConfiguration) GetVisibilityArchivalStatus() (o ArchivalStatus) {
if v != nil && v.VisibilityArchivalStatus != nil {
return *v.VisibilityArchivalStatus
}
return
}
// GetVisibilityArchivalURI is an internal getter (TBD...)
func (v *DomainConfiguration) GetVisibilityArchivalURI() (o string) {
if v != nil {
return v.VisibilityArchivalURI
}
return
}
// GetIsolationGroupsConfiguration is an internal getter (TBD...)
func (v *DomainConfiguration) GetIsolationGroupsConfiguration() IsolationGroupConfiguration {
if v.IsolationGroups != nil {
return *v.IsolationGroups
}
return nil
}
func (v *DomainConfiguration) GetAsyncWorkflowConfiguration() AsyncWorkflowConfiguration {
if v.AsyncWorkflowConfig != nil {
return *v.AsyncWorkflowConfig
}
return AsyncWorkflowConfiguration{}
}
// DomainInfo is an internal type (TBD...)
type DomainInfo struct {
Name string `json:"name,omitempty"`
Status *DomainStatus `json:"status,omitempty"`
Description string `json:"description,omitempty"`
OwnerEmail string `json:"ownerEmail,omitempty"`
Data map[string]string `json:"data,omitempty"`
UUID string `json:"uuid,omitempty"`
}
// GetName is an internal getter (TBD...)
func (v *DomainInfo) GetName() (o string) {
if v != nil {
return v.Name
}
return
}
// GetStatus is an internal getter (TBD...)
func (v *DomainInfo) GetStatus() (o DomainStatus) {
if v != nil && v.Status != nil {
return *v.Status
}
return
}
// GetDescription is an internal getter (TBD...)
func (v *DomainInfo) GetDescription() (o string) {
if v != nil {
return v.Description
}
return
}
// GetOwnerEmail is an internal getter (TBD...)
func (v *DomainInfo) GetOwnerEmail() (o string) {
if v != nil {
return v.OwnerEmail
}
return
}
// GetData is an internal getter (TBD...)
func (v *DomainInfo) GetData() (o map[string]string) {
if v != nil && v.Data != nil {
return v.Data
}
return
}
// GetUUID is an internal getter (TBD...)
func (v *DomainInfo) GetUUID() (o string) {
if v != nil {
return v.UUID
}
return
}
// DomainNotActiveError is an internal type (TBD...)
type DomainNotActiveError struct {
Message string `json:"message,required"`
DomainName string `json:"domainName,required"`
CurrentCluster string `json:"currentCluster,required"`
ActiveCluster string `json:"activeCluster,required"`
}
// GetCurrentCluster is an internal getter (TBD...)
func (v *DomainNotActiveError) GetCurrentCluster() (o string) {
if v != nil {
return v.CurrentCluster
}
return
}
// GetActiveCluster is an internal getter (TBD...)
func (v *DomainNotActiveError) GetActiveCluster() (o string) {
if v != nil {
return v.ActiveCluster
}
return
}
// DomainReplicationConfiguration is an internal type (TBD...)
type DomainReplicationConfiguration struct {
ActiveClusterName string `json:"activeClusterName,omitempty"`
Clusters []*ClusterReplicationConfiguration `json:"clusters,omitempty"`
}
// GetActiveClusterName is an internal getter (TBD...)
func (v *DomainReplicationConfiguration) GetActiveClusterName() (o string) {
if v != nil {
return v.ActiveClusterName
}
return
}
// GetClusters is an internal getter (TBD...)
func (v *DomainReplicationConfiguration) GetClusters() (o []*ClusterReplicationConfiguration) {
if v != nil && v.Clusters != nil {
return v.Clusters
}
return
}
// DomainStatus is an internal type (TBD...)
type DomainStatus int32
// Ptr is a helper function for getting pointer value
func (e DomainStatus) Ptr() *DomainStatus {
return &e
}
// String returns a readable string representation of DomainStatus.
func (e DomainStatus) String() string {
w := int32(e)
switch w {
case 0:
return "REGISTERED"
case 1:
return "DEPRECATED"
case 2:
return "DELETED"
}
return fmt.Sprintf("DomainStatus(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *DomainStatus) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "REGISTERED":
*e = DomainStatusRegistered
return nil
case "DEPRECATED":
*e = DomainStatusDeprecated
return nil
case "DELETED":
*e = DomainStatusDeleted
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "DomainStatus", err)
}
*e = DomainStatus(val)
return nil
}
}
// MarshalText encodes DomainStatus to text.
func (e DomainStatus) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// DomainStatusRegistered is an option for DomainStatus
DomainStatusRegistered DomainStatus = iota
// DomainStatusDeprecated is an option for DomainStatus
DomainStatusDeprecated
// DomainStatusDeleted is an option for DomainStatus
DomainStatusDeleted
)
// EncodingType is an internal type (TBD...)
type EncodingType int32
// Ptr is a helper function for getting pointer value
func (e EncodingType) Ptr() *EncodingType {
return &e
}
// String returns a readable string representation of EncodingType.
func (e EncodingType) String() string {
w := int32(e)
switch w {
case 0:
return "ThriftRW"
case 1:
return "JSON"
}
return fmt.Sprintf("EncodingType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *EncodingType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "THRIFTRW":
*e = EncodingTypeThriftRW
return nil
case "JSON":
*e = EncodingTypeJSON
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "EncodingType", err)
}
*e = EncodingType(val)
return nil
}
}
// MarshalText encodes EncodingType to text.
func (e EncodingType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// EncodingTypeThriftRW is an option for EncodingType
EncodingTypeThriftRW EncodingType = iota
// EncodingTypeJSON is an option for EncodingType
EncodingTypeJSON
)
// EntityNotExistsError is an internal type (TBD...)
type EntityNotExistsError struct {
Message string `json:"message,required"`
CurrentCluster string `json:"currentCluster,omitempty"`
ActiveCluster string `json:"activeCluster,omitempty"`
}
// WorkflowExecutionAlreadyCompletedError is an internal type (TBD...)
type WorkflowExecutionAlreadyCompletedError struct {
Message string `json:"message,required"`
}
// EventType is an internal type (TBD...)
type EventType int32
// Ptr is a helper function for getting pointer value
func (e EventType) Ptr() *EventType {
return &e
}
// String returns a readable string representation of EventType.
func (e EventType) String() string {
w := int32(e)
switch w {
case 0:
return "WorkflowExecutionStarted"
case 1:
return "WorkflowExecutionCompleted"
case 2:
return "WorkflowExecutionFailed"
case 3:
return "WorkflowExecutionTimedOut"
case 4:
return "DecisionTaskScheduled"
case 5:
return "DecisionTaskStarted"
case 6:
return "DecisionTaskCompleted"
case 7:
return "DecisionTaskTimedOut"
case 8:
return "DecisionTaskFailed"
case 9:
return "ActivityTaskScheduled"
case 10:
return "ActivityTaskStarted"
case 11:
return "ActivityTaskCompleted"
case 12:
return "ActivityTaskFailed"
case 13:
return "ActivityTaskTimedOut"
case 14:
return "ActivityTaskCancelRequested"
case 15:
return "RequestCancelActivityTaskFailed"
case 16:
return "ActivityTaskCanceled"
case 17:
return "TimerStarted"
case 18:
return "TimerFired"
case 19:
return "CancelTimerFailed"
case 20:
return "TimerCanceled"
case 21:
return "WorkflowExecutionCancelRequested"
case 22:
return "WorkflowExecutionCanceled"
case 23:
return "RequestCancelExternalWorkflowExecutionInitiated"
case 24:
return "RequestCancelExternalWorkflowExecutionFailed"
case 25:
return "ExternalWorkflowExecutionCancelRequested"
case 26:
return "MarkerRecorded"
case 27:
return "WorkflowExecutionSignaled"
case 28:
return "WorkflowExecutionTerminated"
case 29:
return "WorkflowExecutionContinuedAsNew"
case 30:
return "StartChildWorkflowExecutionInitiated"
case 31:
return "StartChildWorkflowExecutionFailed"
case 32:
return "ChildWorkflowExecutionStarted"
case 33:
return "ChildWorkflowExecutionCompleted"
case 34:
return "ChildWorkflowExecutionFailed"
case 35:
return "ChildWorkflowExecutionCanceled"
case 36:
return "ChildWorkflowExecutionTimedOut"
case 37:
return "ChildWorkflowExecutionTerminated"
case 38:
return "SignalExternalWorkflowExecutionInitiated"
case 39:
return "SignalExternalWorkflowExecutionFailed"
case 40:
return "ExternalWorkflowExecutionSignaled"
case 41:
return "UpsertWorkflowSearchAttributes"
}
return fmt.Sprintf("EventType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *EventType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "WORKFLOWEXECUTIONSTARTED":
*e = EventTypeWorkflowExecutionStarted
return nil
case "WORKFLOWEXECUTIONCOMPLETED":
*e = EventTypeWorkflowExecutionCompleted
return nil
case "WORKFLOWEXECUTIONFAILED":
*e = EventTypeWorkflowExecutionFailed
return nil
case "WORKFLOWEXECUTIONTIMEDOUT":
*e = EventTypeWorkflowExecutionTimedOut
return nil
case "DECISIONTASKSCHEDULED":
*e = EventTypeDecisionTaskScheduled
return nil
case "DECISIONTASKSTARTED":
*e = EventTypeDecisionTaskStarted
return nil
case "DECISIONTASKCOMPLETED":
*e = EventTypeDecisionTaskCompleted
return nil
case "DECISIONTASKTIMEDOUT":
*e = EventTypeDecisionTaskTimedOut
return nil
case "DECISIONTASKFAILED":
*e = EventTypeDecisionTaskFailed
return nil
case "ACTIVITYTASKSCHEDULED":
*e = EventTypeActivityTaskScheduled
return nil
case "ACTIVITYTASKSTARTED":
*e = EventTypeActivityTaskStarted
return nil
case "ACTIVITYTASKCOMPLETED":
*e = EventTypeActivityTaskCompleted
return nil
case "ACTIVITYTASKFAILED":
*e = EventTypeActivityTaskFailed
return nil
case "ACTIVITYTASKTIMEDOUT":
*e = EventTypeActivityTaskTimedOut
return nil
case "ACTIVITYTASKCANCELREQUESTED":
*e = EventTypeActivityTaskCancelRequested
return nil
case "REQUESTCANCELACTIVITYTASKFAILED":
*e = EventTypeRequestCancelActivityTaskFailed
return nil
case "ACTIVITYTASKCANCELED":
*e = EventTypeActivityTaskCanceled
return nil
case "TIMERSTARTED":
*e = EventTypeTimerStarted
return nil
case "TIMERFIRED":
*e = EventTypeTimerFired
return nil
case "CANCELTIMERFAILED":
*e = EventTypeCancelTimerFailed
return nil
case "TIMERCANCELED":
*e = EventTypeTimerCanceled
return nil
case "WORKFLOWEXECUTIONCANCELREQUESTED":
*e = EventTypeWorkflowExecutionCancelRequested
return nil
case "WORKFLOWEXECUTIONCANCELED":
*e = EventTypeWorkflowExecutionCanceled
return nil
case "REQUESTCANCELEXTERNALWORKFLOWEXECUTIONINITIATED":
*e = EventTypeRequestCancelExternalWorkflowExecutionInitiated
return nil
case "REQUESTCANCELEXTERNALWORKFLOWEXECUTIONFAILED":
*e = EventTypeRequestCancelExternalWorkflowExecutionFailed
return nil
case "EXTERNALWORKFLOWEXECUTIONCANCELREQUESTED":
*e = EventTypeExternalWorkflowExecutionCancelRequested
return nil
case "MARKERRECORDED":
*e = EventTypeMarkerRecorded
return nil
case "WORKFLOWEXECUTIONSIGNALED":
*e = EventTypeWorkflowExecutionSignaled
return nil
case "WORKFLOWEXECUTIONTERMINATED":
*e = EventTypeWorkflowExecutionTerminated
return nil
case "WORKFLOWEXECUTIONCONTINUEDASNEW":
*e = EventTypeWorkflowExecutionContinuedAsNew
return nil
case "STARTCHILDWORKFLOWEXECUTIONINITIATED":
*e = EventTypeStartChildWorkflowExecutionInitiated
return nil
case "STARTCHILDWORKFLOWEXECUTIONFAILED":
*e = EventTypeStartChildWorkflowExecutionFailed
return nil
case "CHILDWORKFLOWEXECUTIONSTARTED":
*e = EventTypeChildWorkflowExecutionStarted
return nil
case "CHILDWORKFLOWEXECUTIONCOMPLETED":
*e = EventTypeChildWorkflowExecutionCompleted
return nil
case "CHILDWORKFLOWEXECUTIONFAILED":
*e = EventTypeChildWorkflowExecutionFailed
return nil
case "CHILDWORKFLOWEXECUTIONCANCELED":
*e = EventTypeChildWorkflowExecutionCanceled
return nil
case "CHILDWORKFLOWEXECUTIONTIMEDOUT":
*e = EventTypeChildWorkflowExecutionTimedOut
return nil
case "CHILDWORKFLOWEXECUTIONTERMINATED":
*e = EventTypeChildWorkflowExecutionTerminated
return nil
case "SIGNALEXTERNALWORKFLOWEXECUTIONINITIATED":
*e = EventTypeSignalExternalWorkflowExecutionInitiated
return nil
case "SIGNALEXTERNALWORKFLOWEXECUTIONFAILED":
*e = EventTypeSignalExternalWorkflowExecutionFailed
return nil
case "EXTERNALWORKFLOWEXECUTIONSIGNALED":
*e = EventTypeExternalWorkflowExecutionSignaled
return nil
case "UPSERTWORKFLOWSEARCHATTRIBUTES":
*e = EventTypeUpsertWorkflowSearchAttributes
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "EventType", err)
}
*e = EventType(val)
return nil
}
}
// MarshalText encodes EventType to text.
func (e EventType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// EventTypeWorkflowExecutionStarted is an option for EventType
EventTypeWorkflowExecutionStarted EventType = iota
// EventTypeWorkflowExecutionCompleted is an option for EventType
EventTypeWorkflowExecutionCompleted
// EventTypeWorkflowExecutionFailed is an option for EventType
EventTypeWorkflowExecutionFailed
// EventTypeWorkflowExecutionTimedOut is an option for EventType
EventTypeWorkflowExecutionTimedOut
// EventTypeDecisionTaskScheduled is an option for EventType
EventTypeDecisionTaskScheduled
// EventTypeDecisionTaskStarted is an option for EventType
EventTypeDecisionTaskStarted
// EventTypeDecisionTaskCompleted is an option for EventType
EventTypeDecisionTaskCompleted
// EventTypeDecisionTaskTimedOut is an option for EventType
EventTypeDecisionTaskTimedOut
// EventTypeDecisionTaskFailed is an option for EventType
EventTypeDecisionTaskFailed
// EventTypeActivityTaskScheduled is an option for EventType
EventTypeActivityTaskScheduled
// EventTypeActivityTaskStarted is an option for EventType
EventTypeActivityTaskStarted
// EventTypeActivityTaskCompleted is an option for EventType
EventTypeActivityTaskCompleted
// EventTypeActivityTaskFailed is an option for EventType
EventTypeActivityTaskFailed
// EventTypeActivityTaskTimedOut is an option for EventType
EventTypeActivityTaskTimedOut
// EventTypeActivityTaskCancelRequested is an option for EventType
EventTypeActivityTaskCancelRequested
// EventTypeRequestCancelActivityTaskFailed is an option for EventType
EventTypeRequestCancelActivityTaskFailed
// EventTypeActivityTaskCanceled is an option for EventType
EventTypeActivityTaskCanceled
// EventTypeTimerStarted is an option for EventType
EventTypeTimerStarted
// EventTypeTimerFired is an option for EventType
EventTypeTimerFired
// EventTypeCancelTimerFailed is an option for EventType
EventTypeCancelTimerFailed
// EventTypeTimerCanceled is an option for EventType
EventTypeTimerCanceled
// EventTypeWorkflowExecutionCancelRequested is an option for EventType
EventTypeWorkflowExecutionCancelRequested
// EventTypeWorkflowExecutionCanceled is an option for EventType
EventTypeWorkflowExecutionCanceled
// EventTypeRequestCancelExternalWorkflowExecutionInitiated is an option for EventType
EventTypeRequestCancelExternalWorkflowExecutionInitiated
// EventTypeRequestCancelExternalWorkflowExecutionFailed is an option for EventType
EventTypeRequestCancelExternalWorkflowExecutionFailed
// EventTypeExternalWorkflowExecutionCancelRequested is an option for EventType
EventTypeExternalWorkflowExecutionCancelRequested
// EventTypeMarkerRecorded is an option for EventType
EventTypeMarkerRecorded
// EventTypeWorkflowExecutionSignaled is an option for EventType
EventTypeWorkflowExecutionSignaled
// EventTypeWorkflowExecutionTerminated is an option for EventType
EventTypeWorkflowExecutionTerminated
// EventTypeWorkflowExecutionContinuedAsNew is an option for EventType
EventTypeWorkflowExecutionContinuedAsNew
// EventTypeStartChildWorkflowExecutionInitiated is an option for EventType
EventTypeStartChildWorkflowExecutionInitiated
// EventTypeStartChildWorkflowExecutionFailed is an option for EventType
EventTypeStartChildWorkflowExecutionFailed
// EventTypeChildWorkflowExecutionStarted is an option for EventType
EventTypeChildWorkflowExecutionStarted
// EventTypeChildWorkflowExecutionCompleted is an option for EventType
EventTypeChildWorkflowExecutionCompleted
// EventTypeChildWorkflowExecutionFailed is an option for EventType
EventTypeChildWorkflowExecutionFailed
// EventTypeChildWorkflowExecutionCanceled is an option for EventType
EventTypeChildWorkflowExecutionCanceled
// EventTypeChildWorkflowExecutionTimedOut is an option for EventType
EventTypeChildWorkflowExecutionTimedOut
// EventTypeChildWorkflowExecutionTerminated is an option for EventType
EventTypeChildWorkflowExecutionTerminated
// EventTypeSignalExternalWorkflowExecutionInitiated is an option for EventType
EventTypeSignalExternalWorkflowExecutionInitiated
// EventTypeSignalExternalWorkflowExecutionFailed is an option for EventType
EventTypeSignalExternalWorkflowExecutionFailed
// EventTypeExternalWorkflowExecutionSignaled is an option for EventType
EventTypeExternalWorkflowExecutionSignaled
// EventTypeUpsertWorkflowSearchAttributes is an option for EventType
EventTypeUpsertWorkflowSearchAttributes
)
// ExternalWorkflowExecutionCancelRequestedEventAttributes is an internal type (TBD...)
type ExternalWorkflowExecutionCancelRequestedEventAttributes struct {
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// GetDomain is an internal getter (TBD...)
func (v *ExternalWorkflowExecutionCancelRequestedEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// ExternalWorkflowExecutionSignaledEventAttributes is an internal type (TBD...)
type ExternalWorkflowExecutionSignaledEventAttributes struct {
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
Control []byte `json:"control,omitempty"`
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *ExternalWorkflowExecutionSignaledEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// GetDomain is an internal getter (TBD...)
func (v *ExternalWorkflowExecutionSignaledEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// FailWorkflowExecutionDecisionAttributes is an internal type (TBD...)
type FailWorkflowExecutionDecisionAttributes struct {
Reason *string `json:"reason,omitempty"`
Details []byte `json:"details,omitempty"`
}
// GetReason is an internal getter (TBD...)
func (v *FailWorkflowExecutionDecisionAttributes) GetReason() (o string) {
if v != nil && v.Reason != nil {
return *v.Reason
}
return
}
// GetSearchAttributesResponse is an internal type (TBD...)
type GetSearchAttributesResponse struct {
Keys map[string]IndexedValueType `json:"keys,omitempty"`
}
// GetKeys is an internal getter (TBD...)
func (v *GetSearchAttributesResponse) GetKeys() (o map[string]IndexedValueType) {
if v != nil && v.Keys != nil {
return v.Keys
}
return
}
// GetWorkflowExecutionHistoryRequest is an internal type (TBD...)
type GetWorkflowExecutionHistoryRequest struct {
Domain string `json:"domain,omitempty"`
Execution *WorkflowExecution `json:"execution,omitempty"`
MaximumPageSize int32 `json:"maximumPageSize,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
WaitForNewEvent bool `json:"waitForNewEvent,omitempty"`
HistoryEventFilterType *HistoryEventFilterType `json:"HistoryEventFilterType,omitempty"`
SkipArchival bool `json:"skipArchival,omitempty"`
}
func (v *GetWorkflowExecutionHistoryRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetExecution is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryRequest) GetExecution() (o *WorkflowExecution) {
if v != nil && v.Execution != nil {
return v.Execution
}
return
}
// GetMaximumPageSize is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() (o int32) {
if v != nil {
return v.MaximumPageSize
}
return
}
// GetNextPageToken is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryRequest) GetNextPageToken() (o []byte) {
if v != nil && v.NextPageToken != nil {
return v.NextPageToken
}
return
}
// GetWaitForNewEvent is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryRequest) GetWaitForNewEvent() (o bool) {
if v != nil {
return v.WaitForNewEvent
}
return
}
// GetHistoryEventFilterType is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType() (o HistoryEventFilterType) {
if v != nil && v.HistoryEventFilterType != nil {
return *v.HistoryEventFilterType
}
return
}
// GetSkipArchival is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryRequest) GetSkipArchival() (o bool) {
if v != nil {
return v.SkipArchival
}
return
}
// GetWorkflowExecutionHistoryResponse is an internal type (TBD...)
type GetWorkflowExecutionHistoryResponse struct {
History *History `json:"history,omitempty"`
RawHistory []*DataBlob `json:"rawHistory,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
Archived bool `json:"archived,omitempty"`
}
// GetHistory is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryResponse) GetHistory() (o *History) {
if v != nil && v.History != nil {
return v.History
}
return
}
// GetArchived is an internal getter (TBD...)
func (v *GetWorkflowExecutionHistoryResponse) GetArchived() (o bool) {
if v != nil {
return v.Archived
}
return
}
// FailoverInfo is an internal type (TBD...)
type FailoverInfo struct {
FailoverVersion int64 `json:"failoverVersion,omitempty"`
FailoverStartTimestamp int64 `json:"failoverStartTimestamp,omitempty"`
FailoverExpireTimestamp int64 `json:"failoverExpireTimestamp,omitempty"`
CompletedShardCount int32 `json:"completedShardCount,omitempty"`
PendingShards []int32 `json:"pendingShards,omitempty"`
}
// GetFailoverVersion is an internal getter (TBD...)
func (v *FailoverInfo) GetFailoverVersion() (o int64) {
if v != nil {
return v.FailoverVersion
}
return
}
// GetFailoverStartTimestamp is an internal getter (TBD...)
func (v *FailoverInfo) GetFailoverStartTimestamp() (o int64) {
if v != nil {
return v.FailoverStartTimestamp
}
return
}
// GetFailoverExpireTimestamp is an internal getter (TBD...)
func (v *FailoverInfo) GetFailoverExpireTimestamp() (o int64) {
if v != nil {
return v.FailoverExpireTimestamp
}
return
}
// GetCompletedShardCount is an internal getter (TBD...)
func (v *FailoverInfo) GetCompletedShardCount() (o int32) {
if v != nil {
return v.CompletedShardCount
}
return
}
// GetPendingShards is an internal getter (TBD...)
func (v *FailoverInfo) GetPendingShards() (o []int32) {
if v != nil {
return v.PendingShards
}
return
}
// Header is an internal type (TBD...)
type Header struct {
Fields map[string][]byte `json:"fields,omitempty"`
}
// History is an internal type (TBD...)
type History struct {
Events []*HistoryEvent `json:"events,omitempty"`
}
// GetEvents is an internal getter (TBD...)
func (v *History) GetEvents() (o []*HistoryEvent) {
if v != nil && v.Events != nil {
return v.Events
}
return
}
// HistoryBranch is an internal type (TBD...)
type HistoryBranch struct {
TreeID string
BranchID string
Ancestors []*HistoryBranchRange
}
// HistoryBranchRange is an internal type (TBD...)
type HistoryBranchRange struct {
BranchID string
BeginNodeID int64
EndNodeID int64
}
// HistoryEvent is an internal type (TBD...)
type HistoryEvent struct {
ID int64 `json:"eventId,omitempty"`
Timestamp *int64 `json:"timestamp,omitempty"`
EventType *EventType `json:"eventType,omitempty"`
Version int64 `json:"version,omitempty"`
TaskID int64 `json:"taskId,omitempty"`
WorkflowExecutionStartedEventAttributes *WorkflowExecutionStartedEventAttributes `json:"workflowExecutionStartedEventAttributes,omitempty"`
WorkflowExecutionCompletedEventAttributes *WorkflowExecutionCompletedEventAttributes `json:"workflowExecutionCompletedEventAttributes,omitempty"`
WorkflowExecutionFailedEventAttributes *WorkflowExecutionFailedEventAttributes `json:"workflowExecutionFailedEventAttributes,omitempty"`
WorkflowExecutionTimedOutEventAttributes *WorkflowExecutionTimedOutEventAttributes `json:"workflowExecutionTimedOutEventAttributes,omitempty"`
DecisionTaskScheduledEventAttributes *DecisionTaskScheduledEventAttributes `json:"decisionTaskScheduledEventAttributes,omitempty"`
DecisionTaskStartedEventAttributes *DecisionTaskStartedEventAttributes `json:"decisionTaskStartedEventAttributes,omitempty"`
DecisionTaskCompletedEventAttributes *DecisionTaskCompletedEventAttributes `json:"decisionTaskCompletedEventAttributes,omitempty"`
DecisionTaskTimedOutEventAttributes *DecisionTaskTimedOutEventAttributes `json:"decisionTaskTimedOutEventAttributes,omitempty"`
DecisionTaskFailedEventAttributes *DecisionTaskFailedEventAttributes `json:"decisionTaskFailedEventAttributes,omitempty"`
ActivityTaskScheduledEventAttributes *ActivityTaskScheduledEventAttributes `json:"activityTaskScheduledEventAttributes,omitempty"`
ActivityTaskStartedEventAttributes *ActivityTaskStartedEventAttributes `json:"activityTaskStartedEventAttributes,omitempty"`
ActivityTaskCompletedEventAttributes *ActivityTaskCompletedEventAttributes `json:"activityTaskCompletedEventAttributes,omitempty"`
ActivityTaskFailedEventAttributes *ActivityTaskFailedEventAttributes `json:"activityTaskFailedEventAttributes,omitempty"`
ActivityTaskTimedOutEventAttributes *ActivityTaskTimedOutEventAttributes `json:"activityTaskTimedOutEventAttributes,omitempty"`
TimerStartedEventAttributes *TimerStartedEventAttributes `json:"timerStartedEventAttributes,omitempty"`
TimerFiredEventAttributes *TimerFiredEventAttributes `json:"timerFiredEventAttributes,omitempty"`
ActivityTaskCancelRequestedEventAttributes *ActivityTaskCancelRequestedEventAttributes `json:"activityTaskCancelRequestedEventAttributes,omitempty"`
RequestCancelActivityTaskFailedEventAttributes *RequestCancelActivityTaskFailedEventAttributes `json:"requestCancelActivityTaskFailedEventAttributes,omitempty"`
ActivityTaskCanceledEventAttributes *ActivityTaskCanceledEventAttributes `json:"activityTaskCanceledEventAttributes,omitempty"`
TimerCanceledEventAttributes *TimerCanceledEventAttributes `json:"timerCanceledEventAttributes,omitempty"`
CancelTimerFailedEventAttributes *CancelTimerFailedEventAttributes `json:"cancelTimerFailedEventAttributes,omitempty"`
MarkerRecordedEventAttributes *MarkerRecordedEventAttributes `json:"markerRecordedEventAttributes,omitempty"`
WorkflowExecutionSignaledEventAttributes *WorkflowExecutionSignaledEventAttributes `json:"workflowExecutionSignaledEventAttributes,omitempty"`
WorkflowExecutionTerminatedEventAttributes *WorkflowExecutionTerminatedEventAttributes `json:"workflowExecutionTerminatedEventAttributes,omitempty"`
WorkflowExecutionCancelRequestedEventAttributes *WorkflowExecutionCancelRequestedEventAttributes `json:"workflowExecutionCancelRequestedEventAttributes,omitempty"`
WorkflowExecutionCanceledEventAttributes *WorkflowExecutionCanceledEventAttributes `json:"workflowExecutionCanceledEventAttributes,omitempty"`
RequestCancelExternalWorkflowExecutionInitiatedEventAttributes *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes `json:"requestCancelExternalWorkflowExecutionInitiatedEventAttributes,omitempty"`
RequestCancelExternalWorkflowExecutionFailedEventAttributes *RequestCancelExternalWorkflowExecutionFailedEventAttributes `json:"requestCancelExternalWorkflowExecutionFailedEventAttributes,omitempty"`
ExternalWorkflowExecutionCancelRequestedEventAttributes *ExternalWorkflowExecutionCancelRequestedEventAttributes `json:"externalWorkflowExecutionCancelRequestedEventAttributes,omitempty"`
WorkflowExecutionContinuedAsNewEventAttributes *WorkflowExecutionContinuedAsNewEventAttributes `json:"workflowExecutionContinuedAsNewEventAttributes,omitempty"`
StartChildWorkflowExecutionInitiatedEventAttributes *StartChildWorkflowExecutionInitiatedEventAttributes `json:"startChildWorkflowExecutionInitiatedEventAttributes,omitempty"`
StartChildWorkflowExecutionFailedEventAttributes *StartChildWorkflowExecutionFailedEventAttributes `json:"startChildWorkflowExecutionFailedEventAttributes,omitempty"`
ChildWorkflowExecutionStartedEventAttributes *ChildWorkflowExecutionStartedEventAttributes `json:"childWorkflowExecutionStartedEventAttributes,omitempty"`
ChildWorkflowExecutionCompletedEventAttributes *ChildWorkflowExecutionCompletedEventAttributes `json:"childWorkflowExecutionCompletedEventAttributes,omitempty"`
ChildWorkflowExecutionFailedEventAttributes *ChildWorkflowExecutionFailedEventAttributes `json:"childWorkflowExecutionFailedEventAttributes,omitempty"`
ChildWorkflowExecutionCanceledEventAttributes *ChildWorkflowExecutionCanceledEventAttributes `json:"childWorkflowExecutionCanceledEventAttributes,omitempty"`
ChildWorkflowExecutionTimedOutEventAttributes *ChildWorkflowExecutionTimedOutEventAttributes `json:"childWorkflowExecutionTimedOutEventAttributes,omitempty"`
ChildWorkflowExecutionTerminatedEventAttributes *ChildWorkflowExecutionTerminatedEventAttributes `json:"childWorkflowExecutionTerminatedEventAttributes,omitempty"`
SignalExternalWorkflowExecutionInitiatedEventAttributes *SignalExternalWorkflowExecutionInitiatedEventAttributes `json:"signalExternalWorkflowExecutionInitiatedEventAttributes,omitempty"`
SignalExternalWorkflowExecutionFailedEventAttributes *SignalExternalWorkflowExecutionFailedEventAttributes `json:"signalExternalWorkflowExecutionFailedEventAttributes,omitempty"`
ExternalWorkflowExecutionSignaledEventAttributes *ExternalWorkflowExecutionSignaledEventAttributes `json:"externalWorkflowExecutionSignaledEventAttributes,omitempty"`
UpsertWorkflowSearchAttributesEventAttributes *UpsertWorkflowSearchAttributesEventAttributes `json:"upsertWorkflowSearchAttributesEventAttributes,omitempty"`
}
// GetTimestamp is an internal getter (TBD...)
func (v *HistoryEvent) GetTimestamp() (o int64) {
if v != nil && v.Timestamp != nil {
return *v.Timestamp
}
return
}
// GetEventType is an internal getter (TBD...)
func (v *HistoryEvent) GetEventType() (o EventType) {
if v != nil && v.EventType != nil {
return *v.EventType
}
return
}
// GetWorkflowExecutionStartedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionStartedEventAttributes() (o *WorkflowExecutionStartedEventAttributes) {
if v != nil && v.WorkflowExecutionStartedEventAttributes != nil {
return v.WorkflowExecutionStartedEventAttributes
}
return
}
// GetWorkflowExecutionCompletedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionCompletedEventAttributes() (o *WorkflowExecutionCompletedEventAttributes) {
if v != nil && v.WorkflowExecutionCompletedEventAttributes != nil {
return v.WorkflowExecutionCompletedEventAttributes
}
return
}
// GetWorkflowExecutionFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionFailedEventAttributes() (o *WorkflowExecutionFailedEventAttributes) {
if v != nil && v.WorkflowExecutionFailedEventAttributes != nil {
return v.WorkflowExecutionFailedEventAttributes
}
return
}
// GetWorkflowExecutionTimedOutEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionTimedOutEventAttributes() (o *WorkflowExecutionTimedOutEventAttributes) {
if v != nil && v.WorkflowExecutionTimedOutEventAttributes != nil {
return v.WorkflowExecutionTimedOutEventAttributes
}
return
}
// GetDecisionTaskScheduledEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetDecisionTaskScheduledEventAttributes() (o *DecisionTaskScheduledEventAttributes) {
if v != nil && v.DecisionTaskScheduledEventAttributes != nil {
return v.DecisionTaskScheduledEventAttributes
}
return
}
// GetDecisionTaskStartedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetDecisionTaskStartedEventAttributes() (o *DecisionTaskStartedEventAttributes) {
if v != nil && v.DecisionTaskStartedEventAttributes != nil {
return v.DecisionTaskStartedEventAttributes
}
return
}
// GetDecisionTaskCompletedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetDecisionTaskCompletedEventAttributes() (o *DecisionTaskCompletedEventAttributes) {
if v != nil && v.DecisionTaskCompletedEventAttributes != nil {
return v.DecisionTaskCompletedEventAttributes
}
return
}
// GetDecisionTaskTimedOutEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetDecisionTaskTimedOutEventAttributes() (o *DecisionTaskTimedOutEventAttributes) {
if v != nil && v.DecisionTaskTimedOutEventAttributes != nil {
return v.DecisionTaskTimedOutEventAttributes
}
return
}
// GetDecisionTaskFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetDecisionTaskFailedEventAttributes() (o *DecisionTaskFailedEventAttributes) {
if v != nil && v.DecisionTaskFailedEventAttributes != nil {
return v.DecisionTaskFailedEventAttributes
}
return
}
// GetActivityTaskScheduledEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetActivityTaskScheduledEventAttributes() (o *ActivityTaskScheduledEventAttributes) {
if v != nil && v.ActivityTaskScheduledEventAttributes != nil {
return v.ActivityTaskScheduledEventAttributes
}
return
}
// GetActivityTaskStartedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetActivityTaskStartedEventAttributes() (o *ActivityTaskStartedEventAttributes) {
if v != nil && v.ActivityTaskStartedEventAttributes != nil {
return v.ActivityTaskStartedEventAttributes
}
return
}
// GetActivityTaskCompletedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetActivityTaskCompletedEventAttributes() (o *ActivityTaskCompletedEventAttributes) {
if v != nil && v.ActivityTaskCompletedEventAttributes != nil {
return v.ActivityTaskCompletedEventAttributes
}
return
}
// GetActivityTaskFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetActivityTaskFailedEventAttributes() (o *ActivityTaskFailedEventAttributes) {
if v != nil && v.ActivityTaskFailedEventAttributes != nil {
return v.ActivityTaskFailedEventAttributes
}
return
}
// GetActivityTaskTimedOutEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetActivityTaskTimedOutEventAttributes() (o *ActivityTaskTimedOutEventAttributes) {
if v != nil && v.ActivityTaskTimedOutEventAttributes != nil {
return v.ActivityTaskTimedOutEventAttributes
}
return
}
// GetTimerStartedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetTimerStartedEventAttributes() (o *TimerStartedEventAttributes) {
if v != nil && v.TimerStartedEventAttributes != nil {
return v.TimerStartedEventAttributes
}
return
}
// GetTimerFiredEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetTimerFiredEventAttributes() (o *TimerFiredEventAttributes) {
if v != nil && v.TimerFiredEventAttributes != nil {
return v.TimerFiredEventAttributes
}
return
}
// GetActivityTaskCancelRequestedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetActivityTaskCancelRequestedEventAttributes() (o *ActivityTaskCancelRequestedEventAttributes) {
if v != nil && v.ActivityTaskCancelRequestedEventAttributes != nil {
return v.ActivityTaskCancelRequestedEventAttributes
}
return
}
// GetRequestCancelActivityTaskFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetRequestCancelActivityTaskFailedEventAttributes() (o *RequestCancelActivityTaskFailedEventAttributes) {
if v != nil && v.RequestCancelActivityTaskFailedEventAttributes != nil {
return v.RequestCancelActivityTaskFailedEventAttributes
}
return
}
// GetActivityTaskCanceledEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetActivityTaskCanceledEventAttributes() (o *ActivityTaskCanceledEventAttributes) {
if v != nil && v.ActivityTaskCanceledEventAttributes != nil {
return v.ActivityTaskCanceledEventAttributes
}
return
}
// GetTimerCanceledEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetTimerCanceledEventAttributes() (o *TimerCanceledEventAttributes) {
if v != nil && v.TimerCanceledEventAttributes != nil {
return v.TimerCanceledEventAttributes
}
return
}
// GetCancelTimerFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetCancelTimerFailedEventAttributes() (o *CancelTimerFailedEventAttributes) {
if v != nil && v.CancelTimerFailedEventAttributes != nil {
return v.CancelTimerFailedEventAttributes
}
return
}
// GetMarkerRecordedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetMarkerRecordedEventAttributes() (o *MarkerRecordedEventAttributes) {
if v != nil && v.MarkerRecordedEventAttributes != nil {
return v.MarkerRecordedEventAttributes
}
return
}
// GetWorkflowExecutionSignaledEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionSignaledEventAttributes() (o *WorkflowExecutionSignaledEventAttributes) {
if v != nil && v.WorkflowExecutionSignaledEventAttributes != nil {
return v.WorkflowExecutionSignaledEventAttributes
}
return
}
// GetWorkflowExecutionTerminatedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionTerminatedEventAttributes() (o *WorkflowExecutionTerminatedEventAttributes) {
if v != nil && v.WorkflowExecutionTerminatedEventAttributes != nil {
return v.WorkflowExecutionTerminatedEventAttributes
}
return
}
// GetWorkflowExecutionCancelRequestedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionCancelRequestedEventAttributes() (o *WorkflowExecutionCancelRequestedEventAttributes) {
if v != nil && v.WorkflowExecutionCancelRequestedEventAttributes != nil {
return v.WorkflowExecutionCancelRequestedEventAttributes
}
return
}
// GetWorkflowExecutionCanceledEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionCanceledEventAttributes() (o *WorkflowExecutionCanceledEventAttributes) {
if v != nil && v.WorkflowExecutionCanceledEventAttributes != nil {
return v.WorkflowExecutionCanceledEventAttributes
}
return
}
// GetRequestCancelExternalWorkflowExecutionInitiatedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetRequestCancelExternalWorkflowExecutionInitiatedEventAttributes() (o *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) {
if v != nil && v.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes != nil {
return v.RequestCancelExternalWorkflowExecutionInitiatedEventAttributes
}
return
}
// GetRequestCancelExternalWorkflowExecutionFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetRequestCancelExternalWorkflowExecutionFailedEventAttributes() (o *RequestCancelExternalWorkflowExecutionFailedEventAttributes) {
if v != nil && v.RequestCancelExternalWorkflowExecutionFailedEventAttributes != nil {
return v.RequestCancelExternalWorkflowExecutionFailedEventAttributes
}
return
}
// GetExternalWorkflowExecutionCancelRequestedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetExternalWorkflowExecutionCancelRequestedEventAttributes() (o *ExternalWorkflowExecutionCancelRequestedEventAttributes) {
if v != nil && v.ExternalWorkflowExecutionCancelRequestedEventAttributes != nil {
return v.ExternalWorkflowExecutionCancelRequestedEventAttributes
}
return
}
// GetWorkflowExecutionContinuedAsNewEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetWorkflowExecutionContinuedAsNewEventAttributes() (o *WorkflowExecutionContinuedAsNewEventAttributes) {
if v != nil && v.WorkflowExecutionContinuedAsNewEventAttributes != nil {
return v.WorkflowExecutionContinuedAsNewEventAttributes
}
return
}
// GetStartChildWorkflowExecutionInitiatedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetStartChildWorkflowExecutionInitiatedEventAttributes() (o *StartChildWorkflowExecutionInitiatedEventAttributes) {
if v != nil && v.StartChildWorkflowExecutionInitiatedEventAttributes != nil {
return v.StartChildWorkflowExecutionInitiatedEventAttributes
}
return
}
// GetStartChildWorkflowExecutionFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetStartChildWorkflowExecutionFailedEventAttributes() (o *StartChildWorkflowExecutionFailedEventAttributes) {
if v != nil && v.StartChildWorkflowExecutionFailedEventAttributes != nil {
return v.StartChildWorkflowExecutionFailedEventAttributes
}
return
}
// GetChildWorkflowExecutionStartedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetChildWorkflowExecutionStartedEventAttributes() (o *ChildWorkflowExecutionStartedEventAttributes) {
if v != nil && v.ChildWorkflowExecutionStartedEventAttributes != nil {
return v.ChildWorkflowExecutionStartedEventAttributes
}
return
}
// GetChildWorkflowExecutionCompletedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetChildWorkflowExecutionCompletedEventAttributes() (o *ChildWorkflowExecutionCompletedEventAttributes) {
if v != nil && v.ChildWorkflowExecutionCompletedEventAttributes != nil {
return v.ChildWorkflowExecutionCompletedEventAttributes
}
return
}
// GetChildWorkflowExecutionFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetChildWorkflowExecutionFailedEventAttributes() (o *ChildWorkflowExecutionFailedEventAttributes) {
if v != nil && v.ChildWorkflowExecutionFailedEventAttributes != nil {
return v.ChildWorkflowExecutionFailedEventAttributes
}
return
}
// GetChildWorkflowExecutionCanceledEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetChildWorkflowExecutionCanceledEventAttributes() (o *ChildWorkflowExecutionCanceledEventAttributes) {
if v != nil && v.ChildWorkflowExecutionCanceledEventAttributes != nil {
return v.ChildWorkflowExecutionCanceledEventAttributes
}
return
}
// GetChildWorkflowExecutionTimedOutEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetChildWorkflowExecutionTimedOutEventAttributes() (o *ChildWorkflowExecutionTimedOutEventAttributes) {
if v != nil && v.ChildWorkflowExecutionTimedOutEventAttributes != nil {
return v.ChildWorkflowExecutionTimedOutEventAttributes
}
return
}
// GetChildWorkflowExecutionTerminatedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetChildWorkflowExecutionTerminatedEventAttributes() (o *ChildWorkflowExecutionTerminatedEventAttributes) {
if v != nil && v.ChildWorkflowExecutionTerminatedEventAttributes != nil {
return v.ChildWorkflowExecutionTerminatedEventAttributes
}
return
}
// GetSignalExternalWorkflowExecutionInitiatedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetSignalExternalWorkflowExecutionInitiatedEventAttributes() (o *SignalExternalWorkflowExecutionInitiatedEventAttributes) {
if v != nil && v.SignalExternalWorkflowExecutionInitiatedEventAttributes != nil {
return v.SignalExternalWorkflowExecutionInitiatedEventAttributes
}
return
}
// GetSignalExternalWorkflowExecutionFailedEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetSignalExternalWorkflowExecutionFailedEventAttributes() (o *SignalExternalWorkflowExecutionFailedEventAttributes) {
if v != nil && v.SignalExternalWorkflowExecutionFailedEventAttributes != nil {
return v.SignalExternalWorkflowExecutionFailedEventAttributes
}
return
}
// GetExternalWorkflowExecutionSignaledEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetExternalWorkflowExecutionSignaledEventAttributes() (o *ExternalWorkflowExecutionSignaledEventAttributes) {
if v != nil && v.ExternalWorkflowExecutionSignaledEventAttributes != nil {
return v.ExternalWorkflowExecutionSignaledEventAttributes
}
return
}
// GetUpsertWorkflowSearchAttributesEventAttributes is an internal getter (TBD...)
func (v *HistoryEvent) GetUpsertWorkflowSearchAttributesEventAttributes() (o *UpsertWorkflowSearchAttributesEventAttributes) {
if v != nil && v.UpsertWorkflowSearchAttributesEventAttributes != nil {
return v.UpsertWorkflowSearchAttributesEventAttributes
}
return
}
// HistoryEventFilterType is an internal type (TBD...)
type HistoryEventFilterType int32
// Ptr is a helper function for getting pointer value
func (e HistoryEventFilterType) Ptr() *HistoryEventFilterType {
return &e
}
// String returns a readable string representation of HistoryEventFilterType.
func (e HistoryEventFilterType) String() string {
w := int32(e)
switch w {
case 0:
return "ALL_EVENT"
case 1:
return "CLOSE_EVENT"
}
return fmt.Sprintf("HistoryEventFilterType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *HistoryEventFilterType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "ALL_EVENT":
*e = HistoryEventFilterTypeAllEvent
return nil
case "CLOSE_EVENT":
*e = HistoryEventFilterTypeCloseEvent
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "HistoryEventFilterType", err)
}
*e = HistoryEventFilterType(val)
return nil
}
}
// MarshalText encodes HistoryEventFilterType to text.
func (e HistoryEventFilterType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// HistoryEventFilterTypeAllEvent is an option for HistoryEventFilterType
HistoryEventFilterTypeAllEvent HistoryEventFilterType = iota
// HistoryEventFilterTypeCloseEvent is an option for HistoryEventFilterType
HistoryEventFilterTypeCloseEvent
)
// IndexedValueType is an internal type (TBD...)
type IndexedValueType int32
// Ptr is a helper function for getting pointer value
func (e IndexedValueType) Ptr() *IndexedValueType {
return &e
}
// String returns a readable string representation of IndexedValueType.
func (e IndexedValueType) String() string {
w := int32(e)
switch w {
case 0:
return "STRING"
case 1:
return "KEYWORD"
case 2:
return "INT"
case 3:
return "DOUBLE"
case 4:
return "BOOL"
case 5:
return "DATETIME"
}
return fmt.Sprintf("IndexedValueType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *IndexedValueType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "STRING":
*e = IndexedValueTypeString
return nil
case "KEYWORD":
*e = IndexedValueTypeKeyword
return nil
case "INT":
*e = IndexedValueTypeInt
return nil
case "DOUBLE":
*e = IndexedValueTypeDouble
return nil
case "BOOL":
*e = IndexedValueTypeBool
return nil
case "DATETIME":
*e = IndexedValueTypeDatetime
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "IndexedValueType", err)
}
*e = IndexedValueType(val)
return nil
}
}
// MarshalText encodes IndexedValueType to text.
func (e IndexedValueType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// IndexedValueTypeString is an option for IndexedValueType
IndexedValueTypeString IndexedValueType = iota
// IndexedValueTypeKeyword is an option for IndexedValueType
IndexedValueTypeKeyword
// IndexedValueTypeInt is an option for IndexedValueType
IndexedValueTypeInt
// IndexedValueTypeDouble is an option for IndexedValueType
IndexedValueTypeDouble
// IndexedValueTypeBool is an option for IndexedValueType
IndexedValueTypeBool
// IndexedValueTypeDatetime is an option for IndexedValueType
IndexedValueTypeDatetime
)
// InternalDataInconsistencyError is an internal type (TBD...)
type InternalDataInconsistencyError struct {
Message string `json:"message,required"`
}
// InternalServiceError is an internal type (TBD...)
type InternalServiceError struct {
Message string `json:"message,required"`
}
// GetMessage is an internal getter (TBD...)
func (v *InternalServiceError) GetMessage() (o string) {
if v != nil {
return v.Message
}
return
}
// LimitExceededError is an internal type (TBD...)
type LimitExceededError struct {
Message string `json:"message,required"`
}
// ListArchivedWorkflowExecutionsRequest is an internal type (TBD...)
type ListArchivedWorkflowExecutionsRequest struct {
Domain string `json:"domain,omitempty"`
PageSize int32 `json:"pageSize,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
Query string `json:"query,omitempty"`
}
func (v *ListArchivedWorkflowExecutionsRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *ListArchivedWorkflowExecutionsRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetPageSize is an internal getter (TBD...)
func (v *ListArchivedWorkflowExecutionsRequest) GetPageSize() (o int32) {
if v != nil {
return v.PageSize
}
return
}
// GetQuery is an internal getter (TBD...)
func (v *ListArchivedWorkflowExecutionsRequest) GetQuery() (o string) {
if v != nil {
return v.Query
}
return
}
// ListArchivedWorkflowExecutionsResponse is an internal type (TBD...)
type ListArchivedWorkflowExecutionsResponse struct {
Executions []*WorkflowExecutionInfo `json:"executions,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
}
// GetExecutions is an internal getter (TBD...)
func (v *ListArchivedWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo) {
if v != nil && v.Executions != nil {
return v.Executions
}
return
}
// ListClosedWorkflowExecutionsRequest is an internal type (TBD...)
type ListClosedWorkflowExecutionsRequest struct {
Domain string `json:"domain,omitempty"`
MaximumPageSize int32 `json:"maximumPageSize,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
StartTimeFilter *StartTimeFilter `json:"StartTimeFilter,omitempty"`
ExecutionFilter *WorkflowExecutionFilter `json:"executionFilter,omitempty"`
TypeFilter *WorkflowTypeFilter `json:"typeFilter,omitempty"`
StatusFilter *WorkflowExecutionCloseStatus `json:"statusFilter,omitempty"`
}
func (v *ListClosedWorkflowExecutionsRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *ListClosedWorkflowExecutionsRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetMaximumPageSize is an internal getter (TBD...)
func (v *ListClosedWorkflowExecutionsRequest) GetMaximumPageSize() (o int32) {
if v != nil {
return v.MaximumPageSize
}
return
}
// GetStatusFilter is an internal getter (TBD...)
func (v *ListClosedWorkflowExecutionsRequest) GetStatusFilter() (o WorkflowExecutionCloseStatus) {
if v != nil && v.StatusFilter != nil {
return *v.StatusFilter
}
return
}
// ListClosedWorkflowExecutionsResponse is an internal type (TBD...)
type ListClosedWorkflowExecutionsResponse struct {
Executions []*WorkflowExecutionInfo `json:"executions,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
}
// GetExecutions is an internal getter (TBD...)
func (v *ListClosedWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo) {
if v != nil && v.Executions != nil {
return v.Executions
}
return
}
// ListDomainsRequest is an internal type (TBD...)
type ListDomainsRequest struct {
PageSize int32 `json:"pageSize,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
}
func (v *ListDomainsRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetPageSize is an internal getter (TBD...)
func (v *ListDomainsRequest) GetPageSize() (o int32) {
if v != nil {
return v.PageSize
}
return
}
// ListDomainsResponse is an internal type (TBD...)
type ListDomainsResponse struct {
Domains []*DescribeDomainResponse `json:"domains,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
}
// GetDomains is an internal getter (TBD...)
func (v *ListDomainsResponse) GetDomains() (o []*DescribeDomainResponse) {
if v != nil && v.Domains != nil {
return v.Domains
}
return
}
// GetNextPageToken is an internal getter (TBD...)
func (v *ListDomainsResponse) GetNextPageToken() (o []byte) {
if v != nil && v.NextPageToken != nil {
return v.NextPageToken
}
return
}
// ListOpenWorkflowExecutionsRequest is an internal type (TBD...)
type ListOpenWorkflowExecutionsRequest struct {
Domain string `json:"domain,omitempty"`
MaximumPageSize int32 `json:"maximumPageSize,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
StartTimeFilter *StartTimeFilter `json:"StartTimeFilter,omitempty"`
ExecutionFilter *WorkflowExecutionFilter `json:"executionFilter,omitempty"`
TypeFilter *WorkflowTypeFilter `json:"typeFilter,omitempty"`
}
func (v *ListOpenWorkflowExecutionsRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *ListOpenWorkflowExecutionsRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetMaximumPageSize is an internal getter (TBD...)
func (v *ListOpenWorkflowExecutionsRequest) GetMaximumPageSize() (o int32) {
if v != nil {
return v.MaximumPageSize
}
return
}
// ListOpenWorkflowExecutionsResponse is an internal type (TBD...)
type ListOpenWorkflowExecutionsResponse struct {
Executions []*WorkflowExecutionInfo `json:"executions,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
}
// GetExecutions is an internal getter (TBD...)
func (v *ListOpenWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo) {
if v != nil && v.Executions != nil {
return v.Executions
}
return
}
// ListTaskListPartitionsRequest is an internal type (TBD...)
type ListTaskListPartitionsRequest struct {
Domain string `json:"domain,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
}
func (v *ListTaskListPartitionsRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *ListTaskListPartitionsRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetTaskList is an internal getter (TBD...)
func (v *ListTaskListPartitionsRequest) GetTaskList() (o *TaskList) {
if v != nil && v.TaskList != nil {
return v.TaskList
}
return
}
// ListTaskListPartitionsResponse is an internal type (TBD...)
type ListTaskListPartitionsResponse struct {
ActivityTaskListPartitions []*TaskListPartitionMetadata `json:"activityTaskListPartitions,omitempty"`
DecisionTaskListPartitions []*TaskListPartitionMetadata `json:"decisionTaskListPartitions,omitempty"`
}
// GetTaskListsByDomainRequest is an internal type (TBD...)
type GetTaskListsByDomainRequest struct {
Domain string `json:"domain,omitempty"`
}
func (v *GetTaskListsByDomainRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *GetTaskListsByDomainRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetTaskListsByDomainResponse is an internal type (TBD...)
type GetTaskListsByDomainResponse struct {
DecisionTaskListMap map[string]*DescribeTaskListResponse `json:"decisionTaskListMap,omitempty"`
ActivityTaskListMap map[string]*DescribeTaskListResponse `json:"activityTaskListMap,omitempty"`
}
// GetDecisionTaskListMap is an internal getter (TBD...)
func (v *GetTaskListsByDomainResponse) GetDecisionTaskListMap() (o map[string]*DescribeTaskListResponse) {
if v != nil && v.DecisionTaskListMap != nil {
return v.DecisionTaskListMap
}
return
}
// GetActivityTaskListMap is an internal getter (TBD...)
func (v *GetTaskListsByDomainResponse) GetActivityTaskListMap() (o map[string]*DescribeTaskListResponse) {
if v != nil && v.ActivityTaskListMap != nil {
return v.ActivityTaskListMap
}
return
}
// ListWorkflowExecutionsRequest is an internal type (TBD...)
type ListWorkflowExecutionsRequest struct {
Domain string `json:"domain,omitempty"`
PageSize int32 `json:"pageSize,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
Query string `json:"query,omitempty"`
}
func (v *ListWorkflowExecutionsRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *ListWorkflowExecutionsRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetPageSize is an internal getter (TBD...)
func (v *ListWorkflowExecutionsRequest) GetPageSize() (o int32) {
if v != nil {
return v.PageSize
}
return
}
// GetQuery is an internal getter (TBD...)
func (v *ListWorkflowExecutionsRequest) GetQuery() (o string) {
if v != nil {
return v.Query
}
return
}
// ListWorkflowExecutionsResponse is an internal type (TBD...)
type ListWorkflowExecutionsResponse struct {
Executions []*WorkflowExecutionInfo `json:"executions,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
}
// GetExecutions is an internal getter (TBD...)
func (v *ListWorkflowExecutionsResponse) GetExecutions() (o []*WorkflowExecutionInfo) {
if v != nil && v.Executions != nil {
return v.Executions
}
return
}
// GetNextPageToken is an internal getter (TBD...)
func (v *ListWorkflowExecutionsResponse) GetNextPageToken() (o []byte) {
if v != nil && v.NextPageToken != nil {
return v.NextPageToken
}
return
}
// MarkerRecordedEventAttributes is an internal type (TBD...)
type MarkerRecordedEventAttributes struct {
MarkerName string `json:"markerName,omitempty"`
Details []byte `json:"details,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
Header *Header `json:"header,omitempty"`
}
// GetMarkerName is an internal getter (TBD...)
func (v *MarkerRecordedEventAttributes) GetMarkerName() (o string) {
if v != nil {
return v.MarkerName
}
return
}
// Memo is an internal type (TBD...)
type Memo struct {
Fields map[string][]byte `json:"fields,omitempty"`
}
// GetFields is an internal getter (TBD...)
func (v *Memo) GetFields() (o map[string][]byte) {
if v != nil && v.Fields != nil {
return v.Fields
}
return
}
// ParentClosePolicy is an internal type (TBD...)
type ParentClosePolicy int32
// Ptr is a helper function for getting pointer value
func (e ParentClosePolicy) Ptr() *ParentClosePolicy {
return &e
}
// String returns a readable string representation of ParentClosePolicy.
func (e ParentClosePolicy) String() string {
w := int32(e)
switch w {
case 0:
return "ABANDON"
case 1:
return "REQUEST_CANCEL"
case 2:
return "TERMINATE"
}
return fmt.Sprintf("ParentClosePolicy(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *ParentClosePolicy) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "ABANDON":
*e = ParentClosePolicyAbandon
return nil
case "REQUEST_CANCEL":
*e = ParentClosePolicyRequestCancel
return nil
case "TERMINATE":
*e = ParentClosePolicyTerminate
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "ParentClosePolicy", err)
}
*e = ParentClosePolicy(val)
return nil
}
}
// MarshalText encodes ParentClosePolicy to text.
func (e ParentClosePolicy) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// ParentClosePolicyAbandon is an option for ParentClosePolicy
ParentClosePolicyAbandon ParentClosePolicy = iota
// ParentClosePolicyRequestCancel is an option for ParentClosePolicy
ParentClosePolicyRequestCancel
// ParentClosePolicyTerminate is an option for ParentClosePolicy
ParentClosePolicyTerminate
)
// PendingActivityInfo is an internal type (TBD...)
type PendingActivityInfo struct {
ActivityID string `json:"activityID,omitempty"`
ActivityType *ActivityType `json:"activityType,omitempty"`
State *PendingActivityState `json:"state,omitempty"`
HeartbeatDetails []byte `json:"heartbeatDetails,omitempty"`
LastHeartbeatTimestamp *int64 `json:"lastHeartbeatTimestamp,omitempty"`
LastStartedTimestamp *int64 `json:"lastStartedTimestamp,omitempty"`
Attempt int32 `json:"attempt,omitempty"`
MaximumAttempts int32 `json:"maximumAttempts,omitempty"`
ScheduledTimestamp *int64 `json:"scheduledTimestamp,omitempty"`
ExpirationTimestamp *int64 `json:"expirationTimestamp,omitempty"`
LastFailureReason *string `json:"lastFailureReason,omitempty"`
StartedWorkerIdentity string `json:"startedWorkerIdentity,omitempty"`
LastWorkerIdentity string `json:"lastWorkerIdentity,omitempty"`
LastFailureDetails []byte `json:"lastFailureDetails,omitempty"`
}
// GetActivityID is an internal getter (TBD...)
func (v *PendingActivityInfo) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// GetState is an internal getter (TBD...)
func (v *PendingActivityInfo) GetState() (o PendingActivityState) {
if v != nil && v.State != nil {
return *v.State
}
return
}
// GetHeartbeatDetails is an internal getter (TBD...)
func (v *PendingActivityInfo) GetHeartbeatDetails() (o []byte) {
if v != nil && v.HeartbeatDetails != nil {
return v.HeartbeatDetails
}
return
}
// GetLastHeartbeatTimestamp is an internal getter (TBD...)
func (v *PendingActivityInfo) GetLastHeartbeatTimestamp() (o int64) {
if v != nil && v.LastHeartbeatTimestamp != nil {
return *v.LastHeartbeatTimestamp
}
return
}
// GetAttempt is an internal getter (TBD...)
func (v *PendingActivityInfo) GetAttempt() (o int32) {
if v != nil {
return v.Attempt
}
return
}
// GetMaximumAttempts is an internal getter (TBD...)
func (v *PendingActivityInfo) GetMaximumAttempts() (o int32) {
if v != nil {
return v.MaximumAttempts
}
return
}
// GetLastFailureReason is an internal getter (TBD...)
func (v *PendingActivityInfo) GetLastFailureReason() (o string) {
if v != nil && v.LastFailureReason != nil {
return *v.LastFailureReason
}
return
}
// GetStartedWorkerIdentity is an internal getter (TBD...)
func (v *PendingActivityInfo) GetStartedWorkerIdentity() (o string) {
if v != nil {
return v.StartedWorkerIdentity
}
return
}
// GetLastWorkerIdentity is an internal getter (TBD...)
func (v *PendingActivityInfo) GetLastWorkerIdentity() (o string) {
if v != nil {
return v.LastWorkerIdentity
}
return
}
// GetLastFailureDetails is an internal getter (TBD...)
func (v *PendingActivityInfo) GetLastFailureDetails() (o []byte) {
if v != nil && v.LastFailureDetails != nil {
return v.LastFailureDetails
}
return
}
// PendingActivityState is an internal type (TBD...)
type PendingActivityState int32
// Ptr is a helper function for getting pointer value
func (e PendingActivityState) Ptr() *PendingActivityState {
return &e
}
// String returns a readable string representation of PendingActivityState.
func (e PendingActivityState) String() string {
w := int32(e)
switch w {
case 0:
return "SCHEDULED"
case 1:
return "STARTED"
case 2:
return "CANCEL_REQUESTED"
}
return fmt.Sprintf("PendingActivityState(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *PendingActivityState) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "SCHEDULED":
*e = PendingActivityStateScheduled
return nil
case "STARTED":
*e = PendingActivityStateStarted
return nil
case "CANCEL_REQUESTED":
*e = PendingActivityStateCancelRequested
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "PendingActivityState", err)
}
*e = PendingActivityState(val)
return nil
}
}
// MarshalText encodes PendingActivityState to text.
func (e PendingActivityState) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// PendingActivityStateScheduled is an option for PendingActivityState
PendingActivityStateScheduled PendingActivityState = iota
// PendingActivityStateStarted is an option for PendingActivityState
PendingActivityStateStarted
// PendingActivityStateCancelRequested is an option for PendingActivityState
PendingActivityStateCancelRequested
)
// PendingChildExecutionInfo is an internal type (TBD...)
type PendingChildExecutionInfo struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowID,omitempty"`
RunID string `json:"runID,omitempty"`
WorkflowTypeName string `json:"workflowTypeName,omitempty"`
InitiatedID int64 `json:"initiatedID,omitempty"`
ParentClosePolicy *ParentClosePolicy `json:"parentClosePolicy,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *PendingChildExecutionInfo) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *PendingChildExecutionInfo) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *PendingChildExecutionInfo) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// GetWorkflowTypeName is an internal getter (TBD...)
func (v *PendingChildExecutionInfo) GetWorkflowTypeName() (o string) {
if v != nil {
return v.WorkflowTypeName
}
return
}
// PendingDecisionInfo is an internal type (TBD...)
type PendingDecisionInfo struct {
State *PendingDecisionState `json:"state,omitempty"`
ScheduledTimestamp *int64 `json:"scheduledTimestamp,omitempty"`
StartedTimestamp *int64 `json:"startedTimestamp,omitempty"`
Attempt int64 `json:"attempt,omitempty"`
OriginalScheduledTimestamp *int64 `json:"originalScheduledTimestamp,omitempty"`
}
// PendingDecisionState is an internal type (TBD...)
type PendingDecisionState int32
// Ptr is a helper function for getting pointer value
func (e PendingDecisionState) Ptr() *PendingDecisionState {
return &e
}
// String returns a readable string representation of PendingDecisionState.
func (e PendingDecisionState) String() string {
w := int32(e)
switch w {
case 0:
return "SCHEDULED"
case 1:
return "STARTED"
}
return fmt.Sprintf("PendingDecisionState(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *PendingDecisionState) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "SCHEDULED":
*e = PendingDecisionStateScheduled
return nil
case "STARTED":
*e = PendingDecisionStateStarted
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "PendingDecisionState", err)
}
*e = PendingDecisionState(val)
return nil
}
}
// MarshalText encodes PendingDecisionState to text.
func (e PendingDecisionState) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// PendingDecisionStateScheduled is an option for PendingDecisionState
PendingDecisionStateScheduled PendingDecisionState = iota
// PendingDecisionStateStarted is an option for PendingDecisionState
PendingDecisionStateStarted
)
// PollForActivityTaskRequest is an internal type (TBD...)
type PollForActivityTaskRequest struct {
Domain string `json:"domain,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Identity string `json:"identity,omitempty"`
TaskListMetadata *TaskListMetadata `json:"taskListMetadata,omitempty"`
}
func (v *PollForActivityTaskRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *PollForActivityTaskRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetTaskList is an internal getter (TBD...)
func (v *PollForActivityTaskRequest) GetTaskList() (o *TaskList) {
if v != nil && v.TaskList != nil {
return v.TaskList
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *PollForActivityTaskRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// PollForActivityTaskResponse is an internal type (TBD...)
type PollForActivityTaskResponse struct {
TaskToken []byte `json:"taskToken,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
ActivityID string `json:"activityId,omitempty"`
ActivityType *ActivityType `json:"activityType,omitempty"`
Input []byte `json:"input,omitempty"`
ScheduledTimestamp *int64 `json:"scheduledTimestamp,omitempty"`
ScheduleToCloseTimeoutSeconds *int32 `json:"scheduleToCloseTimeoutSeconds,omitempty"`
StartedTimestamp *int64 `json:"startedTimestamp,omitempty"`
StartToCloseTimeoutSeconds *int32 `json:"startToCloseTimeoutSeconds,omitempty"`
HeartbeatTimeoutSeconds *int32 `json:"heartbeatTimeoutSeconds,omitempty"`
Attempt int32 `json:"attempt,omitempty"`
ScheduledTimestampOfThisAttempt *int64 `json:"scheduledTimestampOfThisAttempt,omitempty"`
HeartbeatDetails []byte `json:"heartbeatDetails,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
WorkflowDomain string `json:"workflowDomain,omitempty"`
Header *Header `json:"header,omitempty"`
}
// GetActivityID is an internal getter (TBD...)
func (v *PollForActivityTaskResponse) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// PollForDecisionTaskRequest is an internal type (TBD...)
type PollForDecisionTaskRequest struct {
Domain string `json:"domain,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Identity string `json:"identity,omitempty"`
BinaryChecksum string `json:"binaryChecksum,omitempty"`
}
func (v *PollForDecisionTaskRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *PollForDecisionTaskRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetTaskList is an internal getter (TBD...)
func (v *PollForDecisionTaskRequest) GetTaskList() (o *TaskList) {
if v != nil && v.TaskList != nil {
return v.TaskList
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *PollForDecisionTaskRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// GetBinaryChecksum is an internal getter (TBD...)
func (v *PollForDecisionTaskRequest) GetBinaryChecksum() (o string) {
if v != nil {
return v.BinaryChecksum
}
return
}
// PollForDecisionTaskResponse is an internal type (TBD...)
type PollForDecisionTaskResponse struct {
TaskToken []byte `json:"taskToken,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
PreviousStartedEventID *int64 `json:"previousStartedEventId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
Attempt int64 `json:"attempt,omitempty"`
BacklogCountHint int64 `json:"backlogCountHint,omitempty"`
History *History `json:"history,omitempty"`
NextPageToken []byte `json:"nextPageToken,omitempty"`
Query *WorkflowQuery `json:"query,omitempty"`
WorkflowExecutionTaskList *TaskList `json:"WorkflowExecutionTaskList,omitempty"`
ScheduledTimestamp *int64 `json:"scheduledTimestamp,omitempty"`
StartedTimestamp *int64 `json:"startedTimestamp,omitempty"`
Queries map[string]*WorkflowQuery `json:"queries,omitempty"`
NextEventID int64 `json:"nextEventId,omitempty"`
TotalHistoryBytes int64 `json:"historySize,omitempty"`
}
// GetTaskToken is an internal getter (TBD...)
func (v *PollForDecisionTaskResponse) GetTaskToken() (o []byte) {
if v != nil && v.TaskToken != nil {
return v.TaskToken
}
return
}
// GetPreviousStartedEventID is an internal getter (TBD...)
func (v *PollForDecisionTaskResponse) GetPreviousStartedEventID() (o int64) {
if v != nil && v.PreviousStartedEventID != nil {
return *v.PreviousStartedEventID
}
return
}
// GetStartedEventID is an internal getter (TBD...)
func (v *PollForDecisionTaskResponse) GetStartedEventID() (o int64) {
if v != nil {
return v.StartedEventID
}
return
}
// GetAttempt is an internal getter (TBD...)
func (v *PollForDecisionTaskResponse) GetAttempt() (o int64) {
if v != nil {
return v.Attempt
}
return
}
// GetQueries is an internal getter (TBD...)
func (v *PollForDecisionTaskResponse) GetQueries() (o map[string]*WorkflowQuery) {
if v != nil && v.Queries != nil {
return v.Queries
}
return
}
// GetNextEventID is an internal getter (TBD...)
func (v *PollForDecisionTaskResponse) GetNextEventID() (o int64) {
if v != nil {
return v.NextEventID
}
return
}
func (v *PollForDecisionTaskResponse) GetHistorySize() (o int64) {
if v != nil {
return v.TotalHistoryBytes
}
return
}
// PollerInfo is an internal type (TBD...)
type PollerInfo struct {
LastAccessTime *int64 `json:"lastAccessTime,omitempty"`
Identity string `json:"identity,omitempty"`
RatePerSecond float64 `json:"ratePerSecond,omitempty"`
}
// GetLastAccessTime is an internal getter (TBD...)
func (v *PollerInfo) GetLastAccessTime() (o int64) {
if v != nil && v.LastAccessTime != nil {
return *v.LastAccessTime
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *PollerInfo) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// GetRatePerSecond is an internal getter (TBD...)
func (v *PollerInfo) GetRatePerSecond() (o float64) {
if v != nil {
return v.RatePerSecond
}
return
}
// QueryConsistencyLevel is an internal type (TBD...)
type QueryConsistencyLevel int32
// Ptr is a helper function for getting pointer value
func (e QueryConsistencyLevel) Ptr() *QueryConsistencyLevel {
return &e
}
// String returns a readable string representation of QueryConsistencyLevel.
func (e QueryConsistencyLevel) String() string {
w := int32(e)
switch w {
case 0:
return "EVENTUAL"
case 1:
return "STRONG"
}
return fmt.Sprintf("QueryConsistencyLevel(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *QueryConsistencyLevel) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "EVENTUAL":
*e = QueryConsistencyLevelEventual
return nil
case "STRONG":
*e = QueryConsistencyLevelStrong
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "QueryConsistencyLevel", err)
}
*e = QueryConsistencyLevel(val)
return nil
}
}
// MarshalText encodes QueryConsistencyLevel to text.
func (e QueryConsistencyLevel) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// QueryConsistencyLevelEventual is an option for QueryConsistencyLevel
QueryConsistencyLevelEventual QueryConsistencyLevel = iota
// QueryConsistencyLevelStrong is an option for QueryConsistencyLevel
QueryConsistencyLevelStrong
)
// QueryFailedError is an internal type (TBD...)
type QueryFailedError struct {
Message string `json:"message,required"`
}
// QueryRejectCondition is an internal type (TBD...)
type QueryRejectCondition int32
// Ptr is a helper function for getting pointer value
func (e QueryRejectCondition) Ptr() *QueryRejectCondition {
return &e
}
// String returns a readable string representation of QueryRejectCondition.
func (e QueryRejectCondition) String() string {
w := int32(e)
switch w {
case 0:
return "NOT_OPEN"
case 1:
return "NOT_COMPLETED_CLEANLY"
}
return fmt.Sprintf("QueryRejectCondition(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *QueryRejectCondition) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "NOT_OPEN":
*e = QueryRejectConditionNotOpen
return nil
case "NOT_COMPLETED_CLEANLY":
*e = QueryRejectConditionNotCompletedCleanly
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "QueryRejectCondition", err)
}
*e = QueryRejectCondition(val)
return nil
}
}
// MarshalText encodes QueryRejectCondition to text.
func (e QueryRejectCondition) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// QueryRejectConditionNotOpen is an option for QueryRejectCondition
QueryRejectConditionNotOpen QueryRejectCondition = iota
// QueryRejectConditionNotCompletedCleanly is an option for QueryRejectCondition
QueryRejectConditionNotCompletedCleanly
)
// QueryRejected is an internal type (TBD...)
type QueryRejected struct {
CloseStatus *WorkflowExecutionCloseStatus `json:"closeStatus,omitempty"`
}
// QueryResultType is an internal type (TBD...)
type QueryResultType int32
// Ptr is a helper function for getting pointer value
func (e QueryResultType) Ptr() *QueryResultType {
return &e
}
// String returns a readable string representation of QueryResultType.
func (e QueryResultType) String() string {
w := int32(e)
switch w {
case 0:
return "ANSWERED"
case 1:
return "FAILED"
}
return fmt.Sprintf("QueryResultType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *QueryResultType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "ANSWERED":
*e = QueryResultTypeAnswered
return nil
case "FAILED":
*e = QueryResultTypeFailed
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "QueryResultType", err)
}
*e = QueryResultType(val)
return nil
}
}
// MarshalText encodes QueryResultType to text.
func (e QueryResultType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// QueryResultTypeAnswered is an option for QueryResultType
QueryResultTypeAnswered QueryResultType = iota
// QueryResultTypeFailed is an option for QueryResultType
QueryResultTypeFailed
)
// QueryTaskCompletedType is an internal type (TBD...)
type QueryTaskCompletedType int32
// Ptr is a helper function for getting pointer value
func (e QueryTaskCompletedType) Ptr() *QueryTaskCompletedType {
return &e
}
// String returns a readable string representation of QueryTaskCompletedType.
func (e QueryTaskCompletedType) String() string {
w := int32(e)
switch w {
case 0:
return "COMPLETED"
case 1:
return "FAILED"
}
return fmt.Sprintf("QueryTaskCompletedType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *QueryTaskCompletedType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "COMPLETED":
*e = QueryTaskCompletedTypeCompleted
return nil
case "FAILED":
*e = QueryTaskCompletedTypeFailed
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "QueryTaskCompletedType", err)
}
*e = QueryTaskCompletedType(val)
return nil
}
}
// MarshalText encodes QueryTaskCompletedType to text.
func (e QueryTaskCompletedType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// QueryTaskCompletedTypeCompleted is an option for QueryTaskCompletedType
QueryTaskCompletedTypeCompleted QueryTaskCompletedType = iota
// QueryTaskCompletedTypeFailed is an option for QueryTaskCompletedType
QueryTaskCompletedTypeFailed
)
// QueryWorkflowRequest is an internal type (TBD...)
type QueryWorkflowRequest struct {
Domain string `json:"domain,omitempty"`
Execution *WorkflowExecution `json:"execution,omitempty"`
Query *WorkflowQuery `json:"query,omitempty"`
QueryRejectCondition *QueryRejectCondition `json:"queryRejectCondition,omitempty"`
QueryConsistencyLevel *QueryConsistencyLevel `json:"queryConsistencyLevel,omitempty"`
}
func (v *QueryWorkflowRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *QueryWorkflowRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetExecution is an internal getter (TBD...)
func (v *QueryWorkflowRequest) GetExecution() (o *WorkflowExecution) {
if v != nil && v.Execution != nil {
return v.Execution
}
return
}
// GetQuery is an internal getter (TBD...)
func (v *QueryWorkflowRequest) GetQuery() (o *WorkflowQuery) {
if v != nil && v.Query != nil {
return v.Query
}
return
}
// GetQueryRejectCondition is an internal getter (TBD...)
func (v *QueryWorkflowRequest) GetQueryRejectCondition() (o QueryRejectCondition) {
if v != nil && v.QueryRejectCondition != nil {
return *v.QueryRejectCondition
}
return
}
// GetQueryConsistencyLevel is an internal getter (TBD...)
func (v *QueryWorkflowRequest) GetQueryConsistencyLevel() (o QueryConsistencyLevel) {
if v != nil && v.QueryConsistencyLevel != nil {
return *v.QueryConsistencyLevel
}
return
}
// QueryWorkflowResponse is an internal type (TBD...)
type QueryWorkflowResponse struct {
QueryResult []byte `json:"queryResult,omitempty"`
QueryRejected *QueryRejected `json:"queryRejected,omitempty"`
}
// GetQueryResult is an internal getter (TBD...)
func (v *QueryWorkflowResponse) GetQueryResult() (o []byte) {
if v != nil && v.QueryResult != nil {
return v.QueryResult
}
return
}
// GetQueryRejected is an internal getter (TBD...)
func (v *QueryWorkflowResponse) GetQueryRejected() (o *QueryRejected) {
if v != nil && v.QueryRejected != nil {
return v.QueryRejected
}
return
}
// ReapplyEventsRequest is an internal type (TBD...)
type ReapplyEventsRequest struct {
DomainName string `json:"domainName,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
Events *DataBlob `json:"events,omitempty"`
}
func (v *ReapplyEventsRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomainName is an internal getter (TBD...)
func (v *ReapplyEventsRequest) GetDomainName() (o string) {
if v != nil {
return v.DomainName
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *ReapplyEventsRequest) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// GetEvents is an internal getter (TBD...)
func (v *ReapplyEventsRequest) GetEvents() (o *DataBlob) {
if v != nil && v.Events != nil {
return v.Events
}
return
}
// RecordActivityTaskHeartbeatByIDRequest is an internal type (TBD...)
type RecordActivityTaskHeartbeatByIDRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowID,omitempty"`
RunID string `json:"runID,omitempty"`
ActivityID string `json:"activityID,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *RecordActivityTaskHeartbeatByIDRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *RecordActivityTaskHeartbeatByIDRequest) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *RecordActivityTaskHeartbeatByIDRequest) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// GetActivityID is an internal getter (TBD...)
func (v *RecordActivityTaskHeartbeatByIDRequest) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// RecordActivityTaskHeartbeatRequest is an internal type (TBD...)
type RecordActivityTaskHeartbeatRequest struct {
TaskToken []byte `json:"taskToken,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
}
func (v *RecordActivityTaskHeartbeatRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// RecordActivityTaskHeartbeatResponse is an internal type (TBD...)
type RecordActivityTaskHeartbeatResponse struct {
CancelRequested bool `json:"cancelRequested,omitempty"`
}
// RecordMarkerDecisionAttributes is an internal type (TBD...)
type RecordMarkerDecisionAttributes struct {
MarkerName string `json:"markerName,omitempty"`
Details []byte `json:"details,omitempty"`
Header *Header `json:"header,omitempty"`
}
// GetMarkerName is an internal getter (TBD...)
func (v *RecordMarkerDecisionAttributes) GetMarkerName() (o string) {
if v != nil {
return v.MarkerName
}
return
}
// RefreshWorkflowTasksRequest is an internal type (TBD...)
type RefreshWorkflowTasksRequest struct {
Domain string `json:"domain,omitempty"`
Execution *WorkflowExecution `json:"execution,omitempty"`
}
func (v *RefreshWorkflowTasksRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *RefreshWorkflowTasksRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetExecution is an internal getter (TBD...)
func (v *RefreshWorkflowTasksRequest) GetExecution() (o *WorkflowExecution) {
if v != nil && v.Execution != nil {
return v.Execution
}
return
}
// RegisterDomainRequest is an internal type (TBD...)
type RegisterDomainRequest struct {
Name string `json:"name,omitempty"`
Description string `json:"description,omitempty"`
OwnerEmail string `json:"ownerEmail,omitempty"`
WorkflowExecutionRetentionPeriodInDays int32 `json:"workflowExecutionRetentionPeriodInDays,omitempty"`
EmitMetric *bool `json:"emitMetric,omitempty"`
Clusters []*ClusterReplicationConfiguration `json:"clusters,omitempty"`
ActiveClusterName string `json:"activeClusterName,omitempty"`
Data map[string]string `json:"data,omitempty"`
SecurityToken string `json:"securityToken,omitempty"`
IsGlobalDomain bool `json:"isGlobalDomain,omitempty"`
HistoryArchivalStatus *ArchivalStatus `json:"historyArchivalStatus,omitempty"`
HistoryArchivalURI string `json:"historyArchivalURI,omitempty"`
VisibilityArchivalStatus *ArchivalStatus `json:"visibilityArchivalStatus,omitempty"`
VisibilityArchivalURI string `json:"visibilityArchivalURI,omitempty"`
}
func (v *RegisterDomainRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetName is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetName() (o string) {
if v != nil {
return v.Name
}
return
}
// GetDescription is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetDescription() (o string) {
if v != nil {
return v.Description
}
return
}
// GetOwnerEmail is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetOwnerEmail() (o string) {
if v != nil {
return v.OwnerEmail
}
return
}
// GetWorkflowExecutionRetentionPeriodInDays is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetWorkflowExecutionRetentionPeriodInDays() (o int32) {
if v != nil {
return v.WorkflowExecutionRetentionPeriodInDays
}
return
}
// GetEmitMetric is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetEmitMetric() (o bool) {
if v != nil && v.EmitMetric != nil {
return *v.EmitMetric
}
o = true
return
}
// GetActiveClusterName is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetActiveClusterName() (o string) {
if v != nil {
return v.ActiveClusterName
}
return
}
// GetData is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetData() (o map[string]string) {
if v != nil && v.Data != nil {
return v.Data
}
return
}
// GetIsGlobalDomain is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetIsGlobalDomain() (o bool) {
if v != nil {
return v.IsGlobalDomain
}
return
}
// GetHistoryArchivalURI is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetHistoryArchivalURI() (o string) {
if v != nil {
return v.HistoryArchivalURI
}
return
}
// GetVisibilityArchivalURI is an internal getter (TBD...)
func (v *RegisterDomainRequest) GetVisibilityArchivalURI() (o string) {
if v != nil {
return v.VisibilityArchivalURI
}
return
}
// RemoteSyncMatchedError is an internal type (TBD...)
type RemoteSyncMatchedError struct {
Message string `json:"message,required"`
}
// RemoveTaskRequest is an internal type (TBD...)
type RemoveTaskRequest struct {
ShardID int32 `json:"shardID,omitempty"`
Type *int32 `json:"type,omitempty"`
TaskID int64 `json:"taskID,omitempty"`
VisibilityTimestamp *int64 `json:"visibilityTimestamp,omitempty"`
ClusterName string `json:"clusterName,omitempty"`
}
func (v *RemoveTaskRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetShardID is an internal getter (TBD...)
func (v *RemoveTaskRequest) GetShardID() (o int32) {
if v != nil {
return v.ShardID
}
return
}
// GetType is an internal getter (TBD...)
func (v *RemoveTaskRequest) GetType() (o int32) {
if v != nil && v.Type != nil {
return *v.Type
}
return
}
// GetTaskID is an internal getter (TBD...)
func (v *RemoveTaskRequest) GetTaskID() (o int64) {
if v != nil {
return v.TaskID
}
return
}
// GetVisibilityTimestamp is an internal getter (TBD...)
func (v *RemoveTaskRequest) GetVisibilityTimestamp() (o int64) {
if v != nil && v.VisibilityTimestamp != nil {
return *v.VisibilityTimestamp
}
return
}
// GetClusterName is an internal getter (TBD...)
func (v *RemoveTaskRequest) GetClusterName() (o string) {
if v != nil {
return v.ClusterName
}
return
}
// RequestCancelActivityTaskDecisionAttributes is an internal type (TBD...)
type RequestCancelActivityTaskDecisionAttributes struct {
ActivityID string `json:"activityId,omitempty"`
}
// GetActivityID is an internal getter (TBD...)
func (v *RequestCancelActivityTaskDecisionAttributes) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// RequestCancelActivityTaskFailedEventAttributes is an internal type (TBD...)
type RequestCancelActivityTaskFailedEventAttributes struct {
ActivityID string `json:"activityId,omitempty"`
Cause string `json:"cause,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
}
// RequestCancelExternalWorkflowExecutionDecisionAttributes is an internal type (TBD...)
type RequestCancelExternalWorkflowExecutionDecisionAttributes struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowId,omitempty"`
RunID string `json:"runId,omitempty"`
Control []byte `json:"control,omitempty"`
ChildWorkflowOnly bool `json:"childWorkflowOnly,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionDecisionAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionDecisionAttributes) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionDecisionAttributes) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// RequestCancelExternalWorkflowExecutionFailedEventAttributes is an internal type (TBD...)
type RequestCancelExternalWorkflowExecutionFailedEventAttributes struct {
Cause *CancelExternalWorkflowExecutionFailedCause `json:"cause,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
Control []byte `json:"control,omitempty"`
}
// GetDecisionTaskCompletedEventID is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetDecisionTaskCompletedEventID() (o int64) {
if v != nil {
return v.DecisionTaskCompletedEventID
}
return
}
// GetDomain is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// RequestCancelExternalWorkflowExecutionInitiatedEventAttributes is an internal type (TBD...)
type RequestCancelExternalWorkflowExecutionInitiatedEventAttributes struct {
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
Control []byte `json:"control,omitempty"`
ChildWorkflowOnly bool `json:"childWorkflowOnly,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// GetChildWorkflowOnly is an internal getter (TBD...)
func (v *RequestCancelExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly() (o bool) {
if v != nil {
return v.ChildWorkflowOnly
}
return
}
// RequestCancelWorkflowExecutionRequest is an internal type (TBD...)
type RequestCancelWorkflowExecutionRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
Cause string `json:"cause,omitempty"`
FirstExecutionRunID string `json:"first_execution_run_id,omitempty"`
}
func (v *RequestCancelWorkflowExecutionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *RequestCancelWorkflowExecutionRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *RequestCancelWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *RequestCancelWorkflowExecutionRequest) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// GetFirstExecutionRunID is an internal getter (TBD...)
func (v *RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunID() (o string) {
if v != nil {
return v.FirstExecutionRunID
}
return
}
// ResetPointInfo is an internal type (TBD...)
type ResetPointInfo struct {
BinaryChecksum string `json:"binaryChecksum,omitempty"`
RunID string `json:"runId,omitempty"`
FirstDecisionCompletedID int64 `json:"firstDecisionCompletedId,omitempty"`
CreatedTimeNano *int64 `json:"createdTimeNano,omitempty"`
ExpiringTimeNano *int64 `json:"expiringTimeNano,omitempty"`
Resettable bool `json:"resettable,omitempty"`
}
// GetBinaryChecksum is an internal getter (TBD...)
func (v *ResetPointInfo) GetBinaryChecksum() (o string) {
if v != nil {
return v.BinaryChecksum
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *ResetPointInfo) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// GetFirstDecisionCompletedID is an internal getter (TBD...)
func (v *ResetPointInfo) GetFirstDecisionCompletedID() (o int64) {
if v != nil {
return v.FirstDecisionCompletedID
}
return
}
// GetCreatedTimeNano is an internal getter (TBD...)
func (v *ResetPointInfo) GetCreatedTimeNano() (o int64) {
if v != nil && v.CreatedTimeNano != nil {
return *v.CreatedTimeNano
}
return
}
// GetExpiringTimeNano is an internal getter (TBD...)
func (v *ResetPointInfo) GetExpiringTimeNano() (o int64) {
if v != nil && v.ExpiringTimeNano != nil {
return *v.ExpiringTimeNano
}
return
}
// GetResettable is an internal getter (TBD...)
func (v *ResetPointInfo) GetResettable() (o bool) {
if v != nil {
return v.Resettable
}
return
}
// ResetPoints is an internal type (TBD...)
type ResetPoints struct {
Points []*ResetPointInfo `json:"points,omitempty"`
}
// ResetQueueRequest is an internal type (TBD...)
type ResetQueueRequest struct {
ShardID int32 `json:"shardID,omitempty"`
ClusterName string `json:"clusterName,omitempty"`
Type *int32 `json:"type,omitempty"`
}
func (v *ResetQueueRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetShardID is an internal getter (TBD...)
func (v *ResetQueueRequest) GetShardID() (o int32) {
if v != nil {
return v.ShardID
}
return
}
// GetClusterName is an internal getter (TBD...)
func (v *ResetQueueRequest) GetClusterName() (o string) {
if v != nil {
return v.ClusterName
}
return
}
// GetType is an internal getter (TBD...)
func (v *ResetQueueRequest) GetType() (o int32) {
if v != nil && v.Type != nil {
return *v.Type
}
return
}
// ResetStickyTaskListRequest is an internal type (TBD...)
type ResetStickyTaskListRequest struct {
Domain string `json:"domain,omitempty"`
Execution *WorkflowExecution `json:"execution,omitempty"`
}
func (v *ResetStickyTaskListRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *ResetStickyTaskListRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetExecution is an internal getter (TBD...)
func (v *ResetStickyTaskListRequest) GetExecution() (o *WorkflowExecution) {
if v != nil && v.Execution != nil {
return v.Execution
}
return
}
// ResetStickyTaskListResponse is an internal type (TBD...)
type ResetStickyTaskListResponse struct {
}
// ResetWorkflowExecutionRequest is an internal type (TBD...)
type ResetWorkflowExecutionRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
Reason string `json:"reason,omitempty"`
DecisionFinishEventID int64 `json:"decisionFinishEventId,omitempty"`
RequestID string `json:"requestId,omitempty"`
SkipSignalReapply bool `json:"skipSignalReapply,omitempty"`
}
func (v *ResetWorkflowExecutionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *ResetWorkflowExecutionRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *ResetWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// GetReason is an internal getter (TBD...)
func (v *ResetWorkflowExecutionRequest) GetReason() (o string) {
if v != nil {
return v.Reason
}
return
}
// GetDecisionFinishEventID is an internal getter (TBD...)
func (v *ResetWorkflowExecutionRequest) GetDecisionFinishEventID() (o int64) {
if v != nil {
return v.DecisionFinishEventID
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *ResetWorkflowExecutionRequest) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// GetSkipSignalReapply is an internal getter (TBD...)
func (v *ResetWorkflowExecutionRequest) GetSkipSignalReapply() (o bool) {
if v != nil {
return v.SkipSignalReapply
}
return
}
// ResetWorkflowExecutionResponse is an internal type (TBD...)
type ResetWorkflowExecutionResponse struct {
RunID string `json:"runId,omitempty"`
}
// GetRunID is an internal getter (TBD...)
func (v *ResetWorkflowExecutionResponse) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// RespondActivityTaskCanceledByIDRequest is an internal type (TBD...)
type RespondActivityTaskCanceledByIDRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowID,omitempty"`
RunID string `json:"runID,omitempty"`
ActivityID string `json:"activityID,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *RespondActivityTaskCanceledByIDRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *RespondActivityTaskCanceledByIDRequest) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *RespondActivityTaskCanceledByIDRequest) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// GetActivityID is an internal getter (TBD...)
func (v *RespondActivityTaskCanceledByIDRequest) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *RespondActivityTaskCanceledByIDRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// RespondActivityTaskCanceledRequest is an internal type (TBD...)
type RespondActivityTaskCanceledRequest struct {
TaskToken []byte `json:"taskToken,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetIdentity is an internal getter (TBD...)
func (v *RespondActivityTaskCanceledRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// RespondActivityTaskCompletedByIDRequest is an internal type (TBD...)
type RespondActivityTaskCompletedByIDRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowID,omitempty"`
RunID string `json:"runID,omitempty"`
ActivityID string `json:"activityID,omitempty"`
Result []byte `json:"result,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *RespondActivityTaskCompletedByIDRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *RespondActivityTaskCompletedByIDRequest) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *RespondActivityTaskCompletedByIDRequest) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// GetActivityID is an internal getter (TBD...)
func (v *RespondActivityTaskCompletedByIDRequest) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *RespondActivityTaskCompletedByIDRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// RespondActivityTaskCompletedRequest is an internal type (TBD...)
type RespondActivityTaskCompletedRequest struct {
TaskToken []byte `json:"taskToken,omitempty"`
Result []byte `json:"result,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetIdentity is an internal getter (TBD...)
func (v *RespondActivityTaskCompletedRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// RespondActivityTaskFailedByIDRequest is an internal type (TBD...)
type RespondActivityTaskFailedByIDRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowID,omitempty"`
RunID string `json:"runID,omitempty"`
ActivityID string `json:"activityID,omitempty"`
Reason *string `json:"reason,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *RespondActivityTaskFailedByIDRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *RespondActivityTaskFailedByIDRequest) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *RespondActivityTaskFailedByIDRequest) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// GetActivityID is an internal getter (TBD...)
func (v *RespondActivityTaskFailedByIDRequest) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *RespondActivityTaskFailedByIDRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// RespondActivityTaskFailedRequest is an internal type (TBD...)
type RespondActivityTaskFailedRequest struct {
TaskToken []byte `json:"taskToken,omitempty"`
Reason *string `json:"reason,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetReason is an internal getter (TBD...)
func (v *RespondActivityTaskFailedRequest) GetReason() (o string) {
if v != nil && v.Reason != nil {
return *v.Reason
}
return
}
// GetDetails is an internal getter (TBD...)
func (v *RespondActivityTaskFailedRequest) GetDetails() (o []byte) {
if v != nil && v.Details != nil {
return v.Details
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *RespondActivityTaskFailedRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// RespondDecisionTaskCompletedRequest is an internal type (TBD...)
type RespondDecisionTaskCompletedRequest struct {
TaskToken []byte `json:"taskToken,omitempty"`
Decisions []*Decision `json:"decisions,omitempty"`
ExecutionContext []byte `json:"executionContext,omitempty"`
Identity string `json:"identity,omitempty"`
StickyAttributes *StickyExecutionAttributes `json:"stickyAttributes,omitempty"`
ReturnNewDecisionTask bool `json:"returnNewDecisionTask,omitempty"`
ForceCreateNewDecisionTask bool `json:"forceCreateNewDecisionTask,omitempty"`
BinaryChecksum string `json:"binaryChecksum,omitempty"`
QueryResults map[string]*WorkflowQueryResult `json:"queryResults,omitempty"`
}
// GetIdentity is an internal getter (TBD...)
func (v *RespondDecisionTaskCompletedRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// GetReturnNewDecisionTask is an internal getter (TBD...)
func (v *RespondDecisionTaskCompletedRequest) GetReturnNewDecisionTask() (o bool) {
if v != nil {
return v.ReturnNewDecisionTask
}
return
}
// GetForceCreateNewDecisionTask is an internal getter (TBD...)
func (v *RespondDecisionTaskCompletedRequest) GetForceCreateNewDecisionTask() (o bool) {
if v != nil {
return v.ForceCreateNewDecisionTask
}
return
}
// GetBinaryChecksum is an internal getter (TBD...)
func (v *RespondDecisionTaskCompletedRequest) GetBinaryChecksum() (o string) {
if v != nil {
return v.BinaryChecksum
}
return
}
// GetQueryResults is an internal getter (TBD...)
func (v *RespondDecisionTaskCompletedRequest) GetQueryResults() (o map[string]*WorkflowQueryResult) {
if v != nil && v.QueryResults != nil {
return v.QueryResults
}
return
}
// RespondDecisionTaskCompletedResponse is an internal type (TBD...)
type RespondDecisionTaskCompletedResponse struct {
DecisionTask *PollForDecisionTaskResponse `json:"decisionTask,omitempty"`
ActivitiesToDispatchLocally map[string]*ActivityLocalDispatchInfo `json:"activitiesToDispatchLocally,omitempty"`
}
// GetDecisionTask is an internal getter (TBD...)
func (v *RespondDecisionTaskCompletedResponse) GetDecisionTask() (o *PollForDecisionTaskResponse) {
if v != nil && v.DecisionTask != nil {
return v.DecisionTask
}
return
}
// RespondDecisionTaskFailedRequest is an internal type (TBD...)
type RespondDecisionTaskFailedRequest struct {
TaskToken []byte `json:"taskToken,omitempty"`
Cause *DecisionTaskFailedCause `json:"cause,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
BinaryChecksum string `json:"binaryChecksum,omitempty"`
}
// GetCause is an internal getter (TBD...)
func (v *RespondDecisionTaskFailedRequest) GetCause() (o DecisionTaskFailedCause) {
if v != nil && v.Cause != nil {
return *v.Cause
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *RespondDecisionTaskFailedRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// GetBinaryChecksum is an internal getter (TBD...)
func (v *RespondDecisionTaskFailedRequest) GetBinaryChecksum() (o string) {
if v != nil {
return v.BinaryChecksum
}
return
}
// RespondQueryTaskCompletedRequest is an internal type (TBD...)
type RespondQueryTaskCompletedRequest struct {
TaskToken []byte `json:"taskToken,omitempty"`
CompletedType *QueryTaskCompletedType `json:"completedType,omitempty"`
QueryResult []byte `json:"queryResult,omitempty"`
ErrorMessage string `json:"errorMessage,omitempty"`
WorkerVersionInfo *WorkerVersionInfo `json:"workerVersionInfo,omitempty"`
}
// GetCompletedType is an internal getter (TBD...)
func (v *RespondQueryTaskCompletedRequest) GetCompletedType() (o QueryTaskCompletedType) {
if v != nil && v.CompletedType != nil {
return *v.CompletedType
}
return
}
// GetQueryResult is an internal getter (TBD...)
func (v *RespondQueryTaskCompletedRequest) GetQueryResult() (o []byte) {
if v != nil && v.QueryResult != nil {
return v.QueryResult
}
return
}
// GetErrorMessage is an internal getter (TBD...)
func (v *RespondQueryTaskCompletedRequest) GetErrorMessage() (o string) {
if v != nil {
return v.ErrorMessage
}
return
}
// GetWorkerVersionInfo is an internal getter (TBD...)
func (v *RespondQueryTaskCompletedRequest) GetWorkerVersionInfo() (o *WorkerVersionInfo) {
if v != nil && v.WorkerVersionInfo != nil {
return v.WorkerVersionInfo
}
return
}
// RetryPolicy is an internal type (TBD...)
type RetryPolicy struct {
InitialIntervalInSeconds int32 `json:"initialIntervalInSeconds,omitempty"`
BackoffCoefficient float64 `json:"backoffCoefficient,omitempty"`
MaximumIntervalInSeconds int32 `json:"maximumIntervalInSeconds,omitempty"`
MaximumAttempts int32 `json:"maximumAttempts,omitempty"`
NonRetriableErrorReasons []string `json:"nonRetriableErrorReasons,omitempty"`
ExpirationIntervalInSeconds int32 `json:"expirationIntervalInSeconds,omitempty"`
}
// GetInitialIntervalInSeconds is an internal getter (TBD...)
func (v *RetryPolicy) GetInitialIntervalInSeconds() (o int32) {
if v != nil {
return v.InitialIntervalInSeconds
}
return
}
// GetBackoffCoefficient is an internal getter (TBD...)
func (v *RetryPolicy) GetBackoffCoefficient() (o float64) {
if v != nil {
return v.BackoffCoefficient
}
return
}
// GetMaximumIntervalInSeconds is an internal getter (TBD...)
func (v *RetryPolicy) GetMaximumIntervalInSeconds() (o int32) {
if v != nil {
return v.MaximumIntervalInSeconds
}
return
}
// GetMaximumAttempts is an internal getter (TBD...)
func (v *RetryPolicy) GetMaximumAttempts() (o int32) {
if v != nil {
return v.MaximumAttempts
}
return
}
// GetNonRetriableErrorReasons is an internal getter (TBD...)
func (v *RetryPolicy) GetNonRetriableErrorReasons() (o []string) {
if v != nil && v.NonRetriableErrorReasons != nil {
return v.NonRetriableErrorReasons
}
return
}
// GetExpirationIntervalInSeconds is an internal getter (TBD...)
func (v *RetryPolicy) GetExpirationIntervalInSeconds() (o int32) {
if v != nil {
return v.ExpirationIntervalInSeconds
}
return
}
// RetryTaskV2Error is an internal type (TBD...)
type RetryTaskV2Error struct {
Message string `json:"message,required"`
DomainID string `json:"domainId,omitempty"`
WorkflowID string `json:"workflowId,omitempty"`
RunID string `json:"runId,omitempty"`
StartEventID *int64 `json:"startEventId,omitempty"`
StartEventVersion *int64 `json:"startEventVersion,omitempty"`
EndEventID *int64 `json:"endEventId,omitempty"`
EndEventVersion *int64 `json:"endEventVersion,omitempty"`
}
// GetDomainID is an internal getter (TBD...)
func (v *RetryTaskV2Error) GetDomainID() (o string) {
if v != nil {
return v.DomainID
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *RetryTaskV2Error) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *RetryTaskV2Error) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// ScheduleActivityTaskDecisionAttributes is an internal type (TBD...)
type ScheduleActivityTaskDecisionAttributes struct {
ActivityID string `json:"activityId,omitempty"`
ActivityType *ActivityType `json:"activityType,omitempty"`
Domain string `json:"domain,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"input,omitempty"`
ScheduleToCloseTimeoutSeconds *int32 `json:"scheduleToCloseTimeoutSeconds,omitempty"`
ScheduleToStartTimeoutSeconds *int32 `json:"scheduleToStartTimeoutSeconds,omitempty"`
StartToCloseTimeoutSeconds *int32 `json:"startToCloseTimeoutSeconds,omitempty"`
HeartbeatTimeoutSeconds *int32 `json:"heartbeatTimeoutSeconds,omitempty"`
RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
Header *Header `json:"header,omitempty"`
RequestLocalDispatch bool `json:"requestLocalDispatch,omitempty"`
}
// GetActivityID is an internal getter (TBD...)
func (v *ScheduleActivityTaskDecisionAttributes) GetActivityID() (o string) {
if v != nil {
return v.ActivityID
}
return
}
// GetActivityType is an internal getter (TBD...)
func (v *ScheduleActivityTaskDecisionAttributes) GetActivityType() (o *ActivityType) {
if v != nil && v.ActivityType != nil {
return v.ActivityType
}
return
}
// GetDomain is an internal getter (TBD...)
func (v *ScheduleActivityTaskDecisionAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetScheduleToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *ScheduleActivityTaskDecisionAttributes) GetScheduleToCloseTimeoutSeconds() (o int32) {
if v != nil && v.ScheduleToCloseTimeoutSeconds != nil {
return *v.ScheduleToCloseTimeoutSeconds
}
return
}
// GetScheduleToStartTimeoutSeconds is an internal getter (TBD...)
func (v *ScheduleActivityTaskDecisionAttributes) GetScheduleToStartTimeoutSeconds() (o int32) {
if v != nil && v.ScheduleToStartTimeoutSeconds != nil {
return *v.ScheduleToStartTimeoutSeconds
}
return
}
// GetStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *ScheduleActivityTaskDecisionAttributes) GetStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.StartToCloseTimeoutSeconds != nil {
return *v.StartToCloseTimeoutSeconds
}
return
}
// GetHeartbeatTimeoutSeconds is an internal getter (TBD...)
func (v *ScheduleActivityTaskDecisionAttributes) GetHeartbeatTimeoutSeconds() (o int32) {
if v != nil && v.HeartbeatTimeoutSeconds != nil {
return *v.HeartbeatTimeoutSeconds
}
return
}
// SearchAttributes is an internal type (TBD...)
type SearchAttributes struct {
IndexedFields map[string][]byte `json:"indexedFields,omitempty"`
}
// GetIndexedFields is an internal getter (TBD...)
func (v *SearchAttributes) GetIndexedFields() (o map[string][]byte) {
if v != nil && v.IndexedFields != nil {
return v.IndexedFields
}
return
}
// ServiceBusyError is an internal type (TBD...)
type ServiceBusyError struct {
Message string `json:"message,required"`
Reason string `json:"reason,omitempty"`
}
// SignalExternalWorkflowExecutionDecisionAttributes is an internal type (TBD...)
type SignalExternalWorkflowExecutionDecisionAttributes struct {
Domain string `json:"domain,omitempty"`
Execution *WorkflowExecution `json:"execution,omitempty"`
SignalName string `json:"signalName,omitempty"`
Input []byte `json:"input,omitempty"`
Control []byte `json:"control,omitempty"`
ChildWorkflowOnly bool `json:"childWorkflowOnly,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *SignalExternalWorkflowExecutionDecisionAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetSignalName is an internal getter (TBD...)
func (v *SignalExternalWorkflowExecutionDecisionAttributes) GetSignalName() (o string) {
if v != nil {
return v.SignalName
}
return
}
// SignalExternalWorkflowExecutionFailedCause is an internal type (TBD...)
type SignalExternalWorkflowExecutionFailedCause int32
// Ptr is a helper function for getting pointer value
func (e SignalExternalWorkflowExecutionFailedCause) Ptr() *SignalExternalWorkflowExecutionFailedCause {
return &e
}
// String returns a readable string representation of SignalExternalWorkflowExecutionFailedCause.
func (e SignalExternalWorkflowExecutionFailedCause) String() string {
w := int32(e)
switch w {
case 0:
return "UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION"
}
return fmt.Sprintf("SignalExternalWorkflowExecutionFailedCause(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *SignalExternalWorkflowExecutionFailedCause) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "UNKNOWN_EXTERNAL_WORKFLOW_EXECUTION":
*e = SignalExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "SignalExternalWorkflowExecutionFailedCause", err)
}
*e = SignalExternalWorkflowExecutionFailedCause(val)
return nil
}
}
// MarshalText encodes SignalExternalWorkflowExecutionFailedCause to text.
func (e SignalExternalWorkflowExecutionFailedCause) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// SignalExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution is an option for SignalExternalWorkflowExecutionFailedCause
SignalExternalWorkflowExecutionFailedCauseUnknownExternalWorkflowExecution SignalExternalWorkflowExecutionFailedCause = iota
)
// SignalExternalWorkflowExecutionFailedEventAttributes is an internal type (TBD...)
type SignalExternalWorkflowExecutionFailedEventAttributes struct {
Cause *SignalExternalWorkflowExecutionFailedCause `json:"cause,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
Control []byte `json:"control,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *SignalExternalWorkflowExecutionFailedEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *SignalExternalWorkflowExecutionFailedEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// SignalExternalWorkflowExecutionInitiatedEventAttributes is an internal type (TBD...)
type SignalExternalWorkflowExecutionInitiatedEventAttributes struct {
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
SignalName string `json:"signalName,omitempty"`
Input []byte `json:"input,omitempty"`
Control []byte `json:"control,omitempty"`
ChildWorkflowOnly bool `json:"childWorkflowOnly,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// GetSignalName is an internal getter (TBD...)
func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetSignalName() (o string) {
if v != nil {
return v.SignalName
}
return
}
// GetChildWorkflowOnly is an internal getter (TBD...)
func (v *SignalExternalWorkflowExecutionInitiatedEventAttributes) GetChildWorkflowOnly() (o bool) {
if v != nil {
return v.ChildWorkflowOnly
}
return
}
// SignalWithStartWorkflowExecutionRequest is an internal type (TBD...)
type SignalWithStartWorkflowExecutionRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowId,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"-"` // Filtering PII
ExecutionStartToCloseTimeoutSeconds *int32 `json:"executionStartToCloseTimeoutSeconds,omitempty"`
TaskStartToCloseTimeoutSeconds *int32 `json:"taskStartToCloseTimeoutSeconds,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
WorkflowIDReusePolicy *WorkflowIDReusePolicy `json:"workflowIdReusePolicy,omitempty"`
SignalName string `json:"signalName,omitempty"`
SignalInput []byte `json:"-"` // Filtering PII
Control []byte `json:"control,omitempty"`
RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
CronSchedule string `json:"cronSchedule,omitempty"`
Memo *Memo `json:"-"` // Filtering PII
SearchAttributes *SearchAttributes `json:"-"` // Filtering PII
Header *Header `json:"header,omitempty"`
DelayStartSeconds *int32 `json:"delayStartSeconds,omitempty"`
JitterStartSeconds *int32 `json:"jitterStartSeconds,omitempty"`
}
func (v *SignalWithStartWorkflowExecutionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetWorkflowType is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetWorkflowType() (o *WorkflowType) {
if v != nil && v.WorkflowType != nil {
return v.WorkflowType
}
return
}
// GetTaskList is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetTaskList() (o *TaskList) {
if v != nil && v.TaskList != nil {
return v.TaskList
}
return
}
// GetExecutionStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetExecutionStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.ExecutionStartToCloseTimeoutSeconds != nil {
return *v.ExecutionStartToCloseTimeoutSeconds
}
return
}
// GetTaskStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetTaskStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.TaskStartToCloseTimeoutSeconds != nil {
return *v.TaskStartToCloseTimeoutSeconds
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// GetWorkflowIDReusePolicy is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetWorkflowIDReusePolicy() (o WorkflowIDReusePolicy) {
if v != nil && v.WorkflowIDReusePolicy != nil {
return *v.WorkflowIDReusePolicy
}
return
}
// GetSignalName is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetSignalName() (o string) {
if v != nil {
return v.SignalName
}
return
}
// GetSignalInput is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetSignalInput() (o []byte) {
if v != nil && v.SignalInput != nil {
return v.SignalInput
}
return
}
// GetCronSchedule is an internal getter (TBD...)
func (v *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() (o string) {
if v != nil {
return v.CronSchedule
}
return
}
// SignalWithStartWorkflowExecutionAsyncRequest is an internal type (TBD...)
type SignalWithStartWorkflowExecutionAsyncRequest struct {
*SignalWithStartWorkflowExecutionRequest
}
// SignalWithStartWorkflowExecutionAsyncResponse is an internal type (TBD...)
type SignalWithStartWorkflowExecutionAsyncResponse struct {
}
// SignalWorkflowExecutionRequest is an internal type (TBD...)
type SignalWorkflowExecutionRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
SignalName string `json:"signalName,omitempty"`
Input []byte `json:"-"` // Filtering PII
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
Control []byte `json:"control,omitempty"`
}
func (v *SignalWorkflowExecutionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *SignalWorkflowExecutionRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *SignalWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// GetSignalName is an internal getter (TBD...)
func (v *SignalWorkflowExecutionRequest) GetSignalName() (o string) {
if v != nil {
return v.SignalName
}
return
}
// GetInput is an internal getter (TBD...)
func (v *SignalWorkflowExecutionRequest) GetInput() (o []byte) {
if v != nil && v.Input != nil {
return v.Input
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *SignalWorkflowExecutionRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *SignalWorkflowExecutionRequest) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// StartChildWorkflowExecutionDecisionAttributes is an internal type (TBD...)
type StartChildWorkflowExecutionDecisionAttributes struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowId,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"input,omitempty"`
ExecutionStartToCloseTimeoutSeconds *int32 `json:"executionStartToCloseTimeoutSeconds,omitempty"`
TaskStartToCloseTimeoutSeconds *int32 `json:"taskStartToCloseTimeoutSeconds,omitempty"`
ParentClosePolicy *ParentClosePolicy `json:"parentClosePolicy,omitempty"`
Control []byte `json:"control,omitempty"`
WorkflowIDReusePolicy *WorkflowIDReusePolicy `json:"workflowIdReusePolicy,omitempty"`
RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
CronSchedule string `json:"cronSchedule,omitempty"`
Header *Header `json:"header,omitempty"`
Memo *Memo `json:"memo,omitempty"`
SearchAttributes *SearchAttributes `json:"searchAttributes,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionDecisionAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionDecisionAttributes) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetExecutionStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionDecisionAttributes) GetExecutionStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.ExecutionStartToCloseTimeoutSeconds != nil {
return *v.ExecutionStartToCloseTimeoutSeconds
}
return
}
// GetTaskStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionDecisionAttributes) GetTaskStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.TaskStartToCloseTimeoutSeconds != nil {
return *v.TaskStartToCloseTimeoutSeconds
}
return
}
// GetParentClosePolicy is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionDecisionAttributes) GetParentClosePolicy() (o ParentClosePolicy) {
if v != nil && v.ParentClosePolicy != nil {
return *v.ParentClosePolicy
}
return
}
// GetCronSchedule is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionDecisionAttributes) GetCronSchedule() (o string) {
if v != nil {
return v.CronSchedule
}
return
}
// StartChildWorkflowExecutionFailedEventAttributes is an internal type (TBD...)
type StartChildWorkflowExecutionFailedEventAttributes struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowId,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
Cause *ChildWorkflowExecutionFailedCause `json:"cause,omitempty"`
Control []byte `json:"control,omitempty"`
InitiatedEventID int64 `json:"initiatedEventId,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionFailedEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetInitiatedEventID is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionFailedEventAttributes) GetInitiatedEventID() (o int64) {
if v != nil {
return v.InitiatedEventID
}
return
}
// StartChildWorkflowExecutionInitiatedEventAttributes is an internal type (TBD...)
type StartChildWorkflowExecutionInitiatedEventAttributes struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowId,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"input,omitempty"`
ExecutionStartToCloseTimeoutSeconds *int32 `json:"executionStartToCloseTimeoutSeconds,omitempty"`
TaskStartToCloseTimeoutSeconds *int32 `json:"taskStartToCloseTimeoutSeconds,omitempty"`
ParentClosePolicy *ParentClosePolicy `json:"parentClosePolicy,omitempty"`
Control []byte `json:"control,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
WorkflowIDReusePolicy *WorkflowIDReusePolicy `json:"workflowIdReusePolicy,omitempty"`
RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
CronSchedule string `json:"cronSchedule,omitempty"`
Header *Header `json:"header,omitempty"`
Memo *Memo `json:"memo,omitempty"`
SearchAttributes *SearchAttributes `json:"searchAttributes,omitempty"`
DelayStartSeconds *int32 `json:"delayStartSeconds,omitempty"`
JitterStartSeconds *int32 `json:"jitterStartSeconds,omitempty"`
}
// GetDomain is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetWorkflowType is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetWorkflowType() (o *WorkflowType) {
if v != nil && v.WorkflowType != nil {
return v.WorkflowType
}
return
}
// GetParentClosePolicy is an internal getter (TBD...)
func (v *StartChildWorkflowExecutionInitiatedEventAttributes) GetParentClosePolicy() (o ParentClosePolicy) {
if v != nil && v.ParentClosePolicy != nil {
return *v.ParentClosePolicy
}
return
}
// StartTimeFilter is an internal type (TBD...)
type StartTimeFilter struct {
EarliestTime *int64 `json:"earliestTime,omitempty"`
LatestTime *int64 `json:"latestTime,omitempty"`
}
// GetEarliestTime is an internal getter (TBD...)
func (v *StartTimeFilter) GetEarliestTime() (o int64) {
if v != nil && v.EarliestTime != nil {
return *v.EarliestTime
}
return
}
// GetLatestTime is an internal getter (TBD...)
func (v *StartTimeFilter) GetLatestTime() (o int64) {
if v != nil && v.LatestTime != nil {
return *v.LatestTime
}
return
}
// StartTimerDecisionAttributes is an internal type (TBD...)
type StartTimerDecisionAttributes struct {
TimerID string `json:"timerId,omitempty"`
StartToFireTimeoutSeconds *int64 `json:"startToFireTimeoutSeconds,omitempty"`
}
// GetTimerID is an internal getter (TBD...)
func (v *StartTimerDecisionAttributes) GetTimerID() (o string) {
if v != nil {
return v.TimerID
}
return
}
// GetStartToFireTimeoutSeconds is an internal getter (TBD...)
func (v *StartTimerDecisionAttributes) GetStartToFireTimeoutSeconds() (o int64) {
if v != nil && v.StartToFireTimeoutSeconds != nil {
return *v.StartToFireTimeoutSeconds
}
return
}
type RestartWorkflowExecutionRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
Identity string `json:"identity,omitempty"`
}
func (v *RestartWorkflowExecutionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *RestartWorkflowExecutionRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *RestartWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// StartWorkflowExecutionRequest is an internal type (TBD...)
type StartWorkflowExecutionRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowID string `json:"workflowId,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"-"`
ExecutionStartToCloseTimeoutSeconds *int32 `json:"executionStartToCloseTimeoutSeconds,omitempty"`
TaskStartToCloseTimeoutSeconds *int32 `json:"taskStartToCloseTimeoutSeconds,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
WorkflowIDReusePolicy *WorkflowIDReusePolicy `json:"workflowIdReusePolicy,omitempty"`
RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
CronSchedule string `json:"cronSchedule,omitempty"`
Memo *Memo `json:"-"`
SearchAttributes *SearchAttributes `json:"-"`
Header *Header `json:"header,omitempty"`
DelayStartSeconds *int32 `json:"delayStartSeconds,omitempty"`
JitterStartSeconds *int32 `json:"jitterStartSeconds,omitempty"`
}
func (v *StartWorkflowExecutionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowID is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetExecutionStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetExecutionStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.ExecutionStartToCloseTimeoutSeconds != nil {
return *v.ExecutionStartToCloseTimeoutSeconds
}
return
}
// GetTaskStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetTaskStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.TaskStartToCloseTimeoutSeconds != nil {
return *v.TaskStartToCloseTimeoutSeconds
}
return
}
// GetDelayStartSeconds is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetDelayStartSeconds() (o int32) {
if v != nil && v.DelayStartSeconds != nil {
return *v.DelayStartSeconds
}
return
}
// GetJitterStartSeconds is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetJitterStartSeconds() (o int32) {
if v != nil && v.JitterStartSeconds != nil {
return *v.JitterStartSeconds
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// GetWorkflowIDReusePolicy is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetWorkflowIDReusePolicy() (o WorkflowIDReusePolicy) {
if v != nil && v.WorkflowIDReusePolicy != nil {
return *v.WorkflowIDReusePolicy
}
return
}
// GetCronSchedule is an internal getter (TBD...)
func (v *StartWorkflowExecutionRequest) GetCronSchedule() (o string) {
if v != nil {
return v.CronSchedule
}
return
}
// StartWorkflowExecutionResponse is an internal type (TBD...)
type StartWorkflowExecutionResponse struct {
RunID string `json:"runId,omitempty"`
}
// GetRunID is an internal getter (TBD...)
func (v *StartWorkflowExecutionResponse) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
type StartWorkflowExecutionAsyncRequest struct {
*StartWorkflowExecutionRequest
}
type StartWorkflowExecutionAsyncResponse struct {
}
// RestartWorkflowExecutionResponse is an internal type (TBD...)
type RestartWorkflowExecutionResponse struct {
RunID string `json:"runId,omitempty"`
}
// GetRunID is an internal getter (TBD...)
func (v *RestartWorkflowExecutionResponse) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// StickyExecutionAttributes is an internal type (TBD...)
type StickyExecutionAttributes struct {
WorkerTaskList *TaskList `json:"workerTaskList,omitempty"`
ScheduleToStartTimeoutSeconds *int32 `json:"scheduleToStartTimeoutSeconds,omitempty"`
}
// GetScheduleToStartTimeoutSeconds is an internal getter (TBD...)
func (v *StickyExecutionAttributes) GetScheduleToStartTimeoutSeconds() (o int32) {
if v != nil && v.ScheduleToStartTimeoutSeconds != nil {
return *v.ScheduleToStartTimeoutSeconds
}
return
}
// SupportedClientVersions is an internal type (TBD...)
type SupportedClientVersions struct {
GoSdk string `json:"goSdk,omitempty"`
JavaSdk string `json:"javaSdk,omitempty"`
}
// TaskIDBlock is an internal type (TBD...)
type TaskIDBlock struct {
StartID int64 `json:"startID,omitempty"`
EndID int64 `json:"endID,omitempty"`
}
// GetStartID is an internal getter (TBD...)
func (v *TaskIDBlock) GetStartID() (o int64) {
if v != nil {
return v.StartID
}
return
}
// GetEndID is an internal getter (TBD...)
func (v *TaskIDBlock) GetEndID() (o int64) {
if v != nil {
return v.EndID
}
return
}
// TaskList is an internal type (TBD...)
type TaskList struct {
Name string `json:"name,omitempty"`
Kind *TaskListKind `json:"kind,omitempty"`
}
// GetName is an internal getter (TBD...)
func (v *TaskList) GetName() (o string) {
if v != nil {
return v.Name
}
return
}
// GetKind is an internal getter (TBD...)
func (v *TaskList) GetKind() (o TaskListKind) {
if v != nil && v.Kind != nil {
return *v.Kind
}
return
}
// TaskListKind is an internal type (TBD...)
type TaskListKind int32
// Ptr is a helper function for getting pointer value
func (e TaskListKind) Ptr() *TaskListKind {
return &e
}
// String returns a readable string representation of TaskListKind.
func (e TaskListKind) String() string {
w := int32(e)
switch w {
case 0:
return "NORMAL"
case 1:
return "STICKY"
}
return fmt.Sprintf("TaskListKind(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *TaskListKind) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "NORMAL":
*e = TaskListKindNormal
return nil
case "STICKY":
*e = TaskListKindSticky
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "TaskListKind", err)
}
*e = TaskListKind(val)
return nil
}
}
// MarshalText encodes TaskListKind to text.
func (e TaskListKind) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// TaskListKindNormal is an option for TaskListKind
TaskListKindNormal TaskListKind = iota
// TaskListKindSticky is an option for TaskListKind
TaskListKindSticky
)
// TaskListMetadata is an internal type (TBD...)
type TaskListMetadata struct {
MaxTasksPerSecond *float64 `json:"maxTasksPerSecond,omitempty"`
}
// TaskListPartitionMetadata is an internal type (TBD...)
type TaskListPartitionMetadata struct {
Key string `json:"key,omitempty"`
OwnerHostName string `json:"ownerHostName,omitempty"`
}
// GetKey is an internal getter (TBD...)
func (v *TaskListPartitionMetadata) GetKey() (o string) {
if v != nil {
return v.Key
}
return
}
// GetOwnerHostName is an internal getter (TBD...)
func (v *TaskListPartitionMetadata) GetOwnerHostName() (o string) {
if v != nil {
return v.OwnerHostName
}
return
}
// TaskListStatus is an internal type (TBD...)
type TaskListStatus struct {
BacklogCountHint int64 `json:"backlogCountHint,omitempty"`
ReadLevel int64 `json:"readLevel,omitempty"`
AckLevel int64 `json:"ackLevel,omitempty"`
RatePerSecond float64 `json:"ratePerSecond,omitempty"`
TaskIDBlock *TaskIDBlock `json:"taskIDBlock,omitempty"`
}
// GetBacklogCountHint is an internal getter (TBD...)
func (v *TaskListStatus) GetBacklogCountHint() (o int64) {
if v != nil {
return v.BacklogCountHint
}
return
}
// GetReadLevel is an internal getter (TBD...)
func (v *TaskListStatus) GetReadLevel() (o int64) {
if v != nil {
return v.ReadLevel
}
return
}
// GetAckLevel is an internal getter (TBD...)
func (v *TaskListStatus) GetAckLevel() (o int64) {
if v != nil {
return v.AckLevel
}
return
}
// GetRatePerSecond is an internal getter (TBD...)
func (v *TaskListStatus) GetRatePerSecond() (o float64) {
if v != nil {
return v.RatePerSecond
}
return
}
// GetTaskIDBlock is an internal getter (TBD...)
func (v *TaskListStatus) GetTaskIDBlock() (o *TaskIDBlock) {
if v != nil && v.TaskIDBlock != nil {
return v.TaskIDBlock
}
return
}
// TaskListType is an internal type (TBD...)
type TaskListType int32
// Ptr is a helper function for getting pointer value
func (e TaskListType) Ptr() *TaskListType {
return &e
}
// String returns a readable string representation of TaskListType.
func (e TaskListType) String() string {
w := int32(e)
switch w {
case 0:
return "Decision"
case 1:
return "Activity"
}
return fmt.Sprintf("TaskListType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *TaskListType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "DECISION":
*e = TaskListTypeDecision
return nil
case "ACTIVITY":
*e = TaskListTypeActivity
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "TaskListType", err)
}
*e = TaskListType(val)
return nil
}
}
// MarshalText encodes TaskListType to text.
func (e TaskListType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// TaskListTypeDecision is an option for TaskListType
TaskListTypeDecision TaskListType = iota
// TaskListTypeActivity is an option for TaskListType
TaskListTypeActivity
)
// TerminateWorkflowExecutionRequest is an internal type (TBD...)
type TerminateWorkflowExecutionRequest struct {
Domain string `json:"domain,omitempty"`
WorkflowExecution *WorkflowExecution `json:"workflowExecution,omitempty"`
Reason string `json:"reason,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
FirstExecutionRunID string `json:"first_execution_run_id,omitempty"`
}
func (v *TerminateWorkflowExecutionRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetDomain is an internal getter (TBD...)
func (v *TerminateWorkflowExecutionRequest) GetDomain() (o string) {
if v != nil {
return v.Domain
}
return
}
// GetWorkflowExecution is an internal getter (TBD...)
func (v *TerminateWorkflowExecutionRequest) GetWorkflowExecution() (o *WorkflowExecution) {
if v != nil && v.WorkflowExecution != nil {
return v.WorkflowExecution
}
return
}
// GetReason is an internal getter (TBD...)
func (v *TerminateWorkflowExecutionRequest) GetReason() (o string) {
if v != nil {
return v.Reason
}
return
}
// GetDetails is an internal getter (TBD...)
func (v *TerminateWorkflowExecutionRequest) GetDetails() (o []byte) {
if v != nil && v.Details != nil {
return v.Details
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *TerminateWorkflowExecutionRequest) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// GetFirstExecutionRunID is an internal getter (TBD...)
func (v *TerminateWorkflowExecutionRequest) GetFirstExecutionRunID() (o string) {
if v != nil {
return v.FirstExecutionRunID
}
return
}
// TimeoutType is an internal type (TBD...)
type TimeoutType int32
// Ptr is a helper function for getting pointer value
func (e TimeoutType) Ptr() *TimeoutType {
return &e
}
// String returns a readable string representation of TimeoutType.
func (e TimeoutType) String() string {
w := int32(e)
switch w {
case 0:
return "START_TO_CLOSE"
case 1:
return "SCHEDULE_TO_START"
case 2:
return "SCHEDULE_TO_CLOSE"
case 3:
return "HEARTBEAT"
}
return fmt.Sprintf("TimeoutType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *TimeoutType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "START_TO_CLOSE":
*e = TimeoutTypeStartToClose
return nil
case "SCHEDULE_TO_START":
*e = TimeoutTypeScheduleToStart
return nil
case "SCHEDULE_TO_CLOSE":
*e = TimeoutTypeScheduleToClose
return nil
case "HEARTBEAT":
*e = TimeoutTypeHeartbeat
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "TimeoutType", err)
}
*e = TimeoutType(val)
return nil
}
}
// MarshalText encodes TimeoutType to text.
func (e TimeoutType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// TimeoutTypeStartToClose is an option for TimeoutType
TimeoutTypeStartToClose TimeoutType = iota
// TimeoutTypeScheduleToStart is an option for TimeoutType
TimeoutTypeScheduleToStart
// TimeoutTypeScheduleToClose is an option for TimeoutType
TimeoutTypeScheduleToClose
// TimeoutTypeHeartbeat is an option for TimeoutType
TimeoutTypeHeartbeat
)
// TimerCanceledEventAttributes is an internal type (TBD...)
type TimerCanceledEventAttributes struct {
TimerID string `json:"timerId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetTimerID is an internal getter (TBD...)
func (v *TimerCanceledEventAttributes) GetTimerID() (o string) {
if v != nil {
return v.TimerID
}
return
}
// TimerFiredEventAttributes is an internal type (TBD...)
type TimerFiredEventAttributes struct {
TimerID string `json:"timerId,omitempty"`
StartedEventID int64 `json:"startedEventId,omitempty"`
}
// GetTimerID is an internal getter (TBD...)
func (v *TimerFiredEventAttributes) GetTimerID() (o string) {
if v != nil {
return v.TimerID
}
return
}
// GetStartedEventID is an internal getter (TBD...)
func (v *TimerFiredEventAttributes) GetStartedEventID() (o int64) {
if v != nil {
return v.StartedEventID
}
return
}
// TimerStartedEventAttributes is an internal type (TBD...)
type TimerStartedEventAttributes struct {
TimerID string `json:"timerId,omitempty"`
StartToFireTimeoutSeconds *int64 `json:"startToFireTimeoutSeconds,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
}
// GetTimerID is an internal getter (TBD...)
func (v *TimerStartedEventAttributes) GetTimerID() (o string) {
if v != nil {
return v.TimerID
}
return
}
// GetStartToFireTimeoutSeconds is an internal getter (TBD...)
func (v *TimerStartedEventAttributes) GetStartToFireTimeoutSeconds() (o int64) {
if v != nil && v.StartToFireTimeoutSeconds != nil {
return *v.StartToFireTimeoutSeconds
}
return
}
// TransientDecisionInfo is an internal type (TBD...)
type TransientDecisionInfo struct {
ScheduledEvent *HistoryEvent `json:"scheduledEvent,omitempty"`
StartedEvent *HistoryEvent `json:"startedEvent,omitempty"`
}
// UpdateDomainRequest is an internal type (TBD...)
type UpdateDomainRequest struct {
Name string `json:"name,omitempty"`
Description *string `json:"description,omitempty"`
OwnerEmail *string `json:"ownerEmail,omitempty"`
Data map[string]string `json:"data,omitempty"`
WorkflowExecutionRetentionPeriodInDays *int32 `json:"workflowExecutionRetentionPeriodInDays,omitempty"`
EmitMetric *bool `json:"emitMetric,omitempty"`
BadBinaries *BadBinaries `json:"badBinaries,omitempty"`
HistoryArchivalStatus *ArchivalStatus `json:"historyArchivalStatus,omitempty"`
HistoryArchivalURI *string `json:"historyArchivalURI,omitempty"`
VisibilityArchivalStatus *ArchivalStatus `json:"visibilityArchivalStatus,omitempty"`
VisibilityArchivalURI *string `json:"visibilityArchivalURI,omitempty"`
ActiveClusterName *string `json:"activeClusterName,omitempty"`
Clusters []*ClusterReplicationConfiguration `json:"clusters,omitempty"`
SecurityToken string `json:"securityToken,omitempty"`
DeleteBadBinary *string `json:"deleteBadBinary,omitempty"`
FailoverTimeoutInSeconds *int32 `json:"failoverTimeoutInSeconds,omitempty"`
}
func (v *UpdateDomainRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetName is an internal getter (TBD...)
func (v *UpdateDomainRequest) GetName() (o string) {
if v != nil {
return v.Name
}
return
}
// GetFailoverTimeoutInSeconds is an internal getter (TBD...)
func (v *UpdateDomainRequest) GetFailoverTimeoutInSeconds() (o int32) {
if v != nil && v.FailoverTimeoutInSeconds != nil {
return *v.FailoverTimeoutInSeconds
}
return
}
// GetHistoryArchivalURI is an internal getter (TBD...)
func (v *UpdateDomainRequest) GetHistoryArchivalURI() (o string) {
if v != nil && v.HistoryArchivalURI != nil {
return *v.HistoryArchivalURI
}
return
}
// GetVisibilityArchivalURI is an internal getter (TBD...)
func (v *UpdateDomainRequest) GetVisibilityArchivalURI() (o string) {
if v != nil && v.VisibilityArchivalURI != nil {
return *v.VisibilityArchivalURI
}
return
}
// UpdateDomainResponse is an internal type (TBD...)
type UpdateDomainResponse struct {
DomainInfo *DomainInfo `json:"domainInfo,omitempty"`
Configuration *DomainConfiguration `json:"configuration,omitempty"`
ReplicationConfiguration *DomainReplicationConfiguration `json:"replicationConfiguration,omitempty"`
FailoverVersion int64 `json:"failoverVersion,omitempty"`
IsGlobalDomain bool `json:"isGlobalDomain,omitempty"`
}
// GetDomainInfo is an internal getter (TBD...)
func (v *UpdateDomainResponse) GetDomainInfo() (o *DomainInfo) {
if v != nil && v.DomainInfo != nil {
return v.DomainInfo
}
return
}
// GetFailoverVersion is an internal getter (TBD...)
func (v *UpdateDomainResponse) GetFailoverVersion() (o int64) {
if v != nil {
return v.FailoverVersion
}
return
}
// GetIsGlobalDomain is an internal getter (TBD...)
func (v *UpdateDomainResponse) GetIsGlobalDomain() (o bool) {
if v != nil {
return v.IsGlobalDomain
}
return
}
// UpsertWorkflowSearchAttributesDecisionAttributes is an internal type (TBD...)
type UpsertWorkflowSearchAttributesDecisionAttributes struct {
SearchAttributes *SearchAttributes `json:"searchAttributes,omitempty"`
}
// GetSearchAttributes is an internal getter (TBD...)
func (v *UpsertWorkflowSearchAttributesDecisionAttributes) GetSearchAttributes() (o *SearchAttributes) {
if v != nil && v.SearchAttributes != nil {
return v.SearchAttributes
}
return
}
// UpsertWorkflowSearchAttributesEventAttributes is an internal type (TBD...)
type UpsertWorkflowSearchAttributesEventAttributes struct {
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
SearchAttributes *SearchAttributes `json:"searchAttributes,omitempty"`
}
// GetSearchAttributes is an internal getter (TBD...)
func (v *UpsertWorkflowSearchAttributesEventAttributes) GetSearchAttributes() (o *SearchAttributes) {
if v != nil && v.SearchAttributes != nil {
return v.SearchAttributes
}
return
}
// VersionHistories is an internal type (TBD...)
type VersionHistories struct {
CurrentVersionHistoryIndex int32 `json:"currentVersionHistoryIndex,omitempty"`
Histories []*VersionHistory `json:"histories,omitempty"`
}
// GetCurrentVersionHistoryIndex is an internal getter (TBD...)
func (v *VersionHistories) GetCurrentVersionHistoryIndex() (o int32) {
if v != nil {
return v.CurrentVersionHistoryIndex
}
return
}
// VersionHistory is an internal type (TBD...)
type VersionHistory struct {
BranchToken []byte `json:"branchToken,omitempty"`
Items []*VersionHistoryItem `json:"items,omitempty"`
}
// GetItems is an internal getter (TBD...)
func (v *VersionHistory) GetItems() (o []*VersionHistoryItem) {
if v != nil && v.Items != nil {
return v.Items
}
return
}
// VersionHistoryItem is an internal type (TBD...)
type VersionHistoryItem struct {
EventID int64 `json:"eventID,omitempty"`
Version int64 `json:"version,omitempty"`
}
// GetVersion is an internal getter (TBD...)
func (v *VersionHistoryItem) GetVersion() (o int64) {
if v != nil {
return v.Version
}
return
}
// WorkerVersionInfo is an internal type (TBD...)
type WorkerVersionInfo struct {
Impl string `json:"impl,omitempty"`
FeatureVersion string `json:"featureVersion,omitempty"`
}
// GetImpl is an internal getter (TBD...)
func (v *WorkerVersionInfo) GetImpl() (o string) {
if v != nil {
return v.Impl
}
return
}
// GetFeatureVersion is an internal getter (TBD...)
func (v *WorkerVersionInfo) GetFeatureVersion() (o string) {
if v != nil {
return v.FeatureVersion
}
return
}
// WorkflowExecution is an internal type (TBD...)
type WorkflowExecution struct {
WorkflowID string `json:"workflowId,omitempty"`
RunID string `json:"runId,omitempty"`
}
// GetWorkflowID is an internal getter (TBD...)
func (v *WorkflowExecution) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// GetRunID is an internal getter (TBD...)
func (v *WorkflowExecution) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// WorkflowExecutionAlreadyStartedError is an internal type (TBD...)
type WorkflowExecutionAlreadyStartedError struct {
Message string `json:"message,omitempty"`
StartRequestID string `json:"startRequestId,omitempty"`
RunID string `json:"runId,omitempty"`
}
// GetMessage is an internal getter (TBD...)
func (v *WorkflowExecutionAlreadyStartedError) GetMessage() (o string) {
if v != nil {
return v.Message
}
return
}
// WorkflowExecutionCancelRequestedEventAttributes is an internal type (TBD...)
type WorkflowExecutionCancelRequestedEventAttributes struct {
Cause string `json:"cause,omitempty"`
ExternalInitiatedEventID *int64 `json:"externalInitiatedEventId,omitempty"`
ExternalWorkflowExecution *WorkflowExecution `json:"externalWorkflowExecution,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
}
// WorkflowExecutionCanceledEventAttributes is an internal type (TBD...)
type WorkflowExecutionCanceledEventAttributes struct {
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
Details []byte `json:"details,omitempty"`
}
// WorkflowExecutionCloseStatus is an internal type (TBD...)
type WorkflowExecutionCloseStatus int32
// Ptr is a helper function for getting pointer value
func (e WorkflowExecutionCloseStatus) Ptr() *WorkflowExecutionCloseStatus {
return &e
}
// String returns a readable string representation of WorkflowExecutionCloseStatus.
func (e WorkflowExecutionCloseStatus) String() string {
w := int32(e)
switch w {
case 0:
return "COMPLETED"
case 1:
return "FAILED"
case 2:
return "CANCELED"
case 3:
return "TERMINATED"
case 4:
return "CONTINUED_AS_NEW"
case 5:
return "TIMED_OUT"
}
return fmt.Sprintf("WorkflowExecutionCloseStatus(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *WorkflowExecutionCloseStatus) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "COMPLETED":
*e = WorkflowExecutionCloseStatusCompleted
return nil
case "FAILED":
*e = WorkflowExecutionCloseStatusFailed
return nil
case "CANCELED":
*e = WorkflowExecutionCloseStatusCanceled
return nil
case "TERMINATED":
*e = WorkflowExecutionCloseStatusTerminated
return nil
case "CONTINUED_AS_NEW":
*e = WorkflowExecutionCloseStatusContinuedAsNew
return nil
case "TIMED_OUT":
*e = WorkflowExecutionCloseStatusTimedOut
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "WorkflowExecutionCloseStatus", err)
}
*e = WorkflowExecutionCloseStatus(val)
return nil
}
}
// MarshalText encodes WorkflowExecutionCloseStatus to text.
func (e WorkflowExecutionCloseStatus) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// WorkflowExecutionCloseStatusCompleted is an option for WorkflowExecutionCloseStatus
WorkflowExecutionCloseStatusCompleted WorkflowExecutionCloseStatus = iota
// WorkflowExecutionCloseStatusFailed is an option for WorkflowExecutionCloseStatus
WorkflowExecutionCloseStatusFailed
// WorkflowExecutionCloseStatusCanceled is an option for WorkflowExecutionCloseStatus
WorkflowExecutionCloseStatusCanceled
// WorkflowExecutionCloseStatusTerminated is an option for WorkflowExecutionCloseStatus
WorkflowExecutionCloseStatusTerminated
// WorkflowExecutionCloseStatusContinuedAsNew is an option for WorkflowExecutionCloseStatus
WorkflowExecutionCloseStatusContinuedAsNew
// WorkflowExecutionCloseStatusTimedOut is an option for WorkflowExecutionCloseStatus
WorkflowExecutionCloseStatusTimedOut
)
// WorkflowExecutionCompletedEventAttributes is an internal type (TBD...)
type WorkflowExecutionCompletedEventAttributes struct {
Result []byte `json:"result,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
}
// WorkflowExecutionConfiguration is an internal type (TBD...)
type WorkflowExecutionConfiguration struct {
TaskList *TaskList `json:"taskList,omitempty"`
ExecutionStartToCloseTimeoutSeconds *int32 `json:"executionStartToCloseTimeoutSeconds,omitempty"`
TaskStartToCloseTimeoutSeconds *int32 `json:"taskStartToCloseTimeoutSeconds,omitempty"`
}
// WorkflowExecutionContinuedAsNewEventAttributes is an internal type (TBD...)
type WorkflowExecutionContinuedAsNewEventAttributes struct {
NewExecutionRunID string `json:"newExecutionRunId,omitempty"`
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"input,omitempty"`
ExecutionStartToCloseTimeoutSeconds *int32 `json:"executionStartToCloseTimeoutSeconds,omitempty"`
TaskStartToCloseTimeoutSeconds *int32 `json:"taskStartToCloseTimeoutSeconds,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
BackoffStartIntervalInSeconds *int32 `json:"backoffStartIntervalInSeconds,omitempty"`
Initiator *ContinueAsNewInitiator `json:"initiator,omitempty"`
FailureReason *string `json:"failureReason,omitempty"`
FailureDetails []byte `json:"failureDetails,omitempty"`
LastCompletionResult []byte `json:"lastCompletionResult,omitempty"`
Header *Header `json:"header,omitempty"`
Memo *Memo `json:"memo,omitempty"`
SearchAttributes *SearchAttributes `json:"searchAttributes,omitempty"`
JitterStartSeconds *int32 `json:"jitterStartSeconds,omitempty"`
}
// GetNewExecutionRunID is an internal getter (TBD...)
func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetNewExecutionRunID() (o string) {
if v != nil {
return v.NewExecutionRunID
}
return
}
// GetInitiator is an internal getter (TBD...)
func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetInitiator() (o ContinueAsNewInitiator) {
if v != nil && v.Initiator != nil {
return *v.Initiator
}
return
}
// GetFailureReason is an internal getter (TBD...)
func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetFailureReason() (o string) {
if v != nil && v.FailureReason != nil {
return *v.FailureReason
}
return
}
// GetLastCompletionResult is an internal getter (TBD...)
func (v *WorkflowExecutionContinuedAsNewEventAttributes) GetLastCompletionResult() (o []byte) {
if v != nil && v.LastCompletionResult != nil {
return v.LastCompletionResult
}
return
}
// WorkflowExecutionFailedEventAttributes is an internal type (TBD...)
type WorkflowExecutionFailedEventAttributes struct {
Reason *string `json:"reason,omitempty"`
Details []byte `json:"details,omitempty"`
DecisionTaskCompletedEventID int64 `json:"decisionTaskCompletedEventId,omitempty"`
}
// GetReason is an internal getter (TBD...)
func (v *WorkflowExecutionFailedEventAttributes) GetReason() (o string) {
if v != nil && v.Reason != nil {
return *v.Reason
}
return
}
// WorkflowExecutionFilter is an internal type (TBD...)
type WorkflowExecutionFilter struct {
WorkflowID string `json:"workflowId,omitempty"`
RunID string `json:"runId,omitempty"`
}
// GetWorkflowID is an internal getter (TBD...)
func (v *WorkflowExecutionFilter) GetWorkflowID() (o string) {
if v != nil {
return v.WorkflowID
}
return
}
// WorkflowExecutionInfo is an internal type (TBD...)
type WorkflowExecutionInfo struct {
Execution *WorkflowExecution `json:"execution,omitempty"`
Type *WorkflowType `json:"type,omitempty"`
StartTime *int64 `json:"startTime,omitempty"`
CloseTime *int64 `json:"closeTime,omitempty"`
CloseStatus *WorkflowExecutionCloseStatus `json:"closeStatus,omitempty"`
HistoryLength int64 `json:"historyLength,omitempty"` // should be history count
ParentDomainID *string `json:"parentDomainId,omitempty"`
ParentDomain *string `json:"parentDomain,omitempty"`
ParentExecution *WorkflowExecution `json:"parentExecution,omitempty"`
ParentInitiatedID *int64 `json:"parentInitiatedId,omitempty"`
ExecutionTime *int64 `json:"executionTime,omitempty"`
Memo *Memo `json:"memo,omitempty"`
SearchAttributes *SearchAttributes `json:"searchAttributes,omitempty"`
AutoResetPoints *ResetPoints `json:"autoResetPoints,omitempty"`
TaskList string `json:"taskList,omitempty"`
IsCron bool `json:"isCron,omitempty"`
UpdateTime *int64 `json:"updateTime,omitempty"`
PartitionConfig map[string]string
}
// GetExecution is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetExecution() (o *WorkflowExecution) {
if v != nil && v.Execution != nil {
return v.Execution
}
return
}
// GetType is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetType() (o *WorkflowType) {
if v != nil && v.Type != nil {
return v.Type
}
return
}
// GetStartTime is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetStartTime() (o int64) {
if v != nil && v.StartTime != nil {
return *v.StartTime
}
return
}
// GetCloseTime is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetCloseTime() (o int64) {
if v != nil && v.CloseTime != nil {
return *v.CloseTime
}
return
}
// GetCloseStatus is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetCloseStatus() (o WorkflowExecutionCloseStatus) {
if v != nil && v.CloseStatus != nil {
return *v.CloseStatus
}
return
}
// GetExecutionTime is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetExecutionTime() (o int64) {
if v != nil && v.ExecutionTime != nil {
return *v.ExecutionTime
}
return
}
// GetUpdateTime is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetUpdateTime() (o int64) {
if v != nil && v.UpdateTime != nil {
return *v.UpdateTime
}
return
}
// GetSearchAttributes is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetSearchAttributes() (o *SearchAttributes) {
if v != nil && v.SearchAttributes != nil {
return v.SearchAttributes
}
return
}
// GetPartitionConfig is an internal getter (TBD...)
func (v *WorkflowExecutionInfo) GetPartitionConfig() (o map[string]string) {
if v != nil && v.PartitionConfig != nil {
return v.PartitionConfig
}
return
}
// WorkflowExecutionSignaledEventAttributes is an internal type (TBD...)
type WorkflowExecutionSignaledEventAttributes struct {
SignalName string `json:"signalName,omitempty"`
Input []byte `json:"input,omitempty"`
Identity string `json:"identity,omitempty"`
RequestID string `json:"requestId,omitempty"`
}
// GetSignalName is an internal getter (TBD...)
func (v *WorkflowExecutionSignaledEventAttributes) GetSignalName() (o string) {
if v != nil {
return v.SignalName
}
return
}
// GetInput is an internal getter (TBD...)
func (v *WorkflowExecutionSignaledEventAttributes) GetInput() (o []byte) {
if v != nil && v.Input != nil {
return v.Input
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *WorkflowExecutionSignaledEventAttributes) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *WorkflowExecutionSignaledEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// WorkflowExecutionStartedEventAttributes is an internal type (TBD...)
type WorkflowExecutionStartedEventAttributes struct {
WorkflowType *WorkflowType `json:"workflowType,omitempty"`
ParentWorkflowDomainID *string `json:"parentWorkflowDomainID,omitempty"`
ParentWorkflowDomain *string `json:"parentWorkflowDomain,omitempty"`
ParentWorkflowExecution *WorkflowExecution `json:"parentWorkflowExecution,omitempty"`
ParentInitiatedEventID *int64 `json:"parentInitiatedEventId,omitempty"`
TaskList *TaskList `json:"taskList,omitempty"`
Input []byte `json:"input,omitempty"`
ExecutionStartToCloseTimeoutSeconds *int32 `json:"executionStartToCloseTimeoutSeconds,omitempty"`
TaskStartToCloseTimeoutSeconds *int32 `json:"taskStartToCloseTimeoutSeconds,omitempty"`
ContinuedExecutionRunID string `json:"continuedExecutionRunId,omitempty"`
Initiator *ContinueAsNewInitiator `json:"initiator,omitempty"`
ContinuedFailureReason *string `json:"continuedFailureReason,omitempty"`
ContinuedFailureDetails []byte `json:"continuedFailureDetails,omitempty"`
LastCompletionResult []byte `json:"lastCompletionResult,omitempty"`
OriginalExecutionRunID string `json:"originalExecutionRunId,omitempty"`
Identity string `json:"identity,omitempty"`
FirstExecutionRunID string `json:"firstExecutionRunId,omitempty"`
FirstScheduleTime *time.Time `json:"firstScheduleTimeNano,omitempty"`
RetryPolicy *RetryPolicy `json:"retryPolicy,omitempty"`
Attempt int32 `json:"attempt,omitempty"`
ExpirationTimestamp *int64 `json:"expirationTimestamp,omitempty"`
CronSchedule string `json:"cronSchedule,omitempty"`
FirstDecisionTaskBackoffSeconds *int32 `json:"firstDecisionTaskBackoffSeconds,omitempty"`
Memo *Memo `json:"memo,omitempty"`
SearchAttributes *SearchAttributes `json:"searchAttributes,omitempty"`
PrevAutoResetPoints *ResetPoints `json:"prevAutoResetPoints,omitempty"`
Header *Header `json:"header,omitempty"`
JitterStartSeconds *int32 `json:"jitterStartSeconds,omitempty"`
PartitionConfig map[string]string
RequestID string `json:"requestId,omitempty"`
}
// GetParentWorkflowDomain is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetParentWorkflowDomain() (o string) {
if v != nil && v.ParentWorkflowDomain != nil {
return *v.ParentWorkflowDomain
}
return
}
// GetParentInitiatedEventID is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetParentInitiatedEventID() (o int64) {
if v != nil && v.ParentInitiatedEventID != nil {
return *v.ParentInitiatedEventID
}
return
}
// GetExecutionStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetExecutionStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.ExecutionStartToCloseTimeoutSeconds != nil {
return *v.ExecutionStartToCloseTimeoutSeconds
}
return
}
// GetTaskStartToCloseTimeoutSeconds is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetTaskStartToCloseTimeoutSeconds() (o int32) {
if v != nil && v.TaskStartToCloseTimeoutSeconds != nil {
return *v.TaskStartToCloseTimeoutSeconds
}
return
}
// GetContinuedExecutionRunID is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetContinuedExecutionRunID() (o string) {
if v != nil {
return v.ContinuedExecutionRunID
}
return
}
// GetInitiator is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetInitiator() (o ContinueAsNewInitiator) {
if v != nil && v.Initiator != nil {
return *v.Initiator
}
return
}
// GetFirstExecutionRunID is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetFirstExecutionRunID() (o string) {
if v != nil {
return v.FirstExecutionRunID
}
return
}
// Get
func (v *WorkflowExecutionStartedEventAttributes) GetFirstScheduledTime() (o time.Time) {
if v != nil && v.FirstScheduleTime != nil {
return *v.FirstScheduleTime
}
return
}
// GetAttempt is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetAttempt() (o int32) {
if v != nil {
return v.Attempt
}
return
}
// GetExpirationTimestamp is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetExpirationTimestamp() (o int64) {
if v != nil && v.ExpirationTimestamp != nil {
return *v.ExpirationTimestamp
}
return
}
// GetCronSchedule is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetCronSchedule() (o string) {
if v != nil {
return v.CronSchedule
}
return
}
// GetFirstDecisionTaskBackoffSeconds is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetFirstDecisionTaskBackoffSeconds() (o int32) {
if v != nil && v.FirstDecisionTaskBackoffSeconds != nil {
return *v.FirstDecisionTaskBackoffSeconds
}
return
}
func (v *WorkflowExecutionStartedEventAttributes) GetJitterStartSeconds() (o int32) {
if v != nil && v.JitterStartSeconds != nil {
return *v.JitterStartSeconds
}
return
}
// GetMemo is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetMemo() (o *Memo) {
if v != nil && v.Memo != nil {
return v.Memo
}
return
}
// GetSearchAttributes is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetSearchAttributes() (o *SearchAttributes) {
if v != nil && v.SearchAttributes != nil {
return v.SearchAttributes
}
return
}
// GetPrevAutoResetPoints is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetPrevAutoResetPoints() (o *ResetPoints) {
if v != nil && v.PrevAutoResetPoints != nil {
return v.PrevAutoResetPoints
}
return
}
// GetPartitionConfig is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetPartitionConfig() (o map[string]string) {
if v != nil && v.PartitionConfig != nil {
return v.PartitionConfig
}
return
}
// GetRequestID is an internal getter (TBD...)
func (v *WorkflowExecutionStartedEventAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// WorkflowExecutionTerminatedEventAttributes is an internal type (TBD...)
type WorkflowExecutionTerminatedEventAttributes struct {
Reason string `json:"reason,omitempty"`
Details []byte `json:"details,omitempty"`
Identity string `json:"identity,omitempty"`
}
// GetReason is an internal getter (TBD...)
func (v *WorkflowExecutionTerminatedEventAttributes) GetReason() (o string) {
if v != nil {
return v.Reason
}
return
}
// GetIdentity is an internal getter (TBD...)
func (v *WorkflowExecutionTerminatedEventAttributes) GetIdentity() (o string) {
if v != nil {
return v.Identity
}
return
}
// WorkflowExecutionTimedOutEventAttributes is an internal type (TBD...)
type WorkflowExecutionTimedOutEventAttributes struct {
TimeoutType *TimeoutType `json:"timeoutType,omitempty"`
}
// GetTimeoutType is an internal getter (TBD...)
func (v *WorkflowExecutionTimedOutEventAttributes) GetTimeoutType() (o TimeoutType) {
if v != nil && v.TimeoutType != nil {
return *v.TimeoutType
}
return
}
// WorkflowIDReusePolicy is an internal type (TBD...)
type WorkflowIDReusePolicy int32
// Ptr is a helper function for getting pointer value
func (e WorkflowIDReusePolicy) Ptr() *WorkflowIDReusePolicy {
return &e
}
// String returns a readable string representation of WorkflowIDReusePolicy.
func (e WorkflowIDReusePolicy) String() string {
w := int32(e)
switch w {
case 0:
return "AllowDuplicateFailedOnly"
case 1:
return "AllowDuplicate"
case 2:
return "RejectDuplicate"
case 3:
return "TerminateIfRunning"
}
return fmt.Sprintf("WorkflowIDReusePolicy(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *WorkflowIDReusePolicy) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "ALLOWDUPLICATEFAILEDONLY":
*e = WorkflowIDReusePolicyAllowDuplicateFailedOnly
return nil
case "ALLOWDUPLICATE":
*e = WorkflowIDReusePolicyAllowDuplicate
return nil
case "REJECTDUPLICATE":
*e = WorkflowIDReusePolicyRejectDuplicate
return nil
case "TERMINATEIFRUNNING":
*e = WorkflowIDReusePolicyTerminateIfRunning
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "WorkflowIDReusePolicy", err)
}
*e = WorkflowIDReusePolicy(val)
return nil
}
}
// MarshalText encodes WorkflowIDReusePolicy to text.
func (e WorkflowIDReusePolicy) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// WorkflowIDReusePolicyAllowDuplicateFailedOnly is an option for WorkflowIDReusePolicy
WorkflowIDReusePolicyAllowDuplicateFailedOnly WorkflowIDReusePolicy = iota
// WorkflowIDReusePolicyAllowDuplicate is an option for WorkflowIDReusePolicy
WorkflowIDReusePolicyAllowDuplicate
// WorkflowIDReusePolicyRejectDuplicate is an option for WorkflowIDReusePolicy
WorkflowIDReusePolicyRejectDuplicate
// WorkflowIDReusePolicyTerminateIfRunning is an option for WorkflowIDReusePolicy
WorkflowIDReusePolicyTerminateIfRunning
)
// WorkflowQuery is an internal type (TBD...)
type WorkflowQuery struct {
QueryType string `json:"queryType,omitempty"`
QueryArgs []byte `json:"queryArgs,omitempty"`
}
// GetQueryType is an internal getter (TBD...)
func (v *WorkflowQuery) GetQueryType() (o string) {
if v != nil {
return v.QueryType
}
return
}
// GetQueryArgs is an internal getter (TBD...)
func (v *WorkflowQuery) GetQueryArgs() (o []byte) {
if v != nil && v.QueryArgs != nil {
return v.QueryArgs
}
return
}
// WorkflowQueryResult is an internal type (TBD...)
type WorkflowQueryResult struct {
ResultType *QueryResultType `json:"resultType,omitempty"`
Answer []byte `json:"answer,omitempty"`
ErrorMessage string `json:"errorMessage,omitempty"`
}
// GetResultType is an internal getter (TBD...)
func (v *WorkflowQueryResult) GetResultType() (o QueryResultType) {
if v != nil && v.ResultType != nil {
return *v.ResultType
}
return
}
// GetAnswer is an internal getter (TBD...)
func (v *WorkflowQueryResult) GetAnswer() (o []byte) {
if v != nil && v.Answer != nil {
return v.Answer
}
return
}
// GetErrorMessage is an internal getter (TBD...)
func (v *WorkflowQueryResult) GetErrorMessage() (o string) {
if v != nil {
return v.ErrorMessage
}
return
}
// WorkflowType is an internal type (TBD...)
type WorkflowType struct {
Name string `json:"name,omitempty"`
}
// GetName is an internal getter (TBD...)
func (v *WorkflowType) GetName() (o string) {
if v != nil {
return v.Name
}
return
}
// WorkflowTypeFilter is an internal type (TBD...)
type WorkflowTypeFilter struct {
Name string `json:"name,omitempty"`
}
// GetName is an internal getter (TBD...)
func (v *WorkflowTypeFilter) GetName() (o string) {
if v != nil {
return v.Name
}
return
}
// CrossClusterTaskType is an internal type (TBD...)
type CrossClusterTaskType int32
// Ptr is a helper function for getting pointer value
func (e CrossClusterTaskType) Ptr() *CrossClusterTaskType {
return &e
}
// String returns a readable string representation of CrossClusterTaskType.
func (e CrossClusterTaskType) String() string {
w := int32(e)
switch w {
case 0:
return "StartChildExecution"
case 1:
return "CancelExecution"
case 2:
return "SignalExecution"
case 3:
return "RecordChildWorkflowExecutionComplete"
case 4:
return "ApplyParentClosePolicy"
}
return fmt.Sprintf("CrossClusterTaskType(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *CrossClusterTaskType) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "STARTCHILDEXECUTION":
*e = CrossClusterTaskTypeStartChildExecution
return nil
case "CANCELEXECUTION":
*e = CrossClusterTaskTypeCancelExecution
return nil
case "SIGNALEXECUTION":
*e = CrossClusterTaskTypeSignalExecution
return nil
case "RECORDCHILDWORKLOWEXECUTIONCOMPLETE":
*e = CrossClusterTaskTypeRecordChildWorkflowExeuctionComplete
return nil
case "APPLYPARENTCLOSEPOLICY":
*e = CrossClusterTaskTypeApplyParentPolicy
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "CrossClusterTaskType", err)
}
*e = CrossClusterTaskType(val)
return nil
}
}
// MarshalText encodes CrossClusterTaskType to text.
func (e CrossClusterTaskType) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// CrossClusterTaskTypeStartChildExecution is an option for CrossClusterTaskType
CrossClusterTaskTypeStartChildExecution CrossClusterTaskType = iota
// CrossClusterTaskTypeCancelExecution is an option for CrossClusterTaskType
CrossClusterTaskTypeCancelExecution
// CrossClusterTaskTypeSignalExecution is an option for CrossClusterTaskType
CrossClusterTaskTypeSignalExecution
// CrossClusterTaskTypeRecordChildWorkflowExeuctionComplete is an option for CrossClusterTaskType
CrossClusterTaskTypeRecordChildWorkflowExeuctionComplete
// CrossClusterTaskTypeApplyParentPolicy is an option for CrossClusterTaskType
CrossClusterTaskTypeApplyParentPolicy
)
// CrossClusterTaskFailedCause is an internal type (TBD...)
type CrossClusterTaskFailedCause int32
// Ptr is a helper function for getting pointer value
func (e CrossClusterTaskFailedCause) Ptr() *CrossClusterTaskFailedCause {
return &e
}
// String returns a readable string representation of CrossClusterTaskFailedCause.
func (e CrossClusterTaskFailedCause) String() string {
w := int32(e)
switch w {
case 0:
return "DOMAIN_NOT_ACTIVE"
case 1:
return "DOMAIN_NOT_EXISTS"
case 2:
return "WORKFLOW_ALREADY_RUNNING"
case 3:
return "WORKFLOW_NOT_EXISTS"
case 4:
return "WORKFLOW_ALREADY_COMPLETED"
case 5:
return "UNCATEGORIZED"
}
return fmt.Sprintf("CrossClusterTaskFailedCause(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *CrossClusterTaskFailedCause) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "DOMAIN_NOT_ACTIVE":
*e = CrossClusterTaskFailedCauseDomainNotActive
return nil
case "DOMAIN_NOT_EXISTS":
*e = CrossClusterTaskFailedCauseDomainNotExists
return nil
case "WORKFLOW_ALREADY_RUNNING":
*e = CrossClusterTaskFailedCauseWorkflowAlreadyRunning
return nil
case "WORKFLOW_NOT_EXISTS":
*e = CrossClusterTaskFailedCauseWorkflowNotExists
return nil
case "WORKFLOW_ALREADY_COMPLETED":
*e = CrossClusterTaskFailedCauseWorkflowAlreadyCompleted
return nil
case "UNCATEGORIZED":
*e = CrossClusterTaskFailedCauseUncategorized
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "CrossClusterTaskFailedCause", err)
}
*e = CrossClusterTaskFailedCause(val)
return nil
}
}
// MarshalText encodes CrossClusterTaskFailedCause to text.
func (e CrossClusterTaskFailedCause) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// CrossClusterTaskFailedCauseDomainNotActive is an option for CrossClusterTaskFailedCause
CrossClusterTaskFailedCauseDomainNotActive CrossClusterTaskFailedCause = iota
// CrossClusterTaskFailedCauseDomainNotExists is an option for CrossClusterTaskFailedCause
CrossClusterTaskFailedCauseDomainNotExists
// CrossClusterTaskFailedCauseWorkflowAlreadyRunning is an option for CrossClusterTaskFailedCause
CrossClusterTaskFailedCauseWorkflowAlreadyRunning
// CrossClusterTaskFailedCauseWorkflowNotExists is an option for CrossClusterTaskFailedCause
CrossClusterTaskFailedCauseWorkflowNotExists
// CrossClusterTaskFailedCauseWorkflowAlreadyCompleted is an option for CrossClusterTaskFailedCause
CrossClusterTaskFailedCauseWorkflowAlreadyCompleted
// CrossClusterTaskFailedCauseUncategorized is an option for CrossClusterTaskFailedCause
CrossClusterTaskFailedCauseUncategorized
)
// GetTaskFailedCause is an internal type (TBD...)
type GetTaskFailedCause int32
// Ptr is a helper function for getting pointer value
func (e GetTaskFailedCause) Ptr() *GetTaskFailedCause {
return &e
}
// String returns a readable string representation of GetCrossClusterTaskFailedCause.
func (e GetTaskFailedCause) String() string {
w := int32(e)
switch w {
case 0:
return "SERVICE_BUSY"
case 1:
return "TIMEOUT"
case 2:
return "SHARD_OWNERSHIP_LOST"
case 3:
return "UNCATEGORIZED"
}
return fmt.Sprintf("GetCrossClusterTaskFailedCause(%d)", w)
}
// UnmarshalText parses enum value from string representation
func (e *GetTaskFailedCause) UnmarshalText(value []byte) error {
switch s := strings.ToUpper(string(value)); s {
case "SERVICE_BUSY":
*e = GetTaskFailedCauseServiceBusy
return nil
case "TIMEOUT":
*e = GetTaskFailedCauseTimeout
return nil
case "SHARD_OWNERSHIP_LOST":
*e = GetTaskFailedCauseShardOwnershipLost
return nil
case "UNCATEGORIZED":
*e = GetTaskFailedCauseUncategorized
return nil
default:
val, err := strconv.ParseInt(s, 10, 32)
if err != nil {
return fmt.Errorf("unknown enum value %q for %q: %v", s, "GetCrossClusterTaskFailedCause", err)
}
*e = GetTaskFailedCause(val)
return nil
}
}
// MarshalText encodes GetCrossClusterTaskFailedCause to text.
func (e GetTaskFailedCause) MarshalText() ([]byte, error) {
return []byte(e.String()), nil
}
const (
// GetTaskFailedCauseServiceBusy is an option for GetCrossClusterTaskFailedCause
GetTaskFailedCauseServiceBusy GetTaskFailedCause = iota
// GetTaskFailedCauseTimeout is an option for GetCrossClusterTaskFailedCause
GetTaskFailedCauseTimeout
// GetTaskFailedCauseShardOwnershipLost is an option for GetCrossClusterTaskFailedCause
GetTaskFailedCauseShardOwnershipLost
// GetTaskFailedCauseUncategorized is an option for GetCrossClusterTaskFailedCause
GetTaskFailedCauseUncategorized
)
// CrossClusterTaskInfo is an internal type (TBD...)
type CrossClusterTaskInfo struct {
DomainID string `json:"domainID,omitempty"`
WorkflowID string `json:"workflowID,omitempty"`
RunID string `json:"runID,omitempty"`
TaskType *CrossClusterTaskType `json:"taskType,omitempty"`
TaskState int16 `json:"taskState,omitempty"`
TaskID int64 `json:"taskID,omitempty"`
VisibilityTimestamp *int64 `json:"visibilityTimestamp,omitempty"`
}
// GetTaskType is an internal getter (TBD...)
func (v *CrossClusterTaskInfo) GetTaskType() (o CrossClusterTaskType) {
if v != nil && v.TaskType != nil {
return *v.TaskType
}
return
}
// GetTaskID is an internal getter (TBD...)
func (v *CrossClusterTaskInfo) GetTaskID() (o int64) {
if v != nil {
return v.TaskID
}
return
}
// GetVisibilityTimestamp is an internal getter (TBD...)
func (v *CrossClusterTaskInfo) GetVisibilityTimestamp() (o int64) {
if v != nil && v.VisibilityTimestamp != nil {
return *v.VisibilityTimestamp
}
return
}
// CrossClusterStartChildExecutionRequestAttributes is an internal type (TBD...)
type CrossClusterStartChildExecutionRequestAttributes struct {
TargetDomainID string `json:"targetDomainID,omitempty"`
RequestID string `json:"requestID,omitempty"`
InitiatedEventID int64 `json:"initiatedEventID,omitempty"`
InitiatedEventAttributes *StartChildWorkflowExecutionInitiatedEventAttributes `json:"initiatedEventAttributes,omitempty"`
TargetRunID *string `json:"targetRunID,omitempty"`
PartitionConfig map[string]string
}
// GetRequestID is an internal getter (TBD...)
func (v *CrossClusterStartChildExecutionRequestAttributes) GetRequestID() (o string) {
if v != nil {
return v.RequestID
}
return
}
// GetInitiatedEventAttributes is an internal getter (TBD...)
func (v *CrossClusterStartChildExecutionRequestAttributes) GetInitiatedEventAttributes() (o *StartChildWorkflowExecutionInitiatedEventAttributes) {
if v != nil && v.InitiatedEventAttributes != nil {
return v.InitiatedEventAttributes
}
return
}
// GetTargetRunID is an internal getter (TBD...)
func (v *CrossClusterStartChildExecutionRequestAttributes) GetTargetRunID() (o string) {
if v != nil && v.TargetRunID != nil {
return *v.TargetRunID
}
return
}
// GetTargetRunID is an internal getter (TBD...)
func (v *CrossClusterStartChildExecutionRequestAttributes) GetPartitionConfig() (o map[string]string) {
if v != nil && v.PartitionConfig != nil {
return v.PartitionConfig
}
return
}
// CrossClusterStartChildExecutionResponseAttributes is an internal type (TBD...)
type CrossClusterStartChildExecutionResponseAttributes struct {
RunID string `json:"runID,omitempty"`
}
// GetRunID is an internal getter (TBD...)
func (v *CrossClusterStartChildExecutionResponseAttributes) GetRunID() (o string) {
if v != nil {
return v.RunID
}
return
}
// CrossClusterCancelExecutionRequestAttributes is an internal type (TBD...)
type CrossClusterCancelExecutionRequestAttributes struct {
TargetDomainID string `json:"targetDomainID,omitempty"`
TargetWorkflowID string `json:"targetWorkflowID,omitempty"`
TargetRunID string `json:"targetRunID,omitempty"`
RequestID string `json:"requestID,omitempty"`
InitiatedEventID int64 `json:"initiatedEventID,omitempty"`
ChildWorkflowOnly bool `json:"childWorkflowOnly,omitempty"`
}
// CrossClusterCancelExecutionResponseAttributes is an internal type (TBD...)
type CrossClusterCancelExecutionResponseAttributes struct {
}
// CrossClusterSignalExecutionRequestAttributes is an internal type (TBD...)
type CrossClusterSignalExecutionRequestAttributes struct {
TargetDomainID string `json:"targetDomainID,omitempty"`
TargetWorkflowID string `json:"targetWorkflowID,omitempty"`
TargetRunID string `json:"targetRunID,omitempty"`
RequestID string `json:"requestID,omitempty"`
InitiatedEventID int64 `json:"initiatedEventID,omitempty"`
ChildWorkflowOnly bool `json:"childWorkflowOnly,omitempty"`
SignalName string `json:"signalName,omitempty"`
SignalInput []byte `json:"signalInput,omitempty"`
Control []byte `json:"control,omitempty"`
}
// CrossClusterSignalExecutionResponseAttributes is an internal type (TBD...)
type CrossClusterSignalExecutionResponseAttributes struct {
}
type CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes struct {
TargetDomainID string `json:"targetDomainID,omitempty"`
TargetWorkflowID string `json:"targetWorkflowID,omitempty"`
TargetRunID string `json:"targetRunID,omitempty"`
InitiatedEventID int64 `json:"initiatedEventID,omitempty"`
CompletionEvent *HistoryEvent `json:"completionEvent,omitempty"`
}
// CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes is an internal type (TBD...)
type CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes struct {
}
type ApplyParentClosePolicyStatus struct {
Completed bool `json:"completed,omitempty"`
FailedCause *CrossClusterTaskFailedCause `json:"failedCause,omitempty"`
}
type ApplyParentClosePolicyAttributes struct {
ChildDomainID string `json:"ChildDomainID,omitempty"`
ChildWorkflowID string `json:"ChildWorkflowID,omitempty"`
ChildRunID string `json:"ChildRunID,omitempty"`
ParentClosePolicy *ParentClosePolicy `json:"parentClosePolicy,omitempty"`
}
// GetParentClosePolicy is an internal getter (TBD...)
func (v *ApplyParentClosePolicyAttributes) GetParentClosePolicy() (o *ParentClosePolicy) {
if v != nil {
return v.ParentClosePolicy
}
return
}
type ApplyParentClosePolicyRequest struct {
Child *ApplyParentClosePolicyAttributes `json:"child,omitempty"`
Status *ApplyParentClosePolicyStatus `json:"status,omitempty"`
}
type CrossClusterApplyParentClosePolicyRequestAttributes struct {
Children []*ApplyParentClosePolicyRequest `json:"children,omitempty"`
}
type ApplyParentClosePolicyResult struct {
Child *ApplyParentClosePolicyAttributes `json:"child,omitempty"`
FailedCause *CrossClusterTaskFailedCause `json:"failedCause,omitempty"`
}
// CrossClusterApplyParentClosePolicyResponseAttributes is an internal type (TBD...)
type CrossClusterApplyParentClosePolicyResponseAttributes struct {
ChildrenStatus []*ApplyParentClosePolicyResult `json:"childrenStatus,omitempty"`
}
// CrossClusterTaskRequest is an internal type (TBD...)
type CrossClusterTaskRequest struct {
TaskInfo *CrossClusterTaskInfo `json:"taskInfo,omitempty"`
StartChildExecutionAttributes *CrossClusterStartChildExecutionRequestAttributes `json:"startChildExecutionAttributes,omitempty"`
CancelExecutionAttributes *CrossClusterCancelExecutionRequestAttributes `json:"cancelExecutionAttributes,omitempty"`
SignalExecutionAttributes *CrossClusterSignalExecutionRequestAttributes `json:"signalExecutionAttributes,omitempty"`
RecordChildWorkflowExecutionCompleteAttributes *CrossClusterRecordChildWorkflowExecutionCompleteRequestAttributes `json:"RecordChildWorkflowExecutionCompleteAttributes,omitempty"`
ApplyParentClosePolicyAttributes *CrossClusterApplyParentClosePolicyRequestAttributes `json:"ApplyParentClosePolicyAttributes,omitempty"`
}
// CrossClusterTaskResponse is an internal type (TBD...)
type CrossClusterTaskResponse struct {
TaskID int64 `json:"taskID,omitempty"`
TaskType *CrossClusterTaskType `json:"taskType,omitempty"`
TaskState int16 `json:"taskState,omitempty"`
FailedCause *CrossClusterTaskFailedCause `json:"failedCause,omitempty"`
StartChildExecutionAttributes *CrossClusterStartChildExecutionResponseAttributes `json:"startChildExecutionAttributes,omitempty"`
CancelExecutionAttributes *CrossClusterCancelExecutionResponseAttributes `json:"cancelExecutionAttributes,omitempty"`
SignalExecutionAttributes *CrossClusterSignalExecutionResponseAttributes `json:"signalExecutionAttributes,omitempty"`
RecordChildWorkflowExecutionCompleteAttributes *CrossClusterRecordChildWorkflowExecutionCompleteResponseAttributes `json:"RecordChildWorkflowExecutionCompleteAttributes,omitempty"`
ApplyParentClosePolicyAttributes *CrossClusterApplyParentClosePolicyResponseAttributes `json:"ApplyParentClosePolicyAttributes,omitempty"`
}
// GetTaskID is an internal getter (TBD...)
func (v *CrossClusterTaskResponse) GetTaskID() (o int64) {
if v != nil {
return v.TaskID
}
return
}
// GetTaskType is an internal getter (TBD...)
func (v *CrossClusterTaskResponse) GetTaskType() (o CrossClusterTaskType) {
if v != nil && v.TaskType != nil {
return *v.TaskType
}
return
}
// GetFailedCause is an internal getter (TBD...)
func (v *CrossClusterTaskResponse) GetFailedCause() (o CrossClusterTaskFailedCause) {
if v != nil && v.FailedCause != nil {
return *v.FailedCause
}
return
}
// GetCrossClusterTasksRequest is an internal type (TBD...)
type GetCrossClusterTasksRequest struct {
ShardIDs []int32 `json:"shardIDs,omitempty"`
TargetCluster string `json:"targetCluster,omitempty"`
}
func (v *GetCrossClusterTasksRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetShardIDs is an internal getter (TBD...)
func (v *GetCrossClusterTasksRequest) GetShardIDs() (o []int32) {
if v != nil && v.ShardIDs != nil {
return v.ShardIDs
}
return
}
// GetTargetCluster is an internal getter (TBD...)
func (v *GetCrossClusterTasksRequest) GetTargetCluster() (o string) {
if v != nil {
return v.TargetCluster
}
return
}
// GetCrossClusterTasksResponse is an internal type (TBD...)
type GetCrossClusterTasksResponse struct {
TasksByShard map[int32][]*CrossClusterTaskRequest `json:"tasksByShard,omitempty"`
FailedCauseByShard map[int32]GetTaskFailedCause `json:"failedCauseByShard,omitempty"`
}
// GetTasksByShard is an internal getter (TBD...)
func (v *GetCrossClusterTasksResponse) GetTasksByShard() (o map[int32][]*CrossClusterTaskRequest) {
if v != nil && v.TasksByShard != nil {
return v.TasksByShard
}
return
}
// RespondCrossClusterTasksCompletedRequest is an internal type (TBD...)
type RespondCrossClusterTasksCompletedRequest struct {
ShardID int32 `json:"shardID,omitempty"`
TargetCluster string `json:"targetCluster,omitempty"`
TaskResponses []*CrossClusterTaskResponse `json:"taskResponses,omitempty"`
FetchNewTasks bool `json:"fetchNewTasks,omitempty"`
}
func (v *RespondCrossClusterTasksCompletedRequest) SerializeForLogging() (string, error) {
if v == nil {
return "", nil
}
return SerializeRequest(v)
}
// GetShardID is an internal getter (TBD...)
func (v *RespondCrossClusterTasksCompletedRequest) GetShardID() (o int32) {
if v != nil {
return v.ShardID
}
return
}
// GetFetchNewTasks is an internal getter (TBD...)
func (v *RespondCrossClusterTasksCompletedRequest) GetFetchNewTasks() (o bool) {
if v != nil {
return v.FetchNewTasks
}
return
}
// RespondCrossClusterTasksCompletedResponse is an internal type (TBD...)
type RespondCrossClusterTasksCompletedResponse struct {
Tasks []*CrossClusterTaskRequest `json:"tasks,omitempty"`
}
// StickyWorkerUnavailableError is an internal type (TBD...)
type StickyWorkerUnavailableError struct {
Message string `json:"message,required"`
}
// SerializeRequest Serialize an arbitrary request for logging
// pass in a pointer as a parameter to save space
func SerializeRequest(request interface{}) (string, error) {
res, err := json.Marshal(request)
if err != nil {
return "", err
}
return string(res), nil
}