cli

package
v0.30.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 17, 2020 License: MIT Imports: 14 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type DescribeWorkflowExecutionResponse 

type DescribeWorkflowExecutionResponse struct {
	ExecutionConfig       *v1.WorkflowExecutionConfig     `protobuf:"bytes,1,opt,name=execution_config,json=executionConfig,proto3" json:"execution_config,omitempty"`
	WorkflowExecutionInfo *WorkflowExecutionInfo          `` /* 126-byte string literal not displayed */
	PendingActivities     []*PendingActivityInfo          `protobuf:"bytes,3,rep,name=pending_activities,json=pendingActivities,proto3" json:"pending_activities,omitempty"`
	PendingChildren       []*v1.PendingChildExecutionInfo `protobuf:"bytes,4,rep,name=pending_children,json=pendingChildren,proto3" json:"pending_children,omitempty"`
}

func (*DescribeWorkflowExecutionResponse) Descriptor 

func (*DescribeWorkflowExecutionResponse) Descriptor() ([]byte, []int)

func (*DescribeWorkflowExecutionResponse) Equal 

func (this *DescribeWorkflowExecutionResponse) Equal(that interface{}) bool

func (*DescribeWorkflowExecutionResponse) GetExecutionConfig 

func (m *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v1.WorkflowExecutionConfig

func (*DescribeWorkflowExecutionResponse) GetPendingActivities 

func (m *DescribeWorkflowExecutionResponse) GetPendingActivities() []*PendingActivityInfo

func (*DescribeWorkflowExecutionResponse) GetPendingChildren 

func (m *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v1.PendingChildExecutionInfo

func (*DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo 

func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *WorkflowExecutionInfo

func (*DescribeWorkflowExecutionResponse) GoString 

func (this *DescribeWorkflowExecutionResponse) GoString() string

func (*DescribeWorkflowExecutionResponse) Marshal 

func (m *DescribeWorkflowExecutionResponse) Marshal() (dAtA []byte, err error)

func (*DescribeWorkflowExecutionResponse) MarshalTo 

func (m *DescribeWorkflowExecutionResponse) MarshalTo(dAtA []byte) (int, error)

func (*DescribeWorkflowExecutionResponse) MarshalToSizedBuffer 

func (m *DescribeWorkflowExecutionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DescribeWorkflowExecutionResponse) ProtoMessage 

func (*DescribeWorkflowExecutionResponse) ProtoMessage()

func (*DescribeWorkflowExecutionResponse) Reset 

func (m *DescribeWorkflowExecutionResponse) Reset()

func (*DescribeWorkflowExecutionResponse) Size 

func (m *DescribeWorkflowExecutionResponse) Size() (n int)

func (*DescribeWorkflowExecutionResponse) String 

func (this *DescribeWorkflowExecutionResponse) String() string

func (*DescribeWorkflowExecutionResponse) Unmarshal 

func (m *DescribeWorkflowExecutionResponse) Unmarshal(dAtA []byte) error

func (*DescribeWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *DescribeWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*DescribeWorkflowExecutionResponse) XXX_Marshal 

func (m *DescribeWorkflowExecutionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DescribeWorkflowExecutionResponse) XXX_Merge 

func (m *DescribeWorkflowExecutionResponse) XXX_Merge(src proto.Message)

func (*DescribeWorkflowExecutionResponse) XXX_Size 

func (m *DescribeWorkflowExecutionResponse) XXX_Size() int

func (*DescribeWorkflowExecutionResponse) XXX_Unmarshal 

func (m *DescribeWorkflowExecutionResponse) XXX_Unmarshal(b []byte) error

type Failure added in v0.28.0 

type Failure struct {
	Message     string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Source      string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	StackTrace  string   `protobuf:"bytes,3,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"`
	Cause       *Failure `protobuf:"bytes,4,opt,name=cause,proto3" json:"cause,omitempty"`
	FailureType string   `protobuf:"bytes,5,opt,name=failure_type,json=failureType,proto3" json:"failure_type,omitempty"`
}

func (*Failure) Descriptor added in v0.28.0 

func (*Failure) Descriptor() ([]byte, []int)

func (*Failure) Equal added in v0.28.0 

func (this *Failure) Equal(that interface{}) bool

func (*Failure) GetCause added in v0.28.0 

func (m *Failure) GetCause() *Failure

func (*Failure) GetFailureType added in v0.28.0 

func (m *Failure) GetFailureType() string

func (*Failure) GetMessage added in v0.28.0 

func (m *Failure) GetMessage() string

func (*Failure) GetSource added in v0.28.0 

func (m *Failure) GetSource() string

func (*Failure) GetStackTrace added in v0.28.0 

func (m *Failure) GetStackTrace() string

func (*Failure) GoString added in v0.28.0 

func (this *Failure) GoString() string

func (*Failure) Marshal added in v0.28.0 

func (m *Failure) Marshal() (dAtA []byte, err error)

func (*Failure) MarshalTo added in v0.28.0 

func (m *Failure) MarshalTo(dAtA []byte) (int, error)

func (*Failure) MarshalToSizedBuffer added in v0.28.0 

func (m *Failure) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Failure) ProtoMessage added in v0.28.0 

func (*Failure) ProtoMessage()

func (*Failure) Reset added in v0.28.0 

func (m *Failure) Reset()

func (*Failure) Size added in v0.28.0 

func (m *Failure) Size() (n int)

func (*Failure) String added in v0.28.0 

func (this *Failure) String() string

func (*Failure) Unmarshal added in v0.28.0 

func (m *Failure) Unmarshal(dAtA []byte) error

func (*Failure) XXX_DiscardUnknown added in v0.28.0 

func (m *Failure) XXX_DiscardUnknown()

func (*Failure) XXX_Marshal added in v0.28.0 

func (m *Failure) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Failure) XXX_Merge added in v0.28.0 

func (m *Failure) XXX_Merge(src proto.Message)

func (*Failure) XXX_Size added in v0.28.0 

func (m *Failure) XXX_Size() int

func (*Failure) XXX_Unmarshal added in v0.28.0 

func (m *Failure) XXX_Unmarshal(b []byte) error

type PendingActivityInfo 

type PendingActivityInfo struct {
	ActivityId         string                   `protobuf:"bytes,1,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	ActivityType       *v11.ActivityType        `protobuf:"bytes,2,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	State              v12.PendingActivityState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.PendingActivityState" json:"state,omitempty"`
	HeartbeatDetails   string                   `protobuf:"bytes,4,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	LastHeartbeatTime  *time.Time               `protobuf:"bytes,5,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3,stdtime" json:"last_heartbeat_time,omitempty"`
	LastStartedTime    *time.Time               `protobuf:"bytes,6,opt,name=last_started_time,json=lastStartedTime,proto3,stdtime" json:"last_started_time,omitempty"`
	Attempt            int32                    `protobuf:"varint,7,opt,name=attempt,proto3" json:"attempt,omitempty"`
	MaximumAttempts    int32                    `protobuf:"varint,8,opt,name=maximum_attempts,json=maximumAttempts,proto3" json:"maximum_attempts,omitempty"`
	ScheduledTime      *time.Time               `protobuf:"bytes,9,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	ExpirationTime     *time.Time               `protobuf:"bytes,10,opt,name=expiration_time,json=expirationTime,proto3,stdtime" json:"expiration_time,omitempty"`
	LastFailure        *Failure                 `protobuf:"bytes,11,opt,name=last_failure,json=lastFailure,proto3" json:"last_failure,omitempty"`
	LastWorkerIdentity string                   `protobuf:"bytes,12,opt,name=last_worker_identity,json=lastWorkerIdentity,proto3" json:"last_worker_identity,omitempty"`
}

func (*PendingActivityInfo) Descriptor 

func (*PendingActivityInfo) Descriptor() ([]byte, []int)

func (*PendingActivityInfo) Equal 

func (this *PendingActivityInfo) Equal(that interface{}) bool

func (*PendingActivityInfo) GetActivityId 

func (m *PendingActivityInfo) GetActivityId() string

func (*PendingActivityInfo) GetActivityType 

func (m *PendingActivityInfo) GetActivityType() *v11.ActivityType

func (*PendingActivityInfo) GetAttempt 

func (m *PendingActivityInfo) GetAttempt() int32

func (*PendingActivityInfo) GetExpirationTime added in v0.28.0 

func (m *PendingActivityInfo) GetExpirationTime() *time.Time

func (*PendingActivityInfo) GetHeartbeatDetails 

func (m *PendingActivityInfo) GetHeartbeatDetails() string

func (*PendingActivityInfo) GetLastFailure 

func (m *PendingActivityInfo) GetLastFailure() *Failure

func (*PendingActivityInfo) GetLastHeartbeatTime added in v0.28.0 

func (m *PendingActivityInfo) GetLastHeartbeatTime() *time.Time

func (*PendingActivityInfo) GetLastStartedTime added in v0.28.0 

func (m *PendingActivityInfo) GetLastStartedTime() *time.Time

func (*PendingActivityInfo) GetLastWorkerIdentity 

func (m *PendingActivityInfo) GetLastWorkerIdentity() string

func (*PendingActivityInfo) GetMaximumAttempts 

func (m *PendingActivityInfo) GetMaximumAttempts() int32

func (*PendingActivityInfo) GetScheduledTime added in v0.28.0 

func (m *PendingActivityInfo) GetScheduledTime() *time.Time

func (*PendingActivityInfo) GetState 

func (m *PendingActivityInfo) GetState() v12.PendingActivityState

func (*PendingActivityInfo) GoString 

func (this *PendingActivityInfo) GoString() string

func (*PendingActivityInfo) Marshal 

func (m *PendingActivityInfo) Marshal() (dAtA []byte, err error)

func (*PendingActivityInfo) MarshalTo 

func (m *PendingActivityInfo) MarshalTo(dAtA []byte) (int, error)

func (*PendingActivityInfo) MarshalToSizedBuffer 

func (m *PendingActivityInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PendingActivityInfo) ProtoMessage 

func (*PendingActivityInfo) ProtoMessage()

func (*PendingActivityInfo) Reset 

func (m *PendingActivityInfo) Reset()

func (*PendingActivityInfo) Size 

func (m *PendingActivityInfo) Size() (n int)

func (*PendingActivityInfo) String 

func (this *PendingActivityInfo) String() string

func (*PendingActivityInfo) Unmarshal 

func (m *PendingActivityInfo) Unmarshal(dAtA []byte) error

func (*PendingActivityInfo) XXX_DiscardUnknown 

func (m *PendingActivityInfo) XXX_DiscardUnknown()

func (*PendingActivityInfo) XXX_Marshal 

func (m *PendingActivityInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PendingActivityInfo) XXX_Merge 

func (m *PendingActivityInfo) XXX_Merge(src proto.Message)

func (*PendingActivityInfo) XXX_Size 

func (m *PendingActivityInfo) XXX_Size() int

func (*PendingActivityInfo) XXX_Unmarshal 

func (m *PendingActivityInfo) XXX_Unmarshal(b []byte) error

type SearchAttributes 

type SearchAttributes struct {
	IndexedFields map[string]string `` /* 188-byte string literal not displayed */
}

func (*SearchAttributes) Descriptor 

func (*SearchAttributes) Descriptor() ([]byte, []int)

func (*SearchAttributes) Equal 

func (this *SearchAttributes) Equal(that interface{}) bool

func (*SearchAttributes) GetIndexedFields 

func (m *SearchAttributes) GetIndexedFields() map[string]string

func (*SearchAttributes) GoString 

func (this *SearchAttributes) GoString() string

func (*SearchAttributes) Marshal 

func (m *SearchAttributes) Marshal() (dAtA []byte, err error)

func (*SearchAttributes) MarshalTo 

func (m *SearchAttributes) MarshalTo(dAtA []byte) (int, error)

func (*SearchAttributes) MarshalToSizedBuffer 

func (m *SearchAttributes) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SearchAttributes) ProtoMessage 

func (*SearchAttributes) ProtoMessage()

func (*SearchAttributes) Reset 

func (m *SearchAttributes) Reset()

func (*SearchAttributes) Size 

func (m *SearchAttributes) Size() (n int)

func (*SearchAttributes) String 

func (this *SearchAttributes) String() string

func (*SearchAttributes) Unmarshal 

func (m *SearchAttributes) Unmarshal(dAtA []byte) error

func (*SearchAttributes) XXX_DiscardUnknown 

func (m *SearchAttributes) XXX_DiscardUnknown()

func (*SearchAttributes) XXX_Marshal 

func (m *SearchAttributes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SearchAttributes) XXX_Merge 

func (m *SearchAttributes) XXX_Merge(src proto.Message)

func (*SearchAttributes) XXX_Size 

func (m *SearchAttributes) XXX_Size() int

func (*SearchAttributes) XXX_Unmarshal 

func (m *SearchAttributes) XXX_Unmarshal(b []byte) error

type WorkflowExecutionInfo 

type WorkflowExecutionInfo struct {
	Execution         *v11.WorkflowExecution      `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Type              *v11.WorkflowType           `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	StartTime         *time.Time                  `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	CloseTime         *time.Time                  `protobuf:"bytes,4,opt,name=close_time,json=closeTime,proto3,stdtime" json:"close_time,omitempty"`
	Status            v12.WorkflowExecutionStatus `protobuf:"varint,5,opt,name=status,proto3,enum=temporal.api.enums.v1.WorkflowExecutionStatus" json:"status,omitempty"`
	HistoryLength     int64                       `protobuf:"varint,6,opt,name=history_length,json=historyLength,proto3" json:"history_length,omitempty"`
	ParentNamespaceId string                      `protobuf:"bytes,7,opt,name=parent_namespace_id,json=parentNamespaceId,proto3" json:"parent_namespace_id,omitempty"`
	ParentExecution   *v11.WorkflowExecution      `protobuf:"bytes,8,opt,name=parent_execution,json=parentExecution,proto3" json:"parent_execution,omitempty"`
	ExecutionTime     *time.Time                  `protobuf:"bytes,9,opt,name=execution_time,json=executionTime,proto3,stdtime" json:"execution_time,omitempty"`
	Memo              *v11.Memo                   `protobuf:"bytes,10,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes  *SearchAttributes           `protobuf:"bytes,11,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	AutoResetPoints   *v1.ResetPoints             `protobuf:"bytes,12,opt,name=auto_reset_points,json=autoResetPoints,proto3" json:"auto_reset_points,omitempty"`
}

func (*WorkflowExecutionInfo) Descriptor 

func (*WorkflowExecutionInfo) Descriptor() ([]byte, []int)

func (*WorkflowExecutionInfo) Equal 

func (this *WorkflowExecutionInfo) Equal(that interface{}) bool

func (*WorkflowExecutionInfo) GetAutoResetPoints 

func (m *WorkflowExecutionInfo) GetAutoResetPoints() *v1.ResetPoints

func (*WorkflowExecutionInfo) GetCloseTime 

func (m *WorkflowExecutionInfo) GetCloseTime() *time.Time

func (*WorkflowExecutionInfo) GetExecution 

func (m *WorkflowExecutionInfo) GetExecution() *v11.WorkflowExecution

func (*WorkflowExecutionInfo) GetExecutionTime 

func (m *WorkflowExecutionInfo) GetExecutionTime() *time.Time

func (*WorkflowExecutionInfo) GetHistoryLength 

func (m *WorkflowExecutionInfo) GetHistoryLength() int64

func (*WorkflowExecutionInfo) GetMemo 

func (m *WorkflowExecutionInfo) GetMemo() *v11.Memo

func (*WorkflowExecutionInfo) GetParentExecution 

func (m *WorkflowExecutionInfo) GetParentExecution() *v11.WorkflowExecution

func (*WorkflowExecutionInfo) GetParentNamespaceId 

func (m *WorkflowExecutionInfo) GetParentNamespaceId() string

func (*WorkflowExecutionInfo) GetSearchAttributes 

func (m *WorkflowExecutionInfo) GetSearchAttributes() *SearchAttributes

func (*WorkflowExecutionInfo) GetStartTime 

func (m *WorkflowExecutionInfo) GetStartTime() *time.Time

func (*WorkflowExecutionInfo) GetStatus 

func (m *WorkflowExecutionInfo) GetStatus() v12.WorkflowExecutionStatus

func (*WorkflowExecutionInfo) GetType 

func (m *WorkflowExecutionInfo) GetType() *v11.WorkflowType

func (*WorkflowExecutionInfo) GoString 

func (this *WorkflowExecutionInfo) GoString() string

func (*WorkflowExecutionInfo) Marshal 

func (m *WorkflowExecutionInfo) Marshal() (dAtA []byte, err error)

func (*WorkflowExecutionInfo) MarshalTo 

func (m *WorkflowExecutionInfo) MarshalTo(dAtA []byte) (int, error)

func (*WorkflowExecutionInfo) MarshalToSizedBuffer 

func (m *WorkflowExecutionInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WorkflowExecutionInfo) ProtoMessage 

func (*WorkflowExecutionInfo) ProtoMessage()

func (*WorkflowExecutionInfo) Reset 

func (m *WorkflowExecutionInfo) Reset()

func (*WorkflowExecutionInfo) Size 

func (m *WorkflowExecutionInfo) Size() (n int)

func (*WorkflowExecutionInfo) String 

func (this *WorkflowExecutionInfo) String() string

func (*WorkflowExecutionInfo) Unmarshal 

func (m *WorkflowExecutionInfo) Unmarshal(dAtA []byte) error

func (*WorkflowExecutionInfo) XXX_DiscardUnknown 

func (m *WorkflowExecutionInfo) XXX_DiscardUnknown()

func (*WorkflowExecutionInfo) XXX_Marshal 

func (m *WorkflowExecutionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkflowExecutionInfo) XXX_Merge 

func (m *WorkflowExecutionInfo) XXX_Merge(src proto.Message)

func (*WorkflowExecutionInfo) XXX_Size 

func (m *WorkflowExecutionInfo) XXX_Size() int

func (*WorkflowExecutionInfo) XXX_Unmarshal 

func (m *WorkflowExecutionInfo) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.