workflowservice

package
v0.24.4 Latest Latest
Warning

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

Go to latest
Published: Jun 15, 2020 License: MIT Imports: 25 Imported by: 0

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 (*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 added in v0.24.4

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 added in v0.24.4

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 DescribeTaskListRequest

type DescribeTaskListRequest struct {
	Namespace             string           `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskList              *v14.TaskList    `protobuf:"bytes,2,opt,name=task_list,json=taskList,proto3" json:"task_list,omitempty"`
	TaskListType          v11.TaskListType `` /* 136-byte string literal not displayed */
	IncludeTaskListStatus bool             `` /* 129-byte string literal not displayed */
}

func (*DescribeTaskListRequest) Descriptor

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

func (*DescribeTaskListRequest) Equal

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

func (*DescribeTaskListRequest) GetIncludeTaskListStatus

func (m *DescribeTaskListRequest) GetIncludeTaskListStatus() bool

func (*DescribeTaskListRequest) GetNamespace

func (m *DescribeTaskListRequest) GetNamespace() string

func (*DescribeTaskListRequest) GetTaskList

func (m *DescribeTaskListRequest) GetTaskList() *v14.TaskList

func (*DescribeTaskListRequest) GetTaskListType

func (m *DescribeTaskListRequest) GetTaskListType() v11.TaskListType

func (*DescribeTaskListRequest) GoString

func (this *DescribeTaskListRequest) GoString() string

func (*DescribeTaskListRequest) Marshal

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

func (*DescribeTaskListRequest) MarshalTo

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

func (*DescribeTaskListRequest) MarshalToSizedBuffer

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

func (*DescribeTaskListRequest) ProtoMessage

func (*DescribeTaskListRequest) ProtoMessage()

func (*DescribeTaskListRequest) Reset

func (m *DescribeTaskListRequest) Reset()

func (*DescribeTaskListRequest) Size

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

func (*DescribeTaskListRequest) String

func (this *DescribeTaskListRequest) String() string

func (*DescribeTaskListRequest) Unmarshal

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

func (*DescribeTaskListRequest) XXX_DiscardUnknown

func (m *DescribeTaskListRequest) XXX_DiscardUnknown()

func (*DescribeTaskListRequest) XXX_Marshal

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

func (*DescribeTaskListRequest) XXX_Merge

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

func (*DescribeTaskListRequest) XXX_Size

func (m *DescribeTaskListRequest) XXX_Size() int

func (*DescribeTaskListRequest) XXX_Unmarshal

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

type DescribeTaskListResponse

type DescribeTaskListResponse struct {
	Pollers        []*v14.PollerInfo   `protobuf:"bytes,1,rep,name=pollers,proto3" json:"pollers,omitempty"`
	TaskListStatus *v14.TaskListStatus `protobuf:"bytes,2,opt,name=task_list_status,json=taskListStatus,proto3" json:"task_list_status,omitempty"`
}

func (*DescribeTaskListResponse) Descriptor

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

func (*DescribeTaskListResponse) Equal

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

func (*DescribeTaskListResponse) GetPollers

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

func (*DescribeTaskListResponse) GetTaskListStatus

func (m *DescribeTaskListResponse) GetTaskListStatus() *v14.TaskListStatus

func (*DescribeTaskListResponse) GoString

func (this *DescribeTaskListResponse) GoString() string

func (*DescribeTaskListResponse) Marshal

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

func (*DescribeTaskListResponse) MarshalTo

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

func (*DescribeTaskListResponse) MarshalToSizedBuffer

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

func (*DescribeTaskListResponse) ProtoMessage

func (*DescribeTaskListResponse) ProtoMessage()

func (*DescribeTaskListResponse) Reset

func (m *DescribeTaskListResponse) Reset()

func (*DescribeTaskListResponse) Size

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

func (*DescribeTaskListResponse) String

func (this *DescribeTaskListResponse) String() string

func (*DescribeTaskListResponse) Unmarshal

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

func (*DescribeTaskListResponse) XXX_DiscardUnknown

func (m *DescribeTaskListResponse) XXX_DiscardUnknown()

func (*DescribeTaskListResponse) XXX_Marshal

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

func (*DescribeTaskListResponse) XXX_Merge

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

func (*DescribeTaskListResponse) XXX_Size

func (m *DescribeTaskListResponse) XXX_Size() int

func (*DescribeTaskListResponse) XXX_Unmarshal

func (m *DescribeTaskListResponse) 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 (*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 (*DescribeWorkflowExecutionRequest) Size

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

func (*DescribeWorkflowExecutionRequest) 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 (*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 added in v0.24.4

func (*DescribeWorkflowExecutionResponse) GetPendingActivities

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

func (*DescribeWorkflowExecutionResponse) GetPendingChildren

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 (*DescribeWorkflowExecutionResponse) Size

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

func (*DescribeWorkflowExecutionResponse) 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 (*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 added in v0.24.3

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 `` /* 190-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 (*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"`
	WaitForNewEvent        bool                       `protobuf:"varint,5,opt,name=wait_for_new_event,json=waitForNewEvent,proto3" json:"wait_for_new_event,omitempty"`
	HistoryEventFilterType v11.HistoryEventFilterType `` /* 178-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 (*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) GetWaitForNewEvent

func (m *GetWorkflowExecutionHistoryRequest) GetWaitForNewEvent() 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 (*GetWorkflowExecutionHistoryRequest) Size

func (*GetWorkflowExecutionHistoryRequest) 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 (*GetWorkflowExecutionHistoryRequest) XXX_Size

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 (*GetWorkflowExecutionHistoryResponse) GetNextPageToken

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

func (*GetWorkflowExecutionHistoryResponse) GetRawHistory

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

func (*GetWorkflowExecutionHistoryResponse) GoString

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 (*GetWorkflowExecutionHistoryResponse) Size

func (*GetWorkflowExecutionHistoryResponse) 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 (*GetWorkflowExecutionHistoryResponse) XXX_Size

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 (*ListArchivedWorkflowExecutionsRequest) GetNextPageToken

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

func (*ListArchivedWorkflowExecutionsRequest) GetPageSize

func (*ListArchivedWorkflowExecutionsRequest) GetQuery

func (*ListArchivedWorkflowExecutionsRequest) GoString

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 (*ListArchivedWorkflowExecutionsRequest) Size

func (*ListArchivedWorkflowExecutionsRequest) 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 (*ListArchivedWorkflowExecutionsRequest) XXX_Size

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 (*ListArchivedWorkflowExecutionsResponse) GetNextPageToken

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

func (*ListArchivedWorkflowExecutionsResponse) GoString

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) Reset

func (*ListArchivedWorkflowExecutionsResponse) Size

func (*ListArchivedWorkflowExecutionsResponse) 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 (*ListArchivedWorkflowExecutionsResponse) XXX_Size

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 (*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 (*ListClosedWorkflowExecutionsRequest) GetTypeFilter

func (*ListClosedWorkflowExecutionsRequest) GoString

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 (*ListClosedWorkflowExecutionsRequest) Size

func (*ListClosedWorkflowExecutionsRequest) 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 (*ListClosedWorkflowExecutionsRequest) XXX_OneofWrappers

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ListClosedWorkflowExecutionsRequest) XXX_Size

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 (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) MarshalTo

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) MarshalToSizedBuffer

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

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) Size

func (*ListClosedWorkflowExecutionsRequest_ExecutionFilter) 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 (*ListClosedWorkflowExecutionsRequest_StatusFilter) MarshalTo

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) MarshalToSizedBuffer

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

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) Size

func (*ListClosedWorkflowExecutionsRequest_StatusFilter) 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 (*ListClosedWorkflowExecutionsRequest_TypeFilter) MarshalTo

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) MarshalToSizedBuffer

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

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) Size

func (*ListClosedWorkflowExecutionsRequest_TypeFilter) 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 (*ListClosedWorkflowExecutionsResponse) GetNextPageToken

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

func (*ListClosedWorkflowExecutionsResponse) GoString

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 (*ListClosedWorkflowExecutionsResponse) Size

func (*ListClosedWorkflowExecutionsResponse) 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 (*ListClosedWorkflowExecutionsResponse) XXX_Size

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 (*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 (*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 (*ListOpenWorkflowExecutionsRequest) Size

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

func (*ListOpenWorkflowExecutionsRequest) 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 (*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 (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) MarshalTo

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) MarshalToSizedBuffer

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

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) Size

func (*ListOpenWorkflowExecutionsRequest_ExecutionFilter) 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 (*ListOpenWorkflowExecutionsRequest_TypeFilter) MarshalTo

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) MarshalToSizedBuffer

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

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) Size

func (*ListOpenWorkflowExecutionsRequest_TypeFilter) 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 (*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 (*ListOpenWorkflowExecutionsResponse) Size

func (*ListOpenWorkflowExecutionsResponse) 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 (*ListOpenWorkflowExecutionsResponse) XXX_Size

func (*ListOpenWorkflowExecutionsResponse) XXX_Unmarshal

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

type ListTaskListPartitionsRequest

type ListTaskListPartitionsRequest struct {
	Namespace string        `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskList  *v14.TaskList `protobuf:"bytes,2,opt,name=task_list,json=taskList,proto3" json:"task_list,omitempty"`
}

func (*ListTaskListPartitionsRequest) Descriptor

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

func (*ListTaskListPartitionsRequest) Equal

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

func (*ListTaskListPartitionsRequest) GetNamespace

func (m *ListTaskListPartitionsRequest) GetNamespace() string

func (*ListTaskListPartitionsRequest) GetTaskList

func (m *ListTaskListPartitionsRequest) GetTaskList() *v14.TaskList

func (*ListTaskListPartitionsRequest) GoString

func (this *ListTaskListPartitionsRequest) GoString() string

func (*ListTaskListPartitionsRequest) Marshal

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

func (*ListTaskListPartitionsRequest) MarshalTo

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

func (*ListTaskListPartitionsRequest) MarshalToSizedBuffer

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

func (*ListTaskListPartitionsRequest) ProtoMessage

func (*ListTaskListPartitionsRequest) ProtoMessage()

func (*ListTaskListPartitionsRequest) Reset

func (m *ListTaskListPartitionsRequest) Reset()

func (*ListTaskListPartitionsRequest) Size

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

func (*ListTaskListPartitionsRequest) String

func (this *ListTaskListPartitionsRequest) String() string

func (*ListTaskListPartitionsRequest) Unmarshal

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

func (*ListTaskListPartitionsRequest) XXX_DiscardUnknown

func (m *ListTaskListPartitionsRequest) XXX_DiscardUnknown()

func (*ListTaskListPartitionsRequest) XXX_Marshal

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

func (*ListTaskListPartitionsRequest) XXX_Merge

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

func (*ListTaskListPartitionsRequest) XXX_Size

func (m *ListTaskListPartitionsRequest) XXX_Size() int

func (*ListTaskListPartitionsRequest) XXX_Unmarshal

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

type ListTaskListPartitionsResponse

type ListTaskListPartitionsResponse struct {
	ActivityTaskListPartitions []*v14.TaskListPartitionMetadata `` /* 143-byte string literal not displayed */
	DecisionTaskListPartitions []*v14.TaskListPartitionMetadata `` /* 143-byte string literal not displayed */
}

func (*ListTaskListPartitionsResponse) Descriptor

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

func (*ListTaskListPartitionsResponse) Equal

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

func (*ListTaskListPartitionsResponse) GetActivityTaskListPartitions

func (m *ListTaskListPartitionsResponse) GetActivityTaskListPartitions() []*v14.TaskListPartitionMetadata

func (*ListTaskListPartitionsResponse) GetDecisionTaskListPartitions

func (m *ListTaskListPartitionsResponse) GetDecisionTaskListPartitions() []*v14.TaskListPartitionMetadata

func (*ListTaskListPartitionsResponse) GoString

func (this *ListTaskListPartitionsResponse) GoString() string

func (*ListTaskListPartitionsResponse) Marshal

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

func (*ListTaskListPartitionsResponse) MarshalTo

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

func (*ListTaskListPartitionsResponse) MarshalToSizedBuffer

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

func (*ListTaskListPartitionsResponse) ProtoMessage

func (*ListTaskListPartitionsResponse) ProtoMessage()

func (*ListTaskListPartitionsResponse) Reset

func (m *ListTaskListPartitionsResponse) Reset()

func (*ListTaskListPartitionsResponse) Size

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

func (*ListTaskListPartitionsResponse) String

func (this *ListTaskListPartitionsResponse) String() string

func (*ListTaskListPartitionsResponse) Unmarshal

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

func (*ListTaskListPartitionsResponse) XXX_DiscardUnknown

func (m *ListTaskListPartitionsResponse) XXX_DiscardUnknown()

func (*ListTaskListPartitionsResponse) XXX_Marshal

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

func (*ListTaskListPartitionsResponse) XXX_Merge

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

func (*ListTaskListPartitionsResponse) XXX_Size

func (m *ListTaskListPartitionsResponse) XXX_Size() int

func (*ListTaskListPartitionsResponse) XXX_Unmarshal

func (m *ListTaskListPartitionsResponse) 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 (*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 PollForActivityTaskRequest

type PollForActivityTaskRequest struct {
	Namespace        string                `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskList         *v14.TaskList         `protobuf:"bytes,2,opt,name=task_list,json=taskList,proto3" json:"task_list,omitempty"`
	Identity         string                `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	TaskListMetadata *v14.TaskListMetadata `protobuf:"bytes,4,opt,name=task_list_metadata,json=taskListMetadata,proto3" json:"task_list_metadata,omitempty"`
}

func (*PollForActivityTaskRequest) Descriptor

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

func (*PollForActivityTaskRequest) Equal

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

func (*PollForActivityTaskRequest) GetIdentity

func (m *PollForActivityTaskRequest) GetIdentity() string

func (*PollForActivityTaskRequest) GetNamespace

func (m *PollForActivityTaskRequest) GetNamespace() string

func (*PollForActivityTaskRequest) GetTaskList

func (m *PollForActivityTaskRequest) GetTaskList() *v14.TaskList

func (*PollForActivityTaskRequest) GetTaskListMetadata

func (m *PollForActivityTaskRequest) GetTaskListMetadata() *v14.TaskListMetadata

func (*PollForActivityTaskRequest) GoString

func (this *PollForActivityTaskRequest) GoString() string

func (*PollForActivityTaskRequest) Marshal

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

func (*PollForActivityTaskRequest) MarshalTo

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

func (*PollForActivityTaskRequest) MarshalToSizedBuffer

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

func (*PollForActivityTaskRequest) ProtoMessage

func (*PollForActivityTaskRequest) ProtoMessage()

func (*PollForActivityTaskRequest) Reset

func (m *PollForActivityTaskRequest) Reset()

func (*PollForActivityTaskRequest) Size

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

func (*PollForActivityTaskRequest) String

func (this *PollForActivityTaskRequest) String() string

func (*PollForActivityTaskRequest) Unmarshal

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

func (*PollForActivityTaskRequest) XXX_DiscardUnknown

func (m *PollForActivityTaskRequest) XXX_DiscardUnknown()

func (*PollForActivityTaskRequest) XXX_Marshal

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

func (*PollForActivityTaskRequest) XXX_Merge

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

func (*PollForActivityTaskRequest) XXX_Size

func (m *PollForActivityTaskRequest) XXX_Size() int

func (*PollForActivityTaskRequest) XXX_Unmarshal

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

type PollForActivityTaskResponse

type PollForActivityTaskResponse 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"`
	ScheduledTimestamp              int64                  `protobuf:"varint,10,opt,name=scheduled_timestamp,json=scheduledTimestamp,proto3" json:"scheduled_timestamp,omitempty"`
	ScheduledTimestampOfThisAttempt int64                  `` /* 162-byte string literal not displayed */
	StartedTimestamp                int64                  `protobuf:"varint,12,opt,name=started_timestamp,json=startedTimestamp,proto3" json:"started_timestamp,omitempty"`
	Attempt                         int32                  `protobuf:"varint,13,opt,name=attempt,proto3" json:"attempt,omitempty"`
	ScheduleToCloseTimeoutSeconds   int32                  `` /* 156-byte string literal not displayed */
	StartToCloseTimeoutSeconds      int32                  `` /* 147-byte string literal not displayed */
	HeartbeatTimeoutSeconds         int32                  `` /* 134-byte string literal not displayed */
	// 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 (*PollForActivityTaskResponse) Descriptor

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

func (*PollForActivityTaskResponse) Equal

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

func (*PollForActivityTaskResponse) GetActivityId

func (m *PollForActivityTaskResponse) GetActivityId() string

func (*PollForActivityTaskResponse) GetActivityType

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

func (*PollForActivityTaskResponse) GetAttempt

func (m *PollForActivityTaskResponse) GetAttempt() int32

func (*PollForActivityTaskResponse) GetHeader

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

func (*PollForActivityTaskResponse) GetHeartbeatDetails

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

func (*PollForActivityTaskResponse) GetHeartbeatTimeoutSeconds

func (m *PollForActivityTaskResponse) GetHeartbeatTimeoutSeconds() int32

func (*PollForActivityTaskResponse) GetInput

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

func (*PollForActivityTaskResponse) GetRetryPolicy

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

func (*PollForActivityTaskResponse) GetScheduleToCloseTimeoutSeconds

func (m *PollForActivityTaskResponse) GetScheduleToCloseTimeoutSeconds() int32

func (*PollForActivityTaskResponse) GetScheduledTimestamp

func (m *PollForActivityTaskResponse) GetScheduledTimestamp() int64

func (*PollForActivityTaskResponse) GetScheduledTimestampOfThisAttempt

func (m *PollForActivityTaskResponse) GetScheduledTimestampOfThisAttempt() int64

func (*PollForActivityTaskResponse) GetStartToCloseTimeoutSeconds

func (m *PollForActivityTaskResponse) GetStartToCloseTimeoutSeconds() int32

func (*PollForActivityTaskResponse) GetStartedTimestamp

func (m *PollForActivityTaskResponse) GetStartedTimestamp() int64

func (*PollForActivityTaskResponse) GetTaskToken

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

func (*PollForActivityTaskResponse) GetWorkflowExecution

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

func (*PollForActivityTaskResponse) GetWorkflowNamespace

func (m *PollForActivityTaskResponse) GetWorkflowNamespace() string

func (*PollForActivityTaskResponse) GetWorkflowType

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

func (*PollForActivityTaskResponse) GoString

func (this *PollForActivityTaskResponse) GoString() string

func (*PollForActivityTaskResponse) Marshal

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

func (*PollForActivityTaskResponse) MarshalTo

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

func (*PollForActivityTaskResponse) MarshalToSizedBuffer

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

func (*PollForActivityTaskResponse) ProtoMessage

func (*PollForActivityTaskResponse) ProtoMessage()

func (*PollForActivityTaskResponse) Reset

func (m *PollForActivityTaskResponse) Reset()

func (*PollForActivityTaskResponse) Size

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

func (*PollForActivityTaskResponse) String

func (this *PollForActivityTaskResponse) String() string

func (*PollForActivityTaskResponse) Unmarshal

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

func (*PollForActivityTaskResponse) XXX_DiscardUnknown

func (m *PollForActivityTaskResponse) XXX_DiscardUnknown()

func (*PollForActivityTaskResponse) XXX_Marshal

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

func (*PollForActivityTaskResponse) XXX_Merge

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

func (*PollForActivityTaskResponse) XXX_Size

func (m *PollForActivityTaskResponse) XXX_Size() int

func (*PollForActivityTaskResponse) XXX_Unmarshal

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

type PollForDecisionTaskRequest

type PollForDecisionTaskRequest struct {
	Namespace      string        `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskList       *v14.TaskList `protobuf:"bytes,2,opt,name=task_list,json=taskList,proto3" json:"task_list,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 (*PollForDecisionTaskRequest) Descriptor

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

func (*PollForDecisionTaskRequest) Equal

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

func (*PollForDecisionTaskRequest) GetBinaryChecksum

func (m *PollForDecisionTaskRequest) GetBinaryChecksum() string

func (*PollForDecisionTaskRequest) GetIdentity

func (m *PollForDecisionTaskRequest) GetIdentity() string

func (*PollForDecisionTaskRequest) GetNamespace

func (m *PollForDecisionTaskRequest) GetNamespace() string

func (*PollForDecisionTaskRequest) GetTaskList

func (m *PollForDecisionTaskRequest) GetTaskList() *v14.TaskList

func (*PollForDecisionTaskRequest) GoString

func (this *PollForDecisionTaskRequest) GoString() string

func (*PollForDecisionTaskRequest) Marshal

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

func (*PollForDecisionTaskRequest) MarshalTo

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

func (*PollForDecisionTaskRequest) MarshalToSizedBuffer

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

func (*PollForDecisionTaskRequest) ProtoMessage

func (*PollForDecisionTaskRequest) ProtoMessage()

func (*PollForDecisionTaskRequest) Reset

func (m *PollForDecisionTaskRequest) Reset()

func (*PollForDecisionTaskRequest) Size

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

func (*PollForDecisionTaskRequest) String

func (this *PollForDecisionTaskRequest) String() string

func (*PollForDecisionTaskRequest) Unmarshal

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

func (*PollForDecisionTaskRequest) XXX_DiscardUnknown

func (m *PollForDecisionTaskRequest) XXX_DiscardUnknown()

func (*PollForDecisionTaskRequest) XXX_Marshal

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

func (*PollForDecisionTaskRequest) XXX_Merge

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

func (*PollForDecisionTaskRequest) XXX_Size

func (m *PollForDecisionTaskRequest) XXX_Size() int

func (*PollForDecisionTaskRequest) XXX_Unmarshal

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

type PollForDecisionTaskResponse

type PollForDecisionTaskResponse 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                   int64                         `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"`
	WorkflowExecutionTaskList *v14.TaskList                 `` /* 141-byte string literal not displayed */
	ScheduledTimestamp        int64                         `protobuf:"varint,12,opt,name=scheduled_timestamp,json=scheduledTimestamp,proto3" json:"scheduled_timestamp,omitempty"`
	StartedTimestamp          int64                         `protobuf:"varint,13,opt,name=started_timestamp,json=startedTimestamp,proto3" json:"started_timestamp,omitempty"`
	Queries                   map[string]*v16.WorkflowQuery `` /* 156-byte string literal not displayed */
}

func (*PollForDecisionTaskResponse) Descriptor

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

func (*PollForDecisionTaskResponse) Equal

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

func (*PollForDecisionTaskResponse) GetAttempt

func (m *PollForDecisionTaskResponse) GetAttempt() int64

func (*PollForDecisionTaskResponse) GetBacklogCountHint

func (m *PollForDecisionTaskResponse) GetBacklogCountHint() int64

func (*PollForDecisionTaskResponse) GetHistory

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

func (*PollForDecisionTaskResponse) GetNextPageToken

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

func (*PollForDecisionTaskResponse) GetPreviousStartedEventId

func (m *PollForDecisionTaskResponse) GetPreviousStartedEventId() int64

func (*PollForDecisionTaskResponse) GetQueries

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

func (*PollForDecisionTaskResponse) GetQuery

func (*PollForDecisionTaskResponse) GetScheduledTimestamp

func (m *PollForDecisionTaskResponse) GetScheduledTimestamp() int64

func (*PollForDecisionTaskResponse) GetStartedEventId

func (m *PollForDecisionTaskResponse) GetStartedEventId() int64

func (*PollForDecisionTaskResponse) GetStartedTimestamp

func (m *PollForDecisionTaskResponse) GetStartedTimestamp() int64

func (*PollForDecisionTaskResponse) GetTaskToken

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

func (*PollForDecisionTaskResponse) GetWorkflowExecution

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

func (*PollForDecisionTaskResponse) GetWorkflowExecutionTaskList

func (m *PollForDecisionTaskResponse) GetWorkflowExecutionTaskList() *v14.TaskList

func (*PollForDecisionTaskResponse) GetWorkflowType

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

func (*PollForDecisionTaskResponse) GoString

func (this *PollForDecisionTaskResponse) GoString() string

func (*PollForDecisionTaskResponse) Marshal

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

func (*PollForDecisionTaskResponse) MarshalTo

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

func (*PollForDecisionTaskResponse) MarshalToSizedBuffer

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

func (*PollForDecisionTaskResponse) ProtoMessage

func (*PollForDecisionTaskResponse) ProtoMessage()

func (*PollForDecisionTaskResponse) Reset

func (m *PollForDecisionTaskResponse) Reset()

func (*PollForDecisionTaskResponse) Size

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

func (*PollForDecisionTaskResponse) String

func (this *PollForDecisionTaskResponse) String() string

func (*PollForDecisionTaskResponse) Unmarshal

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

func (*PollForDecisionTaskResponse) XXX_DiscardUnknown

func (m *PollForDecisionTaskResponse) XXX_DiscardUnknown()

func (*PollForDecisionTaskResponse) XXX_Marshal

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

func (*PollForDecisionTaskResponse) XXX_Merge

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

func (*PollForDecisionTaskResponse) XXX_Size

func (m *PollForDecisionTaskResponse) XXX_Size() int

func (*PollForDecisionTaskResponse) XXX_Unmarshal

func (m *PollForDecisionTaskResponse) 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
	QueryRejectCondition v11.QueryRejectCondition `` /* 168-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 (*RecordActivityTaskHeartbeatByIdRequest) GetDetails

func (*RecordActivityTaskHeartbeatByIdRequest) GetIdentity

func (*RecordActivityTaskHeartbeatByIdRequest) GetNamespace

func (*RecordActivityTaskHeartbeatByIdRequest) GetRunId

func (*RecordActivityTaskHeartbeatByIdRequest) GetWorkflowId

func (*RecordActivityTaskHeartbeatByIdRequest) GoString

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) Reset

func (*RecordActivityTaskHeartbeatByIdRequest) Size

func (*RecordActivityTaskHeartbeatByIdRequest) 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 (*RecordActivityTaskHeartbeatByIdRequest) XXX_Size

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 (*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) Reset

func (*RecordActivityTaskHeartbeatByIdResponse) Size

func (*RecordActivityTaskHeartbeatByIdResponse) 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 (*RecordActivityTaskHeartbeatByIdResponse) XXX_Size

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 (*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 (*RecordActivityTaskHeartbeatRequest) Size

func (*RecordActivityTaskHeartbeatRequest) 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 (*RecordActivityTaskHeartbeatRequest) XXX_Size

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 (*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 (*RecordActivityTaskHeartbeatResponse) Size

func (*RecordActivityTaskHeartbeatResponse) 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 (*RecordActivityTaskHeartbeatResponse) XXX_Size

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"`
	WorkflowExecutionRetentionPeriodInDays int32                          `` /* 184-byte string literal not displayed */
	EmitMetric                             bool                           `protobuf:"varint,5,opt,name=emit_metric,json=emitMetric,proto3" json:"emit_metric,omitempty"`
	Clusters                               []*v1.ClusterReplicationConfig `protobuf:"bytes,6,rep,name=clusters,proto3" json:"clusters,omitempty"`
	ActiveClusterName                      string                         `protobuf:"bytes,7,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,9,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
	IsGlobalNamespace        bool               `protobuf:"varint,10,opt,name=is_global_namespace,json=isGlobalNamespace,proto3" json:"is_global_namespace,omitempty"`
	HistoryArchivalStatus    v11.ArchivalStatus `` /* 166-byte string literal not displayed */
	HistoryArchivalUri       string             `protobuf:"bytes,12,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
	VisibilityArchivalStatus v11.ArchivalStatus `` /* 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 (*RegisterNamespaceRequest) GetData

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

func (*RegisterNamespaceRequest) GetDescription

func (m *RegisterNamespaceRequest) GetDescription() string

func (*RegisterNamespaceRequest) GetEmitMetric

func (m *RegisterNamespaceRequest) GetEmitMetric() bool

func (*RegisterNamespaceRequest) GetHistoryArchivalStatus

func (m *RegisterNamespaceRequest) GetHistoryArchivalStatus() v11.ArchivalStatus

func (*RegisterNamespaceRequest) GetHistoryArchivalUri added in v0.24.4

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) GetVisibilityArchivalStatus

func (m *RegisterNamespaceRequest) GetVisibilityArchivalStatus() v11.ArchivalStatus

func (*RegisterNamespaceRequest) GetVisibilityArchivalUri added in v0.24.4

func (m *RegisterNamespaceRequest) GetVisibilityArchivalUri() string

func (*RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriodInDays

func (m *RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriodInDays() int32

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"`
}

func (*RequestCancelWorkflowExecutionRequest) Descriptor

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

func (*RequestCancelWorkflowExecutionRequest) Equal

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

func (*RequestCancelWorkflowExecutionRequest) GetIdentity

func (*RequestCancelWorkflowExecutionRequest) GetNamespace

func (*RequestCancelWorkflowExecutionRequest) GetRequestId

func (*RequestCancelWorkflowExecutionRequest) GetWorkflowExecution

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

func (*RequestCancelWorkflowExecutionRequest) GoString

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 (*RequestCancelWorkflowExecutionRequest) Size

func (*RequestCancelWorkflowExecutionRequest) 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 (*RequestCancelWorkflowExecutionRequest) XXX_Size

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 (*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) Reset

func (*RequestCancelWorkflowExecutionResponse) Size

func (*RequestCancelWorkflowExecutionResponse) 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 (*RequestCancelWorkflowExecutionResponse) XXX_Size

func (*RequestCancelWorkflowExecutionResponse) XXX_Unmarshal

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

type ResetStickyTaskListRequest

type ResetStickyTaskListRequest 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 (*ResetStickyTaskListRequest) Descriptor

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

func (*ResetStickyTaskListRequest) Equal

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

func (*ResetStickyTaskListRequest) GetExecution

func (*ResetStickyTaskListRequest) GetNamespace

func (m *ResetStickyTaskListRequest) GetNamespace() string

func (*ResetStickyTaskListRequest) GoString

func (this *ResetStickyTaskListRequest) GoString() string

func (*ResetStickyTaskListRequest) Marshal

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

func (*ResetStickyTaskListRequest) MarshalTo

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

func (*ResetStickyTaskListRequest) MarshalToSizedBuffer

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

func (*ResetStickyTaskListRequest) ProtoMessage

func (*ResetStickyTaskListRequest) ProtoMessage()

func (*ResetStickyTaskListRequest) Reset

func (m *ResetStickyTaskListRequest) Reset()

func (*ResetStickyTaskListRequest) Size

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

func (*ResetStickyTaskListRequest) String

func (this *ResetStickyTaskListRequest) String() string

func (*ResetStickyTaskListRequest) Unmarshal

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

func (*ResetStickyTaskListRequest) XXX_DiscardUnknown

func (m *ResetStickyTaskListRequest) XXX_DiscardUnknown()

func (*ResetStickyTaskListRequest) XXX_Marshal

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

func (*ResetStickyTaskListRequest) XXX_Merge

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

func (*ResetStickyTaskListRequest) XXX_Size

func (m *ResetStickyTaskListRequest) XXX_Size() int

func (*ResetStickyTaskListRequest) XXX_Unmarshal

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

type ResetStickyTaskListResponse

type ResetStickyTaskListResponse struct {
}

func (*ResetStickyTaskListResponse) Descriptor

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

func (*ResetStickyTaskListResponse) Equal

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

func (*ResetStickyTaskListResponse) GoString

func (this *ResetStickyTaskListResponse) GoString() string

func (*ResetStickyTaskListResponse) Marshal

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

func (*ResetStickyTaskListResponse) MarshalTo

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

func (*ResetStickyTaskListResponse) MarshalToSizedBuffer

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

func (*ResetStickyTaskListResponse) ProtoMessage

func (*ResetStickyTaskListResponse) ProtoMessage()

func (*ResetStickyTaskListResponse) Reset

func (m *ResetStickyTaskListResponse) Reset()

func (*ResetStickyTaskListResponse) Size

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

func (*ResetStickyTaskListResponse) String

func (this *ResetStickyTaskListResponse) String() string

func (*ResetStickyTaskListResponse) Unmarshal

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

func (*ResetStickyTaskListResponse) XXX_DiscardUnknown

func (m *ResetStickyTaskListResponse) XXX_DiscardUnknown()

func (*ResetStickyTaskListResponse) XXX_Marshal

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

func (*ResetStickyTaskListResponse) XXX_Merge

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

func (*ResetStickyTaskListResponse) XXX_Size

func (m *ResetStickyTaskListResponse) XXX_Size() int

func (*ResetStickyTaskListResponse) XXX_Unmarshal

func (m *ResetStickyTaskListResponse) 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"`
	DecisionFinishEventId int64                  `` /* 129-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) GetDecisionFinishEventId

func (m *ResetWorkflowExecutionRequest) GetDecisionFinishEventId() int64

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) 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 (*RespondActivityTaskCanceledByIdRequest) GetDetails

func (*RespondActivityTaskCanceledByIdRequest) GetIdentity

func (*RespondActivityTaskCanceledByIdRequest) GetNamespace

func (*RespondActivityTaskCanceledByIdRequest) GetRunId

func (*RespondActivityTaskCanceledByIdRequest) GetWorkflowId

func (*RespondActivityTaskCanceledByIdRequest) GoString

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) Reset

func (*RespondActivityTaskCanceledByIdRequest) Size

func (*RespondActivityTaskCanceledByIdRequest) 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 (*RespondActivityTaskCanceledByIdRequest) XXX_Size

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 (*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) Reset

func (*RespondActivityTaskCanceledByIdResponse) Size

func (*RespondActivityTaskCanceledByIdResponse) 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 (*RespondActivityTaskCanceledByIdResponse) XXX_Size

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 (*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 (*RespondActivityTaskCanceledRequest) Size

func (*RespondActivityTaskCanceledRequest) 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 (*RespondActivityTaskCanceledRequest) XXX_Size

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 (*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 (*RespondActivityTaskCanceledResponse) Size

func (*RespondActivityTaskCanceledResponse) 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 (*RespondActivityTaskCanceledResponse) XXX_Size

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 (*RespondActivityTaskCompletedByIdRequest) GetIdentity

func (*RespondActivityTaskCompletedByIdRequest) GetNamespace

func (*RespondActivityTaskCompletedByIdRequest) GetResult

func (*RespondActivityTaskCompletedByIdRequest) GetRunId

func (*RespondActivityTaskCompletedByIdRequest) GetWorkflowId

func (*RespondActivityTaskCompletedByIdRequest) GoString

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) Reset

func (*RespondActivityTaskCompletedByIdRequest) Size

func (*RespondActivityTaskCompletedByIdRequest) 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 (*RespondActivityTaskCompletedByIdRequest) XXX_Size

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 (*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) Reset

func (*RespondActivityTaskCompletedByIdResponse) Size

func (*RespondActivityTaskCompletedByIdResponse) String

func (*RespondActivityTaskCompletedByIdResponse) Unmarshal

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 (*RespondActivityTaskCompletedByIdResponse) XXX_Size

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 (*RespondActivityTaskCompletedRequest) GetResult

func (*RespondActivityTaskCompletedRequest) GetTaskToken

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

func (*RespondActivityTaskCompletedRequest) GoString

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 (*RespondActivityTaskCompletedRequest) Size

func (*RespondActivityTaskCompletedRequest) 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 (*RespondActivityTaskCompletedRequest) XXX_Size

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 (*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 (*RespondActivityTaskCompletedResponse) Size

func (*RespondActivityTaskCompletedResponse) 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 (*RespondActivityTaskCompletedResponse) XXX_Size

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 (*RespondActivityTaskFailedByIdRequest) GetIdentity

func (*RespondActivityTaskFailedByIdRequest) GetNamespace

func (m *RespondActivityTaskFailedByIdRequest) GetNamespace() string

func (*RespondActivityTaskFailedByIdRequest) GetRunId

func (*RespondActivityTaskFailedByIdRequest) GetWorkflowId

func (m *RespondActivityTaskFailedByIdRequest) GetWorkflowId() string

func (*RespondActivityTaskFailedByIdRequest) GoString

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 (*RespondActivityTaskFailedByIdRequest) Size

func (*RespondActivityTaskFailedByIdRequest) 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 (*RespondActivityTaskFailedByIdRequest) XXX_Size

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 (*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 (*RespondActivityTaskFailedByIdResponse) Size

func (*RespondActivityTaskFailedByIdResponse) 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 (*RespondActivityTaskFailedByIdResponse) XXX_Size

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 (*RespondActivityTaskFailedRequest) Size

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

func (*RespondActivityTaskFailedRequest) 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 (*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 (*RespondActivityTaskFailedResponse) Size

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

func (*RespondActivityTaskFailedResponse) 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 (*RespondActivityTaskFailedResponse) XXX_Size

func (m *RespondActivityTaskFailedResponse) XXX_Size() int

func (*RespondActivityTaskFailedResponse) XXX_Unmarshal

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

type RespondDecisionTaskCompletedRequest

type RespondDecisionTaskCompletedRequest struct {
	TaskToken                  []byte                              `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	Decisions                  []*v17.Decision                     `protobuf:"bytes,2,rep,name=decisions,proto3" json:"decisions,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"`
	ReturnNewDecisionTask      bool                                `` /* 129-byte string literal not displayed */
	ForceCreateNewDecisionTask 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 (*RespondDecisionTaskCompletedRequest) Descriptor

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

func (*RespondDecisionTaskCompletedRequest) Equal

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

func (*RespondDecisionTaskCompletedRequest) GetBinaryChecksum

func (m *RespondDecisionTaskCompletedRequest) GetBinaryChecksum() string

func (*RespondDecisionTaskCompletedRequest) GetDecisions

func (m *RespondDecisionTaskCompletedRequest) GetDecisions() []*v17.Decision

func (*RespondDecisionTaskCompletedRequest) GetForceCreateNewDecisionTask

func (m *RespondDecisionTaskCompletedRequest) GetForceCreateNewDecisionTask() bool

func (*RespondDecisionTaskCompletedRequest) GetIdentity

func (*RespondDecisionTaskCompletedRequest) GetQueryResults

func (*RespondDecisionTaskCompletedRequest) GetReturnNewDecisionTask

func (m *RespondDecisionTaskCompletedRequest) GetReturnNewDecisionTask() bool

func (*RespondDecisionTaskCompletedRequest) GetStickyAttributes

func (*RespondDecisionTaskCompletedRequest) GetTaskToken

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

func (*RespondDecisionTaskCompletedRequest) GoString

func (*RespondDecisionTaskCompletedRequest) Marshal

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

func (*RespondDecisionTaskCompletedRequest) MarshalTo

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

func (*RespondDecisionTaskCompletedRequest) MarshalToSizedBuffer

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

func (*RespondDecisionTaskCompletedRequest) ProtoMessage

func (*RespondDecisionTaskCompletedRequest) ProtoMessage()

func (*RespondDecisionTaskCompletedRequest) Reset

func (*RespondDecisionTaskCompletedRequest) Size

func (*RespondDecisionTaskCompletedRequest) String

func (*RespondDecisionTaskCompletedRequest) Unmarshal

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

func (*RespondDecisionTaskCompletedRequest) XXX_DiscardUnknown

func (m *RespondDecisionTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondDecisionTaskCompletedRequest) XXX_Marshal

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

func (*RespondDecisionTaskCompletedRequest) XXX_Merge

func (*RespondDecisionTaskCompletedRequest) XXX_Size

func (*RespondDecisionTaskCompletedRequest) XXX_Unmarshal

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

type RespondDecisionTaskCompletedResponse

type RespondDecisionTaskCompletedResponse struct {
	DecisionTask *PollForDecisionTaskResponse `protobuf:"bytes,1,opt,name=decision_task,json=decisionTask,proto3" json:"decision_task,omitempty"`
}

func (*RespondDecisionTaskCompletedResponse) Descriptor

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

func (*RespondDecisionTaskCompletedResponse) Equal

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

func (*RespondDecisionTaskCompletedResponse) GetDecisionTask

func (*RespondDecisionTaskCompletedResponse) GoString

func (*RespondDecisionTaskCompletedResponse) Marshal

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

func (*RespondDecisionTaskCompletedResponse) MarshalTo

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

func (*RespondDecisionTaskCompletedResponse) MarshalToSizedBuffer

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

func (*RespondDecisionTaskCompletedResponse) ProtoMessage

func (*RespondDecisionTaskCompletedResponse) ProtoMessage()

func (*RespondDecisionTaskCompletedResponse) Reset

func (*RespondDecisionTaskCompletedResponse) Size

func (*RespondDecisionTaskCompletedResponse) String

func (*RespondDecisionTaskCompletedResponse) Unmarshal

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

func (*RespondDecisionTaskCompletedResponse) XXX_DiscardUnknown

func (m *RespondDecisionTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondDecisionTaskCompletedResponse) XXX_Marshal

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

func (*RespondDecisionTaskCompletedResponse) XXX_Merge

func (*RespondDecisionTaskCompletedResponse) XXX_Size

func (*RespondDecisionTaskCompletedResponse) XXX_Unmarshal

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

type RespondDecisionTaskFailedRequest

type RespondDecisionTaskFailedRequest struct {
	TaskToken      []byte                      `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	Cause          v11.DecisionTaskFailedCause `protobuf:"varint,2,opt,name=cause,proto3,enum=temporal.enums.v1.DecisionTaskFailedCause" 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 (*RespondDecisionTaskFailedRequest) Descriptor

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

func (*RespondDecisionTaskFailedRequest) Equal

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

func (*RespondDecisionTaskFailedRequest) GetBinaryChecksum

func (m *RespondDecisionTaskFailedRequest) GetBinaryChecksum() string

func (*RespondDecisionTaskFailedRequest) GetCause

func (*RespondDecisionTaskFailedRequest) GetFailure

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

func (*RespondDecisionTaskFailedRequest) GetIdentity

func (m *RespondDecisionTaskFailedRequest) GetIdentity() string

func (*RespondDecisionTaskFailedRequest) GetTaskToken

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

func (*RespondDecisionTaskFailedRequest) GoString

func (this *RespondDecisionTaskFailedRequest) GoString() string

func (*RespondDecisionTaskFailedRequest) Marshal

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

func (*RespondDecisionTaskFailedRequest) MarshalTo

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

func (*RespondDecisionTaskFailedRequest) MarshalToSizedBuffer

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

func (*RespondDecisionTaskFailedRequest) ProtoMessage

func (*RespondDecisionTaskFailedRequest) ProtoMessage()

func (*RespondDecisionTaskFailedRequest) Reset

func (*RespondDecisionTaskFailedRequest) Size

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

func (*RespondDecisionTaskFailedRequest) String

func (*RespondDecisionTaskFailedRequest) Unmarshal

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

func (*RespondDecisionTaskFailedRequest) XXX_DiscardUnknown

func (m *RespondDecisionTaskFailedRequest) XXX_DiscardUnknown()

func (*RespondDecisionTaskFailedRequest) XXX_Marshal

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

func (*RespondDecisionTaskFailedRequest) XXX_Merge

func (*RespondDecisionTaskFailedRequest) XXX_Size

func (m *RespondDecisionTaskFailedRequest) XXX_Size() int

func (*RespondDecisionTaskFailedRequest) XXX_Unmarshal

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

type RespondDecisionTaskFailedResponse

type RespondDecisionTaskFailedResponse struct {
}

func (*RespondDecisionTaskFailedResponse) Descriptor

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

func (*RespondDecisionTaskFailedResponse) Equal

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

func (*RespondDecisionTaskFailedResponse) GoString

func (this *RespondDecisionTaskFailedResponse) GoString() string

func (*RespondDecisionTaskFailedResponse) Marshal

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

func (*RespondDecisionTaskFailedResponse) MarshalTo

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

func (*RespondDecisionTaskFailedResponse) MarshalToSizedBuffer

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

func (*RespondDecisionTaskFailedResponse) ProtoMessage

func (*RespondDecisionTaskFailedResponse) ProtoMessage()

func (*RespondDecisionTaskFailedResponse) Reset

func (*RespondDecisionTaskFailedResponse) Size

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

func (*RespondDecisionTaskFailedResponse) String

func (*RespondDecisionTaskFailedResponse) Unmarshal

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

func (*RespondDecisionTaskFailedResponse) XXX_DiscardUnknown

func (m *RespondDecisionTaskFailedResponse) XXX_DiscardUnknown()

func (*RespondDecisionTaskFailedResponse) XXX_Marshal

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

func (*RespondDecisionTaskFailedResponse) XXX_Merge

func (*RespondDecisionTaskFailedResponse) XXX_Size

func (m *RespondDecisionTaskFailedResponse) XXX_Size() int

func (*RespondDecisionTaskFailedResponse) XXX_Unmarshal

func (m *RespondDecisionTaskFailedResponse) 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     `` /* 140-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 (*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 (*RespondQueryTaskCompletedRequest) Size

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

func (*RespondQueryTaskCompletedRequest) 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 (*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 (*RespondQueryTaskCompletedResponse) Size

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

func (*RespondQueryTaskCompletedResponse) 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 (*RespondQueryTaskCompletedResponse) XXX_Size

func (m *RespondQueryTaskCompletedResponse) XXX_Size() int

func (*RespondQueryTaskCompletedResponse) XXX_Unmarshal

func (m *RespondQueryTaskCompletedResponse) 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 (*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"`
	TaskList     *v14.TaskList     `protobuf:"bytes,4,opt,name=task_list,json=taskList,proto3" json:"task_list,omitempty"`
	Input        *v13.Payloads     `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new
	WorkflowExecutionTimeoutSeconds int32 `` /* 159-byte string literal not displayed */
	// Timeout of a single workflow run
	WorkflowRunTimeoutSeconds int32 `` /* 141-byte string literal not displayed */
	// Timeout of a single workflow task
	WorkflowTaskTimeoutSeconds int32                     `` /* 144-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 `` /* 175-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"`
	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 (*SignalWithStartWorkflowExecutionRequest) GetCronSchedule

func (m *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() string

func (*SignalWithStartWorkflowExecutionRequest) GetHeader

func (*SignalWithStartWorkflowExecutionRequest) GetIdentity

func (*SignalWithStartWorkflowExecutionRequest) GetInput

func (*SignalWithStartWorkflowExecutionRequest) GetMemo

func (*SignalWithStartWorkflowExecutionRequest) GetNamespace

func (*SignalWithStartWorkflowExecutionRequest) GetRequestId

func (*SignalWithStartWorkflowExecutionRequest) GetRetryPolicy

func (*SignalWithStartWorkflowExecutionRequest) GetSearchAttributes

func (*SignalWithStartWorkflowExecutionRequest) GetSignalInput

func (*SignalWithStartWorkflowExecutionRequest) GetSignalName

func (*SignalWithStartWorkflowExecutionRequest) GetTaskList

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeoutSeconds

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeoutSeconds() int32

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowId

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeoutSeconds

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeoutSeconds() int32

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeoutSeconds

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeoutSeconds() int32

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowType

func (*SignalWithStartWorkflowExecutionRequest) GoString

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) Reset

func (*SignalWithStartWorkflowExecutionRequest) Size

func (*SignalWithStartWorkflowExecutionRequest) 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 (*SignalWithStartWorkflowExecutionRequest) XXX_Size

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 (*SignalWithStartWorkflowExecutionResponse) GoString

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) Reset

func (*SignalWithStartWorkflowExecutionResponse) Size

func (*SignalWithStartWorkflowExecutionResponse) String

func (*SignalWithStartWorkflowExecutionResponse) Unmarshal

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 (*SignalWithStartWorkflowExecutionResponse) XXX_Size

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 (*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 (*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"`
	TaskList     *v14.TaskList     `protobuf:"bytes,4,opt,name=task_list,json=taskList,proto3" json:"task_list,omitempty"`
	Input        *v13.Payloads     `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new.
	WorkflowExecutionTimeoutSeconds int32 `` /* 159-byte string literal not displayed */
	// Timeout of a single workflow run.
	WorkflowRunTimeoutSeconds int32 `` /* 141-byte string literal not displayed */
	// Timeout of a single workflow task.
	WorkflowTaskTimeoutSeconds int32                     `` /* 144-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 `` /* 175-byte string literal not displayed */
	// Retries up to workflowExecutionTimeoutSeconds.
	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 (*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) GetTaskList

func (m *StartWorkflowExecutionRequest) GetTaskList() *v14.TaskList

func (*StartWorkflowExecutionRequest) GetWorkflowExecutionTimeoutSeconds

func (m *StartWorkflowExecutionRequest) GetWorkflowExecutionTimeoutSeconds() int32

func (*StartWorkflowExecutionRequest) GetWorkflowId

func (m *StartWorkflowExecutionRequest) GetWorkflowId() string

func (*StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy

func (m *StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

func (*StartWorkflowExecutionRequest) GetWorkflowRunTimeoutSeconds

func (m *StartWorkflowExecutionRequest) GetWorkflowRunTimeoutSeconds() int32

func (*StartWorkflowExecutionRequest) GetWorkflowTaskTimeoutSeconds

func (m *StartWorkflowExecutionRequest) GetWorkflowTaskTimeoutSeconds() int32

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"`
}

func (*TerminateWorkflowExecutionRequest) Descriptor

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

func (*TerminateWorkflowExecutionRequest) Equal

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

func (*TerminateWorkflowExecutionRequest) GetDetails

func (*TerminateWorkflowExecutionRequest) GetIdentity

func (m *TerminateWorkflowExecutionRequest) GetIdentity() string

func (*TerminateWorkflowExecutionRequest) GetNamespace

func (m *TerminateWorkflowExecutionRequest) GetNamespace() string

func (*TerminateWorkflowExecutionRequest) GetReason

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 (*TerminateWorkflowExecutionRequest) Size

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

func (*TerminateWorkflowExecutionRequest) 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 (*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 (*TerminateWorkflowExecutionResponse) Size

func (*TerminateWorkflowExecutionResponse) 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 (*TerminateWorkflowExecutionResponse) XXX_Size

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) DeprecateNamespace

func (*UnimplementedWorkflowServiceServer) DescribeNamespace

func (*UnimplementedWorkflowServiceServer) DescribeTaskList

func (*UnimplementedWorkflowServiceServer) DescribeWorkflowExecution

func (*UnimplementedWorkflowServiceServer) GetClusterInfo

func (*UnimplementedWorkflowServiceServer) GetSearchAttributes

func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory

func (*UnimplementedWorkflowServiceServer) ListArchivedWorkflowExecutions

func (*UnimplementedWorkflowServiceServer) ListClosedWorkflowExecutions

func (*UnimplementedWorkflowServiceServer) ListNamespaces

func (*UnimplementedWorkflowServiceServer) ListOpenWorkflowExecutions

func (*UnimplementedWorkflowServiceServer) ListTaskListPartitions

func (*UnimplementedWorkflowServiceServer) ListWorkflowExecutions

func (*UnimplementedWorkflowServiceServer) PollForActivityTask

func (*UnimplementedWorkflowServiceServer) PollForDecisionTask

func (*UnimplementedWorkflowServiceServer) QueryWorkflow

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeat

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeatById

func (*UnimplementedWorkflowServiceServer) RegisterNamespace

func (*UnimplementedWorkflowServiceServer) RequestCancelWorkflowExecution

func (*UnimplementedWorkflowServiceServer) ResetStickyTaskList

func (*UnimplementedWorkflowServiceServer) ResetWorkflowExecution

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceled

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceledById

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompleted

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompletedById

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailed

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailedById

func (*UnimplementedWorkflowServiceServer) RespondDecisionTaskCompleted

func (*UnimplementedWorkflowServiceServer) RespondDecisionTaskFailed

func (*UnimplementedWorkflowServiceServer) RespondQueryTaskCompleted

func (*UnimplementedWorkflowServiceServer) ScanWorkflowExecutions

func (*UnimplementedWorkflowServiceServer) SignalWithStartWorkflowExecution

func (*UnimplementedWorkflowServiceServer) SignalWorkflowExecution

func (*UnimplementedWorkflowServiceServer) StartWorkflowExecution

func (*UnimplementedWorkflowServiceServer) TerminateWorkflowExecution

func (*UnimplementedWorkflowServiceServer) UpdateNamespace

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"`
}

func (*UpdateNamespaceRequest) Descriptor

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

func (*UpdateNamespaceRequest) Equal

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

func (*UpdateNamespaceRequest) GetConfig added in v0.24.4

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 added in v0.24.4

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

func (*UpdateNamespaceRequest) GetSecurityToken

func (m *UpdateNamespaceRequest) GetSecurityToken() string

func (*UpdateNamespaceRequest) GetUpdateInfo added in v0.24.4

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 added in v0.24.4

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 added in v0.24.4

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 lists, 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)
	// 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 us used to update status 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 DecisionTask for the worker to make the
	// first decision 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)
	// PollForDecisionTask is called by application worker to process DecisionTask from a specific task list.  A
	// DecisionTask is dispatched to callers for active workflow executions, with pending decisions.
	// Application is then expected to call 'RespondDecisionTaskCompleted' API when it is done processing the DecisionTask.
	// It will also create a 'DecisionTaskStarted' event in the history for that session before handing off DecisionTask to
	// application worker.
	PollForDecisionTask(ctx context.Context, in *PollForDecisionTaskRequest, opts ...grpc.CallOption) (*PollForDecisionTaskResponse, error)
	// RespondDecisionTaskCompleted is called by application worker to complete a DecisionTask handed as a result of
	// 'PollForDecisionTask' API call.  Completing a DecisionTask will result in new events for the workflow execution and
	// potentially new ActivityTask being created for corresponding decisions.  It will also create a DecisionTaskCompleted
	// event in the history for that session.  Use the 'taskToken' provided as response of PollForDecisionTask API call
	// for completing the DecisionTask.
	// The response could contain a new decision task if there is one or if the request asking for one.
	RespondDecisionTaskCompleted(ctx context.Context, in *RespondDecisionTaskCompletedRequest, opts ...grpc.CallOption) (*RespondDecisionTaskCompletedResponse, error)
	// RespondDecisionTaskFailed is called by application worker to indicate failure.  This results in
	// DecisionTaskFailedEvent written to the history and a new DecisionTask created.  This API can be used by client to
	// either clear sticky task list or report any panics during DecisionTask processing.  Temporal will only append first
	// DecisionTaskFailed event to the history of workflow execution for consecutive failures.
	RespondDecisionTaskFailed(ctx context.Context, in *RespondDecisionTaskFailedRequest, opts ...grpc.CallOption) (*RespondDecisionTaskFailedResponse, error)
	// PollForActivityTask is called by application worker to process ActivityTask from a specific task list.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask decision 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.
	PollForActivityTask(ctx context.Context, in *PollForActivityTaskRequest, opts ...grpc.CallOption) (*PollForActivityTaskResponse, 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
	// PollForActivityTask API call for heart beating.
	RecordActivityTaskHeartbeat(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatResponse, error)
	// 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 DecisionTask
	// created for the workflow so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask 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)
	// 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 DecisionTask
	// created for the workflow so new decisions 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 DecisionTask
	// created for the workflow instance so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask 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)
	// 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 DecisionTask
	// created for the workflow instance so new decisions 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 DecisionTask
	// created for the workflow instance so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask 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)
	// 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 DecisionTask
	// created for the workflow instance so new decisions 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 DecisionTask
	// created for the workflow instance so new decisions 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 decision task being created for the execution.
	SignalWorkflowExecution(ctx context.Context, in *SignalWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWorkflowExecutionResponse, error)
	// 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 decision 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 decision task being created for the execution
	SignalWithStartWorkflowExecution(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution to DecisionTaskCompleted 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 DecisionTask for query)
	// as a result of 'PollForDecisionTask' 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)
	// ResetStickyTaskList resets the sticky task list related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskList
	// 2. StickyScheduleToStartTimeout
	// 3. ClientLibraryVersion
	// 4. ClientFeatureVersion
	// 5. ClientImpl
	ResetStickyTaskList(ctx context.Context, in *ResetStickyTaskListRequest, opts ...grpc.CallOption) (*ResetStickyTaskListResponse, 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)
	// DescribeTaskList returns information about the target task list, right now this API returns the
	// pollers which polled this task list in last few minutes.
	DescribeTaskList(ctx context.Context, in *DescribeTaskListRequest, opts ...grpc.CallOption) (*DescribeTaskListResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
	ListTaskListPartitions(ctx context.Context, in *ListTaskListPartitionsRequest, opts ...grpc.CallOption) (*ListTaskListPartitionsResponse, 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 lists, 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)
	// UpdateNamespace is used to update the information and configuration for a registered namespace.
	UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace us used to update status 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 DecisionTask for the worker to make the
	// first decision 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)
	// PollForDecisionTask is called by application worker to process DecisionTask from a specific task list.  A
	// DecisionTask is dispatched to callers for active workflow executions, with pending decisions.
	// Application is then expected to call 'RespondDecisionTaskCompleted' API when it is done processing the DecisionTask.
	// It will also create a 'DecisionTaskStarted' event in the history for that session before handing off DecisionTask to
	// application worker.
	PollForDecisionTask(context.Context, *PollForDecisionTaskRequest) (*PollForDecisionTaskResponse, error)
	// RespondDecisionTaskCompleted is called by application worker to complete a DecisionTask handed as a result of
	// 'PollForDecisionTask' API call.  Completing a DecisionTask will result in new events for the workflow execution and
	// potentially new ActivityTask being created for corresponding decisions.  It will also create a DecisionTaskCompleted
	// event in the history for that session.  Use the 'taskToken' provided as response of PollForDecisionTask API call
	// for completing the DecisionTask.
	// The response could contain a new decision task if there is one or if the request asking for one.
	RespondDecisionTaskCompleted(context.Context, *RespondDecisionTaskCompletedRequest) (*RespondDecisionTaskCompletedResponse, error)
	// RespondDecisionTaskFailed is called by application worker to indicate failure.  This results in
	// DecisionTaskFailedEvent written to the history and a new DecisionTask created.  This API can be used by client to
	// either clear sticky task list or report any panics during DecisionTask processing.  Temporal will only append first
	// DecisionTaskFailed event to the history of workflow execution for consecutive failures.
	RespondDecisionTaskFailed(context.Context, *RespondDecisionTaskFailedRequest) (*RespondDecisionTaskFailedResponse, error)
	// PollForActivityTask is called by application worker to process ActivityTask from a specific task list.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask decision 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.
	PollForActivityTask(context.Context, *PollForActivityTaskRequest) (*PollForActivityTaskResponse, 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
	// PollForActivityTask API call for heart beating.
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)
	// 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 DecisionTask
	// created for the workflow so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask 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)
	// 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 DecisionTask
	// created for the workflow so new decisions 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 DecisionTask
	// created for the workflow instance so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask 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)
	// 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 DecisionTask
	// created for the workflow instance so new decisions 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 DecisionTask
	// created for the workflow instance so new decisions could be made.  Use the 'taskToken' provided as response of
	// PollForActivityTask 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)
	// 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 DecisionTask
	// created for the workflow instance so new decisions 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 DecisionTask
	// created for the workflow instance so new decisions 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 decision task being created for the execution.
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)
	// 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 decision 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 decision task being created for the execution
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution to DecisionTaskCompleted 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 DecisionTask for query)
	// as a result of 'PollForDecisionTask' 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)
	// ResetStickyTaskList resets the sticky task list related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskList
	// 2. StickyScheduleToStartTimeout
	// 3. ClientLibraryVersion
	// 4. ClientFeatureVersion
	// 5. ClientImpl
	ResetStickyTaskList(context.Context, *ResetStickyTaskListRequest) (*ResetStickyTaskListResponse, 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)
	// DescribeTaskList returns information about the target task list, right now this API returns the
	// pollers which polled this task list in last few minutes.
	DescribeTaskList(context.Context, *DescribeTaskListRequest) (*DescribeTaskListResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	ListTaskListPartitions(context.Context, *ListTaskListPartitionsRequest) (*ListTaskListPartitionsResponse, error)
}

WorkflowServiceServer is the server API for WorkflowService service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL