workflowservicev1

package
v1.33.0-20230419173345... Latest Latest
Warning

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

 Go to latest Published: unknown License: MIT Imports: 24 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_temporal_api_workflowservice_v1_request_response_proto protoreflect.FileDescriptor
View Source 
var File_temporal_api_workflowservice_v1_service_proto protoreflect.FileDescriptor

Functions

This section is empty.

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"`
	// contains filtered or unexported fields
}

func (*CountWorkflowExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use CountWorkflowExecutionsRequest.ProtoReflect.Descriptor instead.

func (*CountWorkflowExecutionsRequest) GetNamespace 

func (x *CountWorkflowExecutionsRequest) GetNamespace() string

func (*CountWorkflowExecutionsRequest) GetQuery 

func (x *CountWorkflowExecutionsRequest) GetQuery() string

func (*CountWorkflowExecutionsRequest) ProtoMessage 

func (*CountWorkflowExecutionsRequest) ProtoMessage()

func (*CountWorkflowExecutionsRequest) ProtoReflect 

func (x *CountWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

func (*CountWorkflowExecutionsRequest) Reset 

func (x *CountWorkflowExecutionsRequest) Reset()

func (*CountWorkflowExecutionsRequest) String 

func (x *CountWorkflowExecutionsRequest) String() string

type CountWorkflowExecutionsResponse 

type CountWorkflowExecutionsResponse struct {
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*CountWorkflowExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use CountWorkflowExecutionsResponse.ProtoReflect.Descriptor instead.

func (*CountWorkflowExecutionsResponse) GetCount 

func (x *CountWorkflowExecutionsResponse) GetCount() int64

func (*CountWorkflowExecutionsResponse) ProtoMessage 

func (*CountWorkflowExecutionsResponse) ProtoMessage()

func (*CountWorkflowExecutionsResponse) ProtoReflect 

func (x *CountWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

func (*CountWorkflowExecutionsResponse) Reset 

func (x *CountWorkflowExecutionsResponse) Reset()

func (*CountWorkflowExecutionsResponse) String 

func (x *CountWorkflowExecutionsResponse) String() string

type CreateScheduleRequest 

type CreateScheduleRequest struct {

	// The namespace the schedule should be created in.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The id of the new schedule.
	ScheduleId string `protobuf:"bytes,2,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// The schedule spec, policies, action, and initial state.
	Schedule *v114.Schedule `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// Optional initial patch (e.g. to run the action once immediately).
	InitialPatch *v114.SchedulePatch `protobuf:"bytes,4,opt,name=initial_patch,json=initialPatch,proto3" json:"initial_patch,omitempty"`
	// The identity of the client who initiated this request.
	Identity string `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
	// A unique identifier for this create request for idempotence. Typically UUIDv4.
	RequestId string `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Memo and search attributes to attach to the schedule itself.
	Memo             *v13.Memo             `protobuf:"bytes,7,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v13.SearchAttributes `protobuf:"bytes,8,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0133::request-parent-required=disabled 

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

(-- api-linter: core::0133::request-unknown-fields=disabled 

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

(-- api-linter: core::0133::request-resource-behavior=disabled 

aip.dev/not-precedent: field_behavior annotation not available in our gogo fork --)

(-- api-linter: core::0203::optional=disabled 

aip.dev/not-precedent: field_behavior annotation not available in our gogo fork --)

func (*CreateScheduleRequest) Descriptor deprecated 

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

Deprecated: Use CreateScheduleRequest.ProtoReflect.Descriptor instead.

func (*CreateScheduleRequest) GetIdentity 

func (x *CreateScheduleRequest) GetIdentity() string

func (*CreateScheduleRequest) GetInitialPatch 

func (x *CreateScheduleRequest) GetInitialPatch() *v114.SchedulePatch

func (*CreateScheduleRequest) GetMemo 

func (x *CreateScheduleRequest) GetMemo() *v13.Memo

func (*CreateScheduleRequest) GetNamespace 

func (x *CreateScheduleRequest) GetNamespace() string

func (*CreateScheduleRequest) GetRequestId 

func (x *CreateScheduleRequest) GetRequestId() string

func (*CreateScheduleRequest) GetSchedule 

func (x *CreateScheduleRequest) GetSchedule() *v114.Schedule

func (*CreateScheduleRequest) GetScheduleId 

func (x *CreateScheduleRequest) GetScheduleId() string

func (*CreateScheduleRequest) GetSearchAttributes 

func (x *CreateScheduleRequest) GetSearchAttributes() *v13.SearchAttributes

func (*CreateScheduleRequest) ProtoMessage 

func (*CreateScheduleRequest) ProtoMessage()

func (*CreateScheduleRequest) ProtoReflect 

func (x *CreateScheduleRequest) ProtoReflect() protoreflect.Message

func (*CreateScheduleRequest) Reset 

func (x *CreateScheduleRequest) Reset()

func (*CreateScheduleRequest) String 

func (x *CreateScheduleRequest) String() string

type CreateScheduleResponse 

type CreateScheduleResponse struct {
	ConflictToken []byte `protobuf:"bytes,1,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateScheduleResponse) Descriptor deprecated 

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

Deprecated: Use CreateScheduleResponse.ProtoReflect.Descriptor instead.

func (*CreateScheduleResponse) GetConflictToken 

func (x *CreateScheduleResponse) GetConflictToken() []byte

func (*CreateScheduleResponse) ProtoMessage 

func (*CreateScheduleResponse) ProtoMessage()

func (*CreateScheduleResponse) ProtoReflect 

func (x *CreateScheduleResponse) ProtoReflect() protoreflect.Message

func (*CreateScheduleResponse) Reset 

func (x *CreateScheduleResponse) Reset()

func (*CreateScheduleResponse) String 

func (x *CreateScheduleResponse) String() string

type DeleteScheduleRequest 

type DeleteScheduleRequest struct {

	// The namespace of the schedule to delete.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The id of the schedule to delete.
	ScheduleId string `protobuf:"bytes,2,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// The identity of the client who initiated this request.
	Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0135::request-name-required=disabled 

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

(-- api-linter: core::0135::request-unknown-fields=disabled 

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

func (*DeleteScheduleRequest) Descriptor deprecated 

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

Deprecated: Use DeleteScheduleRequest.ProtoReflect.Descriptor instead.

func (*DeleteScheduleRequest) GetIdentity 

func (x *DeleteScheduleRequest) GetIdentity() string

func (*DeleteScheduleRequest) GetNamespace 

func (x *DeleteScheduleRequest) GetNamespace() string

func (*DeleteScheduleRequest) GetScheduleId 

func (x *DeleteScheduleRequest) GetScheduleId() string

func (*DeleteScheduleRequest) ProtoMessage 

func (*DeleteScheduleRequest) ProtoMessage()

func (*DeleteScheduleRequest) ProtoReflect 

func (x *DeleteScheduleRequest) ProtoReflect() protoreflect.Message

func (*DeleteScheduleRequest) Reset 

func (x *DeleteScheduleRequest) Reset()

func (*DeleteScheduleRequest) String 

func (x *DeleteScheduleRequest) String() string

type DeleteScheduleResponse 

type DeleteScheduleResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteScheduleResponse) Descriptor deprecated 

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

Deprecated: Use DeleteScheduleResponse.ProtoReflect.Descriptor instead.

func (*DeleteScheduleResponse) ProtoMessage 

func (*DeleteScheduleResponse) ProtoMessage()

func (*DeleteScheduleResponse) ProtoReflect 

func (x *DeleteScheduleResponse) ProtoReflect() protoreflect.Message

func (*DeleteScheduleResponse) Reset 

func (x *DeleteScheduleResponse) Reset()

func (*DeleteScheduleResponse) String 

func (x *DeleteScheduleResponse) String() string

type DeleteWorkflowExecutionRequest 

type DeleteWorkflowExecutionRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Workflow Execution to delete. If run_id is not specified, the latest one is used.
	WorkflowExecution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0135::request-unknown-fields=disabled 

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

(-- api-linter: core::0135::request-name-required=disabled 

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

func (*DeleteWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowExecutionRequest) GetNamespace 

func (x *DeleteWorkflowExecutionRequest) GetNamespace() string

func (*DeleteWorkflowExecutionRequest) GetWorkflowExecution 

func (x *DeleteWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

func (*DeleteWorkflowExecutionRequest) ProtoMessage 

func (*DeleteWorkflowExecutionRequest) ProtoMessage()

func (*DeleteWorkflowExecutionRequest) ProtoReflect 

func (x *DeleteWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*DeleteWorkflowExecutionRequest) Reset 

func (x *DeleteWorkflowExecutionRequest) Reset()

func (*DeleteWorkflowExecutionRequest) String 

func (x *DeleteWorkflowExecutionRequest) String() string

type DeleteWorkflowExecutionResponse 

type DeleteWorkflowExecutionResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowExecutionResponse) ProtoMessage 

func (*DeleteWorkflowExecutionResponse) ProtoMessage()

func (*DeleteWorkflowExecutionResponse) ProtoReflect 

func (x *DeleteWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*DeleteWorkflowExecutionResponse) Reset 

func (x *DeleteWorkflowExecutionResponse) Reset()

func (*DeleteWorkflowExecutionResponse) String 

func (x *DeleteWorkflowExecutionResponse) String() string

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"`
	// contains filtered or unexported fields
}

Deprecated.

func (*DeprecateNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use DeprecateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DeprecateNamespaceRequest) GetNamespace 

func (x *DeprecateNamespaceRequest) GetNamespace() string

func (*DeprecateNamespaceRequest) GetSecurityToken 

func (x *DeprecateNamespaceRequest) GetSecurityToken() string

func (*DeprecateNamespaceRequest) ProtoMessage 

func (*DeprecateNamespaceRequest) ProtoMessage()

func (*DeprecateNamespaceRequest) ProtoReflect 

func (x *DeprecateNamespaceRequest) ProtoReflect() protoreflect.Message

func (*DeprecateNamespaceRequest) Reset 

func (x *DeprecateNamespaceRequest) Reset()

func (*DeprecateNamespaceRequest) String 

func (x *DeprecateNamespaceRequest) String() string

type DeprecateNamespaceResponse 

type DeprecateNamespaceResponse struct {
	// contains filtered or unexported fields
}

Deprecated.

func (*DeprecateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use DeprecateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DeprecateNamespaceResponse) ProtoMessage 

func (*DeprecateNamespaceResponse) ProtoMessage()

func (*DeprecateNamespaceResponse) ProtoReflect 

func (x *DeprecateNamespaceResponse) ProtoReflect() protoreflect.Message

func (*DeprecateNamespaceResponse) Reset 

func (x *DeprecateNamespaceResponse) Reset()

func (*DeprecateNamespaceResponse) String 

func (x *DeprecateNamespaceResponse) String() string

type DescribeBatchOperationRequest 

type DescribeBatchOperationRequest struct {

	// Namespace that contains the batch operation
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Batch job id
	JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeBatchOperationRequest) Descriptor deprecated 

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

Deprecated: Use DescribeBatchOperationRequest.ProtoReflect.Descriptor instead.

func (*DescribeBatchOperationRequest) GetJobId 

func (x *DescribeBatchOperationRequest) GetJobId() string

func (*DescribeBatchOperationRequest) GetNamespace 

func (x *DescribeBatchOperationRequest) GetNamespace() string

func (*DescribeBatchOperationRequest) ProtoMessage 

func (*DescribeBatchOperationRequest) ProtoMessage()

func (*DescribeBatchOperationRequest) ProtoReflect 

func (x *DescribeBatchOperationRequest) ProtoReflect() protoreflect.Message

func (*DescribeBatchOperationRequest) Reset 

func (x *DescribeBatchOperationRequest) Reset()

func (*DescribeBatchOperationRequest) String 

func (x *DescribeBatchOperationRequest) String() string

type DescribeBatchOperationResponse 

type DescribeBatchOperationResponse struct {

	// Batch operation type
	OperationType v11.BatchOperationType `` /* 147-byte string literal not displayed */
	// Batch job ID
	JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Batch operation state
	State v11.BatchOperationState `protobuf:"varint,3,opt,name=state,proto3,enum=temporal.api.enums.v1.BatchOperationState" json:"state,omitempty"`
	// Batch operation start time
	StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Batch operation close time
	CloseTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=close_time,json=closeTime,proto3" json:"close_time,omitempty"`
	// Total operation count
	TotalOperationCount int64 `protobuf:"varint,6,opt,name=total_operation_count,json=totalOperationCount,proto3" json:"total_operation_count,omitempty"`
	// Complete operation count
	CompleteOperationCount int64 `` /* 130-byte string literal not displayed */
	// Failure operation count
	FailureOperationCount int64 `` /* 127-byte string literal not displayed */
	// Identity indicates the operator identity
	Identity string `protobuf:"bytes,9,opt,name=identity,proto3" json:"identity,omitempty"`
	// Reason indicates the reason to stop a operation
	Reason string `protobuf:"bytes,10,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeBatchOperationResponse) Descriptor deprecated 

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

Deprecated: Use DescribeBatchOperationResponse.ProtoReflect.Descriptor instead.

func (*DescribeBatchOperationResponse) GetCloseTime 

func (x *DescribeBatchOperationResponse) GetCloseTime() *timestamppb.Timestamp

func (*DescribeBatchOperationResponse) GetCompleteOperationCount 

func (x *DescribeBatchOperationResponse) GetCompleteOperationCount() int64

func (*DescribeBatchOperationResponse) GetFailureOperationCount 

func (x *DescribeBatchOperationResponse) GetFailureOperationCount() int64

func (*DescribeBatchOperationResponse) GetIdentity 

func (x *DescribeBatchOperationResponse) GetIdentity() string

func (*DescribeBatchOperationResponse) GetJobId 

func (x *DescribeBatchOperationResponse) GetJobId() string

func (*DescribeBatchOperationResponse) GetOperationType 

func (x *DescribeBatchOperationResponse) GetOperationType() v11.BatchOperationType

func (*DescribeBatchOperationResponse) GetReason 

func (x *DescribeBatchOperationResponse) GetReason() string

func (*DescribeBatchOperationResponse) GetStartTime 

func (x *DescribeBatchOperationResponse) GetStartTime() *timestamppb.Timestamp

func (*DescribeBatchOperationResponse) GetState 

func (x *DescribeBatchOperationResponse) GetState() v11.BatchOperationState

func (*DescribeBatchOperationResponse) GetTotalOperationCount 

func (x *DescribeBatchOperationResponse) GetTotalOperationCount() int64

func (*DescribeBatchOperationResponse) ProtoMessage 

func (*DescribeBatchOperationResponse) ProtoMessage()

func (*DescribeBatchOperationResponse) ProtoReflect 

func (x *DescribeBatchOperationResponse) ProtoReflect() protoreflect.Message

func (*DescribeBatchOperationResponse) Reset 

func (x *DescribeBatchOperationResponse) Reset()

func (*DescribeBatchOperationResponse) String 

func (x *DescribeBatchOperationResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*DescribeNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use DescribeNamespaceRequest.ProtoReflect.Descriptor instead.

func (*DescribeNamespaceRequest) GetId 

func (x *DescribeNamespaceRequest) GetId() string

func (*DescribeNamespaceRequest) GetNamespace 

func (x *DescribeNamespaceRequest) GetNamespace() string

func (*DescribeNamespaceRequest) ProtoMessage 

func (*DescribeNamespaceRequest) ProtoMessage()

func (*DescribeNamespaceRequest) ProtoReflect 

func (x *DescribeNamespaceRequest) ProtoReflect() protoreflect.Message

func (*DescribeNamespaceRequest) Reset 

func (x *DescribeNamespaceRequest) Reset()

func (*DescribeNamespaceRequest) String 

func (x *DescribeNamespaceRequest) String() string

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"`
	// Contains the historical state of failover_versions for the cluster, truncated to contain only the last N
	// states to ensure that the list does not grow unbounded.
	FailoverHistory []*v1.FailoverStatus `protobuf:"bytes,6,rep,name=failover_history,json=failoverHistory,proto3" json:"failover_history,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use DescribeNamespaceResponse.ProtoReflect.Descriptor instead.

func (*DescribeNamespaceResponse) GetConfig 

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

func (*DescribeNamespaceResponse) GetFailoverHistory 

func (x *DescribeNamespaceResponse) GetFailoverHistory() []*v1.FailoverStatus

func (*DescribeNamespaceResponse) GetFailoverVersion 

func (x *DescribeNamespaceResponse) GetFailoverVersion() int64

func (*DescribeNamespaceResponse) GetIsGlobalNamespace 

func (x *DescribeNamespaceResponse) GetIsGlobalNamespace() bool

func (*DescribeNamespaceResponse) GetNamespaceInfo 

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

func (*DescribeNamespaceResponse) GetReplicationConfig 

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

func (*DescribeNamespaceResponse) ProtoMessage 

func (*DescribeNamespaceResponse) ProtoMessage()

func (*DescribeNamespaceResponse) ProtoReflect 

func (x *DescribeNamespaceResponse) ProtoReflect() protoreflect.Message

func (*DescribeNamespaceResponse) Reset 

func (x *DescribeNamespaceResponse) Reset()

func (*DescribeNamespaceResponse) String 

func (x *DescribeNamespaceResponse) String() string

type DescribeScheduleRequest 

type DescribeScheduleRequest struct {

	// The namespace of the schedule to describe.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The id of the schedule to describe.
	ScheduleId string `protobuf:"bytes,2,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeScheduleRequest) Descriptor deprecated 

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

Deprecated: Use DescribeScheduleRequest.ProtoReflect.Descriptor instead.

func (*DescribeScheduleRequest) GetNamespace 

func (x *DescribeScheduleRequest) GetNamespace() string

func (*DescribeScheduleRequest) GetScheduleId 

func (x *DescribeScheduleRequest) GetScheduleId() string

func (*DescribeScheduleRequest) ProtoMessage 

func (*DescribeScheduleRequest) ProtoMessage()

func (*DescribeScheduleRequest) ProtoReflect 

func (x *DescribeScheduleRequest) ProtoReflect() protoreflect.Message

func (*DescribeScheduleRequest) Reset 

func (x *DescribeScheduleRequest) Reset()

func (*DescribeScheduleRequest) String 

func (x *DescribeScheduleRequest) String() string

type DescribeScheduleResponse 

type DescribeScheduleResponse struct {

	// The complete current schedule details. This may not match the schedule as
	// created because:
	//   - some types of schedule specs may get compiled into others (e.g.
	//     CronString into StructuredCalendarSpec)
	//   - some unspecified fields may be replaced by defaults
	//   - some fields in the state are modified automatically
	//   - the schedule may have been modified by UpdateSchedule or PatchSchedule
	Schedule *v114.Schedule `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// Extra schedule state info.
	Info *v114.ScheduleInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// The memo and search attributes that the schedule was created with.
	Memo             *v13.Memo             `protobuf:"bytes,3,opt,name=memo,proto3" json:"memo,omitempty"`
	SearchAttributes *v13.SearchAttributes `protobuf:"bytes,4,opt,name=search_attributes,json=searchAttributes,proto3" json:"search_attributes,omitempty"`
	// This value can be passed back to UpdateSchedule to ensure that the
	// schedule was not modified between a Describe and an Update, which could
	// lead to lost updates and other confusion.
	ConflictToken []byte `protobuf:"bytes,5,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeScheduleResponse) Descriptor deprecated 

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

Deprecated: Use DescribeScheduleResponse.ProtoReflect.Descriptor instead.

func (*DescribeScheduleResponse) GetConflictToken 

func (x *DescribeScheduleResponse) GetConflictToken() []byte

func (*DescribeScheduleResponse) GetInfo 

func (x *DescribeScheduleResponse) GetInfo() *v114.ScheduleInfo

func (*DescribeScheduleResponse) GetMemo 

func (x *DescribeScheduleResponse) GetMemo() *v13.Memo

func (*DescribeScheduleResponse) GetSchedule 

func (x *DescribeScheduleResponse) GetSchedule() *v114.Schedule

func (*DescribeScheduleResponse) GetSearchAttributes 

func (x *DescribeScheduleResponse) GetSearchAttributes() *v13.SearchAttributes

func (*DescribeScheduleResponse) ProtoMessage 

func (*DescribeScheduleResponse) ProtoMessage()

func (*DescribeScheduleResponse) ProtoReflect 

func (x *DescribeScheduleResponse) ProtoReflect() protoreflect.Message

func (*DescribeScheduleResponse) Reset 

func (x *DescribeScheduleResponse) Reset()

func (*DescribeScheduleResponse) String 

func (x *DescribeScheduleResponse) String() string

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 */
	// contains filtered or unexported fields
}

func (*DescribeTaskQueueRequest) Descriptor deprecated 

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

Deprecated: Use DescribeTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*DescribeTaskQueueRequest) GetIncludeTaskQueueStatus 

func (x *DescribeTaskQueueRequest) GetIncludeTaskQueueStatus() bool

func (*DescribeTaskQueueRequest) GetNamespace 

func (x *DescribeTaskQueueRequest) GetNamespace() string

func (*DescribeTaskQueueRequest) GetTaskQueue 

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

func (*DescribeTaskQueueRequest) GetTaskQueueType 

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

func (*DescribeTaskQueueRequest) ProtoMessage 

func (*DescribeTaskQueueRequest) ProtoMessage()

func (*DescribeTaskQueueRequest) ProtoReflect 

func (x *DescribeTaskQueueRequest) ProtoReflect() protoreflect.Message

func (*DescribeTaskQueueRequest) Reset 

func (x *DescribeTaskQueueRequest) Reset()

func (*DescribeTaskQueueRequest) String 

func (x *DescribeTaskQueueRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*DescribeTaskQueueResponse) Descriptor deprecated 

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

Deprecated: Use DescribeTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*DescribeTaskQueueResponse) GetPollers 

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

func (*DescribeTaskQueueResponse) GetTaskQueueStatus 

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

func (*DescribeTaskQueueResponse) ProtoMessage 

func (*DescribeTaskQueueResponse) ProtoMessage()

func (*DescribeTaskQueueResponse) ProtoReflect 

func (x *DescribeTaskQueueResponse) ProtoReflect() protoreflect.Message

func (*DescribeTaskQueueResponse) Reset 

func (x *DescribeTaskQueueResponse) Reset()

func (*DescribeTaskQueueResponse) String 

func (x *DescribeTaskQueueResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*DescribeWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use DescribeWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*DescribeWorkflowExecutionRequest) GetExecution 

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

func (*DescribeWorkflowExecutionRequest) GetNamespace 

func (x *DescribeWorkflowExecutionRequest) GetNamespace() string

func (*DescribeWorkflowExecutionRequest) ProtoMessage 

func (*DescribeWorkflowExecutionRequest) ProtoMessage()

func (*DescribeWorkflowExecutionRequest) ProtoReflect 

func (x *DescribeWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*DescribeWorkflowExecutionRequest) Reset 

func (x *DescribeWorkflowExecutionRequest) Reset()

func (*DescribeWorkflowExecutionRequest) String 

func (x *DescribeWorkflowExecutionRequest) String() string

type DescribeWorkflowExecutionResponse 

type DescribeWorkflowExecutionResponse struct {
	ExecutionConfig       *v112.WorkflowExecutionConfig     `protobuf:"bytes,1,opt,name=execution_config,json=executionConfig,proto3" json:"execution_config,omitempty"`
	WorkflowExecutionInfo *v112.WorkflowExecutionInfo       `` /* 126-byte string literal not displayed */
	PendingActivities     []*v112.PendingActivityInfo       `protobuf:"bytes,3,rep,name=pending_activities,json=pendingActivities,proto3" json:"pending_activities,omitempty"`
	PendingChildren       []*v112.PendingChildExecutionInfo `protobuf:"bytes,4,rep,name=pending_children,json=pendingChildren,proto3" json:"pending_children,omitempty"`
	PendingWorkflowTask   *v112.PendingWorkflowTaskInfo     `protobuf:"bytes,5,opt,name=pending_workflow_task,json=pendingWorkflowTask,proto3" json:"pending_workflow_task,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use DescribeWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*DescribeWorkflowExecutionResponse) GetExecutionConfig 

func (x *DescribeWorkflowExecutionResponse) GetExecutionConfig() *v112.WorkflowExecutionConfig

func (*DescribeWorkflowExecutionResponse) GetPendingActivities 

func (x *DescribeWorkflowExecutionResponse) GetPendingActivities() []*v112.PendingActivityInfo

func (*DescribeWorkflowExecutionResponse) GetPendingChildren 

func (x *DescribeWorkflowExecutionResponse) GetPendingChildren() []*v112.PendingChildExecutionInfo

func (*DescribeWorkflowExecutionResponse) GetPendingWorkflowTask 

func (x *DescribeWorkflowExecutionResponse) GetPendingWorkflowTask() *v112.PendingWorkflowTaskInfo

func (*DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo 

func (x *DescribeWorkflowExecutionResponse) GetWorkflowExecutionInfo() *v112.WorkflowExecutionInfo

func (*DescribeWorkflowExecutionResponse) ProtoMessage 

func (*DescribeWorkflowExecutionResponse) ProtoMessage()

func (*DescribeWorkflowExecutionResponse) ProtoReflect 

func (x *DescribeWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*DescribeWorkflowExecutionResponse) Reset 

func (x *DescribeWorkflowExecutionResponse) Reset()

func (*DescribeWorkflowExecutionResponse) String 

func (x *DescribeWorkflowExecutionResponse) String() string

type GetClusterInfoRequest 

type GetClusterInfoRequest struct {
	// contains filtered or unexported fields
}

func (*GetClusterInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetClusterInfoRequest.ProtoReflect.Descriptor instead.

func (*GetClusterInfoRequest) ProtoMessage 

func (*GetClusterInfoRequest) ProtoMessage()

func (*GetClusterInfoRequest) ProtoReflect 

func (x *GetClusterInfoRequest) ProtoReflect() protoreflect.Message

func (*GetClusterInfoRequest) Reset 

func (x *GetClusterInfoRequest) Reset()

func (*GetClusterInfoRequest) String 

func (x *GetClusterInfoRequest) String() string

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       *v113.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"`
	// contains filtered or unexported fields
}

GetClusterInfoResponse contains information about Temporal cluster.

func (*GetClusterInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetClusterInfoResponse.ProtoReflect.Descriptor instead.

func (*GetClusterInfoResponse) GetClusterId 

func (x *GetClusterInfoResponse) GetClusterId() string

func (*GetClusterInfoResponse) GetClusterName 

func (x *GetClusterInfoResponse) GetClusterName() string

func (*GetClusterInfoResponse) GetHistoryShardCount 

func (x *GetClusterInfoResponse) GetHistoryShardCount() int32

func (*GetClusterInfoResponse) GetPersistenceStore 

func (x *GetClusterInfoResponse) GetPersistenceStore() string

func (*GetClusterInfoResponse) GetServerVersion 

func (x *GetClusterInfoResponse) GetServerVersion() string

func (*GetClusterInfoResponse) GetSupportedClients 

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

func (*GetClusterInfoResponse) GetVersionInfo 

func (x *GetClusterInfoResponse) GetVersionInfo() *v113.VersionInfo

func (*GetClusterInfoResponse) GetVisibilityStore 

func (x *GetClusterInfoResponse) GetVisibilityStore() string

func (*GetClusterInfoResponse) ProtoMessage 

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) ProtoReflect 

func (x *GetClusterInfoResponse) ProtoReflect() protoreflect.Message

func (*GetClusterInfoResponse) Reset 

func (x *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) String 

func (x *GetClusterInfoResponse) String() string

type GetSearchAttributesRequest 

type GetSearchAttributesRequest struct {
	// contains filtered or unexported fields
}

func (*GetSearchAttributesRequest) Descriptor deprecated 

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

Deprecated: Use GetSearchAttributesRequest.ProtoReflect.Descriptor instead.

func (*GetSearchAttributesRequest) ProtoMessage 

func (*GetSearchAttributesRequest) ProtoMessage()

func (*GetSearchAttributesRequest) ProtoReflect 

func (x *GetSearchAttributesRequest) ProtoReflect() protoreflect.Message

func (*GetSearchAttributesRequest) Reset 

func (x *GetSearchAttributesRequest) Reset()

func (*GetSearchAttributesRequest) String 

func (x *GetSearchAttributesRequest) String() string

type GetSearchAttributesResponse 

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

func (*GetSearchAttributesResponse) Descriptor deprecated 

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

Deprecated: Use GetSearchAttributesResponse.ProtoReflect.Descriptor instead.

func (*GetSearchAttributesResponse) GetKeys 

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

func (*GetSearchAttributesResponse) ProtoMessage 

func (*GetSearchAttributesResponse) ProtoMessage()

func (*GetSearchAttributesResponse) ProtoReflect 

func (x *GetSearchAttributesResponse) ProtoReflect() protoreflect.Message

func (*GetSearchAttributesResponse) Reset 

func (x *GetSearchAttributesResponse) Reset()

func (*GetSearchAttributesResponse) String 

func (x *GetSearchAttributesResponse) String() string

type GetSystemInfoRequest 

type GetSystemInfoRequest struct {
	// contains filtered or unexported fields
}

func (*GetSystemInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetSystemInfoRequest.ProtoReflect.Descriptor instead.

func (*GetSystemInfoRequest) ProtoMessage 

func (*GetSystemInfoRequest) ProtoMessage()

func (*GetSystemInfoRequest) ProtoReflect 

func (x *GetSystemInfoRequest) ProtoReflect() protoreflect.Message

func (*GetSystemInfoRequest) Reset 

func (x *GetSystemInfoRequest) Reset()

func (*GetSystemInfoRequest) String 

func (x *GetSystemInfoRequest) String() string

type GetSystemInfoResponse 

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"`
	// contains filtered or unexported fields
}

func (*GetSystemInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetSystemInfoResponse.ProtoReflect.Descriptor instead.

func (*GetSystemInfoResponse) GetCapabilities 

func (x *GetSystemInfoResponse) GetCapabilities() *GetSystemInfoResponse_Capabilities

func (*GetSystemInfoResponse) GetServerVersion 

func (x *GetSystemInfoResponse) GetServerVersion() string

func (*GetSystemInfoResponse) ProtoMessage 

func (*GetSystemInfoResponse) ProtoMessage()

func (*GetSystemInfoResponse) ProtoReflect 

func (x *GetSystemInfoResponse) ProtoReflect() protoreflect.Message

func (*GetSystemInfoResponse) Reset 

func (x *GetSystemInfoResponse) Reset()

func (*GetSystemInfoResponse) String 

func (x *GetSystemInfoResponse) String() string

type GetSystemInfoResponse_Capabilities 

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 */
	// Supports scheduled workflow features.
	SupportsSchedules bool `protobuf:"varint,4,opt,name=supports_schedules,json=supportsSchedules,proto3" json:"supports_schedules,omitempty"`
	// True if server uses protos that include temporal.api.failure.v1.Failure.encoded_attributes
	EncodedFailureAttributes bool `` /* 136-byte string literal not displayed */
	// True if server supports dispatching Workflow and Activity tasks based on a worker's build_id
	// (see:
	// https://github.com/temporalio/proposals/blob/a123af3b559f43db16ea6dd31870bfb754c4dc5e/versioning/worker-versions.md)
	BuildIdBasedVersioning bool `` /* 132-byte string literal not displayed */
	// True if server supports upserting workflow memo
	UpsertMemo bool `protobuf:"varint,7,opt,name=upsert_memo,json=upsertMemo,proto3" json:"upsert_memo,omitempty"`
	// True if server supports eager workflow task dispatching for the StartWorkflowExecution API
	EagerWorkflowStart bool `protobuf:"varint,8,opt,name=eager_workflow_start,json=eagerWorkflowStart,proto3" json:"eager_workflow_start,omitempty"`
	// True if the server knows about the sdk metadata field on WFT completions and will record
	// it in history
	SdkMetadata bool `protobuf:"varint,9,opt,name=sdk_metadata,json=sdkMetadata,proto3" json:"sdk_metadata,omitempty"`
	// contains filtered or unexported fields
}

System capability details.

func (*GetSystemInfoResponse_Capabilities) Descriptor deprecated 

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

Deprecated: Use GetSystemInfoResponse_Capabilities.ProtoReflect.Descriptor instead.

func (*GetSystemInfoResponse_Capabilities) GetActivityFailureIncludeHeartbeat 

func (x *GetSystemInfoResponse_Capabilities) GetActivityFailureIncludeHeartbeat() bool

func (*GetSystemInfoResponse_Capabilities) GetBuildIdBasedVersioning 

func (x *GetSystemInfoResponse_Capabilities) GetBuildIdBasedVersioning() bool

func (*GetSystemInfoResponse_Capabilities) GetEagerWorkflowStart 

func (x *GetSystemInfoResponse_Capabilities) GetEagerWorkflowStart() bool

func (*GetSystemInfoResponse_Capabilities) GetEncodedFailureAttributes 

func (x *GetSystemInfoResponse_Capabilities) GetEncodedFailureAttributes() bool

func (*GetSystemInfoResponse_Capabilities) GetInternalErrorDifferentiation 

func (x *GetSystemInfoResponse_Capabilities) GetInternalErrorDifferentiation() bool

func (*GetSystemInfoResponse_Capabilities) GetSdkMetadata 

func (x *GetSystemInfoResponse_Capabilities) GetSdkMetadata() bool

func (*GetSystemInfoResponse_Capabilities) GetSignalAndQueryHeader 

func (x *GetSystemInfoResponse_Capabilities) GetSignalAndQueryHeader() bool

func (*GetSystemInfoResponse_Capabilities) GetSupportsSchedules 

func (x *GetSystemInfoResponse_Capabilities) GetSupportsSchedules() bool

func (*GetSystemInfoResponse_Capabilities) GetUpsertMemo 

func (x *GetSystemInfoResponse_Capabilities) GetUpsertMemo() bool

func (*GetSystemInfoResponse_Capabilities) ProtoMessage 

func (*GetSystemInfoResponse_Capabilities) ProtoMessage()

func (*GetSystemInfoResponse_Capabilities) ProtoReflect 

func (x *GetSystemInfoResponse_Capabilities) ProtoReflect() protoreflect.Message

func (*GetSystemInfoResponse_Capabilities) Reset 

func (x *GetSystemInfoResponse_Capabilities) Reset()

func (*GetSystemInfoResponse_Capabilities) String 

func (x *GetSystemInfoResponse_Capabilities) String() string

type GetWorkerBuildIdCompatibilityRequest 

type GetWorkerBuildIdCompatibilityRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Must be set, the task queue to interrogate about worker id compatibility.
	TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Limits how many compatible sets will be returned. Specify 1 to only return the current
	// default major version set. 0 returns all sets.
	MaxSets int32 `protobuf:"varint,3,opt,name=max_sets,json=maxSets,proto3" json:"max_sets,omitempty"`
	// If set, the response will include information about worker versions which are ready to be
	// retired.
	IncludeRetirementCandidates bool `` /* 145-byte string literal not displayed */
	// If set, the response will include information about which versions have open workflows, and
	// whether or not there are currently polling workers who are compatible with those versions.
	IncludePollerCompatibility bool `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

func (*GetWorkerBuildIdCompatibilityRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkerBuildIdCompatibilityRequest.ProtoReflect.Descriptor instead.

func (*GetWorkerBuildIdCompatibilityRequest) GetIncludePollerCompatibility 

func (x *GetWorkerBuildIdCompatibilityRequest) GetIncludePollerCompatibility() bool

func (*GetWorkerBuildIdCompatibilityRequest) GetIncludeRetirementCandidates 

func (x *GetWorkerBuildIdCompatibilityRequest) GetIncludeRetirementCandidates() bool

func (*GetWorkerBuildIdCompatibilityRequest) GetMaxSets 

func (x *GetWorkerBuildIdCompatibilityRequest) GetMaxSets() int32

func (*GetWorkerBuildIdCompatibilityRequest) GetNamespace 

func (x *GetWorkerBuildIdCompatibilityRequest) GetNamespace() string

func (*GetWorkerBuildIdCompatibilityRequest) GetTaskQueue 

func (x *GetWorkerBuildIdCompatibilityRequest) GetTaskQueue() string

func (*GetWorkerBuildIdCompatibilityRequest) ProtoMessage 

func (*GetWorkerBuildIdCompatibilityRequest) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityRequest) ProtoReflect 

func (x *GetWorkerBuildIdCompatibilityRequest) ProtoReflect() protoreflect.Message

func (*GetWorkerBuildIdCompatibilityRequest) Reset 

func (x *GetWorkerBuildIdCompatibilityRequest) Reset()

func (*GetWorkerBuildIdCompatibilityRequest) String 

func (x *GetWorkerBuildIdCompatibilityRequest) String() string

type GetWorkerBuildIdCompatibilityResponse 

type GetWorkerBuildIdCompatibilityResponse struct {

	// Major version sets, in order from oldest to newest. The last element of the list will always
	// be the current default major version. IE: New workflows will target the most recent version
	// in that version set.
	//
	// There may be fewer sets returned than exist, if the request chose to limit this response.
	MajorVersionSets []*v14.CompatibleVersionSet `protobuf:"bytes,1,rep,name=major_version_sets,json=majorVersionSets,proto3" json:"major_version_sets,omitempty"`
	// A list of workers who are still live and polling the task queue, but may no longer be needed
	// to make progress on open workflows.
	RetirementCandidates []*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate `protobuf:"bytes,2,rep,name=retirement_candidates,json=retirementCandidates,proto3" json:"retirement_candidates,omitempty"`
	// A list of versions and pollers who are capable of processing tasks at that version (if any)
	// for which there are currently open workflows.
	ActiveVersionsAndPollers []*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GetWorkerBuildIdCompatibilityResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkerBuildIdCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerBuildIdCompatibilityResponse) GetActiveVersionsAndPollers 

func (x *GetWorkerBuildIdCompatibilityResponse) GetActiveVersionsAndPollers() []*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers

func (*GetWorkerBuildIdCompatibilityResponse) GetMajorVersionSets 

func (x *GetWorkerBuildIdCompatibilityResponse) GetMajorVersionSets() []*v14.CompatibleVersionSet

func (*GetWorkerBuildIdCompatibilityResponse) GetRetirementCandidates 

func (x *GetWorkerBuildIdCompatibilityResponse) GetRetirementCandidates() []*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate

func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage 

func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityResponse) ProtoReflect 

func (x *GetWorkerBuildIdCompatibilityResponse) ProtoReflect() protoreflect.Message

func (*GetWorkerBuildIdCompatibilityResponse) Reset 

func (x *GetWorkerBuildIdCompatibilityResponse) Reset()

func (*GetWorkerBuildIdCompatibilityResponse) String 

func (x *GetWorkerBuildIdCompatibilityResponse) String() string

type GetWorkerBuildIdCompatibilityResponse_RetirementCandidate 

type GetWorkerBuildIdCompatibilityResponse_RetirementCandidate struct {

	// The worker build id which is ready for retirement
	BuildId string `protobuf:"bytes,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// If true, there are no open *or* closed workflows, meaning there is no reason at all
	// to keep the worker alive, not even to service queries on closed workflows. If not true,
	// then there are no open workflows, but some closed ones.
	AllWorkflowsAreArchived bool `` /* 135-byte string literal not displayed */
	// Currently polling workers who match the build id ready for retirement
	Pollers []*v14.PollerInfo `protobuf:"bytes,3,rep,name=pollers,proto3" json:"pollers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) Descriptor deprecated 

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

Deprecated: Use GetWorkerBuildIdCompatibilityResponse_RetirementCandidate.ProtoReflect.Descriptor instead.

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) GetAllWorkflowsAreArchived 

func (x *GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) GetAllWorkflowsAreArchived() bool

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) GetBuildId 

func (x *GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) GetBuildId() string

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) GetPollers 

func (x *GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) GetPollers() []*v14.PollerInfo

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) ProtoMessage 

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) ProtoReflect 

func (x *GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) ProtoReflect() protoreflect.Message

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) Reset 

func (x *GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) Reset()

func (*GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) String 

func (x *GetWorkerBuildIdCompatibilityResponse_RetirementCandidate) String() string

type GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers 

type GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers struct {

	// The latest build id which completed a workflow task on some open workflow
	MostRecentBuildId string `protobuf:"bytes,1,opt,name=most_recent_build_id,json=mostRecentBuildId,proto3" json:"most_recent_build_id,omitempty"`
	// Currently polling workers who are compatible with `most_recent_build_id`.
	Pollers []*v14.PollerInfo `protobuf:"bytes,2,rep,name=pollers,proto3" json:"pollers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) Descriptor deprecated 

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

Deprecated: Use GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers.ProtoReflect.Descriptor instead.

func (*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) GetMostRecentBuildId 

func (x *GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) GetMostRecentBuildId() string

func (*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) GetPollers 

func (x *GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) GetPollers() []*v14.PollerInfo

func (*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) ProtoMessage 

func (*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) ProtoReflect 

func (x *GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) ProtoReflect() protoreflect.Message

func (*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) Reset 

func (x *GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) Reset()

func (*GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) String 

func (x *GetWorkerBuildIdCompatibilityResponse_VersionsWithCompatiblePollers) String() string

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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowExecutionHistoryRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowExecutionHistoryRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionHistoryRequest) GetExecution 

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

func (*GetWorkflowExecutionHistoryRequest) GetHistoryEventFilterType 

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

func (*GetWorkflowExecutionHistoryRequest) GetMaximumPageSize 

func (x *GetWorkflowExecutionHistoryRequest) GetMaximumPageSize() int32

func (*GetWorkflowExecutionHistoryRequest) GetNamespace 

func (x *GetWorkflowExecutionHistoryRequest) GetNamespace() string

func (*GetWorkflowExecutionHistoryRequest) GetNextPageToken 

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

func (*GetWorkflowExecutionHistoryRequest) GetSkipArchival 

func (x *GetWorkflowExecutionHistoryRequest) GetSkipArchival() bool

func (*GetWorkflowExecutionHistoryRequest) GetWaitNewEvent 

func (x *GetWorkflowExecutionHistoryRequest) GetWaitNewEvent() bool

func (*GetWorkflowExecutionHistoryRequest) ProtoMessage 

func (*GetWorkflowExecutionHistoryRequest) ProtoMessage()

func (*GetWorkflowExecutionHistoryRequest) ProtoReflect 

func (x *GetWorkflowExecutionHistoryRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowExecutionHistoryRequest) Reset 

func (x *GetWorkflowExecutionHistoryRequest) Reset()

func (*GetWorkflowExecutionHistoryRequest) String 

func (x *GetWorkflowExecutionHistoryRequest) String() string

type GetWorkflowExecutionHistoryResponse 

type GetWorkflowExecutionHistoryResponse struct {
	History *v16.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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowExecutionHistoryResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowExecutionHistoryResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionHistoryResponse) GetArchived 

func (x *GetWorkflowExecutionHistoryResponse) GetArchived() bool

func (*GetWorkflowExecutionHistoryResponse) GetHistory 

func (x *GetWorkflowExecutionHistoryResponse) GetHistory() *v16.History

func (*GetWorkflowExecutionHistoryResponse) GetNextPageToken 

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

func (*GetWorkflowExecutionHistoryResponse) GetRawHistory 

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

func (*GetWorkflowExecutionHistoryResponse) ProtoMessage 

func (*GetWorkflowExecutionHistoryResponse) ProtoMessage()

func (*GetWorkflowExecutionHistoryResponse) ProtoReflect 

func (x *GetWorkflowExecutionHistoryResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowExecutionHistoryResponse) Reset 

func (x *GetWorkflowExecutionHistoryResponse) Reset()

func (*GetWorkflowExecutionHistoryResponse) String 

func (x *GetWorkflowExecutionHistoryResponse) String() string

type GetWorkflowExecutionHistoryReverseRequest 

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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowExecutionHistoryReverseRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowExecutionHistoryReverseRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionHistoryReverseRequest) GetExecution 

func (x *GetWorkflowExecutionHistoryReverseRequest) GetExecution() *v13.WorkflowExecution

func (*GetWorkflowExecutionHistoryReverseRequest) GetMaximumPageSize 

func (x *GetWorkflowExecutionHistoryReverseRequest) GetMaximumPageSize() int32

func (*GetWorkflowExecutionHistoryReverseRequest) GetNamespace 

func (x *GetWorkflowExecutionHistoryReverseRequest) GetNamespace() string

func (*GetWorkflowExecutionHistoryReverseRequest) GetNextPageToken 

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

func (*GetWorkflowExecutionHistoryReverseRequest) ProtoMessage 

func (*GetWorkflowExecutionHistoryReverseRequest) ProtoMessage()

func (*GetWorkflowExecutionHistoryReverseRequest) ProtoReflect 

func (x *GetWorkflowExecutionHistoryReverseRequest) ProtoReflect() protoreflect.Message

func (*GetWorkflowExecutionHistoryReverseRequest) Reset 

func (x *GetWorkflowExecutionHistoryReverseRequest) Reset()

func (*GetWorkflowExecutionHistoryReverseRequest) String 

func (x *GetWorkflowExecutionHistoryReverseRequest) String() string

type GetWorkflowExecutionHistoryReverseResponse 

type GetWorkflowExecutionHistoryReverseResponse struct {
	History *v16.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"`
	// contains filtered or unexported fields
}

func (*GetWorkflowExecutionHistoryReverseResponse) Descriptor deprecated 

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

Deprecated: Use GetWorkflowExecutionHistoryReverseResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionHistoryReverseResponse) GetHistory 

func (x *GetWorkflowExecutionHistoryReverseResponse) GetHistory() *v16.History

func (*GetWorkflowExecutionHistoryReverseResponse) GetNextPageToken 

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

func (*GetWorkflowExecutionHistoryReverseResponse) ProtoMessage 

func (*GetWorkflowExecutionHistoryReverseResponse) ProtoMessage()

func (*GetWorkflowExecutionHistoryReverseResponse) ProtoReflect 

func (x *GetWorkflowExecutionHistoryReverseResponse) ProtoReflect() protoreflect.Message

func (*GetWorkflowExecutionHistoryReverseResponse) Reset 

func (x *GetWorkflowExecutionHistoryReverseResponse) Reset()

func (*GetWorkflowExecutionHistoryReverseResponse) String 

func (x *GetWorkflowExecutionHistoryReverseResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListArchivedWorkflowExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use ListArchivedWorkflowExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ListArchivedWorkflowExecutionsRequest) GetNamespace 

func (x *ListArchivedWorkflowExecutionsRequest) GetNamespace() string

func (*ListArchivedWorkflowExecutionsRequest) GetNextPageToken 

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

func (*ListArchivedWorkflowExecutionsRequest) GetPageSize 

func (x *ListArchivedWorkflowExecutionsRequest) GetPageSize() int32

func (*ListArchivedWorkflowExecutionsRequest) GetQuery 

func (x *ListArchivedWorkflowExecutionsRequest) GetQuery() string

func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage 

func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage()

func (*ListArchivedWorkflowExecutionsRequest) ProtoReflect 

func (x *ListArchivedWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

func (*ListArchivedWorkflowExecutionsRequest) Reset 

func (x *ListArchivedWorkflowExecutionsRequest) Reset()

func (*ListArchivedWorkflowExecutionsRequest) String 

func (x *ListArchivedWorkflowExecutionsRequest) String() string

type ListArchivedWorkflowExecutionsResponse 

type ListArchivedWorkflowExecutionsResponse struct {
	Executions    []*v112.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"`
	// contains filtered or unexported fields
}

func (*ListArchivedWorkflowExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use ListArchivedWorkflowExecutionsResponse.ProtoReflect.Descriptor instead.

func (*ListArchivedWorkflowExecutionsResponse) GetExecutions 

func (x *ListArchivedWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

func (*ListArchivedWorkflowExecutionsResponse) GetNextPageToken 

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

func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage 

func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage()

func (*ListArchivedWorkflowExecutionsResponse) ProtoReflect 

func (x *ListArchivedWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

func (*ListArchivedWorkflowExecutionsResponse) Reset 

func (x *ListArchivedWorkflowExecutionsResponse) Reset()

func (*ListArchivedWorkflowExecutionsResponse) String 

func (x *ListArchivedWorkflowExecutionsResponse) String() string

type ListBatchOperationsRequest 

type ListBatchOperationsRequest struct {

	// Namespace that contains the batch operation
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// List page size
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Next page token
	NextPageToken []byte `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBatchOperationsRequest) Descriptor deprecated 

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

Deprecated: Use ListBatchOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListBatchOperationsRequest) GetNamespace 

func (x *ListBatchOperationsRequest) GetNamespace() string

func (*ListBatchOperationsRequest) GetNextPageToken 

func (x *ListBatchOperationsRequest) GetNextPageToken() []byte

func (*ListBatchOperationsRequest) GetPageSize 

func (x *ListBatchOperationsRequest) GetPageSize() int32

func (*ListBatchOperationsRequest) ProtoMessage 

func (*ListBatchOperationsRequest) ProtoMessage()

func (*ListBatchOperationsRequest) ProtoReflect 

func (x *ListBatchOperationsRequest) ProtoReflect() protoreflect.Message

func (*ListBatchOperationsRequest) Reset 

func (x *ListBatchOperationsRequest) Reset()

func (*ListBatchOperationsRequest) String 

func (x *ListBatchOperationsRequest) String() string

type ListBatchOperationsResponse 

type ListBatchOperationsResponse struct {

	// BatchOperationInfo contains the basic info about batch operation
	OperationInfo []*v116.BatchOperationInfo `protobuf:"bytes,1,rep,name=operation_info,json=operationInfo,proto3" json:"operation_info,omitempty"`
	NextPageToken []byte                     `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBatchOperationsResponse) Descriptor deprecated 

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

Deprecated: Use ListBatchOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListBatchOperationsResponse) GetNextPageToken 

func (x *ListBatchOperationsResponse) GetNextPageToken() []byte

func (*ListBatchOperationsResponse) GetOperationInfo 

func (x *ListBatchOperationsResponse) GetOperationInfo() []*v116.BatchOperationInfo

func (*ListBatchOperationsResponse) ProtoMessage 

func (*ListBatchOperationsResponse) ProtoMessage()

func (*ListBatchOperationsResponse) ProtoReflect 

func (x *ListBatchOperationsResponse) ProtoReflect() protoreflect.Message

func (*ListBatchOperationsResponse) Reset 

func (x *ListBatchOperationsResponse) Reset()

func (*ListBatchOperationsResponse) String 

func (x *ListBatchOperationsResponse) String() string

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 *v111.StartTimeFilter `protobuf:"bytes,4,opt,name=start_time_filter,json=startTimeFilter,proto3" json:"start_time_filter,omitempty"`
	// Types that are assignable to Filters:
	//
	//	*ListClosedWorkflowExecutionsRequest_ExecutionFilter
	//	*ListClosedWorkflowExecutionsRequest_TypeFilter
	//	*ListClosedWorkflowExecutionsRequest_StatusFilter
	Filters isListClosedWorkflowExecutionsRequest_Filters `protobuf_oneof:"filters"`
	// contains filtered or unexported fields
}

func (*ListClosedWorkflowExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use ListClosedWorkflowExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ListClosedWorkflowExecutionsRequest) GetExecutionFilter 

func (x *ListClosedWorkflowExecutionsRequest) GetExecutionFilter() *v111.WorkflowExecutionFilter

func (*ListClosedWorkflowExecutionsRequest) GetFilters 

func (m *ListClosedWorkflowExecutionsRequest) GetFilters() isListClosedWorkflowExecutionsRequest_Filters

func (*ListClosedWorkflowExecutionsRequest) GetMaximumPageSize 

func (x *ListClosedWorkflowExecutionsRequest) GetMaximumPageSize() int32

func (*ListClosedWorkflowExecutionsRequest) GetNamespace 

func (x *ListClosedWorkflowExecutionsRequest) GetNamespace() string

func (*ListClosedWorkflowExecutionsRequest) GetNextPageToken 

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

func (*ListClosedWorkflowExecutionsRequest) GetStartTimeFilter 

func (x *ListClosedWorkflowExecutionsRequest) GetStartTimeFilter() *v111.StartTimeFilter

func (*ListClosedWorkflowExecutionsRequest) GetStatusFilter 

func (x *ListClosedWorkflowExecutionsRequest) GetStatusFilter() *v111.StatusFilter

func (*ListClosedWorkflowExecutionsRequest) GetTypeFilter 

func (x *ListClosedWorkflowExecutionsRequest) GetTypeFilter() *v111.WorkflowTypeFilter

func (*ListClosedWorkflowExecutionsRequest) ProtoMessage 

func (*ListClosedWorkflowExecutionsRequest) ProtoMessage()

func (*ListClosedWorkflowExecutionsRequest) ProtoReflect 

func (x *ListClosedWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

func (*ListClosedWorkflowExecutionsRequest) Reset 

func (x *ListClosedWorkflowExecutionsRequest) Reset()

func (*ListClosedWorkflowExecutionsRequest) String 

func (x *ListClosedWorkflowExecutionsRequest) String() string

type ListClosedWorkflowExecutionsRequest_ExecutionFilter 

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

type ListClosedWorkflowExecutionsRequest_StatusFilter 

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

type ListClosedWorkflowExecutionsRequest_TypeFilter 

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

type ListClosedWorkflowExecutionsResponse 

type ListClosedWorkflowExecutionsResponse struct {
	Executions    []*v112.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"`
	// contains filtered or unexported fields
}

func (*ListClosedWorkflowExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use ListClosedWorkflowExecutionsResponse.ProtoReflect.Descriptor instead.

func (*ListClosedWorkflowExecutionsResponse) GetExecutions 

func (x *ListClosedWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

func (*ListClosedWorkflowExecutionsResponse) GetNextPageToken 

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

func (*ListClosedWorkflowExecutionsResponse) ProtoMessage 

func (*ListClosedWorkflowExecutionsResponse) ProtoMessage()

func (*ListClosedWorkflowExecutionsResponse) ProtoReflect 

func (x *ListClosedWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

func (*ListClosedWorkflowExecutionsResponse) Reset 

func (x *ListClosedWorkflowExecutionsResponse) Reset()

func (*ListClosedWorkflowExecutionsResponse) String 

func (x *ListClosedWorkflowExecutionsResponse) String() string

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"`
	NamespaceFilter *v12.NamespaceFilter `protobuf:"bytes,3,opt,name=namespace_filter,json=namespaceFilter,proto3" json:"namespace_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNamespacesRequest) Descriptor deprecated 

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

Deprecated: Use ListNamespacesRequest.ProtoReflect.Descriptor instead.

func (*ListNamespacesRequest) GetNamespaceFilter 

func (x *ListNamespacesRequest) GetNamespaceFilter() *v12.NamespaceFilter

func (*ListNamespacesRequest) GetNextPageToken 

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

func (*ListNamespacesRequest) GetPageSize 

func (x *ListNamespacesRequest) GetPageSize() int32

func (*ListNamespacesRequest) ProtoMessage 

func (*ListNamespacesRequest) ProtoMessage()

func (*ListNamespacesRequest) ProtoReflect 

func (x *ListNamespacesRequest) ProtoReflect() protoreflect.Message

func (*ListNamespacesRequest) Reset 

func (x *ListNamespacesRequest) Reset()

func (*ListNamespacesRequest) String 

func (x *ListNamespacesRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListNamespacesResponse) Descriptor deprecated 

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

Deprecated: Use ListNamespacesResponse.ProtoReflect.Descriptor instead.

func (*ListNamespacesResponse) GetNamespaces 

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

func (*ListNamespacesResponse) GetNextPageToken 

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

func (*ListNamespacesResponse) ProtoMessage 

func (*ListNamespacesResponse) ProtoMessage()

func (*ListNamespacesResponse) ProtoReflect 

func (x *ListNamespacesResponse) ProtoReflect() protoreflect.Message

func (*ListNamespacesResponse) Reset 

func (x *ListNamespacesResponse) Reset()

func (*ListNamespacesResponse) String 

func (x *ListNamespacesResponse) String() string

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 *v111.StartTimeFilter `protobuf:"bytes,4,opt,name=start_time_filter,json=startTimeFilter,proto3" json:"start_time_filter,omitempty"`
	// Types that are assignable to Filters:
	//
	//	*ListOpenWorkflowExecutionsRequest_ExecutionFilter
	//	*ListOpenWorkflowExecutionsRequest_TypeFilter
	Filters isListOpenWorkflowExecutionsRequest_Filters `protobuf_oneof:"filters"`
	// contains filtered or unexported fields
}

func (*ListOpenWorkflowExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use ListOpenWorkflowExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ListOpenWorkflowExecutionsRequest) GetExecutionFilter 

func (x *ListOpenWorkflowExecutionsRequest) GetExecutionFilter() *v111.WorkflowExecutionFilter

func (*ListOpenWorkflowExecutionsRequest) GetFilters 

func (m *ListOpenWorkflowExecutionsRequest) GetFilters() isListOpenWorkflowExecutionsRequest_Filters

func (*ListOpenWorkflowExecutionsRequest) GetMaximumPageSize 

func (x *ListOpenWorkflowExecutionsRequest) GetMaximumPageSize() int32

func (*ListOpenWorkflowExecutionsRequest) GetNamespace 

func (x *ListOpenWorkflowExecutionsRequest) GetNamespace() string

func (*ListOpenWorkflowExecutionsRequest) GetNextPageToken 

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

func (*ListOpenWorkflowExecutionsRequest) GetStartTimeFilter 

func (x *ListOpenWorkflowExecutionsRequest) GetStartTimeFilter() *v111.StartTimeFilter

func (*ListOpenWorkflowExecutionsRequest) GetTypeFilter 

func (x *ListOpenWorkflowExecutionsRequest) GetTypeFilter() *v111.WorkflowTypeFilter

func (*ListOpenWorkflowExecutionsRequest) ProtoMessage 

func (*ListOpenWorkflowExecutionsRequest) ProtoMessage()

func (*ListOpenWorkflowExecutionsRequest) ProtoReflect 

func (x *ListOpenWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

func (*ListOpenWorkflowExecutionsRequest) Reset 

func (x *ListOpenWorkflowExecutionsRequest) Reset()

func (*ListOpenWorkflowExecutionsRequest) String 

func (x *ListOpenWorkflowExecutionsRequest) String() string

type ListOpenWorkflowExecutionsRequest_ExecutionFilter 

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

type ListOpenWorkflowExecutionsRequest_TypeFilter 

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

type ListOpenWorkflowExecutionsResponse 

type ListOpenWorkflowExecutionsResponse struct {
	Executions    []*v112.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"`
	// contains filtered or unexported fields
}

func (*ListOpenWorkflowExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use ListOpenWorkflowExecutionsResponse.ProtoReflect.Descriptor instead.

func (*ListOpenWorkflowExecutionsResponse) GetExecutions 

func (x *ListOpenWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

func (*ListOpenWorkflowExecutionsResponse) GetNextPageToken 

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

func (*ListOpenWorkflowExecutionsResponse) ProtoMessage 

func (*ListOpenWorkflowExecutionsResponse) ProtoMessage()

func (*ListOpenWorkflowExecutionsResponse) ProtoReflect 

func (x *ListOpenWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

func (*ListOpenWorkflowExecutionsResponse) Reset 

func (x *ListOpenWorkflowExecutionsResponse) Reset()

func (*ListOpenWorkflowExecutionsResponse) String 

func (x *ListOpenWorkflowExecutionsResponse) String() string

type ListScheduleMatchingTimesRequest 

type ListScheduleMatchingTimesRequest struct {

	// The namespace of the schedule to query.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The id of the schedule to query.
	ScheduleId string `protobuf:"bytes,2,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// Time range to query.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ListScheduleMatchingTimesRequest) Descriptor deprecated 

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

Deprecated: Use ListScheduleMatchingTimesRequest.ProtoReflect.Descriptor instead.

func (*ListScheduleMatchingTimesRequest) GetEndTime 

func (x *ListScheduleMatchingTimesRequest) GetEndTime() *timestamppb.Timestamp

func (*ListScheduleMatchingTimesRequest) GetNamespace 

func (x *ListScheduleMatchingTimesRequest) GetNamespace() string

func (*ListScheduleMatchingTimesRequest) GetScheduleId 

func (x *ListScheduleMatchingTimesRequest) GetScheduleId() string

func (*ListScheduleMatchingTimesRequest) GetStartTime 

func (x *ListScheduleMatchingTimesRequest) GetStartTime() *timestamppb.Timestamp

func (*ListScheduleMatchingTimesRequest) ProtoMessage 

func (*ListScheduleMatchingTimesRequest) ProtoMessage()

func (*ListScheduleMatchingTimesRequest) ProtoReflect 

func (x *ListScheduleMatchingTimesRequest) ProtoReflect() protoreflect.Message

func (*ListScheduleMatchingTimesRequest) Reset 

func (x *ListScheduleMatchingTimesRequest) Reset()

func (*ListScheduleMatchingTimesRequest) String 

func (x *ListScheduleMatchingTimesRequest) String() string

type ListScheduleMatchingTimesResponse 

type ListScheduleMatchingTimesResponse struct {
	StartTime []*timestamppb.Timestamp `protobuf:"bytes,1,rep,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// contains filtered or unexported fields
}

func (*ListScheduleMatchingTimesResponse) Descriptor deprecated 

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

Deprecated: Use ListScheduleMatchingTimesResponse.ProtoReflect.Descriptor instead.

func (*ListScheduleMatchingTimesResponse) GetStartTime 

func (x *ListScheduleMatchingTimesResponse) GetStartTime() []*timestamppb.Timestamp

func (*ListScheduleMatchingTimesResponse) ProtoMessage 

func (*ListScheduleMatchingTimesResponse) ProtoMessage()

func (*ListScheduleMatchingTimesResponse) ProtoReflect 

func (x *ListScheduleMatchingTimesResponse) ProtoReflect() protoreflect.Message

func (*ListScheduleMatchingTimesResponse) Reset 

func (x *ListScheduleMatchingTimesResponse) Reset()

func (*ListScheduleMatchingTimesResponse) String 

func (x *ListScheduleMatchingTimesResponse) String() string

type ListSchedulesRequest 

type ListSchedulesRequest struct {

	// The namespace to list schedules in.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// How many to return at once.
	MaximumPageSize int32 `protobuf:"varint,2,opt,name=maximum_page_size,json=maximumPageSize,proto3" json:"maximum_page_size,omitempty"`
	// Token to get the next page of results.
	NextPageToken []byte `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSchedulesRequest) Descriptor deprecated 

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

Deprecated: Use ListSchedulesRequest.ProtoReflect.Descriptor instead.

func (*ListSchedulesRequest) GetMaximumPageSize 

func (x *ListSchedulesRequest) GetMaximumPageSize() int32

func (*ListSchedulesRequest) GetNamespace 

func (x *ListSchedulesRequest) GetNamespace() string

func (*ListSchedulesRequest) GetNextPageToken 

func (x *ListSchedulesRequest) GetNextPageToken() []byte

func (*ListSchedulesRequest) ProtoMessage 

func (*ListSchedulesRequest) ProtoMessage()

func (*ListSchedulesRequest) ProtoReflect 

func (x *ListSchedulesRequest) ProtoReflect() protoreflect.Message

func (*ListSchedulesRequest) Reset 

func (x *ListSchedulesRequest) Reset()

func (*ListSchedulesRequest) String 

func (x *ListSchedulesRequest) String() string

type ListSchedulesResponse 

type ListSchedulesResponse struct {
	Schedules     []*v114.ScheduleListEntry `protobuf:"bytes,1,rep,name=schedules,proto3" json:"schedules,omitempty"`
	NextPageToken []byte                    `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSchedulesResponse) Descriptor deprecated 

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

Deprecated: Use ListSchedulesResponse.ProtoReflect.Descriptor instead.

func (*ListSchedulesResponse) GetNextPageToken 

func (x *ListSchedulesResponse) GetNextPageToken() []byte

func (*ListSchedulesResponse) GetSchedules 

func (x *ListSchedulesResponse) GetSchedules() []*v114.ScheduleListEntry

func (*ListSchedulesResponse) ProtoMessage 

func (*ListSchedulesResponse) ProtoMessage()

func (*ListSchedulesResponse) ProtoReflect 

func (x *ListSchedulesResponse) ProtoReflect() protoreflect.Message

func (*ListSchedulesResponse) Reset 

func (x *ListSchedulesResponse) Reset()

func (*ListSchedulesResponse) String 

func (x *ListSchedulesResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListTaskQueuePartitionsRequest) Descriptor deprecated 

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

Deprecated: Use ListTaskQueuePartitionsRequest.ProtoReflect.Descriptor instead.

func (*ListTaskQueuePartitionsRequest) GetNamespace 

func (x *ListTaskQueuePartitionsRequest) GetNamespace() string

func (*ListTaskQueuePartitionsRequest) GetTaskQueue 

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

func (*ListTaskQueuePartitionsRequest) ProtoMessage 

func (*ListTaskQueuePartitionsRequest) ProtoMessage()

func (*ListTaskQueuePartitionsRequest) ProtoReflect 

func (x *ListTaskQueuePartitionsRequest) ProtoReflect() protoreflect.Message

func (*ListTaskQueuePartitionsRequest) Reset 

func (x *ListTaskQueuePartitionsRequest) Reset()

func (*ListTaskQueuePartitionsRequest) String 

func (x *ListTaskQueuePartitionsRequest) String() string

type ListTaskQueuePartitionsResponse 

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

func (*ListTaskQueuePartitionsResponse) Descriptor deprecated 

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

Deprecated: Use ListTaskQueuePartitionsResponse.ProtoReflect.Descriptor instead.

func (*ListTaskQueuePartitionsResponse) GetActivityTaskQueuePartitions 

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

func (*ListTaskQueuePartitionsResponse) GetWorkflowTaskQueuePartitions 

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

func (*ListTaskQueuePartitionsResponse) ProtoMessage 

func (*ListTaskQueuePartitionsResponse) ProtoMessage()

func (*ListTaskQueuePartitionsResponse) ProtoReflect 

func (x *ListTaskQueuePartitionsResponse) ProtoReflect() protoreflect.Message

func (*ListTaskQueuePartitionsResponse) Reset 

func (x *ListTaskQueuePartitionsResponse) Reset()

func (*ListTaskQueuePartitionsResponse) String 

func (x *ListTaskQueuePartitionsResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ListWorkflowExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkflowExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowExecutionsRequest) GetNamespace 

func (x *ListWorkflowExecutionsRequest) GetNamespace() string

func (*ListWorkflowExecutionsRequest) GetNextPageToken 

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

func (*ListWorkflowExecutionsRequest) GetPageSize 

func (x *ListWorkflowExecutionsRequest) GetPageSize() int32

func (*ListWorkflowExecutionsRequest) GetQuery 

func (x *ListWorkflowExecutionsRequest) GetQuery() string

func (*ListWorkflowExecutionsRequest) ProtoMessage 

func (*ListWorkflowExecutionsRequest) ProtoMessage()

func (*ListWorkflowExecutionsRequest) ProtoReflect 

func (x *ListWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

func (*ListWorkflowExecutionsRequest) Reset 

func (x *ListWorkflowExecutionsRequest) Reset()

func (*ListWorkflowExecutionsRequest) String 

func (x *ListWorkflowExecutionsRequest) String() string

type ListWorkflowExecutionsResponse 

type ListWorkflowExecutionsResponse struct {
	Executions    []*v112.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"`
	// contains filtered or unexported fields
}

func (*ListWorkflowExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkflowExecutionsResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowExecutionsResponse) GetExecutions 

func (x *ListWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

func (*ListWorkflowExecutionsResponse) GetNextPageToken 

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

func (*ListWorkflowExecutionsResponse) ProtoMessage 

func (*ListWorkflowExecutionsResponse) ProtoMessage()

func (*ListWorkflowExecutionsResponse) ProtoReflect 

func (x *ListWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

func (*ListWorkflowExecutionsResponse) Reset 

func (x *ListWorkflowExecutionsResponse) Reset()

func (*ListWorkflowExecutionsResponse) String 

func (x *ListWorkflowExecutionsResponse) String() string

type PatchScheduleRequest 

type PatchScheduleRequest struct {

	// The namespace of the schedule to patch.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The id of the schedule to patch.
	ScheduleId string              `protobuf:"bytes,2,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	Patch      *v114.SchedulePatch `protobuf:"bytes,3,opt,name=patch,proto3" json:"patch,omitempty"`
	// The identity of the client who initiated this request.
	Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// A unique identifier for this update request for idempotence. Typically UUIDv4.
	RequestId string `protobuf:"bytes,5,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PatchScheduleRequest) Descriptor deprecated 

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

Deprecated: Use PatchScheduleRequest.ProtoReflect.Descriptor instead.

func (*PatchScheduleRequest) GetIdentity 

func (x *PatchScheduleRequest) GetIdentity() string

func (*PatchScheduleRequest) GetNamespace 

func (x *PatchScheduleRequest) GetNamespace() string

func (*PatchScheduleRequest) GetPatch 

func (x *PatchScheduleRequest) GetPatch() *v114.SchedulePatch

func (*PatchScheduleRequest) GetRequestId 

func (x *PatchScheduleRequest) GetRequestId() string

func (*PatchScheduleRequest) GetScheduleId 

func (x *PatchScheduleRequest) GetScheduleId() string

func (*PatchScheduleRequest) ProtoMessage 

func (*PatchScheduleRequest) ProtoMessage()

func (*PatchScheduleRequest) ProtoReflect 

func (x *PatchScheduleRequest) ProtoReflect() protoreflect.Message

func (*PatchScheduleRequest) Reset 

func (x *PatchScheduleRequest) Reset()

func (*PatchScheduleRequest) String 

func (x *PatchScheduleRequest) String() string

type PatchScheduleResponse 

type PatchScheduleResponse struct {
	// contains filtered or unexported fields
}

func (*PatchScheduleResponse) Descriptor deprecated 

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

Deprecated: Use PatchScheduleResponse.ProtoReflect.Descriptor instead.

func (*PatchScheduleResponse) ProtoMessage 

func (*PatchScheduleResponse) ProtoMessage()

func (*PatchScheduleResponse) ProtoReflect 

func (x *PatchScheduleResponse) ProtoReflect() protoreflect.Message

func (*PatchScheduleResponse) Reset 

func (x *PatchScheduleResponse) Reset()

func (*PatchScheduleResponse) String 

func (x *PatchScheduleResponse) String() string

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"`
	// If set, the worker is opting in to versioning and wishes to only
	// receive tasks that are considered compatible with the capabilities provided.
	// Doing so only makes sense in conjunction with the `UpdateWorkerBuildIdCompatibility` API.
	WorkerVersionCapabilities *v13.WorkerVersionCapabilities `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PollActivityTaskQueueRequest) Descriptor deprecated 

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

Deprecated: Use PollActivityTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*PollActivityTaskQueueRequest) GetIdentity 

func (x *PollActivityTaskQueueRequest) GetIdentity() string

func (*PollActivityTaskQueueRequest) GetNamespace 

func (x *PollActivityTaskQueueRequest) GetNamespace() string

func (*PollActivityTaskQueueRequest) GetTaskQueue 

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

func (*PollActivityTaskQueueRequest) GetTaskQueueMetadata 

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

func (*PollActivityTaskQueueRequest) GetWorkerVersionCapabilities 

func (x *PollActivityTaskQueueRequest) GetWorkerVersionCapabilities() *v13.WorkerVersionCapabilities

func (*PollActivityTaskQueueRequest) ProtoMessage 

func (*PollActivityTaskQueueRequest) ProtoMessage()

func (*PollActivityTaskQueueRequest) ProtoReflect 

func (x *PollActivityTaskQueueRequest) ProtoReflect() protoreflect.Message

func (*PollActivityTaskQueueRequest) Reset 

func (x *PollActivityTaskQueueRequest) Reset()

func (*PollActivityTaskQueueRequest) String 

func (x *PollActivityTaskQueueRequest) String() string

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 *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	// When was this task attempt scheduled
	CurrentAttemptScheduledTime *timestamppb.Timestamp `` /* 147-byte string literal not displayed */
	// When was this task started (this attempt)
	StartedTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=started_time,json=startedTime,proto3" 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 *durationpb.Duration `` /* 132-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 *durationpb.Duration `protobuf:"bytes,15,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"`
	// Window within which the activity must report a heartbeat, or be timed out.
	HeartbeatTimeout *durationpb.Duration `protobuf:"bytes,16,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" 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"`
	// contains filtered or unexported fields
}

func (*PollActivityTaskQueueResponse) Descriptor deprecated 

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

Deprecated: Use PollActivityTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*PollActivityTaskQueueResponse) GetActivityId 

func (x *PollActivityTaskQueueResponse) GetActivityId() string

func (*PollActivityTaskQueueResponse) GetActivityType 

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

func (*PollActivityTaskQueueResponse) GetAttempt 

func (x *PollActivityTaskQueueResponse) GetAttempt() int32

func (*PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime 

func (x *PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime() *timestamppb.Timestamp

func (*PollActivityTaskQueueResponse) GetHeader 

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

func (*PollActivityTaskQueueResponse) GetHeartbeatDetails 

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

func (*PollActivityTaskQueueResponse) GetHeartbeatTimeout 

func (x *PollActivityTaskQueueResponse) GetHeartbeatTimeout() *durationpb.Duration

func (*PollActivityTaskQueueResponse) GetInput 

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

func (*PollActivityTaskQueueResponse) GetRetryPolicy 

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

func (*PollActivityTaskQueueResponse) GetScheduleToCloseTimeout 

func (x *PollActivityTaskQueueResponse) GetScheduleToCloseTimeout() *durationpb.Duration

func (*PollActivityTaskQueueResponse) GetScheduledTime 

func (x *PollActivityTaskQueueResponse) GetScheduledTime() *timestamppb.Timestamp

func (*PollActivityTaskQueueResponse) GetStartToCloseTimeout 

func (x *PollActivityTaskQueueResponse) GetStartToCloseTimeout() *durationpb.Duration

func (*PollActivityTaskQueueResponse) GetStartedTime 

func (x *PollActivityTaskQueueResponse) GetStartedTime() *timestamppb.Timestamp

func (*PollActivityTaskQueueResponse) GetTaskToken 

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

func (*PollActivityTaskQueueResponse) GetWorkflowExecution 

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

func (*PollActivityTaskQueueResponse) GetWorkflowNamespace 

func (x *PollActivityTaskQueueResponse) GetWorkflowNamespace() string

func (*PollActivityTaskQueueResponse) GetWorkflowType 

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

func (*PollActivityTaskQueueResponse) ProtoMessage 

func (*PollActivityTaskQueueResponse) ProtoMessage()

func (*PollActivityTaskQueueResponse) ProtoReflect 

func (x *PollActivityTaskQueueResponse) ProtoReflect() protoreflect.Message

func (*PollActivityTaskQueueResponse) Reset 

func (x *PollActivityTaskQueueResponse) Reset()

func (*PollActivityTaskQueueResponse) String 

func (x *PollActivityTaskQueueResponse) String() string

type PollWorkflowExecutionUpdateRequest 

type PollWorkflowExecutionUpdateRequest struct {

	// The namespace of the workflow execution to which the update was
	// originally issued.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The update reference returned in the initial
	// UpdateWorkflowExecutionResponse
	UpdateRef *v115.UpdateRef `protobuf:"bytes,2,opt,name=update_ref,json=updateRef,proto3" json:"update_ref,omitempty"`
	// The identity of the worker/client who is polling this update outcome
	Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// Describes when this poll request should return a response
	WaitPolicy *v115.WaitPolicy `protobuf:"bytes,4,opt,name=wait_policy,json=waitPolicy,proto3" json:"wait_policy,omitempty"`
	// contains filtered or unexported fields
}

func (*PollWorkflowExecutionUpdateRequest) Descriptor deprecated 

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

Deprecated: Use PollWorkflowExecutionUpdateRequest.ProtoReflect.Descriptor instead.

func (*PollWorkflowExecutionUpdateRequest) GetIdentity 

func (x *PollWorkflowExecutionUpdateRequest) GetIdentity() string

func (*PollWorkflowExecutionUpdateRequest) GetNamespace 

func (x *PollWorkflowExecutionUpdateRequest) GetNamespace() string

func (*PollWorkflowExecutionUpdateRequest) GetUpdateRef 

func (x *PollWorkflowExecutionUpdateRequest) GetUpdateRef() *v115.UpdateRef

func (*PollWorkflowExecutionUpdateRequest) GetWaitPolicy 

func (x *PollWorkflowExecutionUpdateRequest) GetWaitPolicy() *v115.WaitPolicy

func (*PollWorkflowExecutionUpdateRequest) ProtoMessage 

func (*PollWorkflowExecutionUpdateRequest) ProtoMessage()

func (*PollWorkflowExecutionUpdateRequest) ProtoReflect 

func (x *PollWorkflowExecutionUpdateRequest) ProtoReflect() protoreflect.Message

func (*PollWorkflowExecutionUpdateRequest) Reset 

func (x *PollWorkflowExecutionUpdateRequest) Reset()

func (*PollWorkflowExecutionUpdateRequest) String 

func (x *PollWorkflowExecutionUpdateRequest) String() string

type PollWorkflowExecutionUpdateResponse 

type PollWorkflowExecutionUpdateResponse struct {

	// The outcome of the update if and only if the update has completed. If
	// this response is being returned before the update has completed (e.g. due
	// to the specification of a wait policy that only waits on
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ACCEPTED) then this field will
	// not be set.
	Outcome *v115.Outcome `protobuf:"bytes,1,opt,name=outcome,proto3" json:"outcome,omitempty"`
	// contains filtered or unexported fields
}

func (*PollWorkflowExecutionUpdateResponse) Descriptor deprecated 

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

Deprecated: Use PollWorkflowExecutionUpdateResponse.ProtoReflect.Descriptor instead.

func (*PollWorkflowExecutionUpdateResponse) GetOutcome 

func (x *PollWorkflowExecutionUpdateResponse) GetOutcome() *v115.Outcome

func (*PollWorkflowExecutionUpdateResponse) ProtoMessage 

func (*PollWorkflowExecutionUpdateResponse) ProtoMessage()

func (*PollWorkflowExecutionUpdateResponse) ProtoReflect 

func (x *PollWorkflowExecutionUpdateResponse) ProtoReflect() protoreflect.Message

func (*PollWorkflowExecutionUpdateResponse) Reset 

func (x *PollWorkflowExecutionUpdateResponse) Reset()

func (*PollWorkflowExecutionUpdateResponse) String 

func (x *PollWorkflowExecutionUpdateResponse) String() string

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
	// "checksum" in this field name isn't very accurate, it should be though of as an id.
	BinaryChecksum string `protobuf:"bytes,4,opt,name=binary_checksum,json=binaryChecksum,proto3" json:"binary_checksum,omitempty"`
	// If set, the worker is opting in to versioning and wishes to only
	// receive tasks that are considered compatible with the version capabilities provided.
	// Doing so only makes sense in conjunction with the `UpdateWorkerBuildIdCompatibility` API.
	// When this field has a `worker_build_id`, and `binary_checksum` is not
	// set, that value should also be considered as the `binary_checksum`.
	WorkerVersionCapabilities *v13.WorkerVersionCapabilities `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PollWorkflowTaskQueueRequest) Descriptor deprecated 

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

Deprecated: Use PollWorkflowTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*PollWorkflowTaskQueueRequest) GetBinaryChecksum 

func (x *PollWorkflowTaskQueueRequest) GetBinaryChecksum() string

func (*PollWorkflowTaskQueueRequest) GetIdentity 

func (x *PollWorkflowTaskQueueRequest) GetIdentity() string

func (*PollWorkflowTaskQueueRequest) GetNamespace 

func (x *PollWorkflowTaskQueueRequest) GetNamespace() string

func (*PollWorkflowTaskQueueRequest) GetTaskQueue 

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

func (*PollWorkflowTaskQueueRequest) GetWorkerVersionCapabilities 

func (x *PollWorkflowTaskQueueRequest) GetWorkerVersionCapabilities() *v13.WorkerVersionCapabilities

func (*PollWorkflowTaskQueueRequest) ProtoMessage 

func (*PollWorkflowTaskQueueRequest) ProtoMessage()

func (*PollWorkflowTaskQueueRequest) ProtoReflect 

func (x *PollWorkflowTaskQueueRequest) ProtoReflect() protoreflect.Message

func (*PollWorkflowTaskQueueRequest) Reset 

func (x *PollWorkflowTaskQueueRequest) Reset()

func (*PollWorkflowTaskQueueRequest) String 

func (x *PollWorkflowTaskQueueRequest) String() string

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 *v16.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 *v17.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 *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	// When the current workflow task started event was generated, meaning the current attempt.
	StartedTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=started_time,json=startedTime,proto3" 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]*v17.WorkflowQuery `` /* 156-byte string literal not displayed */
	// Protocol messages piggybacking on a WFT as a transport
	Messages []*v18.Message `protobuf:"bytes,15,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*PollWorkflowTaskQueueResponse) Descriptor deprecated 

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

Deprecated: Use PollWorkflowTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*PollWorkflowTaskQueueResponse) GetAttempt 

func (x *PollWorkflowTaskQueueResponse) GetAttempt() int32

func (*PollWorkflowTaskQueueResponse) GetBacklogCountHint 

func (x *PollWorkflowTaskQueueResponse) GetBacklogCountHint() int64

func (*PollWorkflowTaskQueueResponse) GetHistory 

func (x *PollWorkflowTaskQueueResponse) GetHistory() *v16.History

func (*PollWorkflowTaskQueueResponse) GetMessages 

func (x *PollWorkflowTaskQueueResponse) GetMessages() []*v18.Message

func (*PollWorkflowTaskQueueResponse) GetNextPageToken 

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

func (*PollWorkflowTaskQueueResponse) GetPreviousStartedEventId 

func (x *PollWorkflowTaskQueueResponse) GetPreviousStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetQueries 

func (x *PollWorkflowTaskQueueResponse) GetQueries() map[string]*v17.WorkflowQuery

func (*PollWorkflowTaskQueueResponse) GetQuery 

func (x *PollWorkflowTaskQueueResponse) GetQuery() *v17.WorkflowQuery

func (*PollWorkflowTaskQueueResponse) GetScheduledTime 

func (x *PollWorkflowTaskQueueResponse) GetScheduledTime() *timestamppb.Timestamp

func (*PollWorkflowTaskQueueResponse) GetStartedEventId 

func (x *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetStartedTime 

func (x *PollWorkflowTaskQueueResponse) GetStartedTime() *timestamppb.Timestamp

func (*PollWorkflowTaskQueueResponse) GetTaskToken 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecution 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowType 

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

func (*PollWorkflowTaskQueueResponse) ProtoMessage 

func (*PollWorkflowTaskQueueResponse) ProtoMessage()

func (*PollWorkflowTaskQueueResponse) ProtoReflect 

func (x *PollWorkflowTaskQueueResponse) ProtoReflect() protoreflect.Message

func (*PollWorkflowTaskQueueResponse) Reset 

func (x *PollWorkflowTaskQueueResponse) Reset()

func (*PollWorkflowTaskQueueResponse) String 

func (x *PollWorkflowTaskQueueResponse) String() string

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     *v17.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 */
	// contains filtered or unexported fields
}

func (*QueryWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use QueryWorkflowRequest.ProtoReflect.Descriptor instead.

func (*QueryWorkflowRequest) GetExecution 

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

func (*QueryWorkflowRequest) GetNamespace 

func (x *QueryWorkflowRequest) GetNamespace() string

func (*QueryWorkflowRequest) GetQuery 

func (x *QueryWorkflowRequest) GetQuery() *v17.WorkflowQuery

func (*QueryWorkflowRequest) GetQueryRejectCondition 

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

func (*QueryWorkflowRequest) ProtoMessage 

func (*QueryWorkflowRequest) ProtoMessage()

func (*QueryWorkflowRequest) ProtoReflect 

func (x *QueryWorkflowRequest) ProtoReflect() protoreflect.Message

func (*QueryWorkflowRequest) Reset 

func (x *QueryWorkflowRequest) Reset()

func (*QueryWorkflowRequest) String 

func (x *QueryWorkflowRequest) String() string

type QueryWorkflowResponse 

type QueryWorkflowResponse struct {
	QueryResult   *v13.Payloads      `protobuf:"bytes,1,opt,name=query_result,json=queryResult,proto3" json:"query_result,omitempty"`
	QueryRejected *v17.QueryRejected `protobuf:"bytes,2,opt,name=query_rejected,json=queryRejected,proto3" json:"query_rejected,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryWorkflowResponse) Descriptor deprecated 

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

Deprecated: Use QueryWorkflowResponse.ProtoReflect.Descriptor instead.

func (*QueryWorkflowResponse) GetQueryRejected 

func (x *QueryWorkflowResponse) GetQueryRejected() *v17.QueryRejected

func (*QueryWorkflowResponse) GetQueryResult 

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

func (*QueryWorkflowResponse) ProtoMessage 

func (*QueryWorkflowResponse) ProtoMessage()

func (*QueryWorkflowResponse) ProtoReflect 

func (x *QueryWorkflowResponse) ProtoReflect() protoreflect.Message

func (*QueryWorkflowResponse) Reset 

func (x *QueryWorkflowResponse) Reset()

func (*QueryWorkflowResponse) String 

func (x *QueryWorkflowResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*RecordActivityTaskHeartbeatByIdRequest) Descriptor deprecated 

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

Deprecated: Use RecordActivityTaskHeartbeatByIdRequest.ProtoReflect.Descriptor instead.

func (*RecordActivityTaskHeartbeatByIdRequest) GetActivityId 

func (x *RecordActivityTaskHeartbeatByIdRequest) GetActivityId() string

func (*RecordActivityTaskHeartbeatByIdRequest) GetDetails 

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

func (*RecordActivityTaskHeartbeatByIdRequest) GetIdentity 

func (x *RecordActivityTaskHeartbeatByIdRequest) GetIdentity() string

func (*RecordActivityTaskHeartbeatByIdRequest) GetNamespace 

func (x *RecordActivityTaskHeartbeatByIdRequest) GetNamespace() string

func (*RecordActivityTaskHeartbeatByIdRequest) GetRunId 

func (x *RecordActivityTaskHeartbeatByIdRequest) GetRunId() string

func (*RecordActivityTaskHeartbeatByIdRequest) GetWorkflowId 

func (x *RecordActivityTaskHeartbeatByIdRequest) GetWorkflowId() string

func (*RecordActivityTaskHeartbeatByIdRequest) ProtoMessage 

func (*RecordActivityTaskHeartbeatByIdRequest) ProtoMessage()

func (*RecordActivityTaskHeartbeatByIdRequest) ProtoReflect 

func (x *RecordActivityTaskHeartbeatByIdRequest) ProtoReflect() protoreflect.Message

func (*RecordActivityTaskHeartbeatByIdRequest) Reset 

func (x *RecordActivityTaskHeartbeatByIdRequest) Reset()

func (*RecordActivityTaskHeartbeatByIdRequest) String 

func (x *RecordActivityTaskHeartbeatByIdRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*RecordActivityTaskHeartbeatByIdResponse) Descriptor deprecated 

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

Deprecated: Use RecordActivityTaskHeartbeatByIdResponse.ProtoReflect.Descriptor instead.

func (*RecordActivityTaskHeartbeatByIdResponse) GetCancelRequested 

func (x *RecordActivityTaskHeartbeatByIdResponse) GetCancelRequested() bool

func (*RecordActivityTaskHeartbeatByIdResponse) ProtoMessage 

func (*RecordActivityTaskHeartbeatByIdResponse) ProtoMessage()

func (*RecordActivityTaskHeartbeatByIdResponse) ProtoReflect 

func (x *RecordActivityTaskHeartbeatByIdResponse) ProtoReflect() protoreflect.Message

func (*RecordActivityTaskHeartbeatByIdResponse) Reset 

func (x *RecordActivityTaskHeartbeatByIdResponse) Reset()

func (*RecordActivityTaskHeartbeatByIdResponse) String 

func (x *RecordActivityTaskHeartbeatByIdResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*RecordActivityTaskHeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use RecordActivityTaskHeartbeatRequest.ProtoReflect.Descriptor instead.

func (*RecordActivityTaskHeartbeatRequest) GetDetails 

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

func (*RecordActivityTaskHeartbeatRequest) GetIdentity 

func (x *RecordActivityTaskHeartbeatRequest) GetIdentity() string

func (*RecordActivityTaskHeartbeatRequest) GetNamespace 

func (x *RecordActivityTaskHeartbeatRequest) GetNamespace() string

func (*RecordActivityTaskHeartbeatRequest) GetTaskToken 

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

func (*RecordActivityTaskHeartbeatRequest) ProtoMessage 

func (*RecordActivityTaskHeartbeatRequest) ProtoMessage()

func (*RecordActivityTaskHeartbeatRequest) ProtoReflect 

func (x *RecordActivityTaskHeartbeatRequest) ProtoReflect() protoreflect.Message

func (*RecordActivityTaskHeartbeatRequest) Reset 

func (x *RecordActivityTaskHeartbeatRequest) Reset()

func (*RecordActivityTaskHeartbeatRequest) String 

func (x *RecordActivityTaskHeartbeatRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*RecordActivityTaskHeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use RecordActivityTaskHeartbeatResponse.ProtoReflect.Descriptor instead.

func (*RecordActivityTaskHeartbeatResponse) GetCancelRequested 

func (x *RecordActivityTaskHeartbeatResponse) GetCancelRequested() bool

func (*RecordActivityTaskHeartbeatResponse) ProtoMessage 

func (*RecordActivityTaskHeartbeatResponse) ProtoMessage()

func (*RecordActivityTaskHeartbeatResponse) ProtoReflect 

func (x *RecordActivityTaskHeartbeatResponse) ProtoReflect() protoreflect.Message

func (*RecordActivityTaskHeartbeatResponse) Reset 

func (x *RecordActivityTaskHeartbeatResponse) Reset()

func (*RecordActivityTaskHeartbeatResponse) String 

func (x *RecordActivityTaskHeartbeatResponse) String() string

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 *durationpb.Duration           `` /* 161-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 */
	// contains filtered or unexported fields
}

func (*RegisterNamespaceRequest) Descriptor deprecated 

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

Deprecated: Use RegisterNamespaceRequest.ProtoReflect.Descriptor instead.

func (*RegisterNamespaceRequest) GetActiveClusterName 

func (x *RegisterNamespaceRequest) GetActiveClusterName() string

func (*RegisterNamespaceRequest) GetClusters 

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

func (*RegisterNamespaceRequest) GetData 

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

func (*RegisterNamespaceRequest) GetDescription 

func (x *RegisterNamespaceRequest) GetDescription() string

func (*RegisterNamespaceRequest) GetHistoryArchivalState 

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

func (*RegisterNamespaceRequest) GetHistoryArchivalUri 

func (x *RegisterNamespaceRequest) GetHistoryArchivalUri() string

func (*RegisterNamespaceRequest) GetIsGlobalNamespace 

func (x *RegisterNamespaceRequest) GetIsGlobalNamespace() bool

func (*RegisterNamespaceRequest) GetNamespace 

func (x *RegisterNamespaceRequest) GetNamespace() string

func (*RegisterNamespaceRequest) GetOwnerEmail 

func (x *RegisterNamespaceRequest) GetOwnerEmail() string

func (*RegisterNamespaceRequest) GetSecurityToken 

func (x *RegisterNamespaceRequest) GetSecurityToken() string

func (*RegisterNamespaceRequest) GetVisibilityArchivalState 

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

func (*RegisterNamespaceRequest) GetVisibilityArchivalUri 

func (x *RegisterNamespaceRequest) GetVisibilityArchivalUri() string

func (*RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriod 

func (x *RegisterNamespaceRequest) GetWorkflowExecutionRetentionPeriod() *durationpb.Duration

func (*RegisterNamespaceRequest) ProtoMessage 

func (*RegisterNamespaceRequest) ProtoMessage()

func (*RegisterNamespaceRequest) ProtoReflect 

func (x *RegisterNamespaceRequest) ProtoReflect() protoreflect.Message

func (*RegisterNamespaceRequest) Reset 

func (x *RegisterNamespaceRequest) Reset()

func (*RegisterNamespaceRequest) String 

func (x *RegisterNamespaceRequest) String() string

type RegisterNamespaceResponse 

type RegisterNamespaceResponse struct {
	// contains filtered or unexported fields
}

func (*RegisterNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use RegisterNamespaceResponse.ProtoReflect.Descriptor instead.

func (*RegisterNamespaceResponse) ProtoMessage 

func (*RegisterNamespaceResponse) ProtoMessage()

func (*RegisterNamespaceResponse) ProtoReflect 

func (x *RegisterNamespaceResponse) ProtoReflect() protoreflect.Message

func (*RegisterNamespaceResponse) Reset 

func (x *RegisterNamespaceResponse) Reset()

func (*RegisterNamespaceResponse) String 

func (x *RegisterNamespaceResponse) String() string

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"`
	// Reason for requesting the cancellation
	Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestCancelWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use RequestCancelWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunId 

func (x *RequestCancelWorkflowExecutionRequest) GetFirstExecutionRunId() string

func (*RequestCancelWorkflowExecutionRequest) GetIdentity 

func (x *RequestCancelWorkflowExecutionRequest) GetIdentity() string

func (*RequestCancelWorkflowExecutionRequest) GetNamespace 

func (x *RequestCancelWorkflowExecutionRequest) GetNamespace() string

func (*RequestCancelWorkflowExecutionRequest) GetReason 

func (x *RequestCancelWorkflowExecutionRequest) GetReason() string

func (*RequestCancelWorkflowExecutionRequest) GetRequestId 

func (x *RequestCancelWorkflowExecutionRequest) GetRequestId() string

func (*RequestCancelWorkflowExecutionRequest) GetWorkflowExecution 

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

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage 

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage()

func (*RequestCancelWorkflowExecutionRequest) ProtoReflect 

func (x *RequestCancelWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*RequestCancelWorkflowExecutionRequest) Reset 

func (x *RequestCancelWorkflowExecutionRequest) Reset()

func (*RequestCancelWorkflowExecutionRequest) String 

func (x *RequestCancelWorkflowExecutionRequest) String() string

type RequestCancelWorkflowExecutionResponse 

type RequestCancelWorkflowExecutionResponse struct {
	// contains filtered or unexported fields
}

func (*RequestCancelWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use RequestCancelWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*RequestCancelWorkflowExecutionResponse) ProtoMessage 

func (*RequestCancelWorkflowExecutionResponse) ProtoMessage()

func (*RequestCancelWorkflowExecutionResponse) ProtoReflect 

func (x *RequestCancelWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*RequestCancelWorkflowExecutionResponse) Reset 

func (x *RequestCancelWorkflowExecutionResponse) Reset()

func (*RequestCancelWorkflowExecutionResponse) String 

func (x *RequestCancelWorkflowExecutionResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ResetStickyTaskQueueRequest) Descriptor deprecated 

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

Deprecated: Use ResetStickyTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*ResetStickyTaskQueueRequest) GetExecution 

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

func (*ResetStickyTaskQueueRequest) GetNamespace 

func (x *ResetStickyTaskQueueRequest) GetNamespace() string

func (*ResetStickyTaskQueueRequest) ProtoMessage 

func (*ResetStickyTaskQueueRequest) ProtoMessage()

func (*ResetStickyTaskQueueRequest) ProtoReflect 

func (x *ResetStickyTaskQueueRequest) ProtoReflect() protoreflect.Message

func (*ResetStickyTaskQueueRequest) Reset 

func (x *ResetStickyTaskQueueRequest) Reset()

func (*ResetStickyTaskQueueRequest) String 

func (x *ResetStickyTaskQueueRequest) String() string

type ResetStickyTaskQueueResponse 

type ResetStickyTaskQueueResponse struct {
	// contains filtered or unexported fields
}

func (*ResetStickyTaskQueueResponse) Descriptor deprecated 

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

Deprecated: Use ResetStickyTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*ResetStickyTaskQueueResponse) ProtoMessage 

func (*ResetStickyTaskQueueResponse) ProtoMessage()

func (*ResetStickyTaskQueueResponse) ProtoReflect 

func (x *ResetStickyTaskQueueResponse) ProtoReflect() protoreflect.Message

func (*ResetStickyTaskQueueResponse) Reset 

func (x *ResetStickyTaskQueueResponse) Reset()

func (*ResetStickyTaskQueueResponse) String 

func (x *ResetStickyTaskQueueResponse) String() string

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"`
	// Reset reapplay(replay) options.
	ResetReapplyType v11.ResetReapplyType `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ResetWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use ResetWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*ResetWorkflowExecutionRequest) GetNamespace 

func (x *ResetWorkflowExecutionRequest) GetNamespace() string

func (*ResetWorkflowExecutionRequest) GetReason 

func (x *ResetWorkflowExecutionRequest) GetReason() string

func (*ResetWorkflowExecutionRequest) GetRequestId 

func (x *ResetWorkflowExecutionRequest) GetRequestId() string

func (*ResetWorkflowExecutionRequest) GetResetReapplyType 

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

func (*ResetWorkflowExecutionRequest) GetWorkflowExecution 

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

func (*ResetWorkflowExecutionRequest) GetWorkflowTaskFinishEventId 

func (x *ResetWorkflowExecutionRequest) GetWorkflowTaskFinishEventId() int64

func (*ResetWorkflowExecutionRequest) ProtoMessage 

func (*ResetWorkflowExecutionRequest) ProtoMessage()

func (*ResetWorkflowExecutionRequest) ProtoReflect 

func (x *ResetWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*ResetWorkflowExecutionRequest) Reset 

func (x *ResetWorkflowExecutionRequest) Reset()

func (*ResetWorkflowExecutionRequest) String 

func (x *ResetWorkflowExecutionRequest) String() string

type ResetWorkflowExecutionResponse 

type ResetWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use ResetWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*ResetWorkflowExecutionResponse) GetRunId 

func (x *ResetWorkflowExecutionResponse) GetRunId() string

func (*ResetWorkflowExecutionResponse) ProtoMessage 

func (*ResetWorkflowExecutionResponse) ProtoMessage()

func (*ResetWorkflowExecutionResponse) ProtoReflect 

func (x *ResetWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*ResetWorkflowExecutionResponse) Reset 

func (x *ResetWorkflowExecutionResponse) Reset()

func (*ResetWorkflowExecutionResponse) String 

func (x *ResetWorkflowExecutionResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*RespondActivityTaskCanceledByIdRequest) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskCanceledByIdRequest.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskCanceledByIdRequest) GetActivityId 

func (x *RespondActivityTaskCanceledByIdRequest) GetActivityId() string

func (*RespondActivityTaskCanceledByIdRequest) GetDetails 

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

func (*RespondActivityTaskCanceledByIdRequest) GetIdentity 

func (x *RespondActivityTaskCanceledByIdRequest) GetIdentity() string

func (*RespondActivityTaskCanceledByIdRequest) GetNamespace 

func (x *RespondActivityTaskCanceledByIdRequest) GetNamespace() string

func (*RespondActivityTaskCanceledByIdRequest) GetRunId 

func (x *RespondActivityTaskCanceledByIdRequest) GetRunId() string

func (*RespondActivityTaskCanceledByIdRequest) GetWorkflowId 

func (x *RespondActivityTaskCanceledByIdRequest) GetWorkflowId() string

func (*RespondActivityTaskCanceledByIdRequest) ProtoMessage 

func (*RespondActivityTaskCanceledByIdRequest) ProtoMessage()

func (*RespondActivityTaskCanceledByIdRequest) ProtoReflect 

func (x *RespondActivityTaskCanceledByIdRequest) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskCanceledByIdRequest) Reset 

func (x *RespondActivityTaskCanceledByIdRequest) Reset()

func (*RespondActivityTaskCanceledByIdRequest) String 

func (x *RespondActivityTaskCanceledByIdRequest) String() string

type RespondActivityTaskCanceledByIdResponse 

type RespondActivityTaskCanceledByIdResponse struct {
	// contains filtered or unexported fields
}

func (*RespondActivityTaskCanceledByIdResponse) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskCanceledByIdResponse.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskCanceledByIdResponse) ProtoMessage 

func (*RespondActivityTaskCanceledByIdResponse) ProtoMessage()

func (*RespondActivityTaskCanceledByIdResponse) ProtoReflect 

func (x *RespondActivityTaskCanceledByIdResponse) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskCanceledByIdResponse) Reset 

func (x *RespondActivityTaskCanceledByIdResponse) Reset()

func (*RespondActivityTaskCanceledByIdResponse) String 

func (x *RespondActivityTaskCanceledByIdResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*RespondActivityTaskCanceledRequest) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskCanceledRequest.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskCanceledRequest) GetDetails 

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

func (*RespondActivityTaskCanceledRequest) GetIdentity 

func (x *RespondActivityTaskCanceledRequest) GetIdentity() string

func (*RespondActivityTaskCanceledRequest) GetNamespace 

func (x *RespondActivityTaskCanceledRequest) GetNamespace() string

func (*RespondActivityTaskCanceledRequest) GetTaskToken 

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

func (*RespondActivityTaskCanceledRequest) ProtoMessage 

func (*RespondActivityTaskCanceledRequest) ProtoMessage()

func (*RespondActivityTaskCanceledRequest) ProtoReflect 

func (x *RespondActivityTaskCanceledRequest) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskCanceledRequest) Reset 

func (x *RespondActivityTaskCanceledRequest) Reset()

func (*RespondActivityTaskCanceledRequest) String 

func (x *RespondActivityTaskCanceledRequest) String() string

type RespondActivityTaskCanceledResponse 

type RespondActivityTaskCanceledResponse struct {
	// contains filtered or unexported fields
}

func (*RespondActivityTaskCanceledResponse) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskCanceledResponse.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskCanceledResponse) ProtoMessage 

func (*RespondActivityTaskCanceledResponse) ProtoMessage()

func (*RespondActivityTaskCanceledResponse) ProtoReflect 

func (x *RespondActivityTaskCanceledResponse) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskCanceledResponse) Reset 

func (x *RespondActivityTaskCanceledResponse) Reset()

func (*RespondActivityTaskCanceledResponse) String 

func (x *RespondActivityTaskCanceledResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*RespondActivityTaskCompletedByIdRequest) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskCompletedByIdRequest.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskCompletedByIdRequest) GetActivityId 

func (x *RespondActivityTaskCompletedByIdRequest) GetActivityId() string

func (*RespondActivityTaskCompletedByIdRequest) GetIdentity 

func (x *RespondActivityTaskCompletedByIdRequest) GetIdentity() string

func (*RespondActivityTaskCompletedByIdRequest) GetNamespace 

func (x *RespondActivityTaskCompletedByIdRequest) GetNamespace() string

func (*RespondActivityTaskCompletedByIdRequest) GetResult 

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

func (*RespondActivityTaskCompletedByIdRequest) GetRunId 

func (x *RespondActivityTaskCompletedByIdRequest) GetRunId() string

func (*RespondActivityTaskCompletedByIdRequest) GetWorkflowId 

func (x *RespondActivityTaskCompletedByIdRequest) GetWorkflowId() string

func (*RespondActivityTaskCompletedByIdRequest) ProtoMessage 

func (*RespondActivityTaskCompletedByIdRequest) ProtoMessage()

func (*RespondActivityTaskCompletedByIdRequest) ProtoReflect 

func (x *RespondActivityTaskCompletedByIdRequest) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskCompletedByIdRequest) Reset 

func (x *RespondActivityTaskCompletedByIdRequest) Reset()

func (*RespondActivityTaskCompletedByIdRequest) String 

func (x *RespondActivityTaskCompletedByIdRequest) String() string

type RespondActivityTaskCompletedByIdResponse 

type RespondActivityTaskCompletedByIdResponse struct {
	// contains filtered or unexported fields
}

func (*RespondActivityTaskCompletedByIdResponse) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskCompletedByIdResponse.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskCompletedByIdResponse) ProtoMessage 

func (*RespondActivityTaskCompletedByIdResponse) ProtoMessage()

func (*RespondActivityTaskCompletedByIdResponse) ProtoReflect 

func (x *RespondActivityTaskCompletedByIdResponse) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskCompletedByIdResponse) Reset 

func (x *RespondActivityTaskCompletedByIdResponse) Reset()

func (*RespondActivityTaskCompletedByIdResponse) String 

func (x *RespondActivityTaskCompletedByIdResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*RespondActivityTaskCompletedRequest) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskCompletedRequest.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskCompletedRequest) GetIdentity 

func (x *RespondActivityTaskCompletedRequest) GetIdentity() string

func (*RespondActivityTaskCompletedRequest) GetNamespace 

func (x *RespondActivityTaskCompletedRequest) GetNamespace() string

func (*RespondActivityTaskCompletedRequest) GetResult 

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

func (*RespondActivityTaskCompletedRequest) GetTaskToken 

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

func (*RespondActivityTaskCompletedRequest) ProtoMessage 

func (*RespondActivityTaskCompletedRequest) ProtoMessage()

func (*RespondActivityTaskCompletedRequest) ProtoReflect 

func (x *RespondActivityTaskCompletedRequest) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskCompletedRequest) Reset 

func (x *RespondActivityTaskCompletedRequest) Reset()

func (*RespondActivityTaskCompletedRequest) String 

func (x *RespondActivityTaskCompletedRequest) String() string

type RespondActivityTaskCompletedResponse 

type RespondActivityTaskCompletedResponse struct {
	// contains filtered or unexported fields
}

func (*RespondActivityTaskCompletedResponse) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskCompletedResponse.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskCompletedResponse) ProtoMessage 

func (*RespondActivityTaskCompletedResponse) ProtoMessage()

func (*RespondActivityTaskCompletedResponse) ProtoReflect 

func (x *RespondActivityTaskCompletedResponse) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskCompletedResponse) Reset 

func (x *RespondActivityTaskCompletedResponse) Reset()

func (*RespondActivityTaskCompletedResponse) String 

func (x *RespondActivityTaskCompletedResponse) String() string

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 *v15.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"`
	// contains filtered or unexported fields
}

func (*RespondActivityTaskFailedByIdRequest) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskFailedByIdRequest.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskFailedByIdRequest) GetActivityId 

func (x *RespondActivityTaskFailedByIdRequest) GetActivityId() string

func (*RespondActivityTaskFailedByIdRequest) GetFailure 

func (x *RespondActivityTaskFailedByIdRequest) GetFailure() *v15.Failure

func (*RespondActivityTaskFailedByIdRequest) GetIdentity 

func (x *RespondActivityTaskFailedByIdRequest) GetIdentity() string

func (*RespondActivityTaskFailedByIdRequest) GetLastHeartbeatDetails 

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

func (*RespondActivityTaskFailedByIdRequest) GetNamespace 

func (x *RespondActivityTaskFailedByIdRequest) GetNamespace() string

func (*RespondActivityTaskFailedByIdRequest) GetRunId 

func (x *RespondActivityTaskFailedByIdRequest) GetRunId() string

func (*RespondActivityTaskFailedByIdRequest) GetWorkflowId 

func (x *RespondActivityTaskFailedByIdRequest) GetWorkflowId() string

func (*RespondActivityTaskFailedByIdRequest) ProtoMessage 

func (*RespondActivityTaskFailedByIdRequest) ProtoMessage()

func (*RespondActivityTaskFailedByIdRequest) ProtoReflect 

func (x *RespondActivityTaskFailedByIdRequest) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskFailedByIdRequest) Reset 

func (x *RespondActivityTaskFailedByIdRequest) Reset()

func (*RespondActivityTaskFailedByIdRequest) String 

func (x *RespondActivityTaskFailedByIdRequest) String() string

type RespondActivityTaskFailedByIdResponse 

type RespondActivityTaskFailedByIdResponse struct {

	// Server validation failures could include
	// last_heartbeat_details payload is too large, request failure is too large
	Failures []*v15.Failure `protobuf:"bytes,1,rep,name=failures,proto3" json:"failures,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondActivityTaskFailedByIdResponse) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskFailedByIdResponse.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskFailedByIdResponse) GetFailures 

func (x *RespondActivityTaskFailedByIdResponse) GetFailures() []*v15.Failure

func (*RespondActivityTaskFailedByIdResponse) ProtoMessage 

func (*RespondActivityTaskFailedByIdResponse) ProtoMessage()

func (*RespondActivityTaskFailedByIdResponse) ProtoReflect 

func (x *RespondActivityTaskFailedByIdResponse) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskFailedByIdResponse) Reset 

func (x *RespondActivityTaskFailedByIdResponse) Reset()

func (*RespondActivityTaskFailedByIdResponse) String 

func (x *RespondActivityTaskFailedByIdResponse) String() string

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 *v15.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"`
	// contains filtered or unexported fields
}

func (*RespondActivityTaskFailedRequest) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskFailedRequest.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskFailedRequest) GetFailure 

func (x *RespondActivityTaskFailedRequest) GetFailure() *v15.Failure

func (*RespondActivityTaskFailedRequest) GetIdentity 

func (x *RespondActivityTaskFailedRequest) GetIdentity() string

func (*RespondActivityTaskFailedRequest) GetLastHeartbeatDetails 

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

func (*RespondActivityTaskFailedRequest) GetNamespace 

func (x *RespondActivityTaskFailedRequest) GetNamespace() string

func (*RespondActivityTaskFailedRequest) GetTaskToken 

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

func (*RespondActivityTaskFailedRequest) ProtoMessage 

func (*RespondActivityTaskFailedRequest) ProtoMessage()

func (*RespondActivityTaskFailedRequest) ProtoReflect 

func (x *RespondActivityTaskFailedRequest) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskFailedRequest) Reset 

func (x *RespondActivityTaskFailedRequest) Reset()

func (*RespondActivityTaskFailedRequest) String 

func (x *RespondActivityTaskFailedRequest) String() string

type RespondActivityTaskFailedResponse 

type RespondActivityTaskFailedResponse struct {

	// Server validation failures could include
	// last_heartbeat_details payload is too large, request failure is too large
	Failures []*v15.Failure `protobuf:"bytes,1,rep,name=failures,proto3" json:"failures,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondActivityTaskFailedResponse) Descriptor deprecated 

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

Deprecated: Use RespondActivityTaskFailedResponse.ProtoReflect.Descriptor instead.

func (*RespondActivityTaskFailedResponse) GetFailures 

func (x *RespondActivityTaskFailedResponse) GetFailures() []*v15.Failure

func (*RespondActivityTaskFailedResponse) ProtoMessage 

func (*RespondActivityTaskFailedResponse) ProtoMessage()

func (*RespondActivityTaskFailedResponse) ProtoReflect 

func (x *RespondActivityTaskFailedResponse) ProtoReflect() protoreflect.Message

func (*RespondActivityTaskFailedResponse) Reset 

func (x *RespondActivityTaskFailedResponse) Reset()

func (*RespondActivityTaskFailedResponse) String 

func (x *RespondActivityTaskFailedResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*RespondQueryTaskCompletedRequest) Descriptor deprecated 

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

Deprecated: Use RespondQueryTaskCompletedRequest.ProtoReflect.Descriptor instead.

func (*RespondQueryTaskCompletedRequest) GetCompletedType 

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

func (*RespondQueryTaskCompletedRequest) GetErrorMessage 

func (x *RespondQueryTaskCompletedRequest) GetErrorMessage() string

func (*RespondQueryTaskCompletedRequest) GetNamespace 

func (x *RespondQueryTaskCompletedRequest) GetNamespace() string

func (*RespondQueryTaskCompletedRequest) GetQueryResult 

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

func (*RespondQueryTaskCompletedRequest) GetTaskToken 

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

func (*RespondQueryTaskCompletedRequest) ProtoMessage 

func (*RespondQueryTaskCompletedRequest) ProtoMessage()

func (*RespondQueryTaskCompletedRequest) ProtoReflect 

func (x *RespondQueryTaskCompletedRequest) ProtoReflect() protoreflect.Message

func (*RespondQueryTaskCompletedRequest) Reset 

func (x *RespondQueryTaskCompletedRequest) Reset()

func (*RespondQueryTaskCompletedRequest) String 

func (x *RespondQueryTaskCompletedRequest) String() string

type RespondQueryTaskCompletedResponse 

type RespondQueryTaskCompletedResponse struct {
	// contains filtered or unexported fields
}

func (*RespondQueryTaskCompletedResponse) Descriptor deprecated 

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

Deprecated: Use RespondQueryTaskCompletedResponse.ProtoReflect.Descriptor instead.

func (*RespondQueryTaskCompletedResponse) ProtoMessage 

func (*RespondQueryTaskCompletedResponse) ProtoMessage()

func (*RespondQueryTaskCompletedResponse) ProtoReflect 

func (x *RespondQueryTaskCompletedResponse) ProtoReflect() protoreflect.Message

func (*RespondQueryTaskCompletedResponse) Reset 

func (x *RespondQueryTaskCompletedResponse) Reset()

func (*RespondQueryTaskCompletedResponse) String 

func (x *RespondQueryTaskCompletedResponse) String() string

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 []*v19.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]*v17.WorkflowQueryResult `` /* 185-byte string literal not displayed */
	Namespace    string                              `protobuf:"bytes,9,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// If using versioning, the worker uses this field to indicate what version(s) it used to
	// process the task. When this field has a `worker_build_id`, and `binary_checksum` is not set,
	// that value should also be considered as the `binary_checksum`. Leaving this field empty when
	// replying to a task has had this field previously populated in history in an error, and such
	// a completion will be rejected.
	WorkerVersionStamp *v13.WorkerVersionStamp `protobuf:"bytes,10,opt,name=worker_version_stamp,json=workerVersionStamp,proto3" json:"worker_version_stamp,omitempty"`
	// Protocol messages piggybacking on a WFT as a transport
	Messages []*v18.Message `protobuf:"bytes,11,rep,name=messages,proto3" json:"messages,omitempty"`
	// Data the SDK wishes to record for itself, but server need not interpret, and does not
	// directly impact workflow state.
	SdkMetadata *v110.WorkflowTaskCompletedMetadata `protobuf:"bytes,12,opt,name=sdk_metadata,json=sdkMetadata,proto3" json:"sdk_metadata,omitempty"`
	// Local usage data collected for metering
	MeteringMetadata *v13.MeteringMetadata `protobuf:"bytes,13,opt,name=metering_metadata,json=meteringMetadata,proto3" json:"metering_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondWorkflowTaskCompletedRequest) Descriptor deprecated 

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

Deprecated: Use RespondWorkflowTaskCompletedRequest.ProtoReflect.Descriptor instead.

func (*RespondWorkflowTaskCompletedRequest) GetBinaryChecksum 

func (x *RespondWorkflowTaskCompletedRequest) GetBinaryChecksum() string

func (*RespondWorkflowTaskCompletedRequest) GetCommands 

func (x *RespondWorkflowTaskCompletedRequest) GetCommands() []*v19.Command

func (*RespondWorkflowTaskCompletedRequest) GetForceCreateNewWorkflowTask 

func (x *RespondWorkflowTaskCompletedRequest) GetForceCreateNewWorkflowTask() bool

func (*RespondWorkflowTaskCompletedRequest) GetIdentity 

func (x *RespondWorkflowTaskCompletedRequest) GetIdentity() string

func (*RespondWorkflowTaskCompletedRequest) GetMessages 

func (x *RespondWorkflowTaskCompletedRequest) GetMessages() []*v18.Message

func (*RespondWorkflowTaskCompletedRequest) GetMeteringMetadata 

func (x *RespondWorkflowTaskCompletedRequest) GetMeteringMetadata() *v13.MeteringMetadata

func (*RespondWorkflowTaskCompletedRequest) GetNamespace 

func (x *RespondWorkflowTaskCompletedRequest) GetNamespace() string

func (*RespondWorkflowTaskCompletedRequest) GetQueryResults 

func (x *RespondWorkflowTaskCompletedRequest) GetQueryResults() map[string]*v17.WorkflowQueryResult

func (*RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask 

func (x *RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask() bool

func (*RespondWorkflowTaskCompletedRequest) GetSdkMetadata 

func (x *RespondWorkflowTaskCompletedRequest) GetSdkMetadata() *v110.WorkflowTaskCompletedMetadata

func (*RespondWorkflowTaskCompletedRequest) GetStickyAttributes 

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

func (*RespondWorkflowTaskCompletedRequest) GetTaskToken 

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

func (*RespondWorkflowTaskCompletedRequest) GetWorkerVersionStamp 

func (x *RespondWorkflowTaskCompletedRequest) GetWorkerVersionStamp() *v13.WorkerVersionStamp

func (*RespondWorkflowTaskCompletedRequest) ProtoMessage 

func (*RespondWorkflowTaskCompletedRequest) ProtoMessage()

func (*RespondWorkflowTaskCompletedRequest) ProtoReflect 

func (x *RespondWorkflowTaskCompletedRequest) ProtoReflect() protoreflect.Message

func (*RespondWorkflowTaskCompletedRequest) Reset 

func (x *RespondWorkflowTaskCompletedRequest) Reset()

func (*RespondWorkflowTaskCompletedRequest) String 

func (x *RespondWorkflowTaskCompletedRequest) String() string

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"`
	// See `ScheduleActivityTaskCommandAttributes::request_start`
	ActivityTasks       []*PollActivityTaskQueueResponse `protobuf:"bytes,2,rep,name=activity_tasks,json=activityTasks,proto3" json:"activity_tasks,omitempty"`
	ResetHistoryEventId int64                            `protobuf:"varint,3,opt,name=reset_history_event_id,json=resetHistoryEventId,proto3" json:"reset_history_event_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondWorkflowTaskCompletedResponse) Descriptor deprecated 

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

Deprecated: Use RespondWorkflowTaskCompletedResponse.ProtoReflect.Descriptor instead.

func (*RespondWorkflowTaskCompletedResponse) GetActivityTasks 

func (x *RespondWorkflowTaskCompletedResponse) GetActivityTasks() []*PollActivityTaskQueueResponse

func (*RespondWorkflowTaskCompletedResponse) GetResetHistoryEventId 

func (x *RespondWorkflowTaskCompletedResponse) GetResetHistoryEventId() int64

func (*RespondWorkflowTaskCompletedResponse) GetWorkflowTask 

func (x *RespondWorkflowTaskCompletedResponse) GetWorkflowTask() *PollWorkflowTaskQueueResponse

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage 

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage()

func (*RespondWorkflowTaskCompletedResponse) ProtoReflect 

func (x *RespondWorkflowTaskCompletedResponse) ProtoReflect() protoreflect.Message

func (*RespondWorkflowTaskCompletedResponse) Reset 

func (x *RespondWorkflowTaskCompletedResponse) Reset()

func (*RespondWorkflowTaskCompletedResponse) String 

func (x *RespondWorkflowTaskCompletedResponse) String() string

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 *v15.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"`
	// Protocol messages piggybacking on a WFT as a transport
	Messages []*v18.Message `protobuf:"bytes,7,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondWorkflowTaskFailedRequest) Descriptor deprecated 

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

Deprecated: Use RespondWorkflowTaskFailedRequest.ProtoReflect.Descriptor instead.

func (*RespondWorkflowTaskFailedRequest) GetBinaryChecksum 

func (x *RespondWorkflowTaskFailedRequest) GetBinaryChecksum() string

func (*RespondWorkflowTaskFailedRequest) GetCause 

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

func (*RespondWorkflowTaskFailedRequest) GetFailure 

func (x *RespondWorkflowTaskFailedRequest) GetFailure() *v15.Failure

func (*RespondWorkflowTaskFailedRequest) GetIdentity 

func (x *RespondWorkflowTaskFailedRequest) GetIdentity() string

func (*RespondWorkflowTaskFailedRequest) GetMessages 

func (x *RespondWorkflowTaskFailedRequest) GetMessages() []*v18.Message

func (*RespondWorkflowTaskFailedRequest) GetNamespace 

func (x *RespondWorkflowTaskFailedRequest) GetNamespace() string

func (*RespondWorkflowTaskFailedRequest) GetTaskToken 

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

func (*RespondWorkflowTaskFailedRequest) ProtoMessage 

func (*RespondWorkflowTaskFailedRequest) ProtoMessage()

func (*RespondWorkflowTaskFailedRequest) ProtoReflect 

func (x *RespondWorkflowTaskFailedRequest) ProtoReflect() protoreflect.Message

func (*RespondWorkflowTaskFailedRequest) Reset 

func (x *RespondWorkflowTaskFailedRequest) Reset()

func (*RespondWorkflowTaskFailedRequest) String 

func (x *RespondWorkflowTaskFailedRequest) String() string

type RespondWorkflowTaskFailedResponse 

type RespondWorkflowTaskFailedResponse struct {
	// contains filtered or unexported fields
}

func (*RespondWorkflowTaskFailedResponse) Descriptor deprecated 

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

Deprecated: Use RespondWorkflowTaskFailedResponse.ProtoReflect.Descriptor instead.

func (*RespondWorkflowTaskFailedResponse) ProtoMessage 

func (*RespondWorkflowTaskFailedResponse) ProtoMessage()

func (*RespondWorkflowTaskFailedResponse) ProtoReflect 

func (x *RespondWorkflowTaskFailedResponse) ProtoReflect() protoreflect.Message

func (*RespondWorkflowTaskFailedResponse) Reset 

func (x *RespondWorkflowTaskFailedResponse) Reset()

func (*RespondWorkflowTaskFailedResponse) String 

func (x *RespondWorkflowTaskFailedResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*ScanWorkflowExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use ScanWorkflowExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ScanWorkflowExecutionsRequest) GetNamespace 

func (x *ScanWorkflowExecutionsRequest) GetNamespace() string

func (*ScanWorkflowExecutionsRequest) GetNextPageToken 

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

func (*ScanWorkflowExecutionsRequest) GetPageSize 

func (x *ScanWorkflowExecutionsRequest) GetPageSize() int32

func (*ScanWorkflowExecutionsRequest) GetQuery 

func (x *ScanWorkflowExecutionsRequest) GetQuery() string

func (*ScanWorkflowExecutionsRequest) ProtoMessage 

func (*ScanWorkflowExecutionsRequest) ProtoMessage()

func (*ScanWorkflowExecutionsRequest) ProtoReflect 

func (x *ScanWorkflowExecutionsRequest) ProtoReflect() protoreflect.Message

func (*ScanWorkflowExecutionsRequest) Reset 

func (x *ScanWorkflowExecutionsRequest) Reset()

func (*ScanWorkflowExecutionsRequest) String 

func (x *ScanWorkflowExecutionsRequest) String() string

type ScanWorkflowExecutionsResponse 

type ScanWorkflowExecutionsResponse struct {
	Executions    []*v112.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"`
	// contains filtered or unexported fields
}

func (*ScanWorkflowExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use ScanWorkflowExecutionsResponse.ProtoReflect.Descriptor instead.

func (*ScanWorkflowExecutionsResponse) GetExecutions 

func (x *ScanWorkflowExecutionsResponse) GetExecutions() []*v112.WorkflowExecutionInfo

func (*ScanWorkflowExecutionsResponse) GetNextPageToken 

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

func (*ScanWorkflowExecutionsResponse) ProtoMessage 

func (*ScanWorkflowExecutionsResponse) ProtoMessage()

func (*ScanWorkflowExecutionsResponse) ProtoReflect 

func (x *ScanWorkflowExecutionsResponse) ProtoReflect() protoreflect.Message

func (*ScanWorkflowExecutionsResponse) Reset 

func (x *ScanWorkflowExecutionsResponse) Reset()

func (*ScanWorkflowExecutionsResponse) String 

func (x *ScanWorkflowExecutionsResponse) String() string

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 *durationpb.Duration `` /* 135-byte string literal not displayed */
	// Timeout of a single workflow run
	WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	// Timeout of a single workflow task
	WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	// 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"`
	// Time to wait before dispatching the first workflow task. Cannot be used with `cron_schedule`.
	// Note that the signal will be delivered with the first workflow task. If the workflow gets
	// another SignalWithStartWorkflow before the delay and `skip_generate_workflow_task` is false
	// or not set, a workflow task will be dispatched immediately and the rest of the delay period
	// will be ignored, even if that request also had a delay. Signal via SignalWorkflowExecution
	// will not unblock the workflow.
	WorkflowStartDelay *durationpb.Duration `protobuf:"bytes,20,opt,name=workflow_start_delay,json=workflowStartDelay,proto3" json:"workflow_start_delay,omitempty"`
	// Indicates that a new workflow task should not be generated when this signal is received.
	SkipGenerateWorkflowTask bool `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SignalWithStartWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use SignalWithStartWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*SignalWithStartWorkflowExecutionRequest) GetControl 

func (x *SignalWithStartWorkflowExecutionRequest) GetControl() string

func (*SignalWithStartWorkflowExecutionRequest) GetCronSchedule 

func (x *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() string

func (*SignalWithStartWorkflowExecutionRequest) GetHeader 

func (x *SignalWithStartWorkflowExecutionRequest) GetHeader() *v13.Header

func (*SignalWithStartWorkflowExecutionRequest) GetIdentity 

func (x *SignalWithStartWorkflowExecutionRequest) GetIdentity() string

func (*SignalWithStartWorkflowExecutionRequest) GetInput 

func (x *SignalWithStartWorkflowExecutionRequest) GetInput() *v13.Payloads

func (*SignalWithStartWorkflowExecutionRequest) GetMemo 

func (x *SignalWithStartWorkflowExecutionRequest) GetMemo() *v13.Memo

func (*SignalWithStartWorkflowExecutionRequest) GetNamespace 

func (x *SignalWithStartWorkflowExecutionRequest) GetNamespace() string

func (*SignalWithStartWorkflowExecutionRequest) GetRequestId 

func (x *SignalWithStartWorkflowExecutionRequest) GetRequestId() string

func (*SignalWithStartWorkflowExecutionRequest) GetRetryPolicy 

func (x *SignalWithStartWorkflowExecutionRequest) GetRetryPolicy() *v13.RetryPolicy

func (*SignalWithStartWorkflowExecutionRequest) GetSearchAttributes 

func (x *SignalWithStartWorkflowExecutionRequest) GetSearchAttributes() *v13.SearchAttributes

func (*SignalWithStartWorkflowExecutionRequest) GetSignalInput 

func (x *SignalWithStartWorkflowExecutionRequest) GetSignalInput() *v13.Payloads

func (*SignalWithStartWorkflowExecutionRequest) GetSignalName 

func (x *SignalWithStartWorkflowExecutionRequest) GetSignalName() string

func (*SignalWithStartWorkflowExecutionRequest) GetSkipGenerateWorkflowTask 

func (x *SignalWithStartWorkflowExecutionRequest) GetSkipGenerateWorkflowTask() bool

func (*SignalWithStartWorkflowExecutionRequest) GetTaskQueue 

func (x *SignalWithStartWorkflowExecutionRequest) GetTaskQueue() *v14.TaskQueue

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout 

func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *durationpb.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowId 

func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowId() string

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy 

func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy() v11.WorkflowIdReusePolicy

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout 

func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowRunTimeout() *durationpb.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowStartDelay 

func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowStartDelay() *durationpb.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout 

func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *durationpb.Duration

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowType 

func (x *SignalWithStartWorkflowExecutionRequest) GetWorkflowType() *v13.WorkflowType

func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage 

func (*SignalWithStartWorkflowExecutionRequest) ProtoMessage()

func (*SignalWithStartWorkflowExecutionRequest) ProtoReflect 

func (x *SignalWithStartWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*SignalWithStartWorkflowExecutionRequest) Reset 

func (x *SignalWithStartWorkflowExecutionRequest) Reset()

func (*SignalWithStartWorkflowExecutionRequest) String 

func (x *SignalWithStartWorkflowExecutionRequest) String() string

type SignalWithStartWorkflowExecutionResponse 

type SignalWithStartWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalWithStartWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use SignalWithStartWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*SignalWithStartWorkflowExecutionResponse) GetRunId 

func (x *SignalWithStartWorkflowExecutionResponse) GetRunId() string

func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage 

func (*SignalWithStartWorkflowExecutionResponse) ProtoMessage()

func (*SignalWithStartWorkflowExecutionResponse) ProtoReflect 

func (x *SignalWithStartWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*SignalWithStartWorkflowExecutionResponse) Reset 

func (x *SignalWithStartWorkflowExecutionResponse) Reset()

func (*SignalWithStartWorkflowExecutionResponse) String 

func (x *SignalWithStartWorkflowExecutionResponse) String() string

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"`
	// Indicates that a new workflow task should not be generated when this signal is received.
	SkipGenerateWorkflowTask bool `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SignalWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use SignalWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*SignalWorkflowExecutionRequest) GetControl 

func (x *SignalWorkflowExecutionRequest) GetControl() string

func (*SignalWorkflowExecutionRequest) GetHeader 

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

func (*SignalWorkflowExecutionRequest) GetIdentity 

func (x *SignalWorkflowExecutionRequest) GetIdentity() string

func (*SignalWorkflowExecutionRequest) GetInput 

func (x *SignalWorkflowExecutionRequest) GetInput() *v13.Payloads

func (*SignalWorkflowExecutionRequest) GetNamespace 

func (x *SignalWorkflowExecutionRequest) GetNamespace() string

func (*SignalWorkflowExecutionRequest) GetRequestId 

func (x *SignalWorkflowExecutionRequest) GetRequestId() string

func (*SignalWorkflowExecutionRequest) GetSignalName 

func (x *SignalWorkflowExecutionRequest) GetSignalName() string

func (*SignalWorkflowExecutionRequest) GetSkipGenerateWorkflowTask 

func (x *SignalWorkflowExecutionRequest) GetSkipGenerateWorkflowTask() bool

func (*SignalWorkflowExecutionRequest) GetWorkflowExecution 

func (x *SignalWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

func (*SignalWorkflowExecutionRequest) ProtoMessage 

func (*SignalWorkflowExecutionRequest) ProtoMessage()

func (*SignalWorkflowExecutionRequest) ProtoReflect 

func (x *SignalWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*SignalWorkflowExecutionRequest) Reset 

func (x *SignalWorkflowExecutionRequest) Reset()

func (*SignalWorkflowExecutionRequest) String 

func (x *SignalWorkflowExecutionRequest) String() string

type SignalWorkflowExecutionResponse 

type SignalWorkflowExecutionResponse struct {
	// contains filtered or unexported fields
}

func (*SignalWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use SignalWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*SignalWorkflowExecutionResponse) ProtoMessage 

func (*SignalWorkflowExecutionResponse) ProtoMessage()

func (*SignalWorkflowExecutionResponse) ProtoReflect 

func (x *SignalWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*SignalWorkflowExecutionResponse) Reset 

func (x *SignalWorkflowExecutionResponse) Reset()

func (*SignalWorkflowExecutionResponse) String 

func (x *SignalWorkflowExecutionResponse) String() string

type StartBatchOperationRequest 

type StartBatchOperationRequest struct {

	// Namespace that contains the batch operation
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Visibility query defines the the group of workflow to apply the batch operation
	// This field and Executions are mutually exclusive
	VisibilityQuery string `protobuf:"bytes,2,opt,name=visibility_query,json=visibilityQuery,proto3" json:"visibility_query,omitempty"`
	// Job ID defines the unique ID for the batch job
	JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Reason to perform the batch operation
	Reason string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// Executions to apply the batch operation
	// This field and VisibilityQuery are mutually exclusive
	Executions []*v13.WorkflowExecution `protobuf:"bytes,5,rep,name=executions,proto3" json:"executions,omitempty"`
	// Operation input
	//
	// Types that are assignable to Operation:
	//
	//	*StartBatchOperationRequest_TerminationOperation
	//	*StartBatchOperationRequest_SignalOperation
	//	*StartBatchOperationRequest_CancellationOperation
	//	*StartBatchOperationRequest_DeletionOperation
	Operation isStartBatchOperationRequest_Operation `protobuf_oneof:"operation"`
	// contains filtered or unexported fields
}

func (*StartBatchOperationRequest) Descriptor deprecated 

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

Deprecated: Use StartBatchOperationRequest.ProtoReflect.Descriptor instead.

func (*StartBatchOperationRequest) GetCancellationOperation 

func (x *StartBatchOperationRequest) GetCancellationOperation() *v116.BatchOperationCancellation

func (*StartBatchOperationRequest) GetDeletionOperation 

func (x *StartBatchOperationRequest) GetDeletionOperation() *v116.BatchOperationDeletion

func (*StartBatchOperationRequest) GetExecutions 

func (x *StartBatchOperationRequest) GetExecutions() []*v13.WorkflowExecution

func (*StartBatchOperationRequest) GetJobId 

func (x *StartBatchOperationRequest) GetJobId() string

func (*StartBatchOperationRequest) GetNamespace 

func (x *StartBatchOperationRequest) GetNamespace() string

func (*StartBatchOperationRequest) GetOperation 

func (m *StartBatchOperationRequest) GetOperation() isStartBatchOperationRequest_Operation

func (*StartBatchOperationRequest) GetReason 

func (x *StartBatchOperationRequest) GetReason() string

func (*StartBatchOperationRequest) GetSignalOperation 

func (x *StartBatchOperationRequest) GetSignalOperation() *v116.BatchOperationSignal

func (*StartBatchOperationRequest) GetTerminationOperation 

func (x *StartBatchOperationRequest) GetTerminationOperation() *v116.BatchOperationTermination

func (*StartBatchOperationRequest) GetVisibilityQuery 

func (x *StartBatchOperationRequest) GetVisibilityQuery() string

func (*StartBatchOperationRequest) ProtoMessage 

func (*StartBatchOperationRequest) ProtoMessage()

func (*StartBatchOperationRequest) ProtoReflect 

func (x *StartBatchOperationRequest) ProtoReflect() protoreflect.Message

func (*StartBatchOperationRequest) Reset 

func (x *StartBatchOperationRequest) Reset()

func (*StartBatchOperationRequest) String 

func (x *StartBatchOperationRequest) String() string

type StartBatchOperationRequest_CancellationOperation 

type StartBatchOperationRequest_CancellationOperation struct {
	CancellationOperation *v116.BatchOperationCancellation `protobuf:"bytes,12,opt,name=cancellation_operation,json=cancellationOperation,proto3,oneof"`
}

type StartBatchOperationRequest_DeletionOperation 

type StartBatchOperationRequest_DeletionOperation struct {
	DeletionOperation *v116.BatchOperationDeletion `protobuf:"bytes,13,opt,name=deletion_operation,json=deletionOperation,proto3,oneof"`
}

type StartBatchOperationRequest_SignalOperation 

type StartBatchOperationRequest_SignalOperation struct {
	SignalOperation *v116.BatchOperationSignal `protobuf:"bytes,11,opt,name=signal_operation,json=signalOperation,proto3,oneof"`
}

type StartBatchOperationRequest_TerminationOperation 

type StartBatchOperationRequest_TerminationOperation struct {
	TerminationOperation *v116.BatchOperationTermination `protobuf:"bytes,10,opt,name=termination_operation,json=terminationOperation,proto3,oneof"`
}

type StartBatchOperationResponse 

type StartBatchOperationResponse struct {
	// contains filtered or unexported fields
}

func (*StartBatchOperationResponse) Descriptor deprecated 

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

Deprecated: Use StartBatchOperationResponse.ProtoReflect.Descriptor instead.

func (*StartBatchOperationResponse) ProtoMessage 

func (*StartBatchOperationResponse) ProtoMessage()

func (*StartBatchOperationResponse) ProtoReflect 

func (x *StartBatchOperationResponse) ProtoReflect() protoreflect.Message

func (*StartBatchOperationResponse) Reset 

func (x *StartBatchOperationResponse) Reset()

func (*StartBatchOperationResponse) String 

func (x *StartBatchOperationResponse) String() string

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 *durationpb.Duration `` /* 135-byte string literal not displayed */
	// Timeout of a single workflow run.
	WorkflowRunTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=workflow_run_timeout,json=workflowRunTimeout,proto3" json:"workflow_run_timeout,omitempty"`
	// Timeout of a single workflow task.
	WorkflowTaskTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=workflow_task_timeout,json=workflowTaskTimeout,proto3" json:"workflow_task_timeout,omitempty"`
	// 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"`
	// Request to get the first workflow task inline in the response bypassing matching service and worker polling.
	// If set to `true` the caller is expected to have a worker available and capable of processing the task.
	// The returned task will be marked as started and is expected to be completed by the specified
	// `workflow_task_timeout`.
	RequestEagerExecution bool `` /* 128-byte string literal not displayed */
	// These values will be available as ContinuedFailure and LastCompletionResult in the
	// WorkflowExecutionStarted event and through SDKs. The are currently only used by the
	// server itself (for the schedules feature) and are not intended to be exposed in
	// StartWorkflowExecution.
	ContinuedFailure     *v15.Failure  `protobuf:"bytes,18,opt,name=continued_failure,json=continuedFailure,proto3" json:"continued_failure,omitempty"`
	LastCompletionResult *v13.Payloads `protobuf:"bytes,19,opt,name=last_completion_result,json=lastCompletionResult,proto3" json:"last_completion_result,omitempty"`
	// Time to wait before dispatching the first workflow task. Cannot be used with `cron_schedule`.
	// If the workflow gets a signal before the delay, a workflow task will be dispatched and the rest
	// of the delay will be ignored.
	WorkflowStartDelay *durationpb.Duration `protobuf:"bytes,20,opt,name=workflow_start_delay,json=workflowStartDelay,proto3" json:"workflow_start_delay,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use StartWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*StartWorkflowExecutionRequest) GetContinuedFailure 

func (x *StartWorkflowExecutionRequest) GetContinuedFailure() *v15.Failure

func (*StartWorkflowExecutionRequest) GetCronSchedule 

func (x *StartWorkflowExecutionRequest) GetCronSchedule() string

func (*StartWorkflowExecutionRequest) GetHeader 

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

func (*StartWorkflowExecutionRequest) GetIdentity 

func (x *StartWorkflowExecutionRequest) GetIdentity() string

func (*StartWorkflowExecutionRequest) GetInput 

func (x *StartWorkflowExecutionRequest) GetInput() *v13.Payloads

func (*StartWorkflowExecutionRequest) GetLastCompletionResult 

func (x *StartWorkflowExecutionRequest) GetLastCompletionResult() *v13.Payloads

func (*StartWorkflowExecutionRequest) GetMemo 

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

func (*StartWorkflowExecutionRequest) GetNamespace 

func (x *StartWorkflowExecutionRequest) GetNamespace() string

func (*StartWorkflowExecutionRequest) GetRequestEagerExecution 

func (x *StartWorkflowExecutionRequest) GetRequestEagerExecution() bool

func (*StartWorkflowExecutionRequest) GetRequestId 

func (x *StartWorkflowExecutionRequest) GetRequestId() string

func (*StartWorkflowExecutionRequest) GetRetryPolicy 

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

func (*StartWorkflowExecutionRequest) GetSearchAttributes 

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

func (*StartWorkflowExecutionRequest) GetTaskQueue 

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

func (*StartWorkflowExecutionRequest) GetWorkflowExecutionTimeout 

func (x *StartWorkflowExecutionRequest) GetWorkflowExecutionTimeout() *durationpb.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowId 

func (x *StartWorkflowExecutionRequest) GetWorkflowId() string

func (*StartWorkflowExecutionRequest) GetWorkflowIdReusePolicy 

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

func (*StartWorkflowExecutionRequest) GetWorkflowRunTimeout 

func (x *StartWorkflowExecutionRequest) GetWorkflowRunTimeout() *durationpb.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowStartDelay 

func (x *StartWorkflowExecutionRequest) GetWorkflowStartDelay() *durationpb.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowTaskTimeout 

func (x *StartWorkflowExecutionRequest) GetWorkflowTaskTimeout() *durationpb.Duration

func (*StartWorkflowExecutionRequest) GetWorkflowType 

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

func (*StartWorkflowExecutionRequest) ProtoMessage 

func (*StartWorkflowExecutionRequest) ProtoMessage()

func (*StartWorkflowExecutionRequest) ProtoReflect 

func (x *StartWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*StartWorkflowExecutionRequest) Reset 

func (x *StartWorkflowExecutionRequest) Reset()

func (*StartWorkflowExecutionRequest) String 

func (x *StartWorkflowExecutionRequest) String() string

type StartWorkflowExecutionResponse 

type StartWorkflowExecutionResponse struct {
	RunId string `protobuf:"bytes,1,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// When `request_eager_execution` is set on the `StartWorkflowExecutionRequest`, the server - if supported - will
	// return the first workflow task to be eagerly executed.
	// The caller is expected to have a worker available to process the task.
	EagerWorkflowTask *PollWorkflowTaskQueueResponse `protobuf:"bytes,2,opt,name=eager_workflow_task,json=eagerWorkflowTask,proto3" json:"eager_workflow_task,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use StartWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*StartWorkflowExecutionResponse) GetEagerWorkflowTask 

func (x *StartWorkflowExecutionResponse) GetEagerWorkflowTask() *PollWorkflowTaskQueueResponse

func (*StartWorkflowExecutionResponse) GetRunId 

func (x *StartWorkflowExecutionResponse) GetRunId() string

func (*StartWorkflowExecutionResponse) ProtoMessage 

func (*StartWorkflowExecutionResponse) ProtoMessage()

func (*StartWorkflowExecutionResponse) ProtoReflect 

func (x *StartWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*StartWorkflowExecutionResponse) Reset 

func (x *StartWorkflowExecutionResponse) Reset()

func (*StartWorkflowExecutionResponse) String 

func (x *StartWorkflowExecutionResponse) String() string

type StopBatchOperationRequest 

type StopBatchOperationRequest struct {

	// Namespace that contains the batch operation
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Batch job id
	JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Reason to stop a batch operation
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// Identity of the operator
	Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// contains filtered or unexported fields
}

func (*StopBatchOperationRequest) Descriptor deprecated 

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

Deprecated: Use StopBatchOperationRequest.ProtoReflect.Descriptor instead.

func (*StopBatchOperationRequest) GetIdentity 

func (x *StopBatchOperationRequest) GetIdentity() string

func (*StopBatchOperationRequest) GetJobId 

func (x *StopBatchOperationRequest) GetJobId() string

func (*StopBatchOperationRequest) GetNamespace 

func (x *StopBatchOperationRequest) GetNamespace() string

func (*StopBatchOperationRequest) GetReason 

func (x *StopBatchOperationRequest) GetReason() string

func (*StopBatchOperationRequest) ProtoMessage 

func (*StopBatchOperationRequest) ProtoMessage()

func (*StopBatchOperationRequest) ProtoReflect 

func (x *StopBatchOperationRequest) ProtoReflect() protoreflect.Message

func (*StopBatchOperationRequest) Reset 

func (x *StopBatchOperationRequest) Reset()

func (*StopBatchOperationRequest) String 

func (x *StopBatchOperationRequest) String() string

type StopBatchOperationResponse 

type StopBatchOperationResponse struct {
	// contains filtered or unexported fields
}

func (*StopBatchOperationResponse) Descriptor deprecated 

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

Deprecated: Use StopBatchOperationResponse.ProtoReflect.Descriptor instead.

func (*StopBatchOperationResponse) ProtoMessage 

func (*StopBatchOperationResponse) ProtoMessage()

func (*StopBatchOperationResponse) ProtoReflect 

func (x *StopBatchOperationResponse) ProtoReflect() protoreflect.Message

func (*StopBatchOperationResponse) Reset 

func (x *StopBatchOperationResponse) Reset()

func (*StopBatchOperationResponse) String 

func (x *StopBatchOperationResponse) String() string

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"`
	// contains filtered or unexported fields
}

func (*TerminateWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use TerminateWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*TerminateWorkflowExecutionRequest) GetDetails 

func (x *TerminateWorkflowExecutionRequest) GetDetails() *v13.Payloads

func (*TerminateWorkflowExecutionRequest) GetFirstExecutionRunId 

func (x *TerminateWorkflowExecutionRequest) GetFirstExecutionRunId() string

func (*TerminateWorkflowExecutionRequest) GetIdentity 

func (x *TerminateWorkflowExecutionRequest) GetIdentity() string

func (*TerminateWorkflowExecutionRequest) GetNamespace 

func (x *TerminateWorkflowExecutionRequest) GetNamespace() string

func (*TerminateWorkflowExecutionRequest) GetReason 

func (x *TerminateWorkflowExecutionRequest) GetReason() string

func (*TerminateWorkflowExecutionRequest) GetWorkflowExecution 

func (x *TerminateWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

func (*TerminateWorkflowExecutionRequest) ProtoMessage 

func (*TerminateWorkflowExecutionRequest) ProtoMessage()

func (*TerminateWorkflowExecutionRequest) ProtoReflect 

func (x *TerminateWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*TerminateWorkflowExecutionRequest) Reset 

func (x *TerminateWorkflowExecutionRequest) Reset()

func (*TerminateWorkflowExecutionRequest) String 

func (x *TerminateWorkflowExecutionRequest) String() string

type TerminateWorkflowExecutionResponse 

type TerminateWorkflowExecutionResponse struct {
	// contains filtered or unexported fields
}

func (*TerminateWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use TerminateWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*TerminateWorkflowExecutionResponse) ProtoMessage 

func (*TerminateWorkflowExecutionResponse) ProtoMessage()

func (*TerminateWorkflowExecutionResponse) ProtoReflect 

func (x *TerminateWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*TerminateWorkflowExecutionResponse) Reset 

func (x *TerminateWorkflowExecutionResponse) Reset()

func (*TerminateWorkflowExecutionResponse) String 

func (x *TerminateWorkflowExecutionResponse) String() string

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"`
	// contains filtered or unexported fields
}

(-- 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 deprecated 

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

Deprecated: Use UpdateNamespaceRequest.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceRequest) GetConfig 

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

func (*UpdateNamespaceRequest) GetDeleteBadBinary 

func (x *UpdateNamespaceRequest) GetDeleteBadBinary() string

func (*UpdateNamespaceRequest) GetNamespace 

func (x *UpdateNamespaceRequest) GetNamespace() string

func (*UpdateNamespaceRequest) GetPromoteNamespace 

func (x *UpdateNamespaceRequest) GetPromoteNamespace() bool

func (*UpdateNamespaceRequest) GetReplicationConfig 

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

func (*UpdateNamespaceRequest) GetSecurityToken 

func (x *UpdateNamespaceRequest) GetSecurityToken() string

func (*UpdateNamespaceRequest) GetUpdateInfo 

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

func (*UpdateNamespaceRequest) ProtoMessage 

func (*UpdateNamespaceRequest) ProtoMessage()

func (*UpdateNamespaceRequest) ProtoReflect 

func (x *UpdateNamespaceRequest) ProtoReflect() protoreflect.Message

func (*UpdateNamespaceRequest) Reset 

func (x *UpdateNamespaceRequest) Reset()

func (*UpdateNamespaceRequest) String 

func (x *UpdateNamespaceRequest) String() string

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"`
	// contains filtered or unexported fields
}

func (*UpdateNamespaceResponse) Descriptor deprecated 

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

Deprecated: Use UpdateNamespaceResponse.ProtoReflect.Descriptor instead.

func (*UpdateNamespaceResponse) GetConfig 

func (x *UpdateNamespaceResponse) GetConfig() *v12.NamespaceConfig

func (*UpdateNamespaceResponse) GetFailoverVersion 

func (x *UpdateNamespaceResponse) GetFailoverVersion() int64

func (*UpdateNamespaceResponse) GetIsGlobalNamespace 

func (x *UpdateNamespaceResponse) GetIsGlobalNamespace() bool

func (*UpdateNamespaceResponse) GetNamespaceInfo 

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

func (*UpdateNamespaceResponse) GetReplicationConfig 

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

func (*UpdateNamespaceResponse) ProtoMessage 

func (*UpdateNamespaceResponse) ProtoMessage()

func (*UpdateNamespaceResponse) ProtoReflect 

func (x *UpdateNamespaceResponse) ProtoReflect() protoreflect.Message

func (*UpdateNamespaceResponse) Reset 

func (x *UpdateNamespaceResponse) Reset()

func (*UpdateNamespaceResponse) String 

func (x *UpdateNamespaceResponse) String() string

type UpdateScheduleRequest 

type UpdateScheduleRequest struct {

	// The namespace of the schedule to update.
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The id of the schedule to update.
	ScheduleId string `protobuf:"bytes,2,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_id,omitempty"`
	// The new schedule. The four main fields of the schedule (spec, action,
	// policies, state) are replaced completely by the values in this message.
	Schedule *v114.Schedule `protobuf:"bytes,3,opt,name=schedule,proto3" json:"schedule,omitempty"`
	// This can be the value of conflict_token from a DescribeScheduleResponse,
	// which will cause this request to fail if the schedule has been modified
	// between the Describe and this Update.
	// If missing, the schedule will be updated unconditionally.
	ConflictToken []byte `protobuf:"bytes,4,opt,name=conflict_token,json=conflictToken,proto3" json:"conflict_token,omitempty"`
	// The identity of the client who initiated this request.
	Identity string `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
	// A unique identifier for this update request for idempotence. Typically UUIDv4.
	RequestId string `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

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

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

func (*UpdateScheduleRequest) Descriptor deprecated 

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

Deprecated: Use UpdateScheduleRequest.ProtoReflect.Descriptor instead.

func (*UpdateScheduleRequest) GetConflictToken 

func (x *UpdateScheduleRequest) GetConflictToken() []byte

func (*UpdateScheduleRequest) GetIdentity 

func (x *UpdateScheduleRequest) GetIdentity() string

func (*UpdateScheduleRequest) GetNamespace 

func (x *UpdateScheduleRequest) GetNamespace() string

func (*UpdateScheduleRequest) GetRequestId 

func (x *UpdateScheduleRequest) GetRequestId() string

func (*UpdateScheduleRequest) GetSchedule 

func (x *UpdateScheduleRequest) GetSchedule() *v114.Schedule

func (*UpdateScheduleRequest) GetScheduleId 

func (x *UpdateScheduleRequest) GetScheduleId() string

func (*UpdateScheduleRequest) ProtoMessage 

func (*UpdateScheduleRequest) ProtoMessage()

func (*UpdateScheduleRequest) ProtoReflect 

func (x *UpdateScheduleRequest) ProtoReflect() protoreflect.Message

func (*UpdateScheduleRequest) Reset 

func (x *UpdateScheduleRequest) Reset()

func (*UpdateScheduleRequest) String 

func (x *UpdateScheduleRequest) String() string

type UpdateScheduleResponse 

type UpdateScheduleResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateScheduleResponse) Descriptor deprecated 

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

Deprecated: Use UpdateScheduleResponse.ProtoReflect.Descriptor instead.

func (*UpdateScheduleResponse) ProtoMessage 

func (*UpdateScheduleResponse) ProtoMessage()

func (*UpdateScheduleResponse) ProtoReflect 

func (x *UpdateScheduleResponse) ProtoReflect() protoreflect.Message

func (*UpdateScheduleResponse) Reset 

func (x *UpdateScheduleResponse) Reset()

func (*UpdateScheduleResponse) String 

func (x *UpdateScheduleResponse) String() string

type UpdateWorkerBuildIdCompatibilityRequest 

type UpdateWorkerBuildIdCompatibilityRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Must be set, the task queue to apply changes to. Because all workers on a given task queue
	// must have the same set of workflow & activity implementations, there is no reason to specify
	// a task queue type here.
	TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Types that are assignable to Operation:
	//
	//	*UpdateWorkerBuildIdCompatibilityRequest_AddNewBuildIdInNewDefaultSet
	//	*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleBuildId
	//	*UpdateWorkerBuildIdCompatibilityRequest_PromoteSetByBuildId
	//	*UpdateWorkerBuildIdCompatibilityRequest_PromoteBuildIdWithinSet
	Operation isUpdateWorkerBuildIdCompatibilityRequest_Operation `protobuf_oneof:"operation"`
	// contains filtered or unexported fields
}

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

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

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

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

func (*UpdateWorkerBuildIdCompatibilityRequest) Descriptor deprecated 

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityRequest) GetAddNewBuildIdInNewDefaultSet 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetAddNewBuildIdInNewDefaultSet() string

func (*UpdateWorkerBuildIdCompatibilityRequest) GetAddNewCompatibleBuildId 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetAddNewCompatibleBuildId() *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion

func (*UpdateWorkerBuildIdCompatibilityRequest) GetNamespace 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetNamespace() string

func (*UpdateWorkerBuildIdCompatibilityRequest) GetOperation 

func (m *UpdateWorkerBuildIdCompatibilityRequest) GetOperation() isUpdateWorkerBuildIdCompatibilityRequest_Operation

func (*UpdateWorkerBuildIdCompatibilityRequest) GetPromoteBuildIdWithinSet 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetPromoteBuildIdWithinSet() string

func (*UpdateWorkerBuildIdCompatibilityRequest) GetPromoteSetByBuildId 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetPromoteSetByBuildId() string

func (*UpdateWorkerBuildIdCompatibilityRequest) GetTaskQueue 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetTaskQueue() string

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoMessage 

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoReflect 

func (x *UpdateWorkerBuildIdCompatibilityRequest) ProtoReflect() protoreflect.Message

func (*UpdateWorkerBuildIdCompatibilityRequest) Reset 

func (x *UpdateWorkerBuildIdCompatibilityRequest) Reset()

func (*UpdateWorkerBuildIdCompatibilityRequest) String 

func (x *UpdateWorkerBuildIdCompatibilityRequest) String() string

type UpdateWorkerBuildIdCompatibilityRequest_AddNewBuildIdInNewDefaultSet 

type UpdateWorkerBuildIdCompatibilityRequest_AddNewBuildIdInNewDefaultSet struct {
	// A new build id. This operation will create a new set which will be the new overall
	// default version for the queue, with this id as its only member. This new set is
	// incompatible with all previous sets/versions.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: In makes perfect sense here. --)
	AddNewBuildIdInNewDefaultSet string `protobuf:"bytes,3,opt,name=add_new_build_id_in_new_default_set,json=addNewBuildIdInNewDefaultSet,proto3,oneof"`
}

type UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleBuildId 

type UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleBuildId struct {
	// Adds a new id to an existing compatible set, see sub-message definition for more.
	AddNewCompatibleBuildId *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion `protobuf:"bytes,4,opt,name=add_new_compatible_build_id,json=addNewCompatibleBuildId,proto3,oneof"`
}

type UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion 

type UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion struct {

	// A new id to be added to an existing compatible set.
	NewBuildId string `protobuf:"bytes,1,opt,name=new_build_id,json=newBuildId,proto3" json:"new_build_id,omitempty"`
	// A build id which must already exist in the version sets known by the task queue. The new
	// id will be stored in the set containing this id, marking it as compatible with
	// the versions within.
	ExistingCompatibleBuildId string `` /* 140-byte string literal not displayed */
	// When set, establishes the compatible set being targeted as the overall default for the
	// queue. If a different set was the current default, the targeted set will replace it as
	// the new default.
	MakeSetDefault bool `protobuf:"varint,3,opt,name=make_set_default,json=makeSetDefault,proto3" json:"make_set_default,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) Descriptor deprecated 

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetExistingCompatibleBuildId 

func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetExistingCompatibleBuildId() string

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetMakeSetDefault 

func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetMakeSetDefault() bool

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetNewBuildId 

func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetNewBuildId() string

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) ProtoMessage 

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) ProtoReflect 

func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) ProtoReflect() protoreflect.Message

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) Reset 

func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) Reset()

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) String 

func (x *UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) String() string

type UpdateWorkerBuildIdCompatibilityRequest_PromoteBuildIdWithinSet 

type UpdateWorkerBuildIdCompatibilityRequest_PromoteBuildIdWithinSet struct {
	// Promote an existing build id within some set to be the current default for that set.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: Within makes perfect sense here. --)
	PromoteBuildIdWithinSet string `protobuf:"bytes,6,opt,name=promote_build_id_within_set,json=promoteBuildIdWithinSet,proto3,oneof"`
}

type UpdateWorkerBuildIdCompatibilityRequest_PromoteSetByBuildId 

type UpdateWorkerBuildIdCompatibilityRequest_PromoteSetByBuildId struct {
	// Promote an existing set to be the current default (if it isn't already) by targeting
	// an existing build id within it. This field's value is the extant build id.
	//
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: Names are hard. --)
	PromoteSetByBuildId string `protobuf:"bytes,5,opt,name=promote_set_by_build_id,json=promoteSetByBuildId,proto3,oneof"`
}

type UpdateWorkerBuildIdCompatibilityResponse 

type UpdateWorkerBuildIdCompatibilityResponse struct {

	// The id of the compatible set that the updated version was added to, or exists in. Users don't
	// need to understand or care about this value, but it has value for debugging purposes.
	VersionSetId string `protobuf:"bytes,1,opt,name=version_set_id,json=versionSetId,proto3" json:"version_set_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkerBuildIdCompatibilityResponse) Descriptor deprecated 

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityResponse) GetVersionSetId 

func (x *UpdateWorkerBuildIdCompatibilityResponse) GetVersionSetId() string

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoMessage 

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoReflect 

func (x *UpdateWorkerBuildIdCompatibilityResponse) ProtoReflect() protoreflect.Message

func (*UpdateWorkerBuildIdCompatibilityResponse) Reset 

func (x *UpdateWorkerBuildIdCompatibilityResponse) Reset()

func (*UpdateWorkerBuildIdCompatibilityResponse) String 

func (x *UpdateWorkerBuildIdCompatibilityResponse) String() string

type UpdateWorkflowExecutionRequest 

type UpdateWorkflowExecutionRequest struct {

	// The namespace name of the target workflow
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The target workflow id and (optionally) a specific run thereof
	// (-- api-linter: core::0203::optional=disabled
	//
	//	aip.dev/not-precedent: false positive triggered by the word "optional" --)
	WorkflowExecution *v13.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,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,3,opt,name=first_execution_run_id,json=firstExecutionRunId,proto3" json:"first_execution_run_id,omitempty"`
	// Describes when this request should return - basically whether the
	// update is synchronous, asynchronous, or somewhere in between.
	WaitPolicy *v115.WaitPolicy `protobuf:"bytes,4,opt,name=wait_policy,json=waitPolicy,proto3" json:"wait_policy,omitempty"`
	// The request information that will be delivered all the way down to the
	// workflow execution.
	Request *v115.Request `protobuf:"bytes,5,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

(-- api-linter: core::0134=disabled 

aip.dev/not-precedent: Update RPCs don't follow Google API format. --)

func (*UpdateWorkflowExecutionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowExecutionRequest) GetFirstExecutionRunId 

func (x *UpdateWorkflowExecutionRequest) GetFirstExecutionRunId() string

func (*UpdateWorkflowExecutionRequest) GetNamespace 

func (x *UpdateWorkflowExecutionRequest) GetNamespace() string

func (*UpdateWorkflowExecutionRequest) GetRequest 

func (x *UpdateWorkflowExecutionRequest) GetRequest() *v115.Request

func (*UpdateWorkflowExecutionRequest) GetWaitPolicy 

func (x *UpdateWorkflowExecutionRequest) GetWaitPolicy() *v115.WaitPolicy

func (*UpdateWorkflowExecutionRequest) GetWorkflowExecution 

func (x *UpdateWorkflowExecutionRequest) GetWorkflowExecution() *v13.WorkflowExecution

func (*UpdateWorkflowExecutionRequest) ProtoMessage 

func (*UpdateWorkflowExecutionRequest) ProtoMessage()

func (*UpdateWorkflowExecutionRequest) ProtoReflect 

func (x *UpdateWorkflowExecutionRequest) ProtoReflect() protoreflect.Message

func (*UpdateWorkflowExecutionRequest) Reset 

func (x *UpdateWorkflowExecutionRequest) Reset()

func (*UpdateWorkflowExecutionRequest) String 

func (x *UpdateWorkflowExecutionRequest) String() string

type UpdateWorkflowExecutionResponse 

type UpdateWorkflowExecutionResponse struct {

	// Enough information for subsequent poll calls if needed. Never null.
	UpdateRef *v115.UpdateRef `protobuf:"bytes,1,opt,name=update_ref,json=updateRef,proto3" json:"update_ref,omitempty"`
	// The outcome of the update if and only if the workflow execution update
	// has completed. If this response is being returned before the update has
	// completed then this field will not be set.
	Outcome *v115.Outcome `protobuf:"bytes,2,opt,name=outcome,proto3" json:"outcome,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkflowExecutionResponse) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowExecutionResponse) GetOutcome 

func (x *UpdateWorkflowExecutionResponse) GetOutcome() *v115.Outcome

func (*UpdateWorkflowExecutionResponse) GetUpdateRef 

func (x *UpdateWorkflowExecutionResponse) GetUpdateRef() *v115.UpdateRef

func (*UpdateWorkflowExecutionResponse) ProtoMessage 

func (*UpdateWorkflowExecutionResponse) ProtoMessage()

func (*UpdateWorkflowExecutionResponse) ProtoReflect 

func (x *UpdateWorkflowExecutionResponse) ProtoReflect() protoreflect.Message

func (*UpdateWorkflowExecutionResponse) Reset 

func (x *UpdateWorkflowExecutionResponse) Reset()

func (*UpdateWorkflowExecutionResponse) String 

func (x *UpdateWorkflowExecutionResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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