workflowservice

package
v0.28.0 Latest Latest
Warning

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

Go to latest
Published: Jul 31, 2020 License: MIT Imports: 28 Imported by: 145

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

func (*DescribeNamespaceResponse) GetFailoverVersion

func (m *DescribeNamespaceResponse) GetFailoverVersion() int64

func (*DescribeNamespaceResponse) GetIsGlobalNamespace

func (m *DescribeNamespaceResponse) GetIsGlobalNamespace() bool

func (*DescribeNamespaceResponse) GetNamespaceInfo

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

func (*DescribeNamespaceResponse) GetReplicationConfig

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

func (*DescribeNamespaceResponse) GoString

func (this *DescribeNamespaceResponse) GoString() string

func (*DescribeNamespaceResponse) Marshal

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

func (*DescribeNamespaceResponse) MarshalTo

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

func (*DescribeNamespaceResponse) MarshalToSizedBuffer

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

func (*DescribeNamespaceResponse) ProtoMessage

func (*DescribeNamespaceResponse) ProtoMessage()

func (*DescribeNamespaceResponse) Reset

func (m *DescribeNamespaceResponse) Reset()

func (*DescribeNamespaceResponse) Size

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

func (*DescribeNamespaceResponse) String

func (this *DescribeNamespaceResponse) String() string

func (*DescribeNamespaceResponse) Unmarshal

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

func (*DescribeNamespaceResponse) XXX_DiscardUnknown

func (m *DescribeNamespaceResponse) XXX_DiscardUnknown()

func (*DescribeNamespaceResponse) XXX_Marshal

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

func (*DescribeNamespaceResponse) XXX_Merge

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

func (*DescribeNamespaceResponse) XXX_Size

func (m *DescribeNamespaceResponse) XXX_Size() int

func (*DescribeNamespaceResponse) XXX_Unmarshal

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

type DescribeTaskQueueRequest

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

func (*DescribeTaskQueueRequest) Descriptor

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

func (*DescribeTaskQueueRequest) Equal

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

func (*DescribeTaskQueueRequest) GetIncludeTaskQueueStatus

func (m *DescribeTaskQueueRequest) GetIncludeTaskQueueStatus() bool

func (*DescribeTaskQueueRequest) GetNamespace

func (m *DescribeTaskQueueRequest) GetNamespace() string

func (*DescribeTaskQueueRequest) GetTaskQueue

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

func (*DescribeTaskQueueRequest) GetTaskQueueType

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

func (*DescribeTaskQueueRequest) GoString

func (this *DescribeTaskQueueRequest) GoString() string

func (*DescribeTaskQueueRequest) Marshal

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

func (*DescribeTaskQueueRequest) MarshalTo

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

func (*DescribeTaskQueueRequest) MarshalToSizedBuffer

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

func (*DescribeTaskQueueRequest) ProtoMessage

func (*DescribeTaskQueueRequest) ProtoMessage()

func (*DescribeTaskQueueRequest) Reset

func (m *DescribeTaskQueueRequest) Reset()

func (*DescribeTaskQueueRequest) Size

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

func (*DescribeTaskQueueRequest) String

func (this *DescribeTaskQueueRequest) String() string

func (*DescribeTaskQueueRequest) Unmarshal

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

func (*DescribeTaskQueueRequest) XXX_DiscardUnknown

func (m *DescribeTaskQueueRequest) XXX_DiscardUnknown()

func (*DescribeTaskQueueRequest) XXX_Marshal

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

func (*DescribeTaskQueueRequest) XXX_Merge

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

func (*DescribeTaskQueueRequest) XXX_Size

func (m *DescribeTaskQueueRequest) XXX_Size() int

func (*DescribeTaskQueueRequest) XXX_Unmarshal

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

type DescribeTaskQueueResponse

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

func (*DescribeTaskQueueResponse) Descriptor

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

func (*DescribeTaskQueueResponse) Equal

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

func (*DescribeTaskQueueResponse) GetPollers

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

func (*DescribeTaskQueueResponse) GetTaskQueueStatus

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

func (*DescribeTaskQueueResponse) GoString

func (this *DescribeTaskQueueResponse) GoString() string

func (*DescribeTaskQueueResponse) Marshal

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

func (*DescribeTaskQueueResponse) MarshalTo

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

func (*DescribeTaskQueueResponse) MarshalToSizedBuffer

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

func (*DescribeTaskQueueResponse) ProtoMessage

func (*DescribeTaskQueueResponse) ProtoMessage()

func (*DescribeTaskQueueResponse) Reset

func (m *DescribeTaskQueueResponse) Reset()

func (*DescribeTaskQueueResponse) Size

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

func (*DescribeTaskQueueResponse) String

func (this *DescribeTaskQueueResponse) String() string

func (*DescribeTaskQueueResponse) Unmarshal

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

func (*DescribeTaskQueueResponse) XXX_DiscardUnknown

func (m *DescribeTaskQueueResponse) XXX_DiscardUnknown()

func (*DescribeTaskQueueResponse) XXX_Marshal

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

func (*DescribeTaskQueueResponse) XXX_Merge

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

func (*DescribeTaskQueueResponse) XXX_Size

func (m *DescribeTaskQueueResponse) XXX_Size() int

func (*DescribeTaskQueueResponse) XXX_Unmarshal

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

type DescribeWorkflowExecutionRequest

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

func (*DescribeWorkflowExecutionRequest) Descriptor

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

func (*DescribeWorkflowExecutionRequest) Equal

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

func (*DescribeWorkflowExecutionRequest) GetExecution

func (*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

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

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

func (*GetClusterInfoResponse) GoString

func (this *GetClusterInfoResponse) GoString() string

func (*GetClusterInfoResponse) Marshal

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

func (*GetClusterInfoResponse) MarshalTo

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

func (*GetClusterInfoResponse) MarshalToSizedBuffer

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

func (*GetClusterInfoResponse) ProtoMessage

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) Reset

func (m *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) Size

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

func (*GetClusterInfoResponse) String

func (this *GetClusterInfoResponse) String() string

func (*GetClusterInfoResponse) Unmarshal

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

func (*GetClusterInfoResponse) XXX_DiscardUnknown

func (m *GetClusterInfoResponse) XXX_DiscardUnknown()

func (*GetClusterInfoResponse) XXX_Marshal

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

func (*GetClusterInfoResponse) XXX_Merge

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

func (*GetClusterInfoResponse) XXX_Size

func (m *GetClusterInfoResponse) XXX_Size() int

func (*GetClusterInfoResponse) XXX_Unmarshal

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

type GetSearchAttributesRequest

type GetSearchAttributesRequest struct {
}

func (*GetSearchAttributesRequest) Descriptor

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

func (*GetSearchAttributesRequest) Equal

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

func (*GetSearchAttributesRequest) GoString

func (this *GetSearchAttributesRequest) GoString() string

func (*GetSearchAttributesRequest) Marshal

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

func (*GetSearchAttributesRequest) MarshalTo

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

func (*GetSearchAttributesRequest) MarshalToSizedBuffer

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

func (*GetSearchAttributesRequest) ProtoMessage

func (*GetSearchAttributesRequest) ProtoMessage()

func (*GetSearchAttributesRequest) Reset

func (m *GetSearchAttributesRequest) Reset()

func (*GetSearchAttributesRequest) Size

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

func (*GetSearchAttributesRequest) String

func (this *GetSearchAttributesRequest) String() string

func (*GetSearchAttributesRequest) Unmarshal

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

func (*GetSearchAttributesRequest) XXX_DiscardUnknown

func (m *GetSearchAttributesRequest) XXX_DiscardUnknown()

func (*GetSearchAttributesRequest) XXX_Marshal

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

func (*GetSearchAttributesRequest) XXX_Merge

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

func (*GetSearchAttributesRequest) XXX_Size

func (m *GetSearchAttributesRequest) XXX_Size() int

func (*GetSearchAttributesRequest) XXX_Unmarshal

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

type GetSearchAttributesResponse

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

func (*GetSearchAttributesResponse) Descriptor

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

func (*GetSearchAttributesResponse) Equal

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

func (*GetSearchAttributesResponse) GetKeys

func (*GetSearchAttributesResponse) GoString

func (this *GetSearchAttributesResponse) GoString() string

func (*GetSearchAttributesResponse) Marshal

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

func (*GetSearchAttributesResponse) MarshalTo

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

func (*GetSearchAttributesResponse) MarshalToSizedBuffer

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

func (*GetSearchAttributesResponse) ProtoMessage

func (*GetSearchAttributesResponse) ProtoMessage()

func (*GetSearchAttributesResponse) Reset

func (m *GetSearchAttributesResponse) Reset()

func (*GetSearchAttributesResponse) Size

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

func (*GetSearchAttributesResponse) String

func (this *GetSearchAttributesResponse) String() string

func (*GetSearchAttributesResponse) Unmarshal

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

func (*GetSearchAttributesResponse) XXX_DiscardUnknown

func (m *GetSearchAttributesResponse) XXX_DiscardUnknown()

func (*GetSearchAttributesResponse) XXX_Marshal

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

func (*GetSearchAttributesResponse) XXX_Merge

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

func (*GetSearchAttributesResponse) XXX_Size

func (m *GetSearchAttributesResponse) XXX_Size() int

func (*GetSearchAttributesResponse) XXX_Unmarshal

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

type GetWorkflowExecutionHistoryRequest

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

func (*GetWorkflowExecutionHistoryRequest) Descriptor

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

func (*GetWorkflowExecutionHistoryRequest) Equal

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

func (*GetWorkflowExecutionHistoryRequest) GetExecution

func (*GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType

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

func (*GetWorkflowExecutionHistoryRequest) GetMaximumPageSize

func (m *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() int32

func (*GetWorkflowExecutionHistoryRequest) GetNamespace

func (m *GetWorkflowExecutionHistoryRequest) GetNamespace() string

func (*GetWorkflowExecutionHistoryRequest) GetNextPageToken

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

func (*GetWorkflowExecutionHistoryRequest) GetSkipArchival

func (m *GetWorkflowExecutionHistoryRequest) GetSkipArchival() bool

func (*GetWorkflowExecutionHistoryRequest) GetWaitNewEvent

func (m *GetWorkflowExecutionHistoryRequest) GetWaitNewEvent() bool

func (*GetWorkflowExecutionHistoryRequest) GoString

func (this *GetWorkflowExecutionHistoryRequest) GoString() string

func (*GetWorkflowExecutionHistoryRequest) Marshal

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

func (*GetWorkflowExecutionHistoryRequest) MarshalTo

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

func (*GetWorkflowExecutionHistoryRequest) MarshalToSizedBuffer

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

func (*GetWorkflowExecutionHistoryRequest) ProtoMessage

func (*GetWorkflowExecutionHistoryRequest) ProtoMessage()

func (*GetWorkflowExecutionHistoryRequest) Reset

func (*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 ListTaskQueuePartitionsRequest

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

func (*ListTaskQueuePartitionsRequest) Descriptor

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

func (*ListTaskQueuePartitionsRequest) Equal

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

func (*ListTaskQueuePartitionsRequest) GetNamespace

func (m *ListTaskQueuePartitionsRequest) GetNamespace() string

func (*ListTaskQueuePartitionsRequest) GetTaskQueue

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

func (*ListTaskQueuePartitionsRequest) GoString

func (this *ListTaskQueuePartitionsRequest) GoString() string

func (*ListTaskQueuePartitionsRequest) Marshal

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

func (*ListTaskQueuePartitionsRequest) MarshalTo

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

func (*ListTaskQueuePartitionsRequest) MarshalToSizedBuffer

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

func (*ListTaskQueuePartitionsRequest) ProtoMessage

func (*ListTaskQueuePartitionsRequest) ProtoMessage()

func (*ListTaskQueuePartitionsRequest) Reset

func (m *ListTaskQueuePartitionsRequest) Reset()

func (*ListTaskQueuePartitionsRequest) Size

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

func (*ListTaskQueuePartitionsRequest) String

func (this *ListTaskQueuePartitionsRequest) String() string

func (*ListTaskQueuePartitionsRequest) Unmarshal

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

func (*ListTaskQueuePartitionsRequest) XXX_DiscardUnknown

func (m *ListTaskQueuePartitionsRequest) XXX_DiscardUnknown()

func (*ListTaskQueuePartitionsRequest) XXX_Marshal

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

func (*ListTaskQueuePartitionsRequest) XXX_Merge

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

func (*ListTaskQueuePartitionsRequest) XXX_Size

func (m *ListTaskQueuePartitionsRequest) XXX_Size() int

func (*ListTaskQueuePartitionsRequest) XXX_Unmarshal

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

type ListTaskQueuePartitionsResponse

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

func (*ListTaskQueuePartitionsResponse) Descriptor

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

func (*ListTaskQueuePartitionsResponse) Equal

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

func (*ListTaskQueuePartitionsResponse) GetActivityTaskQueuePartitions

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

func (*ListTaskQueuePartitionsResponse) GetWorkflowTaskQueuePartitions

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

func (*ListTaskQueuePartitionsResponse) GoString

func (this *ListTaskQueuePartitionsResponse) GoString() string

func (*ListTaskQueuePartitionsResponse) Marshal

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

func (*ListTaskQueuePartitionsResponse) MarshalTo

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

func (*ListTaskQueuePartitionsResponse) MarshalToSizedBuffer

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

func (*ListTaskQueuePartitionsResponse) ProtoMessage

func (*ListTaskQueuePartitionsResponse) ProtoMessage()

func (*ListTaskQueuePartitionsResponse) Reset

func (*ListTaskQueuePartitionsResponse) Size

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

func (*ListTaskQueuePartitionsResponse) String

func (this *ListTaskQueuePartitionsResponse) String() string

func (*ListTaskQueuePartitionsResponse) Unmarshal

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

func (*ListTaskQueuePartitionsResponse) XXX_DiscardUnknown

func (m *ListTaskQueuePartitionsResponse) XXX_DiscardUnknown()

func (*ListTaskQueuePartitionsResponse) XXX_Marshal

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

func (*ListTaskQueuePartitionsResponse) XXX_Merge

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

func (*ListTaskQueuePartitionsResponse) XXX_Size

func (m *ListTaskQueuePartitionsResponse) XXX_Size() int

func (*ListTaskQueuePartitionsResponse) XXX_Unmarshal

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

type ListWorkflowExecutionsRequest

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

func (*ListWorkflowExecutionsRequest) Descriptor

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

func (*ListWorkflowExecutionsRequest) Equal

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

func (*ListWorkflowExecutionsRequest) GetNamespace

func (m *ListWorkflowExecutionsRequest) GetNamespace() string

func (*ListWorkflowExecutionsRequest) GetNextPageToken

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

func (*ListWorkflowExecutionsRequest) GetPageSize

func (m *ListWorkflowExecutionsRequest) GetPageSize() int32

func (*ListWorkflowExecutionsRequest) GetQuery

func (m *ListWorkflowExecutionsRequest) GetQuery() string

func (*ListWorkflowExecutionsRequest) GoString

func (this *ListWorkflowExecutionsRequest) GoString() string

func (*ListWorkflowExecutionsRequest) Marshal

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

func (*ListWorkflowExecutionsRequest) MarshalTo

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

func (*ListWorkflowExecutionsRequest) MarshalToSizedBuffer

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

func (*ListWorkflowExecutionsRequest) ProtoMessage

func (*ListWorkflowExecutionsRequest) ProtoMessage()

func (*ListWorkflowExecutionsRequest) Reset

func (m *ListWorkflowExecutionsRequest) Reset()

func (*ListWorkflowExecutionsRequest) Size

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

func (*ListWorkflowExecutionsRequest) String

func (this *ListWorkflowExecutionsRequest) String() string

func (*ListWorkflowExecutionsRequest) Unmarshal

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

func (*ListWorkflowExecutionsRequest) XXX_DiscardUnknown

func (m *ListWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ListWorkflowExecutionsRequest) XXX_Marshal

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

func (*ListWorkflowExecutionsRequest) XXX_Merge

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

func (*ListWorkflowExecutionsRequest) XXX_Size

func (m *ListWorkflowExecutionsRequest) XXX_Size() int

func (*ListWorkflowExecutionsRequest) XXX_Unmarshal

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

type ListWorkflowExecutionsResponse

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

func (*ListWorkflowExecutionsResponse) Descriptor

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

func (*ListWorkflowExecutionsResponse) Equal

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

func (*ListWorkflowExecutionsResponse) GetExecutions

func (*ListWorkflowExecutionsResponse) GetNextPageToken

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

func (*ListWorkflowExecutionsResponse) GoString

func (this *ListWorkflowExecutionsResponse) GoString() string

func (*ListWorkflowExecutionsResponse) Marshal

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

func (*ListWorkflowExecutionsResponse) MarshalTo

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

func (*ListWorkflowExecutionsResponse) MarshalToSizedBuffer

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

func (*ListWorkflowExecutionsResponse) ProtoMessage

func (*ListWorkflowExecutionsResponse) ProtoMessage()

func (*ListWorkflowExecutionsResponse) Reset

func (m *ListWorkflowExecutionsResponse) Reset()

func (*ListWorkflowExecutionsResponse) Size

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

func (*ListWorkflowExecutionsResponse) String

func (this *ListWorkflowExecutionsResponse) String() string

func (*ListWorkflowExecutionsResponse) Unmarshal

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

func (*ListWorkflowExecutionsResponse) XXX_DiscardUnknown

func (m *ListWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ListWorkflowExecutionsResponse) XXX_Marshal

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

func (*ListWorkflowExecutionsResponse) XXX_Merge

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

func (*ListWorkflowExecutionsResponse) XXX_Size

func (m *ListWorkflowExecutionsResponse) XXX_Size() int

func (*ListWorkflowExecutionsResponse) XXX_Unmarshal

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

type PollActivityTaskQueueRequest

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

func (*PollActivityTaskQueueRequest) Descriptor

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

func (*PollActivityTaskQueueRequest) Equal

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

func (*PollActivityTaskQueueRequest) GetIdentity

func (m *PollActivityTaskQueueRequest) GetIdentity() string

func (*PollActivityTaskQueueRequest) GetNamespace

func (m *PollActivityTaskQueueRequest) GetNamespace() string

func (*PollActivityTaskQueueRequest) GetTaskQueue

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

func (*PollActivityTaskQueueRequest) GetTaskQueueMetadata

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

func (*PollActivityTaskQueueRequest) GoString

func (this *PollActivityTaskQueueRequest) GoString() string

func (*PollActivityTaskQueueRequest) Marshal

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

func (*PollActivityTaskQueueRequest) MarshalTo

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

func (*PollActivityTaskQueueRequest) MarshalToSizedBuffer

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

func (*PollActivityTaskQueueRequest) ProtoMessage

func (*PollActivityTaskQueueRequest) ProtoMessage()

func (*PollActivityTaskQueueRequest) Reset

func (m *PollActivityTaskQueueRequest) Reset()

func (*PollActivityTaskQueueRequest) Size

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

func (*PollActivityTaskQueueRequest) String

func (this *PollActivityTaskQueueRequest) String() string

func (*PollActivityTaskQueueRequest) Unmarshal

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

func (*PollActivityTaskQueueRequest) XXX_DiscardUnknown

func (m *PollActivityTaskQueueRequest) XXX_DiscardUnknown()

func (*PollActivityTaskQueueRequest) XXX_Marshal

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

func (*PollActivityTaskQueueRequest) XXX_Merge

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

func (*PollActivityTaskQueueRequest) XXX_Size

func (m *PollActivityTaskQueueRequest) XXX_Size() int

func (*PollActivityTaskQueueRequest) XXX_Unmarshal

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

type PollActivityTaskQueueResponse

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

func (*PollActivityTaskQueueResponse) Descriptor

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

func (*PollActivityTaskQueueResponse) Equal

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

func (*PollActivityTaskQueueResponse) GetActivityId

func (m *PollActivityTaskQueueResponse) GetActivityId() string

func (*PollActivityTaskQueueResponse) GetActivityType

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

func (*PollActivityTaskQueueResponse) GetAttempt

func (m *PollActivityTaskQueueResponse) GetAttempt() int32

func (*PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime added in v0.28.0

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

func (*PollActivityTaskQueueResponse) GetHeader

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

func (*PollActivityTaskQueueResponse) GetHeartbeatDetails

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

func (*PollActivityTaskQueueResponse) GetHeartbeatTimeout added in v0.28.0

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

func (*PollActivityTaskQueueResponse) GetInput

func (*PollActivityTaskQueueResponse) GetRetryPolicy

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

func (*PollActivityTaskQueueResponse) GetScheduleToCloseTimeout added in v0.28.0

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

func (*PollActivityTaskQueueResponse) GetScheduledTime added in v0.28.0

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

func (*PollActivityTaskQueueResponse) GetStartToCloseTimeout added in v0.28.0

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

func (*PollActivityTaskQueueResponse) GetStartedTime added in v0.28.0

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

func (*PollActivityTaskQueueResponse) GetTaskToken

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

func (*PollActivityTaskQueueResponse) GetWorkflowExecution

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

func (*PollActivityTaskQueueResponse) GetWorkflowNamespace

func (m *PollActivityTaskQueueResponse) GetWorkflowNamespace() string

func (*PollActivityTaskQueueResponse) GetWorkflowType

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

func (*PollActivityTaskQueueResponse) GoString

func (this *PollActivityTaskQueueResponse) GoString() string

func (*PollActivityTaskQueueResponse) Marshal

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

func (*PollActivityTaskQueueResponse) MarshalTo

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

func (*PollActivityTaskQueueResponse) MarshalToSizedBuffer

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

func (*PollActivityTaskQueueResponse) ProtoMessage

func (*PollActivityTaskQueueResponse) ProtoMessage()

func (*PollActivityTaskQueueResponse) Reset

func (m *PollActivityTaskQueueResponse) Reset()

func (*PollActivityTaskQueueResponse) Size

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

func (*PollActivityTaskQueueResponse) String

func (this *PollActivityTaskQueueResponse) String() string

func (*PollActivityTaskQueueResponse) Unmarshal

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

func (*PollActivityTaskQueueResponse) XXX_DiscardUnknown

func (m *PollActivityTaskQueueResponse) XXX_DiscardUnknown()

func (*PollActivityTaskQueueResponse) XXX_Marshal

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

func (*PollActivityTaskQueueResponse) XXX_Merge

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

func (*PollActivityTaskQueueResponse) XXX_Size

func (m *PollActivityTaskQueueResponse) XXX_Size() int

func (*PollActivityTaskQueueResponse) XXX_Unmarshal

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

type PollWorkflowTaskQueueRequest

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

func (*PollWorkflowTaskQueueRequest) Descriptor

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

func (*PollWorkflowTaskQueueRequest) Equal

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

func (*PollWorkflowTaskQueueRequest) GetBinaryChecksum

func (m *PollWorkflowTaskQueueRequest) GetBinaryChecksum() string

func (*PollWorkflowTaskQueueRequest) GetIdentity

func (m *PollWorkflowTaskQueueRequest) GetIdentity() string

func (*PollWorkflowTaskQueueRequest) GetNamespace

func (m *PollWorkflowTaskQueueRequest) GetNamespace() string

func (*PollWorkflowTaskQueueRequest) GetTaskQueue

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

func (*PollWorkflowTaskQueueRequest) GoString

func (this *PollWorkflowTaskQueueRequest) GoString() string

func (*PollWorkflowTaskQueueRequest) Marshal

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

func (*PollWorkflowTaskQueueRequest) MarshalTo

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

func (*PollWorkflowTaskQueueRequest) MarshalToSizedBuffer

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

func (*PollWorkflowTaskQueueRequest) ProtoMessage

func (*PollWorkflowTaskQueueRequest) ProtoMessage()

func (*PollWorkflowTaskQueueRequest) Reset

func (m *PollWorkflowTaskQueueRequest) Reset()

func (*PollWorkflowTaskQueueRequest) Size

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

func (*PollWorkflowTaskQueueRequest) String

func (this *PollWorkflowTaskQueueRequest) String() string

func (*PollWorkflowTaskQueueRequest) Unmarshal

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

func (*PollWorkflowTaskQueueRequest) XXX_DiscardUnknown

func (m *PollWorkflowTaskQueueRequest) XXX_DiscardUnknown()

func (*PollWorkflowTaskQueueRequest) XXX_Marshal

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

func (*PollWorkflowTaskQueueRequest) XXX_Merge

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

func (*PollWorkflowTaskQueueRequest) XXX_Size

func (m *PollWorkflowTaskQueueRequest) XXX_Size() int

func (*PollWorkflowTaskQueueRequest) XXX_Unmarshal

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

type PollWorkflowTaskQueueResponse

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

func (*PollWorkflowTaskQueueResponse) Descriptor

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

func (*PollWorkflowTaskQueueResponse) Equal

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

func (*PollWorkflowTaskQueueResponse) GetAttempt

func (m *PollWorkflowTaskQueueResponse) GetAttempt() int32

func (*PollWorkflowTaskQueueResponse) GetBacklogCountHint

func (m *PollWorkflowTaskQueueResponse) GetBacklogCountHint() int64

func (*PollWorkflowTaskQueueResponse) GetHistory

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

func (*PollWorkflowTaskQueueResponse) GetNextPageToken

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

func (*PollWorkflowTaskQueueResponse) GetPreviousStartedEventId

func (m *PollWorkflowTaskQueueResponse) GetPreviousStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetQueries

func (*PollWorkflowTaskQueueResponse) GetQuery

func (*PollWorkflowTaskQueueResponse) GetScheduledTime added in v0.28.0

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

func (*PollWorkflowTaskQueueResponse) GetStartedEventId

func (m *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetStartedTime added in v0.28.0

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

func (*PollWorkflowTaskQueueResponse) GetTaskToken

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecution

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowType

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

func (*PollWorkflowTaskQueueResponse) GoString

func (this *PollWorkflowTaskQueueResponse) GoString() string

func (*PollWorkflowTaskQueueResponse) Marshal

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

func (*PollWorkflowTaskQueueResponse) MarshalTo

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

func (*PollWorkflowTaskQueueResponse) MarshalToSizedBuffer

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

func (*PollWorkflowTaskQueueResponse) ProtoMessage

func (*PollWorkflowTaskQueueResponse) ProtoMessage()

func (*PollWorkflowTaskQueueResponse) Reset

func (m *PollWorkflowTaskQueueResponse) Reset()

func (*PollWorkflowTaskQueueResponse) Size

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

func (*PollWorkflowTaskQueueResponse) String

func (this *PollWorkflowTaskQueueResponse) String() string

func (*PollWorkflowTaskQueueResponse) Unmarshal

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

func (*PollWorkflowTaskQueueResponse) XXX_DiscardUnknown

func (m *PollWorkflowTaskQueueResponse) XXX_DiscardUnknown()

func (*PollWorkflowTaskQueueResponse) XXX_Marshal

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

func (*PollWorkflowTaskQueueResponse) XXX_Merge

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

func (*PollWorkflowTaskQueueResponse) XXX_Size

func (m *PollWorkflowTaskQueueResponse) XXX_Size() int

func (*PollWorkflowTaskQueueResponse) XXX_Unmarshal

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

type QueryWorkflowRequest

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

func (*QueryWorkflowRequest) Descriptor

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

func (*QueryWorkflowRequest) Equal

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

func (*QueryWorkflowRequest) GetExecution

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

func (*QueryWorkflowRequest) GetNamespace

func (m *QueryWorkflowRequest) GetNamespace() string

func (*QueryWorkflowRequest) GetQuery

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

func (*QueryWorkflowRequest) GetQueryRejectCondition

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

func (*QueryWorkflowRequest) GoString

func (this *QueryWorkflowRequest) GoString() string

func (*QueryWorkflowRequest) Marshal

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

func (*QueryWorkflowRequest) MarshalTo

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

func (*QueryWorkflowRequest) MarshalToSizedBuffer

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

func (*QueryWorkflowRequest) ProtoMessage

func (*QueryWorkflowRequest) ProtoMessage()

func (*QueryWorkflowRequest) Reset

func (m *QueryWorkflowRequest) Reset()

func (*QueryWorkflowRequest) Size

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

func (*QueryWorkflowRequest) String

func (this *QueryWorkflowRequest) String() string

func (*QueryWorkflowRequest) Unmarshal

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

func (*QueryWorkflowRequest) XXX_DiscardUnknown

func (m *QueryWorkflowRequest) XXX_DiscardUnknown()

func (*QueryWorkflowRequest) XXX_Marshal

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

func (*QueryWorkflowRequest) XXX_Merge

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

func (*QueryWorkflowRequest) XXX_Size

func (m *QueryWorkflowRequest) XXX_Size() int

func (*QueryWorkflowRequest) XXX_Unmarshal

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

type QueryWorkflowResponse

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

func (*QueryWorkflowResponse) Descriptor

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

func (*QueryWorkflowResponse) Equal

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

func (*QueryWorkflowResponse) GetQueryRejected

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

func (*QueryWorkflowResponse) GetQueryResult

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

func (*QueryWorkflowResponse) GoString

func (this *QueryWorkflowResponse) GoString() string

func (*QueryWorkflowResponse) Marshal

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

func (*QueryWorkflowResponse) MarshalTo

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

func (*QueryWorkflowResponse) MarshalToSizedBuffer

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

func (*QueryWorkflowResponse) ProtoMessage

func (*QueryWorkflowResponse) ProtoMessage()

func (*QueryWorkflowResponse) Reset

func (m *QueryWorkflowResponse) Reset()

func (*QueryWorkflowResponse) Size

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

func (*QueryWorkflowResponse) String

func (this *QueryWorkflowResponse) String() string

func (*QueryWorkflowResponse) Unmarshal

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

func (*QueryWorkflowResponse) XXX_DiscardUnknown

func (m *QueryWorkflowResponse) XXX_DiscardUnknown()

func (*QueryWorkflowResponse) XXX_Marshal

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

func (*QueryWorkflowResponse) XXX_Merge

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

func (*QueryWorkflowResponse) XXX_Size

func (m *QueryWorkflowResponse) XXX_Size() int

func (*QueryWorkflowResponse) XXX_Unmarshal

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

type RecordActivityTaskHeartbeatByIdRequest

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

func (*RecordActivityTaskHeartbeatByIdRequest) Descriptor

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

func (*RecordActivityTaskHeartbeatByIdRequest) Equal

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

func (*RecordActivityTaskHeartbeatByIdRequest) GetActivityId

func (*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"`
	WorkflowExecutionRetentionPeriod *time.Duration                 `` /* 173-byte string literal not displayed */
	Clusters                         []*v1.ClusterReplicationConfig `protobuf:"bytes,5,rep,name=clusters,proto3" json:"clusters,omitempty"`
	ActiveClusterName                string                         `protobuf:"bytes,6,opt,name=active_cluster_name,json=activeClusterName,proto3" json:"active_cluster_name,omitempty"`
	// A key-value map for any customized purpose.
	Data              map[string]string `` /* 149-byte string literal not displayed */
	SecurityToken     string            `protobuf:"bytes,8,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
	IsGlobalNamespace bool              `protobuf:"varint,9,opt,name=is_global_namespace,json=isGlobalNamespace,proto3" json:"is_global_namespace,omitempty"`
	// If unspecified (ARCHIVAL_STATE_UNSPECIFIED) then default server configuration is used.
	HistoryArchivalState v11.ArchivalState `` /* 166-byte string literal not displayed */
	HistoryArchivalUri   string            `protobuf:"bytes,11,opt,name=history_archival_uri,json=historyArchivalUri,proto3" json:"history_archival_uri,omitempty"`
	// If unspecified (ARCHIVAL_STATE_UNSPECIFIED) then default server configuration is used.
	VisibilityArchivalState v11.ArchivalState `` /* 175-byte string literal not displayed */
	VisibilityArchivalUri   string            `` /* 127-byte string literal not displayed */
}

func (*RegisterNamespaceRequest) Descriptor

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

func (*RegisterNamespaceRequest) Equal

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

func (*RegisterNamespaceRequest) GetActiveClusterName

func (m *RegisterNamespaceRequest) GetActiveClusterName() string

func (*RegisterNamespaceRequest) GetClusters

func (*RegisterNamespaceRequest) GetData

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

func (*RegisterNamespaceRequest) GetDescription

func (m *RegisterNamespaceRequest) GetDescription() string

func (*RegisterNamespaceRequest) GetHistoryArchivalState

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

func (*RegisterNamespaceRequest) GetHistoryArchivalUri

func (m *RegisterNamespaceRequest) GetHistoryArchivalUri() string

func (*RegisterNamespaceRequest) GetIsGlobalNamespace

func (m *RegisterNamespaceRequest) GetIsGlobalNamespace() bool

func (*RegisterNamespaceRequest) GetName

func (m *RegisterNamespaceRequest) GetName() string

func (*RegisterNamespaceRequest) GetOwnerEmail

func (m *RegisterNamespaceRequest) GetOwnerEmail() string

func (*RegisterNamespaceRequest) GetSecurityToken

func (m *RegisterNamespaceRequest) GetSecurityToken() string

func (*RegisterNamespaceRequest) GetVisibilityArchivalState

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

func (*RegisterNamespaceRequest) GetVisibilityArchivalUri

func (m *RegisterNamespaceRequest) GetVisibilityArchivalUri() string

func (*RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriod added in v0.28.0

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

func (*RegisterNamespaceRequest) GoString

func (this *RegisterNamespaceRequest) GoString() string

func (*RegisterNamespaceRequest) Marshal

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

func (*RegisterNamespaceRequest) MarshalTo

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

func (*RegisterNamespaceRequest) MarshalToSizedBuffer

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

func (*RegisterNamespaceRequest) ProtoMessage

func (*RegisterNamespaceRequest) ProtoMessage()

func (*RegisterNamespaceRequest) Reset

func (m *RegisterNamespaceRequest) Reset()

func (*RegisterNamespaceRequest) Size

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

func (*RegisterNamespaceRequest) String

func (this *RegisterNamespaceRequest) String() string

func (*RegisterNamespaceRequest) Unmarshal

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

func (*RegisterNamespaceRequest) XXX_DiscardUnknown

func (m *RegisterNamespaceRequest) XXX_DiscardUnknown()

func (*RegisterNamespaceRequest) XXX_Marshal

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

func (*RegisterNamespaceRequest) XXX_Merge

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

func (*RegisterNamespaceRequest) XXX_Size

func (m *RegisterNamespaceRequest) XXX_Size() int

func (*RegisterNamespaceRequest) XXX_Unmarshal

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

type RegisterNamespaceResponse

type RegisterNamespaceResponse struct {
}

func (*RegisterNamespaceResponse) Descriptor

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

func (*RegisterNamespaceResponse) Equal

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

func (*RegisterNamespaceResponse) GoString

func (this *RegisterNamespaceResponse) GoString() string

func (*RegisterNamespaceResponse) Marshal

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

func (*RegisterNamespaceResponse) MarshalTo

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

func (*RegisterNamespaceResponse) MarshalToSizedBuffer

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

func (*RegisterNamespaceResponse) ProtoMessage

func (*RegisterNamespaceResponse) ProtoMessage()

func (*RegisterNamespaceResponse) Reset

func (m *RegisterNamespaceResponse) Reset()

func (*RegisterNamespaceResponse) Size

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

func (*RegisterNamespaceResponse) String

func (this *RegisterNamespaceResponse) String() string

func (*RegisterNamespaceResponse) Unmarshal

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

func (*RegisterNamespaceResponse) XXX_DiscardUnknown

func (m *RegisterNamespaceResponse) XXX_DiscardUnknown()

func (*RegisterNamespaceResponse) XXX_Marshal

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

func (*RegisterNamespaceResponse) XXX_Merge

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

func (*RegisterNamespaceResponse) XXX_Size

func (m *RegisterNamespaceResponse) XXX_Size() int

func (*RegisterNamespaceResponse) XXX_Unmarshal

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

type RequestCancelWorkflowExecutionRequest

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

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 ResetStickyTaskQueueRequest

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

func (*ResetStickyTaskQueueRequest) Descriptor

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

func (*ResetStickyTaskQueueRequest) Equal

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

func (*ResetStickyTaskQueueRequest) GetExecution

func (*ResetStickyTaskQueueRequest) GetNamespace

func (m *ResetStickyTaskQueueRequest) GetNamespace() string

func (*ResetStickyTaskQueueRequest) GoString

func (this *ResetStickyTaskQueueRequest) GoString() string

func (*ResetStickyTaskQueueRequest) Marshal

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

func (*ResetStickyTaskQueueRequest) MarshalTo

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

func (*ResetStickyTaskQueueRequest) MarshalToSizedBuffer

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

func (*ResetStickyTaskQueueRequest) ProtoMessage

func (*ResetStickyTaskQueueRequest) ProtoMessage()

func (*ResetStickyTaskQueueRequest) Reset

func (m *ResetStickyTaskQueueRequest) Reset()

func (*ResetStickyTaskQueueRequest) Size

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

func (*ResetStickyTaskQueueRequest) String

func (this *ResetStickyTaskQueueRequest) String() string

func (*ResetStickyTaskQueueRequest) Unmarshal

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

func (*ResetStickyTaskQueueRequest) XXX_DiscardUnknown

func (m *ResetStickyTaskQueueRequest) XXX_DiscardUnknown()

func (*ResetStickyTaskQueueRequest) XXX_Marshal

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

func (*ResetStickyTaskQueueRequest) XXX_Merge

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

func (*ResetStickyTaskQueueRequest) XXX_Size

func (m *ResetStickyTaskQueueRequest) XXX_Size() int

func (*ResetStickyTaskQueueRequest) XXX_Unmarshal

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

type ResetStickyTaskQueueResponse

type ResetStickyTaskQueueResponse struct {
}

func (*ResetStickyTaskQueueResponse) Descriptor

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

func (*ResetStickyTaskQueueResponse) Equal

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

func (*ResetStickyTaskQueueResponse) GoString

func (this *ResetStickyTaskQueueResponse) GoString() string

func (*ResetStickyTaskQueueResponse) Marshal

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

func (*ResetStickyTaskQueueResponse) MarshalTo

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

func (*ResetStickyTaskQueueResponse) MarshalToSizedBuffer

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

func (*ResetStickyTaskQueueResponse) ProtoMessage

func (*ResetStickyTaskQueueResponse) ProtoMessage()

func (*ResetStickyTaskQueueResponse) Reset

func (m *ResetStickyTaskQueueResponse) Reset()

func (*ResetStickyTaskQueueResponse) Size

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

func (*ResetStickyTaskQueueResponse) String

func (this *ResetStickyTaskQueueResponse) String() string

func (*ResetStickyTaskQueueResponse) Unmarshal

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

func (*ResetStickyTaskQueueResponse) XXX_DiscardUnknown

func (m *ResetStickyTaskQueueResponse) XXX_DiscardUnknown()

func (*ResetStickyTaskQueueResponse) XXX_Marshal

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

func (*ResetStickyTaskQueueResponse) XXX_Merge

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

func (*ResetStickyTaskQueueResponse) XXX_Size

func (m *ResetStickyTaskQueueResponse) XXX_Size() int

func (*ResetStickyTaskQueueResponse) XXX_Unmarshal

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

type ResetWorkflowExecutionRequest

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

func (*ResetWorkflowExecutionRequest) Descriptor

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

func (*ResetWorkflowExecutionRequest) Equal

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

func (*ResetWorkflowExecutionRequest) GetNamespace

func (m *ResetWorkflowExecutionRequest) GetNamespace() string

func (*ResetWorkflowExecutionRequest) GetReason

func (m *ResetWorkflowExecutionRequest) GetReason() string

func (*ResetWorkflowExecutionRequest) GetRequestId

func (m *ResetWorkflowExecutionRequest) GetRequestId() string

func (*ResetWorkflowExecutionRequest) GetWorkflowExecution

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

func (*ResetWorkflowExecutionRequest) GetWorkflowTaskFinishEventId

func (m *ResetWorkflowExecutionRequest) GetWorkflowTaskFinishEventId() int64

func (*ResetWorkflowExecutionRequest) GoString

func (this *ResetWorkflowExecutionRequest) GoString() string

func (*ResetWorkflowExecutionRequest) Marshal

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

func (*ResetWorkflowExecutionRequest) MarshalTo

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

func (*ResetWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*ResetWorkflowExecutionRequest) ProtoMessage

func (*ResetWorkflowExecutionRequest) ProtoMessage()

func (*ResetWorkflowExecutionRequest) Reset

func (m *ResetWorkflowExecutionRequest) Reset()

func (*ResetWorkflowExecutionRequest) Size

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

func (*ResetWorkflowExecutionRequest) String

func (this *ResetWorkflowExecutionRequest) String() string

func (*ResetWorkflowExecutionRequest) Unmarshal

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

func (*ResetWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *ResetWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*ResetWorkflowExecutionRequest) XXX_Marshal

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

func (*ResetWorkflowExecutionRequest) XXX_Merge

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

func (*ResetWorkflowExecutionRequest) XXX_Size

func (m *ResetWorkflowExecutionRequest) XXX_Size() int

func (*ResetWorkflowExecutionRequest) XXX_Unmarshal

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

type ResetWorkflowExecutionResponse

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

func (*ResetWorkflowExecutionResponse) Descriptor

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

func (*ResetWorkflowExecutionResponse) Equal

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

func (*ResetWorkflowExecutionResponse) GetRunId

func (m *ResetWorkflowExecutionResponse) GetRunId() string

func (*ResetWorkflowExecutionResponse) GoString

func (this *ResetWorkflowExecutionResponse) GoString() string

func (*ResetWorkflowExecutionResponse) Marshal

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

func (*ResetWorkflowExecutionResponse) MarshalTo

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

func (*ResetWorkflowExecutionResponse) MarshalToSizedBuffer

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

func (*ResetWorkflowExecutionResponse) ProtoMessage

func (*ResetWorkflowExecutionResponse) ProtoMessage()

func (*ResetWorkflowExecutionResponse) Reset

func (m *ResetWorkflowExecutionResponse) Reset()

func (*ResetWorkflowExecutionResponse) Size

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

func (*ResetWorkflowExecutionResponse) String

func (this *ResetWorkflowExecutionResponse) String() string

func (*ResetWorkflowExecutionResponse) Unmarshal

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

func (*ResetWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *ResetWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*ResetWorkflowExecutionResponse) XXX_Marshal

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

func (*ResetWorkflowExecutionResponse) XXX_Merge

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

func (*ResetWorkflowExecutionResponse) XXX_Size

func (m *ResetWorkflowExecutionResponse) XXX_Size() int

func (*ResetWorkflowExecutionResponse) XXX_Unmarshal

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

type RespondActivityTaskCanceledByIdRequest

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

func (*RespondActivityTaskCanceledByIdRequest) Descriptor

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

func (*RespondActivityTaskCanceledByIdRequest) Equal

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

func (*RespondActivityTaskCanceledByIdRequest) GetActivityId

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

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

TODO: deprecated APIs

func (*RespondQueryTaskCompletedRequest) Descriptor

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

func (*RespondQueryTaskCompletedRequest) Equal

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

func (*RespondQueryTaskCompletedRequest) GetCompletedType

func (*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 RespondWorkflowTaskCompletedRequest

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

func (*RespondWorkflowTaskCompletedRequest) Descriptor

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

func (*RespondWorkflowTaskCompletedRequest) Equal

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

func (*RespondWorkflowTaskCompletedRequest) GetBinaryChecksum

func (m *RespondWorkflowTaskCompletedRequest) GetBinaryChecksum() string

func (*RespondWorkflowTaskCompletedRequest) GetCommands

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

func (*RespondWorkflowTaskCompletedRequest) GetForceCreateNewWorkflowTask

func (m *RespondWorkflowTaskCompletedRequest) GetForceCreateNewWorkflowTask() bool

func (*RespondWorkflowTaskCompletedRequest) GetIdentity

func (*RespondWorkflowTaskCompletedRequest) GetQueryResults

func (*RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask

func (m *RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask() bool

func (*RespondWorkflowTaskCompletedRequest) GetStickyAttributes

func (*RespondWorkflowTaskCompletedRequest) GetTaskToken

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

func (*RespondWorkflowTaskCompletedRequest) GoString

func (*RespondWorkflowTaskCompletedRequest) Marshal

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

func (*RespondWorkflowTaskCompletedRequest) MarshalTo

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

func (*RespondWorkflowTaskCompletedRequest) MarshalToSizedBuffer

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

func (*RespondWorkflowTaskCompletedRequest) ProtoMessage

func (*RespondWorkflowTaskCompletedRequest) ProtoMessage()

func (*RespondWorkflowTaskCompletedRequest) Reset

func (*RespondWorkflowTaskCompletedRequest) Size

func (*RespondWorkflowTaskCompletedRequest) String

func (*RespondWorkflowTaskCompletedRequest) Unmarshal

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

func (*RespondWorkflowTaskCompletedRequest) XXX_DiscardUnknown

func (m *RespondWorkflowTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondWorkflowTaskCompletedRequest) XXX_Marshal

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

func (*RespondWorkflowTaskCompletedRequest) XXX_Merge

func (*RespondWorkflowTaskCompletedRequest) XXX_Size

func (*RespondWorkflowTaskCompletedRequest) XXX_Unmarshal

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

type RespondWorkflowTaskCompletedResponse

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

func (*RespondWorkflowTaskCompletedResponse) Descriptor

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

func (*RespondWorkflowTaskCompletedResponse) Equal

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

func (*RespondWorkflowTaskCompletedResponse) GetWorkflowTask

func (*RespondWorkflowTaskCompletedResponse) GoString

func (*RespondWorkflowTaskCompletedResponse) Marshal

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

func (*RespondWorkflowTaskCompletedResponse) MarshalTo

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

func (*RespondWorkflowTaskCompletedResponse) MarshalToSizedBuffer

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

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage()

func (*RespondWorkflowTaskCompletedResponse) Reset

func (*RespondWorkflowTaskCompletedResponse) Size

func (*RespondWorkflowTaskCompletedResponse) String

func (*RespondWorkflowTaskCompletedResponse) Unmarshal

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

func (*RespondWorkflowTaskCompletedResponse) XXX_DiscardUnknown

func (m *RespondWorkflowTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondWorkflowTaskCompletedResponse) XXX_Marshal

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

func (*RespondWorkflowTaskCompletedResponse) XXX_Merge

func (*RespondWorkflowTaskCompletedResponse) XXX_Size

func (*RespondWorkflowTaskCompletedResponse) XXX_Unmarshal

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

type RespondWorkflowTaskFailedRequest

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

func (*RespondWorkflowTaskFailedRequest) Descriptor

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

func (*RespondWorkflowTaskFailedRequest) Equal

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

func (*RespondWorkflowTaskFailedRequest) GetBinaryChecksum

func (m *RespondWorkflowTaskFailedRequest) GetBinaryChecksum() string

func (*RespondWorkflowTaskFailedRequest) GetCause

func (*RespondWorkflowTaskFailedRequest) GetFailure

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

func (*RespondWorkflowTaskFailedRequest) GetIdentity

func (m *RespondWorkflowTaskFailedRequest) GetIdentity() string

func (*RespondWorkflowTaskFailedRequest) GetTaskToken

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

func (*RespondWorkflowTaskFailedRequest) GoString

func (this *RespondWorkflowTaskFailedRequest) GoString() string

func (*RespondWorkflowTaskFailedRequest) Marshal

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

func (*RespondWorkflowTaskFailedRequest) MarshalTo

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

func (*RespondWorkflowTaskFailedRequest) MarshalToSizedBuffer

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

func (*RespondWorkflowTaskFailedRequest) ProtoMessage

func (*RespondWorkflowTaskFailedRequest) ProtoMessage()

func (*RespondWorkflowTaskFailedRequest) Reset

func (*RespondWorkflowTaskFailedRequest) Size

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

func (*RespondWorkflowTaskFailedRequest) String

func (*RespondWorkflowTaskFailedRequest) Unmarshal

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

func (*RespondWorkflowTaskFailedRequest) XXX_DiscardUnknown

func (m *RespondWorkflowTaskFailedRequest) XXX_DiscardUnknown()

func (*RespondWorkflowTaskFailedRequest) XXX_Marshal

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

func (*RespondWorkflowTaskFailedRequest) XXX_Merge

func (*RespondWorkflowTaskFailedRequest) XXX_Size

func (m *RespondWorkflowTaskFailedRequest) XXX_Size() int

func (*RespondWorkflowTaskFailedRequest) XXX_Unmarshal

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

type RespondWorkflowTaskFailedResponse

type RespondWorkflowTaskFailedResponse struct {
}

func (*RespondWorkflowTaskFailedResponse) Descriptor

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

func (*RespondWorkflowTaskFailedResponse) Equal

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

func (*RespondWorkflowTaskFailedResponse) GoString

func (this *RespondWorkflowTaskFailedResponse) GoString() string

func (*RespondWorkflowTaskFailedResponse) Marshal

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

func (*RespondWorkflowTaskFailedResponse) MarshalTo

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

func (*RespondWorkflowTaskFailedResponse) MarshalToSizedBuffer

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

func (*RespondWorkflowTaskFailedResponse) ProtoMessage

func (*RespondWorkflowTaskFailedResponse) ProtoMessage()

func (*RespondWorkflowTaskFailedResponse) Reset

func (*RespondWorkflowTaskFailedResponse) Size

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

func (*RespondWorkflowTaskFailedResponse) String

func (*RespondWorkflowTaskFailedResponse) Unmarshal

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

func (*RespondWorkflowTaskFailedResponse) XXX_DiscardUnknown

func (m *RespondWorkflowTaskFailedResponse) XXX_DiscardUnknown()

func (*RespondWorkflowTaskFailedResponse) XXX_Marshal

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

func (*RespondWorkflowTaskFailedResponse) XXX_Merge

func (*RespondWorkflowTaskFailedResponse) XXX_Size

func (m *RespondWorkflowTaskFailedResponse) XXX_Size() int

func (*RespondWorkflowTaskFailedResponse) XXX_Unmarshal

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

type ScanWorkflowExecutionsRequest

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

func (*ScanWorkflowExecutionsRequest) Descriptor

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

func (*ScanWorkflowExecutionsRequest) Equal

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

func (*ScanWorkflowExecutionsRequest) GetNamespace

func (m *ScanWorkflowExecutionsRequest) GetNamespace() string

func (*ScanWorkflowExecutionsRequest) GetNextPageToken

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

func (*ScanWorkflowExecutionsRequest) GetPageSize

func (m *ScanWorkflowExecutionsRequest) GetPageSize() int32

func (*ScanWorkflowExecutionsRequest) GetQuery

func (m *ScanWorkflowExecutionsRequest) GetQuery() string

func (*ScanWorkflowExecutionsRequest) GoString

func (this *ScanWorkflowExecutionsRequest) GoString() string

func (*ScanWorkflowExecutionsRequest) Marshal

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

func (*ScanWorkflowExecutionsRequest) MarshalTo

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

func (*ScanWorkflowExecutionsRequest) MarshalToSizedBuffer

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

func (*ScanWorkflowExecutionsRequest) ProtoMessage

func (*ScanWorkflowExecutionsRequest) ProtoMessage()

func (*ScanWorkflowExecutionsRequest) Reset

func (m *ScanWorkflowExecutionsRequest) Reset()

func (*ScanWorkflowExecutionsRequest) Size

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

func (*ScanWorkflowExecutionsRequest) String

func (this *ScanWorkflowExecutionsRequest) String() string

func (*ScanWorkflowExecutionsRequest) Unmarshal

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

func (*ScanWorkflowExecutionsRequest) XXX_DiscardUnknown

func (m *ScanWorkflowExecutionsRequest) XXX_DiscardUnknown()

func (*ScanWorkflowExecutionsRequest) XXX_Marshal

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

func (*ScanWorkflowExecutionsRequest) XXX_Merge

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

func (*ScanWorkflowExecutionsRequest) XXX_Size

func (m *ScanWorkflowExecutionsRequest) XXX_Size() int

func (*ScanWorkflowExecutionsRequest) XXX_Unmarshal

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

type ScanWorkflowExecutionsResponse

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

func (*ScanWorkflowExecutionsResponse) Descriptor

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

func (*ScanWorkflowExecutionsResponse) Equal

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

func (*ScanWorkflowExecutionsResponse) GetExecutions

func (*ScanWorkflowExecutionsResponse) GetNextPageToken

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

func (*ScanWorkflowExecutionsResponse) GoString

func (this *ScanWorkflowExecutionsResponse) GoString() string

func (*ScanWorkflowExecutionsResponse) Marshal

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

func (*ScanWorkflowExecutionsResponse) MarshalTo

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

func (*ScanWorkflowExecutionsResponse) MarshalToSizedBuffer

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

func (*ScanWorkflowExecutionsResponse) ProtoMessage

func (*ScanWorkflowExecutionsResponse) ProtoMessage()

func (*ScanWorkflowExecutionsResponse) Reset

func (m *ScanWorkflowExecutionsResponse) Reset()

func (*ScanWorkflowExecutionsResponse) Size

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

func (*ScanWorkflowExecutionsResponse) String

func (this *ScanWorkflowExecutionsResponse) String() string

func (*ScanWorkflowExecutionsResponse) Unmarshal

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

func (*ScanWorkflowExecutionsResponse) XXX_DiscardUnknown

func (m *ScanWorkflowExecutionsResponse) XXX_DiscardUnknown()

func (*ScanWorkflowExecutionsResponse) XXX_Marshal

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

func (*ScanWorkflowExecutionsResponse) XXX_Merge

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

func (*ScanWorkflowExecutionsResponse) XXX_Size

func (m *ScanWorkflowExecutionsResponse) XXX_Size() int

func (*ScanWorkflowExecutionsResponse) XXX_Unmarshal

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

type SignalWithStartWorkflowExecutionRequest

type SignalWithStartWorkflowExecutionRequest struct {
	Namespace    string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowId   string            `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	WorkflowType *v13.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	TaskQueue    *v14.TaskQueue    `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Input        *v13.Payloads     `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new
	WorkflowExecutionTimeout *time.Duration `` /* 147-byte string literal not displayed */
	// Timeout of a single workflow run
	WorkflowRunTimeout *time.Duration `` /* 129-byte string literal not displayed */
	// Timeout of a single workflow task
	WorkflowTaskTimeout   *time.Duration            `` /* 132-byte string literal not displayed */
	Identity              string                    `protobuf:"bytes,9,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId             string                    `protobuf:"bytes,10,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	WorkflowIdReusePolicy v11.WorkflowIdReusePolicy `` /* 179-byte string literal not displayed */
	SignalName            string                    `protobuf:"bytes,12,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	SignalInput           *v13.Payloads             `protobuf:"bytes,13,opt,name=signal_input,json=signalInput,proto3" json:"signal_input,omitempty"`
	Control               string                    `protobuf:"bytes,14,opt,name=control,proto3" json:"control,omitempty"`
	// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	RetryPolicy      *v13.RetryPolicy      `protobuf:"bytes,15,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	CronSchedule     string                `protobuf:"bytes,16,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	Memo             *v13.Memo             `protobuf:"bytes,17,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v13.SearchAttributes `protobuf:"bytes,18,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	Header           *v13.Header           `protobuf:"bytes,19,opt,name=header,proto3" json:"header,omitempty"`
}

func (*SignalWithStartWorkflowExecutionRequest) Descriptor

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

func (*SignalWithStartWorkflowExecutionRequest) Equal

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

func (*SignalWithStartWorkflowExecutionRequest) GetControl

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

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout added in v0.28.0

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *time.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowId

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout added in v0.28.0

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout() *time.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout added in v0.28.0

func (m *SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *time.Duration

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"`
	TaskQueue    *v14.TaskQueue    `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	Input        *v13.Payloads     `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	// Total workflow execution timeout including retries and continue as new.
	WorkflowExecutionTimeout *time.Duration `` /* 147-byte string literal not displayed */
	// Timeout of a single workflow run.
	WorkflowRunTimeout *time.Duration `` /* 129-byte string literal not displayed */
	// Timeout of a single workflow task.
	WorkflowTaskTimeout *time.Duration `` /* 132-byte string literal not displayed */
	Identity            string         `protobuf:"bytes,9,opt,name=identity,proto3" json:"identity,omitempty"`
	RequestId           string         `protobuf:"bytes,10,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	WorkflowIdReusePolicy v11.WorkflowIdReusePolicy `` /* 179-byte string literal not displayed */
	// Retries up to workflow_execution_timeout_seconds.
	RetryPolicy      *v13.RetryPolicy      `protobuf:"bytes,12,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	CronSchedule     string                `protobuf:"bytes,13,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"`
	Memo             *v13.Memo             `protobuf:"bytes,14,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v13.SearchAttributes `protobuf:"bytes,15,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	Header           *v13.Header           `protobuf:"bytes,16,opt,name=header,proto3" json:"header,omitempty"`
}

func (*StartWorkflowExecutionRequest) Descriptor

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

func (*StartWorkflowExecutionRequest) Equal

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

func (*StartWorkflowExecutionRequest) GetCronSchedule

func (m *StartWorkflowExecutionRequest) GetCronSchedule() string

func (*StartWorkflowExecutionRequest) GetHeader

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

func (*StartWorkflowExecutionRequest) GetIdentity

func (m *StartWorkflowExecutionRequest) GetIdentity() string

func (*StartWorkflowExecutionRequest) GetInput

func (*StartWorkflowExecutionRequest) GetMemo

func (m *StartWorkflowExecutionRequest) GetMemo() *v13.Memo

func (*StartWorkflowExecutionRequest) GetNamespace

func (m *StartWorkflowExecutionRequest) GetNamespace() string

func (*StartWorkflowExecutionRequest) GetRequestId

func (m *StartWorkflowExecutionRequest) GetRequestId() string

func (*StartWorkflowExecutionRequest) GetRetryPolicy

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

func (*StartWorkflowExecutionRequest) GetSearchAttributes

func (m *StartWorkflowExecutionRequest) GetSearchAttributes() *v13.SearchAttributes

func (*StartWorkflowExecutionRequest) GetTaskQueue

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

func (*StartWorkflowExecutionRequest) GetWorkflowExecutionTimeout added in v0.28.0

func (m *StartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *time.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowId

func (m *StartWorkflowExecutionRequest) GetWorkflowId() string

func (*StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy

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

func (*StartWorkflowExecutionRequest) GetWorkflowRunTimeout added in v0.28.0

func (m *StartWorkflowExecutionRequest) GetWorkflowRunTimeout() *time.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowTaskTimeout added in v0.28.0

func (m *StartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *time.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowType

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

func (*StartWorkflowExecutionRequest) GoString

func (this *StartWorkflowExecutionRequest) GoString() string

func (*StartWorkflowExecutionRequest) Marshal

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

func (*StartWorkflowExecutionRequest) MarshalTo

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

func (*StartWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*StartWorkflowExecutionRequest) ProtoMessage

func (*StartWorkflowExecutionRequest) ProtoMessage()

func (*StartWorkflowExecutionRequest) Reset

func (m *StartWorkflowExecutionRequest) Reset()

func (*StartWorkflowExecutionRequest) Size

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

func (*StartWorkflowExecutionRequest) String

func (this *StartWorkflowExecutionRequest) String() string

func (*StartWorkflowExecutionRequest) Unmarshal

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

func (*StartWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *StartWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*StartWorkflowExecutionRequest) XXX_Marshal

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

func (*StartWorkflowExecutionRequest) XXX_Merge

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

func (*StartWorkflowExecutionRequest) XXX_Size

func (m *StartWorkflowExecutionRequest) XXX_Size() int

func (*StartWorkflowExecutionRequest) XXX_Unmarshal

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

type StartWorkflowExecutionResponse

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

func (*StartWorkflowExecutionResponse) Descriptor

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

func (*StartWorkflowExecutionResponse) Equal

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

func (*StartWorkflowExecutionResponse) GetRunId

func (m *StartWorkflowExecutionResponse) GetRunId() string

func (*StartWorkflowExecutionResponse) GoString

func (this *StartWorkflowExecutionResponse) GoString() string

func (*StartWorkflowExecutionResponse) Marshal

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

func (*StartWorkflowExecutionResponse) MarshalTo

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

func (*StartWorkflowExecutionResponse) MarshalToSizedBuffer

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

func (*StartWorkflowExecutionResponse) ProtoMessage

func (*StartWorkflowExecutionResponse) ProtoMessage()

func (*StartWorkflowExecutionResponse) Reset

func (m *StartWorkflowExecutionResponse) Reset()

func (*StartWorkflowExecutionResponse) Size

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

func (*StartWorkflowExecutionResponse) String

func (this *StartWorkflowExecutionResponse) String() string

func (*StartWorkflowExecutionResponse) Unmarshal

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

func (*StartWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *StartWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*StartWorkflowExecutionResponse) XXX_Marshal

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

func (*StartWorkflowExecutionResponse) XXX_Merge

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

func (*StartWorkflowExecutionResponse) XXX_Size

func (m *StartWorkflowExecutionResponse) XXX_Size() int

func (*StartWorkflowExecutionResponse) XXX_Unmarshal

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

type TerminateWorkflowExecutionRequest

type TerminateWorkflowExecutionRequest struct {
	Namespace         string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Reason            string                 `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	Details           *v13.Payloads          `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	Identity          string                 `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
}

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

func (*UnimplementedWorkflowServiceServer) DescribeWorkflowExecution

func (*UnimplementedWorkflowServiceServer) GetClusterInfo

func (*UnimplementedWorkflowServiceServer) GetSearchAttributes

func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory

func (*UnimplementedWorkflowServiceServer) ListClosedWorkflowExecutions

func (*UnimplementedWorkflowServiceServer) ListNamespaces

func (*UnimplementedWorkflowServiceServer) ListOpenWorkflowExecutions

func (*UnimplementedWorkflowServiceServer) ListTaskQueuePartitions

func (*UnimplementedWorkflowServiceServer) ListWorkflowExecutions

func (*UnimplementedWorkflowServiceServer) PollActivityTaskQueue

func (*UnimplementedWorkflowServiceServer) PollWorkflowTaskQueue

func (*UnimplementedWorkflowServiceServer) QueryWorkflow

func (*UnimplementedWorkflowServiceServer) RecordActivityTaskHeartbeat

func (*UnimplementedWorkflowServiceServer) RegisterNamespace

func (*UnimplementedWorkflowServiceServer) ResetStickyTaskQueue

func (*UnimplementedWorkflowServiceServer) ResetWorkflowExecution

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCanceled

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskCompleted

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailed

func (*UnimplementedWorkflowServiceServer) RespondActivityTaskFailedById

func (*UnimplementedWorkflowServiceServer) RespondQueryTaskCompleted

func (*UnimplementedWorkflowServiceServer) RespondWorkflowTaskCompleted

func (*UnimplementedWorkflowServiceServer) RespondWorkflowTaskFailed

func (*UnimplementedWorkflowServiceServer) ScanWorkflowExecutions

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

(-- api-linter: core::0134::request-mask-required=disabled

aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)

(-- api-linter: core::0134::request-resource-required=disabled

aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)

func (*UpdateNamespaceRequest) Descriptor

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

func (*UpdateNamespaceRequest) Equal

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

func (*UpdateNamespaceRequest) GetConfig

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

func (*UpdateNamespaceRequest) GetDeleteBadBinary

func (m *UpdateNamespaceRequest) GetDeleteBadBinary() string

func (*UpdateNamespaceRequest) GetName

func (m *UpdateNamespaceRequest) GetName() string

func (*UpdateNamespaceRequest) GetReplicationConfig

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

func (*UpdateNamespaceRequest) GetSecurityToken

func (m *UpdateNamespaceRequest) GetSecurityToken() string

func (*UpdateNamespaceRequest) GetUpdateInfo

func (m *UpdateNamespaceRequest) GetUpdateInfo() *v12.UpdateNamespaceInfo

func (*UpdateNamespaceRequest) GoString

func (this *UpdateNamespaceRequest) GoString() string

func (*UpdateNamespaceRequest) Marshal

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

func (*UpdateNamespaceRequest) MarshalTo

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

func (*UpdateNamespaceRequest) MarshalToSizedBuffer

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

func (*UpdateNamespaceRequest) ProtoMessage

func (*UpdateNamespaceRequest) ProtoMessage()

func (*UpdateNamespaceRequest) Reset

func (m *UpdateNamespaceRequest) Reset()

func (*UpdateNamespaceRequest) Size

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

func (*UpdateNamespaceRequest) String

func (this *UpdateNamespaceRequest) String() string

func (*UpdateNamespaceRequest) Unmarshal

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

func (*UpdateNamespaceRequest) XXX_DiscardUnknown

func (m *UpdateNamespaceRequest) XXX_DiscardUnknown()

func (*UpdateNamespaceRequest) XXX_Marshal

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

func (*UpdateNamespaceRequest) XXX_Merge

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

func (*UpdateNamespaceRequest) XXX_Size

func (m *UpdateNamespaceRequest) XXX_Size() int

func (*UpdateNamespaceRequest) XXX_Unmarshal

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

type UpdateNamespaceResponse

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

func (*UpdateNamespaceResponse) Descriptor

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

func (*UpdateNamespaceResponse) Equal

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

func (*UpdateNamespaceResponse) GetConfig

func (*UpdateNamespaceResponse) GetFailoverVersion

func (m *UpdateNamespaceResponse) GetFailoverVersion() int64

func (*UpdateNamespaceResponse) GetIsGlobalNamespace

func (m *UpdateNamespaceResponse) GetIsGlobalNamespace() bool

func (*UpdateNamespaceResponse) GetNamespaceInfo

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

func (*UpdateNamespaceResponse) GetReplicationConfig

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

func (*UpdateNamespaceResponse) GoString

func (this *UpdateNamespaceResponse) GoString() string

func (*UpdateNamespaceResponse) Marshal

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

func (*UpdateNamespaceResponse) MarshalTo

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

func (*UpdateNamespaceResponse) MarshalToSizedBuffer

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

func (*UpdateNamespaceResponse) ProtoMessage

func (*UpdateNamespaceResponse) ProtoMessage()

func (*UpdateNamespaceResponse) Reset

func (m *UpdateNamespaceResponse) Reset()

func (*UpdateNamespaceResponse) Size

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

func (*UpdateNamespaceResponse) String

func (this *UpdateNamespaceResponse) String() string

func (*UpdateNamespaceResponse) Unmarshal

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

func (*UpdateNamespaceResponse) XXX_DiscardUnknown

func (m *UpdateNamespaceResponse) XXX_DiscardUnknown()

func (*UpdateNamespaceResponse) XXX_Marshal

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

func (*UpdateNamespaceResponse) XXX_Merge

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

func (*UpdateNamespaceResponse) XXX_Size

func (m *UpdateNamespaceResponse) XXX_Size() int

func (*UpdateNamespaceResponse) XXX_Unmarshal

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

type WorkflowServiceClient

type WorkflowServiceClient interface {
	// RegisterNamespace creates a new namespace which can be used as a container for all resources.  Namespace is a top level
	// entity within Temporal, used as a container for all resources like workflow executions, task queues, etc.  Namespace
	// acts as a sandbox and provides isolation for all resources within the namespace.  All resources belongs to exactly one
	// namespace.
	RegisterNamespace(ctx context.Context, in *RegisterNamespaceRequest, opts ...grpc.CallOption) (*RegisterNamespaceResponse, error)
	// DescribeNamespace returns the information and configuration for a registered namespace.
	DescribeNamespace(ctx context.Context, in *DescribeNamespaceRequest, opts ...grpc.CallOption) (*DescribeNamespaceResponse, error)
	// ListNamespaces returns the information and configuration for all namespaces.
	ListNamespaces(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)
	// (-- api-linter: core::0134::method-signature=disabled
	//     aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)
	// (-- api-linter: core::0134::response-message-name=disabled
	//     aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)
	// UpdateNamespace is used to update the information and configuration for a registered namespace.
	UpdateNamespace(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace is used to update state of a registered namespace to DEPRECATED.  Once the namespace is deprecated
	// it cannot be used to start new workflow executions.  Existing workflow executions will continue to run on
	// deprecated namespaces.
	DeprecateNamespace(ctx context.Context, in *DeprecateNamespaceRequest, opts ...grpc.CallOption) (*DeprecateNamespaceResponse, error)
	// StartWorkflowExecution starts a new long running workflow instance.  It will create the instance with
	// 'WorkflowExecutionStarted' event in history and also schedule the first WorkflowTask for the worker to make the
	// first command for this instance.  It will return 'WorkflowExecutionAlreadyStartedFailure', if an instance already
	// exists with same workflowId.
	StartWorkflowExecution(ctx context.Context, in *StartWorkflowExecutionRequest, opts ...grpc.CallOption) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution.  It fails with 'NotFoundFailure' if specified workflow
	// execution in unknown to the service.
	GetWorkflowExecutionHistory(ctx context.Context, in *GetWorkflowExecutionHistoryRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionHistoryResponse, error)
	// PollWorkflowTaskQueue is called by application worker to process WorkflowTask from a specific task queue.  A
	// WorkflowTask is dispatched to callers for active workflow executions, with pending workflow tasks.
	// Application is then expected to call 'RespondWorkflowTaskCompleted' API when it is done processing the WorkflowTask.
	// It will also create a 'WorkflowTaskStarted' event in the history for that session before handing off WorkflowTask to
	// application worker.
	PollWorkflowTaskQueue(ctx context.Context, in *PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*PollWorkflowTaskQueueResponse, error)
	// RespondWorkflowTaskCompleted is called by application worker to complete a WorkflowTask handed as a result of
	// 'PollWorkflowTaskQueue' API call.  Completing a WorkflowTask will result in new events for the workflow execution and
	// potentially new ActivityTask being created for corresponding commands.  It will also create a WorkflowTaskCompleted
	// event in the history for that session.  Use the 'taskToken' provided as response of PollWorkflowTaskQueue API call
	// for completing the WorkflowTask.
	// The response could contain a new workflow task if there is one or if the request asking for one.
	RespondWorkflowTaskCompleted(ctx context.Context, in *RespondWorkflowTaskCompletedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by application worker to indicate failure.  This results in
	// WorkflowTaskFailedEvent written to the history and a new WorkflowTask created.  This API can be used by client to
	// either clear sticky task queue or report any panics during WorkflowTask processing.  Temporal will only append first
	// WorkflowTaskFailed event to the history of workflow execution for consecutive failures.
	RespondWorkflowTaskFailed(ctx context.Context, in *RespondWorkflowTaskFailedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskFailedResponse, error)
	// PollActivityTaskQueue is called by application worker to process ActivityTask from a specific task queue.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask command is made for a workflow execution.
	// Application is expected to call 'RespondActivityTaskCompleted' or 'RespondActivityTaskFailed' once it is done
	// processing the task.
	// Application also needs to call 'RecordActivityTaskHeartbeat' API within 'heartbeatTimeoutSeconds' interval to
	// prevent the task from getting timed out.  An event 'ActivityTaskStarted' event is also written to workflow execution
	// history before the ActivityTask is dispatched to application worker.
	PollActivityTaskQueue(ctx context.Context, in *PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*PollActivityTaskQueueResponse, error)
	// RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timedout and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeat' will
	// fail with 'NotFoundFailure' in such situations.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for heart beating.
	RecordActivityTaskHeartbeat(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RecordActivityTaskHeartbeatById is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timed out and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeatById' will
	// fail with 'NotFoundFailure' in such situations.  Instead of using 'taskToken' like in RecordActivityTaskHeartbeat,
	// use Namespace, WorkflowId and ActivityId
	RecordActivityTaskHeartbeatById(ctx context.Context, in *RecordActivityTaskHeartbeatByIdRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatByIdResponse, error)
	// RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCompleted(ctx context.Context, in *RespondActivityTaskCompletedRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskCompletedById is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Similar to RespondActivityTaskCompleted but use Namespace,
	// WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskCompletedById(ctx context.Context, in *RespondActivityTaskCompletedByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedByIdResponse, error)
	// RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskFailed(ctx context.Context, in *RespondActivityTaskFailedRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskFailedById is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Similar to RespondActivityTaskFailed but use
	// Namespace, WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskFailedById(ctx context.Context, in *RespondActivityTaskFailedByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedByIdResponse, error)
	// RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask.  It will
	// result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCanceled(ctx context.Context, in *RespondActivityTaskCanceledRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskCanceledById is called by application worker when it is successfully canceled an ActivityTask.
	// It will result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Similar to RespondActivityTaskCanceled but use
	// Namespace, WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskCanceledById(ctx context.Context, in *RespondActivityTaskCanceledByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledByIdResponse, error)
	// RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance.
	// It will result in a new 'WorkflowExecutionCancelRequested' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made. It fails with 'NotFoundFailure' if the workflow is not valid
	// anymore due to completion or doesn't exist.
	RequestCancelWorkflowExecution(ctx context.Context, in *RequestCancelWorkflowExecutionRequest, opts ...grpc.CallOption) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal event to running workflow execution.  This results in
	// WorkflowExecutionSignaled event recorded in the history and a workflow task being created for the execution.
	SignalWorkflowExecution(ctx context.Context, in *SignalWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWorkflowExecutionResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "With" is used to indicate combined operation. --)
	// SignalWithStartWorkflowExecution is used to ensure sending signal to a workflow.
	// If the workflow is running, this results in WorkflowExecutionSignaled event being recorded in the history
	// and a workflow task being created for the execution.
	// If the workflow is not running or not found, this results in WorkflowExecutionStarted and WorkflowExecutionSignaled
	// events being recorded in history, and a workflow task being created for the execution
	SignalWithStartWorkflowExecution(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution to WorkflowTaskCompleted event(exclusive).
	// And it will immediately terminating the current execution instance.
	ResetWorkflowExecution(ctx context.Context, in *ResetWorkflowExecutionRequest, opts ...grpc.CallOption) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event
	// in the history and immediately terminating the execution instance.
	TerminateWorkflowExecution(ctx context.Context, in *TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*TerminateWorkflowExecutionResponse, error)
	// ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific namespace.
	ListOpenWorkflowExecutions(ctx context.Context, in *ListOpenWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListOpenWorkflowExecutionsResponse, error)
	// ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific namespace.
	ListClosedWorkflowExecutions(ctx context.Context, in *ListClosedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListClosedWorkflowExecutionsResponse, error)
	// ListWorkflowExecutions is a visibility API to list workflow executions in a specific namespace.
	ListWorkflowExecutions(ctx context.Context, in *ListWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListWorkflowExecutionsResponse, error)
	// ListArchivedWorkflowExecutions is a visibility API to list archived workflow executions in a specific namespace.
	ListArchivedWorkflowExecutions(ctx context.Context, in *ListArchivedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListArchivedWorkflowExecutionsResponse, error)
	// ScanWorkflowExecutions is a visibility API to list large amount of workflow executions in a specific namespace without order.
	ScanWorkflowExecutions(ctx context.Context, in *ScanWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ScanWorkflowExecutionsResponse, error)
	// CountWorkflowExecutions is a visibility API to count of workflow executions in a specific namespace.
	CountWorkflowExecutions(ctx context.Context, in *CountWorkflowExecutionsRequest, opts ...grpc.CallOption) (*CountWorkflowExecutionsResponse, error)
	// GetSearchAttributes is a visibility API to get all legal keys that could be used in list APIs
	GetSearchAttributes(ctx context.Context, in *GetSearchAttributesRequest, opts ...grpc.CallOption) (*GetSearchAttributesResponse, error)
	// RespondQueryTaskCompleted is called by application worker to complete a QueryTask (which is a WorkflowTask for query)
	// as a result of 'PollWorkflowTaskQueue' API call. Completing a QueryTask will unblock the client call to 'QueryWorkflow'
	// API and return the query result to client as a response to 'QueryWorkflow' API call.
	RespondQueryTaskCompleted(ctx context.Context, in *RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskQueue resets the sticky task queue related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	// 3. ClientLibraryVersion
	// 4. ClientFeatureVersion
	// 5. ClientImpl
	ResetStickyTaskQueue(ctx context.Context, in *ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*ResetStickyTaskQueueResponse, error)
	// QueryWorkflow returns query result for a specified workflow execution
	QueryWorkflow(ctx context.Context, in *QueryWorkflowRequest, opts ...grpc.CallOption) (*QueryWorkflowResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(ctx context.Context, in *DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*DescribeWorkflowExecutionResponse, error)
	// DescribeTaskQueue returns information about the target task queue, right now this API returns the
	// pollers which polled this task queue in last few minutes.
	DescribeTaskQueue(ctx context.Context, in *DescribeTaskQueueRequest, opts ...grpc.CallOption) (*DescribeTaskQueueResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
	ListTaskQueuePartitions(ctx context.Context, in *ListTaskQueuePartitionsRequest, opts ...grpc.CallOption) (*ListTaskQueuePartitionsResponse, error)
}

WorkflowServiceClient is the client API for WorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkflowServiceClient

func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient

type WorkflowServiceServer

type WorkflowServiceServer interface {
	// RegisterNamespace creates a new namespace which can be used as a container for all resources.  Namespace is a top level
	// entity within Temporal, used as a container for all resources like workflow executions, task queues, etc.  Namespace
	// acts as a sandbox and provides isolation for all resources within the namespace.  All resources belongs to exactly one
	// namespace.
	RegisterNamespace(context.Context, *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)
	// DescribeNamespace returns the information and configuration for a registered namespace.
	DescribeNamespace(context.Context, *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)
	// ListNamespaces returns the information and configuration for all namespaces.
	ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
	// (-- api-linter: core::0134::method-signature=disabled
	//     aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)
	// (-- api-linter: core::0134::response-message-name=disabled
	//     aip.dev/not-precedent: UpdateNamespace RPC doesn't follow Google API format. --)
	// UpdateNamespace is used to update the information and configuration for a registered namespace.
	UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace is used to update state of a registered namespace to DEPRECATED.  Once the namespace is deprecated
	// it cannot be used to start new workflow executions.  Existing workflow executions will continue to run on
	// deprecated namespaces.
	DeprecateNamespace(context.Context, *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)
	// StartWorkflowExecution starts a new long running workflow instance.  It will create the instance with
	// 'WorkflowExecutionStarted' event in history and also schedule the first WorkflowTask for the worker to make the
	// first command for this instance.  It will return 'WorkflowExecutionAlreadyStartedFailure', if an instance already
	// exists with same workflowId.
	StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution.  It fails with 'NotFoundFailure' if specified workflow
	// execution in unknown to the service.
	GetWorkflowExecutionHistory(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)
	// PollWorkflowTaskQueue is called by application worker to process WorkflowTask from a specific task queue.  A
	// WorkflowTask is dispatched to callers for active workflow executions, with pending workflow tasks.
	// Application is then expected to call 'RespondWorkflowTaskCompleted' API when it is done processing the WorkflowTask.
	// It will also create a 'WorkflowTaskStarted' event in the history for that session before handing off WorkflowTask to
	// application worker.
	PollWorkflowTaskQueue(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)
	// RespondWorkflowTaskCompleted is called by application worker to complete a WorkflowTask handed as a result of
	// 'PollWorkflowTaskQueue' API call.  Completing a WorkflowTask will result in new events for the workflow execution and
	// potentially new ActivityTask being created for corresponding commands.  It will also create a WorkflowTaskCompleted
	// event in the history for that session.  Use the 'taskToken' provided as response of PollWorkflowTaskQueue API call
	// for completing the WorkflowTask.
	// The response could contain a new workflow task if there is one or if the request asking for one.
	RespondWorkflowTaskCompleted(context.Context, *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by application worker to indicate failure.  This results in
	// WorkflowTaskFailedEvent written to the history and a new WorkflowTask created.  This API can be used by client to
	// either clear sticky task queue or report any panics during WorkflowTask processing.  Temporal will only append first
	// WorkflowTaskFailed event to the history of workflow execution for consecutive failures.
	RespondWorkflowTaskFailed(context.Context, *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)
	// PollActivityTaskQueue is called by application worker to process ActivityTask from a specific task queue.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask command is made for a workflow execution.
	// Application is expected to call 'RespondActivityTaskCompleted' or 'RespondActivityTaskFailed' once it is done
	// processing the task.
	// Application also needs to call 'RecordActivityTaskHeartbeat' API within 'heartbeatTimeoutSeconds' interval to
	// prevent the task from getting timed out.  An event 'ActivityTaskStarted' event is also written to workflow execution
	// history before the ActivityTask is dispatched to application worker.
	PollActivityTaskQueue(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)
	// RecordActivityTaskHeartbeat is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timedout and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeat' will
	// fail with 'NotFoundFailure' in such situations.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for heart beating.
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RecordActivityTaskHeartbeatById is called by application worker while it is processing an ActivityTask.  If worker fails
	// to heartbeat within 'heartbeatTimeoutSeconds' interval for the ActivityTask, then it will be marked as timed out and
	// 'ActivityTaskTimedOut' event will be written to the workflow history.  Calling 'RecordActivityTaskHeartbeatById' will
	// fail with 'NotFoundFailure' in such situations.  Instead of using 'taskToken' like in RecordActivityTaskHeartbeat,
	// use Namespace, WorkflowId and ActivityId
	RecordActivityTaskHeartbeatById(context.Context, *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)
	// RespondActivityTaskCompleted is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskCompletedById is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskCompleted' event being written to the workflow history and a new WorkflowTask
	// created for the workflow so new commands could be made.  Similar to RespondActivityTaskCompleted but use Namespace,
	// WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskCompletedById(context.Context, *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)
	// RespondActivityTaskFailed is called by application worker when it is done processing an ActivityTask.  It will
	// result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskFailedById is called by application worker when it is done processing an ActivityTask.
	// It will result in a new 'ActivityTaskFailed' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Similar to RespondActivityTaskFailed but use
	// Namespace, WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskFailedById(context.Context, *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)
	// RespondActivityTaskCanceled is called by application worker when it is successfully canceled an ActivityTask.  It will
	// result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Use the 'taskToken' provided as response of
	// PollActivityTaskQueue API call for completion. It fails with 'NotFoundFailure' if the taskToken is not valid
	// anymore due to activity timeout.
	RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	// RespondActivityTaskCanceledById is called by application worker when it is successfully canceled an ActivityTask.
	// It will result in a new 'ActivityTaskCanceled' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made.  Similar to RespondActivityTaskCanceled but use
	// Namespace, WorkflowId and ActivityId instead of 'taskToken' for completion. It fails with 'NotFoundFailure'
	// if the these Ids are not valid anymore due to activity timeout.
	RespondActivityTaskCanceledById(context.Context, *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)
	// RequestCancelWorkflowExecution is called by application worker when it wants to request cancellation of a workflow instance.
	// It will result in a new 'WorkflowExecutionCancelRequested' event being written to the workflow history and a new WorkflowTask
	// created for the workflow instance so new commands could be made. It fails with 'NotFoundFailure' if the workflow is not valid
	// anymore due to completion or doesn't exist.
	RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal event to running workflow execution.  This results in
	// WorkflowExecutionSignaled event recorded in the history and a workflow task being created for the execution.
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "With" is used to indicate combined operation. --)
	// SignalWithStartWorkflowExecution is used to ensure sending signal to a workflow.
	// If the workflow is running, this results in WorkflowExecutionSignaled event being recorded in the history
	// and a workflow task being created for the execution.
	// If the workflow is not running or not found, this results in WorkflowExecutionStarted and WorkflowExecutionSignaled
	// events being recorded in history, and a workflow task being created for the execution
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution reset an existing workflow execution to WorkflowTaskCompleted event(exclusive).
	// And it will immediately terminating the current execution instance.
	ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording WorkflowExecutionTerminated event
	// in the history and immediately terminating the execution instance.
	TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)
	// ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific namespace.
	ListOpenWorkflowExecutions(context.Context, *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)
	// ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific namespace.
	ListClosedWorkflowExecutions(context.Context, *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)
	// ListWorkflowExecutions is a visibility API to list workflow executions in a specific namespace.
	ListWorkflowExecutions(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	// ListArchivedWorkflowExecutions is a visibility API to list archived workflow executions in a specific namespace.
	ListArchivedWorkflowExecutions(context.Context, *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)
	// ScanWorkflowExecutions is a visibility API to list large amount of workflow executions in a specific namespace without order.
	ScanWorkflowExecutions(context.Context, *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)
	// CountWorkflowExecutions is a visibility API to count of workflow executions in a specific namespace.
	CountWorkflowExecutions(context.Context, *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
	// GetSearchAttributes is a visibility API to get all legal keys that could be used in list APIs
	GetSearchAttributes(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)
	// RespondQueryTaskCompleted is called by application worker to complete a QueryTask (which is a WorkflowTask for query)
	// as a result of 'PollWorkflowTaskQueue' API call. Completing a QueryTask will unblock the client call to 'QueryWorkflow'
	// API and return the query result to client as a response to 'QueryWorkflow' API call.
	RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskQueue resets the sticky task queue related information in mutable state of a given workflow.
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	// 3. ClientLibraryVersion
	// 4. ClientFeatureVersion
	// 5. ClientImpl
	ResetStickyTaskQueue(context.Context, *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)
	// QueryWorkflow returns query result for a specified workflow execution
	QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)
	// DescribeTaskQueue returns information about the target task queue, right now this API returns the
	// pollers which polled this task queue in last few minutes.
	DescribeTaskQueue(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	ListTaskQueuePartitions(context.Context, *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)
}

WorkflowServiceServer is the server API for WorkflowService service.

Jump to

Keyboard shortcuts

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