workflowservice

package
v4.12.0 Latest Latest
Warning

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

Go to latest
Published: Mar 28, 2024 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source
const (
	WorkflowService_RegisterNamespace_FullMethodName                  = "/temporal.api.workflowservice.v1.WorkflowService/RegisterNamespace"
	WorkflowService_DescribeNamespace_FullMethodName                  = "/temporal.api.workflowservice.v1.WorkflowService/DescribeNamespace"
	WorkflowService_ListNamespaces_FullMethodName                     = "/temporal.api.workflowservice.v1.WorkflowService/ListNamespaces"
	WorkflowService_UpdateNamespace_FullMethodName                    = "/temporal.api.workflowservice.v1.WorkflowService/UpdateNamespace"
	WorkflowService_DeprecateNamespace_FullMethodName                 = "/temporal.api.workflowservice.v1.WorkflowService/DeprecateNamespace"
	WorkflowService_StartWorkflowExecution_FullMethodName             = "/temporal.api.workflowservice.v1.WorkflowService/StartWorkflowExecution"
	WorkflowService_GetWorkflowExecutionHistory_FullMethodName        = "/temporal.api.workflowservice.v1.WorkflowService/GetWorkflowExecutionHistory"
	WorkflowService_GetWorkflowExecutionHistoryReverse_FullMethodName = "/temporal.api.workflowservice.v1.WorkflowService/GetWorkflowExecutionHistoryReverse"
	WorkflowService_PollWorkflowTaskQueue_FullMethodName              = "/temporal.api.workflowservice.v1.WorkflowService/PollWorkflowTaskQueue"
	WorkflowService_RespondWorkflowTaskCompleted_FullMethodName       = "/temporal.api.workflowservice.v1.WorkflowService/RespondWorkflowTaskCompleted"
	WorkflowService_RespondWorkflowTaskFailed_FullMethodName          = "/temporal.api.workflowservice.v1.WorkflowService/RespondWorkflowTaskFailed"
	WorkflowService_PollActivityTaskQueue_FullMethodName              = "/temporal.api.workflowservice.v1.WorkflowService/PollActivityTaskQueue"
	WorkflowService_RecordActivityTaskHeartbeat_FullMethodName        = "/temporal.api.workflowservice.v1.WorkflowService/RecordActivityTaskHeartbeat"
	WorkflowService_RecordActivityTaskHeartbeatById_FullMethodName    = "/temporal.api.workflowservice.v1.WorkflowService/RecordActivityTaskHeartbeatById"
	WorkflowService_RespondActivityTaskCompleted_FullMethodName       = "/temporal.api.workflowservice.v1.WorkflowService/RespondActivityTaskCompleted"
	WorkflowService_RespondActivityTaskCompletedById_FullMethodName   = "/temporal.api.workflowservice.v1.WorkflowService/RespondActivityTaskCompletedById"
	WorkflowService_RespondActivityTaskFailed_FullMethodName          = "/temporal.api.workflowservice.v1.WorkflowService/RespondActivityTaskFailed"
	WorkflowService_RespondActivityTaskFailedById_FullMethodName      = "/temporal.api.workflowservice.v1.WorkflowService/RespondActivityTaskFailedById"
	WorkflowService_RespondActivityTaskCanceled_FullMethodName        = "/temporal.api.workflowservice.v1.WorkflowService/RespondActivityTaskCanceled"
	WorkflowService_RespondActivityTaskCanceledById_FullMethodName    = "/temporal.api.workflowservice.v1.WorkflowService/RespondActivityTaskCanceledById"
	WorkflowService_RequestCancelWorkflowExecution_FullMethodName     = "/temporal.api.workflowservice.v1.WorkflowService/RequestCancelWorkflowExecution"
	WorkflowService_SignalWorkflowExecution_FullMethodName            = "/temporal.api.workflowservice.v1.WorkflowService/SignalWorkflowExecution"
	WorkflowService_SignalWithStartWorkflowExecution_FullMethodName   = "/temporal.api.workflowservice.v1.WorkflowService/SignalWithStartWorkflowExecution"
	WorkflowService_ResetWorkflowExecution_FullMethodName             = "/temporal.api.workflowservice.v1.WorkflowService/ResetWorkflowExecution"
	WorkflowService_TerminateWorkflowExecution_FullMethodName         = "/temporal.api.workflowservice.v1.WorkflowService/TerminateWorkflowExecution"
	WorkflowService_DeleteWorkflowExecution_FullMethodName            = "/temporal.api.workflowservice.v1.WorkflowService/DeleteWorkflowExecution"
	WorkflowService_ListOpenWorkflowExecutions_FullMethodName         = "/temporal.api.workflowservice.v1.WorkflowService/ListOpenWorkflowExecutions"
	WorkflowService_ListClosedWorkflowExecutions_FullMethodName       = "/temporal.api.workflowservice.v1.WorkflowService/ListClosedWorkflowExecutions"
	WorkflowService_ListWorkflowExecutions_FullMethodName             = "/temporal.api.workflowservice.v1.WorkflowService/ListWorkflowExecutions"
	WorkflowService_ListArchivedWorkflowExecutions_FullMethodName     = "/temporal.api.workflowservice.v1.WorkflowService/ListArchivedWorkflowExecutions"
	WorkflowService_ScanWorkflowExecutions_FullMethodName             = "/temporal.api.workflowservice.v1.WorkflowService/ScanWorkflowExecutions"
	WorkflowService_CountWorkflowExecutions_FullMethodName            = "/temporal.api.workflowservice.v1.WorkflowService/CountWorkflowExecutions"
	WorkflowService_GetSearchAttributes_FullMethodName                = "/temporal.api.workflowservice.v1.WorkflowService/GetSearchAttributes"
	WorkflowService_RespondQueryTaskCompleted_FullMethodName          = "/temporal.api.workflowservice.v1.WorkflowService/RespondQueryTaskCompleted"
	WorkflowService_ResetStickyTaskQueue_FullMethodName               = "/temporal.api.workflowservice.v1.WorkflowService/ResetStickyTaskQueue"
	WorkflowService_QueryWorkflow_FullMethodName                      = "/temporal.api.workflowservice.v1.WorkflowService/QueryWorkflow"
	WorkflowService_DescribeWorkflowExecution_FullMethodName          = "/temporal.api.workflowservice.v1.WorkflowService/DescribeWorkflowExecution"
	WorkflowService_DescribeTaskQueue_FullMethodName                  = "/temporal.api.workflowservice.v1.WorkflowService/DescribeTaskQueue"
	WorkflowService_GetClusterInfo_FullMethodName                     = "/temporal.api.workflowservice.v1.WorkflowService/GetClusterInfo"
	WorkflowService_GetSystemInfo_FullMethodName                      = "/temporal.api.workflowservice.v1.WorkflowService/GetSystemInfo"
	WorkflowService_ListTaskQueuePartitions_FullMethodName            = "/temporal.api.workflowservice.v1.WorkflowService/ListTaskQueuePartitions"
	WorkflowService_CreateSchedule_FullMethodName                     = "/temporal.api.workflowservice.v1.WorkflowService/CreateSchedule"
	WorkflowService_DescribeSchedule_FullMethodName                   = "/temporal.api.workflowservice.v1.WorkflowService/DescribeSchedule"
	WorkflowService_UpdateSchedule_FullMethodName                     = "/temporal.api.workflowservice.v1.WorkflowService/UpdateSchedule"
	WorkflowService_PatchSchedule_FullMethodName                      = "/temporal.api.workflowservice.v1.WorkflowService/PatchSchedule"
	WorkflowService_ListScheduleMatchingTimes_FullMethodName          = "/temporal.api.workflowservice.v1.WorkflowService/ListScheduleMatchingTimes"
	WorkflowService_DeleteSchedule_FullMethodName                     = "/temporal.api.workflowservice.v1.WorkflowService/DeleteSchedule"
	WorkflowService_ListSchedules_FullMethodName                      = "/temporal.api.workflowservice.v1.WorkflowService/ListSchedules"
	WorkflowService_UpdateWorkerBuildIdCompatibility_FullMethodName   = "/temporal.api.workflowservice.v1.WorkflowService/UpdateWorkerBuildIdCompatibility"
	WorkflowService_GetWorkerBuildIdCompatibility_FullMethodName      = "/temporal.api.workflowservice.v1.WorkflowService/GetWorkerBuildIdCompatibility"
	WorkflowService_GetWorkerTaskReachability_FullMethodName          = "/temporal.api.workflowservice.v1.WorkflowService/GetWorkerTaskReachability"
	WorkflowService_UpdateWorkflowExecution_FullMethodName            = "/temporal.api.workflowservice.v1.WorkflowService/UpdateWorkflowExecution"
	WorkflowService_PollWorkflowExecutionUpdate_FullMethodName        = "/temporal.api.workflowservice.v1.WorkflowService/PollWorkflowExecutionUpdate"
	WorkflowService_StartBatchOperation_FullMethodName                = "/temporal.api.workflowservice.v1.WorkflowService/StartBatchOperation"
	WorkflowService_StopBatchOperation_FullMethodName                 = "/temporal.api.workflowservice.v1.WorkflowService/StopBatchOperation"
	WorkflowService_DescribeBatchOperation_FullMethodName             = "/temporal.api.workflowservice.v1.WorkflowService/DescribeBatchOperation"
	WorkflowService_ListBatchOperations_FullMethodName                = "/temporal.api.workflowservice.v1.WorkflowService/ListBatchOperations"
	WorkflowService_PollNexusTaskQueue_FullMethodName                 = "/temporal.api.workflowservice.v1.WorkflowService/PollNexusTaskQueue"
	WorkflowService_RespondNexusTaskCompleted_FullMethodName          = "/temporal.api.workflowservice.v1.WorkflowService/RespondNexusTaskCompleted"
	WorkflowService_RespondNexusTaskFailed_FullMethodName             = "/temporal.api.workflowservice.v1.WorkflowService/RespondNexusTaskFailed"
)

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
View Source
var WorkflowService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "temporal.api.workflowservice.v1.WorkflowService",
	HandlerType: (*WorkflowServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterNamespace",
			Handler:    _WorkflowService_RegisterNamespace_Handler,
		},
		{
			MethodName: "DescribeNamespace",
			Handler:    _WorkflowService_DescribeNamespace_Handler,
		},
		{
			MethodName: "ListNamespaces",
			Handler:    _WorkflowService_ListNamespaces_Handler,
		},
		{
			MethodName: "UpdateNamespace",
			Handler:    _WorkflowService_UpdateNamespace_Handler,
		},
		{
			MethodName: "DeprecateNamespace",
			Handler:    _WorkflowService_DeprecateNamespace_Handler,
		},
		{
			MethodName: "StartWorkflowExecution",
			Handler:    _WorkflowService_StartWorkflowExecution_Handler,
		},
		{
			MethodName: "GetWorkflowExecutionHistory",
			Handler:    _WorkflowService_GetWorkflowExecutionHistory_Handler,
		},
		{
			MethodName: "GetWorkflowExecutionHistoryReverse",
			Handler:    _WorkflowService_GetWorkflowExecutionHistoryReverse_Handler,
		},
		{
			MethodName: "PollWorkflowTaskQueue",
			Handler:    _WorkflowService_PollWorkflowTaskQueue_Handler,
		},
		{
			MethodName: "RespondWorkflowTaskCompleted",
			Handler:    _WorkflowService_RespondWorkflowTaskCompleted_Handler,
		},
		{
			MethodName: "RespondWorkflowTaskFailed",
			Handler:    _WorkflowService_RespondWorkflowTaskFailed_Handler,
		},
		{
			MethodName: "PollActivityTaskQueue",
			Handler:    _WorkflowService_PollActivityTaskQueue_Handler,
		},
		{
			MethodName: "RecordActivityTaskHeartbeat",
			Handler:    _WorkflowService_RecordActivityTaskHeartbeat_Handler,
		},
		{
			MethodName: "RecordActivityTaskHeartbeatById",
			Handler:    _WorkflowService_RecordActivityTaskHeartbeatById_Handler,
		},
		{
			MethodName: "RespondActivityTaskCompleted",
			Handler:    _WorkflowService_RespondActivityTaskCompleted_Handler,
		},
		{
			MethodName: "RespondActivityTaskCompletedById",
			Handler:    _WorkflowService_RespondActivityTaskCompletedById_Handler,
		},
		{
			MethodName: "RespondActivityTaskFailed",
			Handler:    _WorkflowService_RespondActivityTaskFailed_Handler,
		},
		{
			MethodName: "RespondActivityTaskFailedById",
			Handler:    _WorkflowService_RespondActivityTaskFailedById_Handler,
		},
		{
			MethodName: "RespondActivityTaskCanceled",
			Handler:    _WorkflowService_RespondActivityTaskCanceled_Handler,
		},
		{
			MethodName: "RespondActivityTaskCanceledById",
			Handler:    _WorkflowService_RespondActivityTaskCanceledById_Handler,
		},
		{
			MethodName: "RequestCancelWorkflowExecution",
			Handler:    _WorkflowService_RequestCancelWorkflowExecution_Handler,
		},
		{
			MethodName: "SignalWorkflowExecution",
			Handler:    _WorkflowService_SignalWorkflowExecution_Handler,
		},
		{
			MethodName: "SignalWithStartWorkflowExecution",
			Handler:    _WorkflowService_SignalWithStartWorkflowExecution_Handler,
		},
		{
			MethodName: "ResetWorkflowExecution",
			Handler:    _WorkflowService_ResetWorkflowExecution_Handler,
		},
		{
			MethodName: "TerminateWorkflowExecution",
			Handler:    _WorkflowService_TerminateWorkflowExecution_Handler,
		},
		{
			MethodName: "DeleteWorkflowExecution",
			Handler:    _WorkflowService_DeleteWorkflowExecution_Handler,
		},
		{
			MethodName: "ListOpenWorkflowExecutions",
			Handler:    _WorkflowService_ListOpenWorkflowExecutions_Handler,
		},
		{
			MethodName: "ListClosedWorkflowExecutions",
			Handler:    _WorkflowService_ListClosedWorkflowExecutions_Handler,
		},
		{
			MethodName: "ListWorkflowExecutions",
			Handler:    _WorkflowService_ListWorkflowExecutions_Handler,
		},
		{
			MethodName: "ListArchivedWorkflowExecutions",
			Handler:    _WorkflowService_ListArchivedWorkflowExecutions_Handler,
		},
		{
			MethodName: "ScanWorkflowExecutions",
			Handler:    _WorkflowService_ScanWorkflowExecutions_Handler,
		},
		{
			MethodName: "CountWorkflowExecutions",
			Handler:    _WorkflowService_CountWorkflowExecutions_Handler,
		},
		{
			MethodName: "GetSearchAttributes",
			Handler:    _WorkflowService_GetSearchAttributes_Handler,
		},
		{
			MethodName: "RespondQueryTaskCompleted",
			Handler:    _WorkflowService_RespondQueryTaskCompleted_Handler,
		},
		{
			MethodName: "ResetStickyTaskQueue",
			Handler:    _WorkflowService_ResetStickyTaskQueue_Handler,
		},
		{
			MethodName: "QueryWorkflow",
			Handler:    _WorkflowService_QueryWorkflow_Handler,
		},
		{
			MethodName: "DescribeWorkflowExecution",
			Handler:    _WorkflowService_DescribeWorkflowExecution_Handler,
		},
		{
			MethodName: "DescribeTaskQueue",
			Handler:    _WorkflowService_DescribeTaskQueue_Handler,
		},
		{
			MethodName: "GetClusterInfo",
			Handler:    _WorkflowService_GetClusterInfo_Handler,
		},
		{
			MethodName: "GetSystemInfo",
			Handler:    _WorkflowService_GetSystemInfo_Handler,
		},
		{
			MethodName: "ListTaskQueuePartitions",
			Handler:    _WorkflowService_ListTaskQueuePartitions_Handler,
		},
		{
			MethodName: "CreateSchedule",
			Handler:    _WorkflowService_CreateSchedule_Handler,
		},
		{
			MethodName: "DescribeSchedule",
			Handler:    _WorkflowService_DescribeSchedule_Handler,
		},
		{
			MethodName: "UpdateSchedule",
			Handler:    _WorkflowService_UpdateSchedule_Handler,
		},
		{
			MethodName: "PatchSchedule",
			Handler:    _WorkflowService_PatchSchedule_Handler,
		},
		{
			MethodName: "ListScheduleMatchingTimes",
			Handler:    _WorkflowService_ListScheduleMatchingTimes_Handler,
		},
		{
			MethodName: "DeleteSchedule",
			Handler:    _WorkflowService_DeleteSchedule_Handler,
		},
		{
			MethodName: "ListSchedules",
			Handler:    _WorkflowService_ListSchedules_Handler,
		},
		{
			MethodName: "UpdateWorkerBuildIdCompatibility",
			Handler:    _WorkflowService_UpdateWorkerBuildIdCompatibility_Handler,
		},
		{
			MethodName: "GetWorkerBuildIdCompatibility",
			Handler:    _WorkflowService_GetWorkerBuildIdCompatibility_Handler,
		},
		{
			MethodName: "GetWorkerTaskReachability",
			Handler:    _WorkflowService_GetWorkerTaskReachability_Handler,
		},
		{
			MethodName: "UpdateWorkflowExecution",
			Handler:    _WorkflowService_UpdateWorkflowExecution_Handler,
		},
		{
			MethodName: "PollWorkflowExecutionUpdate",
			Handler:    _WorkflowService_PollWorkflowExecutionUpdate_Handler,
		},
		{
			MethodName: "StartBatchOperation",
			Handler:    _WorkflowService_StartBatchOperation_Handler,
		},
		{
			MethodName: "StopBatchOperation",
			Handler:    _WorkflowService_StopBatchOperation_Handler,
		},
		{
			MethodName: "DescribeBatchOperation",
			Handler:    _WorkflowService_DescribeBatchOperation_Handler,
		},
		{
			MethodName: "ListBatchOperations",
			Handler:    _WorkflowService_ListBatchOperations_Handler,
		},
		{
			MethodName: "PollNexusTaskQueue",
			Handler:    _WorkflowService_PollNexusTaskQueue_Handler,
		},
		{
			MethodName: "RespondNexusTaskCompleted",
			Handler:    _WorkflowService_RespondNexusTaskCompleted_Handler,
		},
		{
			MethodName: "RespondNexusTaskFailed",
			Handler:    _WorkflowService_RespondNexusTaskFailed_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "temporal/api/workflowservice/v1/service.proto",
}

WorkflowService_ServiceDesc is the grpc.ServiceDesc for WorkflowService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWorkflowServiceServer

func RegisterWorkflowServiceServer(s grpc.ServiceRegistrar, srv WorkflowServiceServer)

Types

type CountWorkflowExecutionsRequest

type CountWorkflowExecutionsRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Query     string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// 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 (*CountWorkflowExecutionsRequest) Reset

func (x *CountWorkflowExecutionsRequest) Reset()

func (*CountWorkflowExecutionsRequest) String

type CountWorkflowExecutionsResponse

type CountWorkflowExecutionsResponse struct {

	// If `query` is not grouping by any field, the count is an approximate number
	// of workflows that matches the query.
	// If `query` is grouping by a field, the count is simply the sum of the counts
	// of the groups returned in the response. This number can be smaller than the
	// total number of workflows matching the query.
	Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// `groups` contains the groups if the request is grouping by a field.
	// The list might not be complete, and the counts of each group is approximate.
	Groups []*CountWorkflowExecutionsResponse_AggregationGroup `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,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) GetGroups added in v4.7.1

func (*CountWorkflowExecutionsResponse) ProtoMessage

func (*CountWorkflowExecutionsResponse) ProtoMessage()

func (*CountWorkflowExecutionsResponse) ProtoReflect

func (*CountWorkflowExecutionsResponse) Reset

func (*CountWorkflowExecutionsResponse) String

type CountWorkflowExecutionsResponse_AggregationGroup added in v4.7.1

type CountWorkflowExecutionsResponse_AggregationGroup struct {
	GroupValues []*v13.Payload `protobuf:"bytes,1,rep,name=group_values,json=groupValues,proto3" json:"group_values,omitempty"`
	Count       int64          `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*CountWorkflowExecutionsResponse_AggregationGroup) Descriptor deprecated added in v4.7.1

Deprecated: Use CountWorkflowExecutionsResponse_AggregationGroup.ProtoReflect.Descriptor instead.

func (*CountWorkflowExecutionsResponse_AggregationGroup) GetCount added in v4.7.1

func (*CountWorkflowExecutionsResponse_AggregationGroup) GetGroupValues added in v4.7.1

func (*CountWorkflowExecutionsResponse_AggregationGroup) ProtoMessage added in v4.7.1

func (*CountWorkflowExecutionsResponse_AggregationGroup) ProtoReflect added in v4.7.1

func (*CountWorkflowExecutionsResponse_AggregationGroup) Reset added in v4.7.1

func (*CountWorkflowExecutionsResponse_AggregationGroup) String added in v4.7.1

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

func (x *DeleteWorkflowExecutionRequest) Reset()

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

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

func (x *DescribeBatchOperationRequest) Reset()

func (*DescribeBatchOperationRequest) 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 (*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 (*DescribeBatchOperationResponse) GetReason

func (x *DescribeBatchOperationResponse) GetReason() string

func (*DescribeBatchOperationResponse) GetStartTime

func (*DescribeBatchOperationResponse) GetState

func (*DescribeBatchOperationResponse) GetTotalOperationCount

func (x *DescribeBatchOperationResponse) GetTotalOperationCount() int64

func (*DescribeBatchOperationResponse) ProtoMessage

func (*DescribeBatchOperationResponse) ProtoMessage()

func (*DescribeBatchOperationResponse) ProtoReflect

func (*DescribeBatchOperationResponse) Reset

func (x *DescribeBatchOperationResponse) Reset()

func (*DescribeBatchOperationResponse) 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 (*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 (*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 (*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"`
	// If unspecified (TASK_QUEUE_TYPE_UNSPECIFIED), then default value (TASK_QUEUE_TYPE_WORKFLOW) will be used.
	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 (*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 (*DescribeWorkflowExecutionRequest) GetNamespace

func (x *DescribeWorkflowExecutionRequest) GetNamespace() string

func (*DescribeWorkflowExecutionRequest) ProtoMessage

func (*DescribeWorkflowExecutionRequest) ProtoMessage()

func (*DescribeWorkflowExecutionRequest) ProtoReflect

func (*DescribeWorkflowExecutionRequest) Reset

func (*DescribeWorkflowExecutionRequest) 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"`
	Callbacks             []*v112.CallbackInfo              `protobuf:"bytes,6,rep,name=callbacks,proto3" json:"callbacks,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeWorkflowExecutionResponse) Descriptor deprecated

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

Deprecated: Use DescribeWorkflowExecutionResponse.ProtoReflect.Descriptor instead.

func (*DescribeWorkflowExecutionResponse) GetCallbacks added in v4.11.0

func (*DescribeWorkflowExecutionResponse) GetExecutionConfig

func (*DescribeWorkflowExecutionResponse) GetPendingActivities

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

func (*DescribeWorkflowExecutionResponse) GetPendingChildren

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

func (*DescribeWorkflowExecutionResponse) 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 (*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 (*GetSearchAttributesResponse) ProtoMessage

func (*GetSearchAttributesResponse) ProtoMessage()

func (*GetSearchAttributesResponse) ProtoReflect

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 (*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"`
	// True if the server supports count group by execution status
	// (-- api-linter: core::0140::prepositions=disabled --)
	CountGroupByExecutionStatus bool `` /* 150-byte string literal not displayed */
	// 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) GetCountGroupByExecutionStatus added in v4.7.1

func (x *GetSystemInfoResponse_Capabilities) GetCountGroupByExecutionStatus() 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 (*GetSystemInfoResponse_Capabilities) Reset

func (*GetSystemInfoResponse_Capabilities) 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"`
	// 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) GetMaxSets

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

func (*GetWorkerBuildIdCompatibilityRequest) 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"`
	// contains filtered or unexported fields
}

func (*GetWorkerBuildIdCompatibilityResponse) Descriptor deprecated

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

Deprecated: Use GetWorkerBuildIdCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerBuildIdCompatibilityResponse) GetMajorVersionSets

func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage

func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityResponse) ProtoReflect

func (*GetWorkerBuildIdCompatibilityResponse) Reset

func (*GetWorkerBuildIdCompatibilityResponse) String

type GetWorkerTaskReachabilityRequest

type GetWorkerTaskReachabilityRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Build ids to retrieve reachability for. An empty string will be interpreted as an unversioned worker.
	// The number of build ids that can be queried in a single API call is limited.
	// Open source users can adjust this limit by setting the server's dynamic config value for
	// `limit.reachabilityQueryBuildIds` with the caveat that this call can strain the visibility store.
	BuildIds []string `protobuf:"bytes,2,rep,name=build_ids,json=buildIds,proto3" json:"build_ids,omitempty"`
	// Task queues to retrieve reachability for. Leave this empty to query for all task queues associated with given
	// build ids in the namespace.
	// Must specify at least one task queue if querying for an unversioned worker.
	// The number of task queues that the server will fetch reachability information for is limited.
	// See the `GetWorkerTaskReachabilityResponse` documentation for more information.
	TaskQueues []string `protobuf:"bytes,3,rep,name=task_queues,json=taskQueues,proto3" json:"task_queues,omitempty"`
	// Type of reachability to query for.
	// `TASK_REACHABILITY_NEW_WORKFLOWS` is always returned in the response.
	// Use `TASK_REACHABILITY_EXISTING_WORKFLOWS` if your application needs to respond to queries on closed workflows.
	// Otherwise, use `TASK_REACHABILITY_OPEN_WORKFLOWS`. Default is `TASK_REACHABILITY_EXISTING_WORKFLOWS` if left
	// unspecified.
	// See the TaskReachability docstring for information about each enum variant.
	Reachability v11.TaskReachability `protobuf:"varint,4,opt,name=reachability,proto3,enum=temporal.api.enums.v1.TaskReachability" json:"reachability,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerTaskReachabilityRequest) Descriptor deprecated

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

Deprecated: Use GetWorkerTaskReachabilityRequest.ProtoReflect.Descriptor instead.

func (*GetWorkerTaskReachabilityRequest) GetBuildIds

func (x *GetWorkerTaskReachabilityRequest) GetBuildIds() []string

func (*GetWorkerTaskReachabilityRequest) GetNamespace

func (x *GetWorkerTaskReachabilityRequest) GetNamespace() string

func (*GetWorkerTaskReachabilityRequest) GetReachability

func (*GetWorkerTaskReachabilityRequest) GetTaskQueues

func (x *GetWorkerTaskReachabilityRequest) GetTaskQueues() []string

func (*GetWorkerTaskReachabilityRequest) ProtoMessage

func (*GetWorkerTaskReachabilityRequest) ProtoMessage()

func (*GetWorkerTaskReachabilityRequest) ProtoReflect

func (*GetWorkerTaskReachabilityRequest) Reset

func (*GetWorkerTaskReachabilityRequest) String

type GetWorkerTaskReachabilityResponse

type GetWorkerTaskReachabilityResponse struct {

	// Task reachability, broken down by build id and then task queue.
	// When requesting a large number of task queues or all task queues associated with the given build ids in a
	// namespace, all task queues will be listed in the response but some of them may not contain reachability
	// information due to a server enforced limit. When reaching the limit, task queues that reachability information
	// could not be retrieved for will be marked with a single TASK_REACHABILITY_UNSPECIFIED entry. The caller may issue
	// another call to get the reachability for those task queues.
	//
	// Open source users can adjust this limit by setting the server's dynamic config value for
	// `limit.reachabilityTaskQueueScan` with the caveat that this call can strain the visibility store.
	BuildIdReachability []*v14.BuildIdReachability `protobuf:"bytes,1,rep,name=build_id_reachability,json=buildIdReachability,proto3" json:"build_id_reachability,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerTaskReachabilityResponse) Descriptor deprecated

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

Deprecated: Use GetWorkerTaskReachabilityResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerTaskReachabilityResponse) GetBuildIdReachability

func (x *GetWorkerTaskReachabilityResponse) GetBuildIdReachability() []*v14.BuildIdReachability

func (*GetWorkerTaskReachabilityResponse) ProtoMessage

func (*GetWorkerTaskReachabilityResponse) ProtoMessage()

func (*GetWorkerTaskReachabilityResponse) ProtoReflect

func (*GetWorkerTaskReachabilityResponse) Reset

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

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

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

func (x *GetWorkflowExecutionHistoryReverseRequest) GetMaximumPageSize() int32

func (*GetWorkflowExecutionHistoryReverseRequest) GetNamespace

func (*GetWorkflowExecutionHistoryReverseRequest) GetNextPageToken

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

func (*GetWorkflowExecutionHistoryReverseRequest) ProtoMessage

func (*GetWorkflowExecutionHistoryReverseRequest) ProtoReflect

func (*GetWorkflowExecutionHistoryReverseRequest) Reset

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

Deprecated: Use GetWorkflowExecutionHistoryReverseResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowExecutionHistoryReverseResponse) GetHistory

func (*GetWorkflowExecutionHistoryReverseResponse) GetNextPageToken

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

func (*GetWorkflowExecutionHistoryReverseResponse) ProtoMessage

func (*GetWorkflowExecutionHistoryReverseResponse) ProtoReflect

func (*GetWorkflowExecutionHistoryReverseResponse) Reset

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

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

func (*ListArchivedWorkflowExecutionsRequest) GetPageSize

func (*ListArchivedWorkflowExecutionsRequest) GetQuery

func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage

func (*ListArchivedWorkflowExecutionsRequest) ProtoMessage()

func (*ListArchivedWorkflowExecutionsRequest) ProtoReflect

func (*ListArchivedWorkflowExecutionsRequest) Reset

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

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

func (*ListArchivedWorkflowExecutionsResponse) ProtoMessage

func (*ListArchivedWorkflowExecutionsResponse) ProtoReflect

func (*ListArchivedWorkflowExecutionsResponse) Reset

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

func (*ListClosedWorkflowExecutionsRequest) ProtoMessage

func (*ListClosedWorkflowExecutionsRequest) ProtoMessage()

func (*ListClosedWorkflowExecutionsRequest) ProtoReflect

func (*ListClosedWorkflowExecutionsRequest) Reset

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

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

func (*ListClosedWorkflowExecutionsResponse) ProtoMessage

func (*ListClosedWorkflowExecutionsResponse) ProtoMessage()

func (*ListClosedWorkflowExecutionsResponse) ProtoReflect

func (*ListClosedWorkflowExecutionsResponse) Reset

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

func (*ListOpenWorkflowExecutionsRequest) ProtoMessage()

func (*ListOpenWorkflowExecutionsRequest) ProtoReflect

func (*ListOpenWorkflowExecutionsRequest) Reset

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

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

func (*ListOpenWorkflowExecutionsResponse) ProtoMessage

func (*ListOpenWorkflowExecutionsResponse) ProtoMessage()

func (*ListOpenWorkflowExecutionsResponse) ProtoReflect

func (*ListOpenWorkflowExecutionsResponse) Reset

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

func (x *ListScheduleMatchingTimesRequest) GetNamespace() string

func (*ListScheduleMatchingTimesRequest) GetScheduleId

func (x *ListScheduleMatchingTimesRequest) GetScheduleId() string

func (*ListScheduleMatchingTimesRequest) GetStartTime

func (*ListScheduleMatchingTimesRequest) ProtoMessage

func (*ListScheduleMatchingTimesRequest) ProtoMessage()

func (*ListScheduleMatchingTimesRequest) ProtoReflect

func (*ListScheduleMatchingTimesRequest) Reset

func (*ListScheduleMatchingTimesRequest) 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 (*ListScheduleMatchingTimesResponse) ProtoMessage

func (*ListScheduleMatchingTimesResponse) ProtoMessage()

func (*ListScheduleMatchingTimesResponse) ProtoReflect

func (*ListScheduleMatchingTimesResponse) Reset

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

func (x *ListTaskQueuePartitionsRequest) Reset()

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

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

func (x *ListWorkflowExecutionsRequest) Reset()

func (*ListWorkflowExecutionsRequest) 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 (*ListWorkflowExecutionsResponse) GetNextPageToken

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

func (*ListWorkflowExecutionsResponse) ProtoMessage

func (*ListWorkflowExecutionsResponse) ProtoMessage()

func (*ListWorkflowExecutionsResponse) ProtoReflect

func (*ListWorkflowExecutionsResponse) Reset

func (x *ListWorkflowExecutionsResponse) Reset()

func (*ListWorkflowExecutionsResponse) 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"`
	// Information about this worker's build identifier and if it is choosing to use the versioning
	// feature. See the `WorkerVersionCapabilities` docstring for more.
	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 (*PollActivityTaskQueueRequest) Reset

func (x *PollActivityTaskQueueRequest) Reset()

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

func (x *PollActivityTaskQueueResponse) Reset()

func (*PollActivityTaskQueueResponse) String

type PollNexusTaskQueueRequest added in v4.11.0

type PollNexusTaskQueueRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The identity of the client who initiated this request.
	Identity  string         `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	TaskQueue *v14.TaskQueue `protobuf:"bytes,3,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Information about this worker's build identifier and if it is choosing to use the versioning
	// feature. See the `WorkerVersionCapabilities` docstring for more.
	WorkerVersionCapabilities *v13.WorkerVersionCapabilities `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PollNexusTaskQueueRequest) Descriptor deprecated added in v4.11.0

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

Deprecated: Use PollNexusTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*PollNexusTaskQueueRequest) GetIdentity added in v4.11.0

func (x *PollNexusTaskQueueRequest) GetIdentity() string

func (*PollNexusTaskQueueRequest) GetNamespace added in v4.11.0

func (x *PollNexusTaskQueueRequest) GetNamespace() string

func (*PollNexusTaskQueueRequest) GetTaskQueue added in v4.11.0

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

func (*PollNexusTaskQueueRequest) GetWorkerVersionCapabilities added in v4.11.0

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

func (*PollNexusTaskQueueRequest) ProtoMessage added in v4.11.0

func (*PollNexusTaskQueueRequest) ProtoMessage()

func (*PollNexusTaskQueueRequest) ProtoReflect added in v4.11.0

func (*PollNexusTaskQueueRequest) Reset added in v4.11.0

func (x *PollNexusTaskQueueRequest) Reset()

func (*PollNexusTaskQueueRequest) String added in v4.11.0

func (x *PollNexusTaskQueueRequest) String() string

type PollNexusTaskQueueResponse added in v4.11.0

type PollNexusTaskQueueResponse struct {

	// An opaque unique identifier for this task for correlating a completion request the embedded request.
	TaskToken []byte `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// Embedded request as translated from the incoming frontend request.
	Request *v117.Request `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*PollNexusTaskQueueResponse) Descriptor deprecated added in v4.11.0

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

Deprecated: Use PollNexusTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*PollNexusTaskQueueResponse) GetRequest added in v4.11.0

func (x *PollNexusTaskQueueResponse) GetRequest() *v117.Request

func (*PollNexusTaskQueueResponse) GetTaskToken added in v4.11.0

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

func (*PollNexusTaskQueueResponse) ProtoMessage added in v4.11.0

func (*PollNexusTaskQueueResponse) ProtoMessage()

func (*PollNexusTaskQueueResponse) ProtoReflect added in v4.11.0

func (*PollNexusTaskQueueResponse) Reset added in v4.11.0

func (x *PollNexusTaskQueueResponse) Reset()

func (*PollNexusTaskQueueResponse) String added in v4.11.0

func (x *PollNexusTaskQueueResponse) 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.
	// Omit to request a non-blocking poll.
	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 (*PollWorkflowExecutionUpdateRequest) GetWaitPolicy

func (*PollWorkflowExecutionUpdateRequest) ProtoMessage

func (*PollWorkflowExecutionUpdateRequest) ProtoMessage()

func (*PollWorkflowExecutionUpdateRequest) ProtoReflect

func (*PollWorkflowExecutionUpdateRequest) Reset

func (*PollWorkflowExecutionUpdateRequest) 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"`
	// The most advanced lifecycle stage that the Update is known to have
	// reached, where lifecycle stages are ordered
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_UNSPECIFIED <
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ADMITTED <
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ACCEPTED <
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_COMPLETED.
	// UNSPECIFIED will be returned if and only if the server's maximum wait
	// time was reached before the Update reached the stage specified in the
	// request WaitPolicy, and before the context deadline expired; clients may
	// may then retry the call as needed.
	Stage v11.UpdateWorkflowExecutionLifecycleStage `` /* 129-byte string literal not displayed */
	// Sufficient information to address this update.
	UpdateRef *v115.UpdateRef `protobuf:"bytes,3,opt,name=update_ref,json=updateRef,proto3" json:"update_ref,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 (*PollWorkflowExecutionUpdateResponse) GetStage added in v4.10.0

func (*PollWorkflowExecutionUpdateResponse) GetUpdateRef added in v4.10.0

func (*PollWorkflowExecutionUpdateResponse) ProtoMessage

func (*PollWorkflowExecutionUpdateResponse) ProtoMessage()

func (*PollWorkflowExecutionUpdateResponse) ProtoReflect

func (*PollWorkflowExecutionUpdateResponse) Reset

func (*PollWorkflowExecutionUpdateResponse) 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"`
	// DEPRECATED since 1.21 - use `worker_version_capabilities` instead.
	// 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"`
	// Information about this worker's build identifier and if it is choosing to use the versioning
	// feature. See the `WorkerVersionCapabilities` docstring for more.
	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 (*PollWorkflowTaskQueueRequest) Reset

func (x *PollWorkflowTaskQueueRequest) Reset()

func (*PollWorkflowTaskQueueRequest) 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. Will be zero if the task
	// does not contain any events which would advance history (no new WFT started).
	// Currently this can happen for queries.
	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 (*PollWorkflowTaskQueueResponse) GetQuery

func (*PollWorkflowTaskQueueResponse) GetScheduledTime

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

func (*PollWorkflowTaskQueueResponse) GetStartedEventId

func (x *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetStartedTime

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

func (x *PollWorkflowTaskQueueResponse) Reset()

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

func (*RecordActivityTaskHeartbeatByIdRequest) GetIdentity

func (*RecordActivityTaskHeartbeatByIdRequest) GetNamespace

func (*RecordActivityTaskHeartbeatByIdRequest) GetRunId

func (*RecordActivityTaskHeartbeatByIdRequest) GetWorkflowId

func (*RecordActivityTaskHeartbeatByIdRequest) ProtoMessage

func (*RecordActivityTaskHeartbeatByIdRequest) ProtoReflect

func (*RecordActivityTaskHeartbeatByIdRequest) Reset

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

func (*RecordActivityTaskHeartbeatByIdResponse) Reset

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

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

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

func (*RequestCancelWorkflowExecutionRequest) GetReason

func (*RequestCancelWorkflowExecutionRequest) GetRequestId

func (*RequestCancelWorkflowExecutionRequest) GetWorkflowExecution

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

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage

func (*RequestCancelWorkflowExecutionRequest) ProtoMessage()

func (*RequestCancelWorkflowExecutionRequest) ProtoReflect

func (*RequestCancelWorkflowExecutionRequest) Reset

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

func (*RequestCancelWorkflowExecutionResponse) Reset

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

func (x *ResetStickyTaskQueueRequest) GetNamespace() string

func (*ResetStickyTaskQueueRequest) ProtoMessage

func (*ResetStickyTaskQueueRequest) ProtoMessage()

func (*ResetStickyTaskQueueRequest) ProtoReflect

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

func (x *ResetStickyTaskQueueResponse) Reset()

func (*ResetStickyTaskQueueResponse) 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"`
	// Event types to be reapplied (deprecated)
	// Default: RESET_REAPPLY_TYPE_ALL_ELIGIBLE
	ResetReapplyType v11.ResetReapplyType `` /* 156-byte string literal not displayed */
	// Event types not to be reapplied
	ResetReapplyExcludeTypes []v11.ResetReapplyExcludeType `` /* 196-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) GetResetReapplyExcludeTypes added in v4.11.0

func (x *ResetWorkflowExecutionRequest) GetResetReapplyExcludeTypes() []v11.ResetReapplyExcludeType

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

func (x *ResetWorkflowExecutionRequest) Reset()

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

func (x *ResetWorkflowExecutionResponse) Reset()

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

func (*RespondActivityTaskCanceledByIdRequest) GetIdentity

func (*RespondActivityTaskCanceledByIdRequest) GetNamespace

func (*RespondActivityTaskCanceledByIdRequest) GetRunId

func (*RespondActivityTaskCanceledByIdRequest) GetWorkflowId

func (*RespondActivityTaskCanceledByIdRequest) ProtoMessage

func (*RespondActivityTaskCanceledByIdRequest) ProtoReflect

func (*RespondActivityTaskCanceledByIdRequest) Reset

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

func (*RespondActivityTaskCanceledByIdResponse) Reset

func (*RespondActivityTaskCanceledByIdResponse) 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"`
	// Version info of the worker who processed this task. This message's `build_id` field should
	// always be set by SDKs. Workers opting into versioning will also set the `use_versioning`
	// field to true. See message docstrings for more.
	WorkerVersion *v13.WorkerVersionStamp `protobuf:"bytes,5,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,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 (*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) GetWorkerVersion

func (*RespondActivityTaskCanceledRequest) ProtoMessage

func (*RespondActivityTaskCanceledRequest) ProtoMessage()

func (*RespondActivityTaskCanceledRequest) ProtoReflect

func (*RespondActivityTaskCanceledRequest) Reset

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

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

func (*RespondActivityTaskCompletedByIdRequest) GetNamespace

func (*RespondActivityTaskCompletedByIdRequest) GetResult

func (*RespondActivityTaskCompletedByIdRequest) GetRunId

func (*RespondActivityTaskCompletedByIdRequest) GetWorkflowId

func (*RespondActivityTaskCompletedByIdRequest) ProtoMessage

func (*RespondActivityTaskCompletedByIdRequest) ProtoReflect

func (*RespondActivityTaskCompletedByIdRequest) Reset

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

func (*RespondActivityTaskCompletedByIdResponse) Reset

func (*RespondActivityTaskCompletedByIdResponse) 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"`
	// Version info of the worker who processed this task. This message's `build_id` field should
	// always be set by SDKs. Workers opting into versioning will also set the `use_versioning`
	// field to true. See message docstrings for more.
	WorkerVersion *v13.WorkerVersionStamp `protobuf:"bytes,5,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,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 (*RespondActivityTaskCompletedRequest) GetNamespace

func (x *RespondActivityTaskCompletedRequest) GetNamespace() string

func (*RespondActivityTaskCompletedRequest) GetResult

func (*RespondActivityTaskCompletedRequest) GetTaskToken

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

func (*RespondActivityTaskCompletedRequest) GetWorkerVersion

func (*RespondActivityTaskCompletedRequest) ProtoMessage

func (*RespondActivityTaskCompletedRequest) ProtoMessage()

func (*RespondActivityTaskCompletedRequest) ProtoReflect

func (*RespondActivityTaskCompletedRequest) Reset

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

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

func (*RespondActivityTaskFailedByIdRequest) GetLastHeartbeatDetails

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

func (*RespondActivityTaskFailedByIdRequest) GetNamespace

func (x *RespondActivityTaskFailedByIdRequest) GetNamespace() string

func (*RespondActivityTaskFailedByIdRequest) GetRunId

func (*RespondActivityTaskFailedByIdRequest) GetWorkflowId

func (x *RespondActivityTaskFailedByIdRequest) GetWorkflowId() string

func (*RespondActivityTaskFailedByIdRequest) ProtoMessage

func (*RespondActivityTaskFailedByIdRequest) ProtoMessage()

func (*RespondActivityTaskFailedByIdRequest) ProtoReflect

func (*RespondActivityTaskFailedByIdRequest) Reset

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

func (*RespondActivityTaskFailedByIdResponse) ProtoMessage()

func (*RespondActivityTaskFailedByIdResponse) ProtoReflect

func (*RespondActivityTaskFailedByIdResponse) Reset

func (*RespondActivityTaskFailedByIdResponse) 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"`
	// Version info of the worker who processed this task. This message's `build_id` field should
	// always be set by SDKs. Workers opting into versioning will also set the `use_versioning`
	// field to true. See message docstrings for more.
	WorkerVersion *v13.WorkerVersionStamp `protobuf:"bytes,6,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,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) GetWorkerVersion

func (*RespondActivityTaskFailedRequest) ProtoMessage

func (*RespondActivityTaskFailedRequest) ProtoMessage()

func (*RespondActivityTaskFailedRequest) ProtoReflect

func (*RespondActivityTaskFailedRequest) Reset

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

func (*RespondActivityTaskFailedResponse) String

type RespondNexusTaskCompletedRequest added in v4.11.0

type RespondNexusTaskCompletedRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The identity of the client who initiated this request.
	Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	// A unique identifier for this task as received via a poll response.
	TaskToken []byte `protobuf:"bytes,3,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// Embedded response to be translated into a frontend response.
	Response *v117.Response `protobuf:"bytes,4,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondNexusTaskCompletedRequest) Descriptor deprecated added in v4.11.0

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

Deprecated: Use RespondNexusTaskCompletedRequest.ProtoReflect.Descriptor instead.

func (*RespondNexusTaskCompletedRequest) GetIdentity added in v4.11.0

func (x *RespondNexusTaskCompletedRequest) GetIdentity() string

func (*RespondNexusTaskCompletedRequest) GetNamespace added in v4.11.0

func (x *RespondNexusTaskCompletedRequest) GetNamespace() string

func (*RespondNexusTaskCompletedRequest) GetResponse added in v4.11.0

func (*RespondNexusTaskCompletedRequest) GetTaskToken added in v4.11.0

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

func (*RespondNexusTaskCompletedRequest) ProtoMessage added in v4.11.0

func (*RespondNexusTaskCompletedRequest) ProtoMessage()

func (*RespondNexusTaskCompletedRequest) ProtoReflect added in v4.11.0

func (*RespondNexusTaskCompletedRequest) Reset added in v4.11.0

func (*RespondNexusTaskCompletedRequest) String added in v4.11.0

type RespondNexusTaskCompletedResponse added in v4.11.0

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

func (*RespondNexusTaskCompletedResponse) Descriptor deprecated added in v4.11.0

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

Deprecated: Use RespondNexusTaskCompletedResponse.ProtoReflect.Descriptor instead.

func (*RespondNexusTaskCompletedResponse) ProtoMessage added in v4.11.0

func (*RespondNexusTaskCompletedResponse) ProtoMessage()

func (*RespondNexusTaskCompletedResponse) ProtoReflect added in v4.11.0

func (*RespondNexusTaskCompletedResponse) Reset added in v4.11.0

func (*RespondNexusTaskCompletedResponse) String added in v4.11.0

type RespondNexusTaskFailedRequest added in v4.11.0

type RespondNexusTaskFailedRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The identity of the client who initiated this request.
	Identity string `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	// A unique identifier for this task.
	TaskToken []byte `protobuf:"bytes,3,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	// The error the handler failed with.
	Error *v117.HandlerError `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondNexusTaskFailedRequest) Descriptor deprecated added in v4.11.0

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

Deprecated: Use RespondNexusTaskFailedRequest.ProtoReflect.Descriptor instead.

func (*RespondNexusTaskFailedRequest) GetError added in v4.11.0

func (*RespondNexusTaskFailedRequest) GetIdentity added in v4.11.0

func (x *RespondNexusTaskFailedRequest) GetIdentity() string

func (*RespondNexusTaskFailedRequest) GetNamespace added in v4.11.0

func (x *RespondNexusTaskFailedRequest) GetNamespace() string

func (*RespondNexusTaskFailedRequest) GetTaskToken added in v4.11.0

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

func (*RespondNexusTaskFailedRequest) ProtoMessage added in v4.11.0

func (*RespondNexusTaskFailedRequest) ProtoMessage()

func (*RespondNexusTaskFailedRequest) ProtoReflect added in v4.11.0

func (*RespondNexusTaskFailedRequest) Reset added in v4.11.0

func (x *RespondNexusTaskFailedRequest) Reset()

func (*RespondNexusTaskFailedRequest) String added in v4.11.0

type RespondNexusTaskFailedResponse added in v4.11.0

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

func (*RespondNexusTaskFailedResponse) Descriptor deprecated added in v4.11.0

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

Deprecated: Use RespondNexusTaskFailedResponse.ProtoReflect.Descriptor instead.

func (*RespondNexusTaskFailedResponse) ProtoMessage added in v4.11.0

func (*RespondNexusTaskFailedResponse) ProtoMessage()

func (*RespondNexusTaskFailedResponse) ProtoReflect added in v4.11.0

func (*RespondNexusTaskFailedResponse) Reset added in v4.11.0

func (x *RespondNexusTaskFailedResponse) Reset()

func (*RespondNexusTaskFailedResponse) String added in v4.11.0

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

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

func (*RespondQueryTaskCompletedResponse) 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 */
	// DEPRECATED since 1.21 - use `worker_version_stamp` instead.
	// 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"`
	// Version info of the worker who processed this task. This message's `build_id` field should
	// always be set by SDKs. Workers opting into versioning will also set the `use_versioning`
	// field to true. See message docstrings for more.
	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 (*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 (*RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask

func (x *RespondWorkflowTaskCompletedRequest) GetReturnNewWorkflowTask() bool

func (*RespondWorkflowTaskCompletedRequest) GetSdkMetadata

func (*RespondWorkflowTaskCompletedRequest) GetStickyAttributes

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

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

func (x *RespondWorkflowTaskCompletedResponse) GetResetHistoryEventId() int64

func (*RespondWorkflowTaskCompletedResponse) GetWorkflowTask

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage

func (*RespondWorkflowTaskCompletedResponse) ProtoMessage()

func (*RespondWorkflowTaskCompletedResponse) ProtoReflect

func (*RespondWorkflowTaskCompletedResponse) Reset

func (*RespondWorkflowTaskCompletedResponse) 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"`
	// DEPRECATED since 1.21 - use `worker_version_stamp` instead.
	// 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"`
	// Version info of the worker who processed this task. This message's `build_id` field should
	// always be set by SDKs. Workers opting into versioning will also set the `use_versioning`
	// field to true. See message docstrings for more.
	WorkerVersion *v13.WorkerVersionStamp `protobuf:"bytes,8,opt,name=worker_version,json=workerVersion,proto3" json:"worker_version,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 (*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) GetWorkerVersion

func (*RespondWorkflowTaskFailedRequest) ProtoMessage

func (*RespondWorkflowTaskFailedRequest) ProtoMessage()

func (*RespondWorkflowTaskFailedRequest) ProtoReflect

func (*RespondWorkflowTaskFailedRequest) Reset

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

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

func (x *ScanWorkflowExecutionsRequest) Reset()

func (*ScanWorkflowExecutionsRequest) 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 (*ScanWorkflowExecutionsResponse) GetNextPageToken

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

func (*ScanWorkflowExecutionsResponse) ProtoMessage

func (*ScanWorkflowExecutionsResponse) ProtoMessage()

func (*ScanWorkflowExecutionsResponse) ProtoReflect

func (*ScanWorkflowExecutionsResponse) Reset

func (x *ScanWorkflowExecutionsResponse) Reset()

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

func (x *SignalWithStartWorkflowExecutionRequest) GetCronSchedule() string

func (*SignalWithStartWorkflowExecutionRequest) GetHeader

func (*SignalWithStartWorkflowExecutionRequest) GetIdentity

func (*SignalWithStartWorkflowExecutionRequest) GetInput

func (*SignalWithStartWorkflowExecutionRequest) GetMemo

func (*SignalWithStartWorkflowExecutionRequest) GetNamespace

func (*SignalWithStartWorkflowExecutionRequest) GetRequestId

func (*SignalWithStartWorkflowExecutionRequest) GetRetryPolicy

func (*SignalWithStartWorkflowExecutionRequest) GetSearchAttributes

func (*SignalWithStartWorkflowExecutionRequest) GetSignalInput

func (*SignalWithStartWorkflowExecutionRequest) GetSignalName

func (*SignalWithStartWorkflowExecutionRequest) GetSkipGenerateWorkflowTask

func (x *SignalWithStartWorkflowExecutionRequest) GetSkipGenerateWorkflowTask() bool

func (*SignalWithStartWorkflowExecutionRequest) GetTaskQueue

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowExecutionTimeout

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

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowId

func (*SignalWithStartWorkflowExecutionRequest) GetWorkflowIdReusePolicy

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

func (*SignalWithStartWorkflowExecutionRequest) ProtoReflect

func (*SignalWithStartWorkflowExecutionRequest) Reset

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

func (*SignalWithStartWorkflowExecutionResponse) ProtoReflect

func (*SignalWithStartWorkflowExecutionResponse) Reset

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

func (x *SignalWorkflowExecutionRequest) Reset()

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

func (*SignalWorkflowExecutionResponse) 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 `visibility_query` are mutually exclusive
	Executions []*v13.WorkflowExecution `protobuf:"bytes,5,rep,name=executions,proto3" json:"executions,omitempty"`
	// Limit for the number of operations processed per second within this batch.
	// Its purpose is to reduce the stress on the system caused by batch operations, which helps to prevent system
	// overload and minimize potential delays in executing ongoing tasks for user workers.
	// Note that when no explicit limit is provided, the server will operate according to its limit defined by the
	// dynamic configuration key `worker.batcherRPS`. This also applies if the value in this field exceeds the
	// server's configured limit.
	MaxOperationsPerSecond float32 `` /* 133-byte string literal not displayed */
	// Operation input
	//
	// Types that are assignable to Operation:
	//
	//	*StartBatchOperationRequest_TerminationOperation
	//	*StartBatchOperationRequest_SignalOperation
	//	*StartBatchOperationRequest_CancellationOperation
	//	*StartBatchOperationRequest_DeletionOperation
	//	*StartBatchOperationRequest_ResetOperation
	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) GetMaxOperationsPerSecond added in v4.10.0

func (x *StartBatchOperationRequest) GetMaxOperationsPerSecond() float32

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

func (x *StartBatchOperationRequest) GetResetOperation() *v116.BatchOperationReset

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

type StartBatchOperationRequest_ResetOperation struct {
	ResetOperation *v116.BatchOperationReset `protobuf:"bytes,14,opt,name=reset_operation,json=resetOperation,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 (*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"`
	// Callbacks to be called by the server when this workflow reaches a terminal state.
	// If the workflow continues-as-new, these callbacks will be carried over to the new execution.
	// Callback addresses must be whitelisted in the server's dynamic configuration.
	CompletionCallbacks []*v13.Callback `protobuf:"bytes,21,rep,name=completion_callbacks,json=completionCallbacks,proto3" json:"completion_callbacks,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowExecutionRequest) Descriptor deprecated

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

Deprecated: Use StartWorkflowExecutionRequest.ProtoReflect.Descriptor instead.

func (*StartWorkflowExecutionRequest) GetCompletionCallbacks added in v4.11.0

func (x *StartWorkflowExecutionRequest) GetCompletionCallbacks() []*v13.Callback

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

func (x *StartWorkflowExecutionRequest) Reset()

func (*StartWorkflowExecutionRequest) 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 (*StartWorkflowExecutionResponse) GetRunId

func (x *StartWorkflowExecutionResponse) GetRunId() string

func (*StartWorkflowExecutionResponse) ProtoMessage

func (*StartWorkflowExecutionResponse) ProtoMessage()

func (*StartWorkflowExecutionResponse) ProtoReflect

func (*StartWorkflowExecutionResponse) Reset

func (x *StartWorkflowExecutionResponse) Reset()

func (*StartWorkflowExecutionResponse) 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 (*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 (*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 (*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 (*TerminateWorkflowExecutionRequest) GetWorkflowExecution

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

func (*TerminateWorkflowExecutionRequest) ProtoMessage

func (*TerminateWorkflowExecutionRequest) ProtoMessage()

func (*TerminateWorkflowExecutionRequest) ProtoReflect

func (*TerminateWorkflowExecutionRequest) Reset

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

func (*TerminateWorkflowExecutionResponse) String

type UnimplementedWorkflowServiceServer

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedWorkflowServiceServer) CreateSchedule

func (UnimplementedWorkflowServiceServer) DeleteSchedule

func (UnimplementedWorkflowServiceServer) DeprecateNamespace

func (UnimplementedWorkflowServiceServer) DescribeNamespace

func (UnimplementedWorkflowServiceServer) DescribeSchedule

func (UnimplementedWorkflowServiceServer) DescribeTaskQueue

func (UnimplementedWorkflowServiceServer) GetClusterInfo

func (UnimplementedWorkflowServiceServer) GetSearchAttributes

func (UnimplementedWorkflowServiceServer) GetSystemInfo

func (UnimplementedWorkflowServiceServer) ListBatchOperations

func (UnimplementedWorkflowServiceServer) ListNamespaces

func (UnimplementedWorkflowServiceServer) ListSchedules

func (UnimplementedWorkflowServiceServer) PatchSchedule

func (UnimplementedWorkflowServiceServer) PollNexusTaskQueue added in v4.11.0

func (UnimplementedWorkflowServiceServer) QueryWorkflow

func (UnimplementedWorkflowServiceServer) RegisterNamespace

func (UnimplementedWorkflowServiceServer) RespondNexusTaskCompleted added in v4.11.0

func (UnimplementedWorkflowServiceServer) RespondNexusTaskFailed added in v4.11.0

func (UnimplementedWorkflowServiceServer) StartBatchOperation

func (UnimplementedWorkflowServiceServer) StopBatchOperation

func (UnimplementedWorkflowServiceServer) UpdateNamespace

func (UnimplementedWorkflowServiceServer) UpdateSchedule

type UnsafeWorkflowServiceServer

type UnsafeWorkflowServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkflowServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkflowServiceServer will result in compilation errors.

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 (*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
	//	*UpdateWorkerBuildIdCompatibilityRequest_MergeSets_
	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 (*UpdateWorkerBuildIdCompatibilityRequest) GetMergeSets

func (*UpdateWorkerBuildIdCompatibilityRequest) GetNamespace

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 (*UpdateWorkerBuildIdCompatibilityRequest) ProtoMessage

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoReflect

func (*UpdateWorkerBuildIdCompatibilityRequest) Reset

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetExistingCompatibleBuildId

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetMakeSetDefault

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) GetNewBuildId

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) ProtoMessage

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) ProtoReflect

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) Reset

func (*UpdateWorkerBuildIdCompatibilityRequest_AddNewCompatibleVersion) String

type UpdateWorkerBuildIdCompatibilityRequest_MergeSets

type UpdateWorkerBuildIdCompatibilityRequest_MergeSets struct {

	// A build ID in the set whose default will become the merged set default
	PrimarySetBuildId string `protobuf:"bytes,1,opt,name=primary_set_build_id,json=primarySetBuildId,proto3" json:"primary_set_build_id,omitempty"`
	// A build ID in the set which will be merged into the primary set
	SecondarySetBuildId string `protobuf:"bytes,2,opt,name=secondary_set_build_id,json=secondarySetBuildId,proto3" json:"secondary_set_build_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) Descriptor deprecated

Deprecated: Use UpdateWorkerBuildIdCompatibilityRequest_MergeSets.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) GetPrimarySetBuildId

func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) GetSecondarySetBuildId

func (x *UpdateWorkerBuildIdCompatibilityRequest_MergeSets) GetSecondarySetBuildId() string

func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) ProtoMessage

func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) ProtoReflect

func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) Reset

func (*UpdateWorkerBuildIdCompatibilityRequest_MergeSets) String

type UpdateWorkerBuildIdCompatibilityRequest_MergeSets_

type UpdateWorkerBuildIdCompatibilityRequest_MergeSets_ struct {
	// Merge two existing sets together, thus declaring all build IDs in both sets compatible
	// with one another. The primary set's default will become the default for the merged set.
	// This is useful if you've accidentally declared a new ID as incompatible you meant to
	// declare as compatible. The unusual case of incomplete replication during failover could
	// also result in a split set, which this operation can repair.
	MergeSets *UpdateWorkerBuildIdCompatibilityRequest_MergeSets `protobuf:"bytes,7,opt,name=merge_sets,json=mergeSets,proto3,oneof"`
}

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

func (*UpdateWorkerBuildIdCompatibilityResponse) Descriptor deprecated

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoMessage

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoReflect

func (*UpdateWorkerBuildIdCompatibilityResponse) Reset

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

func (x *UpdateWorkflowExecutionRequest) Reset()

func (*UpdateWorkflowExecutionRequest) 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"`
	// The most advanced lifecycle stage that the Update is known to have
	// reached, where lifecycle stages are ordered
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_UNSPECIFIED <
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ADMITTED <
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_ACCEPTED <
	// UPDATE_WORKFLOW_EXECUTION_LIFECYCLE_STAGE_COMPLETED.
	// UNSPECIFIED will be returned if and only if the server's maximum wait
	// time was reached before the Update reached the stage specified in the
	// request WaitPolicy, and before the context deadline expired; clients may
	// may then retry the call as needed.
	Stage v11.UpdateWorkflowExecutionLifecycleStage `` /* 129-byte string literal not displayed */
	// 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) GetStage added in v4.10.0

func (*UpdateWorkflowExecutionResponse) GetUpdateRef

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

func (*UpdateWorkflowExecutionResponse) ProtoMessage

func (*UpdateWorkflowExecutionResponse) ProtoMessage()

func (*UpdateWorkflowExecutionResponse) ProtoReflect

func (*UpdateWorkflowExecutionResponse) Reset

func (*UpdateWorkflowExecutionResponse) String

type WorkflowServiceClient

type WorkflowServiceClient interface {
	// RegisterNamespace creates a new namespace which can be used as a container for all resources.
	//
	// A Namespace is a top level entity within Temporal, and is used as a container for resources
	// like workflow executions, task queues, etc. A Namespace acts as a sandbox and provides
	// isolation for all resources within the namespace. All resources belongs to exactly one
	// namespace.
	RegisterNamespace(ctx context.Context, in *RegisterNamespaceRequest, opts ...grpc.CallOption) (*RegisterNamespaceResponse, error)
	// DescribeNamespace returns the information and configuration for a registered namespace.
	DescribeNamespace(ctx context.Context, in *DescribeNamespaceRequest, opts ...grpc.CallOption) (*DescribeNamespaceResponse, error)
	// ListNamespaces returns the information and configuration for all namespaces.
	ListNamespaces(ctx context.Context, in *ListNamespacesRequest, opts ...grpc.CallOption) (*ListNamespacesResponse, error)
	// UpdateNamespace is used to update the information and configuration of a registered
	// namespace.
	UpdateNamespace(ctx context.Context, in *UpdateNamespaceRequest, opts ...grpc.CallOption) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace is used to update the state of a registered namespace to DEPRECATED.
	//
	// Once the namespace is deprecated it cannot be used to start new workflow executions. Existing
	// workflow executions will continue to run on deprecated namespaces.
	// Deprecated.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: Deprecated --)
	DeprecateNamespace(ctx context.Context, in *DeprecateNamespaceRequest, opts ...grpc.CallOption) (*DeprecateNamespaceResponse, error)
	// StartWorkflowExecution starts a new workflow execution.
	//
	// It will create the execution with a `WORKFLOW_EXECUTION_STARTED` event in its history and
	// also schedule the first workflow task. Returns `WorkflowExecutionAlreadyStarted`, if an
	// instance already exists with same workflow id.
	StartWorkflowExecution(ctx context.Context, in *StartWorkflowExecutionRequest, opts ...grpc.CallOption) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution. Fails with
	// `NotFound` if the specified workflow execution is unknown to the service.
	GetWorkflowExecutionHistory(ctx context.Context, in *GetWorkflowExecutionHistoryRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionHistoryResponse, error)
	// GetWorkflowExecutionHistoryReverse returns the history of specified workflow execution in reverse
	// order (starting from last event). Fails with`NotFound` if the specified workflow execution is
	// unknown to the service.
	GetWorkflowExecutionHistoryReverse(ctx context.Context, in *GetWorkflowExecutionHistoryReverseRequest, opts ...grpc.CallOption) (*GetWorkflowExecutionHistoryReverseResponse, error)
	// PollWorkflowTaskQueue is called by workers to make progress on workflows.
	//
	// A WorkflowTask is dispatched to callers for active workflow executions with pending workflow
	// tasks. The worker is expected to call `RespondWorkflowTaskCompleted` when it is done
	// processing the task. The service will create a `WorkflowTaskStarted` event in the history for
	// this task before handing it to the worker.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	PollWorkflowTaskQueue(ctx context.Context, in *PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*PollWorkflowTaskQueueResponse, error)
	// RespondWorkflowTaskCompleted is called by workers to successfully complete workflow tasks
	// they received from `PollWorkflowTaskQueue`.
	//
	// Completing a WorkflowTask will write a `WORKFLOW_TASK_COMPLETED` event to the workflow's
	// history, along with events corresponding to whatever commands the SDK generated while
	// executing the task (ex timer started, activity task scheduled, etc).
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondWorkflowTaskCompleted(ctx context.Context, in *RespondWorkflowTaskCompletedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by workers to indicate the processing of a workflow task
	// failed.
	//
	// This results in a `WORKFLOW_TASK_FAILED` event written to the history, and a new workflow
	// task will be scheduled. This API can be used to report unhandled failures resulting from
	// applying the workflow task.
	//
	// Temporal will only append first WorkflowTaskFailed event to the history of workflow execution
	// for consecutive failures.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondWorkflowTaskFailed(ctx context.Context, in *RespondWorkflowTaskFailedRequest, opts ...grpc.CallOption) (*RespondWorkflowTaskFailedResponse, error)
	// PollActivityTaskQueue is called by workers to process activity tasks from a specific task
	// queue.
	//
	// The worker is expected to call one of the `RespondActivityTaskXXX` methods when it is done
	// processing the task.
	//
	// An activity task is dispatched whenever a `SCHEDULE_ACTIVITY_TASK` command is produced during
	// workflow execution. An in memory `ACTIVITY_TASK_STARTED` event is written to mutable state
	// before the task is dispatched to the worker. The started event, and the final event
	// (`ACTIVITY_TASK_COMPLETED` / `ACTIVITY_TASK_FAILED` / `ACTIVITY_TASK_TIMED_OUT`) will both be
	// written permanently to Workflow execution history when Activity is finished. This is done to
	// avoid writing many events in the case of a failure/retry loop.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	PollActivityTaskQueue(ctx context.Context, in *PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*PollActivityTaskQueueResponse, error)
	// RecordActivityTaskHeartbeat is optionally called by workers while they execute activities.
	//
	// If worker fails to heartbeat within the `heartbeat_timeout` interval for the activity task,
	// then it will be marked as timed out and an `ACTIVITY_TASK_TIMED_OUT` event will be written to
	// the workflow history. Calling `RecordActivityTaskHeartbeat` will fail with `NotFound` in
	// such situations, in that event, the SDK should request cancellation of the activity.
	RecordActivityTaskHeartbeat(ctx context.Context, in *RecordActivityTaskHeartbeatRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatResponse, error)
	// See `RecordActivityTaskHeartbeat`. This version allows clients to record heartbeats by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "By" is used to indicate request type. --)
	RecordActivityTaskHeartbeatById(ctx context.Context, in *RecordActivityTaskHeartbeatByIdRequest, opts ...grpc.CallOption) (*RecordActivityTaskHeartbeatByIdResponse, error)
	// RespondActivityTaskCompleted is called by workers when they successfully complete an activity
	// task.
	//
	// This results in a new `ACTIVITY_TASK_COMPLETED` event being written to the workflow history
	// and a new workflow task created for the workflow. Fails with `NotFound` if the task token is
	// no longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskCompleted(ctx context.Context, in *RespondActivityTaskCompletedRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedResponse, error)
	// See `RecordActivityTaskCompleted`. This version allows clients to record completions by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskCompletedById(ctx context.Context, in *RespondActivityTaskCompletedByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskCompletedByIdResponse, error)
	// RespondActivityTaskFailed is called by workers when processing an activity task fails.
	//
	// This results in a new `ACTIVITY_TASK_FAILED` event being written to the workflow history and
	// a new workflow task created for the workflow. Fails with `NotFound` if the task token is no
	// longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskFailed(ctx context.Context, in *RespondActivityTaskFailedRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedResponse, error)
	// See `RecordActivityTaskFailed`. This version allows clients to record failures by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskFailedById(ctx context.Context, in *RespondActivityTaskFailedByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskFailedByIdResponse, error)
	// RespondActivityTaskFailed is called by workers when processing an activity task fails.
	//
	// This results in a new `ACTIVITY_TASK_CANCELED` event being written to the workflow history
	// and a new workflow task created for the workflow. Fails with `NotFound` if the task token is
	// no longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskCanceled(ctx context.Context, in *RespondActivityTaskCanceledRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledResponse, error)
	// See `RecordActivityTaskCanceled`. This version allows clients to record failures by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskCanceledById(ctx context.Context, in *RespondActivityTaskCanceledByIdRequest, opts ...grpc.CallOption) (*RespondActivityTaskCanceledByIdResponse, error)
	// RequestCancelWorkflowExecution is called by workers when they want to request cancellation of
	// a workflow execution.
	//
	// This results in a new `WORKFLOW_EXECUTION_CANCEL_REQUESTED` event being written to the
	// workflow history and a new workflow task created for the workflow. It returns success if the requested
	// workflow is already closed. It fails with 'NotFound' if the requested workflow doesn't exist.
	RequestCancelWorkflowExecution(ctx context.Context, in *RequestCancelWorkflowExecutionRequest, opts ...grpc.CallOption) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal to a running workflow execution.
	//
	// This results in a `WORKFLOW_EXECUTION_SIGNALED` event recorded in the history and a workflow
	// task being created for the execution.
	SignalWorkflowExecution(ctx context.Context, in *SignalWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWorkflowExecutionResponse, error)
	// SignalWithStartWorkflowExecution is used to ensure a signal is sent to a workflow, even if
	// it isn't yet started.
	//
	// If the workflow is running, a `WORKFLOW_EXECUTION_SIGNALED` event is recorded in the history
	// and a workflow task is generated.
	//
	// If the workflow is not running or not found, then the workflow is created with
	// `WORKFLOW_EXECUTION_STARTED` and `WORKFLOW_EXECUTION_SIGNALED` events in its history, and a
	// workflow task is generated.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "With" is used to indicate combined operation. --)
	SignalWithStartWorkflowExecution(ctx context.Context, in *SignalWithStartWorkflowExecutionRequest, opts ...grpc.CallOption) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution will reset an existing workflow execution to a specified
	// `WORKFLOW_TASK_COMPLETED` event (exclusive). It will immediately terminate the current
	// execution instance.
	// TODO: Does exclusive here mean *just* the completed event, or also WFT started? Otherwise the task is doomed to time out?
	ResetWorkflowExecution(ctx context.Context, in *ResetWorkflowExecutionRequest, opts ...grpc.CallOption) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording a
	// `WORKFLOW_EXECUTION_TERMINATED` event in the history and immediately terminating the
	// execution instance.
	TerminateWorkflowExecution(ctx context.Context, in *TerminateWorkflowExecutionRequest, opts ...grpc.CallOption) (*TerminateWorkflowExecutionResponse, error)
	// DeleteWorkflowExecution asynchronously deletes a specific Workflow Execution (when
	// WorkflowExecution.run_id is provided) or the latest Workflow Execution (when
	// WorkflowExecution.run_id is not provided). If the Workflow Execution is Running, it will be
	// terminated before deletion.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: Workflow deletion not exposed to HTTP, users should use cancel or terminate. --)
	DeleteWorkflowExecution(ctx context.Context, in *DeleteWorkflowExecutionRequest, opts ...grpc.CallOption) (*DeleteWorkflowExecutionResponse, error)
	// ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific namespace.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: HTTP users should use ListWorkflowExecutions instead. --)
	ListOpenWorkflowExecutions(ctx context.Context, in *ListOpenWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListOpenWorkflowExecutionsResponse, error)
	// ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific namespace.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: HTTP users should use ListWorkflowExecutions instead. --)
	ListClosedWorkflowExecutions(ctx context.Context, in *ListClosedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListClosedWorkflowExecutionsResponse, error)
	// ListWorkflowExecutions is a visibility API to list workflow executions in a specific namespace.
	ListWorkflowExecutions(ctx context.Context, in *ListWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListWorkflowExecutionsResponse, error)
	// ListArchivedWorkflowExecutions is a visibility API to list archived workflow executions in a specific namespace.
	ListArchivedWorkflowExecutions(ctx context.Context, in *ListArchivedWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ListArchivedWorkflowExecutionsResponse, error)
	// ScanWorkflowExecutions is a visibility API to list large amount of workflow executions in a specific namespace without order.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: HTTP users should use ListWorkflowExecutions instead. --)
	ScanWorkflowExecutions(ctx context.Context, in *ScanWorkflowExecutionsRequest, opts ...grpc.CallOption) (*ScanWorkflowExecutionsResponse, error)
	// CountWorkflowExecutions is a visibility API to count of workflow executions in a specific namespace.
	CountWorkflowExecutions(ctx context.Context, in *CountWorkflowExecutionsRequest, opts ...grpc.CallOption) (*CountWorkflowExecutionsResponse, error)
	// GetSearchAttributes is a visibility API to get all legal keys that could be used in list APIs
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose this search attribute API to HTTP (but may expose on OperatorService). --)
	GetSearchAttributes(ctx context.Context, in *GetSearchAttributesRequest, opts ...grpc.CallOption) (*GetSearchAttributesResponse, error)
	// RespondQueryTaskCompleted is called by workers to complete queries which were delivered on
	// the `query` (not `queries`) field of a `PollWorkflowTaskQueueResponse`.
	//
	// Completing the query will unblock the corresponding client call to `QueryWorkflow` and return
	// the query result a response.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondQueryTaskCompleted(ctx context.Context, in *RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskQueue resets the sticky task queue related information in the mutable state of
	// a given workflow. This is prudent for workers to perform if a workflow has been paged out of
	// their cache.
	//
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	ResetStickyTaskQueue(ctx context.Context, in *ResetStickyTaskQueueRequest, opts ...grpc.CallOption) (*ResetStickyTaskQueueResponse, error)
	// QueryWorkflow requests a query be executed for a specified workflow execution.
	QueryWorkflow(ctx context.Context, in *QueryWorkflowRequest, opts ...grpc.CallOption) (*QueryWorkflowResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(ctx context.Context, in *DescribeWorkflowExecutionRequest, opts ...grpc.CallOption) (*DescribeWorkflowExecutionResponse, error)
	// DescribeTaskQueue returns information about the target task queue.
	DescribeTaskQueue(ctx context.Context, in *DescribeTaskQueueRequest, opts ...grpc.CallOption) (*DescribeTaskQueueResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
	// GetSystemInfo returns information about the system.
	GetSystemInfo(ctx context.Context, in *GetSystemInfoRequest, opts ...grpc.CallOption) (*GetSystemInfoResponse, error)
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose this low-level API to HTTP. --)
	ListTaskQueuePartitions(ctx context.Context, in *ListTaskQueuePartitionsRequest, opts ...grpc.CallOption) (*ListTaskQueuePartitionsResponse, error)
	// Creates a new schedule.
	CreateSchedule(ctx context.Context, in *CreateScheduleRequest, opts ...grpc.CallOption) (*CreateScheduleResponse, error)
	// Returns the schedule description and current state of an existing schedule.
	DescribeSchedule(ctx context.Context, in *DescribeScheduleRequest, opts ...grpc.CallOption) (*DescribeScheduleResponse, error)
	// Changes the configuration or state of an existing schedule.
	UpdateSchedule(ctx context.Context, in *UpdateScheduleRequest, opts ...grpc.CallOption) (*UpdateScheduleResponse, error)
	// Makes a specific change to a schedule or triggers an immediate action.
	PatchSchedule(ctx context.Context, in *PatchScheduleRequest, opts ...grpc.CallOption) (*PatchScheduleResponse, error)
	// Lists matching times within a range.
	ListScheduleMatchingTimes(ctx context.Context, in *ListScheduleMatchingTimesRequest, opts ...grpc.CallOption) (*ListScheduleMatchingTimesResponse, error)
	// Deletes a schedule, removing it from the system.
	DeleteSchedule(ctx context.Context, in *DeleteScheduleRequest, opts ...grpc.CallOption) (*DeleteScheduleResponse, error)
	// List all schedules in a namespace.
	ListSchedules(ctx context.Context, in *ListSchedulesRequest, opts ...grpc.CallOption) (*ListSchedulesResponse, error)
	// Allows users to specify sets of worker build id versions on a per task queue basis. Versions
	// are ordered, and may be either compatible with some extant version, or a new incompatible
	// version, forming sets of ids which are incompatible with each other, but whose contained
	// members are compatible with one another.
	//
	// A single build id may be mapped to multiple task queues using this API for cases where a single process hosts
	// multiple workers.
	//
	// To query which workers can be retired, use the `GetWorkerTaskReachability` API.
	//
	// NOTE: The number of task queues mapped to a single build id is limited by the `limit.taskQueuesPerBuildId`
	// (default is 20), if this limit is exceeded this API will error with a FailedPrecondition.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do yet expose versioning API to HTTP. --)
	UpdateWorkerBuildIdCompatibility(ctx context.Context, in *UpdateWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption) (*UpdateWorkerBuildIdCompatibilityResponse, error)
	// Fetches the worker build id versioning sets for a task queue.
	GetWorkerBuildIdCompatibility(ctx context.Context, in *GetWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption) (*GetWorkerBuildIdCompatibilityResponse, error)
	// Fetches task reachability to determine whether a worker may be retired.
	// The request may specify task queues to query for or let the server fetch all task queues mapped to the given
	// build IDs.
	//
	// When requesting a large number of task queues or all task queues associated with the given build ids in a
	// namespace, all task queues will be listed in the response but some of them may not contain reachability
	// information due to a server enforced limit. When reaching the limit, task queues that reachability information
	// could not be retrieved for will be marked with a single TASK_REACHABILITY_UNSPECIFIED entry. The caller may issue
	// another call to get the reachability for those task queues.
	//
	// Open source users can adjust this limit by setting the server's dynamic config value for
	// `limit.reachabilityTaskQueueScan` with the caveat that this call can strain the visibility store.
	GetWorkerTaskReachability(ctx context.Context, in *GetWorkerTaskReachabilityRequest, opts ...grpc.CallOption) (*GetWorkerTaskReachabilityResponse, error)
	// Invokes the specified update function on user workflow code.
	UpdateWorkflowExecution(ctx context.Context, in *UpdateWorkflowExecutionRequest, opts ...grpc.CallOption) (*UpdateWorkflowExecutionResponse, error)
	// Polls a workflow execution for the outcome of a workflow execution update
	// previously issued through the UpdateWorkflowExecution RPC. The effective
	// timeout on this call will be shorter of the the caller-supplied gRPC
	// timeout and the server's configured long-poll timeout.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We don't expose update polling API to HTTP in favor of a potential future non-blocking form. --)
	PollWorkflowExecutionUpdate(ctx context.Context, in *PollWorkflowExecutionUpdateRequest, opts ...grpc.CallOption) (*PollWorkflowExecutionUpdateResponse, error)
	// StartBatchOperation starts a new batch operation
	StartBatchOperation(ctx context.Context, in *StartBatchOperationRequest, opts ...grpc.CallOption) (*StartBatchOperationResponse, error)
	// StopBatchOperation stops a batch operation
	StopBatchOperation(ctx context.Context, in *StopBatchOperationRequest, opts ...grpc.CallOption) (*StopBatchOperationResponse, error)
	// DescribeBatchOperation returns the information about a batch operation
	DescribeBatchOperation(ctx context.Context, in *DescribeBatchOperationRequest, opts ...grpc.CallOption) (*DescribeBatchOperationResponse, error)
	// ListBatchOperations returns a list of batch operations
	ListBatchOperations(ctx context.Context, in *ListBatchOperationsRequest, opts ...grpc.CallOption) (*ListBatchOperationsResponse, error)
	// PollNexusTaskQueue is a long poll call used by workers to receive Nexus tasks.
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	PollNexusTaskQueue(ctx context.Context, in *PollNexusTaskQueueRequest, opts ...grpc.CallOption) (*PollNexusTaskQueueResponse, error)
	// RespondNexusTaskCompleted is called by workers to respond to Nexus tasks received via PollNexusTaskQueue.
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondNexusTaskCompleted(ctx context.Context, in *RespondNexusTaskCompletedRequest, opts ...grpc.CallOption) (*RespondNexusTaskCompletedResponse, error)
	// RespondNexusTaskFailed is called by workers to fail Nexus tasks received via PollNexusTaskQueue.
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondNexusTaskFailed(ctx context.Context, in *RespondNexusTaskFailedRequest, opts ...grpc.CallOption) (*RespondNexusTaskFailedResponse, error)
}

WorkflowServiceClient is the client API for WorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type WorkflowServiceServer

type WorkflowServiceServer interface {
	// RegisterNamespace creates a new namespace which can be used as a container for all resources.
	//
	// A Namespace is a top level entity within Temporal, and is used as a container for resources
	// like workflow executions, task queues, etc. A Namespace acts as a sandbox and provides
	// isolation for all resources within the namespace. All resources belongs to exactly one
	// namespace.
	RegisterNamespace(context.Context, *RegisterNamespaceRequest) (*RegisterNamespaceResponse, error)
	// DescribeNamespace returns the information and configuration for a registered namespace.
	DescribeNamespace(context.Context, *DescribeNamespaceRequest) (*DescribeNamespaceResponse, error)
	// ListNamespaces returns the information and configuration for all namespaces.
	ListNamespaces(context.Context, *ListNamespacesRequest) (*ListNamespacesResponse, error)
	// UpdateNamespace is used to update the information and configuration of a registered
	// namespace.
	UpdateNamespace(context.Context, *UpdateNamespaceRequest) (*UpdateNamespaceResponse, error)
	// DeprecateNamespace is used to update the state of a registered namespace to DEPRECATED.
	//
	// Once the namespace is deprecated it cannot be used to start new workflow executions. Existing
	// workflow executions will continue to run on deprecated namespaces.
	// Deprecated.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: Deprecated --)
	DeprecateNamespace(context.Context, *DeprecateNamespaceRequest) (*DeprecateNamespaceResponse, error)
	// StartWorkflowExecution starts a new workflow execution.
	//
	// It will create the execution with a `WORKFLOW_EXECUTION_STARTED` event in its history and
	// also schedule the first workflow task. Returns `WorkflowExecutionAlreadyStarted`, if an
	// instance already exists with same workflow id.
	StartWorkflowExecution(context.Context, *StartWorkflowExecutionRequest) (*StartWorkflowExecutionResponse, error)
	// GetWorkflowExecutionHistory returns the history of specified workflow execution. Fails with
	// `NotFound` if the specified workflow execution is unknown to the service.
	GetWorkflowExecutionHistory(context.Context, *GetWorkflowExecutionHistoryRequest) (*GetWorkflowExecutionHistoryResponse, error)
	// GetWorkflowExecutionHistoryReverse returns the history of specified workflow execution in reverse
	// order (starting from last event). Fails with`NotFound` if the specified workflow execution is
	// unknown to the service.
	GetWorkflowExecutionHistoryReverse(context.Context, *GetWorkflowExecutionHistoryReverseRequest) (*GetWorkflowExecutionHistoryReverseResponse, error)
	// PollWorkflowTaskQueue is called by workers to make progress on workflows.
	//
	// A WorkflowTask is dispatched to callers for active workflow executions with pending workflow
	// tasks. The worker is expected to call `RespondWorkflowTaskCompleted` when it is done
	// processing the task. The service will create a `WorkflowTaskStarted` event in the history for
	// this task before handing it to the worker.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	PollWorkflowTaskQueue(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)
	// RespondWorkflowTaskCompleted is called by workers to successfully complete workflow tasks
	// they received from `PollWorkflowTaskQueue`.
	//
	// Completing a WorkflowTask will write a `WORKFLOW_TASK_COMPLETED` event to the workflow's
	// history, along with events corresponding to whatever commands the SDK generated while
	// executing the task (ex timer started, activity task scheduled, etc).
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondWorkflowTaskCompleted(context.Context, *RespondWorkflowTaskCompletedRequest) (*RespondWorkflowTaskCompletedResponse, error)
	// RespondWorkflowTaskFailed is called by workers to indicate the processing of a workflow task
	// failed.
	//
	// This results in a `WORKFLOW_TASK_FAILED` event written to the history, and a new workflow
	// task will be scheduled. This API can be used to report unhandled failures resulting from
	// applying the workflow task.
	//
	// Temporal will only append first WorkflowTaskFailed event to the history of workflow execution
	// for consecutive failures.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondWorkflowTaskFailed(context.Context, *RespondWorkflowTaskFailedRequest) (*RespondWorkflowTaskFailedResponse, error)
	// PollActivityTaskQueue is called by workers to process activity tasks from a specific task
	// queue.
	//
	// The worker is expected to call one of the `RespondActivityTaskXXX` methods when it is done
	// processing the task.
	//
	// An activity task is dispatched whenever a `SCHEDULE_ACTIVITY_TASK` command is produced during
	// workflow execution. An in memory `ACTIVITY_TASK_STARTED` event is written to mutable state
	// before the task is dispatched to the worker. The started event, and the final event
	// (`ACTIVITY_TASK_COMPLETED` / `ACTIVITY_TASK_FAILED` / `ACTIVITY_TASK_TIMED_OUT`) will both be
	// written permanently to Workflow execution history when Activity is finished. This is done to
	// avoid writing many events in the case of a failure/retry loop.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	PollActivityTaskQueue(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)
	// RecordActivityTaskHeartbeat is optionally called by workers while they execute activities.
	//
	// If worker fails to heartbeat within the `heartbeat_timeout` interval for the activity task,
	// then it will be marked as timed out and an `ACTIVITY_TASK_TIMED_OUT` event will be written to
	// the workflow history. Calling `RecordActivityTaskHeartbeat` will fail with `NotFound` in
	// such situations, in that event, the SDK should request cancellation of the activity.
	RecordActivityTaskHeartbeat(context.Context, *RecordActivityTaskHeartbeatRequest) (*RecordActivityTaskHeartbeatResponse, error)
	// See `RecordActivityTaskHeartbeat`. This version allows clients to record heartbeats by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "By" is used to indicate request type. --)
	RecordActivityTaskHeartbeatById(context.Context, *RecordActivityTaskHeartbeatByIdRequest) (*RecordActivityTaskHeartbeatByIdResponse, error)
	// RespondActivityTaskCompleted is called by workers when they successfully complete an activity
	// task.
	//
	// This results in a new `ACTIVITY_TASK_COMPLETED` event being written to the workflow history
	// and a new workflow task created for the workflow. Fails with `NotFound` if the task token is
	// no longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskCompleted(context.Context, *RespondActivityTaskCompletedRequest) (*RespondActivityTaskCompletedResponse, error)
	// See `RecordActivityTaskCompleted`. This version allows clients to record completions by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskCompletedById(context.Context, *RespondActivityTaskCompletedByIdRequest) (*RespondActivityTaskCompletedByIdResponse, error)
	// RespondActivityTaskFailed is called by workers when processing an activity task fails.
	//
	// This results in a new `ACTIVITY_TASK_FAILED` event being written to the workflow history and
	// a new workflow task created for the workflow. Fails with `NotFound` if the task token is no
	// longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskFailed(context.Context, *RespondActivityTaskFailedRequest) (*RespondActivityTaskFailedResponse, error)
	// See `RecordActivityTaskFailed`. This version allows clients to record failures by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskFailedById(context.Context, *RespondActivityTaskFailedByIdRequest) (*RespondActivityTaskFailedByIdResponse, error)
	// RespondActivityTaskFailed is called by workers when processing an activity task fails.
	//
	// This results in a new `ACTIVITY_TASK_CANCELED` event being written to the workflow history
	// and a new workflow task created for the workflow. Fails with `NotFound` if the task token is
	// no longer valid due to activity timeout, already being completed, or never having existed.
	RespondActivityTaskCanceled(context.Context, *RespondActivityTaskCanceledRequest) (*RespondActivityTaskCanceledResponse, error)
	// See `RecordActivityTaskCanceled`. This version allows clients to record failures by
	// namespace/workflow id/activity id instead of task token.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "By" is used to indicate request type. --)
	RespondActivityTaskCanceledById(context.Context, *RespondActivityTaskCanceledByIdRequest) (*RespondActivityTaskCanceledByIdResponse, error)
	// RequestCancelWorkflowExecution is called by workers when they want to request cancellation of
	// a workflow execution.
	//
	// This results in a new `WORKFLOW_EXECUTION_CANCEL_REQUESTED` event being written to the
	// workflow history and a new workflow task created for the workflow. It returns success if the requested
	// workflow is already closed. It fails with 'NotFound' if the requested workflow doesn't exist.
	RequestCancelWorkflowExecution(context.Context, *RequestCancelWorkflowExecutionRequest) (*RequestCancelWorkflowExecutionResponse, error)
	// SignalWorkflowExecution is used to send a signal to a running workflow execution.
	//
	// This results in a `WORKFLOW_EXECUTION_SIGNALED` event recorded in the history and a workflow
	// task being created for the execution.
	SignalWorkflowExecution(context.Context, *SignalWorkflowExecutionRequest) (*SignalWorkflowExecutionResponse, error)
	// SignalWithStartWorkflowExecution is used to ensure a signal is sent to a workflow, even if
	// it isn't yet started.
	//
	// If the workflow is running, a `WORKFLOW_EXECUTION_SIGNALED` event is recorded in the history
	// and a workflow task is generated.
	//
	// If the workflow is not running or not found, then the workflow is created with
	// `WORKFLOW_EXECUTION_STARTED` and `WORKFLOW_EXECUTION_SIGNALED` events in its history, and a
	// workflow task is generated.
	//
	// (-- api-linter: core::0136::prepositions=disabled
	//
	//	aip.dev/not-precedent: "With" is used to indicate combined operation. --)
	SignalWithStartWorkflowExecution(context.Context, *SignalWithStartWorkflowExecutionRequest) (*SignalWithStartWorkflowExecutionResponse, error)
	// ResetWorkflowExecution will reset an existing workflow execution to a specified
	// `WORKFLOW_TASK_COMPLETED` event (exclusive). It will immediately terminate the current
	// execution instance.
	// TODO: Does exclusive here mean *just* the completed event, or also WFT started? Otherwise the task is doomed to time out?
	ResetWorkflowExecution(context.Context, *ResetWorkflowExecutionRequest) (*ResetWorkflowExecutionResponse, error)
	// TerminateWorkflowExecution terminates an existing workflow execution by recording a
	// `WORKFLOW_EXECUTION_TERMINATED` event in the history and immediately terminating the
	// execution instance.
	TerminateWorkflowExecution(context.Context, *TerminateWorkflowExecutionRequest) (*TerminateWorkflowExecutionResponse, error)
	// DeleteWorkflowExecution asynchronously deletes a specific Workflow Execution (when
	// WorkflowExecution.run_id is provided) or the latest Workflow Execution (when
	// WorkflowExecution.run_id is not provided). If the Workflow Execution is Running, it will be
	// terminated before deletion.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: Workflow deletion not exposed to HTTP, users should use cancel or terminate. --)
	DeleteWorkflowExecution(context.Context, *DeleteWorkflowExecutionRequest) (*DeleteWorkflowExecutionResponse, error)
	// ListOpenWorkflowExecutions is a visibility API to list the open executions in a specific namespace.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: HTTP users should use ListWorkflowExecutions instead. --)
	ListOpenWorkflowExecutions(context.Context, *ListOpenWorkflowExecutionsRequest) (*ListOpenWorkflowExecutionsResponse, error)
	// ListClosedWorkflowExecutions is a visibility API to list the closed executions in a specific namespace.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: HTTP users should use ListWorkflowExecutions instead. --)
	ListClosedWorkflowExecutions(context.Context, *ListClosedWorkflowExecutionsRequest) (*ListClosedWorkflowExecutionsResponse, error)
	// ListWorkflowExecutions is a visibility API to list workflow executions in a specific namespace.
	ListWorkflowExecutions(context.Context, *ListWorkflowExecutionsRequest) (*ListWorkflowExecutionsResponse, error)
	// ListArchivedWorkflowExecutions is a visibility API to list archived workflow executions in a specific namespace.
	ListArchivedWorkflowExecutions(context.Context, *ListArchivedWorkflowExecutionsRequest) (*ListArchivedWorkflowExecutionsResponse, error)
	// ScanWorkflowExecutions is a visibility API to list large amount of workflow executions in a specific namespace without order.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: HTTP users should use ListWorkflowExecutions instead. --)
	ScanWorkflowExecutions(context.Context, *ScanWorkflowExecutionsRequest) (*ScanWorkflowExecutionsResponse, error)
	// CountWorkflowExecutions is a visibility API to count of workflow executions in a specific namespace.
	CountWorkflowExecutions(context.Context, *CountWorkflowExecutionsRequest) (*CountWorkflowExecutionsResponse, error)
	// GetSearchAttributes is a visibility API to get all legal keys that could be used in list APIs
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose this search attribute API to HTTP (but may expose on OperatorService). --)
	GetSearchAttributes(context.Context, *GetSearchAttributesRequest) (*GetSearchAttributesResponse, error)
	// RespondQueryTaskCompleted is called by workers to complete queries which were delivered on
	// the `query` (not `queries`) field of a `PollWorkflowTaskQueueResponse`.
	//
	// Completing the query will unblock the corresponding client call to `QueryWorkflow` and return
	// the query result a response.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)
	// ResetStickyTaskQueue resets the sticky task queue related information in the mutable state of
	// a given workflow. This is prudent for workers to perform if a workflow has been paged out of
	// their cache.
	//
	// Things cleared are:
	// 1. StickyTaskQueue
	// 2. StickyScheduleToStartTimeout
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	ResetStickyTaskQueue(context.Context, *ResetStickyTaskQueueRequest) (*ResetStickyTaskQueueResponse, error)
	// QueryWorkflow requests a query be executed for a specified workflow execution.
	QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)
	// DescribeWorkflowExecution returns information about the specified workflow execution.
	DescribeWorkflowExecution(context.Context, *DescribeWorkflowExecutionRequest) (*DescribeWorkflowExecutionResponse, error)
	// DescribeTaskQueue returns information about the target task queue.
	DescribeTaskQueue(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)
	// GetClusterInfo returns information about temporal cluster
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	// GetSystemInfo returns information about the system.
	GetSystemInfo(context.Context, *GetSystemInfoRequest) (*GetSystemInfoResponse, error)
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose this low-level API to HTTP. --)
	ListTaskQueuePartitions(context.Context, *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)
	// Creates a new schedule.
	CreateSchedule(context.Context, *CreateScheduleRequest) (*CreateScheduleResponse, error)
	// Returns the schedule description and current state of an existing schedule.
	DescribeSchedule(context.Context, *DescribeScheduleRequest) (*DescribeScheduleResponse, error)
	// Changes the configuration or state of an existing schedule.
	UpdateSchedule(context.Context, *UpdateScheduleRequest) (*UpdateScheduleResponse, error)
	// Makes a specific change to a schedule or triggers an immediate action.
	PatchSchedule(context.Context, *PatchScheduleRequest) (*PatchScheduleResponse, error)
	// Lists matching times within a range.
	ListScheduleMatchingTimes(context.Context, *ListScheduleMatchingTimesRequest) (*ListScheduleMatchingTimesResponse, error)
	// Deletes a schedule, removing it from the system.
	DeleteSchedule(context.Context, *DeleteScheduleRequest) (*DeleteScheduleResponse, error)
	// List all schedules in a namespace.
	ListSchedules(context.Context, *ListSchedulesRequest) (*ListSchedulesResponse, error)
	// Allows users to specify sets of worker build id versions on a per task queue basis. Versions
	// are ordered, and may be either compatible with some extant version, or a new incompatible
	// version, forming sets of ids which are incompatible with each other, but whose contained
	// members are compatible with one another.
	//
	// A single build id may be mapped to multiple task queues using this API for cases where a single process hosts
	// multiple workers.
	//
	// To query which workers can be retired, use the `GetWorkerTaskReachability` API.
	//
	// NOTE: The number of task queues mapped to a single build id is limited by the `limit.taskQueuesPerBuildId`
	// (default is 20), if this limit is exceeded this API will error with a FailedPrecondition.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do yet expose versioning API to HTTP. --)
	UpdateWorkerBuildIdCompatibility(context.Context, *UpdateWorkerBuildIdCompatibilityRequest) (*UpdateWorkerBuildIdCompatibilityResponse, error)
	// Fetches the worker build id versioning sets for a task queue.
	GetWorkerBuildIdCompatibility(context.Context, *GetWorkerBuildIdCompatibilityRequest) (*GetWorkerBuildIdCompatibilityResponse, error)
	// Fetches task reachability to determine whether a worker may be retired.
	// The request may specify task queues to query for or let the server fetch all task queues mapped to the given
	// build IDs.
	//
	// When requesting a large number of task queues or all task queues associated with the given build ids in a
	// namespace, all task queues will be listed in the response but some of them may not contain reachability
	// information due to a server enforced limit. When reaching the limit, task queues that reachability information
	// could not be retrieved for will be marked with a single TASK_REACHABILITY_UNSPECIFIED entry. The caller may issue
	// another call to get the reachability for those task queues.
	//
	// Open source users can adjust this limit by setting the server's dynamic config value for
	// `limit.reachabilityTaskQueueScan` with the caveat that this call can strain the visibility store.
	GetWorkerTaskReachability(context.Context, *GetWorkerTaskReachabilityRequest) (*GetWorkerTaskReachabilityResponse, error)
	// Invokes the specified update function on user workflow code.
	UpdateWorkflowExecution(context.Context, *UpdateWorkflowExecutionRequest) (*UpdateWorkflowExecutionResponse, error)
	// Polls a workflow execution for the outcome of a workflow execution update
	// previously issued through the UpdateWorkflowExecution RPC. The effective
	// timeout on this call will be shorter of the the caller-supplied gRPC
	// timeout and the server's configured long-poll timeout.
	//
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We don't expose update polling API to HTTP in favor of a potential future non-blocking form. --)
	PollWorkflowExecutionUpdate(context.Context, *PollWorkflowExecutionUpdateRequest) (*PollWorkflowExecutionUpdateResponse, error)
	// StartBatchOperation starts a new batch operation
	StartBatchOperation(context.Context, *StartBatchOperationRequest) (*StartBatchOperationResponse, error)
	// StopBatchOperation stops a batch operation
	StopBatchOperation(context.Context, *StopBatchOperationRequest) (*StopBatchOperationResponse, error)
	// DescribeBatchOperation returns the information about a batch operation
	DescribeBatchOperation(context.Context, *DescribeBatchOperationRequest) (*DescribeBatchOperationResponse, error)
	// ListBatchOperations returns a list of batch operations
	ListBatchOperations(context.Context, *ListBatchOperationsRequest) (*ListBatchOperationsResponse, error)
	// PollNexusTaskQueue is a long poll call used by workers to receive Nexus tasks.
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	PollNexusTaskQueue(context.Context, *PollNexusTaskQueueRequest) (*PollNexusTaskQueueResponse, error)
	// RespondNexusTaskCompleted is called by workers to respond to Nexus tasks received via PollNexusTaskQueue.
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondNexusTaskCompleted(context.Context, *RespondNexusTaskCompletedRequest) (*RespondNexusTaskCompletedResponse, error)
	// RespondNexusTaskFailed is called by workers to fail Nexus tasks received via PollNexusTaskQueue.
	// (-- api-linter: core::0127::http-annotation=disabled
	//
	//	aip.dev/not-precedent: We do not expose worker API to HTTP. --)
	RespondNexusTaskFailed(context.Context, *RespondNexusTaskFailedRequest) (*RespondNexusTaskFailedResponse, error)
}

WorkflowServiceServer is the server API for WorkflowService service. All implementations should embed UnimplementedWorkflowServiceServer for forward compatibility

Jump to

Keyboard shortcuts

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