workflowservice

package
v0.10.2 Latest Latest
Warning

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

Go to latest
Published: Apr 14, 2022 License: MIT Imports: 36 Imported by: 0

Documentation

Overview

Package workflowservice is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

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 RegisterWorkflowServiceHandler

func RegisterWorkflowServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterWorkflowServiceHandler registers the http handlers for service WorkflowService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterWorkflowServiceHandlerClient

func RegisterWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkflowServiceClient) error

RegisterWorkflowServiceHandlerClient registers the http handlers for service WorkflowService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WorkflowServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WorkflowServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "WorkflowServiceClient" to call the correct interceptors.

func RegisterWorkflowServiceHandlerFromEndpoint

func RegisterWorkflowServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterWorkflowServiceHandlerFromEndpoint is same as RegisterWorkflowServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterWorkflowServiceHandlerServer

func RegisterWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkflowServiceServer) error

RegisterWorkflowServiceHandlerServer registers the http handlers for service WorkflowService to "mux". UnaryRPC :call WorkflowServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWorkflowServiceHandlerFromEndpoint instead.

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 {
	Namespace     string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	SecurityToken string `protobuf:"bytes,2,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
}

Deprecated.

func (*DeprecateNamespaceRequest) Descriptor

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

func (*DeprecateNamespaceRequest) Equal

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

func (*DeprecateNamespaceRequest) GetNamespace

func (m *DeprecateNamespaceRequest) GetNamespace() 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 {
}

Deprecated.

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 {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,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) GetNamespace

func (m *DescribeNamespaceRequest) GetNamespace() 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"`
	PendingWorkflowTask   *v110.PendingWorkflowTaskInfo     `protobuf:"bytes,5,opt,name=pending_workflow_task,json=pendingWorkflowTask,proto3" json:"pending_workflow_task,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) GetPendingWorkflowTask added in v0.8.0

func (m *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v110.PendingWorkflowTaskInfo

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 {
	// Key is client name i.e "temporal-go", "temporal-java", or "temporal-cli".
	// Value is ranges of supported versions of this client i.e ">1.1.1 <=1.4.0 || ^5.0.0".
	SupportedClients  map[string]string `` /* 197-byte string literal not displayed */
	ServerVersion     string            `protobuf:"bytes,2,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	ClusterId         string            `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	VersionInfo       *v111.VersionInfo `protobuf:"bytes,4,opt,name=version_info,json=versionInfo,proto3" json:"version_info,omitempty"`
	ClusterName       string            `protobuf:"bytes,5,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	HistoryShardCount int32             `protobuf:"varint,6,opt,name=history_shard_count,json=historyShardCount,proto3" json:"history_shard_count,omitempty"`
	PersistenceStore  string            `protobuf:"bytes,7,opt,name=persistence_store,json=persistenceStore,proto3" json:"persistence_store,omitempty"`
	VisibilityStore   string            `protobuf:"bytes,8,opt,name=visibility_store,json=visibilityStore,proto3" json:"visibility_store,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) GetClusterId

func (m *GetClusterInfoResponse) GetClusterId() string

func (*GetClusterInfoResponse) GetClusterName

func (m *GetClusterInfoResponse) GetClusterName() string

func (*GetClusterInfoResponse) GetHistoryShardCount

func (m *GetClusterInfoResponse) GetHistoryShardCount() int32

func (*GetClusterInfoResponse) GetPersistenceStore added in v0.8.0

func (m *GetClusterInfoResponse) GetPersistenceStore() string

func (*GetClusterInfoResponse) GetServerVersion

func (m *GetClusterInfoResponse) GetServerVersion() string

func (*GetClusterInfoResponse) GetSupportedClients

func (m *GetClusterInfoResponse) GetSupportedClients() map[string]string

func (*GetClusterInfoResponse) GetVersionInfo

func (m *GetClusterInfoResponse) GetVersionInfo() *v111.VersionInfo

func (*GetClusterInfoResponse) GetVisibilityStore added in v0.8.0

func (m *GetClusterInfoResponse) GetVisibilityStore() string

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

type GetSystemInfoRequest struct {
}

func (*GetSystemInfoRequest) Descriptor added in v0.8.0

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

func (*GetSystemInfoRequest) Equal added in v0.8.0

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

func (*GetSystemInfoRequest) GoString added in v0.8.0

func (this *GetSystemInfoRequest) GoString() string

func (*GetSystemInfoRequest) Marshal added in v0.8.0

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

func (*GetSystemInfoRequest) MarshalTo added in v0.8.0

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

func (*GetSystemInfoRequest) MarshalToSizedBuffer added in v0.8.0

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

func (*GetSystemInfoRequest) ProtoMessage added in v0.8.0

func (*GetSystemInfoRequest) ProtoMessage()

func (*GetSystemInfoRequest) Reset added in v0.8.0

func (m *GetSystemInfoRequest) Reset()

func (*GetSystemInfoRequest) Size added in v0.8.0

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

func (*GetSystemInfoRequest) String added in v0.8.0

func (this *GetSystemInfoRequest) String() string

func (*GetSystemInfoRequest) Unmarshal added in v0.8.0

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

func (*GetSystemInfoRequest) XXX_DiscardUnknown added in v0.8.0

func (m *GetSystemInfoRequest) XXX_DiscardUnknown()

func (*GetSystemInfoRequest) XXX_Marshal added in v0.8.0

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

func (*GetSystemInfoRequest) XXX_Merge added in v0.8.0

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

func (*GetSystemInfoRequest) XXX_Size added in v0.8.0

func (m *GetSystemInfoRequest) XXX_Size() int

func (*GetSystemInfoRequest) XXX_Unmarshal added in v0.8.0

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

type GetSystemInfoResponse added in v0.8.0

type GetSystemInfoResponse struct {
	// Version of the server.
	ServerVersion string `protobuf:"bytes,1,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	// All capabilities the system supports.
	Capabilities *GetSystemInfoResponse_Capabilities `protobuf:"bytes,2,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
}

func (*GetSystemInfoResponse) Descriptor added in v0.8.0

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

func (*GetSystemInfoResponse) Equal added in v0.8.0

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

func (*GetSystemInfoResponse) GetCapabilities added in v0.8.0

func (*GetSystemInfoResponse) GetServerVersion added in v0.8.0

func (m *GetSystemInfoResponse) GetServerVersion() string

func (*GetSystemInfoResponse) GoString added in v0.8.0

func (this *GetSystemInfoResponse) GoString() string

func (*GetSystemInfoResponse) Marshal added in v0.8.0

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

func (*GetSystemInfoResponse) MarshalTo added in v0.8.0

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

func (*GetSystemInfoResponse) MarshalToSizedBuffer added in v0.8.0

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

func (*GetSystemInfoResponse) ProtoMessage added in v0.8.0

func (*GetSystemInfoResponse) ProtoMessage()

func (*GetSystemInfoResponse) Reset added in v0.8.0

func (m *GetSystemInfoResponse) Reset()

func (*GetSystemInfoResponse) Size added in v0.8.0

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

func (*GetSystemInfoResponse) String added in v0.8.0

func (this *GetSystemInfoResponse) String() string

func (*GetSystemInfoResponse) Unmarshal added in v0.8.0

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

func (*GetSystemInfoResponse) XXX_DiscardUnknown added in v0.8.0

func (m *GetSystemInfoResponse) XXX_DiscardUnknown()

func (*GetSystemInfoResponse) XXX_Marshal added in v0.8.0

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

func (*GetSystemInfoResponse) XXX_Merge added in v0.8.0

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

func (*GetSystemInfoResponse) XXX_Size added in v0.8.0

func (m *GetSystemInfoResponse) XXX_Size() int

func (*GetSystemInfoResponse) XXX_Unmarshal added in v0.8.0

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

type GetSystemInfoResponse_Capabilities added in v0.8.0

type GetSystemInfoResponse_Capabilities struct {
	// True if signal and query headers are supported.
	SignalAndQueryHeader bool `` /* 126-byte string literal not displayed */
	// True if internal errors are differentiated from other types of errors for purposes of
	// retrying non-internal errors.
	//
	// When unset/false, clients retry all failures. When true, clients should only retry
	// non-internal errors.
	InternalErrorDifferentiation bool `` /* 148-byte string literal not displayed */
	// True if RespondActivityTaskFailed API supports including heartbeat details
	ActivityFailureIncludeHeartbeat bool `` /* 159-byte string literal not displayed */
}

System capability details.

func (*GetSystemInfoResponse_Capabilities) Descriptor added in v0.8.0

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

func (*GetSystemInfoResponse_Capabilities) Equal added in v0.8.0

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

func (*GetSystemInfoResponse_Capabilities) GetActivityFailureIncludeHeartbeat added in v0.8.0

func (m *GetSystemInfoResponse_Capabilities) GetActivityFailureIncludeHeartbeat() bool

func (*GetSystemInfoResponse_Capabilities) GetInternalErrorDifferentiation added in v0.8.0

func (m *GetSystemInfoResponse_Capabilities) GetInternalErrorDifferentiation() bool

func (*GetSystemInfoResponse_Capabilities) GetSignalAndQueryHeader added in v0.8.0

func (m *GetSystemInfoResponse_Capabilities) GetSignalAndQueryHeader() bool

func (*GetSystemInfoResponse_Capabilities) GoString added in v0.8.0

func (this *GetSystemInfoResponse_Capabilities) GoString() string

func (*GetSystemInfoResponse_Capabilities) Marshal added in v0.8.0

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

func (*GetSystemInfoResponse_Capabilities) MarshalTo added in v0.8.0

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

func (*GetSystemInfoResponse_Capabilities) MarshalToSizedBuffer added in v0.8.0

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

func (*GetSystemInfoResponse_Capabilities) ProtoMessage added in v0.8.0

func (*GetSystemInfoResponse_Capabilities) ProtoMessage()

func (*GetSystemInfoResponse_Capabilities) Reset added in v0.8.0

func (*GetSystemInfoResponse_Capabilities) Size added in v0.8.0

func (*GetSystemInfoResponse_Capabilities) String added in v0.8.0

func (*GetSystemInfoResponse_Capabilities) Unmarshal added in v0.8.0

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

func (*GetSystemInfoResponse_Capabilities) XXX_DiscardUnknown added in v0.8.0

func (m *GetSystemInfoResponse_Capabilities) XXX_DiscardUnknown()

func (*GetSystemInfoResponse_Capabilities) XXX_Marshal added in v0.8.0

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

func (*GetSystemInfoResponse_Capabilities) XXX_Merge added in v0.8.0

func (*GetSystemInfoResponse_Capabilities) XXX_Size added in v0.8.0

func (*GetSystemInfoResponse_Capabilities) XXX_Unmarshal added in v0.8.0

func (m *GetSystemInfoResponse_Capabilities) 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"`
	// If a `GetWorkflowExecutionHistoryResponse` or a `PollWorkflowTaskQueueResponse` had one of
	// these, it should be passed here to fetch the next page.
	NextPageToken []byte `protobuf:"bytes,4,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// If set to true, the RPC call will not resolve until there is a new event which matches
	// the `history_event_filter_type`, or a timeout is hit.
	WaitNewEvent bool `protobuf:"varint,5,opt,name=wait_new_event,json=waitNewEvent,proto3" json:"wait_new_event,omitempty"`
	// Filter returned events such that they match the specified filter type.
	// 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"`
	// Raw history is an alternate representation of history that may be returned if configured on
	// the frontend. This is not supported by all SDKs. Either this or `history` will be set.
	RawHistory []*v13.DataBlob `protobuf:"bytes,2,rep,name=raw_history,json=rawHistory,proto3" json:"raw_history,omitempty"`
	// Will be set if there are more history events than were included in this response
	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 GetWorkflowExecutionHistoryReverseRequest added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseRequest) Descriptor added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseRequest) Equal added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseRequest) GetExecution added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) GetMaximumPageSize added in v0.8.0

func (m *GetWorkflowExecutionHistoryReverseRequest) GetMaximumPageSize() int32

func (*GetWorkflowExecutionHistoryReverseRequest) GetNamespace added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) GetNextPageToken added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseRequest) GoString added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) Marshal added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseRequest) MarshalTo added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseRequest) MarshalToSizedBuffer added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseRequest) ProtoMessage added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) Reset added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) Size added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) String added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) Unmarshal added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) XXX_DiscardUnknown added in v0.8.0

func (m *GetWorkflowExecutionHistoryReverseRequest) XXX_DiscardUnknown()

func (*GetWorkflowExecutionHistoryReverseRequest) XXX_Marshal added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseRequest) XXX_Merge added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) XXX_Size added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseRequest) XXX_Unmarshal added in v0.8.0

type GetWorkflowExecutionHistoryReverseResponse added in v0.8.0

type GetWorkflowExecutionHistoryReverseResponse struct {
	History *v15.History `protobuf:"bytes,1,opt,name=history,proto3" json:"history,omitempty"`
	// Will be set if there are more history events than were included in this response
	NextPageToken []byte `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
}

func (*GetWorkflowExecutionHistoryReverseResponse) Descriptor added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) Equal added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseResponse) GetHistory added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) GetNextPageToken added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseResponse) GoString added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) Marshal added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseResponse) MarshalTo added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseResponse) MarshalToSizedBuffer added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseResponse) ProtoMessage added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) Reset added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) Size added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) String added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) Unmarshal added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) XXX_DiscardUnknown added in v0.8.0

func (m *GetWorkflowExecutionHistoryReverseResponse) XXX_DiscardUnknown()

func (*GetWorkflowExecutionHistoryReverseResponse) XXX_Marshal added in v0.8.0

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

func (*GetWorkflowExecutionHistoryReverseResponse) XXX_Merge added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) XXX_Size added in v0.8.0

func (*GetWorkflowExecutionHistoryReverseResponse) XXX_Unmarshal added in v0.8.0

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"`
	// The identity of the worker/client
	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 {
	// A unique identifier for this task
	TaskToken []byte `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// The namespace the workflow which requested this activity lives in
	WorkflowNamespace string `protobuf:"bytes,2,opt,name=workflow_namespace,json=workflowNamespace,proto3" json:"workflow_namespace,omitempty"`
	// Type of the requesting workflow
	WorkflowType *v13.WorkflowType `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	// Execution info of the requesting workflow
	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"`
	// The autogenerated or user specified identifier of this activity. Can be used to complete the
	// activity via `RespondActivityTaskCompletedById`. May be re-used as long as the last usage
	// has resolved, but unique IDs for every activity invocation is a good idea.
	ActivityId string `protobuf:"bytes,6,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	// Headers specified by the scheduling workflow. Commonly used to propagate contextual info
	// from the workflow to its activities. For example, tracing contexts.
	Header *v13.Header `protobuf:"bytes,7,opt,name=header,proto3" json:"header,omitempty"`
	// Arguments to the activity invocation
	Input *v13.Payloads `protobuf:"bytes,8,opt,name=input,proto3" json:"input,omitempty"`
	// Details of the last heartbeat that was recorded for this activity as of the time this task
	// was delivered.
	HeartbeatDetails *v13.Payloads `protobuf:"bytes,9,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	// When was this task first scheduled
	ScheduledTime *time.Time `protobuf:"bytes,10,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	// When was this task attempt scheduled
	CurrentAttemptScheduledTime *time.Time `` /* 155-byte string literal not displayed */
	// When was this task started (this attempt)
	StartedTime *time.Time `protobuf:"bytes,12,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	// Starting at 1, the number of attempts to perform this activity
	Attempt int32 `protobuf:"varint,13,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// First scheduled -> final result reported timeout
	//
	// (-- 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 */
	// Current attempt start -> final result reported timeout
	//
	// (-- 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 */
	// Window within which the activity must report a heartbeat, or be timed out.
	HeartbeatTimeout *time.Duration `protobuf:"bytes,16,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3,stdduration" json:"heartbeat_timeout,omitempty"`
	// This is the retry policy the service uses which may be different from the one provided
	// (or not) during activity scheduling. The service can override the provided one if some
	// values are not specified or exceed configured system limits.
	RetryPolicy *v13.RetryPolicy `protobuf:"bytes,17,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
}

func (*PollActivityTaskQueueResponse) Descriptor

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

func (*PollActivityTaskQueueResponse) Equal

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

func (*PollActivityTaskQueueResponse) GetActivityId

func (m *PollActivityTaskQueueResponse) GetActivityId() string

func (*PollActivityTaskQueueResponse) GetActivityType

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

func (*PollActivityTaskQueueResponse) GetAttempt

func (m *PollActivityTaskQueueResponse) GetAttempt() int32

func (*PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime

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

func (*PollActivityTaskQueueResponse) GetHeader

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

func (*PollActivityTaskQueueResponse) GetHeartbeatDetails

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

func (*PollActivityTaskQueueResponse) GetHeartbeatTimeout

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

func (*PollActivityTaskQueueResponse) GetInput

func (*PollActivityTaskQueueResponse) GetRetryPolicy

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

func (*PollActivityTaskQueueResponse) GetScheduleToCloseTimeout

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

func (*PollActivityTaskQueueResponse) GetScheduledTime

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

func (*PollActivityTaskQueueResponse) GetStartToCloseTimeout

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

func (*PollActivityTaskQueueResponse) GetStartedTime

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

func (*PollActivityTaskQueueResponse) GetTaskToken

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

func (*PollActivityTaskQueueResponse) GetWorkflowExecution

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

func (*PollActivityTaskQueueResponse) GetWorkflowNamespace

func (m *PollActivityTaskQueueResponse) GetWorkflowNamespace() string

func (*PollActivityTaskQueueResponse) GetWorkflowType

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

func (*PollActivityTaskQueueResponse) GoString

func (this *PollActivityTaskQueueResponse) GoString() string

func (*PollActivityTaskQueueResponse) Marshal

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

func (*PollActivityTaskQueueResponse) MarshalTo

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

func (*PollActivityTaskQueueResponse) MarshalToSizedBuffer

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

func (*PollActivityTaskQueueResponse) ProtoMessage

func (*PollActivityTaskQueueResponse) ProtoMessage()

func (*PollActivityTaskQueueResponse) Reset

func (m *PollActivityTaskQueueResponse) Reset()

func (*PollActivityTaskQueueResponse) Size

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

func (*PollActivityTaskQueueResponse) String

func (this *PollActivityTaskQueueResponse) String() string

func (*PollActivityTaskQueueResponse) Unmarshal

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

func (*PollActivityTaskQueueResponse) XXX_DiscardUnknown

func (m *PollActivityTaskQueueResponse) XXX_DiscardUnknown()

func (*PollActivityTaskQueueResponse) XXX_Marshal

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

func (*PollActivityTaskQueueResponse) XXX_Merge

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

func (*PollActivityTaskQueueResponse) XXX_Size

func (m *PollActivityTaskQueueResponse) XXX_Size() int

func (*PollActivityTaskQueueResponse) XXX_Unmarshal

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

type PollWorkflowTaskQueueRequest

type PollWorkflowTaskQueueRequest struct {
	Namespace string         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueue *v14.TaskQueue `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// The identity of the worker/client who is polling this task queue
	Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// Each worker process should provide an ID unique to the specific set of code it is running
	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 {
	// A unique identifier for this task
	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"`
	// The last workflow task started event which was processed by some worker for this execution.
	// Will be zero if no task has ever started.
	PreviousStartedEventId int64 `` /* 132-byte string literal not displayed */
	// The id of the most recent workflow task started event, which will have been generated as a
	// result of this poll request being served.
	StartedEventId int64 `protobuf:"varint,5,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	// Starting at 1, the number of attempts to complete this task by any worker.
	Attempt int32 `protobuf:"varint,6,opt,name=attempt,proto3" json:"attempt,omitempty"`
	// A hint that there are more tasks already present in this task queue. Can be used to
	// prioritize draining a sticky queue before polling from a normal queue.
	BacklogCountHint int64 `protobuf:"varint,7,opt,name=backlog_count_hint,json=backlogCountHint,proto3" json:"backlog_count_hint,omitempty"`
	// The history for this workflow, which will either be complete or partial. Partial histories
	// are sent to workers who have signaled that they are using a sticky queue when completing
	// a workflow task.
	History *v15.History `protobuf:"bytes,8,opt,name=history,proto3" json:"history,omitempty"`
	// Will be set if there are more history events than were included in this response. Such events
	// should be fetched via `GetWorkflowExecutionHistory`.
	NextPageToken []byte `protobuf:"bytes,9,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Legacy queries appear in this field. The query must be responded to via
	// `RespondQueryTaskCompleted`. If the workflow is already closed (queries are permitted on
	// closed workflows) then the `history` field will be populated with the entire history. It
	// may also be populated if this task originates on a non-sticky queue.
	Query *v16.WorkflowQuery `protobuf:"bytes,10,opt,name=query,proto3" json:"query,omitempty"`
	// The task queue this task originated from, which will always be the original non-sticky name
	// for the queue, even if this response came from polling a sticky queue.
	WorkflowExecutionTaskQueue *v14.TaskQueue `` /* 144-byte string literal not displayed */
	// When this task was scheduled by the server
	ScheduledTime *time.Time `protobuf:"bytes,12,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	// When the current workflow task started event was generated, meaning the current attempt.
	StartedTime *time.Time `protobuf:"bytes,13,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	// Queries that should be executed after applying the history in this task. Responses should be
	// attached to `RespondWorkflowTaskCompletedRequest::query_results`
	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

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

func (*PollWorkflowTaskQueueResponse) GetStartedEventId

func (m *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetStartedTime

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

func (*PollWorkflowTaskQueueResponse) GetTaskToken

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecution

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowType

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

func (*PollWorkflowTaskQueueResponse) GoString

func (this *PollWorkflowTaskQueueResponse) GoString() string

func (*PollWorkflowTaskQueueResponse) Marshal

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

func (*PollWorkflowTaskQueueResponse) MarshalTo

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

func (*PollWorkflowTaskQueueResponse) MarshalToSizedBuffer

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

func (*PollWorkflowTaskQueueResponse) ProtoMessage

func (*PollWorkflowTaskQueueResponse) ProtoMessage()

func (*PollWorkflowTaskQueueResponse) Reset

func (m *PollWorkflowTaskQueueResponse) Reset()

func (*PollWorkflowTaskQueueResponse) Size

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

func (*PollWorkflowTaskQueueResponse) String

func (this *PollWorkflowTaskQueueResponse) String() string

func (*PollWorkflowTaskQueueResponse) Unmarshal

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

func (*PollWorkflowTaskQueueResponse) XXX_DiscardUnknown

func (m *PollWorkflowTaskQueueResponse) XXX_DiscardUnknown()

func (*PollWorkflowTaskQueueResponse) XXX_Marshal

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

func (*PollWorkflowTaskQueueResponse) XXX_Merge

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

func (*PollWorkflowTaskQueueResponse) XXX_Size

func (m *PollWorkflowTaskQueueResponse) XXX_Size() int

func (*PollWorkflowTaskQueueResponse) XXX_Unmarshal

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

type QueryWorkflowRequest

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

func (*QueryWorkflowRequest) Descriptor

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

func (*QueryWorkflowRequest) Equal

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

func (*QueryWorkflowRequest) GetExecution

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

func (*QueryWorkflowRequest) GetNamespace

func (m *QueryWorkflowRequest) GetNamespace() string

func (*QueryWorkflowRequest) GetQuery

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

func (*QueryWorkflowRequest) GetQueryRejectCondition

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

func (*QueryWorkflowRequest) GoString

func (this *QueryWorkflowRequest) GoString() string

func (*QueryWorkflowRequest) Marshal

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

func (*QueryWorkflowRequest) MarshalTo

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

func (*QueryWorkflowRequest) MarshalToSizedBuffer

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

func (*QueryWorkflowRequest) ProtoMessage

func (*QueryWorkflowRequest) ProtoMessage()

func (*QueryWorkflowRequest) Reset

func (m *QueryWorkflowRequest) Reset()

func (*QueryWorkflowRequest) Size

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

func (*QueryWorkflowRequest) String

func (this *QueryWorkflowRequest) String() string

func (*QueryWorkflowRequest) Unmarshal

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

func (*QueryWorkflowRequest) XXX_DiscardUnknown

func (m *QueryWorkflowRequest) XXX_DiscardUnknown()

func (*QueryWorkflowRequest) XXX_Marshal

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

func (*QueryWorkflowRequest) XXX_Merge

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

func (*QueryWorkflowRequest) XXX_Size

func (m *QueryWorkflowRequest) XXX_Size() int

func (*QueryWorkflowRequest) XXX_Unmarshal

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

type QueryWorkflowResponse

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

func (*QueryWorkflowResponse) Descriptor

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

func (*QueryWorkflowResponse) Equal

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

func (*QueryWorkflowResponse) GetQueryRejected

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

func (*QueryWorkflowResponse) GetQueryResult

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

func (*QueryWorkflowResponse) GoString

func (this *QueryWorkflowResponse) GoString() string

func (*QueryWorkflowResponse) Marshal

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

func (*QueryWorkflowResponse) MarshalTo

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

func (*QueryWorkflowResponse) MarshalToSizedBuffer

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

func (*QueryWorkflowResponse) ProtoMessage

func (*QueryWorkflowResponse) ProtoMessage()

func (*QueryWorkflowResponse) Reset

func (m *QueryWorkflowResponse) Reset()

func (*QueryWorkflowResponse) Size

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

func (*QueryWorkflowResponse) String

func (this *QueryWorkflowResponse) String() string

func (*QueryWorkflowResponse) Unmarshal

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

func (*QueryWorkflowResponse) XXX_DiscardUnknown

func (m *QueryWorkflowResponse) XXX_DiscardUnknown()

func (*QueryWorkflowResponse) XXX_Marshal

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

func (*QueryWorkflowResponse) XXX_Merge

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

func (*QueryWorkflowResponse) XXX_Size

func (m *QueryWorkflowResponse) XXX_Size() int

func (*QueryWorkflowResponse) XXX_Unmarshal

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

type RecordActivityTaskHeartbeatByIdRequest

type RecordActivityTaskHeartbeatByIdRequest struct {
	// Namespace of the workflow which scheduled this activity
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Id of the workflow which scheduled this activity
	WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Run Id of the workflow which scheduled this activity
	RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Id of the activity we're heartbeating
	ActivityId string `protobuf:"bytes,4,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	// Arbitrary data, of which the most recent call is kept, to store for this activity
	Details *v13.Payloads `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	// The identity of the worker/client
	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 {
	// Will be set to true if the activity has been asked to cancel itself. The SDK should then
	// notify the activity of cancellation if it is still running.
	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 {
	// The task token as received in `PollActivityTaskQueueResponse`
	TaskToken []byte `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// Arbitrary data, of which the most recent call is kept, to store for this activity
	Details *v13.Payloads `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// The identity of the worker/client
	Identity  string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,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) GetNamespace

func (m *RecordActivityTaskHeartbeatRequest) GetNamespace() 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 {
	// Will be set to true if the activity has been asked to cancel itself. The SDK should then
	// notify the activity of cancellation if it is still running.
	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 {
	Namespace                        string                         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,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) GetNamespace

func (m *RegisterNamespaceRequest) GetNamespace() string

func (*RegisterNamespaceRequest) GetOwnerEmail

func (m *RegisterNamespaceRequest) GetOwnerEmail() string

func (*RegisterNamespaceRequest) GetSecurityToken

func (m *RegisterNamespaceRequest) GetSecurityToken() string

func (*RegisterNamespaceRequest) GetVisibilityArchivalState

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

func (*RegisterNamespaceRequest) GetVisibilityArchivalUri

func (m *RegisterNamespaceRequest) GetVisibilityArchivalUri() string

func (*RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriod

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

func (*RegisterNamespaceRequest) GoString

func (this *RegisterNamespaceRequest) GoString() string

func (*RegisterNamespaceRequest) Marshal

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

func (*RegisterNamespaceRequest) MarshalTo

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

func (*RegisterNamespaceRequest) MarshalToSizedBuffer

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

func (*RegisterNamespaceRequest) ProtoMessage

func (*RegisterNamespaceRequest) ProtoMessage()

func (*RegisterNamespaceRequest) Reset

func (m *RegisterNamespaceRequest) Reset()

func (*RegisterNamespaceRequest) Size

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

func (*RegisterNamespaceRequest) String

func (this *RegisterNamespaceRequest) String() string

func (*RegisterNamespaceRequest) Unmarshal

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

func (*RegisterNamespaceRequest) XXX_DiscardUnknown

func (m *RegisterNamespaceRequest) XXX_DiscardUnknown()

func (*RegisterNamespaceRequest) XXX_Marshal

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

func (*RegisterNamespaceRequest) XXX_Merge

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

func (*RegisterNamespaceRequest) XXX_Size

func (m *RegisterNamespaceRequest) XXX_Size() int

func (*RegisterNamespaceRequest) XXX_Unmarshal

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

type RegisterNamespaceResponse

type RegisterNamespaceResponse struct {
}

func (*RegisterNamespaceResponse) Descriptor

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

func (*RegisterNamespaceResponse) Equal

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

func (*RegisterNamespaceResponse) GoString

func (this *RegisterNamespaceResponse) GoString() string

func (*RegisterNamespaceResponse) Marshal

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

func (*RegisterNamespaceResponse) MarshalTo

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

func (*RegisterNamespaceResponse) MarshalToSizedBuffer

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

func (*RegisterNamespaceResponse) ProtoMessage

func (*RegisterNamespaceResponse) ProtoMessage()

func (*RegisterNamespaceResponse) Reset

func (m *RegisterNamespaceResponse) Reset()

func (*RegisterNamespaceResponse) Size

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

func (*RegisterNamespaceResponse) String

func (this *RegisterNamespaceResponse) String() string

func (*RegisterNamespaceResponse) Unmarshal

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

func (*RegisterNamespaceResponse) XXX_DiscardUnknown

func (m *RegisterNamespaceResponse) XXX_DiscardUnknown()

func (*RegisterNamespaceResponse) XXX_Marshal

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

func (*RegisterNamespaceResponse) XXX_Merge

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

func (*RegisterNamespaceResponse) XXX_Size

func (m *RegisterNamespaceResponse) XXX_Size() int

func (*RegisterNamespaceResponse) XXX_Unmarshal

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

type RequestCancelWorkflowExecutionRequest

type RequestCancelWorkflowExecutionRequest struct {
	Namespace         string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	// The identity of the worker/client
	Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// Used to de-dupe cancellation requests
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// If set, this call will error if the most recent (if no run id is set on
	// `workflow_execution`), or specified (if it is) workflow execution is not part of the same
	// execution chain as this id.
	FirstExecutionRunId string `protobuf:"bytes,5,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
}

func (*RequestCancelWorkflowExecutionRequest) Descriptor

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

func (*RequestCancelWorkflowExecutionRequest) Equal

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

func (*RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunId

func (m *RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunId() string

func (*RequestCancelWorkflowExecutionRequest) GetIdentity

func (*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"`
	// The id of a `WORKFLOW_TASK_COMPLETED`,`WORKFLOW_TASK_TIMED_OUT`, `WORKFLOW_TASK_FAILED`, or
	// `WORKFLOW_TASK_STARTED` event to reset to.
	WorkflowTaskFinishEventId int64 `` /* 143-byte string literal not displayed */
	// Used to de-dupe reset requests
	RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Should be removed. Appears unused.
	ResetReapplyType v11.ResetReapplyType `` /* 156-byte string literal not displayed */
}

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) GetResetReapplyType added in v0.8.0

func (m *ResetWorkflowExecutionRequest) GetResetReapplyType() v11.ResetReapplyType

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 of the workflow which scheduled this activity
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Id of the workflow which scheduled this activity
	WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Run Id of the workflow which scheduled this activity
	RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Id of the activity to confirm is cancelled
	ActivityId string `protobuf:"bytes,4,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	// Serialized additional information to attach to the cancellation
	Details *v13.Payloads `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	// The identity of the worker/client
	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 {
	// The task token as received in `PollActivityTaskQueueResponse`
	TaskToken []byte `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// Serialized additional information to attach to the cancellation
	Details *v13.Payloads `protobuf:"bytes,2,opt,name=details,proto3" json:"details,omitempty"`
	// The identity of the worker/client
	Identity  string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,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) GetNamespace

func (m *RespondActivityTaskCanceledRequest) GetNamespace() 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 of the workflow which scheduled this activity
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Id of the workflow which scheduled this activity
	WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Run Id of the workflow which scheduled this activity
	RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Id of the activity to complete
	ActivityId string `protobuf:"bytes,4,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	// The serialized result of activity execution
	Result *v13.Payloads `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	// The identity of the worker/client
	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 {
	// The task token as received in `PollActivityTaskQueueResponse`
	TaskToken []byte `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// The result of successfully executing the activity
	Result *v13.Payloads `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// The identity of the worker/client
	Identity  string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*RespondActivityTaskCompletedRequest) Descriptor

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

func (*RespondActivityTaskCompletedRequest) Equal

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

func (*RespondActivityTaskCompletedRequest) GetIdentity

func (*RespondActivityTaskCompletedRequest) GetNamespace

func (m *RespondActivityTaskCompletedRequest) GetNamespace() string

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 of the workflow which scheduled this activity
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Id of the workflow which scheduled this activity
	WorkflowId string `protobuf:"bytes,2,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// Run Id of the workflow which scheduled this activity
	RunId string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Id of the activity to fail
	ActivityId string `protobuf:"bytes,4,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	// Detailed failure information
	Failure *v18.Failure `protobuf:"bytes,5,opt,name=failure,proto3" json:"failure,omitempty"`
	// The identity of the worker/client
	Identity string `protobuf:"bytes,6,opt,name=identity,proto3" json:"identity,omitempty"`
	// Additional details to be stored as last activity heartbeat
	LastHeartbeatDetails *v13.Payloads `protobuf:"bytes,7,opt,name=last_heartbeat_details,json=lastHeartbeatDetails,proto3" json:"last_heartbeat_details,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) GetLastHeartbeatDetails added in v0.8.0

func (m *RespondActivityTaskFailedByIdRequest) GetLastHeartbeatDetails() *v13.Payloads

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 {
	// Server validation failures could include
	// last_heartbeat_details payload is too large, request failure is too large
	Failures []*v18.Failure `protobuf:"bytes,1,rep,name=failures,proto3" json:"failures,omitempty"`
}

func (*RespondActivityTaskFailedByIdResponse) Descriptor

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

func (*RespondActivityTaskFailedByIdResponse) Equal

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

func (*RespondActivityTaskFailedByIdResponse) GetFailures added in v0.8.0

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 {
	// The task token as received in `PollActivityTaskQueueResponse`
	TaskToken []byte `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// Detailed failure information
	Failure *v18.Failure `protobuf:"bytes,2,opt,name=failure,proto3" json:"failure,omitempty"`
	// The identity of the worker/client
	Identity  string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Additional details to be stored as last activity heartbeat
	LastHeartbeatDetails *v13.Payloads `protobuf:"bytes,5,opt,name=last_heartbeat_details,json=lastHeartbeatDetails,proto3" json:"last_heartbeat_details,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) GetLastHeartbeatDetails added in v0.8.0

func (m *RespondActivityTaskFailedRequest) GetLastHeartbeatDetails() *v13.Payloads

func (*RespondActivityTaskFailedRequest) GetNamespace

func (m *RespondActivityTaskFailedRequest) GetNamespace() 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 {
	// Server validation failures could include
	// last_heartbeat_details payload is too large, request failure is too large
	Failures []*v18.Failure `protobuf:"bytes,1,rep,name=failures,proto3" json:"failures,omitempty"`
}

func (*RespondActivityTaskFailedResponse) Descriptor

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

func (*RespondActivityTaskFailedResponse) Equal

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

func (*RespondActivityTaskFailedResponse) GetFailures added in v0.8.0

func (m *RespondActivityTaskFailedResponse) GetFailures() []*v18.Failure

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"`
	Namespace     string              `protobuf:"bytes,6,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

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

func (m *RespondQueryTaskCompletedRequest) GetNamespace() string

func (*RespondQueryTaskCompletedRequest) GetQueryResult

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

func (*RespondQueryTaskCompletedRequest) GetTaskToken

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

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 {
	// The task token as received in `PollWorkflowTaskQueueResponse`
	TaskToken []byte `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// A list of commands generated when driving the workflow code in response to the new task
	Commands []*v17.Command `protobuf:"bytes,2,rep,name=commands,proto3" json:"commands,omitempty"`
	// The identity of the worker/client
	Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// May be set by workers to indicate that the worker desires future tasks to be provided with
	// incremental history on a sticky queue.
	StickyAttributes *v14.StickyExecutionAttributes `protobuf:"bytes,4,opt,name=sticky_attributes,json=stickyAttributes,proto3" json:"sticky_attributes,omitempty"`
	// If set, the worker wishes to immediately receive the next workflow task as a response to
	// this completion. This can save on polling round-trips.
	ReturnNewWorkflowTask bool `` /* 129-byte string literal not displayed */
	// Can be used to *force* creation of a new workflow task, even if no commands have resolved or
	// one would not otherwise have been generated. This is used when the worker knows it is doing
	// something useful, but cannot complete it within the workflow task timeout. Local activities
	// which run for longer than the task timeout being the prime example.
	ForceCreateNewWorkflowTask bool `` /* 146-byte string literal not displayed */
	// Worker process' unique binary id
	BinaryChecksum string `protobuf:"bytes,7,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
	// Responses to the `queries` field in the task being responded to
	QueryResults map[string]*v16.WorkflowQueryResult `` /* 185-byte string literal not displayed */
	Namespace    string                              `protobuf:"bytes,9,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

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

func (m *RespondWorkflowTaskCompletedRequest) GetNamespace() string

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 {
	// See `RespondWorkflowTaskCompletedResponse::return_new_workflow_task`
	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 {
	// The task token as received in `PollWorkflowTaskQueueResponse`
	TaskToken []byte `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// Why did the task fail? It's important to note that many of the variants in this enum cannot
	// apply to worker responses. See the type's doc for more.
	Cause v11.WorkflowTaskFailedCause `protobuf:"varint,2,opt,name=cause,proto3,enum=temporal.api.enums.v1.WorkflowTaskFailedCause" json:"cause,omitempty"`
	// Failure details
	Failure *v18.Failure `protobuf:"bytes,3,opt,name=failure,proto3" json:"failure,omitempty"`
	// The identity of the worker/client
	Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// Worker process' unique binary id
	BinaryChecksum string `protobuf:"bytes,5,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
	Namespace      string `protobuf:"bytes,6,opt,name=namespace,proto3" json:"namespace,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) GetNamespace

func (m *RespondWorkflowTaskFailedRequest) GetNamespace() 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"`
	// The task queue to start this workflow on, if it will be started
	TaskQueue *v14.TaskQueue `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Serialized arguments to the workflow. These are passed as arguments to the workflow function.
	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 */
	// The identity of the worker/client
	Identity string `protobuf:"bytes,9,opt,name=identity,proto3" json:"identity,omitempty"`
	// Used to de-dupe signal w/ start requests
	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 */
	// The workflow author-defined name of the signal to send to the workflow
	SignalName string `protobuf:"bytes,12,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	// Serialized value(s) to provide with the signal
	SignalInput *v13.Payloads `protobuf:"bytes,13,opt,name=signal_input,json=signalInput,proto3" json:"signal_input,omitempty"`
	// Deprecated
	Control string `protobuf:"bytes,14,opt,name=control,proto3" json:"control,omitempty"`
	// Retry policy for the workflow Default: WORKFLOW_ID_REUSE_POLICY_ALLOW_DUPLICATE.
	RetryPolicy *v13.RetryPolicy `protobuf:"bytes,15,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// See https://docs.temporal.io/docs/content/what-is-a-temporal-cron-job/
	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

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

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowId

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout

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

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout

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"`
	// The workflow author-defined name of the signal to send to the workflow
	SignalName string `protobuf:"bytes,3,opt,name=signal_name,json=signalName,proto3" json:"signal_name,omitempty"`
	// Serialized value(s) to provide with the signal
	Input *v13.Payloads `protobuf:"bytes,4,opt,name=input,proto3" json:"input,omitempty"`
	// The identity of the worker/client
	Identity string `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
	// Used to de-dupe sent signals
	RequestId string `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Deprecated
	Control string `protobuf:"bytes,7,opt,name=control,proto3" json:"control,omitempty"`
	// Headers that are passed with the signal to the processing workflow.
	// These can include things like auth or tracing tokens.
	Header *v13.Header `protobuf:"bytes,8,opt,name=header,proto3" json:"header,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) GetHeader added in v0.8.0

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

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"`
	// Serialized arguments to the workflow. These are passed as arguments to the workflow function.
	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 */
	// The identity of the client who initiated this request
	Identity string `protobuf:"bytes,9,opt,name=identity,proto3" json:"identity,omitempty"`
	// A unique identifier for this start request. Typically UUIDv4.
	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 */
	// The retry policy for the workflow. Will never exceed `workflow_execution_timeout`.
	RetryPolicy *v13.RetryPolicy `protobuf:"bytes,12,opt,name=retry_policy,json=retryPolicy,proto3" json:"retry_policy,omitempty"`
	// See https://docs.temporal.io/docs/content/what-is-a-temporal-cron-job/
	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

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

func (*StartWorkflowExecutionRequest) GetWorkflowId

func (m *StartWorkflowExecutionRequest) GetWorkflowId() string

func (*StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy

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

func (*StartWorkflowExecutionRequest) GetWorkflowRunTimeout

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

func (*StartWorkflowExecutionRequest) GetWorkflowTaskTimeout

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

func (*StartWorkflowExecutionRequest) GetWorkflowType

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

func (*StartWorkflowExecutionRequest) GoString

func (this *StartWorkflowExecutionRequest) GoString() string

func (*StartWorkflowExecutionRequest) Marshal

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

func (*StartWorkflowExecutionRequest) MarshalTo

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

func (*StartWorkflowExecutionRequest) MarshalToSizedBuffer

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

func (*StartWorkflowExecutionRequest) ProtoMessage

func (*StartWorkflowExecutionRequest) ProtoMessage()

func (*StartWorkflowExecutionRequest) Reset

func (m *StartWorkflowExecutionRequest) Reset()

func (*StartWorkflowExecutionRequest) Size

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

func (*StartWorkflowExecutionRequest) String

func (this *StartWorkflowExecutionRequest) String() string

func (*StartWorkflowExecutionRequest) Unmarshal

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

func (*StartWorkflowExecutionRequest) XXX_DiscardUnknown

func (m *StartWorkflowExecutionRequest) XXX_DiscardUnknown()

func (*StartWorkflowExecutionRequest) XXX_Marshal

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

func (*StartWorkflowExecutionRequest) XXX_Merge

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

func (*StartWorkflowExecutionRequest) XXX_Size

func (m *StartWorkflowExecutionRequest) XXX_Size() int

func (*StartWorkflowExecutionRequest) XXX_Unmarshal

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

type StartWorkflowExecutionResponse

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

func (*StartWorkflowExecutionResponse) Descriptor

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

func (*StartWorkflowExecutionResponse) Equal

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

func (*StartWorkflowExecutionResponse) GetRunId

func (m *StartWorkflowExecutionResponse) GetRunId() string

func (*StartWorkflowExecutionResponse) GoString

func (this *StartWorkflowExecutionResponse) GoString() string

func (*StartWorkflowExecutionResponse) Marshal

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

func (*StartWorkflowExecutionResponse) MarshalTo

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

func (*StartWorkflowExecutionResponse) MarshalToSizedBuffer

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

func (*StartWorkflowExecutionResponse) ProtoMessage

func (*StartWorkflowExecutionResponse) ProtoMessage()

func (*StartWorkflowExecutionResponse) Reset

func (m *StartWorkflowExecutionResponse) Reset()

func (*StartWorkflowExecutionResponse) Size

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

func (*StartWorkflowExecutionResponse) String

func (this *StartWorkflowExecutionResponse) String() string

func (*StartWorkflowExecutionResponse) Unmarshal

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

func (*StartWorkflowExecutionResponse) XXX_DiscardUnknown

func (m *StartWorkflowExecutionResponse) XXX_DiscardUnknown()

func (*StartWorkflowExecutionResponse) XXX_Marshal

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

func (*StartWorkflowExecutionResponse) XXX_Merge

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

func (*StartWorkflowExecutionResponse) XXX_Size

func (m *StartWorkflowExecutionResponse) XXX_Size() int

func (*StartWorkflowExecutionResponse) XXX_Unmarshal

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

type TerminateWorkflowExecutionRequest

type TerminateWorkflowExecutionRequest struct {
	Namespace         string                 `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkflowExecution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	Reason            string                 `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// Serialized additional information to attach to the termination event
	Details *v13.Payloads `protobuf:"bytes,4,opt,name=details,proto3" json:"details,omitempty"`
	// The identity of the worker/client
	Identity string `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
	// If set, this call will error if the most recent (if no run id is set on
	// `workflow_execution`), or specified (if it is) workflow execution is not part of the same
	// execution chain as this id.
	FirstExecutionRunId string `protobuf:"bytes,6,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
}

func (*TerminateWorkflowExecutionRequest) Descriptor

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

func (*TerminateWorkflowExecutionRequest) Equal

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

func (*TerminateWorkflowExecutionRequest) GetDetails

func (*TerminateWorkflowExecutionRequest) GetFirstExecutionRunId

func (m *TerminateWorkflowExecutionRequest) GetFirstExecutionRunId() string

func (*TerminateWorkflowExecutionRequest) GetIdentity

func (m *TerminateWorkflowExecutionRequest) GetIdentity() string

func (*TerminateWorkflowExecutionRequest) GetNamespace

func (m *TerminateWorkflowExecutionRequest) GetNamespace() string

func (*TerminateWorkflowExecutionRequest) GetReason

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

func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistory

func (*UnimplementedWorkflowServiceServer) GetWorkflowExecutionHistoryReverse added in v0.8.0

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 {
	Namespace         string                         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,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"`
	// promote local namespace to global namespace. Ignored if namespace is already global namespace.
	PromoteNamespace bool `protobuf:"varint,7,opt,name=promote_namespace,json=promoteNamespace,proto3" json:"promote_namespace,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) GetNamespace

func (m *UpdateNamespaceRequest) GetNamespace() string

func (*UpdateNamespaceRequest) GetPromoteNamespace added in v0.8.0

func (m *UpdateNamespaceRequest) GetPromoteNamespace() bool

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.
	//
	// A Namespace is a top level entity within Temporal, and is used as a container for resources
	// like workflow executions, task queues, etc. A Namespace acts as a sandbox and provides
	// isolation for all resources within the namespace. All resources belongs to exactly one
	// namespace.
	RegisterNamespace(ctx context.Context, in *RegisterNamespaceRequest, opts ...grpc.CallOption) (*RegisterNamespaceResponse, error)
	// DescribeNamespace returns the information and configuration for a registered namespace.
	DescribeNamespace(ctx context.Context, in *DescribeNamespaceRequest, opts ...grpc.CallOption) (*DescribeNamespaceResponse, error)
	// ListNamespaces returns the information and configuration for all namespaces.
	ListNamespaces(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)
	// UpdateNamespace is used to update the information and configuration of a registered
	// namespace.
	//
	// (-- 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(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace is used to update the 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.
	// Deprecated.
	DeprecateNamespace(ctx context.Context, in *DeprecateNamespaceRequest, opts ...grpc.CallOption) (*DeprecateNamespaceResponse, error)
	// StartWorkflowExecution starts a new workflow execution.
	//
	// It will create the execution with a `WORKFLOW_EXECUTION_STARTED` event in its history and
	// also schedule the first workflow task. Returns `WorkflowExecutionAlreadyStarted`, if an
	// instance already exists with same workflow id.
	StartWorkflowExecution(ctx context.Context, in *StartWorkflowExecutionRequest, opts ...grpc.CallOption) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution. Fails with
	// `NotFound` if the specified workflow execution is unknown to the service.
	GetWorkflowExecutionHistory(ctx context.Context, in *GetWorkflowExecutionHistoryRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionHistoryResponse, error)
	// GetWorkflowExecutionHistoryReverse returns the history of specified workflow execution in reverse
	// order (starting from last event). Fails with`NotFound` if the specified workflow execution is
	// unknown to the service.
	GetWorkflowExecutionHistoryReverse(ctx context.Context, in *GetWorkflowExecutionHistoryReverseRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionHistoryReverseResponse, error)
	// PollWorkflowTaskQueue is called by workers to make progress on workflows.
	//
	// A WorkflowTask is dispatched to callers for active workflow executions with pending workflow
	// tasks. The worker is expected to call `RespondWorkflowTaskCompleted` when it is done
	// processing the task. The service will create a `WorkflowTaskStarted` event in the history for
	// this task before handing it to the worker.
	PollWorkflowTaskQueue(ctx context.Context, in *PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*PollWorkflowTaskQueueResponse, error)
	// RespondWorkflowTaskCompleted is called by workers to successfully complete workflow tasks
	// they received from `PollWorkflowTaskQueue`.
	//
	// Completing a WorkflowTask will write a `WORKFLOW_TASK_COMPLETED` event to the workflow's
	// history, along with events corresponding to whatever commands the SDK generated while
	// executing the task (ex timer started, activity task scheduled, etc).
	RespondWorkflowTaskCompleted(ctx context.Context, in *RespondWorkflowTaskCompletedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by workers to indicate the processing of a workflow task
	// failed.
	//
	// This results in a `WORKFLOW_TASK_FAILED` event written to the history, and a new workflow
	// task will be scheduled. This API can be used to report unhandled failures resulting from
	// applying the workflow task.
	//
	// 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 workers to process activity tasks from a specific task
	// queue.
	//
	// The worker is expected to call one of the `RespondActivityTaskXXX` methods when it is done
	// processing the task.
	//
	// An activity task is dispatched whenever a `SCHEDULE_ACTIVITY_TASK` command is produced during
	// workflow execution. An in memory `ACTIVITY_TASK_STARTED` event is written to mutable state
	// before the task is dispatched to the worker. The started event, and the final event
	// (`ACTIVITY_TASK_COMPLETED` / `ACTIVITY_TASK_FAILED` / `ACTIVITY_TASK_TIMED_OUT`) will both be
	// written permanently to Workflow execution history when Activity is finished. This is done to
	// avoid writing many events in the case of a failure/retry loop.
	PollActivityTaskQueue(ctx context.Context, in *PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*PollActivityTaskQueueResponse, error)
	// RecordActivityTaskHeartbeat is optionally called by workers while they execute activities.
	//
	// If worker fails to heartbeat within the `heartbeat_timeout` interval for the activity task,
	// then it will be marked as timed out and an `ACTIVITY_TASK_TIMED_OUT` event will be written to
	// the workflow history. Calling `RecordActivityTaskHeartbeat` will fail with `NotFound` in
	// such situations, in that event, the SDK should request cancellation of the activity.
	RecordActivityTaskHeartbeat(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatResponse, error)
	// See `RecordActivityTaskHeartbeat`. This version allows clients to record heartbeats by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	RecordActivityTaskHeartbeatById(ctx context.Context, in *RecordActivityTaskHeartbeatByIdRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatByIdResponse, error)
	// RespondActivityTaskCompleted is called by workers when they successfully complete an activity
	// task.
	//
	// This results in a new `ACTIVITY_TASK_COMPLETED` event being written to the workflow history
	// and a new workflow task created for the workflow. Fails with `NotFound` if the task token is
	// no longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskCompleted(ctx context.Context, in *RespondActivityTaskCompletedRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedResponse, error)
	// See `RecordActivityTaskCompleted`. This version allows clients to record completions by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskCompletedById(ctx context.Context, in *RespondActivityTaskCompletedByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedByIdResponse, error)
	// RespondActivityTaskFailed is called by workers when processing an activity task fails.
	//
	// This results in a new `ACTIVITY_TASK_FAILED` event being written to the workflow history and
	// a new workflow task created for the workflow. Fails with `NotFound` if the task token is no
	// longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskFailed(ctx context.Context, in *RespondActivityTaskFailedRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedResponse, error)
	// See `RecordActivityTaskFailed`. This version allows clients to record failures by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskFailedById(ctx context.Context, in *RespondActivityTaskFailedByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedByIdResponse, error)
	// RespondActivityTaskFailed is called by workers when processing an activity task fails.
	//
	// This results in a new `ACTIVITY_TASK_CANCELED` event being written to the workflow history
	// and a new workflow task created for the workflow. Fails with `NotFound` if the task token is
	// no longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskCanceled(ctx context.Context, in *RespondActivityTaskCanceledRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledResponse, error)
	// See `RecordActivityTaskCanceled`. This version allows clients to record failures by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskCanceledById(ctx context.Context, in *RespondActivityTaskCanceledByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledByIdResponse, error)
	// RequestCancelWorkflowExecution is called by workers when they want to request cancellation of
	// a workflow execution.
	//
	// This result in a new `WORKFLOW_EXECUTION_CANCEL_REQUESTED` event being written to the
	// workflow history and a new workflow task created for the workflow. Fails with `NotFound` if
	// the workflow is already completed or doesn't exist.
	RequestCancelWorkflowExecution(ctx context.Context, in *RequestCancelWorkflowExecutionRequest, opts ...grpc.CallOption) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal to a running workflow execution.
	//
	// This results in a `WORKFLOW_EXECUTION_SIGNALED` 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)
	// SignalWithStartWorkflowExecution is used to ensure a signal is sent to a workflow, even if
	// it isn't yet started.
	//
	// If the workflow is running, a `WORKFLOW_EXECUTION_SIGNALED` event is recorded in the history
	// and a workflow task is generated.
	//
	// If the workflow is not running or not found, then the workflow is created with
	// `WORKFLOW_EXECUTION_STARTED` and `WORKFLOW_EXECUTION_SIGNALED` events in its history, and a
	// workflow task is generated.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "With" is used to indicate combined operation. --)
	SignalWithStartWorkflowExecution(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution will reset an existing workflow execution to a specified
	// `WORKFLOW_TASK_COMPLETED` event (exclusive). It will immediately terminate the current
	// execution instance.
	// TODO: Does exclusive here mean *just* the completed event, or also WFT started? Otherwise the task is doomed to time out?
	ResetWorkflowExecution(ctx context.Context, in *ResetWorkflowExecutionRequest, opts ...grpc.CallOption) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording a
	// `WORKFLOW_EXECUTION_TERMINATED` 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 workers to complete queries which were delivered on
	// the `query` (not `queries`) field of a `PollWorkflowTaskQueueResponse`.
	//
	// Completing the query will unblock the corresponding client call to `QueryWorkflow` and return
	// the query result a response.
	RespondQueryTaskCompleted(ctx context.Context, in *RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskQueue resets the sticky task queue related information in the mutable state of
	// a given workflow. This is prudent for workers to perform if a workflow has been paged out of
	// their cache.
	//
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	ResetStickyTaskQueue(ctx context.Context, in *ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*ResetStickyTaskQueueResponse, error)
	// QueryWorkflow requests a query be executed 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.
	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)
	// GetSystemInfo returns information about the system.
	GetSystemInfo(ctx context.Context, in *GetSystemInfoRequest, opts ...grpc.CallOption) (*GetSystemInfoResponse, 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.
	//
	// A Namespace is a top level entity within Temporal, and is used as a container for resources
	// like workflow executions, task queues, etc. A Namespace acts as a sandbox and provides
	// isolation for all resources within the namespace. All resources belongs to exactly one
	// namespace.
	RegisterNamespace(context.Context, *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)
	// DescribeNamespace returns the information and configuration for a registered namespace.
	DescribeNamespace(context.Context, *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)
	// ListNamespaces returns the information and configuration for all namespaces.
	ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
	// UpdateNamespace is used to update the information and configuration of a registered
	// namespace.
	//
	// (-- 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(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace is used to update the 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.
	// Deprecated.
	DeprecateNamespace(context.Context, *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)
	// StartWorkflowExecution starts a new workflow execution.
	//
	// It will create the execution with a `WORKFLOW_EXECUTION_STARTED` event in its history and
	// also schedule the first workflow task. Returns `WorkflowExecutionAlreadyStarted`, if an
	// instance already exists with same workflow id.
	StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution. Fails with
	// `NotFound` if the specified workflow execution is unknown to the service.
	GetWorkflowExecutionHistory(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)
	// GetWorkflowExecutionHistoryReverse returns the history of specified workflow execution in reverse
	// order (starting from last event). Fails with`NotFound` if the specified workflow execution is
	// unknown to the service.
	GetWorkflowExecutionHistoryReverse(context.Context, *GetWorkflowExecutionHistoryReverseRequest) (*GetWorkflowExecutionHistoryReverseResponse, error)
	// PollWorkflowTaskQueue is called by workers to make progress on workflows.
	//
	// A WorkflowTask is dispatched to callers for active workflow executions with pending workflow
	// tasks. The worker is expected to call `RespondWorkflowTaskCompleted` when it is done
	// processing the task. The service will create a `WorkflowTaskStarted` event in the history for
	// this task before handing it to the worker.
	PollWorkflowTaskQueue(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)
	// RespondWorkflowTaskCompleted is called by workers to successfully complete workflow tasks
	// they received from `PollWorkflowTaskQueue`.
	//
	// Completing a WorkflowTask will write a `WORKFLOW_TASK_COMPLETED` event to the workflow's
	// history, along with events corresponding to whatever commands the SDK generated while
	// executing the task (ex timer started, activity task scheduled, etc).
	RespondWorkflowTaskCompleted(context.Context, *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by workers to indicate the processing of a workflow task
	// failed.
	//
	// This results in a `WORKFLOW_TASK_FAILED` event written to the history, and a new workflow
	// task will be scheduled. This API can be used to report unhandled failures resulting from
	// applying the workflow task.
	//
	// 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 workers to process activity tasks from a specific task
	// queue.
	//
	// The worker is expected to call one of the `RespondActivityTaskXXX` methods when it is done
	// processing the task.
	//
	// An activity task is dispatched whenever a `SCHEDULE_ACTIVITY_TASK` command is produced during
	// workflow execution. An in memory `ACTIVITY_TASK_STARTED` event is written to mutable state
	// before the task is dispatched to the worker. The started event, and the final event
	// (`ACTIVITY_TASK_COMPLETED` / `ACTIVITY_TASK_FAILED` / `ACTIVITY_TASK_TIMED_OUT`) will both be
	// written permanently to Workflow execution history when Activity is finished. This is done to
	// avoid writing many events in the case of a failure/retry loop.
	PollActivityTaskQueue(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)
	// RecordActivityTaskHeartbeat is optionally called by workers while they execute activities.
	//
	// If worker fails to heartbeat within the `heartbeat_timeout` interval for the activity task,
	// then it will be marked as timed out and an `ACTIVITY_TASK_TIMED_OUT` event will be written to
	// the workflow history. Calling `RecordActivityTaskHeartbeat` will fail with `NotFound` in
	// such situations, in that event, the SDK should request cancellation of the activity.
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)
	// See `RecordActivityTaskHeartbeat`. This version allows clients to record heartbeats by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	RecordActivityTaskHeartbeatById(context.Context, *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)
	// RespondActivityTaskCompleted is called by workers when they successfully complete an activity
	// task.
	//
	// This results in a new `ACTIVITY_TASK_COMPLETED` event being written to the workflow history
	// and a new workflow task created for the workflow. Fails with `NotFound` if the task token is
	// no longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)
	// See `RecordActivityTaskCompleted`. This version allows clients to record completions by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskCompletedById(context.Context, *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)
	// RespondActivityTaskFailed is called by workers when processing an activity task fails.
	//
	// This results in a new `ACTIVITY_TASK_FAILED` event being written to the workflow history and
	// a new workflow task created for the workflow. Fails with `NotFound` if the task token is no
	// longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)
	// See `RecordActivityTaskFailed`. This version allows clients to record failures by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskFailedById(context.Context, *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)
	// RespondActivityTaskFailed is called by workers when processing an activity task fails.
	//
	// This results in a new `ACTIVITY_TASK_CANCELED` event being written to the workflow history
	// and a new workflow task created for the workflow. Fails with `NotFound` if the task token is
	// no longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)
	// See `RecordActivityTaskCanceled`. This version allows clients to record failures by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskCanceledById(context.Context, *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)
	// RequestCancelWorkflowExecution is called by workers when they want to request cancellation of
	// a workflow execution.
	//
	// This result in a new `WORKFLOW_EXECUTION_CANCEL_REQUESTED` event being written to the
	// workflow history and a new workflow task created for the workflow. Fails with `NotFound` if
	// the workflow is already completed or doesn't exist.
	RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal to a running workflow execution.
	//
	// This results in a `WORKFLOW_EXECUTION_SIGNALED` event recorded in the history and a workflow
	// task being created for the execution.
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)
	// SignalWithStartWorkflowExecution is used to ensure a signal is sent to a workflow, even if
	// it isn't yet started.
	//
	// If the workflow is running, a `WORKFLOW_EXECUTION_SIGNALED` event is recorded in the history
	// and a workflow task is generated.
	//
	// If the workflow is not running or not found, then the workflow is created with
	// `WORKFLOW_EXECUTION_STARTED` and `WORKFLOW_EXECUTION_SIGNALED` events in its history, and a
	// workflow task is generated.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//     aip.dev/not-precedent: "With" is used to indicate combined operation. --)
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution will reset an existing workflow execution to a specified
	// `WORKFLOW_TASK_COMPLETED` event (exclusive). It will immediately terminate the current
	// execution instance.
	// TODO: Does exclusive here mean *just* the completed event, or also WFT started? Otherwise the task is doomed to time out?
	ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording a
	// `WORKFLOW_EXECUTION_TERMINATED` 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 workers to complete queries which were delivered on
	// the `query` (not `queries`) field of a `PollWorkflowTaskQueueResponse`.
	//
	// Completing the query will unblock the corresponding client call to `QueryWorkflow` and return
	// the query result a response.
	RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskQueue resets the sticky task queue related information in the mutable state of
	// a given workflow. This is prudent for workers to perform if a workflow has been paged out of
	// their cache.
	//
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	ResetStickyTaskQueue(context.Context, *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)
	// QueryWorkflow requests a query be executed 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.
	DescribeTaskQueue(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	// GetSystemInfo returns information about the system.
	GetSystemInfo(context.Context, *GetSystemInfoRequest) (*GetSystemInfoResponse, 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