matchingservice

package
v1.25.0-115.0 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2024 License: MIT Imports: 23 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-helpers. DO NOT EDIT.

Index

Constants

View Source 
const (
	MatchingService_PollWorkflowTaskQueue_FullMethodName                  = "/temporal.server.api.matchingservice.v1.MatchingService/PollWorkflowTaskQueue"
	MatchingService_PollActivityTaskQueue_FullMethodName                  = "/temporal.server.api.matchingservice.v1.MatchingService/PollActivityTaskQueue"
	MatchingService_AddWorkflowTask_FullMethodName                        = "/temporal.server.api.matchingservice.v1.MatchingService/AddWorkflowTask"
	MatchingService_AddActivityTask_FullMethodName                        = "/temporal.server.api.matchingservice.v1.MatchingService/AddActivityTask"
	MatchingService_QueryWorkflow_FullMethodName                          = "/temporal.server.api.matchingservice.v1.MatchingService/QueryWorkflow"
	MatchingService_RespondQueryTaskCompleted_FullMethodName              = "/temporal.server.api.matchingservice.v1.MatchingService/RespondQueryTaskCompleted"
	MatchingService_DispatchNexusTask_FullMethodName                      = "/temporal.server.api.matchingservice.v1.MatchingService/DispatchNexusTask"
	MatchingService_PollNexusTaskQueue_FullMethodName                     = "/temporal.server.api.matchingservice.v1.MatchingService/PollNexusTaskQueue"
	MatchingService_RespondNexusTaskCompleted_FullMethodName              = "/temporal.server.api.matchingservice.v1.MatchingService/RespondNexusTaskCompleted"
	MatchingService_RespondNexusTaskFailed_FullMethodName                 = "/temporal.server.api.matchingservice.v1.MatchingService/RespondNexusTaskFailed"
	MatchingService_CancelOutstandingPoll_FullMethodName                  = "/temporal.server.api.matchingservice.v1.MatchingService/CancelOutstandingPoll"
	MatchingService_DescribeTaskQueue_FullMethodName                      = "/temporal.server.api.matchingservice.v1.MatchingService/DescribeTaskQueue"
	MatchingService_DescribeTaskQueuePartition_FullMethodName             = "/temporal.server.api.matchingservice.v1.MatchingService/DescribeTaskQueuePartition"
	MatchingService_ListTaskQueuePartitions_FullMethodName                = "/temporal.server.api.matchingservice.v1.MatchingService/ListTaskQueuePartitions"
	MatchingService_UpdateWorkerBuildIdCompatibility_FullMethodName       = "/temporal.server.api.matchingservice.v1.MatchingService/UpdateWorkerBuildIdCompatibility"
	MatchingService_GetWorkerBuildIdCompatibility_FullMethodName          = "/temporal.server.api.matchingservice.v1.MatchingService/GetWorkerBuildIdCompatibility"
	MatchingService_GetTaskQueueUserData_FullMethodName                   = "/temporal.server.api.matchingservice.v1.MatchingService/GetTaskQueueUserData"
	MatchingService_UpdateWorkerVersioningRules_FullMethodName            = "/temporal.server.api.matchingservice.v1.MatchingService/UpdateWorkerVersioningRules"
	MatchingService_GetWorkerVersioningRules_FullMethodName               = "/temporal.server.api.matchingservice.v1.MatchingService/GetWorkerVersioningRules"
	MatchingService_ApplyTaskQueueUserDataReplicationEvent_FullMethodName = "/temporal.server.api.matchingservice.v1.MatchingService/ApplyTaskQueueUserDataReplicationEvent"
	MatchingService_GetBuildIdTaskQueueMapping_FullMethodName             = "/temporal.server.api.matchingservice.v1.MatchingService/GetBuildIdTaskQueueMapping"
	MatchingService_ForceUnloadTaskQueue_FullMethodName                   = "/temporal.server.api.matchingservice.v1.MatchingService/ForceUnloadTaskQueue"
	MatchingService_UpdateTaskQueueUserData_FullMethodName                = "/temporal.server.api.matchingservice.v1.MatchingService/UpdateTaskQueueUserData"
	MatchingService_ReplicateTaskQueueUserData_FullMethodName             = "/temporal.server.api.matchingservice.v1.MatchingService/ReplicateTaskQueueUserData"
	MatchingService_CreateNexusEndpoint_FullMethodName                    = "/temporal.server.api.matchingservice.v1.MatchingService/CreateNexusEndpoint"
	MatchingService_UpdateNexusEndpoint_FullMethodName                    = "/temporal.server.api.matchingservice.v1.MatchingService/UpdateNexusEndpoint"
	MatchingService_DeleteNexusEndpoint_FullMethodName                    = "/temporal.server.api.matchingservice.v1.MatchingService/DeleteNexusEndpoint"
	MatchingService_ListNexusEndpoints_FullMethodName                     = "/temporal.server.api.matchingservice.v1.MatchingService/ListNexusEndpoints"
)

Variables

View Source 
var File_temporal_server_api_matchingservice_v1_request_response_proto protoreflect.FileDescriptor
View Source 
var File_temporal_server_api_matchingservice_v1_service_proto protoreflect.FileDescriptor
View Source 
var MatchingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "temporal.server.api.matchingservice.v1.MatchingService",
	HandlerType: (*MatchingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PollWorkflowTaskQueue",
			Handler:    _MatchingService_PollWorkflowTaskQueue_Handler,
		},
		{
			MethodName: "PollActivityTaskQueue",
			Handler:    _MatchingService_PollActivityTaskQueue_Handler,
		},
		{
			MethodName: "AddWorkflowTask",
			Handler:    _MatchingService_AddWorkflowTask_Handler,
		},
		{
			MethodName: "AddActivityTask",
			Handler:    _MatchingService_AddActivityTask_Handler,
		},
		{
			MethodName: "QueryWorkflow",
			Handler:    _MatchingService_QueryWorkflow_Handler,
		},
		{
			MethodName: "RespondQueryTaskCompleted",
			Handler:    _MatchingService_RespondQueryTaskCompleted_Handler,
		},
		{
			MethodName: "DispatchNexusTask",
			Handler:    _MatchingService_DispatchNexusTask_Handler,
		},
		{
			MethodName: "PollNexusTaskQueue",
			Handler:    _MatchingService_PollNexusTaskQueue_Handler,
		},
		{
			MethodName: "RespondNexusTaskCompleted",
			Handler:    _MatchingService_RespondNexusTaskCompleted_Handler,
		},
		{
			MethodName: "RespondNexusTaskFailed",
			Handler:    _MatchingService_RespondNexusTaskFailed_Handler,
		},
		{
			MethodName: "CancelOutstandingPoll",
			Handler:    _MatchingService_CancelOutstandingPoll_Handler,
		},
		{
			MethodName: "DescribeTaskQueue",
			Handler:    _MatchingService_DescribeTaskQueue_Handler,
		},
		{
			MethodName: "DescribeTaskQueuePartition",
			Handler:    _MatchingService_DescribeTaskQueuePartition_Handler,
		},
		{
			MethodName: "ListTaskQueuePartitions",
			Handler:    _MatchingService_ListTaskQueuePartitions_Handler,
		},
		{
			MethodName: "UpdateWorkerBuildIdCompatibility",
			Handler:    _MatchingService_UpdateWorkerBuildIdCompatibility_Handler,
		},
		{
			MethodName: "GetWorkerBuildIdCompatibility",
			Handler:    _MatchingService_GetWorkerBuildIdCompatibility_Handler,
		},
		{
			MethodName: "GetTaskQueueUserData",
			Handler:    _MatchingService_GetTaskQueueUserData_Handler,
		},
		{
			MethodName: "UpdateWorkerVersioningRules",
			Handler:    _MatchingService_UpdateWorkerVersioningRules_Handler,
		},
		{
			MethodName: "GetWorkerVersioningRules",
			Handler:    _MatchingService_GetWorkerVersioningRules_Handler,
		},
		{
			MethodName: "ApplyTaskQueueUserDataReplicationEvent",
			Handler:    _MatchingService_ApplyTaskQueueUserDataReplicationEvent_Handler,
		},
		{
			MethodName: "GetBuildIdTaskQueueMapping",
			Handler:    _MatchingService_GetBuildIdTaskQueueMapping_Handler,
		},
		{
			MethodName: "ForceUnloadTaskQueue",
			Handler:    _MatchingService_ForceUnloadTaskQueue_Handler,
		},
		{
			MethodName: "UpdateTaskQueueUserData",
			Handler:    _MatchingService_UpdateTaskQueueUserData_Handler,
		},
		{
			MethodName: "ReplicateTaskQueueUserData",
			Handler:    _MatchingService_ReplicateTaskQueueUserData_Handler,
		},
		{
			MethodName: "CreateNexusEndpoint",
			Handler:    _MatchingService_CreateNexusEndpoint_Handler,
		},
		{
			MethodName: "UpdateNexusEndpoint",
			Handler:    _MatchingService_UpdateNexusEndpoint_Handler,
		},
		{
			MethodName: "DeleteNexusEndpoint",
			Handler:    _MatchingService_DeleteNexusEndpoint_Handler,
		},
		{
			MethodName: "ListNexusEndpoints",
			Handler:    _MatchingService_ListNexusEndpoints_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "temporal/server/api/matchingservice/v1/service.proto",
}

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

Functions

func RegisterMatchingServiceServer 

func RegisterMatchingServiceServer(s grpc.ServiceRegistrar, srv MatchingServiceServer)

Types

type AddActivityTaskRequest 

type AddActivityTaskRequest struct {
	NamespaceId      string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution        *v11.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	TaskQueue        *v14.TaskQueue         `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	ScheduledEventId int64                  `protobuf:"varint,5,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	Clock                  *v17.VectorClock     `protobuf:"bytes,9,opt,name=clock,proto3" json:"clock,omitempty"`
	// How this task should be directed by matching. (Missing means the default
	// for TaskVersionDirective, which is unversioned.)
	VersionDirective *v18.TaskVersionDirective `protobuf:"bytes,10,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,omitempty"`
	ForwardInfo      *v18.TaskForwardInfo      `protobuf:"bytes,11,opt,name=forward_info,json=forwardInfo,proto3" json:"forward_info,omitempty"`
	// contains filtered or unexported fields
}

func (*AddActivityTaskRequest) Descriptor deprecated 

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

Deprecated: Use AddActivityTaskRequest.ProtoReflect.Descriptor instead.

func (*AddActivityTaskRequest) Equal 

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

Equal returns whether two AddActivityTaskRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddActivityTaskRequest) GetClock added in v1.17.0 

func (x *AddActivityTaskRequest) GetClock() *v17.VectorClock

func (*AddActivityTaskRequest) GetExecution 

func (x *AddActivityTaskRequest) GetExecution() *v11.WorkflowExecution

func (*AddActivityTaskRequest) GetForwardInfo added in v1.25.0 

func (x *AddActivityTaskRequest) GetForwardInfo() *v18.TaskForwardInfo

func (*AddActivityTaskRequest) GetNamespaceId 

func (x *AddActivityTaskRequest) GetNamespaceId() string

func (*AddActivityTaskRequest) GetScheduleToStartTimeout added in v0.28.0 

func (x *AddActivityTaskRequest) GetScheduleToStartTimeout() *durationpb.Duration

func (*AddActivityTaskRequest) GetScheduledEventId added in v1.17.0 

func (x *AddActivityTaskRequest) GetScheduledEventId() int64

func (*AddActivityTaskRequest) GetTaskQueue 

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

func (*AddActivityTaskRequest) GetVersionDirective added in v1.21.0 

func (x *AddActivityTaskRequest) GetVersionDirective() *v18.TaskVersionDirective

func (*AddActivityTaskRequest) Marshal 

func (val *AddActivityTaskRequest) Marshal() ([]byte, error)

Marshal an object of type AddActivityTaskRequest to the protobuf v3 wire format

func (*AddActivityTaskRequest) ProtoMessage 

func (*AddActivityTaskRequest) ProtoMessage()

func (*AddActivityTaskRequest) ProtoReflect added in v1.23.0 

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

func (*AddActivityTaskRequest) Reset 

func (x *AddActivityTaskRequest) Reset()

func (*AddActivityTaskRequest) Size 

func (val *AddActivityTaskRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddActivityTaskRequest) String 

func (x *AddActivityTaskRequest) String() string

func (*AddActivityTaskRequest) Unmarshal 

func (val *AddActivityTaskRequest) Unmarshal(buf []byte) error

Unmarshal an object of type AddActivityTaskRequest from the protobuf v3 wire format

type AddActivityTaskResponse 

type AddActivityTaskResponse struct {

	// When present, it means that the task is spooled to a versioned queue of this build ID
	AssignedBuildId string `protobuf:"bytes,1,opt,name=assigned_build_id,json=assignedBuildId,proto3" json:"assigned_build_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddActivityTaskResponse) Descriptor deprecated 

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

Deprecated: Use AddActivityTaskResponse.ProtoReflect.Descriptor instead.

func (*AddActivityTaskResponse) Equal 

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

Equal returns whether two AddActivityTaskResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddActivityTaskResponse) GetAssignedBuildId added in v1.24.0 

func (x *AddActivityTaskResponse) GetAssignedBuildId() string

func (*AddActivityTaskResponse) Marshal 

func (val *AddActivityTaskResponse) Marshal() ([]byte, error)

Marshal an object of type AddActivityTaskResponse to the protobuf v3 wire format

func (*AddActivityTaskResponse) ProtoMessage 

func (*AddActivityTaskResponse) ProtoMessage()

func (*AddActivityTaskResponse) ProtoReflect added in v1.23.0 

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

func (*AddActivityTaskResponse) Reset 

func (x *AddActivityTaskResponse) Reset()

func (*AddActivityTaskResponse) Size 

func (val *AddActivityTaskResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddActivityTaskResponse) String 

func (x *AddActivityTaskResponse) String() string

func (*AddActivityTaskResponse) Unmarshal 

func (val *AddActivityTaskResponse) Unmarshal(buf []byte) error

Unmarshal an object of type AddActivityTaskResponse from the protobuf v3 wire format

type AddWorkflowTaskRequest 

type AddWorkflowTaskRequest struct {
	NamespaceId      string                 `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Execution        *v11.WorkflowExecution `protobuf:"bytes,2,opt,name=execution,proto3" json:"execution,omitempty"`
	TaskQueue        *v14.TaskQueue         `protobuf:"bytes,3,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	ScheduledEventId int64                  `protobuf:"varint,4,opt,name=scheduled_event_id,json=scheduledEventId,proto3" json:"scheduled_event_id,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToStartTimeout *durationpb.Duration `` /* 131-byte string literal not displayed */
	Clock                  *v17.VectorClock     `protobuf:"bytes,9,opt,name=clock,proto3" json:"clock,omitempty"`
	// How this task should be directed by matching. (Missing means the default
	// for TaskVersionDirective, which is unversioned.)
	VersionDirective *v18.TaskVersionDirective `protobuf:"bytes,10,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,omitempty"`
	ForwardInfo      *v18.TaskForwardInfo      `protobuf:"bytes,11,opt,name=forward_info,json=forwardInfo,proto3" json:"forward_info,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkflowTaskRequest) Descriptor deprecated 

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

Deprecated: Use AddWorkflowTaskRequest.ProtoReflect.Descriptor instead.

func (*AddWorkflowTaskRequest) Equal 

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

Equal returns whether two AddWorkflowTaskRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddWorkflowTaskRequest) GetClock added in v1.17.0 

func (x *AddWorkflowTaskRequest) GetClock() *v17.VectorClock

func (*AddWorkflowTaskRequest) GetExecution 

func (x *AddWorkflowTaskRequest) GetExecution() *v11.WorkflowExecution

func (*AddWorkflowTaskRequest) GetForwardInfo added in v1.25.0 

func (x *AddWorkflowTaskRequest) GetForwardInfo() *v18.TaskForwardInfo

func (*AddWorkflowTaskRequest) GetNamespaceId 

func (x *AddWorkflowTaskRequest) GetNamespaceId() string

func (*AddWorkflowTaskRequest) GetScheduleToStartTimeout added in v0.28.0 

func (x *AddWorkflowTaskRequest) GetScheduleToStartTimeout() *durationpb.Duration

func (*AddWorkflowTaskRequest) GetScheduledEventId added in v1.17.0 

func (x *AddWorkflowTaskRequest) GetScheduledEventId() int64

func (*AddWorkflowTaskRequest) GetTaskQueue 

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

func (*AddWorkflowTaskRequest) GetVersionDirective added in v1.21.0 

func (x *AddWorkflowTaskRequest) GetVersionDirective() *v18.TaskVersionDirective

func (*AddWorkflowTaskRequest) Marshal 

func (val *AddWorkflowTaskRequest) Marshal() ([]byte, error)

Marshal an object of type AddWorkflowTaskRequest to the protobuf v3 wire format

func (*AddWorkflowTaskRequest) ProtoMessage 

func (*AddWorkflowTaskRequest) ProtoMessage()

func (*AddWorkflowTaskRequest) ProtoReflect added in v1.23.0 

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

func (*AddWorkflowTaskRequest) Reset 

func (x *AddWorkflowTaskRequest) Reset()

func (*AddWorkflowTaskRequest) Size 

func (val *AddWorkflowTaskRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddWorkflowTaskRequest) String 

func (x *AddWorkflowTaskRequest) String() string

func (*AddWorkflowTaskRequest) Unmarshal 

func (val *AddWorkflowTaskRequest) Unmarshal(buf []byte) error

Unmarshal an object of type AddWorkflowTaskRequest from the protobuf v3 wire format

type AddWorkflowTaskResponse 

type AddWorkflowTaskResponse struct {

	// When present, it means that the task is spooled to a versioned queue of this build ID
	AssignedBuildId string `protobuf:"bytes,1,opt,name=assigned_build_id,json=assignedBuildId,proto3" json:"assigned_build_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkflowTaskResponse) Descriptor deprecated 

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

Deprecated: Use AddWorkflowTaskResponse.ProtoReflect.Descriptor instead.

func (*AddWorkflowTaskResponse) Equal 

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

Equal returns whether two AddWorkflowTaskResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*AddWorkflowTaskResponse) GetAssignedBuildId added in v1.24.0 

func (x *AddWorkflowTaskResponse) GetAssignedBuildId() string

func (*AddWorkflowTaskResponse) Marshal 

func (val *AddWorkflowTaskResponse) Marshal() ([]byte, error)

Marshal an object of type AddWorkflowTaskResponse to the protobuf v3 wire format

func (*AddWorkflowTaskResponse) ProtoMessage 

func (*AddWorkflowTaskResponse) ProtoMessage()

func (*AddWorkflowTaskResponse) ProtoReflect added in v1.23.0 

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

func (*AddWorkflowTaskResponse) Reset 

func (x *AddWorkflowTaskResponse) Reset()

func (*AddWorkflowTaskResponse) Size 

func (val *AddWorkflowTaskResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*AddWorkflowTaskResponse) String 

func (x *AddWorkflowTaskResponse) String() string

func (*AddWorkflowTaskResponse) Unmarshal 

func (val *AddWorkflowTaskResponse) Unmarshal(buf []byte) error

Unmarshal an object of type AddWorkflowTaskResponse from the protobuf v3 wire format

type ApplyTaskQueueUserDataReplicationEventRequest added in v1.21.0 

type ApplyTaskQueueUserDataReplicationEventRequest struct {
	NamespaceId string                  `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   string                  `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	UserData    *v110.TaskQueueUserData `protobuf:"bytes,3,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyTaskQueueUserDataReplicationEventRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use ApplyTaskQueueUserDataReplicationEventRequest.ProtoReflect.Descriptor instead.

func (*ApplyTaskQueueUserDataReplicationEventRequest) Equal added in v1.21.0 

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

Equal returns whether two ApplyTaskQueueUserDataReplicationEventRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ApplyTaskQueueUserDataReplicationEventRequest) GetNamespaceId added in v1.21.0 

func (x *ApplyTaskQueueUserDataReplicationEventRequest) GetNamespaceId() string

func (*ApplyTaskQueueUserDataReplicationEventRequest) GetTaskQueue added in v1.21.0 

func (x *ApplyTaskQueueUserDataReplicationEventRequest) GetTaskQueue() string

func (*ApplyTaskQueueUserDataReplicationEventRequest) GetUserData added in v1.21.0 

func (x *ApplyTaskQueueUserDataReplicationEventRequest) GetUserData() *v110.TaskQueueUserData

func (*ApplyTaskQueueUserDataReplicationEventRequest) Marshal added in v1.21.0 

func (val *ApplyTaskQueueUserDataReplicationEventRequest) Marshal() ([]byte, error)

Marshal an object of type ApplyTaskQueueUserDataReplicationEventRequest to the protobuf v3 wire format

func (*ApplyTaskQueueUserDataReplicationEventRequest) ProtoMessage added in v1.21.0 

func (*ApplyTaskQueueUserDataReplicationEventRequest) ProtoMessage()

func (*ApplyTaskQueueUserDataReplicationEventRequest) ProtoReflect added in v1.23.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) Reset added in v1.21.0 

func (x *ApplyTaskQueueUserDataReplicationEventRequest) Reset()

func (*ApplyTaskQueueUserDataReplicationEventRequest) Size added in v1.21.0 

func (val *ApplyTaskQueueUserDataReplicationEventRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ApplyTaskQueueUserDataReplicationEventRequest) String added in v1.21.0 

func (x *ApplyTaskQueueUserDataReplicationEventRequest) String() string

func (*ApplyTaskQueueUserDataReplicationEventRequest) Unmarshal added in v1.21.0 

func (val *ApplyTaskQueueUserDataReplicationEventRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ApplyTaskQueueUserDataReplicationEventRequest from the protobuf v3 wire format

type ApplyTaskQueueUserDataReplicationEventResponse added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use ApplyTaskQueueUserDataReplicationEventResponse.ProtoReflect.Descriptor instead.

func (*ApplyTaskQueueUserDataReplicationEventResponse) Equal added in v1.21.0 

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

Equal returns whether two ApplyTaskQueueUserDataReplicationEventResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ApplyTaskQueueUserDataReplicationEventResponse) Marshal added in v1.21.0 

func (val *ApplyTaskQueueUserDataReplicationEventResponse) Marshal() ([]byte, error)

Marshal an object of type ApplyTaskQueueUserDataReplicationEventResponse to the protobuf v3 wire format

func (*ApplyTaskQueueUserDataReplicationEventResponse) ProtoMessage added in v1.21.0 

func (*ApplyTaskQueueUserDataReplicationEventResponse) ProtoMessage()

func (*ApplyTaskQueueUserDataReplicationEventResponse) ProtoReflect added in v1.23.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) Reset added in v1.21.0 

func (x *ApplyTaskQueueUserDataReplicationEventResponse) Reset()

func (*ApplyTaskQueueUserDataReplicationEventResponse) Size added in v1.21.0 

func (val *ApplyTaskQueueUserDataReplicationEventResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ApplyTaskQueueUserDataReplicationEventResponse) String added in v1.21.0 

func (x *ApplyTaskQueueUserDataReplicationEventResponse) String() string

func (*ApplyTaskQueueUserDataReplicationEventResponse) Unmarshal added in v1.21.0 

func (val *ApplyTaskQueueUserDataReplicationEventResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ApplyTaskQueueUserDataReplicationEventResponse from the protobuf v3 wire format

type CancelOutstandingPollRequest 

type CancelOutstandingPollRequest struct {
	NamespaceId   string            `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueueType v19.TaskQueueType `` /* 144-byte string literal not displayed */
	TaskQueue     *v14.TaskQueue    `protobuf:"bytes,3,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	PollerId      string            `protobuf:"bytes,4,opt,name=poller_id,json=pollerId,proto3" json:"poller_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelOutstandingPollRequest) Descriptor deprecated 

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

Deprecated: Use CancelOutstandingPollRequest.ProtoReflect.Descriptor instead.

func (*CancelOutstandingPollRequest) Equal 

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

Equal returns whether two CancelOutstandingPollRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelOutstandingPollRequest) GetNamespaceId 

func (x *CancelOutstandingPollRequest) GetNamespaceId() string

func (*CancelOutstandingPollRequest) GetPollerId 

func (x *CancelOutstandingPollRequest) GetPollerId() string

func (*CancelOutstandingPollRequest) GetTaskQueue 

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

func (*CancelOutstandingPollRequest) GetTaskQueueType 

func (x *CancelOutstandingPollRequest) GetTaskQueueType() v19.TaskQueueType

func (*CancelOutstandingPollRequest) Marshal 

func (val *CancelOutstandingPollRequest) Marshal() ([]byte, error)

Marshal an object of type CancelOutstandingPollRequest to the protobuf v3 wire format

func (*CancelOutstandingPollRequest) ProtoMessage 

func (*CancelOutstandingPollRequest) ProtoMessage()

func (*CancelOutstandingPollRequest) ProtoReflect added in v1.23.0 

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

func (*CancelOutstandingPollRequest) Reset 

func (x *CancelOutstandingPollRequest) Reset()

func (*CancelOutstandingPollRequest) Size 

func (val *CancelOutstandingPollRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelOutstandingPollRequest) String 

func (x *CancelOutstandingPollRequest) String() string

func (*CancelOutstandingPollRequest) Unmarshal 

func (val *CancelOutstandingPollRequest) Unmarshal(buf []byte) error

Unmarshal an object of type CancelOutstandingPollRequest from the protobuf v3 wire format

type CancelOutstandingPollResponse 

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

func (*CancelOutstandingPollResponse) Descriptor deprecated 

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

Deprecated: Use CancelOutstandingPollResponse.ProtoReflect.Descriptor instead.

func (*CancelOutstandingPollResponse) Equal 

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

Equal returns whether two CancelOutstandingPollResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CancelOutstandingPollResponse) Marshal 

func (val *CancelOutstandingPollResponse) Marshal() ([]byte, error)

Marshal an object of type CancelOutstandingPollResponse to the protobuf v3 wire format

func (*CancelOutstandingPollResponse) ProtoMessage 

func (*CancelOutstandingPollResponse) ProtoMessage()

func (*CancelOutstandingPollResponse) ProtoReflect added in v1.23.0 

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

func (*CancelOutstandingPollResponse) Reset 

func (x *CancelOutstandingPollResponse) Reset()

func (*CancelOutstandingPollResponse) Size 

func (val *CancelOutstandingPollResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CancelOutstandingPollResponse) String 

func (x *CancelOutstandingPollResponse) String() string

func (*CancelOutstandingPollResponse) Unmarshal 

func (val *CancelOutstandingPollResponse) Unmarshal(buf []byte) error

Unmarshal an object of type CancelOutstandingPollResponse from the protobuf v3 wire format

type CreateNexusEndpointRequest added in v1.25.0 

type CreateNexusEndpointRequest struct {
	Spec *v110.NexusEndpointSpec `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

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

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

func (*CreateNexusEndpointRequest) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use CreateNexusEndpointRequest.ProtoReflect.Descriptor instead.

func (*CreateNexusEndpointRequest) Equal added in v1.25.0 

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

Equal returns whether two CreateNexusEndpointRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CreateNexusEndpointRequest) GetSpec added in v1.25.0 

func (x *CreateNexusEndpointRequest) GetSpec() *v110.NexusEndpointSpec

func (*CreateNexusEndpointRequest) Marshal added in v1.25.0 

func (val *CreateNexusEndpointRequest) Marshal() ([]byte, error)

Marshal an object of type CreateNexusEndpointRequest to the protobuf v3 wire format

func (*CreateNexusEndpointRequest) ProtoMessage added in v1.25.0 

func (*CreateNexusEndpointRequest) ProtoMessage()

func (*CreateNexusEndpointRequest) ProtoReflect added in v1.25.0 

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

func (*CreateNexusEndpointRequest) Reset added in v1.25.0 

func (x *CreateNexusEndpointRequest) Reset()

func (*CreateNexusEndpointRequest) Size added in v1.25.0 

func (val *CreateNexusEndpointRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CreateNexusEndpointRequest) String added in v1.25.0 

func (x *CreateNexusEndpointRequest) String() string

func (*CreateNexusEndpointRequest) Unmarshal added in v1.25.0 

func (val *CreateNexusEndpointRequest) Unmarshal(buf []byte) error

Unmarshal an object of type CreateNexusEndpointRequest from the protobuf v3 wire format

type CreateNexusEndpointResponse added in v1.25.0 

type CreateNexusEndpointResponse struct {
	Entry *v110.NexusEndpointEntry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateNexusEndpointResponse) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use CreateNexusEndpointResponse.ProtoReflect.Descriptor instead.

func (*CreateNexusEndpointResponse) Equal added in v1.25.0 

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

Equal returns whether two CreateNexusEndpointResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*CreateNexusEndpointResponse) GetEntry added in v1.25.0 

func (x *CreateNexusEndpointResponse) GetEntry() *v110.NexusEndpointEntry

func (*CreateNexusEndpointResponse) Marshal added in v1.25.0 

func (val *CreateNexusEndpointResponse) Marshal() ([]byte, error)

Marshal an object of type CreateNexusEndpointResponse to the protobuf v3 wire format

func (*CreateNexusEndpointResponse) ProtoMessage added in v1.25.0 

func (*CreateNexusEndpointResponse) ProtoMessage()

func (*CreateNexusEndpointResponse) ProtoReflect added in v1.25.0 

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

func (*CreateNexusEndpointResponse) Reset added in v1.25.0 

func (x *CreateNexusEndpointResponse) Reset()

func (*CreateNexusEndpointResponse) Size added in v1.25.0 

func (val *CreateNexusEndpointResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*CreateNexusEndpointResponse) String added in v1.25.0 

func (x *CreateNexusEndpointResponse) String() string

func (*CreateNexusEndpointResponse) Unmarshal added in v1.25.0 

func (val *CreateNexusEndpointResponse) Unmarshal(buf []byte) error

Unmarshal an object of type CreateNexusEndpointResponse from the protobuf v3 wire format

type DeleteNexusEndpointRequest added in v1.25.0 

type DeleteNexusEndpointRequest struct {

	// ID of the endpoint to delete.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

func (*DeleteNexusEndpointRequest) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use DeleteNexusEndpointRequest.ProtoReflect.Descriptor instead.

func (*DeleteNexusEndpointRequest) Equal added in v1.25.0 

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

Equal returns whether two DeleteNexusEndpointRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DeleteNexusEndpointRequest) GetId added in v1.25.0 

func (x *DeleteNexusEndpointRequest) GetId() string

func (*DeleteNexusEndpointRequest) Marshal added in v1.25.0 

func (val *DeleteNexusEndpointRequest) Marshal() ([]byte, error)

Marshal an object of type DeleteNexusEndpointRequest to the protobuf v3 wire format

func (*DeleteNexusEndpointRequest) ProtoMessage added in v1.25.0 

func (*DeleteNexusEndpointRequest) ProtoMessage()

func (*DeleteNexusEndpointRequest) ProtoReflect added in v1.25.0 

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

func (*DeleteNexusEndpointRequest) Reset added in v1.25.0 

func (x *DeleteNexusEndpointRequest) Reset()

func (*DeleteNexusEndpointRequest) Size added in v1.25.0 

func (val *DeleteNexusEndpointRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DeleteNexusEndpointRequest) String added in v1.25.0 

func (x *DeleteNexusEndpointRequest) String() string

func (*DeleteNexusEndpointRequest) Unmarshal added in v1.25.0 

func (val *DeleteNexusEndpointRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DeleteNexusEndpointRequest from the protobuf v3 wire format

type DeleteNexusEndpointResponse added in v1.25.0 

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

func (*DeleteNexusEndpointResponse) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use DeleteNexusEndpointResponse.ProtoReflect.Descriptor instead.

func (*DeleteNexusEndpointResponse) Equal added in v1.25.0 

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

Equal returns whether two DeleteNexusEndpointResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DeleteNexusEndpointResponse) Marshal added in v1.25.0 

func (val *DeleteNexusEndpointResponse) Marshal() ([]byte, error)

Marshal an object of type DeleteNexusEndpointResponse to the protobuf v3 wire format

func (*DeleteNexusEndpointResponse) ProtoMessage added in v1.25.0 

func (*DeleteNexusEndpointResponse) ProtoMessage()

func (*DeleteNexusEndpointResponse) ProtoReflect added in v1.25.0 

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

func (*DeleteNexusEndpointResponse) Reset added in v1.25.0 

func (x *DeleteNexusEndpointResponse) Reset()

func (*DeleteNexusEndpointResponse) Size added in v1.25.0 

func (val *DeleteNexusEndpointResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DeleteNexusEndpointResponse) String added in v1.25.0 

func (x *DeleteNexusEndpointResponse) String() string

func (*DeleteNexusEndpointResponse) Unmarshal added in v1.25.0 

func (val *DeleteNexusEndpointResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DeleteNexusEndpointResponse from the protobuf v3 wire format

type DescribeTaskQueuePartitionRequest added in v1.24.0 

type DescribeTaskQueuePartitionRequest struct {
	NamespaceId        string                         `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueuePartition *v18.TaskQueuePartition        `protobuf:"bytes,2,opt,name=task_queue_partition,json=taskQueuePartition,proto3" json:"task_queue_partition,omitempty"`
	Versions           *v14.TaskQueueVersionSelection `protobuf:"bytes,3,opt,name=versions,proto3" json:"versions,omitempty"`
	// Report task queue stats for the requested task queue types and versions
	ReportStats bool `protobuf:"varint,4,opt,name=report_stats,json=reportStats,proto3" json:"report_stats,omitempty"`
	// Report list of pollers for requested task queue types and versions
	ReportPollers bool `protobuf:"varint,5,opt,name=report_pollers,json=reportPollers,proto3" json:"report_pollers,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskQueuePartitionRequest) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use DescribeTaskQueuePartitionRequest.ProtoReflect.Descriptor instead.

func (*DescribeTaskQueuePartitionRequest) Equal added in v1.24.0 

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

Equal returns whether two DescribeTaskQueuePartitionRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeTaskQueuePartitionRequest) GetNamespaceId added in v1.24.0 

func (x *DescribeTaskQueuePartitionRequest) GetNamespaceId() string

func (*DescribeTaskQueuePartitionRequest) GetReportPollers added in v1.24.0 

func (x *DescribeTaskQueuePartitionRequest) GetReportPollers() bool

func (*DescribeTaskQueuePartitionRequest) GetReportStats added in v1.25.0 

func (x *DescribeTaskQueuePartitionRequest) GetReportStats() bool

func (*DescribeTaskQueuePartitionRequest) GetTaskQueuePartition added in v1.24.0 

func (x *DescribeTaskQueuePartitionRequest) GetTaskQueuePartition() *v18.TaskQueuePartition

func (*DescribeTaskQueuePartitionRequest) GetVersions added in v1.24.0 

func (x *DescribeTaskQueuePartitionRequest) GetVersions() *v14.TaskQueueVersionSelection

func (*DescribeTaskQueuePartitionRequest) Marshal added in v1.24.0 

func (val *DescribeTaskQueuePartitionRequest) Marshal() ([]byte, error)

Marshal an object of type DescribeTaskQueuePartitionRequest to the protobuf v3 wire format

func (*DescribeTaskQueuePartitionRequest) ProtoMessage added in v1.24.0 

func (*DescribeTaskQueuePartitionRequest) ProtoMessage()

func (*DescribeTaskQueuePartitionRequest) ProtoReflect added in v1.24.0 

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

func (*DescribeTaskQueuePartitionRequest) Reset added in v1.24.0 

func (x *DescribeTaskQueuePartitionRequest) Reset()

func (*DescribeTaskQueuePartitionRequest) Size added in v1.24.0 

func (val *DescribeTaskQueuePartitionRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeTaskQueuePartitionRequest) String added in v1.24.0 

func (x *DescribeTaskQueuePartitionRequest) String() string

func (*DescribeTaskQueuePartitionRequest) Unmarshal added in v1.24.0 

func (val *DescribeTaskQueuePartitionRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeTaskQueuePartitionRequest from the protobuf v3 wire format

type DescribeTaskQueuePartitionResponse added in v1.24.0 

type DescribeTaskQueuePartitionResponse struct {
	VersionsInfoInternal map[string]*v18.TaskQueueVersionInfoInternal `` /* 211-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DescribeTaskQueuePartitionResponse) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use DescribeTaskQueuePartitionResponse.ProtoReflect.Descriptor instead.

func (*DescribeTaskQueuePartitionResponse) Equal added in v1.24.0 

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

Equal returns whether two DescribeTaskQueuePartitionResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeTaskQueuePartitionResponse) GetVersionsInfoInternal added in v1.24.0 

func (x *DescribeTaskQueuePartitionResponse) GetVersionsInfoInternal() map[string]*v18.TaskQueueVersionInfoInternal

func (*DescribeTaskQueuePartitionResponse) Marshal added in v1.24.0 

func (val *DescribeTaskQueuePartitionResponse) Marshal() ([]byte, error)

Marshal an object of type DescribeTaskQueuePartitionResponse to the protobuf v3 wire format

func (*DescribeTaskQueuePartitionResponse) ProtoMessage added in v1.24.0 

func (*DescribeTaskQueuePartitionResponse) ProtoMessage()

func (*DescribeTaskQueuePartitionResponse) ProtoReflect added in v1.24.0 

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

func (*DescribeTaskQueuePartitionResponse) Reset added in v1.24.0 

func (x *DescribeTaskQueuePartitionResponse) Reset()

func (*DescribeTaskQueuePartitionResponse) Size added in v1.24.0 

func (val *DescribeTaskQueuePartitionResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeTaskQueuePartitionResponse) String added in v1.24.0 

func (x *DescribeTaskQueuePartitionResponse) String() string

func (*DescribeTaskQueuePartitionResponse) Unmarshal added in v1.24.0 

func (val *DescribeTaskQueuePartitionResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeTaskQueuePartitionResponse from the protobuf v3 wire format

type DescribeTaskQueueRequest 

type DescribeTaskQueueRequest struct {
	NamespaceId string                       `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	DescRequest *v1.DescribeTaskQueueRequest `protobuf:"bytes,2,opt,name=desc_request,json=descRequest,proto3" json:"desc_request,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskQueueRequest) Descriptor deprecated 

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

Deprecated: Use DescribeTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*DescribeTaskQueueRequest) Equal 

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

Equal returns whether two DescribeTaskQueueRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeTaskQueueRequest) GetDescRequest 

func (x *DescribeTaskQueueRequest) GetDescRequest() *v1.DescribeTaskQueueRequest

func (*DescribeTaskQueueRequest) GetNamespaceId 

func (x *DescribeTaskQueueRequest) GetNamespaceId() string

func (*DescribeTaskQueueRequest) Marshal 

func (val *DescribeTaskQueueRequest) Marshal() ([]byte, error)

Marshal an object of type DescribeTaskQueueRequest to the protobuf v3 wire format

func (*DescribeTaskQueueRequest) ProtoMessage 

func (*DescribeTaskQueueRequest) ProtoMessage()

func (*DescribeTaskQueueRequest) ProtoReflect added in v1.23.0 

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

func (*DescribeTaskQueueRequest) Reset 

func (x *DescribeTaskQueueRequest) Reset()

func (*DescribeTaskQueueRequest) Size 

func (val *DescribeTaskQueueRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeTaskQueueRequest) String 

func (x *DescribeTaskQueueRequest) String() string

func (*DescribeTaskQueueRequest) Unmarshal 

func (val *DescribeTaskQueueRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeTaskQueueRequest from the protobuf v3 wire format

type DescribeTaskQueueResponse 

type DescribeTaskQueueResponse struct {
	DescResponse *v1.DescribeTaskQueueResponse `protobuf:"bytes,3,opt,name=desc_response,json=descResponse,proto3" json:"desc_response,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskQueueResponse) Descriptor deprecated 

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

Deprecated: Use DescribeTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*DescribeTaskQueueResponse) Equal 

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

Equal returns whether two DescribeTaskQueueResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DescribeTaskQueueResponse) GetDescResponse added in v1.24.0 

func (x *DescribeTaskQueueResponse) GetDescResponse() *v1.DescribeTaskQueueResponse

func (*DescribeTaskQueueResponse) Marshal 

func (val *DescribeTaskQueueResponse) Marshal() ([]byte, error)

Marshal an object of type DescribeTaskQueueResponse to the protobuf v3 wire format

func (*DescribeTaskQueueResponse) ProtoMessage 

func (*DescribeTaskQueueResponse) ProtoMessage()

func (*DescribeTaskQueueResponse) ProtoReflect added in v1.23.0 

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

func (*DescribeTaskQueueResponse) Reset 

func (x *DescribeTaskQueueResponse) Reset()

func (*DescribeTaskQueueResponse) Size 

func (val *DescribeTaskQueueResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DescribeTaskQueueResponse) String 

func (x *DescribeTaskQueueResponse) String() string

func (*DescribeTaskQueueResponse) Unmarshal 

func (val *DescribeTaskQueueResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DescribeTaskQueueResponse from the protobuf v3 wire format

type DispatchNexusTaskRequest added in v1.24.0 

type DispatchNexusTaskRequest struct {
	NamespaceId string         `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   *v14.TaskQueue `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Nexus request extracted by the frontend and translated into Temporal API format.
	Request     *v111.Request        `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	ForwardInfo *v18.TaskForwardInfo `protobuf:"bytes,4,opt,name=forward_info,json=forwardInfo,proto3" json:"forward_info,omitempty"`
	// contains filtered or unexported fields
}

func (*DispatchNexusTaskRequest) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use DispatchNexusTaskRequest.ProtoReflect.Descriptor instead.

func (*DispatchNexusTaskRequest) Equal added in v1.24.0 

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

Equal returns whether two DispatchNexusTaskRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DispatchNexusTaskRequest) GetForwardInfo added in v1.25.0 

func (x *DispatchNexusTaskRequest) GetForwardInfo() *v18.TaskForwardInfo

func (*DispatchNexusTaskRequest) GetNamespaceId added in v1.24.0 

func (x *DispatchNexusTaskRequest) GetNamespaceId() string

func (*DispatchNexusTaskRequest) GetRequest added in v1.24.0 

func (x *DispatchNexusTaskRequest) GetRequest() *v111.Request

func (*DispatchNexusTaskRequest) GetTaskQueue added in v1.24.0 

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

func (*DispatchNexusTaskRequest) Marshal added in v1.24.0 

func (val *DispatchNexusTaskRequest) Marshal() ([]byte, error)

Marshal an object of type DispatchNexusTaskRequest to the protobuf v3 wire format

func (*DispatchNexusTaskRequest) ProtoMessage added in v1.24.0 

func (*DispatchNexusTaskRequest) ProtoMessage()

func (*DispatchNexusTaskRequest) ProtoReflect added in v1.24.0 

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

func (*DispatchNexusTaskRequest) Reset added in v1.24.0 

func (x *DispatchNexusTaskRequest) Reset()

func (*DispatchNexusTaskRequest) Size added in v1.24.0 

func (val *DispatchNexusTaskRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DispatchNexusTaskRequest) String added in v1.24.0 

func (x *DispatchNexusTaskRequest) String() string

func (*DispatchNexusTaskRequest) Unmarshal added in v1.24.0 

func (val *DispatchNexusTaskRequest) Unmarshal(buf []byte) error

Unmarshal an object of type DispatchNexusTaskRequest from the protobuf v3 wire format

type DispatchNexusTaskResponse added in v1.24.0 

type DispatchNexusTaskResponse struct {

	// Types that are assignable to Outcome:
	//
	//	*DispatchNexusTaskResponse_HandlerError
	//	*DispatchNexusTaskResponse_Response
	Outcome isDispatchNexusTaskResponse_Outcome `protobuf_oneof:"outcome"`
	// contains filtered or unexported fields
}

func (*DispatchNexusTaskResponse) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use DispatchNexusTaskResponse.ProtoReflect.Descriptor instead.

func (*DispatchNexusTaskResponse) Equal added in v1.24.0 

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

Equal returns whether two DispatchNexusTaskResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*DispatchNexusTaskResponse) GetHandlerError added in v1.24.0 

func (x *DispatchNexusTaskResponse) GetHandlerError() *v111.HandlerError

func (*DispatchNexusTaskResponse) GetOutcome added in v1.24.0 

func (m *DispatchNexusTaskResponse) GetOutcome() isDispatchNexusTaskResponse_Outcome

func (*DispatchNexusTaskResponse) GetResponse added in v1.24.0 

func (x *DispatchNexusTaskResponse) GetResponse() *v111.Response

func (*DispatchNexusTaskResponse) Marshal added in v1.24.0 

func (val *DispatchNexusTaskResponse) Marshal() ([]byte, error)

Marshal an object of type DispatchNexusTaskResponse to the protobuf v3 wire format

func (*DispatchNexusTaskResponse) ProtoMessage added in v1.24.0 

func (*DispatchNexusTaskResponse) ProtoMessage()

func (*DispatchNexusTaskResponse) ProtoReflect added in v1.24.0 

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

func (*DispatchNexusTaskResponse) Reset added in v1.24.0 

func (x *DispatchNexusTaskResponse) Reset()

func (*DispatchNexusTaskResponse) Size added in v1.24.0 

func (val *DispatchNexusTaskResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*DispatchNexusTaskResponse) String added in v1.24.0 

func (x *DispatchNexusTaskResponse) String() string

func (*DispatchNexusTaskResponse) Unmarshal added in v1.24.0 

func (val *DispatchNexusTaskResponse) Unmarshal(buf []byte) error

Unmarshal an object of type DispatchNexusTaskResponse from the protobuf v3 wire format

type DispatchNexusTaskResponse_HandlerError added in v1.24.0 

type DispatchNexusTaskResponse_HandlerError struct {
	// Set if the worker's handler failed the nexus task.
	HandlerError *v111.HandlerError `protobuf:"bytes,1,opt,name=handler_error,json=handlerError,proto3,oneof"`
}

type DispatchNexusTaskResponse_Response added in v1.24.0 

type DispatchNexusTaskResponse_Response struct {
	// Set if the worker's handler responded successfully to the nexus task.
	Response *v111.Response `protobuf:"bytes,2,opt,name=response,proto3,oneof"`
}

type ForceUnloadTaskQueueRequest added in v1.21.0 

type ForceUnloadTaskQueueRequest struct {
	NamespaceId   string            `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue     string            `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	TaskQueueType v19.TaskQueueType `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ForceUnloadTaskQueueRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use ForceUnloadTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*ForceUnloadTaskQueueRequest) Equal added in v1.21.0 

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

Equal returns whether two ForceUnloadTaskQueueRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ForceUnloadTaskQueueRequest) GetNamespaceId added in v1.21.0 

func (x *ForceUnloadTaskQueueRequest) GetNamespaceId() string

func (*ForceUnloadTaskQueueRequest) GetTaskQueue added in v1.21.0 

func (x *ForceUnloadTaskQueueRequest) GetTaskQueue() string

func (*ForceUnloadTaskQueueRequest) GetTaskQueueType added in v1.21.0 

func (x *ForceUnloadTaskQueueRequest) GetTaskQueueType() v19.TaskQueueType

func (*ForceUnloadTaskQueueRequest) Marshal added in v1.21.0 

func (val *ForceUnloadTaskQueueRequest) Marshal() ([]byte, error)

Marshal an object of type ForceUnloadTaskQueueRequest to the protobuf v3 wire format

func (*ForceUnloadTaskQueueRequest) ProtoMessage added in v1.21.0 

func (*ForceUnloadTaskQueueRequest) ProtoMessage()

func (*ForceUnloadTaskQueueRequest) ProtoReflect added in v1.23.0 

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

func (*ForceUnloadTaskQueueRequest) Reset added in v1.21.0 

func (x *ForceUnloadTaskQueueRequest) Reset()

func (*ForceUnloadTaskQueueRequest) Size added in v1.21.0 

func (val *ForceUnloadTaskQueueRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ForceUnloadTaskQueueRequest) String added in v1.21.0 

func (x *ForceUnloadTaskQueueRequest) String() string

func (*ForceUnloadTaskQueueRequest) Unmarshal added in v1.21.0 

func (val *ForceUnloadTaskQueueRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ForceUnloadTaskQueueRequest from the protobuf v3 wire format

type ForceUnloadTaskQueueResponse added in v1.21.0 

type ForceUnloadTaskQueueResponse struct {
	WasLoaded bool `protobuf:"varint,1,opt,name=was_loaded,json=wasLoaded,proto3" json:"was_loaded,omitempty"`
	// contains filtered or unexported fields
}

func (*ForceUnloadTaskQueueResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use ForceUnloadTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*ForceUnloadTaskQueueResponse) Equal added in v1.21.0 

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

Equal returns whether two ForceUnloadTaskQueueResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ForceUnloadTaskQueueResponse) GetWasLoaded added in v1.21.0 

func (x *ForceUnloadTaskQueueResponse) GetWasLoaded() bool

func (*ForceUnloadTaskQueueResponse) Marshal added in v1.21.0 

func (val *ForceUnloadTaskQueueResponse) Marshal() ([]byte, error)

Marshal an object of type ForceUnloadTaskQueueResponse to the protobuf v3 wire format

func (*ForceUnloadTaskQueueResponse) ProtoMessage added in v1.21.0 

func (*ForceUnloadTaskQueueResponse) ProtoMessage()

func (*ForceUnloadTaskQueueResponse) ProtoReflect added in v1.23.0 

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

func (*ForceUnloadTaskQueueResponse) Reset added in v1.21.0 

func (x *ForceUnloadTaskQueueResponse) Reset()

func (*ForceUnloadTaskQueueResponse) Size added in v1.21.0 

func (val *ForceUnloadTaskQueueResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ForceUnloadTaskQueueResponse) String added in v1.21.0 

func (x *ForceUnloadTaskQueueResponse) String() string

func (*ForceUnloadTaskQueueResponse) Unmarshal added in v1.21.0 

func (val *ForceUnloadTaskQueueResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ForceUnloadTaskQueueResponse from the protobuf v3 wire format

type GetBuildIdTaskQueueMappingRequest added in v1.21.0 

type GetBuildIdTaskQueueMappingRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	BuildId     string `protobuf:"bytes,2,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBuildIdTaskQueueMappingRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use GetBuildIdTaskQueueMappingRequest.ProtoReflect.Descriptor instead.

func (*GetBuildIdTaskQueueMappingRequest) Equal added in v1.21.0 

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

Equal returns whether two GetBuildIdTaskQueueMappingRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetBuildIdTaskQueueMappingRequest) GetBuildId added in v1.21.0 

func (x *GetBuildIdTaskQueueMappingRequest) GetBuildId() string

func (*GetBuildIdTaskQueueMappingRequest) GetNamespaceId added in v1.21.0 

func (x *GetBuildIdTaskQueueMappingRequest) GetNamespaceId() string

func (*GetBuildIdTaskQueueMappingRequest) Marshal added in v1.21.0 

func (val *GetBuildIdTaskQueueMappingRequest) Marshal() ([]byte, error)

Marshal an object of type GetBuildIdTaskQueueMappingRequest to the protobuf v3 wire format

func (*GetBuildIdTaskQueueMappingRequest) ProtoMessage added in v1.21.0 

func (*GetBuildIdTaskQueueMappingRequest) ProtoMessage()

func (*GetBuildIdTaskQueueMappingRequest) ProtoReflect added in v1.23.0 

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

func (*GetBuildIdTaskQueueMappingRequest) Reset added in v1.21.0 

func (x *GetBuildIdTaskQueueMappingRequest) Reset()

func (*GetBuildIdTaskQueueMappingRequest) Size added in v1.21.0 

func (val *GetBuildIdTaskQueueMappingRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetBuildIdTaskQueueMappingRequest) String added in v1.21.0 

func (x *GetBuildIdTaskQueueMappingRequest) String() string

func (*GetBuildIdTaskQueueMappingRequest) Unmarshal added in v1.21.0 

func (val *GetBuildIdTaskQueueMappingRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetBuildIdTaskQueueMappingRequest from the protobuf v3 wire format

type GetBuildIdTaskQueueMappingResponse added in v1.21.0 

type GetBuildIdTaskQueueMappingResponse struct {
	TaskQueues []string `protobuf:"bytes,1,rep,name=task_queues,json=taskQueues,proto3" json:"task_queues,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBuildIdTaskQueueMappingResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use GetBuildIdTaskQueueMappingResponse.ProtoReflect.Descriptor instead.

func (*GetBuildIdTaskQueueMappingResponse) Equal added in v1.21.0 

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

Equal returns whether two GetBuildIdTaskQueueMappingResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetBuildIdTaskQueueMappingResponse) GetTaskQueues added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) Marshal added in v1.21.0 

func (val *GetBuildIdTaskQueueMappingResponse) Marshal() ([]byte, error)

Marshal an object of type GetBuildIdTaskQueueMappingResponse to the protobuf v3 wire format

func (*GetBuildIdTaskQueueMappingResponse) ProtoMessage added in v1.21.0 

func (*GetBuildIdTaskQueueMappingResponse) ProtoMessage()

func (*GetBuildIdTaskQueueMappingResponse) ProtoReflect added in v1.23.0 

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

func (*GetBuildIdTaskQueueMappingResponse) Reset added in v1.21.0 

func (x *GetBuildIdTaskQueueMappingResponse) Reset()

func (*GetBuildIdTaskQueueMappingResponse) Size added in v1.21.0 

func (val *GetBuildIdTaskQueueMappingResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetBuildIdTaskQueueMappingResponse) String added in v1.21.0 

func (x *GetBuildIdTaskQueueMappingResponse) String() string

func (*GetBuildIdTaskQueueMappingResponse) Unmarshal added in v1.21.0 

func (val *GetBuildIdTaskQueueMappingResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetBuildIdTaskQueueMappingResponse from the protobuf v3 wire format

type GetTaskQueueUserDataRequest added in v1.21.0 

type GetTaskQueueUserDataRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// The task queue to fetch data from. The task queue is always considered as a normal
	// queue, since sticky queues have no user data.
	TaskQueue string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Normally task queue type should always be TASK_QUEUE_TYPE_WORKFLOW here, but querying
	// activity task queues is useful for testing.
	TaskQueueType v19.TaskQueueType `` /* 144-byte string literal not displayed */
	// The value of the last known user data version.
	// If the requester has no data, it should set this to 0.
	// This value must not be set to a negative number (note that our linter suggests avoiding uint64).
	LastKnownUserDataVersion int64 `` /* 140-byte string literal not displayed */
	// If set and last_known_user_data_version is the current version, block until new data is
	// available (or timeout).
	WaitNewData bool `protobuf:"varint,4,opt,name=wait_new_data,json=waitNewData,proto3" json:"wait_new_data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskQueueUserDataRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use GetTaskQueueUserDataRequest.ProtoReflect.Descriptor instead.

func (*GetTaskQueueUserDataRequest) Equal added in v1.21.0 

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

Equal returns whether two GetTaskQueueUserDataRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetTaskQueueUserDataRequest) GetLastKnownUserDataVersion added in v1.21.0 

func (x *GetTaskQueueUserDataRequest) GetLastKnownUserDataVersion() int64

func (*GetTaskQueueUserDataRequest) GetNamespaceId added in v1.21.0 

func (x *GetTaskQueueUserDataRequest) GetNamespaceId() string

func (*GetTaskQueueUserDataRequest) GetTaskQueue added in v1.21.0 

func (x *GetTaskQueueUserDataRequest) GetTaskQueue() string

func (*GetTaskQueueUserDataRequest) GetTaskQueueType added in v1.21.0 

func (x *GetTaskQueueUserDataRequest) GetTaskQueueType() v19.TaskQueueType

func (*GetTaskQueueUserDataRequest) GetWaitNewData added in v1.21.0 

func (x *GetTaskQueueUserDataRequest) GetWaitNewData() bool

func (*GetTaskQueueUserDataRequest) Marshal added in v1.21.0 

func (val *GetTaskQueueUserDataRequest) Marshal() ([]byte, error)

Marshal an object of type GetTaskQueueUserDataRequest to the protobuf v3 wire format

func (*GetTaskQueueUserDataRequest) ProtoMessage added in v1.21.0 

func (*GetTaskQueueUserDataRequest) ProtoMessage()

func (*GetTaskQueueUserDataRequest) ProtoReflect added in v1.23.0 

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

func (*GetTaskQueueUserDataRequest) Reset added in v1.21.0 

func (x *GetTaskQueueUserDataRequest) Reset()

func (*GetTaskQueueUserDataRequest) Size added in v1.21.0 

func (val *GetTaskQueueUserDataRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetTaskQueueUserDataRequest) String added in v1.21.0 

func (x *GetTaskQueueUserDataRequest) String() string

func (*GetTaskQueueUserDataRequest) Unmarshal added in v1.21.0 

func (val *GetTaskQueueUserDataRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetTaskQueueUserDataRequest from the protobuf v3 wire format

type GetTaskQueueUserDataResponse added in v1.21.0 

type GetTaskQueueUserDataResponse struct {

	// Versioned user data, set if the task queue has user data and the request's last_known_user_data_version is less
	// than the version cached in the root partition.
	UserData *v110.VersionedTaskQueueUserData `protobuf:"bytes,2,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskQueueUserDataResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use GetTaskQueueUserDataResponse.ProtoReflect.Descriptor instead.

func (*GetTaskQueueUserDataResponse) Equal added in v1.21.0 

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

Equal returns whether two GetTaskQueueUserDataResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetTaskQueueUserDataResponse) GetUserData added in v1.21.0 

func (x *GetTaskQueueUserDataResponse) GetUserData() *v110.VersionedTaskQueueUserData

func (*GetTaskQueueUserDataResponse) Marshal added in v1.21.0 

func (val *GetTaskQueueUserDataResponse) Marshal() ([]byte, error)

Marshal an object of type GetTaskQueueUserDataResponse to the protobuf v3 wire format

func (*GetTaskQueueUserDataResponse) ProtoMessage added in v1.21.0 

func (*GetTaskQueueUserDataResponse) ProtoMessage()

func (*GetTaskQueueUserDataResponse) ProtoReflect added in v1.23.0 

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

func (*GetTaskQueueUserDataResponse) Reset added in v1.21.0 

func (x *GetTaskQueueUserDataResponse) Reset()

func (*GetTaskQueueUserDataResponse) Size added in v1.21.0 

func (val *GetTaskQueueUserDataResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetTaskQueueUserDataResponse) String added in v1.21.0 

func (x *GetTaskQueueUserDataResponse) String() string

func (*GetTaskQueueUserDataResponse) Unmarshal added in v1.21.0 

func (val *GetTaskQueueUserDataResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetTaskQueueUserDataResponse from the protobuf v3 wire format

type GetWorkerBuildIdCompatibilityRequest added in v1.21.0 

type GetWorkerBuildIdCompatibilityRequest struct {
	NamespaceId string                                   `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	Request     *v1.GetWorkerBuildIdCompatibilityRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerBuildIdCompatibilityRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use GetWorkerBuildIdCompatibilityRequest.ProtoReflect.Descriptor instead.

func (*GetWorkerBuildIdCompatibilityRequest) Equal added in v1.21.0 

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

Equal returns whether two GetWorkerBuildIdCompatibilityRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetWorkerBuildIdCompatibilityRequest) GetNamespaceId added in v1.21.0 

func (x *GetWorkerBuildIdCompatibilityRequest) GetNamespaceId() string

func (*GetWorkerBuildIdCompatibilityRequest) GetRequest added in v1.21.0 

func (x *GetWorkerBuildIdCompatibilityRequest) GetRequest() *v1.GetWorkerBuildIdCompatibilityRequest

func (*GetWorkerBuildIdCompatibilityRequest) Marshal added in v1.21.0 

func (val *GetWorkerBuildIdCompatibilityRequest) Marshal() ([]byte, error)

Marshal an object of type GetWorkerBuildIdCompatibilityRequest to the protobuf v3 wire format

func (*GetWorkerBuildIdCompatibilityRequest) ProtoMessage added in v1.21.0 

func (*GetWorkerBuildIdCompatibilityRequest) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityRequest) ProtoReflect added in v1.23.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) Reset added in v1.21.0 

func (x *GetWorkerBuildIdCompatibilityRequest) Reset()

func (*GetWorkerBuildIdCompatibilityRequest) Size added in v1.21.0 

func (val *GetWorkerBuildIdCompatibilityRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetWorkerBuildIdCompatibilityRequest) String added in v1.21.0 

func (x *GetWorkerBuildIdCompatibilityRequest) String() string

func (*GetWorkerBuildIdCompatibilityRequest) Unmarshal added in v1.21.0 

func (val *GetWorkerBuildIdCompatibilityRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetWorkerBuildIdCompatibilityRequest from the protobuf v3 wire format

type GetWorkerBuildIdCompatibilityResponse added in v1.21.0 

type GetWorkerBuildIdCompatibilityResponse struct {
	Response *v1.GetWorkerBuildIdCompatibilityResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerBuildIdCompatibilityResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use GetWorkerBuildIdCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerBuildIdCompatibilityResponse) Equal added in v1.21.0 

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

Equal returns whether two GetWorkerBuildIdCompatibilityResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetWorkerBuildIdCompatibilityResponse) GetResponse added in v1.21.0 

func (x *GetWorkerBuildIdCompatibilityResponse) GetResponse() *v1.GetWorkerBuildIdCompatibilityResponse

func (*GetWorkerBuildIdCompatibilityResponse) Marshal added in v1.21.0 

func (val *GetWorkerBuildIdCompatibilityResponse) Marshal() ([]byte, error)

Marshal an object of type GetWorkerBuildIdCompatibilityResponse to the protobuf v3 wire format

func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage added in v1.21.0 

func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityResponse) ProtoReflect added in v1.23.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) Reset added in v1.21.0 

func (x *GetWorkerBuildIdCompatibilityResponse) Reset()

func (*GetWorkerBuildIdCompatibilityResponse) Size added in v1.21.0 

func (val *GetWorkerBuildIdCompatibilityResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetWorkerBuildIdCompatibilityResponse) String added in v1.21.0 

func (x *GetWorkerBuildIdCompatibilityResponse) String() string

func (*GetWorkerBuildIdCompatibilityResponse) Unmarshal added in v1.21.0 

func (val *GetWorkerBuildIdCompatibilityResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetWorkerBuildIdCompatibilityResponse from the protobuf v3 wire format

type GetWorkerVersioningRulesRequest added in v1.24.0 

type GetWorkerVersioningRulesRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Types that are assignable to Command:
	//
	//	*GetWorkerVersioningRulesRequest_Request
	Command isGetWorkerVersioningRulesRequest_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

func (*GetWorkerVersioningRulesRequest) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use GetWorkerVersioningRulesRequest.ProtoReflect.Descriptor instead.

func (*GetWorkerVersioningRulesRequest) Equal added in v1.24.0 

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

Equal returns whether two GetWorkerVersioningRulesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetWorkerVersioningRulesRequest) GetCommand added in v1.24.0 

func (m *GetWorkerVersioningRulesRequest) GetCommand() isGetWorkerVersioningRulesRequest_Command

func (*GetWorkerVersioningRulesRequest) GetNamespaceId added in v1.24.0 

func (x *GetWorkerVersioningRulesRequest) GetNamespaceId() string

func (*GetWorkerVersioningRulesRequest) GetRequest added in v1.24.0 

func (x *GetWorkerVersioningRulesRequest) GetRequest() *v1.GetWorkerVersioningRulesRequest

func (*GetWorkerVersioningRulesRequest) GetTaskQueue added in v1.24.0 

func (x *GetWorkerVersioningRulesRequest) GetTaskQueue() string

func (*GetWorkerVersioningRulesRequest) Marshal added in v1.24.0 

func (val *GetWorkerVersioningRulesRequest) Marshal() ([]byte, error)

Marshal an object of type GetWorkerVersioningRulesRequest to the protobuf v3 wire format

func (*GetWorkerVersioningRulesRequest) ProtoMessage added in v1.24.0 

func (*GetWorkerVersioningRulesRequest) ProtoMessage()

func (*GetWorkerVersioningRulesRequest) ProtoReflect added in v1.24.0 

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

func (*GetWorkerVersioningRulesRequest) Reset added in v1.24.0 

func (x *GetWorkerVersioningRulesRequest) Reset()

func (*GetWorkerVersioningRulesRequest) Size added in v1.24.0 

func (val *GetWorkerVersioningRulesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetWorkerVersioningRulesRequest) String added in v1.24.0 

func (x *GetWorkerVersioningRulesRequest) String() string

func (*GetWorkerVersioningRulesRequest) Unmarshal added in v1.24.0 

func (val *GetWorkerVersioningRulesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type GetWorkerVersioningRulesRequest from the protobuf v3 wire format

type GetWorkerVersioningRulesRequest_Request added in v1.24.0 

type GetWorkerVersioningRulesRequest_Request struct {
	Request *v1.GetWorkerVersioningRulesRequest `protobuf:"bytes,3,opt,name=request,proto3,oneof"`
}

type GetWorkerVersioningRulesResponse added in v1.24.0 

type GetWorkerVersioningRulesResponse struct {
	Response *v1.GetWorkerVersioningRulesResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerVersioningRulesResponse) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use GetWorkerVersioningRulesResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerVersioningRulesResponse) Equal added in v1.24.0 

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

Equal returns whether two GetWorkerVersioningRulesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*GetWorkerVersioningRulesResponse) GetResponse added in v1.24.0 

func (x *GetWorkerVersioningRulesResponse) GetResponse() *v1.GetWorkerVersioningRulesResponse

func (*GetWorkerVersioningRulesResponse) Marshal added in v1.24.0 

func (val *GetWorkerVersioningRulesResponse) Marshal() ([]byte, error)

Marshal an object of type GetWorkerVersioningRulesResponse to the protobuf v3 wire format

func (*GetWorkerVersioningRulesResponse) ProtoMessage added in v1.24.0 

func (*GetWorkerVersioningRulesResponse) ProtoMessage()

func (*GetWorkerVersioningRulesResponse) ProtoReflect added in v1.24.0 

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

func (*GetWorkerVersioningRulesResponse) Reset added in v1.24.0 

func (x *GetWorkerVersioningRulesResponse) Reset()

func (*GetWorkerVersioningRulesResponse) Size added in v1.24.0 

func (val *GetWorkerVersioningRulesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*GetWorkerVersioningRulesResponse) String added in v1.24.0 

func (x *GetWorkerVersioningRulesResponse) String() string

func (*GetWorkerVersioningRulesResponse) Unmarshal added in v1.24.0 

func (val *GetWorkerVersioningRulesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type GetWorkerVersioningRulesResponse from the protobuf v3 wire format

type ListNexusEndpointsRequest added in v1.25.0 

type ListNexusEndpointsRequest struct {

	// To get the next page, pass in `ListNexusEndpointsResponse.next_page_token` from the previous page's response. The
	// token will be empty if there's no other page.
	// Note: the last page may be empty if the total number of services registered is a multiple of the page size.
	// Mutually exclusive with wait. Specifying both will result in an invalid argument error.
	NextPageToken []byte `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	PageSize      int32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The nexus_endpoints table has a monotonically increasing version number that is incremented on every change to
	// the table. This field can be used to provide the last known table version in conjuction with the `wait` field to
	// long poll on changes to the table.
	// If next_page_token is not empty and the current table version does not match this field, this request will fail
	// with a failed precondition error.
	LastKnownTableVersion int64 `` /* 129-byte string literal not displayed */
	// If true, this request becomes a long poll and will be unblocked once the DB version is incremented.
	// Mutually exclusive with next_page_token. Specifying both will result in an invalid argument error.
	Wait bool `protobuf:"varint,4,opt,name=wait,proto3" json:"wait,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNexusEndpointsRequest) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use ListNexusEndpointsRequest.ProtoReflect.Descriptor instead.

func (*ListNexusEndpointsRequest) Equal added in v1.25.0 

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

Equal returns whether two ListNexusEndpointsRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListNexusEndpointsRequest) GetLastKnownTableVersion added in v1.25.0 

func (x *ListNexusEndpointsRequest) GetLastKnownTableVersion() int64

func (*ListNexusEndpointsRequest) GetNextPageToken added in v1.25.0 

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

func (*ListNexusEndpointsRequest) GetPageSize added in v1.25.0 

func (x *ListNexusEndpointsRequest) GetPageSize() int32

func (*ListNexusEndpointsRequest) GetWait added in v1.25.0 

func (x *ListNexusEndpointsRequest) GetWait() bool

func (*ListNexusEndpointsRequest) Marshal added in v1.25.0 

func (val *ListNexusEndpointsRequest) Marshal() ([]byte, error)

Marshal an object of type ListNexusEndpointsRequest to the protobuf v3 wire format

func (*ListNexusEndpointsRequest) ProtoMessage added in v1.25.0 

func (*ListNexusEndpointsRequest) ProtoMessage()

func (*ListNexusEndpointsRequest) ProtoReflect added in v1.25.0 

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

func (*ListNexusEndpointsRequest) Reset added in v1.25.0 

func (x *ListNexusEndpointsRequest) Reset()

func (*ListNexusEndpointsRequest) Size added in v1.25.0 

func (val *ListNexusEndpointsRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListNexusEndpointsRequest) String added in v1.25.0 

func (x *ListNexusEndpointsRequest) String() string

func (*ListNexusEndpointsRequest) Unmarshal added in v1.25.0 

func (val *ListNexusEndpointsRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ListNexusEndpointsRequest from the protobuf v3 wire format

type ListNexusEndpointsResponse added in v1.25.0 

type ListNexusEndpointsResponse struct {

	// Token for getting the next page.
	NextPageToken []byte                     `protobuf:"bytes,1,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	TableVersion  int64                      `protobuf:"varint,2,opt,name=table_version,json=tableVersion,proto3" json:"table_version,omitempty"`
	Entries       []*v110.NexusEndpointEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNexusEndpointsResponse) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use ListNexusEndpointsResponse.ProtoReflect.Descriptor instead.

func (*ListNexusEndpointsResponse) Equal added in v1.25.0 

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

Equal returns whether two ListNexusEndpointsResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListNexusEndpointsResponse) GetEntries added in v1.25.0 

func (x *ListNexusEndpointsResponse) GetEntries() []*v110.NexusEndpointEntry

func (*ListNexusEndpointsResponse) GetNextPageToken added in v1.25.0 

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

func (*ListNexusEndpointsResponse) GetTableVersion added in v1.25.0 

func (x *ListNexusEndpointsResponse) GetTableVersion() int64

func (*ListNexusEndpointsResponse) Marshal added in v1.25.0 

func (val *ListNexusEndpointsResponse) Marshal() ([]byte, error)

Marshal an object of type ListNexusEndpointsResponse to the protobuf v3 wire format

func (*ListNexusEndpointsResponse) ProtoMessage added in v1.25.0 

func (*ListNexusEndpointsResponse) ProtoMessage()

func (*ListNexusEndpointsResponse) ProtoReflect added in v1.25.0 

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

func (*ListNexusEndpointsResponse) Reset added in v1.25.0 

func (x *ListNexusEndpointsResponse) Reset()

func (*ListNexusEndpointsResponse) Size added in v1.25.0 

func (val *ListNexusEndpointsResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListNexusEndpointsResponse) String added in v1.25.0 

func (x *ListNexusEndpointsResponse) String() string

func (*ListNexusEndpointsResponse) Unmarshal added in v1.25.0 

func (val *ListNexusEndpointsResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ListNexusEndpointsResponse from the protobuf v3 wire format

type ListTaskQueuePartitionsRequest 

type ListTaskQueuePartitionsRequest struct {
	Namespace   string         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	NamespaceId string         `protobuf:"bytes,3,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,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) Equal 

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

Equal returns whether two ListTaskQueuePartitionsRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListTaskQueuePartitionsRequest) GetNamespace 

func (x *ListTaskQueuePartitionsRequest) GetNamespace() string

func (*ListTaskQueuePartitionsRequest) GetNamespaceId added in v1.17.3 

func (x *ListTaskQueuePartitionsRequest) GetNamespaceId() string

func (*ListTaskQueuePartitionsRequest) GetTaskQueue 

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

func (*ListTaskQueuePartitionsRequest) Marshal 

func (val *ListTaskQueuePartitionsRequest) Marshal() ([]byte, error)

Marshal an object of type ListTaskQueuePartitionsRequest to the protobuf v3 wire format

func (*ListTaskQueuePartitionsRequest) ProtoMessage 

func (*ListTaskQueuePartitionsRequest) ProtoMessage()

func (*ListTaskQueuePartitionsRequest) ProtoReflect added in v1.23.0 

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

func (*ListTaskQueuePartitionsRequest) Reset 

func (x *ListTaskQueuePartitionsRequest) Reset()

func (*ListTaskQueuePartitionsRequest) Size 

func (val *ListTaskQueuePartitionsRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListTaskQueuePartitionsRequest) String 

func (x *ListTaskQueuePartitionsRequest) String() string

func (*ListTaskQueuePartitionsRequest) Unmarshal 

func (val *ListTaskQueuePartitionsRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ListTaskQueuePartitionsRequest from the protobuf v3 wire format

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

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

Equal returns whether two ListTaskQueuePartitionsResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ListTaskQueuePartitionsResponse) GetActivityTaskQueuePartitions 

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

func (*ListTaskQueuePartitionsResponse) GetWorkflowTaskQueuePartitions 

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

func (*ListTaskQueuePartitionsResponse) Marshal 

func (val *ListTaskQueuePartitionsResponse) Marshal() ([]byte, error)

Marshal an object of type ListTaskQueuePartitionsResponse to the protobuf v3 wire format

func (*ListTaskQueuePartitionsResponse) ProtoMessage 

func (*ListTaskQueuePartitionsResponse) ProtoMessage()

func (*ListTaskQueuePartitionsResponse) ProtoReflect added in v1.23.0 

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

func (*ListTaskQueuePartitionsResponse) Reset 

func (x *ListTaskQueuePartitionsResponse) Reset()

func (*ListTaskQueuePartitionsResponse) Size 

func (val *ListTaskQueuePartitionsResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ListTaskQueuePartitionsResponse) String 

func (x *ListTaskQueuePartitionsResponse) String() string

func (*ListTaskQueuePartitionsResponse) Unmarshal 

func (val *ListTaskQueuePartitionsResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ListTaskQueuePartitionsResponse from the protobuf v3 wire format

type MatchingServiceClient 

type MatchingServiceClient interface {
	// PollWorkflowTaskQueue is called by frontend to process WorkflowTask from a specific task queue.  A
	// WorkflowTask is dispatched to callers for active workflow executions, with pending workflow tasks.
	PollWorkflowTaskQueue(ctx context.Context, in *PollWorkflowTaskQueueRequest, opts ...grpc.CallOption) (*PollWorkflowTaskQueueResponse, error)
	// PollActivityTaskQueue is called by frontend to process ActivityTask from a specific task queue.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask command is made for a workflow execution.
	PollActivityTaskQueue(ctx context.Context, in *PollActivityTaskQueueRequest, opts ...grpc.CallOption) (*PollActivityTaskQueueResponse, error)
	// AddWorkflowTask is called by the history service when a workflow task is scheduled, so that it can be dispatched
	// by the MatchingEngine.
	AddWorkflowTask(ctx context.Context, in *AddWorkflowTaskRequest, opts ...grpc.CallOption) (*AddWorkflowTaskResponse, error)
	// AddActivityTask is called by the history service when a workflow task is scheduled, so that it can be dispatched
	// by the MatchingEngine.
	AddActivityTask(ctx context.Context, in *AddActivityTaskRequest, opts ...grpc.CallOption) (*AddActivityTaskResponse, error)
	// QueryWorkflow is called by frontend to query a workflow.
	QueryWorkflow(ctx context.Context, in *QueryWorkflowRequest, opts ...grpc.CallOption) (*QueryWorkflowResponse, error)
	// RespondQueryTaskCompleted is called by frontend to respond query completed.
	RespondQueryTaskCompleted(ctx context.Context, in *RespondQueryTaskCompletedRequest, opts ...grpc.CallOption) (*RespondQueryTaskCompletedResponse, error)
	// Request from frontend to synchronously dispatch a nexus task to a worker.
	DispatchNexusTask(ctx context.Context, in *DispatchNexusTaskRequest, opts ...grpc.CallOption) (*DispatchNexusTaskResponse, error)
	// Request from worker (via frontend) to long poll on nexus tasks.
	PollNexusTaskQueue(ctx context.Context, in *PollNexusTaskQueueRequest, opts ...grpc.CallOption) (*PollNexusTaskQueueResponse, error)
	// Response from a worker (via frontend) to a Nexus task, unblocks the corresponding DispatchNexusTask request.
	RespondNexusTaskCompleted(ctx context.Context, in *RespondNexusTaskCompletedRequest, opts ...grpc.CallOption) (*RespondNexusTaskCompletedResponse, error)
	// Response from a worker (via frontend) to a Nexus task, unblocks the corresponding DispatchNexusTask request.
	RespondNexusTaskFailed(ctx context.Context, in *RespondNexusTaskFailedRequest, opts ...grpc.CallOption) (*RespondNexusTaskFailedResponse, error)
	// CancelOutstandingPoll is called by frontend to unblock long polls on matching for zombie pollers.
	// Our rpc stack does not support context propagation, so when a client connection goes away frontend sees
	// cancellation of context for that handler, but any corresponding calls (long-poll) to matching service does not
	// see the cancellation propagated so it can unblock corresponding long-polls on its end.  This results is tasks
	// being dispatched to zombie pollers in this situation.  This API is added so every time frontend makes a long-poll
	// api call to matching it passes in a pollerId and then calls this API when it detects client connection is closed
	// to unblock long polls for this poller and prevent tasks being sent to these zombie pollers.
	CancelOutstandingPoll(ctx context.Context, in *CancelOutstandingPollRequest, opts ...grpc.CallOption) (*CancelOutstandingPollResponse, error)
	// DescribeTaskQueue returns information about the target task queue, right now this API returns the
	// pollers which polled this task queue in last few minutes.
	DescribeTaskQueue(ctx context.Context, in *DescribeTaskQueueRequest, opts ...grpc.CallOption) (*DescribeTaskQueueResponse, error)
	// DescribeTaskQueuePartition returns information about the target task queue partition.
	DescribeTaskQueuePartition(ctx context.Context, in *DescribeTaskQueuePartitionRequest, opts ...grpc.CallOption) (*DescribeTaskQueuePartitionResponse, error)
	// ListTaskQueuePartitions returns a map of partitionKey and hostAddress for a task queue.
	ListTaskQueuePartitions(ctx context.Context, in *ListTaskQueuePartitionsRequest, opts ...grpc.CallOption) (*ListTaskQueuePartitionsResponse, error)
	// (-- api-linter: core::0134::response-message-name=disabled
	//
	//	aip.dev/not-precedent: UpdateWorkerBuildIdCompatibility RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::method-signature=disabled
	//
	//	aip.dev/not-precedent: UpdateWorkerBuildIdCompatibility RPC doesn't follow Google API format. --)
	UpdateWorkerBuildIdCompatibility(ctx context.Context, in *UpdateWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption) (*UpdateWorkerBuildIdCompatibilityResponse, error)
	GetWorkerBuildIdCompatibility(ctx context.Context, in *GetWorkerBuildIdCompatibilityRequest, opts ...grpc.CallOption) (*GetWorkerBuildIdCompatibilityResponse, error)
	// Fetch user data for a task queue, this request should always be routed to the node holding the root partition of the workflow task queue.
	GetTaskQueueUserData(ctx context.Context, in *GetTaskQueueUserDataRequest, opts ...grpc.CallOption) (*GetTaskQueueUserDataResponse, error)
	// Allows updating the Build ID assignment and redirect rules for a given Task Queue.
	// (-- api-linter: core::0134::method-signature=disabled
	//
	//	aip.dev/not-precedent: UpdateWorkerVersioningRulesRequest RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::response-message-name=disabled
	//
	//	aip.dev/not-precedent: UpdateWorkerVersioningRulesRequest RPC doesn't follow Google API format. --)
	UpdateWorkerVersioningRules(ctx context.Context, in *UpdateWorkerVersioningRulesRequest, opts ...grpc.CallOption) (*UpdateWorkerVersioningRulesResponse, error)
	// Fetches the Build ID assignment and redirect rules for a Task Queue
	// (-- api-linter: core::0127::resource-name-extraction=disabled
	//
	//	aip.dev/not-precedent: GetWorkerVersioningRulesRequest RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0131::http-uri-name=disabled
	//
	//	aip.dev/not-precedent: GetWorkerVersioningRulesRequest RPC doesn't follow Google API format. --)
	GetWorkerVersioningRules(ctx context.Context, in *GetWorkerVersioningRulesRequest, opts ...grpc.CallOption) (*GetWorkerVersioningRulesResponse, error)
	// Apply a user data replication event.
	ApplyTaskQueueUserDataReplicationEvent(ctx context.Context, in *ApplyTaskQueueUserDataReplicationEventRequest, opts ...grpc.CallOption) (*ApplyTaskQueueUserDataReplicationEventResponse, error)
	// Gets all task queue names mapped to a given build ID
	GetBuildIdTaskQueueMapping(ctx context.Context, in *GetBuildIdTaskQueueMappingRequest, opts ...grpc.CallOption) (*GetBuildIdTaskQueueMappingResponse, error)
	// Force unloading a task queue. Used for testing only.
	ForceUnloadTaskQueue(ctx context.Context, in *ForceUnloadTaskQueueRequest, opts ...grpc.CallOption) (*ForceUnloadTaskQueueResponse, error)
	// Update task queue user data in owning node for all updates in namespace.
	// All user data updates must first go through the task queue owner using the `UpdateWorkerBuildIdCompatibility`
	// API.
	// (-- api-linter: core::0134::response-message-name=disabled
	//
	//	aip.dev/not-precedent: UpdateTaskQueueUserData RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::method-signature=disabled
	//
	//	aip.dev/not-precedent: UpdateTaskQueueUserData RPC doesn't follow Google API format. --)
	UpdateTaskQueueUserData(ctx context.Context, in *UpdateTaskQueueUserDataRequest, opts ...grpc.CallOption) (*UpdateTaskQueueUserDataResponse, error)
	// Replicate task queue user data across clusters, must be done via the owning node for updates in namespace.
	ReplicateTaskQueueUserData(ctx context.Context, in *ReplicateTaskQueueUserDataRequest, opts ...grpc.CallOption) (*ReplicateTaskQueueUserDataResponse, error)
	// Create a Nexus endpoint.
	// (-- api-linter: core::0133::method-signature=disabled
	//
	//	aip.dev/not-precedent: CreateNexusEndpoint RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0133::response-message-name=disabled
	//
	//	aip.dev/not-precedent: CreateNexusEndpoint RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0133::http-uri-parent=disabled
	//
	//	aip.dev/not-precedent: CreateNexusEndpoint RPC doesn't follow Google API format. --)
	CreateNexusEndpoint(ctx context.Context, in *CreateNexusEndpointRequest, opts ...grpc.CallOption) (*CreateNexusEndpointResponse, error)
	// Optimistically update a Nexus endpoint based on provided version.
	// If this request is accepted, the input is considered the "current" state of this service at the time it was
	// persisted and the updated version is returned.
	// (-- api-linter: core::0134::method-signature=disabled
	//
	//	aip.dev/not-precedent: UpdateNexusEndpoint RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::response-message-name=disabled
	//
	//	aip.dev/not-precedent: UpdateNexusEndpoint RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::request-resource-required=disabled
	//
	//	aip.dev/not-precedent: UpdateNexusEndpoint RPC doesn't follow Google API format. --)
	UpdateNexusEndpoint(ctx context.Context, in *UpdateNexusEndpointRequest, opts ...grpc.CallOption) (*UpdateNexusEndpointResponse, error)
	// Delete a service by its name.
	DeleteNexusEndpoint(ctx context.Context, in *DeleteNexusEndpointRequest, opts ...grpc.CallOption) (*DeleteNexusEndpointResponse, error)
	// List all registered services.
	ListNexusEndpoints(ctx context.Context, in *ListNexusEndpointsRequest, opts ...grpc.CallOption) (*ListNexusEndpointsResponse, error)
}

MatchingServiceClient is the client API for MatchingService 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.

func NewMatchingServiceClient 

func NewMatchingServiceClient(cc grpc.ClientConnInterface) MatchingServiceClient

type MatchingServiceServer 

type MatchingServiceServer interface {
	// PollWorkflowTaskQueue is called by frontend to process WorkflowTask from a specific task queue.  A
	// WorkflowTask is dispatched to callers for active workflow executions, with pending workflow tasks.
	PollWorkflowTaskQueue(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)
	// PollActivityTaskQueue is called by frontend to process ActivityTask from a specific task queue.  ActivityTask
	// is dispatched to callers whenever a ScheduleTask command is made for a workflow execution.
	PollActivityTaskQueue(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)
	// AddWorkflowTask is called by the history service when a workflow task is scheduled, so that it can be dispatched
	// by the MatchingEngine.
	AddWorkflowTask(context.Context, *AddWorkflowTaskRequest) (*AddWorkflowTaskResponse, error)
	// AddActivityTask is called by the history service when a workflow task is scheduled, so that it can be dispatched
	// by the MatchingEngine.
	AddActivityTask(context.Context, *AddActivityTaskRequest) (*AddActivityTaskResponse, error)
	// QueryWorkflow is called by frontend to query a workflow.
	QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)
	// RespondQueryTaskCompleted is called by frontend to respond query completed.
	RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)
	// Request from frontend to synchronously dispatch a nexus task to a worker.
	DispatchNexusTask(context.Context, *DispatchNexusTaskRequest) (*DispatchNexusTaskResponse, error)
	// Request from worker (via frontend) to long poll on nexus tasks.
	PollNexusTaskQueue(context.Context, *PollNexusTaskQueueRequest) (*PollNexusTaskQueueResponse, error)
	// Response from a worker (via frontend) to a Nexus task, unblocks the corresponding DispatchNexusTask request.
	RespondNexusTaskCompleted(context.Context, *RespondNexusTaskCompletedRequest) (*RespondNexusTaskCompletedResponse, error)
	// Response from a worker (via frontend) to a Nexus task, unblocks the corresponding DispatchNexusTask request.
	RespondNexusTaskFailed(context.Context, *RespondNexusTaskFailedRequest) (*RespondNexusTaskFailedResponse, error)
	// CancelOutstandingPoll is called by frontend to unblock long polls on matching for zombie pollers.
	// Our rpc stack does not support context propagation, so when a client connection goes away frontend sees
	// cancellation of context for that handler, but any corresponding calls (long-poll) to matching service does not
	// see the cancellation propagated so it can unblock corresponding long-polls on its end.  This results is tasks
	// being dispatched to zombie pollers in this situation.  This API is added so every time frontend makes a long-poll
	// api call to matching it passes in a pollerId and then calls this API when it detects client connection is closed
	// to unblock long polls for this poller and prevent tasks being sent to these zombie pollers.
	CancelOutstandingPoll(context.Context, *CancelOutstandingPollRequest) (*CancelOutstandingPollResponse, error)
	// DescribeTaskQueue returns information about the target task queue, right now this API returns the
	// pollers which polled this task queue in last few minutes.
	DescribeTaskQueue(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)
	// DescribeTaskQueuePartition returns information about the target task queue partition.
	DescribeTaskQueuePartition(context.Context, *DescribeTaskQueuePartitionRequest) (*DescribeTaskQueuePartitionResponse, error)
	// ListTaskQueuePartitions returns a map of partitionKey and hostAddress for a task queue.
	ListTaskQueuePartitions(context.Context, *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)
	// (-- api-linter: core::0134::response-message-name=disabled
	//
	//	aip.dev/not-precedent: UpdateWorkerBuildIdCompatibility RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::method-signature=disabled
	//
	//	aip.dev/not-precedent: UpdateWorkerBuildIdCompatibility RPC doesn't follow Google API format. --)
	UpdateWorkerBuildIdCompatibility(context.Context, *UpdateWorkerBuildIdCompatibilityRequest) (*UpdateWorkerBuildIdCompatibilityResponse, error)
	GetWorkerBuildIdCompatibility(context.Context, *GetWorkerBuildIdCompatibilityRequest) (*GetWorkerBuildIdCompatibilityResponse, error)
	// Fetch user data for a task queue, this request should always be routed to the node holding the root partition of the workflow task queue.
	GetTaskQueueUserData(context.Context, *GetTaskQueueUserDataRequest) (*GetTaskQueueUserDataResponse, error)
	// Allows updating the Build ID assignment and redirect rules for a given Task Queue.
	// (-- api-linter: core::0134::method-signature=disabled
	//
	//	aip.dev/not-precedent: UpdateWorkerVersioningRulesRequest RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::response-message-name=disabled
	//
	//	aip.dev/not-precedent: UpdateWorkerVersioningRulesRequest RPC doesn't follow Google API format. --)
	UpdateWorkerVersioningRules(context.Context, *UpdateWorkerVersioningRulesRequest) (*UpdateWorkerVersioningRulesResponse, error)
	// Fetches the Build ID assignment and redirect rules for a Task Queue
	// (-- api-linter: core::0127::resource-name-extraction=disabled
	//
	//	aip.dev/not-precedent: GetWorkerVersioningRulesRequest RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0131::http-uri-name=disabled
	//
	//	aip.dev/not-precedent: GetWorkerVersioningRulesRequest RPC doesn't follow Google API format. --)
	GetWorkerVersioningRules(context.Context, *GetWorkerVersioningRulesRequest) (*GetWorkerVersioningRulesResponse, error)
	// Apply a user data replication event.
	ApplyTaskQueueUserDataReplicationEvent(context.Context, *ApplyTaskQueueUserDataReplicationEventRequest) (*ApplyTaskQueueUserDataReplicationEventResponse, error)
	// Gets all task queue names mapped to a given build ID
	GetBuildIdTaskQueueMapping(context.Context, *GetBuildIdTaskQueueMappingRequest) (*GetBuildIdTaskQueueMappingResponse, error)
	// Force unloading a task queue. Used for testing only.
	ForceUnloadTaskQueue(context.Context, *ForceUnloadTaskQueueRequest) (*ForceUnloadTaskQueueResponse, error)
	// Update task queue user data in owning node for all updates in namespace.
	// All user data updates must first go through the task queue owner using the `UpdateWorkerBuildIdCompatibility`
	// API.
	// (-- api-linter: core::0134::response-message-name=disabled
	//
	//	aip.dev/not-precedent: UpdateTaskQueueUserData RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::method-signature=disabled
	//
	//	aip.dev/not-precedent: UpdateTaskQueueUserData RPC doesn't follow Google API format. --)
	UpdateTaskQueueUserData(context.Context, *UpdateTaskQueueUserDataRequest) (*UpdateTaskQueueUserDataResponse, error)
	// Replicate task queue user data across clusters, must be done via the owning node for updates in namespace.
	ReplicateTaskQueueUserData(context.Context, *ReplicateTaskQueueUserDataRequest) (*ReplicateTaskQueueUserDataResponse, error)
	// Create a Nexus endpoint.
	// (-- api-linter: core::0133::method-signature=disabled
	//
	//	aip.dev/not-precedent: CreateNexusEndpoint RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0133::response-message-name=disabled
	//
	//	aip.dev/not-precedent: CreateNexusEndpoint RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0133::http-uri-parent=disabled
	//
	//	aip.dev/not-precedent: CreateNexusEndpoint RPC doesn't follow Google API format. --)
	CreateNexusEndpoint(context.Context, *CreateNexusEndpointRequest) (*CreateNexusEndpointResponse, error)
	// Optimistically update a Nexus endpoint based on provided version.
	// If this request is accepted, the input is considered the "current" state of this service at the time it was
	// persisted and the updated version is returned.
	// (-- api-linter: core::0134::method-signature=disabled
	//
	//	aip.dev/not-precedent: UpdateNexusEndpoint RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::response-message-name=disabled
	//
	//	aip.dev/not-precedent: UpdateNexusEndpoint RPC doesn't follow Google API format. --)
	//
	// (-- api-linter: core::0134::request-resource-required=disabled
	//
	//	aip.dev/not-precedent: UpdateNexusEndpoint RPC doesn't follow Google API format. --)
	UpdateNexusEndpoint(context.Context, *UpdateNexusEndpointRequest) (*UpdateNexusEndpointResponse, error)
	// Delete a service by its name.
	DeleteNexusEndpoint(context.Context, *DeleteNexusEndpointRequest) (*DeleteNexusEndpointResponse, error)
	// List all registered services.
	ListNexusEndpoints(context.Context, *ListNexusEndpointsRequest) (*ListNexusEndpointsResponse, error)
	// contains filtered or unexported methods
}

MatchingServiceServer is the server API for MatchingService service. All implementations must embed UnimplementedMatchingServiceServer for forward compatibility

type PollActivityTaskQueueRequest 

type PollActivityTaskQueueRequest struct {
	NamespaceId     string                           `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PollerId        string                           `protobuf:"bytes,2,opt,name=poller_id,json=pollerId,proto3" json:"poller_id,omitempty"`
	PollRequest     *v1.PollActivityTaskQueueRequest `protobuf:"bytes,3,opt,name=poll_request,json=pollRequest,proto3" json:"poll_request,omitempty"`
	ForwardedSource string                           `protobuf:"bytes,4,opt,name=forwarded_source,json=forwardedSource,proto3" json:"forwarded_source,omitempty"`
	// contains filtered or unexported fields
}

func (*PollActivityTaskQueueRequest) Descriptor deprecated 

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

Deprecated: Use PollActivityTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*PollActivityTaskQueueRequest) Equal 

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

Equal returns whether two PollActivityTaskQueueRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PollActivityTaskQueueRequest) GetForwardedSource added in v0.28.0 

func (x *PollActivityTaskQueueRequest) GetForwardedSource() string

func (*PollActivityTaskQueueRequest) GetNamespaceId 

func (x *PollActivityTaskQueueRequest) GetNamespaceId() string

func (*PollActivityTaskQueueRequest) GetPollRequest 

func (x *PollActivityTaskQueueRequest) GetPollRequest() *v1.PollActivityTaskQueueRequest

func (*PollActivityTaskQueueRequest) GetPollerId 

func (x *PollActivityTaskQueueRequest) GetPollerId() string

func (*PollActivityTaskQueueRequest) Marshal 

func (val *PollActivityTaskQueueRequest) Marshal() ([]byte, error)

Marshal an object of type PollActivityTaskQueueRequest to the protobuf v3 wire format

func (*PollActivityTaskQueueRequest) ProtoMessage 

func (*PollActivityTaskQueueRequest) ProtoMessage()

func (*PollActivityTaskQueueRequest) ProtoReflect added in v1.23.0 

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

func (*PollActivityTaskQueueRequest) Reset 

func (x *PollActivityTaskQueueRequest) Reset()

func (*PollActivityTaskQueueRequest) Size 

func (val *PollActivityTaskQueueRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PollActivityTaskQueueRequest) String 

func (x *PollActivityTaskQueueRequest) String() string

func (*PollActivityTaskQueueRequest) Unmarshal 

func (val *PollActivityTaskQueueRequest) Unmarshal(buf []byte) error

Unmarshal an object of type PollActivityTaskQueueRequest from the protobuf v3 wire format

type PollActivityTaskQueueResponse 

type PollActivityTaskQueueResponse struct {
	TaskToken         []byte                 `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	WorkflowExecution *v11.WorkflowExecution `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	ActivityId        string                 `protobuf:"bytes,3,opt,name=activity_id,json=activityId,proto3" json:"activity_id,omitempty"`
	ActivityType      *v11.ActivityType      `protobuf:"bytes,4,opt,name=activity_type,json=activityType,proto3" json:"activity_type,omitempty"`
	Input             *v11.Payloads          `protobuf:"bytes,5,opt,name=input,proto3" json:"input,omitempty"`
	ScheduledTime     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeout *durationpb.Duration   `` /* 131-byte string literal not displayed */
	StartedTime            *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//
	//	aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeout         *durationpb.Duration   `protobuf:"bytes,9,opt,name=start_to_close_timeout,json=startToCloseTimeout,proto3" json:"start_to_close_timeout,omitempty"`
	HeartbeatTimeout            *durationpb.Duration   `protobuf:"bytes,10,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"`
	Attempt                     int32                  `protobuf:"varint,11,opt,name=attempt,proto3" json:"attempt,omitempty"`
	CurrentAttemptScheduledTime *timestamppb.Timestamp `` /* 147-byte string literal not displayed */
	HeartbeatDetails            *v11.Payloads          `protobuf:"bytes,13,opt,name=heartbeat_details,json=heartbeatDetails,proto3" json:"heartbeat_details,omitempty"`
	WorkflowType                *v11.WorkflowType      `protobuf:"bytes,14,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	WorkflowNamespace           string                 `protobuf:"bytes,15,opt,name=workflow_namespace,json=workflowNamespace,proto3" json:"workflow_namespace,omitempty"`
	Header                      *v11.Header            `protobuf:"bytes,16,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*PollActivityTaskQueueResponse) Descriptor deprecated 

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

Deprecated: Use PollActivityTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*PollActivityTaskQueueResponse) Equal 

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

Equal returns whether two PollActivityTaskQueueResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PollActivityTaskQueueResponse) GetActivityId 

func (x *PollActivityTaskQueueResponse) GetActivityId() string

func (*PollActivityTaskQueueResponse) GetActivityType 

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

func (*PollActivityTaskQueueResponse) GetAttempt 

func (x *PollActivityTaskQueueResponse) GetAttempt() int32

func (*PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetHeader 

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

func (*PollActivityTaskQueueResponse) GetHeartbeatDetails 

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

func (*PollActivityTaskQueueResponse) GetHeartbeatTimeout added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetInput 

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

func (*PollActivityTaskQueueResponse) GetScheduleToCloseTimeout added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetScheduledTime added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetStartToCloseTimeout added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetStartedTime added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetTaskToken 

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

func (*PollActivityTaskQueueResponse) GetWorkflowExecution 

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

func (*PollActivityTaskQueueResponse) GetWorkflowNamespace 

func (x *PollActivityTaskQueueResponse) GetWorkflowNamespace() string

func (*PollActivityTaskQueueResponse) GetWorkflowType 

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

func (*PollActivityTaskQueueResponse) Marshal 

func (val *PollActivityTaskQueueResponse) Marshal() ([]byte, error)

Marshal an object of type PollActivityTaskQueueResponse to the protobuf v3 wire format

func (*PollActivityTaskQueueResponse) ProtoMessage 

func (*PollActivityTaskQueueResponse) ProtoMessage()

func (*PollActivityTaskQueueResponse) ProtoReflect added in v1.23.0 

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

func (*PollActivityTaskQueueResponse) Reset 

func (x *PollActivityTaskQueueResponse) Reset()

func (*PollActivityTaskQueueResponse) Size 

func (val *PollActivityTaskQueueResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PollActivityTaskQueueResponse) String 

func (x *PollActivityTaskQueueResponse) String() string

func (*PollActivityTaskQueueResponse) Unmarshal 

func (val *PollActivityTaskQueueResponse) Unmarshal(buf []byte) error

Unmarshal an object of type PollActivityTaskQueueResponse from the protobuf v3 wire format

type PollNexusTaskQueueRequest added in v1.24.0 

type PollNexusTaskQueueRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	// A unique ID generated by the frontend for this request.
	PollerId string `protobuf:"bytes,2,opt,name=poller_id,json=pollerId,proto3" json:"poller_id,omitempty"`
	// Original WorkflowService poll request as received by the frontend.
	Request *v1.PollNexusTaskQueueRequest `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
	// Non-empty if this poll was forwarded from a child partition.
	ForwardedSource string `protobuf:"bytes,4,opt,name=forwarded_source,json=forwardedSource,proto3" json:"forwarded_source,omitempty"`
	// contains filtered or unexported fields
}

func (*PollNexusTaskQueueRequest) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use PollNexusTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*PollNexusTaskQueueRequest) Equal added in v1.24.0 

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

Equal returns whether two PollNexusTaskQueueRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PollNexusTaskQueueRequest) GetForwardedSource added in v1.24.0 

func (x *PollNexusTaskQueueRequest) GetForwardedSource() string

func (*PollNexusTaskQueueRequest) GetNamespaceId added in v1.24.0 

func (x *PollNexusTaskQueueRequest) GetNamespaceId() string

func (*PollNexusTaskQueueRequest) GetPollerId added in v1.24.0 

func (x *PollNexusTaskQueueRequest) GetPollerId() string

func (*PollNexusTaskQueueRequest) GetRequest added in v1.24.0 

func (x *PollNexusTaskQueueRequest) GetRequest() *v1.PollNexusTaskQueueRequest

func (*PollNexusTaskQueueRequest) Marshal added in v1.24.0 

func (val *PollNexusTaskQueueRequest) Marshal() ([]byte, error)

Marshal an object of type PollNexusTaskQueueRequest to the protobuf v3 wire format

func (*PollNexusTaskQueueRequest) ProtoMessage added in v1.24.0 

func (*PollNexusTaskQueueRequest) ProtoMessage()

func (*PollNexusTaskQueueRequest) ProtoReflect added in v1.24.0 

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

func (*PollNexusTaskQueueRequest) Reset added in v1.24.0 

func (x *PollNexusTaskQueueRequest) Reset()

func (*PollNexusTaskQueueRequest) Size added in v1.24.0 

func (val *PollNexusTaskQueueRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PollNexusTaskQueueRequest) String added in v1.24.0 

func (x *PollNexusTaskQueueRequest) String() string

func (*PollNexusTaskQueueRequest) Unmarshal added in v1.24.0 

func (val *PollNexusTaskQueueRequest) Unmarshal(buf []byte) error

Unmarshal an object of type PollNexusTaskQueueRequest from the protobuf v3 wire format

type PollNexusTaskQueueResponse added in v1.24.0 

type PollNexusTaskQueueResponse struct {

	// Response that should be delivered to the worker containing a request from DispatchNexusTaskRequest.
	Response *v1.PollNexusTaskQueueResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*PollNexusTaskQueueResponse) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use PollNexusTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*PollNexusTaskQueueResponse) Equal added in v1.24.0 

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

Equal returns whether two PollNexusTaskQueueResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PollNexusTaskQueueResponse) GetResponse added in v1.24.0 

func (x *PollNexusTaskQueueResponse) GetResponse() *v1.PollNexusTaskQueueResponse

func (*PollNexusTaskQueueResponse) Marshal added in v1.24.0 

func (val *PollNexusTaskQueueResponse) Marshal() ([]byte, error)

Marshal an object of type PollNexusTaskQueueResponse to the protobuf v3 wire format

func (*PollNexusTaskQueueResponse) ProtoMessage added in v1.24.0 

func (*PollNexusTaskQueueResponse) ProtoMessage()

func (*PollNexusTaskQueueResponse) ProtoReflect added in v1.24.0 

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

func (*PollNexusTaskQueueResponse) Reset added in v1.24.0 

func (x *PollNexusTaskQueueResponse) Reset()

func (*PollNexusTaskQueueResponse) Size added in v1.24.0 

func (val *PollNexusTaskQueueResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PollNexusTaskQueueResponse) String added in v1.24.0 

func (x *PollNexusTaskQueueResponse) String() string

func (*PollNexusTaskQueueResponse) Unmarshal added in v1.24.0 

func (val *PollNexusTaskQueueResponse) Unmarshal(buf []byte) error

Unmarshal an object of type PollNexusTaskQueueResponse from the protobuf v3 wire format

type PollWorkflowTaskQueueRequest 

type PollWorkflowTaskQueueRequest struct {
	NamespaceId     string                           `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	PollerId        string                           `protobuf:"bytes,2,opt,name=poller_id,json=pollerId,proto3" json:"poller_id,omitempty"`
	PollRequest     *v1.PollWorkflowTaskQueueRequest `protobuf:"bytes,3,opt,name=poll_request,json=pollRequest,proto3" json:"poll_request,omitempty"`
	ForwardedSource string                           `protobuf:"bytes,4,opt,name=forwarded_source,json=forwardedSource,proto3" json:"forwarded_source,omitempty"`
	// contains filtered or unexported fields
}

func (*PollWorkflowTaskQueueRequest) Descriptor deprecated 

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

Deprecated: Use PollWorkflowTaskQueueRequest.ProtoReflect.Descriptor instead.

func (*PollWorkflowTaskQueueRequest) Equal 

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

Equal returns whether two PollWorkflowTaskQueueRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PollWorkflowTaskQueueRequest) GetForwardedSource added in v0.28.0 

func (x *PollWorkflowTaskQueueRequest) GetForwardedSource() string

func (*PollWorkflowTaskQueueRequest) GetNamespaceId 

func (x *PollWorkflowTaskQueueRequest) GetNamespaceId() string

func (*PollWorkflowTaskQueueRequest) GetPollRequest 

func (x *PollWorkflowTaskQueueRequest) GetPollRequest() *v1.PollWorkflowTaskQueueRequest

func (*PollWorkflowTaskQueueRequest) GetPollerId 

func (x *PollWorkflowTaskQueueRequest) GetPollerId() string

func (*PollWorkflowTaskQueueRequest) Marshal 

func (val *PollWorkflowTaskQueueRequest) Marshal() ([]byte, error)

Marshal an object of type PollWorkflowTaskQueueRequest to the protobuf v3 wire format

func (*PollWorkflowTaskQueueRequest) ProtoMessage 

func (*PollWorkflowTaskQueueRequest) ProtoMessage()

func (*PollWorkflowTaskQueueRequest) ProtoReflect added in v1.23.0 

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

func (*PollWorkflowTaskQueueRequest) Reset 

func (x *PollWorkflowTaskQueueRequest) Reset()

func (*PollWorkflowTaskQueueRequest) Size 

func (val *PollWorkflowTaskQueueRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PollWorkflowTaskQueueRequest) String 

func (x *PollWorkflowTaskQueueRequest) String() string

func (*PollWorkflowTaskQueueRequest) Unmarshal 

func (val *PollWorkflowTaskQueueRequest) Unmarshal(buf []byte) error

Unmarshal an object of type PollWorkflowTaskQueueRequest from the protobuf v3 wire format

type PollWorkflowTaskQueueResponse 

type PollWorkflowTaskQueueResponse struct {
	TaskToken                  []byte                         `protobuf:"bytes,1,opt,name=task_token,json=taskToken,proto3" json:"task_token,omitempty"`
	WorkflowExecution          *v11.WorkflowExecution         `protobuf:"bytes,2,opt,name=workflow_execution,json=workflowExecution,proto3" json:"workflow_execution,omitempty"`
	WorkflowType               *v11.WorkflowType              `protobuf:"bytes,3,opt,name=workflow_type,json=workflowType,proto3" json:"workflow_type,omitempty"`
	PreviousStartedEventId     int64                          `` /* 132-byte string literal not displayed */
	StartedEventId             int64                          `protobuf:"varint,5,opt,name=started_event_id,json=startedEventId,proto3" json:"started_event_id,omitempty"`
	Attempt                    int32                          `protobuf:"varint,6,opt,name=attempt,proto3" json:"attempt,omitempty"`
	NextEventId                int64                          `protobuf:"varint,7,opt,name=next_event_id,json=nextEventId,proto3" json:"next_event_id,omitempty"`
	BacklogCountHint           int64                          `protobuf:"varint,8,opt,name=backlog_count_hint,json=backlogCountHint,proto3" json:"backlog_count_hint,omitempty"`
	StickyExecutionEnabled     bool                           `` /* 130-byte string literal not displayed */
	Query                      *v12.WorkflowQuery             `protobuf:"bytes,10,opt,name=query,proto3" json:"query,omitempty"`
	TransientWorkflowTask      *v13.TransientWorkflowTaskInfo `` /* 127-byte string literal not displayed */
	WorkflowExecutionTaskQueue *v14.TaskQueue                 `` /* 144-byte string literal not displayed */
	BranchToken                []byte                         `protobuf:"bytes,14,opt,name=branch_token,json=branchToken,proto3" json:"branch_token,omitempty"`
	ScheduledTime              *timestamppb.Timestamp         `protobuf:"bytes,15,opt,name=scheduled_time,json=scheduledTime,proto3" json:"scheduled_time,omitempty"`
	StartedTime                *timestamppb.Timestamp         `protobuf:"bytes,16,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"`
	Queries                    map[string]*v12.WorkflowQuery  `` /* 156-byte string literal not displayed */
	Messages                   []*v15.Message                 `protobuf:"bytes,18,rep,name=messages,proto3" json:"messages,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. Sticky query tasks will not include any history.
	History       *v16.History `protobuf:"bytes,19,opt,name=history,proto3" json:"history,omitempty"`
	NextPageToken []byte       `protobuf:"bytes,20,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*PollWorkflowTaskQueueResponse) Descriptor deprecated 

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

Deprecated: Use PollWorkflowTaskQueueResponse.ProtoReflect.Descriptor instead.

func (*PollWorkflowTaskQueueResponse) Equal 

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

Equal returns whether two PollWorkflowTaskQueueResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*PollWorkflowTaskQueueResponse) GetAttempt 

func (x *PollWorkflowTaskQueueResponse) GetAttempt() int32

func (*PollWorkflowTaskQueueResponse) GetBacklogCountHint 

func (x *PollWorkflowTaskQueueResponse) GetBacklogCountHint() int64

func (*PollWorkflowTaskQueueResponse) GetBranchToken 

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

func (*PollWorkflowTaskQueueResponse) GetHistory added in v1.23.0 

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

func (*PollWorkflowTaskQueueResponse) GetMessages added in v1.20.0 

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

func (*PollWorkflowTaskQueueResponse) GetNextEventId 

func (x *PollWorkflowTaskQueueResponse) GetNextEventId() int64

func (*PollWorkflowTaskQueueResponse) GetNextPageToken added in v1.23.0 

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

func (*PollWorkflowTaskQueueResponse) GetPreviousStartedEventId 

func (x *PollWorkflowTaskQueueResponse) GetPreviousStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetQueries 

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

func (*PollWorkflowTaskQueueResponse) GetQuery 

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

func (*PollWorkflowTaskQueueResponse) GetScheduledTime added in v0.28.0 

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

func (*PollWorkflowTaskQueueResponse) GetStartedEventId 

func (x *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetStartedTime added in v0.28.0 

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

func (*PollWorkflowTaskQueueResponse) GetStickyExecutionEnabled 

func (x *PollWorkflowTaskQueueResponse) GetStickyExecutionEnabled() bool

func (*PollWorkflowTaskQueueResponse) GetTaskToken 

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

func (*PollWorkflowTaskQueueResponse) GetTransientWorkflowTask added in v1.17.3 

func (x *PollWorkflowTaskQueueResponse) GetTransientWorkflowTask() *v13.TransientWorkflowTaskInfo

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecution 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowType 

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

func (*PollWorkflowTaskQueueResponse) Marshal 

func (val *PollWorkflowTaskQueueResponse) Marshal() ([]byte, error)

Marshal an object of type PollWorkflowTaskQueueResponse to the protobuf v3 wire format

func (*PollWorkflowTaskQueueResponse) ProtoMessage 

func (*PollWorkflowTaskQueueResponse) ProtoMessage()

func (*PollWorkflowTaskQueueResponse) ProtoReflect added in v1.23.0 

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

func (*PollWorkflowTaskQueueResponse) Reset 

func (x *PollWorkflowTaskQueueResponse) Reset()

func (*PollWorkflowTaskQueueResponse) Size 

func (val *PollWorkflowTaskQueueResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*PollWorkflowTaskQueueResponse) String 

func (x *PollWorkflowTaskQueueResponse) String() string

func (*PollWorkflowTaskQueueResponse) Unmarshal 

func (val *PollWorkflowTaskQueueResponse) Unmarshal(buf []byte) error

Unmarshal an object of type PollWorkflowTaskQueueResponse from the protobuf v3 wire format

type QueryWorkflowRequest 

type QueryWorkflowRequest struct {
	NamespaceId  string                   `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue    *v14.TaskQueue           `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	QueryRequest *v1.QueryWorkflowRequest `protobuf:"bytes,3,opt,name=query_request,json=queryRequest,proto3" json:"query_request,omitempty"`
	// How this task should be directed by matching. (Missing means the default
	// for TaskVersionDirective, which is unversioned.)
	VersionDirective *v18.TaskVersionDirective `protobuf:"bytes,5,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,omitempty"`
	ForwardInfo      *v18.TaskForwardInfo      `protobuf:"bytes,6,opt,name=forward_info,json=forwardInfo,proto3" json:"forward_info,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use QueryWorkflowRequest.ProtoReflect.Descriptor instead.

func (*QueryWorkflowRequest) Equal 

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

Equal returns whether two QueryWorkflowRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueryWorkflowRequest) GetForwardInfo added in v1.25.0 

func (x *QueryWorkflowRequest) GetForwardInfo() *v18.TaskForwardInfo

func (*QueryWorkflowRequest) GetNamespaceId 

func (x *QueryWorkflowRequest) GetNamespaceId() string

func (*QueryWorkflowRequest) GetQueryRequest 

func (x *QueryWorkflowRequest) GetQueryRequest() *v1.QueryWorkflowRequest

func (*QueryWorkflowRequest) GetTaskQueue 

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

func (*QueryWorkflowRequest) GetVersionDirective added in v1.21.0 

func (x *QueryWorkflowRequest) GetVersionDirective() *v18.TaskVersionDirective

func (*QueryWorkflowRequest) Marshal 

func (val *QueryWorkflowRequest) Marshal() ([]byte, error)

Marshal an object of type QueryWorkflowRequest to the protobuf v3 wire format

func (*QueryWorkflowRequest) ProtoMessage 

func (*QueryWorkflowRequest) ProtoMessage()

func (*QueryWorkflowRequest) ProtoReflect added in v1.23.0 

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

func (*QueryWorkflowRequest) Reset 

func (x *QueryWorkflowRequest) Reset()

func (*QueryWorkflowRequest) Size 

func (val *QueryWorkflowRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueryWorkflowRequest) String 

func (x *QueryWorkflowRequest) String() string

func (*QueryWorkflowRequest) Unmarshal 

func (val *QueryWorkflowRequest) Unmarshal(buf []byte) error

Unmarshal an object of type QueryWorkflowRequest from the protobuf v3 wire format

type QueryWorkflowResponse 

type QueryWorkflowResponse struct {
	QueryResult   *v11.Payloads      `protobuf:"bytes,1,opt,name=query_result,json=queryResult,proto3" json:"query_result,omitempty"`
	QueryRejected *v12.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) Equal 

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

Equal returns whether two QueryWorkflowResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*QueryWorkflowResponse) GetQueryRejected 

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

func (*QueryWorkflowResponse) GetQueryResult 

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

func (*QueryWorkflowResponse) Marshal 

func (val *QueryWorkflowResponse) Marshal() ([]byte, error)

Marshal an object of type QueryWorkflowResponse to the protobuf v3 wire format

func (*QueryWorkflowResponse) ProtoMessage 

func (*QueryWorkflowResponse) ProtoMessage()

func (*QueryWorkflowResponse) ProtoReflect added in v1.23.0 

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

func (*QueryWorkflowResponse) Reset 

func (x *QueryWorkflowResponse) Reset()

func (*QueryWorkflowResponse) Size 

func (val *QueryWorkflowResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*QueryWorkflowResponse) String 

func (x *QueryWorkflowResponse) String() string

func (*QueryWorkflowResponse) Unmarshal 

func (val *QueryWorkflowResponse) Unmarshal(buf []byte) error

Unmarshal an object of type QueryWorkflowResponse from the protobuf v3 wire format

type ReplicateTaskQueueUserDataRequest added in v1.21.0 

type ReplicateTaskQueueUserDataRequest struct {
	NamespaceId string                  `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   string                  `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	UserData    *v110.TaskQueueUserData `protobuf:"bytes,3,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplicateTaskQueueUserDataRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use ReplicateTaskQueueUserDataRequest.ProtoReflect.Descriptor instead.

func (*ReplicateTaskQueueUserDataRequest) Equal added in v1.21.0 

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

Equal returns whether two ReplicateTaskQueueUserDataRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ReplicateTaskQueueUserDataRequest) GetNamespaceId added in v1.21.0 

func (x *ReplicateTaskQueueUserDataRequest) GetNamespaceId() string

func (*ReplicateTaskQueueUserDataRequest) GetTaskQueue added in v1.21.0 

func (x *ReplicateTaskQueueUserDataRequest) GetTaskQueue() string

func (*ReplicateTaskQueueUserDataRequest) GetUserData added in v1.21.0 

func (x *ReplicateTaskQueueUserDataRequest) GetUserData() *v110.TaskQueueUserData

func (*ReplicateTaskQueueUserDataRequest) Marshal added in v1.21.0 

func (val *ReplicateTaskQueueUserDataRequest) Marshal() ([]byte, error)

Marshal an object of type ReplicateTaskQueueUserDataRequest to the protobuf v3 wire format

func (*ReplicateTaskQueueUserDataRequest) ProtoMessage added in v1.21.0 

func (*ReplicateTaskQueueUserDataRequest) ProtoMessage()

func (*ReplicateTaskQueueUserDataRequest) ProtoReflect added in v1.23.0 

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

func (*ReplicateTaskQueueUserDataRequest) Reset added in v1.21.0 

func (x *ReplicateTaskQueueUserDataRequest) Reset()

func (*ReplicateTaskQueueUserDataRequest) Size added in v1.21.0 

func (val *ReplicateTaskQueueUserDataRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ReplicateTaskQueueUserDataRequest) String added in v1.21.0 

func (x *ReplicateTaskQueueUserDataRequest) String() string

func (*ReplicateTaskQueueUserDataRequest) Unmarshal added in v1.21.0 

func (val *ReplicateTaskQueueUserDataRequest) Unmarshal(buf []byte) error

Unmarshal an object of type ReplicateTaskQueueUserDataRequest from the protobuf v3 wire format

type ReplicateTaskQueueUserDataResponse added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use ReplicateTaskQueueUserDataResponse.ProtoReflect.Descriptor instead.

func (*ReplicateTaskQueueUserDataResponse) Equal added in v1.21.0 

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

Equal returns whether two ReplicateTaskQueueUserDataResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*ReplicateTaskQueueUserDataResponse) Marshal added in v1.21.0 

func (val *ReplicateTaskQueueUserDataResponse) Marshal() ([]byte, error)

Marshal an object of type ReplicateTaskQueueUserDataResponse to the protobuf v3 wire format

func (*ReplicateTaskQueueUserDataResponse) ProtoMessage added in v1.21.0 

func (*ReplicateTaskQueueUserDataResponse) ProtoMessage()

func (*ReplicateTaskQueueUserDataResponse) ProtoReflect added in v1.23.0 

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

func (*ReplicateTaskQueueUserDataResponse) Reset added in v1.21.0 

func (x *ReplicateTaskQueueUserDataResponse) Reset()

func (*ReplicateTaskQueueUserDataResponse) Size added in v1.21.0 

func (val *ReplicateTaskQueueUserDataResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*ReplicateTaskQueueUserDataResponse) String added in v1.21.0 

func (x *ReplicateTaskQueueUserDataResponse) String() string

func (*ReplicateTaskQueueUserDataResponse) Unmarshal added in v1.21.0 

func (val *ReplicateTaskQueueUserDataResponse) Unmarshal(buf []byte) error

Unmarshal an object of type ReplicateTaskQueueUserDataResponse from the protobuf v3 wire format

type RespondNexusTaskCompletedRequest added in v1.24.0 

type RespondNexusTaskCompletedRequest struct {
	NamespaceId string         `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   *v14.TaskQueue `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// A unique ID for this task generated by the matching engine. Decoded from the incoming request's task token.
	TaskId string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Original completion as received by the frontend.
	Request *v1.RespondNexusTaskCompletedRequest `protobuf:"bytes,4,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondNexusTaskCompletedRequest) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use RespondNexusTaskCompletedRequest.ProtoReflect.Descriptor instead.

func (*RespondNexusTaskCompletedRequest) Equal added in v1.24.0 

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

Equal returns whether two RespondNexusTaskCompletedRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RespondNexusTaskCompletedRequest) GetNamespaceId added in v1.24.0 

func (x *RespondNexusTaskCompletedRequest) GetNamespaceId() string

func (*RespondNexusTaskCompletedRequest) GetRequest added in v1.24.0 

func (x *RespondNexusTaskCompletedRequest) GetRequest() *v1.RespondNexusTaskCompletedRequest

func (*RespondNexusTaskCompletedRequest) GetTaskId added in v1.24.0 

func (x *RespondNexusTaskCompletedRequest) GetTaskId() string

func (*RespondNexusTaskCompletedRequest) GetTaskQueue added in v1.24.0 

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

func (*RespondNexusTaskCompletedRequest) Marshal added in v1.24.0 

func (val *RespondNexusTaskCompletedRequest) Marshal() ([]byte, error)

Marshal an object of type RespondNexusTaskCompletedRequest to the protobuf v3 wire format

func (*RespondNexusTaskCompletedRequest) ProtoMessage added in v1.24.0 

func (*RespondNexusTaskCompletedRequest) ProtoMessage()

func (*RespondNexusTaskCompletedRequest) ProtoReflect added in v1.24.0 

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

func (*RespondNexusTaskCompletedRequest) Reset added in v1.24.0 

func (x *RespondNexusTaskCompletedRequest) Reset()

func (*RespondNexusTaskCompletedRequest) Size added in v1.24.0 

func (val *RespondNexusTaskCompletedRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RespondNexusTaskCompletedRequest) String added in v1.24.0 

func (x *RespondNexusTaskCompletedRequest) String() string

func (*RespondNexusTaskCompletedRequest) Unmarshal added in v1.24.0 

func (val *RespondNexusTaskCompletedRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RespondNexusTaskCompletedRequest from the protobuf v3 wire format

type RespondNexusTaskCompletedResponse added in v1.24.0 

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

func (*RespondNexusTaskCompletedResponse) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use RespondNexusTaskCompletedResponse.ProtoReflect.Descriptor instead.

func (*RespondNexusTaskCompletedResponse) Equal added in v1.24.0 

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

Equal returns whether two RespondNexusTaskCompletedResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RespondNexusTaskCompletedResponse) Marshal added in v1.24.0 

func (val *RespondNexusTaskCompletedResponse) Marshal() ([]byte, error)

Marshal an object of type RespondNexusTaskCompletedResponse to the protobuf v3 wire format

func (*RespondNexusTaskCompletedResponse) ProtoMessage added in v1.24.0 

func (*RespondNexusTaskCompletedResponse) ProtoMessage()

func (*RespondNexusTaskCompletedResponse) ProtoReflect added in v1.24.0 

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

func (*RespondNexusTaskCompletedResponse) Reset added in v1.24.0 

func (x *RespondNexusTaskCompletedResponse) Reset()

func (*RespondNexusTaskCompletedResponse) Size added in v1.24.0 

func (val *RespondNexusTaskCompletedResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RespondNexusTaskCompletedResponse) String added in v1.24.0 

func (x *RespondNexusTaskCompletedResponse) String() string

func (*RespondNexusTaskCompletedResponse) Unmarshal added in v1.24.0 

func (val *RespondNexusTaskCompletedResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RespondNexusTaskCompletedResponse from the protobuf v3 wire format

type RespondNexusTaskFailedRequest added in v1.24.0 

type RespondNexusTaskFailedRequest struct {
	NamespaceId string         `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   *v14.TaskQueue `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// A unique ID for this task generated by the matching engine. Decoded from the incoming request's task token.
	TaskId string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Original failure as received by the frontend.
	Request *v1.RespondNexusTaskFailedRequest `protobuf:"bytes,4,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondNexusTaskFailedRequest) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use RespondNexusTaskFailedRequest.ProtoReflect.Descriptor instead.

func (*RespondNexusTaskFailedRequest) Equal added in v1.24.0 

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

Equal returns whether two RespondNexusTaskFailedRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RespondNexusTaskFailedRequest) GetNamespaceId added in v1.24.0 

func (x *RespondNexusTaskFailedRequest) GetNamespaceId() string

func (*RespondNexusTaskFailedRequest) GetRequest added in v1.24.0 

func (x *RespondNexusTaskFailedRequest) GetRequest() *v1.RespondNexusTaskFailedRequest

func (*RespondNexusTaskFailedRequest) GetTaskId added in v1.24.0 

func (x *RespondNexusTaskFailedRequest) GetTaskId() string

func (*RespondNexusTaskFailedRequest) GetTaskQueue added in v1.24.0 

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

func (*RespondNexusTaskFailedRequest) Marshal added in v1.24.0 

func (val *RespondNexusTaskFailedRequest) Marshal() ([]byte, error)

Marshal an object of type RespondNexusTaskFailedRequest to the protobuf v3 wire format

func (*RespondNexusTaskFailedRequest) ProtoMessage added in v1.24.0 

func (*RespondNexusTaskFailedRequest) ProtoMessage()

func (*RespondNexusTaskFailedRequest) ProtoReflect added in v1.24.0 

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

func (*RespondNexusTaskFailedRequest) Reset added in v1.24.0 

func (x *RespondNexusTaskFailedRequest) Reset()

func (*RespondNexusTaskFailedRequest) Size added in v1.24.0 

func (val *RespondNexusTaskFailedRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RespondNexusTaskFailedRequest) String added in v1.24.0 

func (x *RespondNexusTaskFailedRequest) String() string

func (*RespondNexusTaskFailedRequest) Unmarshal added in v1.24.0 

func (val *RespondNexusTaskFailedRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RespondNexusTaskFailedRequest from the protobuf v3 wire format

type RespondNexusTaskFailedResponse added in v1.24.0 

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

func (*RespondNexusTaskFailedResponse) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use RespondNexusTaskFailedResponse.ProtoReflect.Descriptor instead.

func (*RespondNexusTaskFailedResponse) Equal added in v1.24.0 

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

Equal returns whether two RespondNexusTaskFailedResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RespondNexusTaskFailedResponse) Marshal added in v1.24.0 

func (val *RespondNexusTaskFailedResponse) Marshal() ([]byte, error)

Marshal an object of type RespondNexusTaskFailedResponse to the protobuf v3 wire format

func (*RespondNexusTaskFailedResponse) ProtoMessage added in v1.24.0 

func (*RespondNexusTaskFailedResponse) ProtoMessage()

func (*RespondNexusTaskFailedResponse) ProtoReflect added in v1.24.0 

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

func (*RespondNexusTaskFailedResponse) Reset added in v1.24.0 

func (x *RespondNexusTaskFailedResponse) Reset()

func (*RespondNexusTaskFailedResponse) Size added in v1.24.0 

func (val *RespondNexusTaskFailedResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RespondNexusTaskFailedResponse) String added in v1.24.0 

func (x *RespondNexusTaskFailedResponse) String() string

func (*RespondNexusTaskFailedResponse) Unmarshal added in v1.24.0 

func (val *RespondNexusTaskFailedResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RespondNexusTaskFailedResponse from the protobuf v3 wire format

type RespondQueryTaskCompletedRequest 

type RespondQueryTaskCompletedRequest struct {
	NamespaceId      string                               `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue        *v14.TaskQueue                       `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	TaskId           string                               `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	CompletedRequest *v1.RespondQueryTaskCompletedRequest `protobuf:"bytes,4,opt,name=completed_request,json=completedRequest,proto3" json:"completed_request,omitempty"`
	// contains filtered or unexported fields
}

func (*RespondQueryTaskCompletedRequest) Descriptor deprecated 

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

Deprecated: Use RespondQueryTaskCompletedRequest.ProtoReflect.Descriptor instead.

func (*RespondQueryTaskCompletedRequest) Equal 

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

Equal returns whether two RespondQueryTaskCompletedRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RespondQueryTaskCompletedRequest) GetCompletedRequest 

func (x *RespondQueryTaskCompletedRequest) GetCompletedRequest() *v1.RespondQueryTaskCompletedRequest

func (*RespondQueryTaskCompletedRequest) GetNamespaceId 

func (x *RespondQueryTaskCompletedRequest) GetNamespaceId() string

func (*RespondQueryTaskCompletedRequest) GetTaskId 

func (x *RespondQueryTaskCompletedRequest) GetTaskId() string

func (*RespondQueryTaskCompletedRequest) GetTaskQueue 

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

func (*RespondQueryTaskCompletedRequest) Marshal 

func (val *RespondQueryTaskCompletedRequest) Marshal() ([]byte, error)

Marshal an object of type RespondQueryTaskCompletedRequest to the protobuf v3 wire format

func (*RespondQueryTaskCompletedRequest) ProtoMessage 

func (*RespondQueryTaskCompletedRequest) ProtoMessage()

func (*RespondQueryTaskCompletedRequest) ProtoReflect added in v1.23.0 

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

func (*RespondQueryTaskCompletedRequest) Reset 

func (x *RespondQueryTaskCompletedRequest) Reset()

func (*RespondQueryTaskCompletedRequest) Size 

func (val *RespondQueryTaskCompletedRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RespondQueryTaskCompletedRequest) String 

func (x *RespondQueryTaskCompletedRequest) String() string

func (*RespondQueryTaskCompletedRequest) Unmarshal 

func (val *RespondQueryTaskCompletedRequest) Unmarshal(buf []byte) error

Unmarshal an object of type RespondQueryTaskCompletedRequest from the protobuf v3 wire format

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

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

Equal returns whether two RespondQueryTaskCompletedResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*RespondQueryTaskCompletedResponse) Marshal 

func (val *RespondQueryTaskCompletedResponse) Marshal() ([]byte, error)

Marshal an object of type RespondQueryTaskCompletedResponse to the protobuf v3 wire format

func (*RespondQueryTaskCompletedResponse) ProtoMessage 

func (*RespondQueryTaskCompletedResponse) ProtoMessage()

func (*RespondQueryTaskCompletedResponse) ProtoReflect added in v1.23.0 

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

func (*RespondQueryTaskCompletedResponse) Reset 

func (x *RespondQueryTaskCompletedResponse) Reset()

func (*RespondQueryTaskCompletedResponse) Size 

func (val *RespondQueryTaskCompletedResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*RespondQueryTaskCompletedResponse) String 

func (x *RespondQueryTaskCompletedResponse) String() string

func (*RespondQueryTaskCompletedResponse) Unmarshal 

func (val *RespondQueryTaskCompletedResponse) Unmarshal(buf []byte) error

Unmarshal an object of type RespondQueryTaskCompletedResponse from the protobuf v3 wire format

type UnimplementedMatchingServiceServer 

type UnimplementedMatchingServiceServer struct {
}

UnimplementedMatchingServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMatchingServiceServer) AddActivityTask 

func (UnimplementedMatchingServiceServer) AddActivityTask(context.Context, *AddActivityTaskRequest) (*AddActivityTaskResponse, error)

func (UnimplementedMatchingServiceServer) AddWorkflowTask 

func (UnimplementedMatchingServiceServer) AddWorkflowTask(context.Context, *AddWorkflowTaskRequest) (*AddWorkflowTaskResponse, error)

func (UnimplementedMatchingServiceServer) ApplyTaskQueueUserDataReplicationEvent added in v1.21.0 

func (UnimplementedMatchingServiceServer) ApplyTaskQueueUserDataReplicationEvent(context.Context, *ApplyTaskQueueUserDataReplicationEventRequest) (*ApplyTaskQueueUserDataReplicationEventResponse, error)

func (UnimplementedMatchingServiceServer) CancelOutstandingPoll 

func (UnimplementedMatchingServiceServer) CancelOutstandingPoll(context.Context, *CancelOutstandingPollRequest) (*CancelOutstandingPollResponse, error)

func (UnimplementedMatchingServiceServer) CreateNexusEndpoint added in v1.25.0 

func (UnimplementedMatchingServiceServer) CreateNexusEndpoint(context.Context, *CreateNexusEndpointRequest) (*CreateNexusEndpointResponse, error)

func (UnimplementedMatchingServiceServer) DeleteNexusEndpoint added in v1.25.0 

func (UnimplementedMatchingServiceServer) DeleteNexusEndpoint(context.Context, *DeleteNexusEndpointRequest) (*DeleteNexusEndpointResponse, error)

func (UnimplementedMatchingServiceServer) DescribeTaskQueue 

func (UnimplementedMatchingServiceServer) DescribeTaskQueue(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, error)

func (UnimplementedMatchingServiceServer) DescribeTaskQueuePartition added in v1.24.0 

func (UnimplementedMatchingServiceServer) DescribeTaskQueuePartition(context.Context, *DescribeTaskQueuePartitionRequest) (*DescribeTaskQueuePartitionResponse, error)

func (UnimplementedMatchingServiceServer) DispatchNexusTask added in v1.24.0 

func (UnimplementedMatchingServiceServer) DispatchNexusTask(context.Context, *DispatchNexusTaskRequest) (*DispatchNexusTaskResponse, error)

func (UnimplementedMatchingServiceServer) ForceUnloadTaskQueue added in v1.21.0 

func (UnimplementedMatchingServiceServer) ForceUnloadTaskQueue(context.Context, *ForceUnloadTaskQueueRequest) (*ForceUnloadTaskQueueResponse, error)

func (UnimplementedMatchingServiceServer) GetBuildIdTaskQueueMapping added in v1.21.0 

func (UnimplementedMatchingServiceServer) GetBuildIdTaskQueueMapping(context.Context, *GetBuildIdTaskQueueMappingRequest) (*GetBuildIdTaskQueueMappingResponse, error)

func (UnimplementedMatchingServiceServer) GetTaskQueueUserData added in v1.21.0 

func (UnimplementedMatchingServiceServer) GetTaskQueueUserData(context.Context, *GetTaskQueueUserDataRequest) (*GetTaskQueueUserDataResponse, error)

func (UnimplementedMatchingServiceServer) GetWorkerBuildIdCompatibility added in v1.21.0 

func (UnimplementedMatchingServiceServer) GetWorkerBuildIdCompatibility(context.Context, *GetWorkerBuildIdCompatibilityRequest) (*GetWorkerBuildIdCompatibilityResponse, error)

func (UnimplementedMatchingServiceServer) GetWorkerVersioningRules added in v1.24.0 

func (UnimplementedMatchingServiceServer) GetWorkerVersioningRules(context.Context, *GetWorkerVersioningRulesRequest) (*GetWorkerVersioningRulesResponse, error)

func (UnimplementedMatchingServiceServer) ListNexusEndpoints added in v1.25.0 

func (UnimplementedMatchingServiceServer) ListNexusEndpoints(context.Context, *ListNexusEndpointsRequest) (*ListNexusEndpointsResponse, error)

func (UnimplementedMatchingServiceServer) ListTaskQueuePartitions 

func (UnimplementedMatchingServiceServer) ListTaskQueuePartitions(context.Context, *ListTaskQueuePartitionsRequest) (*ListTaskQueuePartitionsResponse, error)

func (UnimplementedMatchingServiceServer) PollActivityTaskQueue 

func (UnimplementedMatchingServiceServer) PollActivityTaskQueue(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, error)

func (UnimplementedMatchingServiceServer) PollNexusTaskQueue added in v1.24.0 

func (UnimplementedMatchingServiceServer) PollNexusTaskQueue(context.Context, *PollNexusTaskQueueRequest) (*PollNexusTaskQueueResponse, error)

func (UnimplementedMatchingServiceServer) PollWorkflowTaskQueue 

func (UnimplementedMatchingServiceServer) PollWorkflowTaskQueue(context.Context, *PollWorkflowTaskQueueRequest) (*PollWorkflowTaskQueueResponse, error)

func (UnimplementedMatchingServiceServer) QueryWorkflow 

func (UnimplementedMatchingServiceServer) QueryWorkflow(context.Context, *QueryWorkflowRequest) (*QueryWorkflowResponse, error)

func (UnimplementedMatchingServiceServer) ReplicateTaskQueueUserData added in v1.21.0 

func (UnimplementedMatchingServiceServer) ReplicateTaskQueueUserData(context.Context, *ReplicateTaskQueueUserDataRequest) (*ReplicateTaskQueueUserDataResponse, error)

func (UnimplementedMatchingServiceServer) RespondNexusTaskCompleted added in v1.24.0 

func (UnimplementedMatchingServiceServer) RespondNexusTaskCompleted(context.Context, *RespondNexusTaskCompletedRequest) (*RespondNexusTaskCompletedResponse, error)

func (UnimplementedMatchingServiceServer) RespondNexusTaskFailed added in v1.24.0 

func (UnimplementedMatchingServiceServer) RespondNexusTaskFailed(context.Context, *RespondNexusTaskFailedRequest) (*RespondNexusTaskFailedResponse, error)

func (UnimplementedMatchingServiceServer) RespondQueryTaskCompleted 

func (UnimplementedMatchingServiceServer) RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, error)

func (UnimplementedMatchingServiceServer) UpdateNexusEndpoint added in v1.25.0 

func (UnimplementedMatchingServiceServer) UpdateNexusEndpoint(context.Context, *UpdateNexusEndpointRequest) (*UpdateNexusEndpointResponse, error)

func (UnimplementedMatchingServiceServer) UpdateTaskQueueUserData added in v1.21.0 

func (UnimplementedMatchingServiceServer) UpdateTaskQueueUserData(context.Context, *UpdateTaskQueueUserDataRequest) (*UpdateTaskQueueUserDataResponse, error)

func (UnimplementedMatchingServiceServer) UpdateWorkerBuildIdCompatibility added in v1.21.0 

func (UnimplementedMatchingServiceServer) UpdateWorkerBuildIdCompatibility(context.Context, *UpdateWorkerBuildIdCompatibilityRequest) (*UpdateWorkerBuildIdCompatibilityResponse, error)

func (UnimplementedMatchingServiceServer) UpdateWorkerVersioningRules added in v1.24.0 

func (UnimplementedMatchingServiceServer) UpdateWorkerVersioningRules(context.Context, *UpdateWorkerVersioningRulesRequest) (*UpdateWorkerVersioningRulesResponse, error)

type UnsafeMatchingServiceServer added in v1.23.0 

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

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

type UpdateNexusEndpointRequest added in v1.25.0 

type UpdateNexusEndpointRequest struct {

	// ID of the endpoint to update.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Version of the endpoint, used for optimistic concurrency. Must match current version in persistence or the
	// request will fail a FAILED_PRECONDITION error.
	Version int64                   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Spec    *v110.NexusEndpointSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

func (*UpdateNexusEndpointRequest) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use UpdateNexusEndpointRequest.ProtoReflect.Descriptor instead.

func (*UpdateNexusEndpointRequest) Equal added in v1.25.0 

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

Equal returns whether two UpdateNexusEndpointRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateNexusEndpointRequest) GetId added in v1.25.0 

func (x *UpdateNexusEndpointRequest) GetId() string

func (*UpdateNexusEndpointRequest) GetSpec added in v1.25.0 

func (x *UpdateNexusEndpointRequest) GetSpec() *v110.NexusEndpointSpec

func (*UpdateNexusEndpointRequest) GetVersion added in v1.25.0 

func (x *UpdateNexusEndpointRequest) GetVersion() int64

func (*UpdateNexusEndpointRequest) Marshal added in v1.25.0 

func (val *UpdateNexusEndpointRequest) Marshal() ([]byte, error)

Marshal an object of type UpdateNexusEndpointRequest to the protobuf v3 wire format

func (*UpdateNexusEndpointRequest) ProtoMessage added in v1.25.0 

func (*UpdateNexusEndpointRequest) ProtoMessage()

func (*UpdateNexusEndpointRequest) ProtoReflect added in v1.25.0 

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

func (*UpdateNexusEndpointRequest) Reset added in v1.25.0 

func (x *UpdateNexusEndpointRequest) Reset()

func (*UpdateNexusEndpointRequest) Size added in v1.25.0 

func (val *UpdateNexusEndpointRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateNexusEndpointRequest) String added in v1.25.0 

func (x *UpdateNexusEndpointRequest) String() string

func (*UpdateNexusEndpointRequest) Unmarshal added in v1.25.0 

func (val *UpdateNexusEndpointRequest) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateNexusEndpointRequest from the protobuf v3 wire format

type UpdateNexusEndpointResponse added in v1.25.0 

type UpdateNexusEndpointResponse struct {
	Entry *v110.NexusEndpointEntry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateNexusEndpointResponse) Descriptor deprecated added in v1.25.0 

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

Deprecated: Use UpdateNexusEndpointResponse.ProtoReflect.Descriptor instead.

func (*UpdateNexusEndpointResponse) Equal added in v1.25.0 

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

Equal returns whether two UpdateNexusEndpointResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateNexusEndpointResponse) GetEntry added in v1.25.0 

func (x *UpdateNexusEndpointResponse) GetEntry() *v110.NexusEndpointEntry

func (*UpdateNexusEndpointResponse) Marshal added in v1.25.0 

func (val *UpdateNexusEndpointResponse) Marshal() ([]byte, error)

Marshal an object of type UpdateNexusEndpointResponse to the protobuf v3 wire format

func (*UpdateNexusEndpointResponse) ProtoMessage added in v1.25.0 

func (*UpdateNexusEndpointResponse) ProtoMessage()

func (*UpdateNexusEndpointResponse) ProtoReflect added in v1.25.0 

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

func (*UpdateNexusEndpointResponse) Reset added in v1.25.0 

func (x *UpdateNexusEndpointResponse) Reset()

func (*UpdateNexusEndpointResponse) Size added in v1.25.0 

func (val *UpdateNexusEndpointResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateNexusEndpointResponse) String added in v1.25.0 

func (x *UpdateNexusEndpointResponse) String() string

func (*UpdateNexusEndpointResponse) Unmarshal added in v1.25.0 

func (val *UpdateNexusEndpointResponse) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateNexusEndpointResponse from the protobuf v3 wire format

type UpdateTaskQueueUserDataRequest added in v1.21.0 

type UpdateTaskQueueUserDataRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Versioned user data, set if the task queue has user data and the request's last_known_user_data_version is less
	// than the version cached in the root partition.
	UserData *v110.VersionedTaskQueueUserData `protobuf:"bytes,3,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
	// List of added build ids
	BuildIdsAdded []string `protobuf:"bytes,4,rep,name=build_ids_added,json=buildIdsAdded,proto3" json:"build_ids_added,omitempty"`
	// List of removed build ids
	BuildIdsRemoved []string `protobuf:"bytes,5,rep,name=build_ids_removed,json=buildIdsRemoved,proto3" json:"build_ids_removed,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

func (*UpdateTaskQueueUserDataRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use UpdateTaskQueueUserDataRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskQueueUserDataRequest) Equal added in v1.21.0 

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

Equal returns whether two UpdateTaskQueueUserDataRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateTaskQueueUserDataRequest) GetBuildIdsAdded added in v1.21.0 

func (x *UpdateTaskQueueUserDataRequest) GetBuildIdsAdded() []string

func (*UpdateTaskQueueUserDataRequest) GetBuildIdsRemoved added in v1.21.0 

func (x *UpdateTaskQueueUserDataRequest) GetBuildIdsRemoved() []string

func (*UpdateTaskQueueUserDataRequest) GetNamespaceId added in v1.21.0 

func (x *UpdateTaskQueueUserDataRequest) GetNamespaceId() string

func (*UpdateTaskQueueUserDataRequest) GetTaskQueue added in v1.21.0 

func (x *UpdateTaskQueueUserDataRequest) GetTaskQueue() string

func (*UpdateTaskQueueUserDataRequest) GetUserData added in v1.21.0 

func (x *UpdateTaskQueueUserDataRequest) GetUserData() *v110.VersionedTaskQueueUserData

func (*UpdateTaskQueueUserDataRequest) Marshal added in v1.21.0 

func (val *UpdateTaskQueueUserDataRequest) Marshal() ([]byte, error)

Marshal an object of type UpdateTaskQueueUserDataRequest to the protobuf v3 wire format

func (*UpdateTaskQueueUserDataRequest) ProtoMessage added in v1.21.0 

func (*UpdateTaskQueueUserDataRequest) ProtoMessage()

func (*UpdateTaskQueueUserDataRequest) ProtoReflect added in v1.23.0 

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

func (*UpdateTaskQueueUserDataRequest) Reset added in v1.21.0 

func (x *UpdateTaskQueueUserDataRequest) Reset()

func (*UpdateTaskQueueUserDataRequest) Size added in v1.21.0 

func (val *UpdateTaskQueueUserDataRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateTaskQueueUserDataRequest) String added in v1.21.0 

func (x *UpdateTaskQueueUserDataRequest) String() string

func (*UpdateTaskQueueUserDataRequest) Unmarshal added in v1.21.0 

func (val *UpdateTaskQueueUserDataRequest) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateTaskQueueUserDataRequest from the protobuf v3 wire format

type UpdateTaskQueueUserDataResponse added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use UpdateTaskQueueUserDataResponse.ProtoReflect.Descriptor instead.

func (*UpdateTaskQueueUserDataResponse) Equal added in v1.21.0 

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

Equal returns whether two UpdateTaskQueueUserDataResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateTaskQueueUserDataResponse) Marshal added in v1.21.0 

func (val *UpdateTaskQueueUserDataResponse) Marshal() ([]byte, error)

Marshal an object of type UpdateTaskQueueUserDataResponse to the protobuf v3 wire format

func (*UpdateTaskQueueUserDataResponse) ProtoMessage added in v1.21.0 

func (*UpdateTaskQueueUserDataResponse) ProtoMessage()

func (*UpdateTaskQueueUserDataResponse) ProtoReflect added in v1.23.0 

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

func (*UpdateTaskQueueUserDataResponse) Reset added in v1.21.0 

func (x *UpdateTaskQueueUserDataResponse) Reset()

func (*UpdateTaskQueueUserDataResponse) Size added in v1.21.0 

func (val *UpdateTaskQueueUserDataResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateTaskQueueUserDataResponse) String added in v1.21.0 

func (x *UpdateTaskQueueUserDataResponse) String() string

func (*UpdateTaskQueueUserDataResponse) Unmarshal added in v1.21.0 

func (val *UpdateTaskQueueUserDataResponse) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateTaskQueueUserDataResponse from the protobuf v3 wire format

type UpdateWorkerBuildIdCompatibilityRequest added in v1.21.0 

type UpdateWorkerBuildIdCompatibilityRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Types that are assignable to Operation:
	//
	//	*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_
	//	*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_
	//	*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId
	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 added in v1.21.0 

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityRequest) Equal added in v1.21.0 

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

Equal returns whether two UpdateWorkerBuildIdCompatibilityRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateWorkerBuildIdCompatibilityRequest) GetApplyPublicRequest added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetApplyPublicRequest() *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest

func (*UpdateWorkerBuildIdCompatibilityRequest) GetNamespaceId added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetNamespaceId() string

func (*UpdateWorkerBuildIdCompatibilityRequest) GetOperation added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest) GetOperation() isUpdateWorkerBuildIdCompatibilityRequest_Operation

func (*UpdateWorkerBuildIdCompatibilityRequest) GetPersistUnknownBuildId added in v1.22.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetPersistUnknownBuildId() string

func (*UpdateWorkerBuildIdCompatibilityRequest) GetRemoveBuildIds added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetRemoveBuildIds() *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds

func (*UpdateWorkerBuildIdCompatibilityRequest) GetTaskQueue added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest) GetTaskQueue() string

func (*UpdateWorkerBuildIdCompatibilityRequest) Marshal added in v1.21.0 

func (val *UpdateWorkerBuildIdCompatibilityRequest) Marshal() ([]byte, error)

Marshal an object of type UpdateWorkerBuildIdCompatibilityRequest to the protobuf v3 wire format

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoMessage added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoReflect added in v1.23.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) Reset added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest) Reset()

func (*UpdateWorkerBuildIdCompatibilityRequest) Size added in v1.21.0 

func (val *UpdateWorkerBuildIdCompatibilityRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateWorkerBuildIdCompatibilityRequest) String added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest) String() string

func (*UpdateWorkerBuildIdCompatibilityRequest) Unmarshal added in v1.21.0 

func (val *UpdateWorkerBuildIdCompatibilityRequest) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateWorkerBuildIdCompatibilityRequest from the protobuf v3 wire format

type UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest added in v1.21.0 

type UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest struct {
	Request *v1.UpdateWorkerBuildIdCompatibilityRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// contains filtered or unexported fields
}

Apply request from public API.

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) GetRequest added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) GetRequest() *v1.UpdateWorkerBuildIdCompatibilityRequest

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) ProtoMessage added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) ProtoReflect added in v1.23.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Reset added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Reset()

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) String added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) String() string

type UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_ added in v1.21.0 

type UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_ struct {
	ApplyPublicRequest *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest `protobuf:"bytes,3,opt,name=apply_public_request,json=applyPublicRequest,proto3,oneof"`
}

type UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId added in v1.22.0 

type UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId struct {
	PersistUnknownBuildId string `protobuf:"bytes,5,opt,name=persist_unknown_build_id,json=persistUnknownBuildId,proto3,oneof"`
}

type UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds added in v1.21.0 

type UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds struct {

	// The last known user data version, used to prevent concurrent updates.
	KnownUserDataVersion int64 `` /* 126-byte string literal not displayed */
	// List of build ids to remove.
	BuildIds []string `protobuf:"bytes,2,rep,name=build_ids,json=buildIds,proto3" json:"build_ids,omitempty"`
	// contains filtered or unexported fields
}

Remove build ids (internal only)

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) GetBuildIds added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) GetKnownUserDataVersion added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) GetKnownUserDataVersion() int64

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) ProtoMessage added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) ProtoReflect added in v1.23.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Reset added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Reset()

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) String added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) String() string

type UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_ added in v1.21.0 

type UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_ struct {
	RemoveBuildIds *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds `protobuf:"bytes,4,opt,name=remove_build_ids,json=removeBuildIds,proto3,oneof"`
}

type UpdateWorkerBuildIdCompatibilityResponse added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) Descriptor deprecated added in v1.21.0 

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

Deprecated: Use UpdateWorkerBuildIdCompatibilityResponse.ProtoReflect.Descriptor instead.

func (*UpdateWorkerBuildIdCompatibilityResponse) Equal added in v1.21.0 

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

Equal returns whether two UpdateWorkerBuildIdCompatibilityResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateWorkerBuildIdCompatibilityResponse) Marshal added in v1.21.0 

func (val *UpdateWorkerBuildIdCompatibilityResponse) Marshal() ([]byte, error)

Marshal an object of type UpdateWorkerBuildIdCompatibilityResponse to the protobuf v3 wire format

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoMessage added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoReflect added in v1.23.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) Reset added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityResponse) Reset()

func (*UpdateWorkerBuildIdCompatibilityResponse) Size added in v1.21.0 

func (val *UpdateWorkerBuildIdCompatibilityResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateWorkerBuildIdCompatibilityResponse) String added in v1.21.0 

func (x *UpdateWorkerBuildIdCompatibilityResponse) String() string

func (*UpdateWorkerBuildIdCompatibilityResponse) Unmarshal added in v1.21.0 

func (val *UpdateWorkerBuildIdCompatibilityResponse) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateWorkerBuildIdCompatibilityResponse from the protobuf v3 wire format

type UpdateWorkerVersioningRulesRequest added in v1.24.0 

type UpdateWorkerVersioningRulesRequest struct {
	NamespaceId string `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueue   string `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	// Types that are assignable to Command:
	//
	//	*UpdateWorkerVersioningRulesRequest_Request
	Command isUpdateWorkerVersioningRulesRequest_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

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

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

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

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

func (*UpdateWorkerVersioningRulesRequest) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use UpdateWorkerVersioningRulesRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkerVersioningRulesRequest) Equal added in v1.24.0 

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

Equal returns whether two UpdateWorkerVersioningRulesRequest values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateWorkerVersioningRulesRequest) GetCommand added in v1.24.0 

func (m *UpdateWorkerVersioningRulesRequest) GetCommand() isUpdateWorkerVersioningRulesRequest_Command

func (*UpdateWorkerVersioningRulesRequest) GetNamespaceId added in v1.24.0 

func (x *UpdateWorkerVersioningRulesRequest) GetNamespaceId() string

func (*UpdateWorkerVersioningRulesRequest) GetRequest added in v1.24.0 

func (x *UpdateWorkerVersioningRulesRequest) GetRequest() *v1.UpdateWorkerVersioningRulesRequest

func (*UpdateWorkerVersioningRulesRequest) GetTaskQueue added in v1.24.0 

func (x *UpdateWorkerVersioningRulesRequest) GetTaskQueue() string

func (*UpdateWorkerVersioningRulesRequest) Marshal added in v1.24.0 

func (val *UpdateWorkerVersioningRulesRequest) Marshal() ([]byte, error)

Marshal an object of type UpdateWorkerVersioningRulesRequest to the protobuf v3 wire format

func (*UpdateWorkerVersioningRulesRequest) ProtoMessage added in v1.24.0 

func (*UpdateWorkerVersioningRulesRequest) ProtoMessage()

func (*UpdateWorkerVersioningRulesRequest) ProtoReflect added in v1.24.0 

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

func (*UpdateWorkerVersioningRulesRequest) Reset added in v1.24.0 

func (x *UpdateWorkerVersioningRulesRequest) Reset()

func (*UpdateWorkerVersioningRulesRequest) Size added in v1.24.0 

func (val *UpdateWorkerVersioningRulesRequest) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateWorkerVersioningRulesRequest) String added in v1.24.0 

func (x *UpdateWorkerVersioningRulesRequest) String() string

func (*UpdateWorkerVersioningRulesRequest) Unmarshal added in v1.24.0 

func (val *UpdateWorkerVersioningRulesRequest) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateWorkerVersioningRulesRequest from the protobuf v3 wire format

type UpdateWorkerVersioningRulesRequest_Request added in v1.24.0 

type UpdateWorkerVersioningRulesRequest_Request struct {
	Request *v1.UpdateWorkerVersioningRulesRequest `protobuf:"bytes,3,opt,name=request,proto3,oneof"`
}

type UpdateWorkerVersioningRulesResponse added in v1.24.0 

type UpdateWorkerVersioningRulesResponse struct {
	Response *v1.UpdateWorkerVersioningRulesResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkerVersioningRulesResponse) Descriptor deprecated added in v1.24.0 

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

Deprecated: Use UpdateWorkerVersioningRulesResponse.ProtoReflect.Descriptor instead.

func (*UpdateWorkerVersioningRulesResponse) Equal added in v1.24.0 

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

Equal returns whether two UpdateWorkerVersioningRulesResponse values are equivalent by recursively comparing the message's fields. For more information see the documentation for https://pkg.go.dev/google.golang.org/protobuf/proto#Equal

func (*UpdateWorkerVersioningRulesResponse) GetResponse added in v1.24.0 

func (x *UpdateWorkerVersioningRulesResponse) GetResponse() *v1.UpdateWorkerVersioningRulesResponse

func (*UpdateWorkerVersioningRulesResponse) Marshal added in v1.24.0 

func (val *UpdateWorkerVersioningRulesResponse) Marshal() ([]byte, error)

Marshal an object of type UpdateWorkerVersioningRulesResponse to the protobuf v3 wire format

func (*UpdateWorkerVersioningRulesResponse) ProtoMessage added in v1.24.0 

func (*UpdateWorkerVersioningRulesResponse) ProtoMessage()

func (*UpdateWorkerVersioningRulesResponse) ProtoReflect added in v1.24.0 

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

func (*UpdateWorkerVersioningRulesResponse) Reset added in v1.24.0 

func (x *UpdateWorkerVersioningRulesResponse) Reset()

func (*UpdateWorkerVersioningRulesResponse) Size added in v1.24.0 

func (val *UpdateWorkerVersioningRulesResponse) Size() int

Size returns the size of the object, in bytes, once serialized

func (*UpdateWorkerVersioningRulesResponse) String added in v1.24.0 

func (x *UpdateWorkerVersioningRulesResponse) String() string

func (*UpdateWorkerVersioningRulesResponse) Unmarshal added in v1.24.0 

func (val *UpdateWorkerVersioningRulesResponse) Unmarshal(buf []byte) error

Unmarshal an object of type UpdateWorkerVersioningRulesResponse from the protobuf v3 wire format

Source Files

View all Source files

Jump to

Keyboard shortcuts

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