workflowservice

package
v0.29.0 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2020 License: MIT Imports: 28 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterWorkflowServiceServer 

func RegisterWorkflowServiceServer(s *grpc.Server, srv WorkflowServiceServer)

Types

type CountWorkflowExecutionsRequest 

type CountWorkflowExecutionsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Query     string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
}

func (*CountWorkflowExecutionsRequest) Descriptor 

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

func (*CountWorkflowExecutionsRequest) Equal 

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

func (*CountWorkflowExecutionsRequest) GetNamespace 

func (m *CountWorkflowExecutionsRequest) GetNamespace() string

func (*CountWorkflowExecutionsRequest) GetQuery 

func (m *CountWorkflowExecutionsRequest) GetQuery() string

func (*CountWorkflowExecutionsRequest) GoString 

func (this *CountWorkflowExecutionsRequest) GoString() string

func (*CountWorkflowExecutionsRequest) Marshal 

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

func (*CountWorkflowExecutionsRequest) MarshalTo 

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

func (*CountWorkflowExecutionsRequest) MarshalToSizedBuffer 

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

func (*CountWorkflowExecutionsRequest) ProtoMessage 

func (*CountWorkflowExecutionsRequest) ProtoMessage()

func (*CountWorkflowExecutionsRequest) Reset 

func (m *CountWorkflowExecutionsRequest) Reset()

func (*CountWorkflowExecutionsRequest) Size 

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

func (*CountWorkflowExecutionsRequest) String 

func (this *CountWorkflowExecutionsRequest) String() string

func (*CountWorkflowExecutionsRequest) Unmarshal 

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

func (*CountWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *CountWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*CountWorkflowExecutionsRequest) XXX_Marshal 

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

func (*CountWorkflowExecutionsRequest) XXX_Merge 

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

func (*CountWorkflowExecutionsRequest) XXX_Size 

func (m *CountWorkflowExecutionsRequest) XXX_Size() int

func (*CountWorkflowExecutionsRequest) XXX_Unmarshal 

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

type CountWorkflowExecutionsResponse 

type CountWorkflowExecutionsResponse struct {
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
}

func (*CountWorkflowExecutionsResponse) Descriptor 

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

func (*CountWorkflowExecutionsResponse) Equal 

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

func (*CountWorkflowExecutionsResponse) GetCount 

func (m *CountWorkflowExecutionsResponse) GetCount() int64

func (*CountWorkflowExecutionsResponse) GoString 

func (this *CountWorkflowExecutionsResponse) GoString() string

func (*CountWorkflowExecutionsResponse) Marshal 

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

func (*CountWorkflowExecutionsResponse) MarshalTo 

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

func (*CountWorkflowExecutionsResponse) MarshalToSizedBuffer 

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

func (*CountWorkflowExecutionsResponse) ProtoMessage 

func (*CountWorkflowExecutionsResponse) ProtoMessage()

func (*CountWorkflowExecutionsResponse) Reset 

func (m *CountWorkflowExecutionsResponse) Reset()

func (*CountWorkflowExecutionsResponse) Size 

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

func (*CountWorkflowExecutionsResponse) String 

func (this *CountWorkflowExecutionsResponse) String() string

func (*CountWorkflowExecutionsResponse) Unmarshal 

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

func (*CountWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *CountWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*CountWorkflowExecutionsResponse) XXX_Marshal 

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

func (*CountWorkflowExecutionsResponse) XXX_Merge 

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

func (*CountWorkflowExecutionsResponse) XXX_Size 

func (m *CountWorkflowExecutionsResponse) XXX_Size() int

func (*CountWorkflowExecutionsResponse) XXX_Unmarshal 

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

type DeprecateNamespaceRequest 

type DeprecateNamespaceRequest struct {
	Name          string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	SecurityToken string `protobuf:"bytes,2,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
}

func (*DeprecateNamespaceRequest) Descriptor 

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

func (*DeprecateNamespaceRequest) Equal 

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

func (*DeprecateNamespaceRequest) GetName 

func (m *DeprecateNamespaceRequest) GetName() string

func (*DeprecateNamespaceRequest) GetSecurityToken 

func (m *DeprecateNamespaceRequest) GetSecurityToken() string

func (*DeprecateNamespaceRequest) GoString 

func (this *DeprecateNamespaceRequest) GoString() string

func (*DeprecateNamespaceRequest) Marshal 

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

func (*DeprecateNamespaceRequest) MarshalTo 

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

func (*DeprecateNamespaceRequest) MarshalToSizedBuffer 

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

func (*DeprecateNamespaceRequest) ProtoMessage 

func (*DeprecateNamespaceRequest) ProtoMessage()

func (*DeprecateNamespaceRequest) Reset 

func (m *DeprecateNamespaceRequest) Reset()

func (*DeprecateNamespaceRequest) Size 

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

func (*DeprecateNamespaceRequest) String 

func (this *DeprecateNamespaceRequest) String() string

func (*DeprecateNamespaceRequest) Unmarshal 

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

func (*DeprecateNamespaceRequest) XXX_DiscardUnknown 

func (m *DeprecateNamespaceRequest) XXX_DiscardUnknown()

func (*DeprecateNamespaceRequest) XXX_Marshal 

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

func (*DeprecateNamespaceRequest) XXX_Merge 

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

func (*DeprecateNamespaceRequest) XXX_Size 

func (m *DeprecateNamespaceRequest) XXX_Size() int

func (*DeprecateNamespaceRequest) XXX_Unmarshal 

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

type DeprecateNamespaceResponse 

type DeprecateNamespaceResponse struct {
}

func (*DeprecateNamespaceResponse) Descriptor 

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

func (*DeprecateNamespaceResponse) Equal 

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

func (*DeprecateNamespaceResponse) GoString 

func (this *DeprecateNamespaceResponse) GoString() string

func (*DeprecateNamespaceResponse) Marshal 

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

func (*DeprecateNamespaceResponse) MarshalTo 

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

func (*DeprecateNamespaceResponse) MarshalToSizedBuffer 

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

func (*DeprecateNamespaceResponse) ProtoMessage 

func (*DeprecateNamespaceResponse) ProtoMessage()

func (*DeprecateNamespaceResponse) Reset 

func (m *DeprecateNamespaceResponse) Reset()

func (*DeprecateNamespaceResponse) Size 

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

func (*DeprecateNamespaceResponse) String 

func (this *DeprecateNamespaceResponse) String() string

func (*DeprecateNamespaceResponse) Unmarshal 

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

func (*DeprecateNamespaceResponse) XXX_DiscardUnknown 

func (m *DeprecateNamespaceResponse) XXX_DiscardUnknown()

func (*DeprecateNamespaceResponse) XXX_Marshal 

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

func (*DeprecateNamespaceResponse) XXX_Merge 

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

func (*DeprecateNamespaceResponse) XXX_Size 

func (m *DeprecateNamespaceResponse) XXX_Size() int

func (*DeprecateNamespaceResponse) XXX_Unmarshal 

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

type DescribeNamespaceRequest 

type DescribeNamespaceRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Id   string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}

func (*DescribeNamespaceRequest) Descriptor 

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

func (*DescribeNamespaceRequest) Equal 

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

func (*DescribeNamespaceRequest) GetId 

func (m *DescribeNamespaceRequest) GetId() string

func (*DescribeNamespaceRequest) GetName 

func (m *DescribeNamespaceRequest) GetName() string

func (*DescribeNamespaceRequest) GoString 

func (this *DescribeNamespaceRequest) GoString() string

func (*DescribeNamespaceRequest) Marshal 

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

func (*DescribeNamespaceRequest) MarshalTo 

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

func (*DescribeNamespaceRequest) MarshalToSizedBuffer 

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

func (*DescribeNamespaceRequest) ProtoMessage 

func (*DescribeNamespaceRequest) ProtoMessage()

func (*DescribeNamespaceRequest) Reset 

func (m *DescribeNamespaceRequest) Reset()

func (*DescribeNamespaceRequest) Size 

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

func (*DescribeNamespaceRequest) String 

func (this *DescribeNamespaceRequest) String() string

func (*DescribeNamespaceRequest) Unmarshal 

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

func (*DescribeNamespaceRequest) XXX_DiscardUnknown 

func (m *DescribeNamespaceRequest) XXX_DiscardUnknown()

func (*DescribeNamespaceRequest) XXX_Marshal 

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

func (*DescribeNamespaceRequest) XXX_Merge 

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

func (*DescribeNamespaceRequest) XXX_Size 

func (m *DescribeNamespaceRequest) XXX_Size() int

func (*DescribeNamespaceRequest) XXX_Unmarshal 

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

type DescribeNamespaceResponse 

type DescribeNamespaceResponse struct {
	NamespaceInfo     *v12.NamespaceInfo             `protobuf:"bytes,1,opt,name=namespace_info,json=namespaceInfo,proto3" json:"namespace_info,omitempty"`
	Config            *v12.NamespaceConfig           `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	ReplicationConfig *v1.NamespaceReplicationConfig `protobuf:"bytes,3,opt,name=replication_config,json=replicationConfig,proto3" json:"replication_config,omitempty"`
	FailoverVersion   int64                          `protobuf:"varint,4,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	IsGlobalNamespace bool                           `protobuf:"varint,5,opt,name=is_global_namespace,json=isGlobalNamespace,proto3" json:"is_global_namespace,omitempty"`
}

func (*DescribeNamespaceResponse) Descriptor 

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

func (*DescribeNamespaceResponse) Equal 

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

func (*DescribeNamespaceResponse) GetConfig 

func (m *DescribeNamespaceResponse) GetConfig() *v12.NamespaceConfig

func (*DescribeNamespaceResponse) GetFailoverVersion 

func (m *DescribeNamespaceResponse) GetFailoverVersion() int64

func (*DescribeNamespaceResponse) GetIsGlobalNamespace 

func (m *DescribeNamespaceResponse) GetIsGlobalNamespace() bool

func (*DescribeNamespaceResponse) GetNamespaceInfo 

func (m *DescribeNamespaceResponse) GetNamespaceInfo() *v12.NamespaceInfo

func (*DescribeNamespaceResponse) GetReplicationConfig 

func (m *DescribeNamespaceResponse) GetReplicationConfig() *v1.NamespaceReplicationConfig

func (*DescribeNamespaceResponse) GoString 

func (this *DescribeNamespaceResponse) GoString() string

func (*DescribeNamespaceResponse) Marshal 

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

func (*DescribeNamespaceResponse) MarshalTo 

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

func (*DescribeNamespaceResponse) MarshalToSizedBuffer 

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

func (*DescribeNamespaceResponse) ProtoMessage 

func (*DescribeNamespaceResponse) ProtoMessage()

func (*DescribeNamespaceResponse) Reset 

func (m *DescribeNamespaceResponse) Reset()

func (*DescribeNamespaceResponse) Size 

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

func (*DescribeNamespaceResponse) String 

func (this *DescribeNamespaceResponse) String() string

func (*DescribeNamespaceResponse) Unmarshal 

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

func (*DescribeNamespaceResponse) XXX_DiscardUnknown 

func (m *DescribeNamespaceResponse) XXX_DiscardUnknown()

func (*DescribeNamespaceResponse) XXX_Marshal 

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

func (*DescribeNamespaceResponse) XXX_Merge 

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

func (*DescribeNamespaceResponse) XXX_Size 

func (m *DescribeNamespaceResponse) XXX_Size() int

func (*DescribeNamespaceResponse) XXX_Unmarshal 

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

type DescribeTaskQueueRequest 

type DescribeTaskQueueRequest struct {
	Namespace              string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueue              *v14.TaskQueue    `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	TaskQueueType          v11.TaskQueueType `` /* 144-byte string literal not displayed */
	IncludeTaskQueueStatus bool              `` /* 132-byte string literal not displayed */
}

func (*DescribeTaskQueueRequest) Descriptor 

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

func (*DescribeTaskQueueRequest) Equal 

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

func (*DescribeTaskQueueRequest) GetIncludeTaskQueueStatus 

func (m *DescribeTaskQueueRequest) GetIncludeTaskQueueStatus() bool

func (*DescribeTaskQueueRequest) GetNamespace 

func (m *DescribeTaskQueueRequest) GetNamespace() string

func (*DescribeTaskQueueRequest) GetTaskQueue 

func (m *DescribeTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

func (*DescribeTaskQueueRequest) GetTaskQueueType 

func (m *DescribeTaskQueueRequest) GetTaskQueueType() v11.TaskQueueType

func (*DescribeTaskQueueRequest) GoString 

func (this *DescribeTaskQueueRequest) GoString() string

func (*DescribeTaskQueueRequest) Marshal 

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

func (*DescribeTaskQueueRequest) MarshalTo 

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

func (*DescribeTaskQueueRequest) MarshalToSizedBuffer 

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

func (*DescribeTaskQueueRequest) ProtoMessage 

func (*DescribeTaskQueueRequest) ProtoMessage()

func (*DescribeTaskQueueRequest) Reset 

func (m *DescribeTaskQueueRequest) Reset()

func (*DescribeTaskQueueRequest) Size 

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

func (*DescribeTaskQueueRequest) String 

func (this *DescribeTaskQueueRequest) String() string

func (*DescribeTaskQueueRequest) Unmarshal 

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

func (*DescribeTaskQueueRequest) XXX_DiscardUnknown 

func (m *DescribeTaskQueueRequest) XXX_DiscardUnknown()

func (*DescribeTaskQueueRequest) XXX_Marshal 

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

func (*DescribeTaskQueueRequest) XXX_Merge 

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

func (*DescribeTaskQueueRequest) XXX_Size 

func (m *DescribeTaskQueueRequest) XXX_Size() int

func (*DescribeTaskQueueRequest) XXX_Unmarshal 

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

type DescribeTaskQueueResponse 

type DescribeTaskQueueResponse struct {
	Pollers         []*v14.PollerInfo    `protobuf:"bytes,1,rep,name=pollers,proto3" json:"pollers,omitempty"`
	TaskQueueStatus *v14.TaskQueueStatus `protobuf:"bytes,2,opt,name=task_queue_status,json=taskQueueStatus,proto3" json:"task_queue_status,omitempty"`
}

func (*DescribeTaskQueueResponse) Descriptor 

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

func (*DescribeTaskQueueResponse) Equal 

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

func (*DescribeTaskQueueResponse) GetPollers 

func (m *DescribeTaskQueueResponse) GetPollers() []*v14.PollerInfo

func (*DescribeTaskQueueResponse) GetTaskQueueStatus 

func (m *DescribeTaskQueueResponse) GetTaskQueueStatus() *v14.TaskQueueStatus

func (*DescribeTaskQueueResponse) GoString 

func (this *DescribeTaskQueueResponse) GoString() string

func (*DescribeTaskQueueResponse) Marshal 

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

func (*DescribeTaskQueueResponse) MarshalTo 

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

func (*DescribeTaskQueueResponse) MarshalToSizedBuffer 

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

func (*DescribeTaskQueueResponse) ProtoMessage 

func (*DescribeTaskQueueResponse) ProtoMessage()

func (*DescribeTaskQueueResponse) Reset 

func (m *DescribeTaskQueueResponse) Reset()

func (*DescribeTaskQueueResponse) Size 

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

func (*DescribeTaskQueueResponse) String 

func (this *DescribeTaskQueueResponse) String() string

func (*DescribeTaskQueueResponse) Unmarshal 

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

func (*DescribeTaskQueueResponse) XXX_DiscardUnknown 

func (m *DescribeTaskQueueResponse) XXX_DiscardUnknown()

func (*DescribeTaskQueueResponse) XXX_Marshal 

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

func (*DescribeTaskQueueResponse) XXX_Merge 

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

func (*DescribeTaskQueueResponse) XXX_Size 

func (m *DescribeTaskQueueResponse) XXX_Size() int

func (*DescribeTaskQueueResponse) XXX_Unmarshal 

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

type DescribeWorkflowExecutionRequest 

type DescribeWorkflowExecutionRequest struct {
	Namespace string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Execution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*DescribeWorkflowExecutionRequest) Descriptor 

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

func (*DescribeWorkflowExecutionRequest) Equal 

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

func (*DescribeWorkflowExecutionRequest) GetExecution 

func (m *DescribeWorkflowExecutionRequest) GetExecution() *v13.WorkflowExecution

func (*DescribeWorkflowExecutionRequest) GetNamespace 

func (m *DescribeWorkflowExecutionRequest) GetNamespace() string

func (*DescribeWorkflowExecutionRequest) GoString 

func (this *DescribeWorkflowExecutionRequest) GoString() string

func (*DescribeWorkflowExecutionRequest) Marshal 

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

func (*DescribeWorkflowExecutionRequest) MarshalTo 

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

func (*DescribeWorkflowExecutionRequest) MarshalToSizedBuffer 

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

func (*DescribeWorkflowExecutionRequest) ProtoMessage 

func (*DescribeWorkflowExecutionRequest) ProtoMessage()

func (*DescribeWorkflowExecutionRequest) Reset 

func (m *DescribeWorkflowExecutionRequest) Reset()

func (*DescribeWorkflowExecutionRequest) Size 

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

func (*DescribeWorkflowExecutionRequest) String 

func (this *DescribeWorkflowExecutionRequest) String() string

func (*DescribeWorkflowExecutionRequest) Unmarshal 

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

func (*DescribeWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *DescribeWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*DescribeWorkflowExecutionRequest) XXX_Marshal 

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

func (*DescribeWorkflowExecutionRequest) XXX_Merge 

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

func (*DescribeWorkflowExecutionRequest) XXX_Size 

func (m *DescribeWorkflowExecutionRequest) XXX_Size() int

func (*DescribeWorkflowExecutionRequest) XXX_Unmarshal 

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

type DescribeWorkflowExecutionResponse 

type DescribeWorkflowExecutionResponse struct {
	ExecutionConfig       *v110.WorkflowExecutionConfig     `protobuf:"bytes,1,opt,name=execution_config,json=executionConfig,proto3" json:"execution_config,omitempty"`
	WorkflowExecutionInfo *v110.WorkflowExecutionInfo       `` /* 126-byte string literal not displayed */
	PendingActivities     []*v110.PendingActivityInfo       `protobuf:"bytes,3,rep,name=pending_activities,json=pendingActivities,proto3" json:"pending_activities,omitempty"`
	PendingChildren       []*v110.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() *v110.WorkflowExecutionConfig

func (*DescribeWorkflowExecutionResponse) GetPendingActivities 

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

func (*DescribeWorkflowExecutionResponse) GetPendingChildren 

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

func (*DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo 

func (m *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *v110.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 GetClusterInfoRequest 

type GetClusterInfoRequest struct {
}

func (*GetClusterInfoRequest) Descriptor 

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

func (*GetClusterInfoRequest) Equal 

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

func (*GetClusterInfoRequest) GoString 

func (this *GetClusterInfoRequest) GoString() string

func (*GetClusterInfoRequest) Marshal 

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

func (*GetClusterInfoRequest) MarshalTo 

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

func (*GetClusterInfoRequest) MarshalToSizedBuffer 

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

func (*GetClusterInfoRequest) ProtoMessage 

func (*GetClusterInfoRequest) ProtoMessage()

func (*GetClusterInfoRequest) Reset 

func (m *GetClusterInfoRequest) Reset()

func (*GetClusterInfoRequest) Size 

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

func (*GetClusterInfoRequest) String 

func (this *GetClusterInfoRequest) String() string

func (*GetClusterInfoRequest) Unmarshal 

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

func (*GetClusterInfoRequest) XXX_DiscardUnknown 

func (m *GetClusterInfoRequest) XXX_DiscardUnknown()

func (*GetClusterInfoRequest) XXX_Marshal 

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

func (*GetClusterInfoRequest) XXX_Merge 

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

func (*GetClusterInfoRequest) XXX_Size 

func (m *GetClusterInfoRequest) XXX_Size() int

func (*GetClusterInfoRequest) XXX_Unmarshal 

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

type GetClusterInfoResponse 

type GetClusterInfoResponse struct {
	SupportedSdkVersions *v111.SupportedSDKVersions `protobuf:"bytes,1,opt,name=supported_sdk_versions,json=supportedSdkVersions,proto3" json:"supported_sdk_versions,omitempty"`
}

GetClusterInfoResponse contains information about Temporal cluster

func (*GetClusterInfoResponse) Descriptor 

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

func (*GetClusterInfoResponse) Equal 

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

func (*GetClusterInfoResponse) GetSupportedSdkVersions 

func (m *GetClusterInfoResponse) GetSupportedSdkVersions() *v111.SupportedSDKVersions

func (*GetClusterInfoResponse) GoString 

func (this *GetClusterInfoResponse) GoString() string

func (*GetClusterInfoResponse) Marshal 

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

func (*GetClusterInfoResponse) MarshalTo 

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

func (*GetClusterInfoResponse) MarshalToSizedBuffer 

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

func (*GetClusterInfoResponse) ProtoMessage 

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) Reset 

func (m *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) Size 

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

func (*GetClusterInfoResponse) String 

func (this *GetClusterInfoResponse) String() string

func (*GetClusterInfoResponse) Unmarshal 

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

func (*GetClusterInfoResponse) XXX_DiscardUnknown 

func (m *GetClusterInfoResponse) XXX_DiscardUnknown()

func (*GetClusterInfoResponse) XXX_Marshal 

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

func (*GetClusterInfoResponse) XXX_Merge 

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

func (*GetClusterInfoResponse) XXX_Size 

func (m *GetClusterInfoResponse) XXX_Size() int

func (*GetClusterInfoResponse) XXX_Unmarshal 

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

type GetSearchAttributesRequest 

type GetSearchAttributesRequest struct {
}

func (*GetSearchAttributesRequest) Descriptor 

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

func (*GetSearchAttributesRequest) Equal 

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

func (*GetSearchAttributesRequest) GoString 

func (this *GetSearchAttributesRequest) GoString() string

func (*GetSearchAttributesRequest) Marshal 

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

func (*GetSearchAttributesRequest) MarshalTo 

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

func (*GetSearchAttributesRequest) MarshalToSizedBuffer 

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

func (*GetSearchAttributesRequest) ProtoMessage 

func (*GetSearchAttributesRequest) ProtoMessage()

func (*GetSearchAttributesRequest) Reset 

func (m *GetSearchAttributesRequest) Reset()

func (*GetSearchAttributesRequest) Size 

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

func (*GetSearchAttributesRequest) String 

func (this *GetSearchAttributesRequest) String() string

func (*GetSearchAttributesRequest) Unmarshal 

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

func (*GetSearchAttributesRequest) XXX_DiscardUnknown 

func (m *GetSearchAttributesRequest) XXX_DiscardUnknown()

func (*GetSearchAttributesRequest) XXX_Marshal 

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

func (*GetSearchAttributesRequest) XXX_Merge 

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

func (*GetSearchAttributesRequest) XXX_Size 

func (m *GetSearchAttributesRequest) XXX_Size() int

func (*GetSearchAttributesRequest) XXX_Unmarshal 

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

type GetSearchAttributesResponse 

type GetSearchAttributesResponse struct {
	Keys map[string]v11.IndexedValueType `` /* 194-byte string literal not displayed */
}

func (*GetSearchAttributesResponse) Descriptor 

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

func (*GetSearchAttributesResponse) Equal 

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

func (*GetSearchAttributesResponse) GetKeys 

func (m *GetSearchAttributesResponse) GetKeys() map[string]v11.IndexedValueType

func (*GetSearchAttributesResponse) GoString 

func (this *GetSearchAttributesResponse) GoString() string

func (*GetSearchAttributesResponse) Marshal 

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

func (*GetSearchAttributesResponse) MarshalTo 

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

func (*GetSearchAttributesResponse) MarshalToSizedBuffer 

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

func (*GetSearchAttributesResponse) ProtoMessage 

func (*GetSearchAttributesResponse) ProtoMessage()

func (*GetSearchAttributesResponse) Reset 

func (m *GetSearchAttributesResponse) Reset()

func (*GetSearchAttributesResponse) Size 

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

func (*GetSearchAttributesResponse) String 

func (this *GetSearchAttributesResponse) String() string

func (*GetSearchAttributesResponse) Unmarshal 

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

func (*GetSearchAttributesResponse) XXX_DiscardUnknown 

func (m *GetSearchAttributesResponse) XXX_DiscardUnknown()

func (*GetSearchAttributesResponse) XXX_Marshal 

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

func (*GetSearchAttributesResponse) XXX_Merge 

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

func (*GetSearchAttributesResponse) XXX_Size 

func (m *GetSearchAttributesResponse) XXX_Size() int

func (*GetSearchAttributesResponse) XXX_Unmarshal 

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

type GetWorkflowExecutionHistoryRequest 

type GetWorkflowExecutionHistoryRequest struct {
	Namespace       string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Execution       *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	MaximumPageSize int32                  `protobuf:"varint,3,opt,name=maximum_page_size,json=maximumPageSize,proto3" json:"maximum_page_size,omitempty"`
	NextPageToken   []byte                 `protobuf:"bytes,4,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	WaitNewEvent    bool                   `protobuf:"varint,5,opt,name=wait_new_event,json=waitNewEvent,proto3" json:"wait_new_event,omitempty"`
	// Default: HISTORY_EVENT_FILTER_TYPE_ALL_EVENT.
	HistoryEventFilterType v11.HistoryEventFilterType `` /* 182-byte string literal not displayed */
	SkipArchival           bool                       `protobuf:"varint,7,opt,name=skip_archival,json=skipArchival,proto3" json:"skip_archival,omitempty"`
}

func (*GetWorkflowExecutionHistoryRequest) Descriptor 

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

func (*GetWorkflowExecutionHistoryRequest) Equal 

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

func (*GetWorkflowExecutionHistoryRequest) GetExecution 

func (m *GetWorkflowExecutionHistoryRequest) GetExecution() *v13.WorkflowExecution

func (*GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType 

func (m *GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType() v11.HistoryEventFilterType

func (*GetWorkflowExecutionHistoryRequest) GetMaximumPageSize 

func (m *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() int32

func (*GetWorkflowExecutionHistoryRequest) GetNamespace 

func (m *GetWorkflowExecutionHistoryRequest) GetNamespace() string

func (*GetWorkflowExecutionHistoryRequest) GetNextPageToken 

func (m *GetWorkflowExecutionHistoryRequest) GetNextPageToken() []byte

func (*GetWorkflowExecutionHistoryRequest) GetSkipArchival 

func (m *GetWorkflowExecutionHistoryRequest) GetSkipArchival() bool

func (*GetWorkflowExecutionHistoryRequest) GetWaitNewEvent 

func (m *GetWorkflowExecutionHistoryRequest) GetWaitNewEvent() bool

func (*GetWorkflowExecutionHistoryRequest) GoString 

func (this *GetWorkflowExecutionHistoryRequest) GoString() string

func (*GetWorkflowExecutionHistoryRequest) Marshal 

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

func (*GetWorkflowExecutionHistoryRequest) MarshalTo 

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

func (*GetWorkflowExecutionHistoryRequest) MarshalToSizedBuffer 

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

func (*GetWorkflowExecutionHistoryRequest) ProtoMessage 

func (*GetWorkflowExecutionHistoryRequest) ProtoMessage()

func (*GetWorkflowExecutionHistoryRequest) Reset 

func (m *GetWorkflowExecutionHistoryRequest) Reset()

func (*GetWorkflowExecutionHistoryRequest) Size 

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

func (*GetWorkflowExecutionHistoryRequest) String 

func (this *GetWorkflowExecutionHistoryRequest) String() string

func (*GetWorkflowExecutionHistoryRequest) Unmarshal 

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

func (*GetWorkflowExecutionHistoryRequest) XXX_DiscardUnknown 

func (m *GetWorkflowExecutionHistoryRequest) XXX_DiscardUnknown()

func (*GetWorkflowExecutionHistoryRequest) XXX_Marshal 

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

func (*GetWorkflowExecutionHistoryRequest) XXX_Merge 

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

func (*GetWorkflowExecutionHistoryRequest) XXX_Size 

func (m *GetWorkflowExecutionHistoryRequest) XXX_Size() int

func (*GetWorkflowExecutionHistoryRequest) XXX_Unmarshal 

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

type GetWorkflowExecutionHistoryResponse 

type GetWorkflowExecutionHistoryResponse struct {
	History       *v15.History    `protobuf:"bytes,1,opt,name=history,proto3" json:"history,omitempty"`
	RawHistory    []*v13.DataBlob `protobuf:"bytes,2,rep,name=raw_history,json=rawHistory,proto3" json:"raw_history,omitempty"`
	NextPageToken []byte          `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Archived      bool            `protobuf:"varint,4,opt,name=archived,proto3" json:"archived,omitempty"`
}

func (*GetWorkflowExecutionHistoryResponse) Descriptor 

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

func (*GetWorkflowExecutionHistoryResponse) Equal 

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

func (*GetWorkflowExecutionHistoryResponse) GetArchived 

func (m *GetWorkflowExecutionHistoryResponse) GetArchived() bool

func (*GetWorkflowExecutionHistoryResponse) GetHistory 

func (m *GetWorkflowExecutionHistoryResponse) GetHistory() *v15.History

func (*GetWorkflowExecutionHistoryResponse) GetNextPageToken 

func (m *GetWorkflowExecutionHistoryResponse) GetNextPageToken() []byte

func (*GetWorkflowExecutionHistoryResponse) GetRawHistory 

func (m *GetWorkflowExecutionHistoryResponse) GetRawHistory() []*v13.DataBlob

func (*GetWorkflowExecutionHistoryResponse) GoString 

func (this *GetWorkflowExecutionHistoryResponse) GoString() string

func (*GetWorkflowExecutionHistoryResponse) Marshal 

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

func (*GetWorkflowExecutionHistoryResponse) MarshalTo 

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

func (*GetWorkflowExecutionHistoryResponse) MarshalToSizedBuffer 

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

func (*GetWorkflowExecutionHistoryResponse) ProtoMessage 

func (*GetWorkflowExecutionHistoryResponse) ProtoMessage()

func (*GetWorkflowExecutionHistoryResponse) Reset 

func (m *GetWorkflowExecutionHistoryResponse) Reset()

func (*GetWorkflowExecutionHistoryResponse) Size 

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

func (*GetWorkflowExecutionHistoryResponse) String 

func (this *GetWorkflowExecutionHistoryResponse) String() string

func (*GetWorkflowExecutionHistoryResponse) Unmarshal 

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

func (*GetWorkflowExecutionHistoryResponse) XXX_DiscardUnknown 

func (m *GetWorkflowExecutionHistoryResponse) XXX_DiscardUnknown()

func (*GetWorkflowExecutionHistoryResponse) XXX_Marshal 

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

func (*GetWorkflowExecutionHistoryResponse) XXX_Merge 

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

func (*GetWorkflowExecutionHistoryResponse) XXX_Size 

func (m *GetWorkflowExecutionHistoryResponse) XXX_Size() int

func (*GetWorkflowExecutionHistoryResponse) XXX_Unmarshal 

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

type ListArchivedWorkflowExecutionsRequest 

type ListArchivedWorkflowExecutionsRequest struct {
	Namespace     string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PageSize      int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Query         string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
}

func (*ListArchivedWorkflowExecutionsRequest) Descriptor 

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

func (*ListArchivedWorkflowExecutionsRequest) Equal 

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

func (*ListArchivedWorkflowExecutionsRequest) GetNamespace 

func (m *ListArchivedWorkflowExecutionsRequest) GetNamespace() string

func (*ListArchivedWorkflowExecutionsRequest) GetNextPageToken 

func (m *ListArchivedWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ListArchivedWorkflowExecutionsRequest) GetPageSize 

func (m *ListArchivedWorkflowExecutionsRequest) GetPageSize() int32

func (*ListArchivedWorkflowExecutionsRequest) GetQuery 

func (m *ListArchivedWorkflowExecutionsRequest) GetQuery() string

func (*ListArchivedWorkflowExecutionsRequest) GoString 

func (this *ListArchivedWorkflowExecutionsRequest) GoString() string

func (*ListArchivedWorkflowExecutionsRequest) Marshal 

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

func (*ListArchivedWorkflowExecutionsRequest) MarshalTo 

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

func (*ListArchivedWorkflowExecutionsRequest) MarshalToSizedBuffer 

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

func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage 

func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage()

func (*ListArchivedWorkflowExecutionsRequest) Reset 

func (m *ListArchivedWorkflowExecutionsRequest) Reset()

func (*ListArchivedWorkflowExecutionsRequest) Size 

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

func (*ListArchivedWorkflowExecutionsRequest) String 

func (this *ListArchivedWorkflowExecutionsRequest) String() string

func (*ListArchivedWorkflowExecutionsRequest) Unmarshal 

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

func (*ListArchivedWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ListArchivedWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListArchivedWorkflowExecutionsRequest) XXX_Marshal 

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

func (*ListArchivedWorkflowExecutionsRequest) XXX_Merge 

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

func (*ListArchivedWorkflowExecutionsRequest) XXX_Size 

func (m *ListArchivedWorkflowExecutionsRequest) XXX_Size() int

func (*ListArchivedWorkflowExecutionsRequest) XXX_Unmarshal 

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

type ListArchivedWorkflowExecutionsResponse 

type ListArchivedWorkflowExecutionsResponse struct {
	Executions    []*v110.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListArchivedWorkflowExecutionsResponse) Descriptor 

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

func (*ListArchivedWorkflowExecutionsResponse) Equal 

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

func (*ListArchivedWorkflowExecutionsResponse) GetExecutions 

func (m *ListArchivedWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

func (*ListArchivedWorkflowExecutionsResponse) GetNextPageToken 

func (m *ListArchivedWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ListArchivedWorkflowExecutionsResponse) GoString 

func (this *ListArchivedWorkflowExecutionsResponse) GoString() string

func (*ListArchivedWorkflowExecutionsResponse) Marshal 

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

func (*ListArchivedWorkflowExecutionsResponse) MarshalTo 

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

func (*ListArchivedWorkflowExecutionsResponse) MarshalToSizedBuffer 

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

func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage 

func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage()

func (*ListArchivedWorkflowExecutionsResponse) Reset 

func (m *ListArchivedWorkflowExecutionsResponse) Reset()

func (*ListArchivedWorkflowExecutionsResponse) Size 

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

func (*ListArchivedWorkflowExecutionsResponse) String 

func (this *ListArchivedWorkflowExecutionsResponse) String() string

func (*ListArchivedWorkflowExecutionsResponse) Unmarshal 

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

func (*ListArchivedWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ListArchivedWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListArchivedWorkflowExecutionsResponse) XXX_Marshal 

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

func (*ListArchivedWorkflowExecutionsResponse) XXX_Merge 

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

func (*ListArchivedWorkflowExecutionsResponse) XXX_Size 

func (m *ListArchivedWorkflowExecutionsResponse) XXX_Size() int

func (*ListArchivedWorkflowExecutionsResponse) XXX_Unmarshal 

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

type ListClosedWorkflowExecutionsRequest 

type ListClosedWorkflowExecutionsRequest struct {
	Namespace       string               `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	MaximumPageSize int32                `protobuf:"varint,2,opt,name=maximum_page_size,json=maximumPageSize,proto3" json:"maximum_page_size,omitempty"`
	NextPageToken   []byte               `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	StartTimeFilter *v19.StartTimeFilter `protobuf:"bytes,4,opt,name=start_time_filter,json=startTimeFilter,proto3" json:"start_time_filter,omitempty"`
	// Types that are valid to be assigned to Filters:
	//	*ListClosedWorkflowExecutionsRequest_ExecutionFilter
	//	*ListClosedWorkflowExecutionsRequest_TypeFilter
	//	*ListClosedWorkflowExecutionsRequest_StatusFilter
	Filters isListClosedWorkflowExecutionsRequest_Filters `protobuf_oneof:"filters"`
}

func (*ListClosedWorkflowExecutionsRequest) Descriptor 

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

func (*ListClosedWorkflowExecutionsRequest) Equal 

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

func (*ListClosedWorkflowExecutionsRequest) GetExecutionFilter 

func (m *ListClosedWorkflowExecutionsRequest) GetExecutionFilter() *v19.WorkflowExecutionFilter

func (*ListClosedWorkflowExecutionsRequest) GetFilters 

func (m *ListClosedWorkflowExecutionsRequest) GetFilters() isListClosedWorkflowExecutionsRequest_Filters

func (*ListClosedWorkflowExecutionsRequest) GetMaximumPageSize 

func (m *ListClosedWorkflowExecutionsRequest) GetMaximumPageSize() int32

func (*ListClosedWorkflowExecutionsRequest) GetNamespace 

func (m *ListClosedWorkflowExecutionsRequest) GetNamespace() string

func (*ListClosedWorkflowExecutionsRequest) GetNextPageToken 

func (m *ListClosedWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ListClosedWorkflowExecutionsRequest) GetStartTimeFilter 

func (m *ListClosedWorkflowExecutionsRequest) GetStartTimeFilter() *v19.StartTimeFilter

func (*ListClosedWorkflowExecutionsRequest) GetStatusFilter 

func (m *ListClosedWorkflowExecutionsRequest) GetStatusFilter() *v19.StatusFilter

func (*ListClosedWorkflowExecutionsRequest) GetTypeFilter 

func (m *ListClosedWorkflowExecutionsRequest) GetTypeFilter() *v19.WorkflowTypeFilter

func (*ListClosedWorkflowExecutionsRequest) GoString 

func (this *ListClosedWorkflowExecutionsRequest) GoString() string

func (*ListClosedWorkflowExecutionsRequest) Marshal 

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

func (*ListClosedWorkflowExecutionsRequest) MarshalTo 

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

func (*ListClosedWorkflowExecutionsRequest) MarshalToSizedBuffer 

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

func (*ListClosedWorkflowExecutionsRequest) ProtoMessage 

func (*ListClosedWorkflowExecutionsRequest) ProtoMessage()

func (*ListClosedWorkflowExecutionsRequest) Reset 

func (m *ListClosedWorkflowExecutionsRequest) Reset()

func (*ListClosedWorkflowExecutionsRequest) Size 

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

func (*ListClosedWorkflowExecutionsRequest) String 

func (this *ListClosedWorkflowExecutionsRequest) String() string

func (*ListClosedWorkflowExecutionsRequest) Unmarshal 

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

func (*ListClosedWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ListClosedWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListClosedWorkflowExecutionsRequest) XXX_Marshal 

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

func (*ListClosedWorkflowExecutionsRequest) XXX_Merge 

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

func (*ListClosedWorkflowExecutionsRequest) XXX_OneofWrappers 

func (*ListClosedWorkflowExecutionsRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ListClosedWorkflowExecutionsRequest) XXX_Size 

func (m *ListClosedWorkflowExecutionsRequest) XXX_Size() int

func (*ListClosedWorkflowExecutionsRequest) XXX_Unmarshal 

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

type ListClosedWorkflowExecutionsRequest_ExecutionFilter 

type ListClosedWorkflowExecutionsRequest_ExecutionFilter struct {
	ExecutionFilter *v19.WorkflowExecutionFilter `protobuf:"bytes,5,opt,name=execution_filter,json=executionFilter,proto3,oneof" json:"execution_filter,omitempty"`
}

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) Equal 

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

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) GoString 

func (this *ListClosedWorkflowExecutionsRequest_ExecutionFilter) GoString() string

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) MarshalTo 

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

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) MarshalToSizedBuffer 

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

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) Size 

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

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) String 

func (this *ListClosedWorkflowExecutionsRequest_ExecutionFilter) String() string

type ListClosedWorkflowExecutionsRequest_StatusFilter 

type ListClosedWorkflowExecutionsRequest_StatusFilter struct {
	StatusFilter *v19.StatusFilter `protobuf:"bytes,7,opt,name=status_filter,json=statusFilter,proto3,oneof" json:"status_filter,omitempty"`
}

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) Equal 

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

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) GoString 

func (this *ListClosedWorkflowExecutionsRequest_StatusFilter) GoString() string

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) MarshalTo 

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

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) MarshalToSizedBuffer 

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

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) Size 

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

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) String 

func (this *ListClosedWorkflowExecutionsRequest_StatusFilter) String() string

type ListClosedWorkflowExecutionsRequest_TypeFilter 

type ListClosedWorkflowExecutionsRequest_TypeFilter struct {
	TypeFilter *v19.WorkflowTypeFilter `protobuf:"bytes,6,opt,name=type_filter,json=typeFilter,proto3,oneof" json:"type_filter,omitempty"`
}

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) Equal 

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

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) GoString 

func (this *ListClosedWorkflowExecutionsRequest_TypeFilter) GoString() string

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) MarshalTo 

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

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) MarshalToSizedBuffer 

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

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) Size 

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

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) String 

func (this *ListClosedWorkflowExecutionsRequest_TypeFilter) String() string

type ListClosedWorkflowExecutionsResponse 

type ListClosedWorkflowExecutionsResponse struct {
	Executions    []*v110.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListClosedWorkflowExecutionsResponse) Descriptor 

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

func (*ListClosedWorkflowExecutionsResponse) Equal 

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

func (*ListClosedWorkflowExecutionsResponse) GetExecutions 

func (m *ListClosedWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

func (*ListClosedWorkflowExecutionsResponse) GetNextPageToken 

func (m *ListClosedWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ListClosedWorkflowExecutionsResponse) GoString 

func (this *ListClosedWorkflowExecutionsResponse) GoString() string

func (*ListClosedWorkflowExecutionsResponse) Marshal 

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

func (*ListClosedWorkflowExecutionsResponse) MarshalTo 

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

func (*ListClosedWorkflowExecutionsResponse) MarshalToSizedBuffer 

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

func (*ListClosedWorkflowExecutionsResponse) ProtoMessage 

func (*ListClosedWorkflowExecutionsResponse) ProtoMessage()

func (*ListClosedWorkflowExecutionsResponse) Reset 

func (m *ListClosedWorkflowExecutionsResponse) Reset()

func (*ListClosedWorkflowExecutionsResponse) Size 

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

func (*ListClosedWorkflowExecutionsResponse) String 

func (this *ListClosedWorkflowExecutionsResponse) String() string

func (*ListClosedWorkflowExecutionsResponse) Unmarshal 

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

func (*ListClosedWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ListClosedWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListClosedWorkflowExecutionsResponse) XXX_Marshal 

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

func (*ListClosedWorkflowExecutionsResponse) XXX_Merge 

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

func (*ListClosedWorkflowExecutionsResponse) XXX_Size 

func (m *ListClosedWorkflowExecutionsResponse) XXX_Size() int

func (*ListClosedWorkflowExecutionsResponse) XXX_Unmarshal 

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

type ListNamespacesRequest 

type ListNamespacesRequest struct {
	PageSize      int32  `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListNamespacesRequest) Descriptor 

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

func (*ListNamespacesRequest) Equal 

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

func (*ListNamespacesRequest) GetNextPageToken 

func (m *ListNamespacesRequest) GetNextPageToken() []byte

func (*ListNamespacesRequest) GetPageSize 

func (m *ListNamespacesRequest) GetPageSize() int32

func (*ListNamespacesRequest) GoString 

func (this *ListNamespacesRequest) GoString() string

func (*ListNamespacesRequest) Marshal 

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

func (*ListNamespacesRequest) MarshalTo 

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

func (*ListNamespacesRequest) MarshalToSizedBuffer 

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

func (*ListNamespacesRequest) ProtoMessage 

func (*ListNamespacesRequest) ProtoMessage()

func (*ListNamespacesRequest) Reset 

func (m *ListNamespacesRequest) Reset()

func (*ListNamespacesRequest) Size 

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

func (*ListNamespacesRequest) String 

func (this *ListNamespacesRequest) String() string

func (*ListNamespacesRequest) Unmarshal 

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

func (*ListNamespacesRequest) XXX_DiscardUnknown 

func (m *ListNamespacesRequest) XXX_DiscardUnknown()

func (*ListNamespacesRequest) XXX_Marshal 

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

func (*ListNamespacesRequest) XXX_Merge 

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

func (*ListNamespacesRequest) XXX_Size 

func (m *ListNamespacesRequest) XXX_Size() int

func (*ListNamespacesRequest) XXX_Unmarshal 

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

type ListNamespacesResponse 

type ListNamespacesResponse struct {
	Namespaces    []*DescribeNamespaceResponse `protobuf:"bytes,1,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	NextPageToken []byte                       `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListNamespacesResponse) Descriptor 

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

func (*ListNamespacesResponse) Equal 

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

func (*ListNamespacesResponse) GetNamespaces 

func (m *ListNamespacesResponse) GetNamespaces() []*DescribeNamespaceResponse

func (*ListNamespacesResponse) GetNextPageToken 

func (m *ListNamespacesResponse) GetNextPageToken() []byte

func (*ListNamespacesResponse) GoString 

func (this *ListNamespacesResponse) GoString() string

func (*ListNamespacesResponse) Marshal 

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

func (*ListNamespacesResponse) MarshalTo 

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

func (*ListNamespacesResponse) MarshalToSizedBuffer 

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

func (*ListNamespacesResponse) ProtoMessage 

func (*ListNamespacesResponse) ProtoMessage()

func (*ListNamespacesResponse) Reset 

func (m *ListNamespacesResponse) Reset()

func (*ListNamespacesResponse) Size 

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

func (*ListNamespacesResponse) String 

func (this *ListNamespacesResponse) String() string

func (*ListNamespacesResponse) Unmarshal 

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

func (*ListNamespacesResponse) XXX_DiscardUnknown 

func (m *ListNamespacesResponse) XXX_DiscardUnknown()

func (*ListNamespacesResponse) XXX_Marshal 

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

func (*ListNamespacesResponse) XXX_Merge 

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

func (*ListNamespacesResponse) XXX_Size 

func (m *ListNamespacesResponse) XXX_Size() int

func (*ListNamespacesResponse) XXX_Unmarshal 

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

type ListOpenWorkflowExecutionsRequest 

type ListOpenWorkflowExecutionsRequest struct {
	Namespace       string               `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	MaximumPageSize int32                `protobuf:"varint,2,opt,name=maximum_page_size,json=maximumPageSize,proto3" json:"maximum_page_size,omitempty"`
	NextPageToken   []byte               `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	StartTimeFilter *v19.StartTimeFilter `protobuf:"bytes,4,opt,name=start_time_filter,json=startTimeFilter,proto3" json:"start_time_filter,omitempty"`
	// Types that are valid to be assigned to Filters:
	//	*ListOpenWorkflowExecutionsRequest_ExecutionFilter
	//	*ListOpenWorkflowExecutionsRequest_TypeFilter
	Filters isListOpenWorkflowExecutionsRequest_Filters `protobuf_oneof:"filters"`
}

func (*ListOpenWorkflowExecutionsRequest) Descriptor 

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

func (*ListOpenWorkflowExecutionsRequest) Equal 

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

func (*ListOpenWorkflowExecutionsRequest) GetExecutionFilter 

func (m *ListOpenWorkflowExecutionsRequest) GetExecutionFilter() *v19.WorkflowExecutionFilter

func (*ListOpenWorkflowExecutionsRequest) GetFilters 

func (m *ListOpenWorkflowExecutionsRequest) GetFilters() isListOpenWorkflowExecutionsRequest_Filters

func (*ListOpenWorkflowExecutionsRequest) GetMaximumPageSize 

func (m *ListOpenWorkflowExecutionsRequest) GetMaximumPageSize() int32

func (*ListOpenWorkflowExecutionsRequest) GetNamespace 

func (m *ListOpenWorkflowExecutionsRequest) GetNamespace() string

func (*ListOpenWorkflowExecutionsRequest) GetNextPageToken 

func (m *ListOpenWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ListOpenWorkflowExecutionsRequest) GetStartTimeFilter 

func (m *ListOpenWorkflowExecutionsRequest) GetStartTimeFilter() *v19.StartTimeFilter

func (*ListOpenWorkflowExecutionsRequest) GetTypeFilter 

func (m *ListOpenWorkflowExecutionsRequest) GetTypeFilter() *v19.WorkflowTypeFilter

func (*ListOpenWorkflowExecutionsRequest) GoString 

func (this *ListOpenWorkflowExecutionsRequest) GoString() string

func (*ListOpenWorkflowExecutionsRequest) Marshal 

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

func (*ListOpenWorkflowExecutionsRequest) MarshalTo 

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

func (*ListOpenWorkflowExecutionsRequest) MarshalToSizedBuffer 

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

func (*ListOpenWorkflowExecutionsRequest) ProtoMessage 

func (*ListOpenWorkflowExecutionsRequest) ProtoMessage()

func (*ListOpenWorkflowExecutionsRequest) Reset 

func (m *ListOpenWorkflowExecutionsRequest) Reset()

func (*ListOpenWorkflowExecutionsRequest) Size 

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

func (*ListOpenWorkflowExecutionsRequest) String 

func (this *ListOpenWorkflowExecutionsRequest) String() string

func (*ListOpenWorkflowExecutionsRequest) Unmarshal 

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

func (*ListOpenWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ListOpenWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListOpenWorkflowExecutionsRequest) XXX_Marshal 

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

func (*ListOpenWorkflowExecutionsRequest) XXX_Merge 

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

func (*ListOpenWorkflowExecutionsRequest) XXX_OneofWrappers 

func (*ListOpenWorkflowExecutionsRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ListOpenWorkflowExecutionsRequest) XXX_Size 

func (m *ListOpenWorkflowExecutionsRequest) XXX_Size() int

func (*ListOpenWorkflowExecutionsRequest) XXX_Unmarshal 

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

type ListOpenWorkflowExecutionsRequest_ExecutionFilter 

type ListOpenWorkflowExecutionsRequest_ExecutionFilter struct {
	ExecutionFilter *v19.WorkflowExecutionFilter `protobuf:"bytes,5,opt,name=execution_filter,json=executionFilter,proto3,oneof" json:"execution_filter,omitempty"`
}

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) Equal 

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

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) GoString 

func (this *ListOpenWorkflowExecutionsRequest_ExecutionFilter) GoString() string

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) MarshalTo 

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

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) MarshalToSizedBuffer 

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

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) Size 

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

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) String 

func (this *ListOpenWorkflowExecutionsRequest_ExecutionFilter) String() string

type ListOpenWorkflowExecutionsRequest_TypeFilter 

type ListOpenWorkflowExecutionsRequest_TypeFilter struct {
	TypeFilter *v19.WorkflowTypeFilter `protobuf:"bytes,6,opt,name=type_filter,json=typeFilter,proto3,oneof" json:"type_filter,omitempty"`
}

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) Equal 

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

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) GoString 

func (this *ListOpenWorkflowExecutionsRequest_TypeFilter) GoString() string

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) MarshalTo 

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

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) MarshalToSizedBuffer 

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

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) Size 

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

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) String 

func (this *ListOpenWorkflowExecutionsRequest_TypeFilter) String() string

type ListOpenWorkflowExecutionsResponse 

type ListOpenWorkflowExecutionsResponse struct {
	Executions    []*v110.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListOpenWorkflowExecutionsResponse) Descriptor 

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

func (*ListOpenWorkflowExecutionsResponse) Equal 

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

func (*ListOpenWorkflowExecutionsResponse) GetExecutions 

func (m *ListOpenWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

func (*ListOpenWorkflowExecutionsResponse) GetNextPageToken 

func (m *ListOpenWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ListOpenWorkflowExecutionsResponse) GoString 

func (this *ListOpenWorkflowExecutionsResponse) GoString() string

func (*ListOpenWorkflowExecutionsResponse) Marshal 

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

func (*ListOpenWorkflowExecutionsResponse) MarshalTo 

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

func (*ListOpenWorkflowExecutionsResponse) MarshalToSizedBuffer 

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

func (*ListOpenWorkflowExecutionsResponse) ProtoMessage 

func (*ListOpenWorkflowExecutionsResponse) ProtoMessage()

func (*ListOpenWorkflowExecutionsResponse) Reset 

func (m *ListOpenWorkflowExecutionsResponse) Reset()

func (*ListOpenWorkflowExecutionsResponse) Size 

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

func (*ListOpenWorkflowExecutionsResponse) String 

func (this *ListOpenWorkflowExecutionsResponse) String() string

func (*ListOpenWorkflowExecutionsResponse) Unmarshal 

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

func (*ListOpenWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ListOpenWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListOpenWorkflowExecutionsResponse) XXX_Marshal 

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

func (*ListOpenWorkflowExecutionsResponse) XXX_Merge 

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

func (*ListOpenWorkflowExecutionsResponse) XXX_Size 

func (m *ListOpenWorkflowExecutionsResponse) XXX_Size() int

func (*ListOpenWorkflowExecutionsResponse) XXX_Unmarshal 

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

type ListTaskQueuePartitionsRequest 

type ListTaskQueuePartitionsRequest struct {
	Namespace string         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueue *v14.TaskQueue `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
}

func (*ListTaskQueuePartitionsRequest) Descriptor 

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

func (*ListTaskQueuePartitionsRequest) Equal 

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

func (*ListTaskQueuePartitionsRequest) GetNamespace 

func (m *ListTaskQueuePartitionsRequest) GetNamespace() string

func (*ListTaskQueuePartitionsRequest) GetTaskQueue 

func (m *ListTaskQueuePartitionsRequest) GetTaskQueue() *v14.TaskQueue

func (*ListTaskQueuePartitionsRequest) GoString 

func (this *ListTaskQueuePartitionsRequest) GoString() string

func (*ListTaskQueuePartitionsRequest) Marshal 

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

func (*ListTaskQueuePartitionsRequest) MarshalTo 

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

func (*ListTaskQueuePartitionsRequest) MarshalToSizedBuffer 

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

func (*ListTaskQueuePartitionsRequest) ProtoMessage 

func (*ListTaskQueuePartitionsRequest) ProtoMessage()

func (*ListTaskQueuePartitionsRequest) Reset 

func (m *ListTaskQueuePartitionsRequest) Reset()

func (*ListTaskQueuePartitionsRequest) Size 

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

func (*ListTaskQueuePartitionsRequest) String 

func (this *ListTaskQueuePartitionsRequest) String() string

func (*ListTaskQueuePartitionsRequest) Unmarshal 

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

func (*ListTaskQueuePartitionsRequest) XXX_DiscardUnknown 

func (m *ListTaskQueuePartitionsRequest) XXX_DiscardUnknown()

func (*ListTaskQueuePartitionsRequest) XXX_Marshal 

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

func (*ListTaskQueuePartitionsRequest) XXX_Merge 

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

func (*ListTaskQueuePartitionsRequest) XXX_Size 

func (m *ListTaskQueuePartitionsRequest) XXX_Size() int

func (*ListTaskQueuePartitionsRequest) XXX_Unmarshal 

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

type ListTaskQueuePartitionsResponse 

type ListTaskQueuePartitionsResponse struct {
	ActivityTaskQueuePartitions []*v14.TaskQueuePartitionMetadata `` /* 146-byte string literal not displayed */
	WorkflowTaskQueuePartitions []*v14.TaskQueuePartitionMetadata `` /* 146-byte string literal not displayed */
}

func (*ListTaskQueuePartitionsResponse) Descriptor 

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

func (*ListTaskQueuePartitionsResponse) Equal 

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

func (*ListTaskQueuePartitionsResponse) GetActivityTaskQueuePartitions 

func (m *ListTaskQueuePartitionsResponse) GetActivityTaskQueuePartitions() []*v14.TaskQueuePartitionMetadata

func (*ListTaskQueuePartitionsResponse) GetWorkflowTaskQueuePartitions 

func (m *ListTaskQueuePartitionsResponse) GetWorkflowTaskQueuePartitions() []*v14.TaskQueuePartitionMetadata

func (*ListTaskQueuePartitionsResponse) GoString 

func (this *ListTaskQueuePartitionsResponse) GoString() string

func (*ListTaskQueuePartitionsResponse) Marshal 

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

func (*ListTaskQueuePartitionsResponse) MarshalTo 

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

func (*ListTaskQueuePartitionsResponse) MarshalToSizedBuffer 

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

func (*ListTaskQueuePartitionsResponse) ProtoMessage 

func (*ListTaskQueuePartitionsResponse) ProtoMessage()

func (*ListTaskQueuePartitionsResponse) Reset 

func (m *ListTaskQueuePartitionsResponse) Reset()

func (*ListTaskQueuePartitionsResponse) Size 

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

func (*ListTaskQueuePartitionsResponse) String 

func (this *ListTaskQueuePartitionsResponse) String() string

func (*ListTaskQueuePartitionsResponse) Unmarshal 

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

func (*ListTaskQueuePartitionsResponse) XXX_DiscardUnknown 

func (m *ListTaskQueuePartitionsResponse) XXX_DiscardUnknown()

func (*ListTaskQueuePartitionsResponse) XXX_Marshal 

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

func (*ListTaskQueuePartitionsResponse) XXX_Merge 

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

func (*ListTaskQueuePartitionsResponse) XXX_Size 

func (m *ListTaskQueuePartitionsResponse) XXX_Size() int

func (*ListTaskQueuePartitionsResponse) XXX_Unmarshal 

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

type ListWorkflowExecutionsRequest 

type ListWorkflowExecutionsRequest struct {
	Namespace     string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PageSize      int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Query         string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
}

func (*ListWorkflowExecutionsRequest) Descriptor 

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

func (*ListWorkflowExecutionsRequest) Equal 

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

func (*ListWorkflowExecutionsRequest) GetNamespace 

func (m *ListWorkflowExecutionsRequest) GetNamespace() string

func (*ListWorkflowExecutionsRequest) GetNextPageToken 

func (m *ListWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ListWorkflowExecutionsRequest) GetPageSize 

func (m *ListWorkflowExecutionsRequest) GetPageSize() int32

func (*ListWorkflowExecutionsRequest) GetQuery 

func (m *ListWorkflowExecutionsRequest) GetQuery() string

func (*ListWorkflowExecutionsRequest) GoString 

func (this *ListWorkflowExecutionsRequest) GoString() string

func (*ListWorkflowExecutionsRequest) Marshal 

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

func (*ListWorkflowExecutionsRequest) MarshalTo 

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

func (*ListWorkflowExecutionsRequest) MarshalToSizedBuffer 

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

func (*ListWorkflowExecutionsRequest) ProtoMessage 

func (*ListWorkflowExecutionsRequest) ProtoMessage()

func (*ListWorkflowExecutionsRequest) Reset 

func (m *ListWorkflowExecutionsRequest) Reset()

func (*ListWorkflowExecutionsRequest) Size 

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

func (*ListWorkflowExecutionsRequest) String 

func (this *ListWorkflowExecutionsRequest) String() string

func (*ListWorkflowExecutionsRequest) Unmarshal 

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

func (*ListWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ListWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListWorkflowExecutionsRequest) XXX_Marshal 

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

func (*ListWorkflowExecutionsRequest) XXX_Merge 

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

func (*ListWorkflowExecutionsRequest) XXX_Size 

func (m *ListWorkflowExecutionsRequest) XXX_Size() int

func (*ListWorkflowExecutionsRequest) XXX_Unmarshal 

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

type ListWorkflowExecutionsResponse 

type ListWorkflowExecutionsResponse struct {
	Executions    []*v110.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ListWorkflowExecutionsResponse) Descriptor 

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

func (*ListWorkflowExecutionsResponse) Equal 

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

func (*ListWorkflowExecutionsResponse) GetExecutions 

func (m *ListWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

func (*ListWorkflowExecutionsResponse) GetNextPageToken 

func (m *ListWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ListWorkflowExecutionsResponse) GoString 

func (this *ListWorkflowExecutionsResponse) GoString() string

func (*ListWorkflowExecutionsResponse) Marshal 

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

func (*ListWorkflowExecutionsResponse) MarshalTo 

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

func (*ListWorkflowExecutionsResponse) MarshalToSizedBuffer 

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

func (*ListWorkflowExecutionsResponse) ProtoMessage 

func (*ListWorkflowExecutionsResponse) ProtoMessage()

func (*ListWorkflowExecutionsResponse) Reset 

func (m *ListWorkflowExecutionsResponse) Reset()

func (*ListWorkflowExecutionsResponse) Size 

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

func (*ListWorkflowExecutionsResponse) String 

func (this *ListWorkflowExecutionsResponse) String() string

func (*ListWorkflowExecutionsResponse) Unmarshal 

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

func (*ListWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ListWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListWorkflowExecutionsResponse) XXX_Marshal 

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

func (*ListWorkflowExecutionsResponse) XXX_Merge 

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

func (*ListWorkflowExecutionsResponse) XXX_Size 

func (m *ListWorkflowExecutionsResponse) XXX_Size() int

func (*ListWorkflowExecutionsResponse) XXX_Unmarshal 

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

type PollActivityTaskQueueRequest 

type PollActivityTaskQueueRequest struct {
	Namespace         string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueue         *v14.TaskQueue         `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Identity          string                 `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	TaskQueueMetadata *v14.TaskQueueMetadata `protobuf:"bytes,4,opt,name=task_queue_metadata,json=taskQueueMetadata,proto3" json:"task_queue_metadata,omitempty"`
}

func (*PollActivityTaskQueueRequest) Descriptor 

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

func (*PollActivityTaskQueueRequest) Equal 

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

func (*PollActivityTaskQueueRequest) GetIdentity 

func (m *PollActivityTaskQueueRequest) GetIdentity() string

func (*PollActivityTaskQueueRequest) GetNamespace 

func (m *PollActivityTaskQueueRequest) GetNamespace() string

func (*PollActivityTaskQueueRequest) GetTaskQueue 

func (m *PollActivityTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

func (*PollActivityTaskQueueRequest) GetTaskQueueMetadata 

func (m *PollActivityTaskQueueRequest) GetTaskQueueMetadata() *v14.TaskQueueMetadata

func (*PollActivityTaskQueueRequest) GoString 

func (this *PollActivityTaskQueueRequest) GoString() string

func (*PollActivityTaskQueueRequest) Marshal 

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

func (*PollActivityTaskQueueRequest) MarshalTo 

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

func (*PollActivityTaskQueueRequest) MarshalToSizedBuffer 

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

func (*PollActivityTaskQueueRequest) ProtoMessage 

func (*PollActivityTaskQueueRequest) ProtoMessage()

func (*PollActivityTaskQueueRequest) Reset 

func (m *PollActivityTaskQueueRequest) Reset()

func (*PollActivityTaskQueueRequest) Size 

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

func (*PollActivityTaskQueueRequest) String 

func (this *PollActivityTaskQueueRequest) String() string

func (*PollActivityTaskQueueRequest) Unmarshal 

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

func (*PollActivityTaskQueueRequest) XXX_DiscardUnknown 

func (m *PollActivityTaskQueueRequest) XXX_DiscardUnknown()

func (*PollActivityTaskQueueRequest) XXX_Marshal 

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

func (*PollActivityTaskQueueRequest) XXX_Merge 

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

func (*PollActivityTaskQueueRequest) XXX_Size 

func (m *PollActivityTaskQueueRequest) XXX_Size() int

func (*PollActivityTaskQueueRequest) XXX_Unmarshal 

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

type PollActivityTaskQueueResponse 

type PollActivityTaskQueueResponse struct {
	TaskToken                   []byte                 `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	WorkflowNamespace           string                 `protobuf:"bytes,2,opt,name=workflow_namespace,json=workflowNamespace,proto3" json:"workflow_namespace,omitempty"`
	WorkflowType                *v13.WorkflowType      `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	WorkflowExecution           *v13.WorkflowExecution `protobuf:"bytes,4,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	ActivityType                *v13.ActivityType      `protobuf:"bytes,5,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	ActivityId                  string                 `protobuf:"bytes,6,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	Header                      *v13.Header            `protobuf:"bytes,7,opt,name=header,proto3" json:"header,omitempty"`
	Input                       *v13.Payloads          `protobuf:"bytes,8,opt,name=input,proto3" json:"input,omitempty"`
	HeartbeatDetails            *v13.Payloads          `protobuf:"bytes,9,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	ScheduledTime               *time.Time             `protobuf:"bytes,10,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	CurrentAttemptScheduledTime *time.Time             `` /* 155-byte string literal not displayed */
	StartedTime                 *time.Time             `protobuf:"bytes,12,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	Attempt                     int32                  `protobuf:"varint,13,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeout *time.Duration `` /* 144-byte string literal not displayed */
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeout *time.Duration `` /* 135-byte string literal not displayed */
	HeartbeatTimeout    *time.Duration `protobuf:"bytes,16,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3,stdduration" json:"heartbeat_timeout,omitempty"`
	// This is an actual retry policy the service uses.
	// It can be different from the one provided (or not) during activity scheduling
	// as the service can override the provided one in case its values are not specified
	// or exceed configured system limits.
	RetryPolicy *v13.RetryPolicy `protobuf:"bytes,17,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
}

func (*PollActivityTaskQueueResponse) Descriptor 

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

func (*PollActivityTaskQueueResponse) Equal 

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

func (*PollActivityTaskQueueResponse) GetActivityId 

func (m *PollActivityTaskQueueResponse) GetActivityId() string

func (*PollActivityTaskQueueResponse) GetActivityType 

func (m *PollActivityTaskQueueResponse) GetActivityType() *v13.ActivityType

func (*PollActivityTaskQueueResponse) GetAttempt 

func (m *PollActivityTaskQueueResponse) GetAttempt() int32

func (*PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime 

func (m *PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime() *time.Time

func (*PollActivityTaskQueueResponse) GetHeader 

func (m *PollActivityTaskQueueResponse) GetHeader() *v13.Header

func (*PollActivityTaskQueueResponse) GetHeartbeatDetails 

func (m *PollActivityTaskQueueResponse) GetHeartbeatDetails() *v13.Payloads

func (*PollActivityTaskQueueResponse) GetHeartbeatTimeout 

func (m *PollActivityTaskQueueResponse) GetHeartbeatTimeout() *time.Duration

func (*PollActivityTaskQueueResponse) GetInput 

func (m *PollActivityTaskQueueResponse) GetInput() *v13.Payloads

func (*PollActivityTaskQueueResponse) GetRetryPolicy 

func (m *PollActivityTaskQueueResponse) GetRetryPolicy() *v13.RetryPolicy

func (*PollActivityTaskQueueResponse) GetScheduleToCloseTimeout 

func (m *PollActivityTaskQueueResponse) GetScheduleToCloseTimeout() *time.Duration

func (*PollActivityTaskQueueResponse) GetScheduledTime 

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

func (*PollActivityTaskQueueResponse) GetStartToCloseTimeout 

func (m *PollActivityTaskQueueResponse) GetStartToCloseTimeout() *time.Duration

func (*PollActivityTaskQueueResponse) GetStartedTime 

func (m *PollActivityTaskQueueResponse) GetStartedTime() *time.Time

func (*PollActivityTaskQueueResponse) GetTaskToken 

func (m *PollActivityTaskQueueResponse) GetTaskToken() []byte

func (*PollActivityTaskQueueResponse) GetWorkflowExecution 

func (m *PollActivityTaskQueueResponse) GetWorkflowExecution() *v13.WorkflowExecution

func (*PollActivityTaskQueueResponse) GetWorkflowNamespace 

func (m *PollActivityTaskQueueResponse) GetWorkflowNamespace() string

func (*PollActivityTaskQueueResponse) GetWorkflowType 

func (m *PollActivityTaskQueueResponse) GetWorkflowType() *v13.WorkflowType

func (*PollActivityTaskQueueResponse) GoString 

func (this *PollActivityTaskQueueResponse) GoString() string

func (*PollActivityTaskQueueResponse) Marshal 

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

func (*PollActivityTaskQueueResponse) MarshalTo 

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

func (*PollActivityTaskQueueResponse) MarshalToSizedBuffer 

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

func (*PollActivityTaskQueueResponse) ProtoMessage 

func (*PollActivityTaskQueueResponse) ProtoMessage()

func (*PollActivityTaskQueueResponse) Reset 

func (m *PollActivityTaskQueueResponse) Reset()

func (*PollActivityTaskQueueResponse) Size 

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

func (*PollActivityTaskQueueResponse) String 

func (this *PollActivityTaskQueueResponse) String() string

func (*PollActivityTaskQueueResponse) Unmarshal 

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

func (*PollActivityTaskQueueResponse) XXX_DiscardUnknown 

func (m *PollActivityTaskQueueResponse) XXX_DiscardUnknown()

func (*PollActivityTaskQueueResponse) XXX_Marshal 

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

func (*PollActivityTaskQueueResponse) XXX_Merge 

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

func (*PollActivityTaskQueueResponse) XXX_Size 

func (m *PollActivityTaskQueueResponse) XXX_Size() int

func (*PollActivityTaskQueueResponse) XXX_Unmarshal 

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

type PollWorkflowTaskQueueRequest 

type PollWorkflowTaskQueueRequest struct {
	Namespace      string         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueue      *v14.TaskQueue `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Identity       string         `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	BinaryChecksum string         `protobuf:"bytes,4,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
}

func (*PollWorkflowTaskQueueRequest) Descriptor 

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

func (*PollWorkflowTaskQueueRequest) Equal 

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

func (*PollWorkflowTaskQueueRequest) GetBinaryChecksum 

func (m *PollWorkflowTaskQueueRequest) GetBinaryChecksum() string

func (*PollWorkflowTaskQueueRequest) GetIdentity 

func (m *PollWorkflowTaskQueueRequest) GetIdentity() string

func (*PollWorkflowTaskQueueRequest) GetNamespace 

func (m *PollWorkflowTaskQueueRequest) GetNamespace() string

func (*PollWorkflowTaskQueueRequest) GetTaskQueue 

func (m *PollWorkflowTaskQueueRequest) GetTaskQueue() *v14.TaskQueue

func (*PollWorkflowTaskQueueRequest) GoString 

func (this *PollWorkflowTaskQueueRequest) GoString() string

func (*PollWorkflowTaskQueueRequest) Marshal 

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

func (*PollWorkflowTaskQueueRequest) MarshalTo 

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

func (*PollWorkflowTaskQueueRequest) MarshalToSizedBuffer 

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

func (*PollWorkflowTaskQueueRequest) ProtoMessage 

func (*PollWorkflowTaskQueueRequest) ProtoMessage()

func (*PollWorkflowTaskQueueRequest) Reset 

func (m *PollWorkflowTaskQueueRequest) Reset()

func (*PollWorkflowTaskQueueRequest) Size 

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

func (*PollWorkflowTaskQueueRequest) String 

func (this *PollWorkflowTaskQueueRequest) String() string

func (*PollWorkflowTaskQueueRequest) Unmarshal 

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

func (*PollWorkflowTaskQueueRequest) XXX_DiscardUnknown 

func (m *PollWorkflowTaskQueueRequest) XXX_DiscardUnknown()

func (*PollWorkflowTaskQueueRequest) XXX_Marshal 

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

func (*PollWorkflowTaskQueueRequest) XXX_Merge 

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

func (*PollWorkflowTaskQueueRequest) XXX_Size 

func (m *PollWorkflowTaskQueueRequest) XXX_Size() int

func (*PollWorkflowTaskQueueRequest) XXX_Unmarshal 

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

type PollWorkflowTaskQueueResponse 

type PollWorkflowTaskQueueResponse struct {
	TaskToken                  []byte                        `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	WorkflowExecution          *v13.WorkflowExecution        `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	WorkflowType               *v13.WorkflowType             `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	PreviousStartedEventId     int64                         `` /* 132-byte string literal not displayed */
	StartedEventId             int64                         `protobuf:"varint,5,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	Attempt                    int32                         `protobuf:"varint,6,opt,name=attempt,proto3" json:"attempt,omitempty"`
	BacklogCountHint           int64                         `protobuf:"varint,7,opt,name=backlog_count_hint,json=backlogCountHint,proto3" json:"backlog_count_hint,omitempty"`
	History                    *v15.History                  `protobuf:"bytes,8,opt,name=history,proto3" json:"history,omitempty"`
	NextPageToken              []byte                        `protobuf:"bytes,9,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Query                      *v16.WorkflowQuery            `protobuf:"bytes,10,opt,name=query,proto3" json:"query,omitempty"`
	WorkflowExecutionTaskQueue *v14.TaskQueue                `` /* 144-byte string literal not displayed */
	ScheduledTime              *time.Time                    `protobuf:"bytes,12,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedTime                *time.Time                    `protobuf:"bytes,13,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	Queries                    map[string]*v16.WorkflowQuery `` /* 156-byte string literal not displayed */
}

func (*PollWorkflowTaskQueueResponse) Descriptor 

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

func (*PollWorkflowTaskQueueResponse) Equal 

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

func (*PollWorkflowTaskQueueResponse) GetAttempt 

func (m *PollWorkflowTaskQueueResponse) GetAttempt() int32

func (*PollWorkflowTaskQueueResponse) GetBacklogCountHint 

func (m *PollWorkflowTaskQueueResponse) GetBacklogCountHint() int64

func (*PollWorkflowTaskQueueResponse) GetHistory 

func (m *PollWorkflowTaskQueueResponse) GetHistory() *v15.History

func (*PollWorkflowTaskQueueResponse) GetNextPageToken 

func (m *PollWorkflowTaskQueueResponse) GetNextPageToken() []byte

func (*PollWorkflowTaskQueueResponse) GetPreviousStartedEventId 

func (m *PollWorkflowTaskQueueResponse) GetPreviousStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetQueries 

func (m *PollWorkflowTaskQueueResponse) GetQueries() map[string]*v16.WorkflowQuery

func (*PollWorkflowTaskQueueResponse) GetQuery 

func (m *PollWorkflowTaskQueueResponse) GetQuery() *v16.WorkflowQuery

func (*PollWorkflowTaskQueueResponse) GetScheduledTime 

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

func (*PollWorkflowTaskQueueResponse) GetStartedEventId 

func (m *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetStartedTime 

func (m *PollWorkflowTaskQueueResponse) GetStartedTime() *time.Time

func (*PollWorkflowTaskQueueResponse) GetTaskToken 

func (m *PollWorkflowTaskQueueResponse) GetTaskToken() []byte

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecution 

func (m *PollWorkflowTaskQueueResponse) GetWorkflowExecution() *v13.WorkflowExecution

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue 

func (m *PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue() *v14.TaskQueue

func (*PollWorkflowTaskQueueResponse) GetWorkflowType 

func (m *PollWorkflowTaskQueueResponse) GetWorkflowType() *v13.WorkflowType

func (*PollWorkflowTaskQueueResponse) GoString 

func (this *PollWorkflowTaskQueueResponse) GoString() string

func (*PollWorkflowTaskQueueResponse) Marshal 

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

func (*PollWorkflowTaskQueueResponse) MarshalTo 

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

func (*PollWorkflowTaskQueueResponse) MarshalToSizedBuffer 

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

func (*PollWorkflowTaskQueueResponse) ProtoMessage 

func (*PollWorkflowTaskQueueResponse) ProtoMessage()

func (*PollWorkflowTaskQueueResponse) Reset 

func (m *PollWorkflowTaskQueueResponse) Reset()

func (*PollWorkflowTaskQueueResponse) Size 

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

func (*PollWorkflowTaskQueueResponse) String 

func (this *PollWorkflowTaskQueueResponse) String() string

func (*PollWorkflowTaskQueueResponse) Unmarshal 

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

func (*PollWorkflowTaskQueueResponse) XXX_DiscardUnknown 

func (m *PollWorkflowTaskQueueResponse) XXX_DiscardUnknown()

func (*PollWorkflowTaskQueueResponse) XXX_Marshal 

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

func (*PollWorkflowTaskQueueResponse) XXX_Merge 

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

func (*PollWorkflowTaskQueueResponse) XXX_Size 

func (m *PollWorkflowTaskQueueResponse) XXX_Size() int

func (*PollWorkflowTaskQueueResponse) XXX_Unmarshal 

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

type QueryWorkflowRequest 

type QueryWorkflowRequest struct {
	Namespace string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Execution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	Query     *v16.WorkflowQuery     `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// QueryRejectCondition can used to reject the query if workflow state does not satisfy condition.
	// Default: QUERY_REJECT_CONDITION_NONE.
	QueryRejectCondition v11.QueryRejectCondition `` /* 172-byte string literal not displayed */
}

func (*QueryWorkflowRequest) Descriptor 

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

func (*QueryWorkflowRequest) Equal 

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

func (*QueryWorkflowRequest) GetExecution 

func (m *QueryWorkflowRequest) GetExecution() *v13.WorkflowExecution

func (*QueryWorkflowRequest) GetNamespace 

func (m *QueryWorkflowRequest) GetNamespace() string

func (*QueryWorkflowRequest) GetQuery 

func (m *QueryWorkflowRequest) GetQuery() *v16.WorkflowQuery

func (*QueryWorkflowRequest) GetQueryRejectCondition 

func (m *QueryWorkflowRequest) GetQueryRejectCondition() v11.QueryRejectCondition

func (*QueryWorkflowRequest) GoString 

func (this *QueryWorkflowRequest) GoString() string

func (*QueryWorkflowRequest) Marshal 

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

func (*QueryWorkflowRequest) MarshalTo 

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

func (*QueryWorkflowRequest) MarshalToSizedBuffer 

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

func (*QueryWorkflowRequest) ProtoMessage 

func (*QueryWorkflowRequest) ProtoMessage()

func (*QueryWorkflowRequest) Reset 

func (m *QueryWorkflowRequest) Reset()

func (*QueryWorkflowRequest) Size 

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

func (*QueryWorkflowRequest) String 

func (this *QueryWorkflowRequest) String() string

func (*QueryWorkflowRequest) Unmarshal 

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

func (*QueryWorkflowRequest) XXX_DiscardUnknown 

func (m *QueryWorkflowRequest) XXX_DiscardUnknown()

func (*QueryWorkflowRequest) XXX_Marshal 

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

func (*QueryWorkflowRequest) XXX_Merge 

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

func (*QueryWorkflowRequest) XXX_Size 

func (m *QueryWorkflowRequest) XXX_Size() int

func (*QueryWorkflowRequest) XXX_Unmarshal 

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

type QueryWorkflowResponse 

type QueryWorkflowResponse struct {
	QueryResult   *v13.Payloads      `protobuf:"bytes,1,opt,name=query_result,json=queryResult,proto3" json:"query_result,omitempty"`
	QueryRejected *v16.QueryRejected `protobuf:"bytes,2,opt,name=query_rejected,json=queryRejected,proto3" json:"query_rejected,omitempty"`
}

func (*QueryWorkflowResponse) Descriptor 

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

func (*QueryWorkflowResponse) Equal 

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

func (*QueryWorkflowResponse) GetQueryRejected 

func (m *QueryWorkflowResponse) GetQueryRejected() *v16.QueryRejected

func (*QueryWorkflowResponse) GetQueryResult 

func (m *QueryWorkflowResponse) GetQueryResult() *v13.Payloads

func (*QueryWorkflowResponse) GoString 

func (this *QueryWorkflowResponse) GoString() string

func (*QueryWorkflowResponse) Marshal 

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

func (*QueryWorkflowResponse) MarshalTo 

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

func (*QueryWorkflowResponse) MarshalToSizedBuffer 

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

func (*QueryWorkflowResponse) ProtoMessage 

func (*QueryWorkflowResponse) ProtoMessage()

func (*QueryWorkflowResponse) Reset 

func (m *QueryWorkflowResponse) Reset()

func (*QueryWorkflowResponse) Size 

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

func (*QueryWorkflowResponse) String 

func (this *QueryWorkflowResponse) String() string

func (*QueryWorkflowResponse) Unmarshal 

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

func (*QueryWorkflowResponse) XXX_DiscardUnknown 

func (m *QueryWorkflowResponse) XXX_DiscardUnknown()

func (*QueryWorkflowResponse) XXX_Marshal 

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

func (*QueryWorkflowResponse) XXX_Merge 

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

func (*QueryWorkflowResponse) XXX_Size 

func (m *QueryWorkflowResponse) XXX_Size() int

func (*QueryWorkflowResponse) XXX_Unmarshal 

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

type RecordActivityTaskHeartbeatByIdRequest 

type RecordActivityTaskHeartbeatByIdRequest struct {
	Namespace  string        `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId string        `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId      string        `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ActivityId string        `protobuf:"bytes,4,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	Details    *v13.Payloads `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	Identity   string        `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RecordActivityTaskHeartbeatByIdRequest) Descriptor 

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

func (*RecordActivityTaskHeartbeatByIdRequest) Equal 

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

func (*RecordActivityTaskHeartbeatByIdRequest) GetActivityId 

func (m *RecordActivityTaskHeartbeatByIdRequest) GetActivityId() string

func (*RecordActivityTaskHeartbeatByIdRequest) GetDetails 

func (m *RecordActivityTaskHeartbeatByIdRequest) GetDetails() *v13.Payloads

func (*RecordActivityTaskHeartbeatByIdRequest) GetIdentity 

func (m *RecordActivityTaskHeartbeatByIdRequest) GetIdentity() string

func (*RecordActivityTaskHeartbeatByIdRequest) GetNamespace 

func (m *RecordActivityTaskHeartbeatByIdRequest) GetNamespace() string

func (*RecordActivityTaskHeartbeatByIdRequest) GetRunId 

func (m *RecordActivityTaskHeartbeatByIdRequest) GetRunId() string

func (*RecordActivityTaskHeartbeatByIdRequest) GetWorkflowId 

func (m *RecordActivityTaskHeartbeatByIdRequest) GetWorkflowId() string

func (*RecordActivityTaskHeartbeatByIdRequest) GoString 

func (this *RecordActivityTaskHeartbeatByIdRequest) GoString() string

func (*RecordActivityTaskHeartbeatByIdRequest) Marshal 

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

func (*RecordActivityTaskHeartbeatByIdRequest) MarshalTo 

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

func (*RecordActivityTaskHeartbeatByIdRequest) MarshalToSizedBuffer 

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

func (*RecordActivityTaskHeartbeatByIdRequest) ProtoMessage 

func (*RecordActivityTaskHeartbeatByIdRequest) ProtoMessage()

func (*RecordActivityTaskHeartbeatByIdRequest) Reset 

func (m *RecordActivityTaskHeartbeatByIdRequest) Reset()

func (*RecordActivityTaskHeartbeatByIdRequest) Size 

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

func (*RecordActivityTaskHeartbeatByIdRequest) String 

func (this *RecordActivityTaskHeartbeatByIdRequest) String() string

func (*RecordActivityTaskHeartbeatByIdRequest) Unmarshal 

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

func (*RecordActivityTaskHeartbeatByIdRequest) XXX_DiscardUnknown 

func (m *RecordActivityTaskHeartbeatByIdRequest) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatByIdRequest) XXX_Marshal 

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

func (*RecordActivityTaskHeartbeatByIdRequest) XXX_Merge 

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

func (*RecordActivityTaskHeartbeatByIdRequest) XXX_Size 

func (m *RecordActivityTaskHeartbeatByIdRequest) XXX_Size() int

func (*RecordActivityTaskHeartbeatByIdRequest) XXX_Unmarshal 

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

type RecordActivityTaskHeartbeatByIdResponse 

type RecordActivityTaskHeartbeatByIdResponse struct {
	CancelRequested bool `protobuf:"varint,1,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
}

func (*RecordActivityTaskHeartbeatByIdResponse) Descriptor 

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

func (*RecordActivityTaskHeartbeatByIdResponse) Equal 

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

func (*RecordActivityTaskHeartbeatByIdResponse) GetCancelRequested 

func (m *RecordActivityTaskHeartbeatByIdResponse) GetCancelRequested() bool

func (*RecordActivityTaskHeartbeatByIdResponse) GoString 

func (this *RecordActivityTaskHeartbeatByIdResponse) GoString() string

func (*RecordActivityTaskHeartbeatByIdResponse) Marshal 

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

func (*RecordActivityTaskHeartbeatByIdResponse) MarshalTo 

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

func (*RecordActivityTaskHeartbeatByIdResponse) MarshalToSizedBuffer 

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

func (*RecordActivityTaskHeartbeatByIdResponse) ProtoMessage 

func (*RecordActivityTaskHeartbeatByIdResponse) ProtoMessage()

func (*RecordActivityTaskHeartbeatByIdResponse) Reset 

func (m *RecordActivityTaskHeartbeatByIdResponse) Reset()

func (*RecordActivityTaskHeartbeatByIdResponse) Size 

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

func (*RecordActivityTaskHeartbeatByIdResponse) String 

func (this *RecordActivityTaskHeartbeatByIdResponse) String() string

func (*RecordActivityTaskHeartbeatByIdResponse) Unmarshal 

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

func (*RecordActivityTaskHeartbeatByIdResponse) XXX_DiscardUnknown 

func (m *RecordActivityTaskHeartbeatByIdResponse) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatByIdResponse) XXX_Marshal 

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

func (*RecordActivityTaskHeartbeatByIdResponse) XXX_Merge 

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

func (*RecordActivityTaskHeartbeatByIdResponse) XXX_Size 

func (m *RecordActivityTaskHeartbeatByIdResponse) XXX_Size() int

func (*RecordActivityTaskHeartbeatByIdResponse) XXX_Unmarshal 

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

type RecordActivityTaskHeartbeatRequest 

type RecordActivityTaskHeartbeatRequest struct {
	TaskToken []byte        `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	Details   *v13.Payloads `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	Identity  string        `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RecordActivityTaskHeartbeatRequest) Descriptor 

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

func (*RecordActivityTaskHeartbeatRequest) Equal 

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

func (*RecordActivityTaskHeartbeatRequest) GetDetails 

func (m *RecordActivityTaskHeartbeatRequest) GetDetails() *v13.Payloads

func (*RecordActivityTaskHeartbeatRequest) GetIdentity 

func (m *RecordActivityTaskHeartbeatRequest) GetIdentity() string

func (*RecordActivityTaskHeartbeatRequest) GetTaskToken 

func (m *RecordActivityTaskHeartbeatRequest) GetTaskToken() []byte

func (*RecordActivityTaskHeartbeatRequest) GoString 

func (this *RecordActivityTaskHeartbeatRequest) GoString() string

func (*RecordActivityTaskHeartbeatRequest) Marshal 

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

func (*RecordActivityTaskHeartbeatRequest) MarshalTo 

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

func (*RecordActivityTaskHeartbeatRequest) MarshalToSizedBuffer 

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

func (*RecordActivityTaskHeartbeatRequest) ProtoMessage 

func (*RecordActivityTaskHeartbeatRequest) ProtoMessage()

func (*RecordActivityTaskHeartbeatRequest) Reset 

func (m *RecordActivityTaskHeartbeatRequest) Reset()

func (*RecordActivityTaskHeartbeatRequest) Size 

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

func (*RecordActivityTaskHeartbeatRequest) String 

func (this *RecordActivityTaskHeartbeatRequest) String() string

func (*RecordActivityTaskHeartbeatRequest) Unmarshal 

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

func (*RecordActivityTaskHeartbeatRequest) XXX_DiscardUnknown 

func (m *RecordActivityTaskHeartbeatRequest) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatRequest) XXX_Marshal 

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

func (*RecordActivityTaskHeartbeatRequest) XXX_Merge 

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

func (*RecordActivityTaskHeartbeatRequest) XXX_Size 

func (m *RecordActivityTaskHeartbeatRequest) XXX_Size() int

func (*RecordActivityTaskHeartbeatRequest) XXX_Unmarshal 

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

type RecordActivityTaskHeartbeatResponse 

type RecordActivityTaskHeartbeatResponse struct {
	CancelRequested bool `protobuf:"varint,1,opt,name=cancel_requested,json=cancelRequested,proto3" json:"cancel_requested,omitempty"`
}

func (*RecordActivityTaskHeartbeatResponse) Descriptor 

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

func (*RecordActivityTaskHeartbeatResponse) Equal 

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

func (*RecordActivityTaskHeartbeatResponse) GetCancelRequested 

func (m *RecordActivityTaskHeartbeatResponse) GetCancelRequested() bool

func (*RecordActivityTaskHeartbeatResponse) GoString 

func (this *RecordActivityTaskHeartbeatResponse) GoString() string

func (*RecordActivityTaskHeartbeatResponse) Marshal 

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

func (*RecordActivityTaskHeartbeatResponse) MarshalTo 

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

func (*RecordActivityTaskHeartbeatResponse) MarshalToSizedBuffer 

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

func (*RecordActivityTaskHeartbeatResponse) ProtoMessage 

func (*RecordActivityTaskHeartbeatResponse) ProtoMessage()

func (*RecordActivityTaskHeartbeatResponse) Reset 

func (m *RecordActivityTaskHeartbeatResponse) Reset()

func (*RecordActivityTaskHeartbeatResponse) Size 

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

func (*RecordActivityTaskHeartbeatResponse) String 

func (this *RecordActivityTaskHeartbeatResponse) String() string

func (*RecordActivityTaskHeartbeatResponse) Unmarshal 

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

func (*RecordActivityTaskHeartbeatResponse) XXX_DiscardUnknown 

func (m *RecordActivityTaskHeartbeatResponse) XXX_DiscardUnknown()

func (*RecordActivityTaskHeartbeatResponse) XXX_Marshal 

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

func (*RecordActivityTaskHeartbeatResponse) XXX_Merge 

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

func (*RecordActivityTaskHeartbeatResponse) XXX_Size 

func (m *RecordActivityTaskHeartbeatResponse) XXX_Size() int

func (*RecordActivityTaskHeartbeatResponse) XXX_Unmarshal 

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

type RegisterNamespaceRequest 

type RegisterNamespaceRequest struct {
	Name                             string                         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description                      string                         `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	OwnerEmail                       string                         `protobuf:"bytes,3,opt,name=owner_email,json=ownerEmail,proto3" json:"owner_email,omitempty"`
	WorkflowExecutionRetentionPeriod *time.Duration                 `` /* 173-byte string literal not displayed */
	Clusters                         []*v1.ClusterReplicationConfig `protobuf:"bytes,5,rep,name=clusters,proto3" json:"clusters,omitempty"`
	ActiveClusterName                string                         `protobuf:"bytes,6,opt,name=active_cluster_name,json=activeClusterName,proto3" json:"active_cluster_name,omitempty"`
	// A key-value map for any customized purpose.
	Data              map[string]string `` /* 149-byte string literal not displayed */
	SecurityToken     string            `protobuf:"bytes,8,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
	IsGlobalNamespace bool              `protobuf:"varint,9,opt,name=is_global_namespace,json=isGlobalNamespace,proto3" json:"is_global_namespace,omitempty"`
	// If unspecified (ARCHIVAL_STATE_UNSPECIFIED) then default server configuration is used.
	HistoryArchivalState v11.ArchivalState `` /* 166-byte string literal not displayed */
	HistoryArchivalUri   string            `protobuf:"bytes,11,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
	// If unspecified (ARCHIVAL_STATE_UNSPECIFIED) then default server configuration is used.
	VisibilityArchivalState v11.ArchivalState `` /* 175-byte string literal not displayed */
	VisibilityArchivalUri   string            `` /* 127-byte string literal not displayed */
}

func (*RegisterNamespaceRequest) Descriptor 

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

func (*RegisterNamespaceRequest) Equal 

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

func (*RegisterNamespaceRequest) GetActiveClusterName 

func (m *RegisterNamespaceRequest) GetActiveClusterName() string

func (*RegisterNamespaceRequest) GetClusters 

func (m *RegisterNamespaceRequest) GetClusters() []*v1.ClusterReplicationConfig

func (*RegisterNamespaceRequest) GetData 

func (m *RegisterNamespaceRequest) GetData() map[string]string

func (*RegisterNamespaceRequest) GetDescription 

func (m *RegisterNamespaceRequest) GetDescription() string

func (*RegisterNamespaceRequest) GetHistoryArchivalState 

func (m *RegisterNamespaceRequest) GetHistoryArchivalState() v11.ArchivalState

func (*RegisterNamespaceRequest) GetHistoryArchivalUri 

func (m *RegisterNamespaceRequest) GetHistoryArchivalUri() string

func (*RegisterNamespaceRequest) GetIsGlobalNamespace 

func (m *RegisterNamespaceRequest) GetIsGlobalNamespace() bool

func (*RegisterNamespaceRequest) GetName 

func (m *RegisterNamespaceRequest) GetName() string

func (*RegisterNamespaceRequest) GetOwnerEmail 

func (m *RegisterNamespaceRequest) GetOwnerEmail() string

func (*RegisterNamespaceRequest) GetSecurityToken 

func (m *RegisterNamespaceRequest) GetSecurityToken() string

func (*RegisterNamespaceRequest) GetVisibilityArchivalState 

func (m *RegisterNamespaceRequest) GetVisibilityArchivalState() v11.ArchivalState

func (*RegisterNamespaceRequest) GetVisibilityArchivalUri 

func (m *RegisterNamespaceRequest) GetVisibilityArchivalUri() string

func (*RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriod 

func (m *RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriod() *time.Duration

func (*RegisterNamespaceRequest) GoString 

func (this *RegisterNamespaceRequest) GoString() string

func (*RegisterNamespaceRequest) Marshal 

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

func (*RegisterNamespaceRequest) MarshalTo 

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

func (*RegisterNamespaceRequest) MarshalToSizedBuffer 

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

func (*RegisterNamespaceRequest) ProtoMessage 

func (*RegisterNamespaceRequest) ProtoMessage()

func (*RegisterNamespaceRequest) Reset 

func (m *RegisterNamespaceRequest) Reset()

func (*RegisterNamespaceRequest) Size 

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

func (*RegisterNamespaceRequest) String 

func (this *RegisterNamespaceRequest) String() string

func (*RegisterNamespaceRequest) Unmarshal 

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

func (*RegisterNamespaceRequest) XXX_DiscardUnknown 

func (m *RegisterNamespaceRequest) XXX_DiscardUnknown()

func (*RegisterNamespaceRequest) XXX_Marshal 

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

func (*RegisterNamespaceRequest) XXX_Merge 

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

func (*RegisterNamespaceRequest) XXX_Size 

func (m *RegisterNamespaceRequest) XXX_Size() int

func (*RegisterNamespaceRequest) XXX_Unmarshal 

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

type RegisterNamespaceResponse 

type RegisterNamespaceResponse struct {
}

func (*RegisterNamespaceResponse) Descriptor 

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

func (*RegisterNamespaceResponse) Equal 

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

func (*RegisterNamespaceResponse) GoString 

func (this *RegisterNamespaceResponse) GoString() string

func (*RegisterNamespaceResponse) Marshal 

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

func (*RegisterNamespaceResponse) MarshalTo 

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

func (*RegisterNamespaceResponse) MarshalToSizedBuffer 

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

func (*RegisterNamespaceResponse) ProtoMessage 

func (*RegisterNamespaceResponse) ProtoMessage()

func (*RegisterNamespaceResponse) Reset 

func (m *RegisterNamespaceResponse) Reset()

func (*RegisterNamespaceResponse) Size 

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

func (*RegisterNamespaceResponse) String 

func (this *RegisterNamespaceResponse) String() string

func (*RegisterNamespaceResponse) Unmarshal 

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

func (*RegisterNamespaceResponse) XXX_DiscardUnknown 

func (m *RegisterNamespaceResponse) XXX_DiscardUnknown()

func (*RegisterNamespaceResponse) XXX_Marshal 

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

func (*RegisterNamespaceResponse) XXX_Merge 

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

func (*RegisterNamespaceResponse) XXX_Size 

func (m *RegisterNamespaceResponse) XXX_Size() int

func (*RegisterNamespaceResponse) XXX_Unmarshal 

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

type RequestCancelWorkflowExecutionRequest 

type RequestCancelWorkflowExecutionRequest struct {
	Namespace           string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution   *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Identity            string                 `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId           string                 `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	FirstExecutionRunId string                 `protobuf:"bytes,5,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
}

func (*RequestCancelWorkflowExecutionRequest) Descriptor 

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

func (*RequestCancelWorkflowExecutionRequest) Equal 

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

func (*RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunId 

func (m *RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunId() string

func (*RequestCancelWorkflowExecutionRequest) GetIdentity 

func (m *RequestCancelWorkflowExecutionRequest) GetIdentity() string

func (*RequestCancelWorkflowExecutionRequest) GetNamespace 

func (m *RequestCancelWorkflowExecutionRequest) GetNamespace() string

func (*RequestCancelWorkflowExecutionRequest) GetRequestId 

func (m *RequestCancelWorkflowExecutionRequest) GetRequestId() string

func (*RequestCancelWorkflowExecutionRequest) GetWorkflowExecution 

func (m *RequestCancelWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

func (*RequestCancelWorkflowExecutionRequest) GoString 

func (this *RequestCancelWorkflowExecutionRequest) GoString() string

func (*RequestCancelWorkflowExecutionRequest) Marshal 

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

func (*RequestCancelWorkflowExecutionRequest) MarshalTo 

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

func (*RequestCancelWorkflowExecutionRequest) MarshalToSizedBuffer 

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

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage 

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage()

func (*RequestCancelWorkflowExecutionRequest) Reset 

func (m *RequestCancelWorkflowExecutionRequest) Reset()

func (*RequestCancelWorkflowExecutionRequest) Size 

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

func (*RequestCancelWorkflowExecutionRequest) String 

func (this *RequestCancelWorkflowExecutionRequest) String() string

func (*RequestCancelWorkflowExecutionRequest) Unmarshal 

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

func (*RequestCancelWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *RequestCancelWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*RequestCancelWorkflowExecutionRequest) XXX_Marshal 

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

func (*RequestCancelWorkflowExecutionRequest) XXX_Merge 

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

func (*RequestCancelWorkflowExecutionRequest) XXX_Size 

func (m *RequestCancelWorkflowExecutionRequest) XXX_Size() int

func (*RequestCancelWorkflowExecutionRequest) XXX_Unmarshal 

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

type RequestCancelWorkflowExecutionResponse 

type RequestCancelWorkflowExecutionResponse struct {
}

func (*RequestCancelWorkflowExecutionResponse) Descriptor 

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

func (*RequestCancelWorkflowExecutionResponse) Equal 

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

func (*RequestCancelWorkflowExecutionResponse) GoString 

func (this *RequestCancelWorkflowExecutionResponse) GoString() string

func (*RequestCancelWorkflowExecutionResponse) Marshal 

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

func (*RequestCancelWorkflowExecutionResponse) MarshalTo 

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

func (*RequestCancelWorkflowExecutionResponse) MarshalToSizedBuffer 

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

func (*RequestCancelWorkflowExecutionResponse) ProtoMessage 

func (*RequestCancelWorkflowExecutionResponse) ProtoMessage()

func (*RequestCancelWorkflowExecutionResponse) Reset 

func (m *RequestCancelWorkflowExecutionResponse) Reset()

func (*RequestCancelWorkflowExecutionResponse) Size 

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

func (*RequestCancelWorkflowExecutionResponse) String 

func (this *RequestCancelWorkflowExecutionResponse) String() string

func (*RequestCancelWorkflowExecutionResponse) Unmarshal 

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

func (*RequestCancelWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *RequestCancelWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*RequestCancelWorkflowExecutionResponse) XXX_Marshal 

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

func (*RequestCancelWorkflowExecutionResponse) XXX_Merge 

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

func (*RequestCancelWorkflowExecutionResponse) XXX_Size 

func (m *RequestCancelWorkflowExecutionResponse) XXX_Size() int

func (*RequestCancelWorkflowExecutionResponse) XXX_Unmarshal 

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

type ResetStickyTaskQueueRequest 

type ResetStickyTaskQueueRequest struct {
	Namespace string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Execution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
}

func (*ResetStickyTaskQueueRequest) Descriptor 

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

func (*ResetStickyTaskQueueRequest) Equal 

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

func (*ResetStickyTaskQueueRequest) GetExecution 

func (m *ResetStickyTaskQueueRequest) GetExecution() *v13.WorkflowExecution

func (*ResetStickyTaskQueueRequest) GetNamespace 

func (m *ResetStickyTaskQueueRequest) GetNamespace() string

func (*ResetStickyTaskQueueRequest) GoString 

func (this *ResetStickyTaskQueueRequest) GoString() string

func (*ResetStickyTaskQueueRequest) Marshal 

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

func (*ResetStickyTaskQueueRequest) MarshalTo 

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

func (*ResetStickyTaskQueueRequest) MarshalToSizedBuffer 

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

func (*ResetStickyTaskQueueRequest) ProtoMessage 

func (*ResetStickyTaskQueueRequest) ProtoMessage()

func (*ResetStickyTaskQueueRequest) Reset 

func (m *ResetStickyTaskQueueRequest) Reset()

func (*ResetStickyTaskQueueRequest) Size 

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

func (*ResetStickyTaskQueueRequest) String 

func (this *ResetStickyTaskQueueRequest) String() string

func (*ResetStickyTaskQueueRequest) Unmarshal 

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

func (*ResetStickyTaskQueueRequest) XXX_DiscardUnknown 

func (m *ResetStickyTaskQueueRequest) XXX_DiscardUnknown()

func (*ResetStickyTaskQueueRequest) XXX_Marshal 

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

func (*ResetStickyTaskQueueRequest) XXX_Merge 

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

func (*ResetStickyTaskQueueRequest) XXX_Size 

func (m *ResetStickyTaskQueueRequest) XXX_Size() int

func (*ResetStickyTaskQueueRequest) XXX_Unmarshal 

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

type ResetStickyTaskQueueResponse 

type ResetStickyTaskQueueResponse struct {
}

func (*ResetStickyTaskQueueResponse) Descriptor 

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

func (*ResetStickyTaskQueueResponse) Equal 

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

func (*ResetStickyTaskQueueResponse) GoString 

func (this *ResetStickyTaskQueueResponse) GoString() string

func (*ResetStickyTaskQueueResponse) Marshal 

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

func (*ResetStickyTaskQueueResponse) MarshalTo 

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

func (*ResetStickyTaskQueueResponse) MarshalToSizedBuffer 

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

func (*ResetStickyTaskQueueResponse) ProtoMessage 

func (*ResetStickyTaskQueueResponse) ProtoMessage()

func (*ResetStickyTaskQueueResponse) Reset 

func (m *ResetStickyTaskQueueResponse) Reset()

func (*ResetStickyTaskQueueResponse) Size 

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

func (*ResetStickyTaskQueueResponse) String 

func (this *ResetStickyTaskQueueResponse) String() string

func (*ResetStickyTaskQueueResponse) Unmarshal 

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

func (*ResetStickyTaskQueueResponse) XXX_DiscardUnknown 

func (m *ResetStickyTaskQueueResponse) XXX_DiscardUnknown()

func (*ResetStickyTaskQueueResponse) XXX_Marshal 

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

func (*ResetStickyTaskQueueResponse) XXX_Merge 

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

func (*ResetStickyTaskQueueResponse) XXX_Size 

func (m *ResetStickyTaskQueueResponse) XXX_Size() int

func (*ResetStickyTaskQueueResponse) XXX_Unmarshal 

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

type ResetWorkflowExecutionRequest 

type ResetWorkflowExecutionRequest struct {
	Namespace                 string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution         *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Reason                    string                 `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	WorkflowTaskFinishEventId int64                  `` /* 143-byte string literal not displayed */
	RequestId                 string                 `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}

func (*ResetWorkflowExecutionRequest) Descriptor 

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

func (*ResetWorkflowExecutionRequest) Equal 

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

func (*ResetWorkflowExecutionRequest) GetNamespace 

func (m *ResetWorkflowExecutionRequest) GetNamespace() string

func (*ResetWorkflowExecutionRequest) GetReason 

func (m *ResetWorkflowExecutionRequest) GetReason() string

func (*ResetWorkflowExecutionRequest) GetRequestId 

func (m *ResetWorkflowExecutionRequest) GetRequestId() string

func (*ResetWorkflowExecutionRequest) GetWorkflowExecution 

func (m *ResetWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

func (*ResetWorkflowExecutionRequest) GetWorkflowTaskFinishEventId 

func (m *ResetWorkflowExecutionRequest) GetWorkflowTaskFinishEventId() int64

func (*ResetWorkflowExecutionRequest) GoString 

func (this *ResetWorkflowExecutionRequest) GoString() string

func (*ResetWorkflowExecutionRequest) Marshal 

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

func (*ResetWorkflowExecutionRequest) MarshalTo 

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

func (*ResetWorkflowExecutionRequest) MarshalToSizedBuffer 

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

func (*ResetWorkflowExecutionRequest) ProtoMessage 

func (*ResetWorkflowExecutionRequest) ProtoMessage()

func (*ResetWorkflowExecutionRequest) Reset 

func (m *ResetWorkflowExecutionRequest) Reset()

func (*ResetWorkflowExecutionRequest) Size 

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

func (*ResetWorkflowExecutionRequest) String 

func (this *ResetWorkflowExecutionRequest) String() string

func (*ResetWorkflowExecutionRequest) Unmarshal 

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

func (*ResetWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *ResetWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*ResetWorkflowExecutionRequest) XXX_Marshal 

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

func (*ResetWorkflowExecutionRequest) XXX_Merge 

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

func (*ResetWorkflowExecutionRequest) XXX_Size 

func (m *ResetWorkflowExecutionRequest) XXX_Size() int

func (*ResetWorkflowExecutionRequest) XXX_Unmarshal 

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

type ResetWorkflowExecutionResponse 

type ResetWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
}

func (*ResetWorkflowExecutionResponse) Descriptor 

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

func (*ResetWorkflowExecutionResponse) Equal 

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

func (*ResetWorkflowExecutionResponse) GetRunId 

func (m *ResetWorkflowExecutionResponse) GetRunId() string

func (*ResetWorkflowExecutionResponse) GoString 

func (this *ResetWorkflowExecutionResponse) GoString() string

func (*ResetWorkflowExecutionResponse) Marshal 

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

func (*ResetWorkflowExecutionResponse) MarshalTo 

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

func (*ResetWorkflowExecutionResponse) MarshalToSizedBuffer 

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

func (*ResetWorkflowExecutionResponse) ProtoMessage 

func (*ResetWorkflowExecutionResponse) ProtoMessage()

func (*ResetWorkflowExecutionResponse) Reset 

func (m *ResetWorkflowExecutionResponse) Reset()

func (*ResetWorkflowExecutionResponse) Size 

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

func (*ResetWorkflowExecutionResponse) String 

func (this *ResetWorkflowExecutionResponse) String() string

func (*ResetWorkflowExecutionResponse) Unmarshal 

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

func (*ResetWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *ResetWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*ResetWorkflowExecutionResponse) XXX_Marshal 

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

func (*ResetWorkflowExecutionResponse) XXX_Merge 

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

func (*ResetWorkflowExecutionResponse) XXX_Size 

func (m *ResetWorkflowExecutionResponse) XXX_Size() int

func (*ResetWorkflowExecutionResponse) XXX_Unmarshal 

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

type RespondActivityTaskCanceledByIdRequest 

type RespondActivityTaskCanceledByIdRequest struct {
	Namespace  string        `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId string        `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId      string        `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ActivityId string        `protobuf:"bytes,4,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	Details    *v13.Payloads `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	Identity   string        `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskCanceledByIdRequest) Descriptor 

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

func (*RespondActivityTaskCanceledByIdRequest) Equal 

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

func (*RespondActivityTaskCanceledByIdRequest) GetActivityId 

func (m *RespondActivityTaskCanceledByIdRequest) GetActivityId() string

func (*RespondActivityTaskCanceledByIdRequest) GetDetails 

func (m *RespondActivityTaskCanceledByIdRequest) GetDetails() *v13.Payloads

func (*RespondActivityTaskCanceledByIdRequest) GetIdentity 

func (m *RespondActivityTaskCanceledByIdRequest) GetIdentity() string

func (*RespondActivityTaskCanceledByIdRequest) GetNamespace 

func (m *RespondActivityTaskCanceledByIdRequest) GetNamespace() string

func (*RespondActivityTaskCanceledByIdRequest) GetRunId 

func (m *RespondActivityTaskCanceledByIdRequest) GetRunId() string

func (*RespondActivityTaskCanceledByIdRequest) GetWorkflowId 

func (m *RespondActivityTaskCanceledByIdRequest) GetWorkflowId() string

func (*RespondActivityTaskCanceledByIdRequest) GoString 

func (this *RespondActivityTaskCanceledByIdRequest) GoString() string

func (*RespondActivityTaskCanceledByIdRequest) Marshal 

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

func (*RespondActivityTaskCanceledByIdRequest) MarshalTo 

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

func (*RespondActivityTaskCanceledByIdRequest) MarshalToSizedBuffer 

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

func (*RespondActivityTaskCanceledByIdRequest) ProtoMessage 

func (*RespondActivityTaskCanceledByIdRequest) ProtoMessage()

func (*RespondActivityTaskCanceledByIdRequest) Reset 

func (m *RespondActivityTaskCanceledByIdRequest) Reset()

func (*RespondActivityTaskCanceledByIdRequest) Size 

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

func (*RespondActivityTaskCanceledByIdRequest) String 

func (this *RespondActivityTaskCanceledByIdRequest) String() string

func (*RespondActivityTaskCanceledByIdRequest) Unmarshal 

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

func (*RespondActivityTaskCanceledByIdRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskCanceledByIdRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledByIdRequest) XXX_Marshal 

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

func (*RespondActivityTaskCanceledByIdRequest) XXX_Merge 

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

func (*RespondActivityTaskCanceledByIdRequest) XXX_Size 

func (m *RespondActivityTaskCanceledByIdRequest) XXX_Size() int

func (*RespondActivityTaskCanceledByIdRequest) XXX_Unmarshal 

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

type RespondActivityTaskCanceledByIdResponse 

type RespondActivityTaskCanceledByIdResponse struct {
}

func (*RespondActivityTaskCanceledByIdResponse) Descriptor 

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

func (*RespondActivityTaskCanceledByIdResponse) Equal 

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

func (*RespondActivityTaskCanceledByIdResponse) GoString 

func (this *RespondActivityTaskCanceledByIdResponse) GoString() string

func (*RespondActivityTaskCanceledByIdResponse) Marshal 

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

func (*RespondActivityTaskCanceledByIdResponse) MarshalTo 

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

func (*RespondActivityTaskCanceledByIdResponse) MarshalToSizedBuffer 

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

func (*RespondActivityTaskCanceledByIdResponse) ProtoMessage 

func (*RespondActivityTaskCanceledByIdResponse) ProtoMessage()

func (*RespondActivityTaskCanceledByIdResponse) Reset 

func (m *RespondActivityTaskCanceledByIdResponse) Reset()

func (*RespondActivityTaskCanceledByIdResponse) Size 

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

func (*RespondActivityTaskCanceledByIdResponse) String 

func (this *RespondActivityTaskCanceledByIdResponse) String() string

func (*RespondActivityTaskCanceledByIdResponse) Unmarshal 

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

func (*RespondActivityTaskCanceledByIdResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskCanceledByIdResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledByIdResponse) XXX_Marshal 

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

func (*RespondActivityTaskCanceledByIdResponse) XXX_Merge 

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

func (*RespondActivityTaskCanceledByIdResponse) XXX_Size 

func (m *RespondActivityTaskCanceledByIdResponse) XXX_Size() int

func (*RespondActivityTaskCanceledByIdResponse) XXX_Unmarshal 

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

type RespondActivityTaskCanceledRequest 

type RespondActivityTaskCanceledRequest struct {
	TaskToken []byte        `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	Details   *v13.Payloads `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	Identity  string        `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskCanceledRequest) Descriptor 

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

func (*RespondActivityTaskCanceledRequest) Equal 

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

func (*RespondActivityTaskCanceledRequest) GetDetails 

func (m *RespondActivityTaskCanceledRequest) GetDetails() *v13.Payloads

func (*RespondActivityTaskCanceledRequest) GetIdentity 

func (m *RespondActivityTaskCanceledRequest) GetIdentity() string

func (*RespondActivityTaskCanceledRequest) GetTaskToken 

func (m *RespondActivityTaskCanceledRequest) GetTaskToken() []byte

func (*RespondActivityTaskCanceledRequest) GoString 

func (this *RespondActivityTaskCanceledRequest) GoString() string

func (*RespondActivityTaskCanceledRequest) Marshal 

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

func (*RespondActivityTaskCanceledRequest) MarshalTo 

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

func (*RespondActivityTaskCanceledRequest) MarshalToSizedBuffer 

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

func (*RespondActivityTaskCanceledRequest) ProtoMessage 

func (*RespondActivityTaskCanceledRequest) ProtoMessage()

func (*RespondActivityTaskCanceledRequest) Reset 

func (m *RespondActivityTaskCanceledRequest) Reset()

func (*RespondActivityTaskCanceledRequest) Size 

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

func (*RespondActivityTaskCanceledRequest) String 

func (this *RespondActivityTaskCanceledRequest) String() string

func (*RespondActivityTaskCanceledRequest) Unmarshal 

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

func (*RespondActivityTaskCanceledRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskCanceledRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledRequest) XXX_Marshal 

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

func (*RespondActivityTaskCanceledRequest) XXX_Merge 

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

func (*RespondActivityTaskCanceledRequest) XXX_Size 

func (m *RespondActivityTaskCanceledRequest) XXX_Size() int

func (*RespondActivityTaskCanceledRequest) XXX_Unmarshal 

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

type RespondActivityTaskCanceledResponse 

type RespondActivityTaskCanceledResponse struct {
}

func (*RespondActivityTaskCanceledResponse) Descriptor 

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

func (*RespondActivityTaskCanceledResponse) Equal 

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

func (*RespondActivityTaskCanceledResponse) GoString 

func (this *RespondActivityTaskCanceledResponse) GoString() string

func (*RespondActivityTaskCanceledResponse) Marshal 

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

func (*RespondActivityTaskCanceledResponse) MarshalTo 

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

func (*RespondActivityTaskCanceledResponse) MarshalToSizedBuffer 

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

func (*RespondActivityTaskCanceledResponse) ProtoMessage 

func (*RespondActivityTaskCanceledResponse) ProtoMessage()

func (*RespondActivityTaskCanceledResponse) Reset 

func (m *RespondActivityTaskCanceledResponse) Reset()

func (*RespondActivityTaskCanceledResponse) Size 

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

func (*RespondActivityTaskCanceledResponse) String 

func (this *RespondActivityTaskCanceledResponse) String() string

func (*RespondActivityTaskCanceledResponse) Unmarshal 

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

func (*RespondActivityTaskCanceledResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskCanceledResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCanceledResponse) XXX_Marshal 

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

func (*RespondActivityTaskCanceledResponse) XXX_Merge 

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

func (*RespondActivityTaskCanceledResponse) XXX_Size 

func (m *RespondActivityTaskCanceledResponse) XXX_Size() int

func (*RespondActivityTaskCanceledResponse) XXX_Unmarshal 

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

type RespondActivityTaskCompletedByIdRequest 

type RespondActivityTaskCompletedByIdRequest struct {
	Namespace  string        `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId string        `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId      string        `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ActivityId string        `protobuf:"bytes,4,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	Result     *v13.Payloads `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	Identity   string        `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskCompletedByIdRequest) Descriptor 

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

func (*RespondActivityTaskCompletedByIdRequest) Equal 

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

func (*RespondActivityTaskCompletedByIdRequest) GetActivityId 

func (m *RespondActivityTaskCompletedByIdRequest) GetActivityId() string

func (*RespondActivityTaskCompletedByIdRequest) GetIdentity 

func (m *RespondActivityTaskCompletedByIdRequest) GetIdentity() string

func (*RespondActivityTaskCompletedByIdRequest) GetNamespace 

func (m *RespondActivityTaskCompletedByIdRequest) GetNamespace() string

func (*RespondActivityTaskCompletedByIdRequest) GetResult 

func (m *RespondActivityTaskCompletedByIdRequest) GetResult() *v13.Payloads

func (*RespondActivityTaskCompletedByIdRequest) GetRunId 

func (m *RespondActivityTaskCompletedByIdRequest) GetRunId() string

func (*RespondActivityTaskCompletedByIdRequest) GetWorkflowId 

func (m *RespondActivityTaskCompletedByIdRequest) GetWorkflowId() string

func (*RespondActivityTaskCompletedByIdRequest) GoString 

func (this *RespondActivityTaskCompletedByIdRequest) GoString() string

func (*RespondActivityTaskCompletedByIdRequest) Marshal 

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

func (*RespondActivityTaskCompletedByIdRequest) MarshalTo 

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

func (*RespondActivityTaskCompletedByIdRequest) MarshalToSizedBuffer 

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

func (*RespondActivityTaskCompletedByIdRequest) ProtoMessage 

func (*RespondActivityTaskCompletedByIdRequest) ProtoMessage()

func (*RespondActivityTaskCompletedByIdRequest) Reset 

func (m *RespondActivityTaskCompletedByIdRequest) Reset()

func (*RespondActivityTaskCompletedByIdRequest) Size 

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

func (*RespondActivityTaskCompletedByIdRequest) String 

func (this *RespondActivityTaskCompletedByIdRequest) String() string

func (*RespondActivityTaskCompletedByIdRequest) Unmarshal 

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

func (*RespondActivityTaskCompletedByIdRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskCompletedByIdRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedByIdRequest) XXX_Marshal 

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

func (*RespondActivityTaskCompletedByIdRequest) XXX_Merge 

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

func (*RespondActivityTaskCompletedByIdRequest) XXX_Size 

func (m *RespondActivityTaskCompletedByIdRequest) XXX_Size() int

func (*RespondActivityTaskCompletedByIdRequest) XXX_Unmarshal 

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

type RespondActivityTaskCompletedByIdResponse 

type RespondActivityTaskCompletedByIdResponse struct {
}

func (*RespondActivityTaskCompletedByIdResponse) Descriptor 

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

func (*RespondActivityTaskCompletedByIdResponse) Equal 

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

func (*RespondActivityTaskCompletedByIdResponse) GoString 

func (this *RespondActivityTaskCompletedByIdResponse) GoString() string

func (*RespondActivityTaskCompletedByIdResponse) Marshal 

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

func (*RespondActivityTaskCompletedByIdResponse) MarshalTo 

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

func (*RespondActivityTaskCompletedByIdResponse) MarshalToSizedBuffer 

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

func (*RespondActivityTaskCompletedByIdResponse) ProtoMessage 

func (*RespondActivityTaskCompletedByIdResponse) ProtoMessage()

func (*RespondActivityTaskCompletedByIdResponse) Reset 

func (m *RespondActivityTaskCompletedByIdResponse) Reset()

func (*RespondActivityTaskCompletedByIdResponse) Size 

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

func (*RespondActivityTaskCompletedByIdResponse) String 

func (this *RespondActivityTaskCompletedByIdResponse) String() string

func (*RespondActivityTaskCompletedByIdResponse) Unmarshal 

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

func (*RespondActivityTaskCompletedByIdResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskCompletedByIdResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedByIdResponse) XXX_Marshal 

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

func (*RespondActivityTaskCompletedByIdResponse) XXX_Merge 

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

func (*RespondActivityTaskCompletedByIdResponse) XXX_Size 

func (m *RespondActivityTaskCompletedByIdResponse) XXX_Size() int

func (*RespondActivityTaskCompletedByIdResponse) XXX_Unmarshal 

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

type RespondActivityTaskCompletedRequest 

type RespondActivityTaskCompletedRequest struct {
	TaskToken []byte        `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	Result    *v13.Payloads `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	Identity  string        `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskCompletedRequest) Descriptor 

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

func (*RespondActivityTaskCompletedRequest) Equal 

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

func (*RespondActivityTaskCompletedRequest) GetIdentity 

func (m *RespondActivityTaskCompletedRequest) GetIdentity() string

func (*RespondActivityTaskCompletedRequest) GetResult 

func (m *RespondActivityTaskCompletedRequest) GetResult() *v13.Payloads

func (*RespondActivityTaskCompletedRequest) GetTaskToken 

func (m *RespondActivityTaskCompletedRequest) GetTaskToken() []byte

func (*RespondActivityTaskCompletedRequest) GoString 

func (this *RespondActivityTaskCompletedRequest) GoString() string

func (*RespondActivityTaskCompletedRequest) Marshal 

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

func (*RespondActivityTaskCompletedRequest) MarshalTo 

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

func (*RespondActivityTaskCompletedRequest) MarshalToSizedBuffer 

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

func (*RespondActivityTaskCompletedRequest) ProtoMessage 

func (*RespondActivityTaskCompletedRequest) ProtoMessage()

func (*RespondActivityTaskCompletedRequest) Reset 

func (m *RespondActivityTaskCompletedRequest) Reset()

func (*RespondActivityTaskCompletedRequest) Size 

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

func (*RespondActivityTaskCompletedRequest) String 

func (this *RespondActivityTaskCompletedRequest) String() string

func (*RespondActivityTaskCompletedRequest) Unmarshal 

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

func (*RespondActivityTaskCompletedRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedRequest) XXX_Marshal 

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

func (*RespondActivityTaskCompletedRequest) XXX_Merge 

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

func (*RespondActivityTaskCompletedRequest) XXX_Size 

func (m *RespondActivityTaskCompletedRequest) XXX_Size() int

func (*RespondActivityTaskCompletedRequest) XXX_Unmarshal 

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

type RespondActivityTaskCompletedResponse 

type RespondActivityTaskCompletedResponse struct {
}

func (*RespondActivityTaskCompletedResponse) Descriptor 

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

func (*RespondActivityTaskCompletedResponse) Equal 

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

func (*RespondActivityTaskCompletedResponse) GoString 

func (this *RespondActivityTaskCompletedResponse) GoString() string

func (*RespondActivityTaskCompletedResponse) Marshal 

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

func (*RespondActivityTaskCompletedResponse) MarshalTo 

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

func (*RespondActivityTaskCompletedResponse) MarshalToSizedBuffer 

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

func (*RespondActivityTaskCompletedResponse) ProtoMessage 

func (*RespondActivityTaskCompletedResponse) ProtoMessage()

func (*RespondActivityTaskCompletedResponse) Reset 

func (m *RespondActivityTaskCompletedResponse) Reset()

func (*RespondActivityTaskCompletedResponse) Size 

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

func (*RespondActivityTaskCompletedResponse) String 

func (this *RespondActivityTaskCompletedResponse) String() string

func (*RespondActivityTaskCompletedResponse) Unmarshal 

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

func (*RespondActivityTaskCompletedResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskCompletedResponse) XXX_Marshal 

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

func (*RespondActivityTaskCompletedResponse) XXX_Merge 

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

func (*RespondActivityTaskCompletedResponse) XXX_Size 

func (m *RespondActivityTaskCompletedResponse) XXX_Size() int

func (*RespondActivityTaskCompletedResponse) XXX_Unmarshal 

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

type RespondActivityTaskFailedByIdRequest 

type RespondActivityTaskFailedByIdRequest struct {
	Namespace  string       `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId string       `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	RunId      string       `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ActivityId string       `protobuf:"bytes,4,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	Failure    *v18.Failure `protobuf:"bytes,5,opt,name=failure,proto3" json:"failure,omitempty"`
	Identity   string       `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskFailedByIdRequest) Descriptor 

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

func (*RespondActivityTaskFailedByIdRequest) Equal 

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

func (*RespondActivityTaskFailedByIdRequest) GetActivityId 

func (m *RespondActivityTaskFailedByIdRequest) GetActivityId() string

func (*RespondActivityTaskFailedByIdRequest) GetFailure 

func (m *RespondActivityTaskFailedByIdRequest) GetFailure() *v18.Failure

func (*RespondActivityTaskFailedByIdRequest) GetIdentity 

func (m *RespondActivityTaskFailedByIdRequest) GetIdentity() string

func (*RespondActivityTaskFailedByIdRequest) GetNamespace 

func (m *RespondActivityTaskFailedByIdRequest) GetNamespace() string

func (*RespondActivityTaskFailedByIdRequest) GetRunId 

func (m *RespondActivityTaskFailedByIdRequest) GetRunId() string

func (*RespondActivityTaskFailedByIdRequest) GetWorkflowId 

func (m *RespondActivityTaskFailedByIdRequest) GetWorkflowId() string

func (*RespondActivityTaskFailedByIdRequest) GoString 

func (this *RespondActivityTaskFailedByIdRequest) GoString() string

func (*RespondActivityTaskFailedByIdRequest) Marshal 

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

func (*RespondActivityTaskFailedByIdRequest) MarshalTo 

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

func (*RespondActivityTaskFailedByIdRequest) MarshalToSizedBuffer 

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

func (*RespondActivityTaskFailedByIdRequest) ProtoMessage 

func (*RespondActivityTaskFailedByIdRequest) ProtoMessage()

func (*RespondActivityTaskFailedByIdRequest) Reset 

func (m *RespondActivityTaskFailedByIdRequest) Reset()

func (*RespondActivityTaskFailedByIdRequest) Size 

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

func (*RespondActivityTaskFailedByIdRequest) String 

func (this *RespondActivityTaskFailedByIdRequest) String() string

func (*RespondActivityTaskFailedByIdRequest) Unmarshal 

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

func (*RespondActivityTaskFailedByIdRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskFailedByIdRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedByIdRequest) XXX_Marshal 

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

func (*RespondActivityTaskFailedByIdRequest) XXX_Merge 

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

func (*RespondActivityTaskFailedByIdRequest) XXX_Size 

func (m *RespondActivityTaskFailedByIdRequest) XXX_Size() int

func (*RespondActivityTaskFailedByIdRequest) XXX_Unmarshal 

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

type RespondActivityTaskFailedByIdResponse 

type RespondActivityTaskFailedByIdResponse struct {
}

func (*RespondActivityTaskFailedByIdResponse) Descriptor 

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

func (*RespondActivityTaskFailedByIdResponse) Equal 

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

func (*RespondActivityTaskFailedByIdResponse) GoString 

func (this *RespondActivityTaskFailedByIdResponse) GoString() string

func (*RespondActivityTaskFailedByIdResponse) Marshal 

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

func (*RespondActivityTaskFailedByIdResponse) MarshalTo 

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

func (*RespondActivityTaskFailedByIdResponse) MarshalToSizedBuffer 

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

func (*RespondActivityTaskFailedByIdResponse) ProtoMessage 

func (*RespondActivityTaskFailedByIdResponse) ProtoMessage()

func (*RespondActivityTaskFailedByIdResponse) Reset 

func (m *RespondActivityTaskFailedByIdResponse) Reset()

func (*RespondActivityTaskFailedByIdResponse) Size 

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

func (*RespondActivityTaskFailedByIdResponse) String 

func (this *RespondActivityTaskFailedByIdResponse) String() string

func (*RespondActivityTaskFailedByIdResponse) Unmarshal 

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

func (*RespondActivityTaskFailedByIdResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskFailedByIdResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedByIdResponse) XXX_Marshal 

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

func (*RespondActivityTaskFailedByIdResponse) XXX_Merge 

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

func (*RespondActivityTaskFailedByIdResponse) XXX_Size 

func (m *RespondActivityTaskFailedByIdResponse) XXX_Size() int

func (*RespondActivityTaskFailedByIdResponse) XXX_Unmarshal 

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

type RespondActivityTaskFailedRequest 

type RespondActivityTaskFailedRequest struct {
	TaskToken []byte       `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	Failure   *v18.Failure `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"`
	Identity  string       `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
}

func (*RespondActivityTaskFailedRequest) Descriptor 

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

func (*RespondActivityTaskFailedRequest) Equal 

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

func (*RespondActivityTaskFailedRequest) GetFailure 

func (m *RespondActivityTaskFailedRequest) GetFailure() *v18.Failure

func (*RespondActivityTaskFailedRequest) GetIdentity 

func (m *RespondActivityTaskFailedRequest) GetIdentity() string

func (*RespondActivityTaskFailedRequest) GetTaskToken 

func (m *RespondActivityTaskFailedRequest) GetTaskToken() []byte

func (*RespondActivityTaskFailedRequest) GoString 

func (this *RespondActivityTaskFailedRequest) GoString() string

func (*RespondActivityTaskFailedRequest) Marshal 

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

func (*RespondActivityTaskFailedRequest) MarshalTo 

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

func (*RespondActivityTaskFailedRequest) MarshalToSizedBuffer 

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

func (*RespondActivityTaskFailedRequest) ProtoMessage 

func (*RespondActivityTaskFailedRequest) ProtoMessage()

func (*RespondActivityTaskFailedRequest) Reset 

func (m *RespondActivityTaskFailedRequest) Reset()

func (*RespondActivityTaskFailedRequest) Size 

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

func (*RespondActivityTaskFailedRequest) String 

func (this *RespondActivityTaskFailedRequest) String() string

func (*RespondActivityTaskFailedRequest) Unmarshal 

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

func (*RespondActivityTaskFailedRequest) XXX_DiscardUnknown 

func (m *RespondActivityTaskFailedRequest) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedRequest) XXX_Marshal 

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

func (*RespondActivityTaskFailedRequest) XXX_Merge 

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

func (*RespondActivityTaskFailedRequest) XXX_Size 

func (m *RespondActivityTaskFailedRequest) XXX_Size() int

func (*RespondActivityTaskFailedRequest) XXX_Unmarshal 

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

type RespondActivityTaskFailedResponse 

type RespondActivityTaskFailedResponse struct {
}

func (*RespondActivityTaskFailedResponse) Descriptor 

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

func (*RespondActivityTaskFailedResponse) Equal 

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

func (*RespondActivityTaskFailedResponse) GoString 

func (this *RespondActivityTaskFailedResponse) GoString() string

func (*RespondActivityTaskFailedResponse) Marshal 

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

func (*RespondActivityTaskFailedResponse) MarshalTo 

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

func (*RespondActivityTaskFailedResponse) MarshalToSizedBuffer 

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

func (*RespondActivityTaskFailedResponse) ProtoMessage 

func (*RespondActivityTaskFailedResponse) ProtoMessage()

func (*RespondActivityTaskFailedResponse) Reset 

func (m *RespondActivityTaskFailedResponse) Reset()

func (*RespondActivityTaskFailedResponse) Size 

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

func (*RespondActivityTaskFailedResponse) String 

func (this *RespondActivityTaskFailedResponse) String() string

func (*RespondActivityTaskFailedResponse) Unmarshal 

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

func (*RespondActivityTaskFailedResponse) XXX_DiscardUnknown 

func (m *RespondActivityTaskFailedResponse) XXX_DiscardUnknown()

func (*RespondActivityTaskFailedResponse) XXX_Marshal 

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

func (*RespondActivityTaskFailedResponse) XXX_Merge 

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

func (*RespondActivityTaskFailedResponse) XXX_Size 

func (m *RespondActivityTaskFailedResponse) XXX_Size() int

func (*RespondActivityTaskFailedResponse) XXX_Unmarshal 

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

type RespondQueryTaskCompletedRequest 

type RespondQueryTaskCompletedRequest struct {
	TaskToken         []byte                  `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	CompletedType     v11.QueryResultType     `` /* 144-byte string literal not displayed */
	QueryResult       *v13.Payloads           `protobuf:"bytes,3,opt,name=query_result,json=queryResult,proto3" json:"query_result,omitempty"`
	ErrorMessage      string                  `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	WorkerVersionInfo *v111.WorkerVersionInfo `protobuf:"bytes,5,opt,name=worker_version_info,json=workerVersionInfo,proto3" json:"worker_version_info,omitempty"`
}

TODO: deprecated APIs

func (*RespondQueryTaskCompletedRequest) Descriptor 

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

func (*RespondQueryTaskCompletedRequest) Equal 

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

func (*RespondQueryTaskCompletedRequest) GetCompletedType 

func (m *RespondQueryTaskCompletedRequest) GetCompletedType() v11.QueryResultType

func (*RespondQueryTaskCompletedRequest) GetErrorMessage 

func (m *RespondQueryTaskCompletedRequest) GetErrorMessage() string

func (*RespondQueryTaskCompletedRequest) GetQueryResult 

func (m *RespondQueryTaskCompletedRequest) GetQueryResult() *v13.Payloads

func (*RespondQueryTaskCompletedRequest) GetTaskToken 

func (m *RespondQueryTaskCompletedRequest) GetTaskToken() []byte

func (*RespondQueryTaskCompletedRequest) GetWorkerVersionInfo 

func (m *RespondQueryTaskCompletedRequest) GetWorkerVersionInfo() *v111.WorkerVersionInfo

func (*RespondQueryTaskCompletedRequest) GoString 

func (this *RespondQueryTaskCompletedRequest) GoString() string

func (*RespondQueryTaskCompletedRequest) Marshal 

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

func (*RespondQueryTaskCompletedRequest) MarshalTo 

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

func (*RespondQueryTaskCompletedRequest) MarshalToSizedBuffer 

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

func (*RespondQueryTaskCompletedRequest) ProtoMessage 

func (*RespondQueryTaskCompletedRequest) ProtoMessage()

func (*RespondQueryTaskCompletedRequest) Reset 

func (m *RespondQueryTaskCompletedRequest) Reset()

func (*RespondQueryTaskCompletedRequest) Size 

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

func (*RespondQueryTaskCompletedRequest) String 

func (this *RespondQueryTaskCompletedRequest) String() string

func (*RespondQueryTaskCompletedRequest) Unmarshal 

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

func (*RespondQueryTaskCompletedRequest) XXX_DiscardUnknown 

func (m *RespondQueryTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondQueryTaskCompletedRequest) XXX_Marshal 

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

func (*RespondQueryTaskCompletedRequest) XXX_Merge 

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

func (*RespondQueryTaskCompletedRequest) XXX_Size 

func (m *RespondQueryTaskCompletedRequest) XXX_Size() int

func (*RespondQueryTaskCompletedRequest) XXX_Unmarshal 

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

type RespondQueryTaskCompletedResponse 

type RespondQueryTaskCompletedResponse struct {
}

func (*RespondQueryTaskCompletedResponse) Descriptor 

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

func (*RespondQueryTaskCompletedResponse) Equal 

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

func (*RespondQueryTaskCompletedResponse) GoString 

func (this *RespondQueryTaskCompletedResponse) GoString() string

func (*RespondQueryTaskCompletedResponse) Marshal 

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

func (*RespondQueryTaskCompletedResponse) MarshalTo 

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

func (*RespondQueryTaskCompletedResponse) MarshalToSizedBuffer 

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

func (*RespondQueryTaskCompletedResponse) ProtoMessage 

func (*RespondQueryTaskCompletedResponse) ProtoMessage()

func (*RespondQueryTaskCompletedResponse) Reset 

func (m *RespondQueryTaskCompletedResponse) Reset()

func (*RespondQueryTaskCompletedResponse) Size 

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

func (*RespondQueryTaskCompletedResponse) String 

func (this *RespondQueryTaskCompletedResponse) String() string

func (*RespondQueryTaskCompletedResponse) Unmarshal 

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

func (*RespondQueryTaskCompletedResponse) XXX_DiscardUnknown 

func (m *RespondQueryTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondQueryTaskCompletedResponse) XXX_Marshal 

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

func (*RespondQueryTaskCompletedResponse) XXX_Merge 

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

func (*RespondQueryTaskCompletedResponse) XXX_Size 

func (m *RespondQueryTaskCompletedResponse) XXX_Size() int

func (*RespondQueryTaskCompletedResponse) XXX_Unmarshal 

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

type RespondWorkflowTaskCompletedRequest 

type RespondWorkflowTaskCompletedRequest struct {
	TaskToken                  []byte                              `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	Commands                   []*v17.Command                      `protobuf:"bytes,2,rep,name=commands,proto3" json:"commands,omitempty"`
	Identity                   string                              `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	StickyAttributes           *v14.StickyExecutionAttributes      `protobuf:"bytes,4,opt,name=sticky_attributes,json=stickyAttributes,proto3" json:"sticky_attributes,omitempty"`
	ReturnNewWorkflowTask      bool                                `` /* 129-byte string literal not displayed */
	ForceCreateNewWorkflowTask bool                                `` /* 146-byte string literal not displayed */
	BinaryChecksum             string                              `protobuf:"bytes,7,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
	QueryResults               map[string]*v16.WorkflowQueryResult `` /* 185-byte string literal not displayed */
}

func (*RespondWorkflowTaskCompletedRequest) Descriptor 

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

func (*RespondWorkflowTaskCompletedRequest) Equal 

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

func (*RespondWorkflowTaskCompletedRequest) GetBinaryChecksum 

func (m *RespondWorkflowTaskCompletedRequest) GetBinaryChecksum() string

func (*RespondWorkflowTaskCompletedRequest) GetCommands 

func (m *RespondWorkflowTaskCompletedRequest) GetCommands() []*v17.Command

func (*RespondWorkflowTaskCompletedRequest) GetForceCreateNewWorkflowTask 

func (m *RespondWorkflowTaskCompletedRequest) GetForceCreateNewWorkflowTask() bool

func (*RespondWorkflowTaskCompletedRequest) GetIdentity 

func (m *RespondWorkflowTaskCompletedRequest) GetIdentity() string

func (*RespondWorkflowTaskCompletedRequest) GetQueryResults 

func (m *RespondWorkflowTaskCompletedRequest) GetQueryResults() map[string]*v16.WorkflowQueryResult

func (*RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask 

func (m *RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask() bool

func (*RespondWorkflowTaskCompletedRequest) GetStickyAttributes 

func (m *RespondWorkflowTaskCompletedRequest) GetStickyAttributes() *v14.StickyExecutionAttributes

func (*RespondWorkflowTaskCompletedRequest) GetTaskToken 

func (m *RespondWorkflowTaskCompletedRequest) GetTaskToken() []byte

func (*RespondWorkflowTaskCompletedRequest) GoString 

func (this *RespondWorkflowTaskCompletedRequest) GoString() string

func (*RespondWorkflowTaskCompletedRequest) Marshal 

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

func (*RespondWorkflowTaskCompletedRequest) MarshalTo 

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

func (*RespondWorkflowTaskCompletedRequest) MarshalToSizedBuffer 

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

func (*RespondWorkflowTaskCompletedRequest) ProtoMessage 

func (*RespondWorkflowTaskCompletedRequest) ProtoMessage()

func (*RespondWorkflowTaskCompletedRequest) Reset 

func (m *RespondWorkflowTaskCompletedRequest) Reset()

func (*RespondWorkflowTaskCompletedRequest) Size 

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

func (*RespondWorkflowTaskCompletedRequest) String 

func (this *RespondWorkflowTaskCompletedRequest) String() string

func (*RespondWorkflowTaskCompletedRequest) Unmarshal 

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

func (*RespondWorkflowTaskCompletedRequest) XXX_DiscardUnknown 

func (m *RespondWorkflowTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondWorkflowTaskCompletedRequest) XXX_Marshal 

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

func (*RespondWorkflowTaskCompletedRequest) XXX_Merge 

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

func (*RespondWorkflowTaskCompletedRequest) XXX_Size 

func (m *RespondWorkflowTaskCompletedRequest) XXX_Size() int

func (*RespondWorkflowTaskCompletedRequest) XXX_Unmarshal 

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

type RespondWorkflowTaskCompletedResponse 

type RespondWorkflowTaskCompletedResponse struct {
	WorkflowTask *PollWorkflowTaskQueueResponse `protobuf:"bytes,1,opt,name=workflow_task,json=workflowTask,proto3" json:"workflow_task,omitempty"`
}

func (*RespondWorkflowTaskCompletedResponse) Descriptor 

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

func (*RespondWorkflowTaskCompletedResponse) Equal 

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

func (*RespondWorkflowTaskCompletedResponse) GetWorkflowTask 

func (m *RespondWorkflowTaskCompletedResponse) GetWorkflowTask() *PollWorkflowTaskQueueResponse

func (*RespondWorkflowTaskCompletedResponse) GoString 

func (this *RespondWorkflowTaskCompletedResponse) GoString() string

func (*RespondWorkflowTaskCompletedResponse) Marshal 

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

func (*RespondWorkflowTaskCompletedResponse) MarshalTo 

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

func (*RespondWorkflowTaskCompletedResponse) MarshalToSizedBuffer 

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

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage 

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage()

func (*RespondWorkflowTaskCompletedResponse) Reset 

func (m *RespondWorkflowTaskCompletedResponse) Reset()

func (*RespondWorkflowTaskCompletedResponse) Size 

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

func (*RespondWorkflowTaskCompletedResponse) String 

func (this *RespondWorkflowTaskCompletedResponse) String() string

func (*RespondWorkflowTaskCompletedResponse) Unmarshal 

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

func (*RespondWorkflowTaskCompletedResponse) XXX_DiscardUnknown 

func (m *RespondWorkflowTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondWorkflowTaskCompletedResponse) XXX_Marshal 

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

func (*RespondWorkflowTaskCompletedResponse) XXX_Merge 

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

func (*RespondWorkflowTaskCompletedResponse) XXX_Size 

func (m *RespondWorkflowTaskCompletedResponse) XXX_Size() int

func (*RespondWorkflowTaskCompletedResponse) XXX_Unmarshal 

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

type RespondWorkflowTaskFailedRequest 

type RespondWorkflowTaskFailedRequest struct {
	TaskToken      []byte                      `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	Cause          v11.WorkflowTaskFailedCause `protobuf:"varint,2,opt,name=cause,proto3,enum=temporal.api.enums.v1.WorkflowTaskFailedCause" json:"cause,omitempty"`
	Failure        *v18.Failure                `protobuf:"bytes,3,opt,name=failure,proto3" json:"failure,omitempty"`
	Identity       string                      `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	BinaryChecksum string                      `protobuf:"bytes,5,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
}

func (*RespondWorkflowTaskFailedRequest) Descriptor 

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

func (*RespondWorkflowTaskFailedRequest) Equal 

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

func (*RespondWorkflowTaskFailedRequest) GetBinaryChecksum 

func (m *RespondWorkflowTaskFailedRequest) GetBinaryChecksum() string

func (*RespondWorkflowTaskFailedRequest) GetCause 

func (m *RespondWorkflowTaskFailedRequest) GetCause() v11.WorkflowTaskFailedCause

func (*RespondWorkflowTaskFailedRequest) GetFailure 

func (m *RespondWorkflowTaskFailedRequest) GetFailure() *v18.Failure

func (*RespondWorkflowTaskFailedRequest) GetIdentity 

func (m *RespondWorkflowTaskFailedRequest) GetIdentity() string

func (*RespondWorkflowTaskFailedRequest) GetTaskToken 

func (m *RespondWorkflowTaskFailedRequest) GetTaskToken() []byte

func (*RespondWorkflowTaskFailedRequest) GoString 

func (this *RespondWorkflowTaskFailedRequest) GoString() string

func (*RespondWorkflowTaskFailedRequest) Marshal 

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

func (*RespondWorkflowTaskFailedRequest) MarshalTo 

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

func (*RespondWorkflowTaskFailedRequest) MarshalToSizedBuffer 

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

func (*RespondWorkflowTaskFailedRequest) ProtoMessage 

func (*RespondWorkflowTaskFailedRequest) ProtoMessage()

func (*RespondWorkflowTaskFailedRequest) Reset 

func (m *RespondWorkflowTaskFailedRequest) Reset()

func (*RespondWorkflowTaskFailedRequest) Size 

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

func (*RespondWorkflowTaskFailedRequest) String 

func (this *RespondWorkflowTaskFailedRequest) String() string

func (*RespondWorkflowTaskFailedRequest) Unmarshal 

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

func (*RespondWorkflowTaskFailedRequest) XXX_DiscardUnknown 

func (m *RespondWorkflowTaskFailedRequest) XXX_DiscardUnknown()

func (*RespondWorkflowTaskFailedRequest) XXX_Marshal 

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

func (*RespondWorkflowTaskFailedRequest) XXX_Merge 

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

func (*RespondWorkflowTaskFailedRequest) XXX_Size 

func (m *RespondWorkflowTaskFailedRequest) XXX_Size() int

func (*RespondWorkflowTaskFailedRequest) XXX_Unmarshal 

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

type RespondWorkflowTaskFailedResponse 

type RespondWorkflowTaskFailedResponse struct {
}

func (*RespondWorkflowTaskFailedResponse) Descriptor 

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

func (*RespondWorkflowTaskFailedResponse) Equal 

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

func (*RespondWorkflowTaskFailedResponse) GoString 

func (this *RespondWorkflowTaskFailedResponse) GoString() string

func (*RespondWorkflowTaskFailedResponse) Marshal 

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

func (*RespondWorkflowTaskFailedResponse) MarshalTo 

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

func (*RespondWorkflowTaskFailedResponse) MarshalToSizedBuffer 

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

func (*RespondWorkflowTaskFailedResponse) ProtoMessage 

func (*RespondWorkflowTaskFailedResponse) ProtoMessage()

func (*RespondWorkflowTaskFailedResponse) Reset 

func (m *RespondWorkflowTaskFailedResponse) Reset()

func (*RespondWorkflowTaskFailedResponse) Size 

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

func (*RespondWorkflowTaskFailedResponse) String 

func (this *RespondWorkflowTaskFailedResponse) String() string

func (*RespondWorkflowTaskFailedResponse) Unmarshal 

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

func (*RespondWorkflowTaskFailedResponse) XXX_DiscardUnknown 

func (m *RespondWorkflowTaskFailedResponse) XXX_DiscardUnknown()

func (*RespondWorkflowTaskFailedResponse) XXX_Marshal 

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

func (*RespondWorkflowTaskFailedResponse) XXX_Merge 

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

func (*RespondWorkflowTaskFailedResponse) XXX_Size 

func (m *RespondWorkflowTaskFailedResponse) XXX_Size() int

func (*RespondWorkflowTaskFailedResponse) XXX_Unmarshal 

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

type ScanWorkflowExecutionsRequest 

type ScanWorkflowExecutionsRequest struct {
	Namespace     string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PageSize      int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	NextPageToken []byte `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	Query         string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
}

func (*ScanWorkflowExecutionsRequest) Descriptor 

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

func (*ScanWorkflowExecutionsRequest) Equal 

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

func (*ScanWorkflowExecutionsRequest) GetNamespace 

func (m *ScanWorkflowExecutionsRequest) GetNamespace() string

func (*ScanWorkflowExecutionsRequest) GetNextPageToken 

func (m *ScanWorkflowExecutionsRequest) GetNextPageToken() []byte

func (*ScanWorkflowExecutionsRequest) GetPageSize 

func (m *ScanWorkflowExecutionsRequest) GetPageSize() int32

func (*ScanWorkflowExecutionsRequest) GetQuery 

func (m *ScanWorkflowExecutionsRequest) GetQuery() string

func (*ScanWorkflowExecutionsRequest) GoString 

func (this *ScanWorkflowExecutionsRequest) GoString() string

func (*ScanWorkflowExecutionsRequest) Marshal 

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

func (*ScanWorkflowExecutionsRequest) MarshalTo 

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

func (*ScanWorkflowExecutionsRequest) MarshalToSizedBuffer 

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

func (*ScanWorkflowExecutionsRequest) ProtoMessage 

func (*ScanWorkflowExecutionsRequest) ProtoMessage()

func (*ScanWorkflowExecutionsRequest) Reset 

func (m *ScanWorkflowExecutionsRequest) Reset()

func (*ScanWorkflowExecutionsRequest) Size 

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

func (*ScanWorkflowExecutionsRequest) String 

func (this *ScanWorkflowExecutionsRequest) String() string

func (*ScanWorkflowExecutionsRequest) Unmarshal 

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

func (*ScanWorkflowExecutionsRequest) XXX_DiscardUnknown 

func (m *ScanWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ScanWorkflowExecutionsRequest) XXX_Marshal 

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

func (*ScanWorkflowExecutionsRequest) XXX_Merge 

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

func (*ScanWorkflowExecutionsRequest) XXX_Size 

func (m *ScanWorkflowExecutionsRequest) XXX_Size() int

func (*ScanWorkflowExecutionsRequest) XXX_Unmarshal 

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

type ScanWorkflowExecutionsResponse 

type ScanWorkflowExecutionsResponse struct {
	Executions    []*v110.WorkflowExecutionInfo `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	NextPageToken []byte                        `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*ScanWorkflowExecutionsResponse) Descriptor 

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

func (*ScanWorkflowExecutionsResponse) Equal 

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

func (*ScanWorkflowExecutionsResponse) GetExecutions 

func (m *ScanWorkflowExecutionsResponse) GetExecutions() []*v110.WorkflowExecutionInfo

func (*ScanWorkflowExecutionsResponse) GetNextPageToken 

func (m *ScanWorkflowExecutionsResponse) GetNextPageToken() []byte

func (*ScanWorkflowExecutionsResponse) GoString 

func (this *ScanWorkflowExecutionsResponse) GoString() string

func (*ScanWorkflowExecutionsResponse) Marshal 

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

func (*ScanWorkflowExecutionsResponse) MarshalTo 

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

func (*ScanWorkflowExecutionsResponse) MarshalToSizedBuffer 

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

func (*ScanWorkflowExecutionsResponse) ProtoMessage 

func (*ScanWorkflowExecutionsResponse) ProtoMessage()

func (*ScanWorkflowExecutionsResponse) Reset 

func (m *ScanWorkflowExecutionsResponse) Reset()

func (*ScanWorkflowExecutionsResponse) Size 

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

func (*ScanWorkflowExecutionsResponse) String 

func (this *ScanWorkflowExecutionsResponse) String() string

func (*ScanWorkflowExecutionsResponse) Unmarshal 

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

func (*ScanWorkflowExecutionsResponse) XXX_DiscardUnknown 

func (m *ScanWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ScanWorkflowExecutionsResponse) XXX_Marshal 

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

func (*ScanWorkflowExecutionsResponse) XXX_Merge 

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

func (*ScanWorkflowExecutionsResponse) XXX_Size 

func (m *ScanWorkflowExecutionsResponse) XXX_Size() int

func (*ScanWorkflowExecutionsResponse) XXX_Unmarshal 

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

type SignalWithStartWorkflowExecutionRequest 

type SignalWithStartWorkflowExecutionRequest struct {
	Namespace    string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId   string            `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowType *v13.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskQueue    *v14.TaskQueue    `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Input        *v13.Payloads     `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new
	WorkflowExecutionTimeout *time.Duration `` /* 147-byte string literal not displayed */
	// Timeout of a single workflow run
	WorkflowRunTimeout *time.Duration `` /* 129-byte string literal not displayed */
	// Timeout of a single workflow task
	WorkflowTaskTimeout   *time.Duration            `` /* 132-byte string literal not displayed */
	Identity              string                    `protobuf:"bytes,9,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId             string                    `protobuf:"bytes,10,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	WorkflowIdReusePolicy v11.WorkflowIdReusePolicy `` /* 179-byte string literal not displayed */
	SignalName            string                    `protobuf:"bytes,12,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	SignalInput           *v13.Payloads             `protobuf:"bytes,13,opt,name=signal_input,json=signalInput,proto3" json:"signal_input,omitempty"`
	Control               string                    `protobuf:"bytes,14,opt,name=control,proto3" json:"control,omitempty"`
	// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	RetryPolicy      *v13.RetryPolicy      `protobuf:"bytes,15,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	CronSchedule     string                `protobuf:"bytes,16,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	Memo             *v13.Memo             `protobuf:"bytes,17,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v13.SearchAttributes `protobuf:"bytes,18,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	Header           *v13.Header           `protobuf:"bytes,19,opt,name=header,proto3" json:"header,omitempty"`
}

func (*SignalWithStartWorkflowExecutionRequest) Descriptor 

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

func (*SignalWithStartWorkflowExecutionRequest) Equal 

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

func (*SignalWithStartWorkflowExecutionRequest) GetControl 

func (m *SignalWithStartWorkflowExecutionRequest) GetControl() string

func (*SignalWithStartWorkflowExecutionRequest) GetCronSchedule 

func (m *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() string

func (*SignalWithStartWorkflowExecutionRequest) GetHeader 

func (m *SignalWithStartWorkflowExecutionRequest) GetHeader() *v13.Header

func (*SignalWithStartWorkflowExecutionRequest) GetIdentity 

func (m *SignalWithStartWorkflowExecutionRequest) GetIdentity() string

func (*SignalWithStartWorkflowExecutionRequest) GetInput 

func (m *SignalWithStartWorkflowExecutionRequest) GetInput() *v13.Payloads

func (*SignalWithStartWorkflowExecutionRequest) GetMemo 

func (m *SignalWithStartWorkflowExecutionRequest) GetMemo() *v13.Memo

func (*SignalWithStartWorkflowExecutionRequest) GetNamespace 

func (m *SignalWithStartWorkflowExecutionRequest) GetNamespace() string

func (*SignalWithStartWorkflowExecutionRequest) GetRequestId 

func (m *SignalWithStartWorkflowExecutionRequest) GetRequestId() string

func (*SignalWithStartWorkflowExecutionRequest) GetRetryPolicy 

func (m *SignalWithStartWorkflowExecutionRequest) GetRetryPolicy() *v13.RetryPolicy

func (*SignalWithStartWorkflowExecutionRequest) GetSearchAttributes 

func (m *SignalWithStartWorkflowExecutionRequest) GetSearchAttributes() *v13.SearchAttributes

func (*SignalWithStartWorkflowExecutionRequest) GetSignalInput 

func (m *SignalWithStartWorkflowExecutionRequest) GetSignalInput() *v13.Payloads

func (*SignalWithStartWorkflowExecutionRequest) GetSignalName 

func (m *SignalWithStartWorkflowExecutionRequest) GetSignalName() string

func (*SignalWithStartWorkflowExecutionRequest) GetTaskQueue 

func (m *SignalWithStartWorkflowExecutionRequest) GetTaskQueue() *v14.TaskQueue

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *time.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowId 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowId() string

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout() *time.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *time.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowType 

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowType() *v13.WorkflowType

func (*SignalWithStartWorkflowExecutionRequest) GoString 

func (this *SignalWithStartWorkflowExecutionRequest) GoString() string

func (*SignalWithStartWorkflowExecutionRequest) Marshal 

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

func (*SignalWithStartWorkflowExecutionRequest) MarshalTo 

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

func (*SignalWithStartWorkflowExecutionRequest) MarshalToSizedBuffer 

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

func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage 

func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage()

func (*SignalWithStartWorkflowExecutionRequest) Reset 

func (m *SignalWithStartWorkflowExecutionRequest) Reset()

func (*SignalWithStartWorkflowExecutionRequest) Size 

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

func (*SignalWithStartWorkflowExecutionRequest) String 

func (this *SignalWithStartWorkflowExecutionRequest) String() string

func (*SignalWithStartWorkflowExecutionRequest) Unmarshal 

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

func (*SignalWithStartWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *SignalWithStartWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*SignalWithStartWorkflowExecutionRequest) XXX_Marshal 

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

func (*SignalWithStartWorkflowExecutionRequest) XXX_Merge 

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

func (*SignalWithStartWorkflowExecutionRequest) XXX_Size 

func (m *SignalWithStartWorkflowExecutionRequest) XXX_Size() int

func (*SignalWithStartWorkflowExecutionRequest) XXX_Unmarshal 

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

type SignalWithStartWorkflowExecutionResponse 

type SignalWithStartWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
}

func (*SignalWithStartWorkflowExecutionResponse) Descriptor 

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

func (*SignalWithStartWorkflowExecutionResponse) Equal 

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

func (*SignalWithStartWorkflowExecutionResponse) GetRunId 

func (m *SignalWithStartWorkflowExecutionResponse) GetRunId() string

func (*SignalWithStartWorkflowExecutionResponse) GoString 

func (this *SignalWithStartWorkflowExecutionResponse) GoString() string

func (*SignalWithStartWorkflowExecutionResponse) Marshal 

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

func (*SignalWithStartWorkflowExecutionResponse) MarshalTo 

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

func (*SignalWithStartWorkflowExecutionResponse) MarshalToSizedBuffer 

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

func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage 

func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage()

func (*SignalWithStartWorkflowExecutionResponse) Reset 

func (m *SignalWithStartWorkflowExecutionResponse) Reset()

func (*SignalWithStartWorkflowExecutionResponse) Size 

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

func (*SignalWithStartWorkflowExecutionResponse) String 

func (this *SignalWithStartWorkflowExecutionResponse) String() string

func (*SignalWithStartWorkflowExecutionResponse) Unmarshal 

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

func (*SignalWithStartWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *SignalWithStartWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*SignalWithStartWorkflowExecutionResponse) XXX_Marshal 

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

func (*SignalWithStartWorkflowExecutionResponse) XXX_Merge 

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

func (*SignalWithStartWorkflowExecutionResponse) XXX_Size 

func (m *SignalWithStartWorkflowExecutionResponse) XXX_Size() int

func (*SignalWithStartWorkflowExecutionResponse) XXX_Unmarshal 

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

type SignalWorkflowExecutionRequest 

type SignalWorkflowExecutionRequest struct {
	Namespace         string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	SignalName        string                 `protobuf:"bytes,3,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	Input             *v13.Payloads          `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	Identity          string                 `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId         string                 `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Control           string                 `protobuf:"bytes,7,opt,name=control,proto3" json:"control,omitempty"`
}

func (*SignalWorkflowExecutionRequest) Descriptor 

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

func (*SignalWorkflowExecutionRequest) Equal 

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

func (*SignalWorkflowExecutionRequest) GetControl 

func (m *SignalWorkflowExecutionRequest) GetControl() string

func (*SignalWorkflowExecutionRequest) GetIdentity 

func (m *SignalWorkflowExecutionRequest) GetIdentity() string

func (*SignalWorkflowExecutionRequest) GetInput 

func (m *SignalWorkflowExecutionRequest) GetInput() *v13.Payloads

func (*SignalWorkflowExecutionRequest) GetNamespace 

func (m *SignalWorkflowExecutionRequest) GetNamespace() string

func (*SignalWorkflowExecutionRequest) GetRequestId 

func (m *SignalWorkflowExecutionRequest) GetRequestId() string

func (*SignalWorkflowExecutionRequest) GetSignalName 

func (m *SignalWorkflowExecutionRequest) GetSignalName() string

func (*SignalWorkflowExecutionRequest) GetWorkflowExecution 

func (m *SignalWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

func (*SignalWorkflowExecutionRequest) GoString 

func (this *SignalWorkflowExecutionRequest) GoString() string

func (*SignalWorkflowExecutionRequest) Marshal 

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

func (*SignalWorkflowExecutionRequest) MarshalTo 

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

func (*SignalWorkflowExecutionRequest) MarshalToSizedBuffer 

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

func (*SignalWorkflowExecutionRequest) ProtoMessage 

func (*SignalWorkflowExecutionRequest) ProtoMessage()

func (*SignalWorkflowExecutionRequest) Reset 

func (m *SignalWorkflowExecutionRequest) Reset()

func (*SignalWorkflowExecutionRequest) Size 

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

func (*SignalWorkflowExecutionRequest) String 

func (this *SignalWorkflowExecutionRequest) String() string

func (*SignalWorkflowExecutionRequest) Unmarshal 

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

func (*SignalWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *SignalWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*SignalWorkflowExecutionRequest) XXX_Marshal 

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

func (*SignalWorkflowExecutionRequest) XXX_Merge 

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

func (*SignalWorkflowExecutionRequest) XXX_Size 

func (m *SignalWorkflowExecutionRequest) XXX_Size() int

func (*SignalWorkflowExecutionRequest) XXX_Unmarshal 

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

type SignalWorkflowExecutionResponse 

type SignalWorkflowExecutionResponse struct {
}

func (*SignalWorkflowExecutionResponse) Descriptor 

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

func (*SignalWorkflowExecutionResponse) Equal 

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

func (*SignalWorkflowExecutionResponse) GoString 

func (this *SignalWorkflowExecutionResponse) GoString() string

func (*SignalWorkflowExecutionResponse) Marshal 

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

func (*SignalWorkflowExecutionResponse) MarshalTo 

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

func (*SignalWorkflowExecutionResponse) MarshalToSizedBuffer 

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

func (*SignalWorkflowExecutionResponse) ProtoMessage 

func (*SignalWorkflowExecutionResponse) ProtoMessage()

func (*SignalWorkflowExecutionResponse) Reset 

func (m *SignalWorkflowExecutionResponse) Reset()

func (*SignalWorkflowExecutionResponse) Size 

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

func (*SignalWorkflowExecutionResponse) String 

func (this *SignalWorkflowExecutionResponse) String() string

func (*SignalWorkflowExecutionResponse) Unmarshal 

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

func (*SignalWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *SignalWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*SignalWorkflowExecutionResponse) XXX_Marshal 

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

func (*SignalWorkflowExecutionResponse) XXX_Merge 

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

func (*SignalWorkflowExecutionResponse) XXX_Size 

func (m *SignalWorkflowExecutionResponse) XXX_Size() int

func (*SignalWorkflowExecutionResponse) XXX_Unmarshal 

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

type StartWorkflowExecutionRequest 

type StartWorkflowExecutionRequest struct {
	Namespace    string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId   string            `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowType *v13.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskQueue    *v14.TaskQueue    `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Input        *v13.Payloads     `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new.
	WorkflowExecutionTimeout *time.Duration `` /* 147-byte string literal not displayed */
	// Timeout of a single workflow run.
	WorkflowRunTimeout *time.Duration `` /* 129-byte string literal not displayed */
	// Timeout of a single workflow task.
	WorkflowTaskTimeout *time.Duration `` /* 132-byte string literal not displayed */
	Identity            string         `protobuf:"bytes,9,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId           string         `protobuf:"bytes,10,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	WorkflowIdReusePolicy v11.WorkflowIdReusePolicy `` /* 179-byte string literal not displayed */
	// Retries up to workflow_execution_timeout_seconds.
	RetryPolicy      *v13.RetryPolicy      `protobuf:"bytes,12,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	CronSchedule     string                `protobuf:"bytes,13,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	Memo             *v13.Memo             `protobuf:"bytes,14,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v13.SearchAttributes `protobuf:"bytes,15,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	Header           *v13.Header           `protobuf:"bytes,16,opt,name=header,proto3" json:"header,omitempty"`
}

func (*StartWorkflowExecutionRequest) Descriptor 

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

func (*StartWorkflowExecutionRequest) Equal 

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

func (*StartWorkflowExecutionRequest) GetCronSchedule 

func (m *StartWorkflowExecutionRequest) GetCronSchedule() string

func (*StartWorkflowExecutionRequest) GetHeader 

func (m *StartWorkflowExecutionRequest) GetHeader() *v13.Header

func (*StartWorkflowExecutionRequest) GetIdentity 

func (m *StartWorkflowExecutionRequest) GetIdentity() string

func (*StartWorkflowExecutionRequest) GetInput 

func (m *StartWorkflowExecutionRequest) GetInput() *v13.Payloads

func (*StartWorkflowExecutionRequest) GetMemo 

func (m *StartWorkflowExecutionRequest) GetMemo() *v13.Memo

func (*StartWorkflowExecutionRequest) GetNamespace 

func (m *StartWorkflowExecutionRequest) GetNamespace() string

func (*StartWorkflowExecutionRequest) GetRequestId 

func (m *StartWorkflowExecutionRequest) GetRequestId() string

func (*StartWorkflowExecutionRequest) GetRetryPolicy 

func (m *StartWorkflowExecutionRequest) GetRetryPolicy() *v13.RetryPolicy

func (*StartWorkflowExecutionRequest) GetSearchAttributes 

func (m *StartWorkflowExecutionRequest) GetSearchAttributes() *v13.SearchAttributes

func (*StartWorkflowExecutionRequest) GetTaskQueue 

func (m *StartWorkflowExecutionRequest) GetTaskQueue() *v14.TaskQueue

func (*StartWorkflowExecutionRequest) GetWorkflowExecutionTimeout 

func (m *StartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *time.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowId 

func (m *StartWorkflowExecutionRequest) GetWorkflowId() string

func (*StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy 

func (m *StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

func (*StartWorkflowExecutionRequest) GetWorkflowRunTimeout 

func (m *StartWorkflowExecutionRequest) GetWorkflowRunTimeout() *time.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowTaskTimeout 

func (m *StartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *time.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowType 

func (m *StartWorkflowExecutionRequest) GetWorkflowType() *v13.WorkflowType

func (*StartWorkflowExecutionRequest) GoString 

func (this *StartWorkflowExecutionRequest) GoString() string

func (*StartWorkflowExecutionRequest) Marshal 

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

func (*StartWorkflowExecutionRequest) MarshalTo 

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

func (*StartWorkflowExecutionRequest) MarshalToSizedBuffer 

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

func (*StartWorkflowExecutionRequest) ProtoMessage 

func (*StartWorkflowExecutionRequest) ProtoMessage()

func (*StartWorkflowExecutionRequest) Reset 

func (m *StartWorkflowExecutionRequest) Reset()

func (*StartWorkflowExecutionRequest) Size 

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

func (*StartWorkflowExecutionRequest) String 

func (this *StartWorkflowExecutionRequest) String() string

func (*StartWorkflowExecutionRequest) Unmarshal 

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

func (*StartWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *StartWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*StartWorkflowExecutionRequest) XXX_Marshal 

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

func (*StartWorkflowExecutionRequest) XXX_Merge 

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

func (*StartWorkflowExecutionRequest) XXX_Size 

func (m *StartWorkflowExecutionRequest) XXX_Size() int

func (*StartWorkflowExecutionRequest) XXX_Unmarshal 

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

type StartWorkflowExecutionResponse 

type StartWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
}

func (*StartWorkflowExecutionResponse) Descriptor 

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

func (*StartWorkflowExecutionResponse) Equal 

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

func (*StartWorkflowExecutionResponse) GetRunId 

func (m *StartWorkflowExecutionResponse) GetRunId() string

func (*StartWorkflowExecutionResponse) GoString 

func (this *StartWorkflowExecutionResponse) GoString() string

func (*StartWorkflowExecutionResponse) Marshal 

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

func (*StartWorkflowExecutionResponse) MarshalTo 

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

func (*StartWorkflowExecutionResponse) MarshalToSizedBuffer 

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

func (*StartWorkflowExecutionResponse) ProtoMessage 

func (*StartWorkflowExecutionResponse) ProtoMessage()

func (*StartWorkflowExecutionResponse) Reset 

func (m *StartWorkflowExecutionResponse) Reset()

func (*StartWorkflowExecutionResponse) Size 

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

func (*StartWorkflowExecutionResponse) String 

func (this *StartWorkflowExecutionResponse) String() string

func (*StartWorkflowExecutionResponse) Unmarshal 

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

func (*StartWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *StartWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*StartWorkflowExecutionResponse) XXX_Marshal 

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

func (*StartWorkflowExecutionResponse) XXX_Merge 

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

func (*StartWorkflowExecutionResponse) XXX_Size 

func (m *StartWorkflowExecutionResponse) XXX_Size() int

func (*StartWorkflowExecutionResponse) XXX_Unmarshal 

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

type TerminateWorkflowExecutionRequest 

type TerminateWorkflowExecutionRequest struct {
	Namespace           string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution   *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Reason              string                 `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Details             *v13.Payloads          `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	Identity            string                 `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
	FirstExecutionRunId string                 `protobuf:"bytes,6,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
}

func (*TerminateWorkflowExecutionRequest) Descriptor 

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

func (*TerminateWorkflowExecutionRequest) Equal 

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

func (*TerminateWorkflowExecutionRequest) GetDetails 

func (m *TerminateWorkflowExecutionRequest) GetDetails() *v13.Payloads

func (*TerminateWorkflowExecutionRequest) GetFirstExecutionRunId 

func (m *TerminateWorkflowExecutionRequest) GetFirstExecutionRunId() string

func (*TerminateWorkflowExecutionRequest) GetIdentity 

func (m *TerminateWorkflowExecutionRequest) GetIdentity() string

func (*TerminateWorkflowExecutionRequest) GetNamespace 

func (m *TerminateWorkflowExecutionRequest) GetNamespace() string

func (*TerminateWorkflowExecutionRequest) GetReason 

func (m *TerminateWorkflowExecutionRequest) GetReason() string

func (*TerminateWorkflowExecutionRequest) GetWorkflowExecution 

func (m *TerminateWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

func (*TerminateWorkflowExecutionRequest) GoString 

func (this *TerminateWorkflowExecutionRequest) GoString() string

func (*TerminateWorkflowExecutionRequest) Marshal 

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

func (*TerminateWorkflowExecutionRequest) MarshalTo 

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

func (*TerminateWorkflowExecutionRequest) MarshalToSizedBuffer 

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

func (*TerminateWorkflowExecutionRequest) ProtoMessage 

func (*TerminateWorkflowExecutionRequest) ProtoMessage()

func (*TerminateWorkflowExecutionRequest) Reset 

func (m *TerminateWorkflowExecutionRequest) Reset()

func (*TerminateWorkflowExecutionRequest) Size 

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

func (*TerminateWorkflowExecutionRequest) String 

func (this *TerminateWorkflowExecutionRequest) String() string

func (*TerminateWorkflowExecutionRequest) Unmarshal 

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

func (*TerminateWorkflowExecutionRequest) XXX_DiscardUnknown 

func (m *TerminateWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*TerminateWorkflowExecutionRequest) XXX_Marshal 

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

func (*TerminateWorkflowExecutionRequest) XXX_Merge 

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

func (*TerminateWorkflowExecutionRequest) XXX_Size 

func (m *TerminateWorkflowExecutionRequest) XXX_Size() int

func (*TerminateWorkflowExecutionRequest) XXX_Unmarshal 

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

type TerminateWorkflowExecutionResponse 

type TerminateWorkflowExecutionResponse struct {
}

func (*TerminateWorkflowExecutionResponse) Descriptor 

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

func (*TerminateWorkflowExecutionResponse) Equal 

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

func (*TerminateWorkflowExecutionResponse) GoString 

func (this *TerminateWorkflowExecutionResponse) GoString() string

func (*TerminateWorkflowExecutionResponse) Marshal 

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

func (*TerminateWorkflowExecutionResponse) MarshalTo 

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

func (*TerminateWorkflowExecutionResponse) MarshalToSizedBuffer 

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

func (*TerminateWorkflowExecutionResponse) ProtoMessage 

func (*TerminateWorkflowExecutionResponse) ProtoMessage()

func (*TerminateWorkflowExecutionResponse) Reset 

func (m *TerminateWorkflowExecutionResponse) Reset()

func (*TerminateWorkflowExecutionResponse) Size 

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

func (*TerminateWorkflowExecutionResponse) String 

func (this *TerminateWorkflowExecutionResponse) String() string

func (*TerminateWorkflowExecutionResponse) Unmarshal 

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

func (*TerminateWorkflowExecutionResponse) XXX_DiscardUnknown 

func (m *TerminateWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*TerminateWorkflowExecutionResponse) XXX_Marshal 

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

func (*TerminateWorkflowExecutionResponse) XXX_Merge 

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

func (*TerminateWorkflowExecutionResponse) XXX_Size 

func (m *TerminateWorkflowExecutionResponse) XXX_Size() int

func (*TerminateWorkflowExecutionResponse) XXX_Unmarshal 

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

type UnimplementedWorkflowServiceServer 

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowServiceServer) CountWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) CountWorkflowExecutions(ctx context.Context, req *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) DeprecateNamespace 

func (*UnimplementedWorkflowServiceServer) DeprecateNamespace(ctx context.Context, req *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)

func (*UnimplementedWorkflowServiceServer) DescribeNamespace 

func (*UnimplementedWorkflowServiceServer) DescribeNamespace(ctx context.Context, req *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)

func (*UnimplementedWorkflowServiceServer) DescribeTaskQueue 

func (*UnimplementedWorkflowServiceServer) DescribeTaskQueue(ctx context.Context, req *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)

func (*UnimplementedWorkflowServiceServer) DescribeWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) DescribeWorkflowExecution(ctx context.Context, req *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) GetClusterInfo 

func (*UnimplementedWorkflowServiceServer) GetClusterInfo(ctx context.Context, req *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

func (*UnimplementedWorkflowServiceServer) GetSearchAttributes 

func (*UnimplementedWorkflowServiceServer) GetSearchAttributes(ctx context.Context, req *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)

func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory 

func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory(ctx context.Context, req *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)

func (*UnimplementedWorkflowServiceServer) ListArchivedWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ListArchivedWorkflowExecutions(ctx context.Context, req *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListClosedWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ListClosedWorkflowExecutions(ctx context.Context, req *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListNamespaces 

func (*UnimplementedWorkflowServiceServer) ListNamespaces(ctx context.Context, req *ListNamespacesRequest) (*ListNamespacesResponse, error)

func (*UnimplementedWorkflowServiceServer) ListOpenWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ListOpenWorkflowExecutions(ctx context.Context, req *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListTaskQueuePartitions 

func (*UnimplementedWorkflowServiceServer) ListTaskQueuePartitions(ctx context.Context, req *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)

func (*UnimplementedWorkflowServiceServer) ListWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ListWorkflowExecutions(ctx context.Context, req *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) PollActivityTaskQueue 

func (*UnimplementedWorkflowServiceServer) PollActivityTaskQueue(ctx context.Context, req *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)

func (*UnimplementedWorkflowServiceServer) PollWorkflowTaskQueue 

func (*UnimplementedWorkflowServiceServer) PollWorkflowTaskQueue(ctx context.Context, req *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)

func (*UnimplementedWorkflowServiceServer) QueryWorkflow 

func (*UnimplementedWorkflowServiceServer) QueryWorkflow(ctx context.Context, req *QueryWorkflowRequest) (*QueryWorkflowResponse, error)

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeat 

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeat(ctx context.Context, req *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeatById 

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeatById(ctx context.Context, req *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)

func (*UnimplementedWorkflowServiceServer) RegisterNamespace 

func (*UnimplementedWorkflowServiceServer) RegisterNamespace(ctx context.Context, req *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)

func (*UnimplementedWorkflowServiceServer) RequestCancelWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) RequestCancelWorkflowExecution(ctx context.Context, req *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) ResetStickyTaskQueue 

func (*UnimplementedWorkflowServiceServer) ResetStickyTaskQueue(ctx context.Context, req *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)

func (*UnimplementedWorkflowServiceServer) ResetWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) ResetWorkflowExecution(ctx context.Context, req *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceled 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceled(ctx context.Context, req *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceledById 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceledById(ctx context.Context, req *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompleted 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompleted(ctx context.Context, req *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompletedById 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompletedById(ctx context.Context, req *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailed 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailed(ctx context.Context, req *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailedById 

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailedById(ctx context.Context, req *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondQueryTaskCompleted 

func (*UnimplementedWorkflowServiceServer) RespondQueryTaskCompleted(ctx context.Context, req *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondWorkflowTaskCompleted 

func (*UnimplementedWorkflowServiceServer) RespondWorkflowTaskCompleted(ctx context.Context, req *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)

func (*UnimplementedWorkflowServiceServer) RespondWorkflowTaskFailed 

func (*UnimplementedWorkflowServiceServer) RespondWorkflowTaskFailed(ctx context.Context, req *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)

func (*UnimplementedWorkflowServiceServer) ScanWorkflowExecutions 

func (*UnimplementedWorkflowServiceServer) ScanWorkflowExecutions(ctx context.Context, req *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)

func (*UnimplementedWorkflowServiceServer) SignalWithStartWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) SignalWithStartWorkflowExecution(ctx context.Context, req *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) SignalWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) SignalWorkflowExecution(ctx context.Context, req *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) StartWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) StartWorkflowExecution(ctx context.Context, req *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) TerminateWorkflowExecution 

func (*UnimplementedWorkflowServiceServer) TerminateWorkflowExecution(ctx context.Context, req *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)

func (*UnimplementedWorkflowServiceServer) UpdateNamespace 

func (*UnimplementedWorkflowServiceServer) UpdateNamespace(ctx context.Context, req *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)

type UpdateNamespaceRequest 

type UpdateNamespaceRequest struct {
	Name              string                         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	UpdateInfo        *v12.UpdateNamespaceInfo       `protobuf:"bytes,2,opt,name=update_info,json=updateInfo,proto3" json:"update_info,omitempty"`
	Config            *v12.NamespaceConfig           `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	ReplicationConfig *v1.NamespaceReplicationConfig `protobuf:"bytes,4,opt,name=replication_config,json=replicationConfig,proto3" json:"replication_config,omitempty"`
	SecurityToken     string                         `protobuf:"bytes,5,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
	DeleteBadBinary   string                         `protobuf:"bytes,6,opt,name=delete_bad_binary,json=deleteBadBinary,proto3" json:"delete_bad_binary,omitempty"`
}

(-- api-linter: core::0134::request-mask-required=disabled 

aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)

(-- api-linter: core::0134::request-resource-required=disabled 

aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)

func (*UpdateNamespaceRequest) Descriptor 

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

func (*UpdateNamespaceRequest) Equal 

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

func (*UpdateNamespaceRequest) GetConfig 

func (m *UpdateNamespaceRequest) GetConfig() *v12.NamespaceConfig

func (*UpdateNamespaceRequest) GetDeleteBadBinary 

func (m *UpdateNamespaceRequest) GetDeleteBadBinary() string

func (*UpdateNamespaceRequest) GetName 

func (m *UpdateNamespaceRequest) GetName() string

func (*UpdateNamespaceRequest) GetReplicationConfig 

func (m *UpdateNamespaceRequest) GetReplicationConfig() *v1.NamespaceReplicationConfig

func (*UpdateNamespaceRequest) GetSecurityToken 

func (m *UpdateNamespaceRequest) GetSecurityToken() string

func (*UpdateNamespaceRequest) GetUpdateInfo 

func (m *UpdateNamespaceRequest) GetUpdateInfo() *v12.UpdateNamespaceInfo

func (*UpdateNamespaceRequest) GoString 

func (this *UpdateNamespaceRequest) GoString() string

func (*UpdateNamespaceRequest) Marshal 

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

func (*UpdateNamespaceRequest) MarshalTo 

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

func (*UpdateNamespaceRequest) MarshalToSizedBuffer 

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

func (*UpdateNamespaceRequest) ProtoMessage 

func (*UpdateNamespaceRequest) ProtoMessage()

func (*UpdateNamespaceRequest) Reset 

func (m *UpdateNamespaceRequest) Reset()

func (*UpdateNamespaceRequest) Size 

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

func (*UpdateNamespaceRequest) String 

func (this *UpdateNamespaceRequest) String() string

func (*UpdateNamespaceRequest) Unmarshal 

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

func (*UpdateNamespaceRequest) XXX_DiscardUnknown 

func (m *UpdateNamespaceRequest) XXX_DiscardUnknown()

func (*UpdateNamespaceRequest) XXX_Marshal 

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

func (*UpdateNamespaceRequest) XXX_Merge 

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

func (*UpdateNamespaceRequest) XXX_Size 

func (m *UpdateNamespaceRequest) XXX_Size() int

func (*UpdateNamespaceRequest) XXX_Unmarshal 

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

type UpdateNamespaceResponse 

type UpdateNamespaceResponse struct {
	NamespaceInfo     *v12.NamespaceInfo             `protobuf:"bytes,1,opt,name=namespace_info,json=namespaceInfo,proto3" json:"namespace_info,omitempty"`
	Config            *v12.NamespaceConfig           `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	ReplicationConfig *v1.NamespaceReplicationConfig `protobuf:"bytes,3,opt,name=replication_config,json=replicationConfig,proto3" json:"replication_config,omitempty"`
	FailoverVersion   int64                          `protobuf:"varint,4,opt,name=failover_version,json=failoverVersion,proto3" json:"failover_version,omitempty"`
	IsGlobalNamespace bool                           `protobuf:"varint,5,opt,name=is_global_namespace,json=isGlobalNamespace,proto3" json:"is_global_namespace,omitempty"`
}

func (*UpdateNamespaceResponse) Descriptor 

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

func (*UpdateNamespaceResponse) Equal 

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

func (*UpdateNamespaceResponse) GetConfig 

func (m *UpdateNamespaceResponse) GetConfig() *v12.NamespaceConfig

func (*UpdateNamespaceResponse) GetFailoverVersion 

func (m *UpdateNamespaceResponse) GetFailoverVersion() int64

func (*UpdateNamespaceResponse) GetIsGlobalNamespace 

func (m *UpdateNamespaceResponse) GetIsGlobalNamespace() bool

func (*UpdateNamespaceResponse) GetNamespaceInfo 

func (m *UpdateNamespaceResponse) GetNamespaceInfo() *v12.NamespaceInfo

func (*UpdateNamespaceResponse) GetReplicationConfig 

func (m *UpdateNamespaceResponse) GetReplicationConfig() *v1.NamespaceReplicationConfig

func (*UpdateNamespaceResponse) GoString 

func (this *UpdateNamespaceResponse) GoString() string

func (*UpdateNamespaceResponse) Marshal 

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

func (*UpdateNamespaceResponse) MarshalTo 

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

func (*UpdateNamespaceResponse) MarshalToSizedBuffer 

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

func (*UpdateNamespaceResponse) ProtoMessage 

func (*UpdateNamespaceResponse) ProtoMessage()

func (*UpdateNamespaceResponse) Reset 

func (m *UpdateNamespaceResponse) Reset()

func (*UpdateNamespaceResponse) Size 

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

func (*UpdateNamespaceResponse) String 

func (this *UpdateNamespaceResponse) String() string

func (*UpdateNamespaceResponse) Unmarshal 

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

func (*UpdateNamespaceResponse) XXX_DiscardUnknown 

func (m *UpdateNamespaceResponse) XXX_DiscardUnknown()

func (*UpdateNamespaceResponse) XXX_Marshal 

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

func (*UpdateNamespaceResponse) XXX_Merge 

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

func (*UpdateNamespaceResponse) XXX_Size 

func (m *UpdateNamespaceResponse) XXX_Size() int

func (*UpdateNamespaceResponse) XXX_Unmarshal 

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

type WorkflowServiceClient 

type WorkflowServiceClient interface {
	// RegisterNamespace creates a new namespace which can be used as a container for all resources.  Namespace is a top level
	// entity within Temporal, used as a container for all resources like workflow executions, task queues, etc.  Namespace
	// acts as a sandbox and provides isolation for all resources within the namespace.  All resources belongs to exactly one
	// namespace.
	RegisterNamespace(ctx context.Context, in *RegisterNamespaceRequest, opts ...grpc.CallOption) (*RegisterNamespaceResponse, error)
	// DescribeNamespace returns the information and configuration for a registered namespace.
	DescribeNamespace(ctx context.Context, in *DescribeNamespaceRequest, opts ...grpc.CallOption) (*DescribeNamespaceResponse, error)
	// ListNamespaces returns the information and configuration for all namespaces.
	ListNamespaces(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)
	// (-- api-linter: core::0134::method-signature=disabled
	//     aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)
	// (-- api-linter: core::0134::response-message-name=disabled
	//     aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)
	// UpdateNamespace is used to update the information and configuration for a registered namespace.
	UpdateNamespace(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace is used to update state of a registered namespace to DEPRECATED.  Once the namespace is deprecated
	// it cannot be used to start new workflow executions.  Existing workflow executions will continue to run on
	// deprecated namespaces.
	DeprecateNamespace(ctx context.Context, in *DeprecateNamespaceRequest, opts ...grpc.CallOption) (*DeprecateNamespaceResponse, error)
	// StartWorkflowExecution starts a new long running workflow instance.  It will create the instance with
	// 'WorkflowExecutionStarted' event in history and also schedule the first WorkflowTask for the worker to make the
	// first command for this instance.  It will return 'WorkflowExecutionAlreadyStartedFailure', if an instance already
	// exists with same workflowId.
	StartWorkflowExecution(ctx context.Context, in *StartWorkflowExecutionRequest, opts ...grpc.CallOption) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution.  It fails with 'NotFoundFailure' if specified workflow
	// execution in unknown to the service.
	GetWorkflowExecutionHistory(ctx context.Context, in *GetWorkflowExecutionHistoryRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionHistoryResponse, error)
	// PollWorkflowTaskQueue is called by application worker to process WorkflowTask from a specific task queue.  A
	// WorkflowTask is dispatched to callers for active workflow executions, with pending workflow tasks.
	// Application is then expected to call 'RespondWorkflowTaskCompleted' API when it is done processing the WorkflowTask.
	// It will also create a 'WorkflowTaskStarted' event in the history for that session before handing off WorkflowTask to
	// application worker.
	PollWorkflowTaskQueue(ctx context.Context, in *PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*PollWorkflowTaskQueueResponse, error)
	// RespondWorkflowTaskCompleted is called by application worker to complete a WorkflowTask handed as a result of
	// 'PollWorkflowTaskQueue' API call.  Completing a WorkflowTask will result in new events for the workflow execution and
	// potentially new ActivityTask being created for corresponding commands.  It will also create a WorkflowTaskCompleted
	// event in the history for that session.  Use the 'taskToken' provided as response of PollWorkflowTaskQueue API call
	// for completing the WorkflowTask.
	// The response could contain a new workflow task if there is one or if the request asking for one.
	RespondWorkflowTaskCompleted(ctx context.Context, in *RespondWorkflowTaskCompletedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by application worker to indicate failure.  This results in
	// WorkflowTaskFailedEvent written to the history and a new WorkflowTask created.  This API can be used by client to
	// either clear sticky task queue or report any panics during WorkflowTask processing.  Temporal will only append first
	// WorkflowTaskFailed event to the history of workflow execution for consecutive failures.
	RespondWorkflowTaskFailed(ctx context.Context, in *RespondWorkflowTaskFailedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskFailedResponse, error)
	// PollActivityTaskQueue is called by application worker to process ActivityTask from a specific task queue.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask command is made for a workflow execution.
	// Application is expected to call 'RespondActivityTaskCompleted' or 'RespondActivityTaskFailed' once it is done
	// processing the task.
	// Application also needs to call 'RecordActivityTaskHeartbeat' API within 'heartbeatTimeoutSeconds' interval to
	// prevent the task from getting timed out.  An event 'ActivityTaskStarted' event is also written to workflow execution
	// history before the ActivityTask is dispatched to application worker.
	PollActivityTaskQueue(ctx context.Context, in *PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*PollActivityTaskQueueResponse, error)
	// RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timedout and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeat' will
	// fail with 'NotFoundFailure' in such situations.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for heart beating.
	RecordActivityTaskHeartbeat(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RecordActivityTaskHeartbeatById is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timed out and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeatById' will
	// fail with 'NotFoundFailure' in such situations.  Instead of using 'taskToken' like in RecordActivityTaskHeartbeat,
	// use Namespace, WorkflowId and ActivityId
	RecordActivityTaskHeartbeatById(ctx context.Context, in *RecordActivityTaskHeartbeatByIdRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatByIdResponse, error)
	// RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCompleted(ctx context.Context, in *RespondActivityTaskCompletedRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskCompletedById is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Similar to RespondActivityTaskCompleted but use Namespace,
	// WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskCompletedById(ctx context.Context, in *RespondActivityTaskCompletedByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedByIdResponse, error)
	// RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskFailed(ctx context.Context, in *RespondActivityTaskFailedRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskFailedById is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Similar to RespondActivityTaskFailed but use
	// Namespace, WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskFailedById(ctx context.Context, in *RespondActivityTaskFailedByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedByIdResponse, error)
	// RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask.  It will
	// result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCanceled(ctx context.Context, in *RespondActivityTaskCanceledRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskCanceledById is called by application worker when it is successfully canceled an ActivityTask.
	// It will result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Similar to RespondActivityTaskCanceled but use
	// Namespace, WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskCanceledById(ctx context.Context, in *RespondActivityTaskCanceledByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledByIdResponse, error)
	// RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance.
	// It will result in a new 'WorkflowExecutionCancelRequested' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made. It fails with 'NotFoundFailure' if the workflow is not valid
	// anymore due to completion or doesn't exist.
	RequestCancelWorkflowExecution(ctx context.Context, in *RequestCancelWorkflowExecutionRequest, opts ...grpc.CallOption) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal event to running workflow execution.  This results in
	// WorkflowExecutionSignaled event recorded in the history and a workflow task being created for the execution.
	SignalWorkflowExecution(ctx context.Context, in *SignalWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWorkflowExecutionResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "With" is used to indicate combined operation. --)
	// SignalWithStartWorkflowExecution is used to ensure sending signal to a workflow.
	// If the workflow is running, this results in WorkflowExecutionSignaled event being recorded in the history
	// and a workflow task being created for the execution.
	// If the workflow is not running or not found, this results in WorkflowExecutionStarted and WorkflowExecutionSignaled
	// events being recorded in history, and a workflow task being created for the execution
	SignalWithStartWorkflowExecution(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution to WorkflowTaskCompleted event(exclusive).
	// And it will immediately terminating the current execution instance.
	ResetWorkflowExecution(ctx context.Context, in *ResetWorkflowExecutionRequest, opts ...grpc.CallOption) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event
	// in the history and immediately terminating the execution instance.
	TerminateWorkflowExecution(ctx context.Context, in *TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*TerminateWorkflowExecutionResponse, error)
	// ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific namespace.
	ListOpenWorkflowExecutions(ctx context.Context, in *ListOpenWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListOpenWorkflowExecutionsResponse, error)
	// ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific namespace.
	ListClosedWorkflowExecutions(ctx context.Context, in *ListClosedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListClosedWorkflowExecutionsResponse, error)
	// ListWorkflowExecutions is a visibility API to list workflow executions in a specific namespace.
	ListWorkflowExecutions(ctx context.Context, in *ListWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListWorkflowExecutionsResponse, error)
	// ListArchivedWorkflowExecutions is a visibility API to list archived workflow executions in a specific namespace.
	ListArchivedWorkflowExecutions(ctx context.Context, in *ListArchivedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListArchivedWorkflowExecutionsResponse, error)
	// ScanWorkflowExecutions is a visibility API to list large amount of workflow executions in a specific namespace without order.
	ScanWorkflowExecutions(ctx context.Context, in *ScanWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ScanWorkflowExecutionsResponse, error)
	// CountWorkflowExecutions is a visibility API to count of workflow executions in a specific namespace.
	CountWorkflowExecutions(ctx context.Context, in *CountWorkflowExecutionsRequest, opts ...grpc.CallOption) (*CountWorkflowExecutionsResponse, error)
	// GetSearchAttributes is a visibility API to get all legal keys that could be used in list APIs
	GetSearchAttributes(ctx context.Context, in *GetSearchAttributesRequest, opts ...grpc.CallOption) (*GetSearchAttributesResponse, error)
	// RespondQueryTaskCompleted is called by application worker to complete a QueryTask (which is a WorkflowTask for query)
	// as a result of 'PollWorkflowTaskQueue' API call. Completing a QueryTask will unblock the client call to 'QueryWorkflow'
	// API and return the query result to client as a response to 'QueryWorkflow' API call.
	RespondQueryTaskCompleted(ctx context.Context, in *RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskQueue resets the sticky task queue related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	// 3. ClientLibraryVersion
	// 4. ClientFeatureVersion
	// 5. ClientImpl
	ResetStickyTaskQueue(ctx context.Context, in *ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*ResetStickyTaskQueueResponse, error)
	// QueryWorkflow returns query result for a specified workflow execution
	QueryWorkflow(ctx context.Context, in *QueryWorkflowRequest, opts ...grpc.CallOption) (*QueryWorkflowResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(ctx context.Context, in *DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*DescribeWorkflowExecutionResponse, error)
	// DescribeTaskQueue returns information about the target task queue, right now this API returns the
	// pollers which polled this task queue in last few minutes.
	DescribeTaskQueue(ctx context.Context, in *DescribeTaskQueueRequest, opts ...grpc.CallOption) (*DescribeTaskQueueResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
	ListTaskQueuePartitions(ctx context.Context, in *ListTaskQueuePartitionsRequest, opts ...grpc.CallOption) (*ListTaskQueuePartitionsResponse, error)
}

WorkflowServiceClient is the client API for WorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkflowServiceClient 

func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient

type WorkflowServiceServer 

type WorkflowServiceServer interface {
	// RegisterNamespace creates a new namespace which can be used as a container for all resources.  Namespace is a top level
	// entity within Temporal, used as a container for all resources like workflow executions, task queues, etc.  Namespace
	// acts as a sandbox and provides isolation for all resources within the namespace.  All resources belongs to exactly one
	// namespace.
	RegisterNamespace(context.Context, *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)
	// DescribeNamespace returns the information and configuration for a registered namespace.
	DescribeNamespace(context.Context, *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)
	// ListNamespaces returns the information and configuration for all namespaces.
	ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
	// (-- api-linter: core::0134::method-signature=disabled
	//     aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)
	// (-- api-linter: core::0134::response-message-name=disabled
	//     aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)
	// UpdateNamespace is used to update the information and configuration for a registered namespace.
	UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace is used to update state of a registered namespace to DEPRECATED.  Once the namespace is deprecated
	// it cannot be used to start new workflow executions.  Existing workflow executions will continue to run on
	// deprecated namespaces.
	DeprecateNamespace(context.Context, *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)
	// StartWorkflowExecution starts a new long running workflow instance.  It will create the instance with
	// 'WorkflowExecutionStarted' event in history and also schedule the first WorkflowTask for the worker to make the
	// first command for this instance.  It will return 'WorkflowExecutionAlreadyStartedFailure', if an instance already
	// exists with same workflowId.
	StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution.  It fails with 'NotFoundFailure' if specified workflow
	// execution in unknown to the service.
	GetWorkflowExecutionHistory(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)
	// PollWorkflowTaskQueue is called by application worker to process WorkflowTask from a specific task queue.  A
	// WorkflowTask is dispatched to callers for active workflow executions, with pending workflow tasks.
	// Application is then expected to call 'RespondWorkflowTaskCompleted' API when it is done processing the WorkflowTask.
	// It will also create a 'WorkflowTaskStarted' event in the history for that session before handing off WorkflowTask to
	// application worker.
	PollWorkflowTaskQueue(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)
	// RespondWorkflowTaskCompleted is called by application worker to complete a WorkflowTask handed as a result of
	// 'PollWorkflowTaskQueue' API call.  Completing a WorkflowTask will result in new events for the workflow execution and
	// potentially new ActivityTask being created for corresponding commands.  It will also create a WorkflowTaskCompleted
	// event in the history for that session.  Use the 'taskToken' provided as response of PollWorkflowTaskQueue API call
	// for completing the WorkflowTask.
	// The response could contain a new workflow task if there is one or if the request asking for one.
	RespondWorkflowTaskCompleted(context.Context, *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by application worker to indicate failure.  This results in
	// WorkflowTaskFailedEvent written to the history and a new WorkflowTask created.  This API can be used by client to
	// either clear sticky task queue or report any panics during WorkflowTask processing.  Temporal will only append first
	// WorkflowTaskFailed event to the history of workflow execution for consecutive failures.
	RespondWorkflowTaskFailed(context.Context, *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)
	// PollActivityTaskQueue is called by application worker to process ActivityTask from a specific task queue.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask command is made for a workflow execution.
	// Application is expected to call 'RespondActivityTaskCompleted' or 'RespondActivityTaskFailed' once it is done
	// processing the task.
	// Application also needs to call 'RecordActivityTaskHeartbeat' API within 'heartbeatTimeoutSeconds' interval to
	// prevent the task from getting timed out.  An event 'ActivityTaskStarted' event is also written to workflow execution
	// history before the ActivityTask is dispatched to application worker.
	PollActivityTaskQueue(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)
	// RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timedout and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeat' will
	// fail with 'NotFoundFailure' in such situations.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for heart beating.
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RecordActivityTaskHeartbeatById is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timed out and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeatById' will
	// fail with 'NotFoundFailure' in such situations.  Instead of using 'taskToken' like in RecordActivityTaskHeartbeat,
	// use Namespace, WorkflowId and ActivityId
	RecordActivityTaskHeartbeatById(context.Context, *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)
	// RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskCompletedById is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Similar to RespondActivityTaskCompleted but use Namespace,
	// WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskCompletedById(context.Context, *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)
	// RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskFailedById is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Similar to RespondActivityTaskFailed but use
	// Namespace, WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskFailedById(context.Context, *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)
	// RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask.  It will
	// result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskCanceledById is called by application worker when it is successfully canceled an ActivityTask.
	// It will result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Similar to RespondActivityTaskCanceled but use
	// Namespace, WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskCanceledById(context.Context, *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)
	// RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance.
	// It will result in a new 'WorkflowExecutionCancelRequested' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made. It fails with 'NotFoundFailure' if the workflow is not valid
	// anymore due to completion or doesn't exist.
	RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal event to running workflow execution.  This results in
	// WorkflowExecutionSignaled event recorded in the history and a workflow task being created for the execution.
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "With" is used to indicate combined operation. --)
	// SignalWithStartWorkflowExecution is used to ensure sending signal to a workflow.
	// If the workflow is running, this results in WorkflowExecutionSignaled event being recorded in the history
	// and a workflow task being created for the execution.
	// If the workflow is not running or not found, this results in WorkflowExecutionStarted and WorkflowExecutionSignaled
	// events being recorded in history, and a workflow task being created for the execution
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution to WorkflowTaskCompleted event(exclusive).
	// And it will immediately terminating the current execution instance.
	ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event
	// in the history and immediately terminating the execution instance.
	TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)
	// ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific namespace.
	ListOpenWorkflowExecutions(context.Context, *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)
	// ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific namespace.
	ListClosedWorkflowExecutions(context.Context, *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)
	// ListWorkflowExecutions is a visibility API to list workflow executions in a specific namespace.
	ListWorkflowExecutions(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	// ListArchivedWorkflowExecutions is a visibility API to list archived workflow executions in a specific namespace.
	ListArchivedWorkflowExecutions(context.Context, *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)
	// ScanWorkflowExecutions is a visibility API to list large amount of workflow executions in a specific namespace without order.
	ScanWorkflowExecutions(context.Context, *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)
	// CountWorkflowExecutions is a visibility API to count of workflow executions in a specific namespace.
	CountWorkflowExecutions(context.Context, *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
	// GetSearchAttributes is a visibility API to get all legal keys that could be used in list APIs
	GetSearchAttributes(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)
	// RespondQueryTaskCompleted is called by application worker to complete a QueryTask (which is a WorkflowTask for query)
	// as a result of 'PollWorkflowTaskQueue' API call. Completing a QueryTask will unblock the client call to 'QueryWorkflow'
	// API and return the query result to client as a response to 'QueryWorkflow' API call.
	RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskQueue resets the sticky task queue related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	// 3. ClientLibraryVersion
	// 4. ClientFeatureVersion
	// 5. ClientImpl
	ResetStickyTaskQueue(context.Context, *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)
	// QueryWorkflow returns query result for a specified workflow execution
	QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)
	// DescribeTaskQueue returns information about the target task queue, right now this API returns the
	// pollers which polled this task queue in last few minutes.
	DescribeTaskQueue(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	ListTaskQueuePartitions(context.Context, *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)
}

WorkflowServiceServer is the server API for WorkflowService service.

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.