matchingservice

package
v1.24.0-m1.3 Latest Latest
Warning

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

 Go to latest Published: Mar 18, 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_CancelOutstandingPoll_FullMethodName                  = "/temporal.server.api.matchingservice.v1.MatchingService/CancelOutstandingPoll"
	MatchingService_DescribeTaskQueue_FullMethodName                      = "/temporal.server.api.matchingservice.v1.MatchingService/DescribeTaskQueue"
	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_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"
)

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: "CancelOutstandingPoll",
			Handler:    _MatchingService_CancelOutstandingPoll_Handler,
		},
		{
			MethodName: "DescribeTaskQueue",
			Handler:    _MatchingService_DescribeTaskQueue_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: "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,
		},
	},
	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 */
	ForwardedSource        string               `protobuf:"bytes,7,opt,name=forwarded_source,json=forwardedSource,proto3" json:"forwarded_source,omitempty"`
	Source                 v17.TaskSource       `protobuf:"varint,8,opt,name=source,proto3,enum=temporal.server.api.enums.v1.TaskSource" json:"source,omitempty"`
	Clock                  *v18.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 *v19.TaskVersionDirective `protobuf:"bytes,10,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,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() *v18.VectorClock

func (*AddActivityTaskRequest) GetExecution 

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

func (*AddActivityTaskRequest) GetForwardedSource added in v0.28.0 

func (x *AddActivityTaskRequest) GetForwardedSource() string

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

func (x *AddActivityTaskRequest) GetSource() v17.TaskSource

func (*AddActivityTaskRequest) GetTaskQueue 

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

func (*AddActivityTaskRequest) GetVersionDirective added in v1.21.0 

func (x *AddActivityTaskRequest) GetVersionDirective() *v19.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 {
	// 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) 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 */
	ForwardedSource        string               `protobuf:"bytes,6,opt,name=forwarded_source,json=forwardedSource,proto3" json:"forwarded_source,omitempty"`
	Source                 v17.TaskSource       `protobuf:"varint,7,opt,name=source,proto3,enum=temporal.server.api.enums.v1.TaskSource" json:"source,omitempty"`
	Clock                  *v18.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 *v19.TaskVersionDirective `protobuf:"bytes,10,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,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() *v18.VectorClock

func (*AddWorkflowTaskRequest) GetExecution 

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

func (*AddWorkflowTaskRequest) GetForwardedSource added in v0.28.0 

func (x *AddWorkflowTaskRequest) GetForwardedSource() string

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

func (x *AddWorkflowTaskRequest) GetSource() v17.TaskSource

func (*AddWorkflowTaskRequest) GetTaskQueue 

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

func (*AddWorkflowTaskRequest) GetVersionDirective added in v1.21.0 

func (x *AddWorkflowTaskRequest) GetVersionDirective() *v19.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 {
	// 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) 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    *v111.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() *v111.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 v110.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() v110.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 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 {
	Pollers         []*v14.PollerInfo    `protobuf:"bytes,1,rep,name=pollers,proto3" json:"pollers,omitempty"`
	TaskQueueStatus *v14.TaskQueueStatus `protobuf:"bytes,2,opt,name=task_queue_status,json=taskQueueStatus,proto3" json:"task_queue_status,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeTaskQueueResponse) Descriptor deprecated 

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

Deprecated: Use DescribeTaskQueueResponse.ProtoReflect.Descriptor instead.

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

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

func (*DescribeTaskQueueResponse) GetTaskQueueStatus 

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

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 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 v110.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() v110.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 v110.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() v110.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 *v111.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() *v111.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 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)
	// 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)
	// 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)
	// 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)
}

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)
	// 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)
	// 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)
	// 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)
	// 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 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"`
	ForwardedSource string                   `protobuf:"bytes,4,opt,name=forwarded_source,json=forwardedSource,proto3" json:"forwarded_source,omitempty"`
	// How this task should be directed by matching. (Missing means the default
	// for TaskVersionDirective, which is unversioned.)
	VersionDirective *v19.TaskVersionDirective `protobuf:"bytes,5,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,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) GetForwardedSource added in v0.28.0 

func (x *QueryWorkflowRequest) GetForwardedSource() string

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() *v19.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    *v111.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() *v111.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 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) DescribeTaskQueue 

func (UnimplementedMatchingServiceServer) DescribeTaskQueue(context.Context, *DescribeTaskQueueRequest) (*DescribeTaskQueueResponse, 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) ListTaskQueuePartitions 

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

func (UnimplementedMatchingServiceServer) PollActivityTaskQueue 

func (UnimplementedMatchingServiceServer) PollActivityTaskQueue(context.Context, *PollActivityTaskQueueRequest) (*PollActivityTaskQueueResponse, 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) RespondQueryTaskCompleted 

func (UnimplementedMatchingServiceServer) RespondQueryTaskCompleted(context.Context, *RespondQueryTaskCompletedRequest) (*RespondQueryTaskCompletedResponse, 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)

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 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 *v111.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() *v111.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

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.