matchingservice

package
v1.22.2-rc2 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2023 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRequestResponse        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRequestResponse          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRequestResponse = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterMatchingServiceServer 

func RegisterMatchingServiceServer(s *grpc.Server, 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 *time.Duration   `` /* 143-byte string literal not displayed */
	ForwardedSource        string           `protobuf:"bytes,7,opt,name=forwarded_source,json=forwardedSource,proto3" json:"forwarded_source,omitempty"`
	Source                 v16.TaskSource   `protobuf:"varint,8,opt,name=source,proto3,enum=temporal.server.api.enums.v1.TaskSource" json:"source,omitempty"`
	Clock                  *v17.VectorClock `protobuf:"bytes,9,opt,name=clock,proto3" json:"clock,omitempty"`
	// How this task should be directed by matching. (Missing means the default
	// for TaskVersionDirective, which is unversioned.)
	VersionDirective *v18.TaskVersionDirective `protobuf:"bytes,10,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,omitempty"`
}

func (*AddActivityTaskRequest) Descriptor 

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

func (*AddActivityTaskRequest) Equal 

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

func (*AddActivityTaskRequest) GetClock added in v1.17.0 

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

func (*AddActivityTaskRequest) GetExecution 

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

func (*AddActivityTaskRequest) GetForwardedSource added in v0.28.0 

func (m *AddActivityTaskRequest) GetForwardedSource() string

func (*AddActivityTaskRequest) GetNamespaceId 

func (m *AddActivityTaskRequest) GetNamespaceId() string

func (*AddActivityTaskRequest) GetScheduleToStartTimeout added in v0.28.0 

func (m *AddActivityTaskRequest) GetScheduleToStartTimeout() *time.Duration

func (*AddActivityTaskRequest) GetScheduledEventId added in v1.17.0 

func (m *AddActivityTaskRequest) GetScheduledEventId() int64

func (*AddActivityTaskRequest) GetSource 

func (m *AddActivityTaskRequest) GetSource() v16.TaskSource

func (*AddActivityTaskRequest) GetTaskQueue 

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

func (*AddActivityTaskRequest) GetVersionDirective added in v1.21.0 

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

func (*AddActivityTaskRequest) GoString 

func (this *AddActivityTaskRequest) GoString() string

func (*AddActivityTaskRequest) Marshal 

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

func (*AddActivityTaskRequest) MarshalTo 

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

func (*AddActivityTaskRequest) MarshalToSizedBuffer 

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

func (*AddActivityTaskRequest) ProtoMessage 

func (*AddActivityTaskRequest) ProtoMessage()

func (*AddActivityTaskRequest) Reset 

func (m *AddActivityTaskRequest) Reset()

func (*AddActivityTaskRequest) Size 

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

func (*AddActivityTaskRequest) String 

func (this *AddActivityTaskRequest) String() string

func (*AddActivityTaskRequest) Unmarshal 

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

func (*AddActivityTaskRequest) XXX_DiscardUnknown 

func (m *AddActivityTaskRequest) XXX_DiscardUnknown()

func (*AddActivityTaskRequest) XXX_Marshal 

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

func (*AddActivityTaskRequest) XXX_Merge 

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

func (*AddActivityTaskRequest) XXX_Size 

func (m *AddActivityTaskRequest) XXX_Size() int

func (*AddActivityTaskRequest) XXX_Unmarshal 

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

type AddActivityTaskResponse 

type AddActivityTaskResponse struct {
}

func (*AddActivityTaskResponse) Descriptor 

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

func (*AddActivityTaskResponse) Equal 

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

func (*AddActivityTaskResponse) GoString 

func (this *AddActivityTaskResponse) GoString() string

func (*AddActivityTaskResponse) Marshal 

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

func (*AddActivityTaskResponse) MarshalTo 

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

func (*AddActivityTaskResponse) MarshalToSizedBuffer 

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

func (*AddActivityTaskResponse) ProtoMessage 

func (*AddActivityTaskResponse) ProtoMessage()

func (*AddActivityTaskResponse) Reset 

func (m *AddActivityTaskResponse) Reset()

func (*AddActivityTaskResponse) Size 

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

func (*AddActivityTaskResponse) String 

func (this *AddActivityTaskResponse) String() string

func (*AddActivityTaskResponse) Unmarshal 

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

func (*AddActivityTaskResponse) XXX_DiscardUnknown 

func (m *AddActivityTaskResponse) XXX_DiscardUnknown()

func (*AddActivityTaskResponse) XXX_Marshal 

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

func (*AddActivityTaskResponse) XXX_Merge 

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

func (*AddActivityTaskResponse) XXX_Size 

func (m *AddActivityTaskResponse) XXX_Size() int

func (*AddActivityTaskResponse) XXX_Unmarshal 

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

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 *time.Duration   `` /* 143-byte string literal not displayed */
	ForwardedSource        string           `protobuf:"bytes,6,opt,name=forwarded_source,json=forwardedSource,proto3" json:"forwarded_source,omitempty"`
	Source                 v16.TaskSource   `protobuf:"varint,7,opt,name=source,proto3,enum=temporal.server.api.enums.v1.TaskSource" json:"source,omitempty"`
	Clock                  *v17.VectorClock `protobuf:"bytes,9,opt,name=clock,proto3" json:"clock,omitempty"`
	// How this task should be directed by matching. (Missing means the default
	// for TaskVersionDirective, which is unversioned.)
	VersionDirective *v18.TaskVersionDirective `protobuf:"bytes,10,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,omitempty"`
}

func (*AddWorkflowTaskRequest) Descriptor 

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

func (*AddWorkflowTaskRequest) Equal 

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

func (*AddWorkflowTaskRequest) GetClock added in v1.17.0 

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

func (*AddWorkflowTaskRequest) GetExecution 

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

func (*AddWorkflowTaskRequest) GetForwardedSource added in v0.28.0 

func (m *AddWorkflowTaskRequest) GetForwardedSource() string

func (*AddWorkflowTaskRequest) GetNamespaceId 

func (m *AddWorkflowTaskRequest) GetNamespaceId() string

func (*AddWorkflowTaskRequest) GetScheduleToStartTimeout added in v0.28.0 

func (m *AddWorkflowTaskRequest) GetScheduleToStartTimeout() *time.Duration

func (*AddWorkflowTaskRequest) GetScheduledEventId added in v1.17.0 

func (m *AddWorkflowTaskRequest) GetScheduledEventId() int64

func (*AddWorkflowTaskRequest) GetSource 

func (m *AddWorkflowTaskRequest) GetSource() v16.TaskSource

func (*AddWorkflowTaskRequest) GetTaskQueue 

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

func (*AddWorkflowTaskRequest) GetVersionDirective added in v1.21.0 

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

func (*AddWorkflowTaskRequest) GoString 

func (this *AddWorkflowTaskRequest) GoString() string

func (*AddWorkflowTaskRequest) Marshal 

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

func (*AddWorkflowTaskRequest) MarshalTo 

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

func (*AddWorkflowTaskRequest) MarshalToSizedBuffer 

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

func (*AddWorkflowTaskRequest) ProtoMessage 

func (*AddWorkflowTaskRequest) ProtoMessage()

func (*AddWorkflowTaskRequest) Reset 

func (m *AddWorkflowTaskRequest) Reset()

func (*AddWorkflowTaskRequest) Size 

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

func (*AddWorkflowTaskRequest) String 

func (this *AddWorkflowTaskRequest) String() string

func (*AddWorkflowTaskRequest) Unmarshal 

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

func (*AddWorkflowTaskRequest) XXX_DiscardUnknown 

func (m *AddWorkflowTaskRequest) XXX_DiscardUnknown()

func (*AddWorkflowTaskRequest) XXX_Marshal 

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

func (*AddWorkflowTaskRequest) XXX_Merge 

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

func (*AddWorkflowTaskRequest) XXX_Size 

func (m *AddWorkflowTaskRequest) XXX_Size() int

func (*AddWorkflowTaskRequest) XXX_Unmarshal 

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

type AddWorkflowTaskResponse 

type AddWorkflowTaskResponse struct {
}

func (*AddWorkflowTaskResponse) Descriptor 

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

func (*AddWorkflowTaskResponse) Equal 

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

func (*AddWorkflowTaskResponse) GoString 

func (this *AddWorkflowTaskResponse) GoString() string

func (*AddWorkflowTaskResponse) Marshal 

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

func (*AddWorkflowTaskResponse) MarshalTo 

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

func (*AddWorkflowTaskResponse) MarshalToSizedBuffer 

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

func (*AddWorkflowTaskResponse) ProtoMessage 

func (*AddWorkflowTaskResponse) ProtoMessage()

func (*AddWorkflowTaskResponse) Reset 

func (m *AddWorkflowTaskResponse) Reset()

func (*AddWorkflowTaskResponse) Size 

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

func (*AddWorkflowTaskResponse) String 

func (this *AddWorkflowTaskResponse) String() string

func (*AddWorkflowTaskResponse) Unmarshal 

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

func (*AddWorkflowTaskResponse) XXX_DiscardUnknown 

func (m *AddWorkflowTaskResponse) XXX_DiscardUnknown()

func (*AddWorkflowTaskResponse) XXX_Marshal 

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

func (*AddWorkflowTaskResponse) XXX_Merge 

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

func (*AddWorkflowTaskResponse) XXX_Size 

func (m *AddWorkflowTaskResponse) XXX_Size() int

func (*AddWorkflowTaskResponse) XXX_Unmarshal 

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

type ApplyTaskQueueUserDataReplicationEventRequest added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) Descriptor added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) Equal added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) GetNamespaceId added in v1.21.0 

func (m *ApplyTaskQueueUserDataReplicationEventRequest) GetNamespaceId() string

func (*ApplyTaskQueueUserDataReplicationEventRequest) GetTaskQueue added in v1.21.0 

func (m *ApplyTaskQueueUserDataReplicationEventRequest) GetTaskQueue() string

func (*ApplyTaskQueueUserDataReplicationEventRequest) GetUserData added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) GoString added in v1.21.0 

func (this *ApplyTaskQueueUserDataReplicationEventRequest) GoString() string

func (*ApplyTaskQueueUserDataReplicationEventRequest) Marshal added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) MarshalTo added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) ProtoMessage added in v1.21.0 

func (*ApplyTaskQueueUserDataReplicationEventRequest) ProtoMessage()

func (*ApplyTaskQueueUserDataReplicationEventRequest) Reset added in v1.21.0 

func (m *ApplyTaskQueueUserDataReplicationEventRequest) Reset()

func (*ApplyTaskQueueUserDataReplicationEventRequest) Size added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) String added in v1.21.0 

func (this *ApplyTaskQueueUserDataReplicationEventRequest) String() string

func (*ApplyTaskQueueUserDataReplicationEventRequest) Unmarshal added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *ApplyTaskQueueUserDataReplicationEventRequest) XXX_DiscardUnknown()

func (*ApplyTaskQueueUserDataReplicationEventRequest) XXX_Marshal added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) XXX_Merge added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventRequest) XXX_Size added in v1.21.0 

func (m *ApplyTaskQueueUserDataReplicationEventRequest) XXX_Size() int

func (*ApplyTaskQueueUserDataReplicationEventRequest) XXX_Unmarshal added in v1.21.0 

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

type ApplyTaskQueueUserDataReplicationEventResponse added in v1.21.0 

type ApplyTaskQueueUserDataReplicationEventResponse struct {
}

func (*ApplyTaskQueueUserDataReplicationEventResponse) Descriptor added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) Equal added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) GoString added in v1.21.0 

func (this *ApplyTaskQueueUserDataReplicationEventResponse) GoString() string

func (*ApplyTaskQueueUserDataReplicationEventResponse) Marshal added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) MarshalTo added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) MarshalToSizedBuffer added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) ProtoMessage added in v1.21.0 

func (*ApplyTaskQueueUserDataReplicationEventResponse) ProtoMessage()

func (*ApplyTaskQueueUserDataReplicationEventResponse) Reset added in v1.21.0 

func (m *ApplyTaskQueueUserDataReplicationEventResponse) Reset()

func (*ApplyTaskQueueUserDataReplicationEventResponse) Size added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) String added in v1.21.0 

func (this *ApplyTaskQueueUserDataReplicationEventResponse) String() string

func (*ApplyTaskQueueUserDataReplicationEventResponse) Unmarshal added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) XXX_DiscardUnknown added in v1.21.0 

func (m *ApplyTaskQueueUserDataReplicationEventResponse) XXX_DiscardUnknown()

func (*ApplyTaskQueueUserDataReplicationEventResponse) XXX_Marshal added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) XXX_Merge added in v1.21.0 

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

func (*ApplyTaskQueueUserDataReplicationEventResponse) XXX_Size added in v1.21.0 

func (m *ApplyTaskQueueUserDataReplicationEventResponse) XXX_Size() int

func (*ApplyTaskQueueUserDataReplicationEventResponse) XXX_Unmarshal added in v1.21.0 

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

type CancelOutstandingPollRequest 

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

func (*CancelOutstandingPollRequest) Descriptor 

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

func (*CancelOutstandingPollRequest) Equal 

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

func (*CancelOutstandingPollRequest) GetNamespaceId 

func (m *CancelOutstandingPollRequest) GetNamespaceId() string

func (*CancelOutstandingPollRequest) GetPollerId 

func (m *CancelOutstandingPollRequest) GetPollerId() string

func (*CancelOutstandingPollRequest) GetTaskQueue 

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

func (*CancelOutstandingPollRequest) GetTaskQueueType 

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

func (*CancelOutstandingPollRequest) GoString 

func (this *CancelOutstandingPollRequest) GoString() string

func (*CancelOutstandingPollRequest) Marshal 

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

func (*CancelOutstandingPollRequest) MarshalTo 

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

func (*CancelOutstandingPollRequest) MarshalToSizedBuffer 

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

func (*CancelOutstandingPollRequest) ProtoMessage 

func (*CancelOutstandingPollRequest) ProtoMessage()

func (*CancelOutstandingPollRequest) Reset 

func (m *CancelOutstandingPollRequest) Reset()

func (*CancelOutstandingPollRequest) Size 

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

func (*CancelOutstandingPollRequest) String 

func (this *CancelOutstandingPollRequest) String() string

func (*CancelOutstandingPollRequest) Unmarshal 

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

func (*CancelOutstandingPollRequest) XXX_DiscardUnknown 

func (m *CancelOutstandingPollRequest) XXX_DiscardUnknown()

func (*CancelOutstandingPollRequest) XXX_Marshal 

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

func (*CancelOutstandingPollRequest) XXX_Merge 

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

func (*CancelOutstandingPollRequest) XXX_Size 

func (m *CancelOutstandingPollRequest) XXX_Size() int

func (*CancelOutstandingPollRequest) XXX_Unmarshal 

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

type CancelOutstandingPollResponse 

type CancelOutstandingPollResponse struct {
}

func (*CancelOutstandingPollResponse) Descriptor 

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

func (*CancelOutstandingPollResponse) Equal 

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

func (*CancelOutstandingPollResponse) GoString 

func (this *CancelOutstandingPollResponse) GoString() string

func (*CancelOutstandingPollResponse) Marshal 

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

func (*CancelOutstandingPollResponse) MarshalTo 

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

func (*CancelOutstandingPollResponse) MarshalToSizedBuffer 

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

func (*CancelOutstandingPollResponse) ProtoMessage 

func (*CancelOutstandingPollResponse) ProtoMessage()

func (*CancelOutstandingPollResponse) Reset 

func (m *CancelOutstandingPollResponse) Reset()

func (*CancelOutstandingPollResponse) Size 

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

func (*CancelOutstandingPollResponse) String 

func (this *CancelOutstandingPollResponse) String() string

func (*CancelOutstandingPollResponse) Unmarshal 

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

func (*CancelOutstandingPollResponse) XXX_DiscardUnknown 

func (m *CancelOutstandingPollResponse) XXX_DiscardUnknown()

func (*CancelOutstandingPollResponse) XXX_Marshal 

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

func (*CancelOutstandingPollResponse) XXX_Merge 

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

func (*CancelOutstandingPollResponse) XXX_Size 

func (m *CancelOutstandingPollResponse) XXX_Size() int

func (*CancelOutstandingPollResponse) XXX_Unmarshal 

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

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

func (*DescribeTaskQueueRequest) Descriptor 

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

func (*DescribeTaskQueueRequest) Equal 

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

func (*DescribeTaskQueueRequest) GetDescRequest 

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

func (*DescribeTaskQueueRequest) GetNamespaceId 

func (m *DescribeTaskQueueRequest) GetNamespaceId() string

func (*DescribeTaskQueueRequest) GoString 

func (this *DescribeTaskQueueRequest) GoString() string

func (*DescribeTaskQueueRequest) Marshal 

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

func (*DescribeTaskQueueRequest) MarshalTo 

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

func (*DescribeTaskQueueRequest) MarshalToSizedBuffer 

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

func (*DescribeTaskQueueRequest) ProtoMessage 

func (*DescribeTaskQueueRequest) ProtoMessage()

func (*DescribeTaskQueueRequest) Reset 

func (m *DescribeTaskQueueRequest) Reset()

func (*DescribeTaskQueueRequest) Size 

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

func (*DescribeTaskQueueRequest) String 

func (this *DescribeTaskQueueRequest) String() string

func (*DescribeTaskQueueRequest) Unmarshal 

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

func (*DescribeTaskQueueRequest) XXX_DiscardUnknown 

func (m *DescribeTaskQueueRequest) XXX_DiscardUnknown()

func (*DescribeTaskQueueRequest) XXX_Marshal 

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

func (*DescribeTaskQueueRequest) XXX_Merge 

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

func (*DescribeTaskQueueRequest) XXX_Size 

func (m *DescribeTaskQueueRequest) XXX_Size() int

func (*DescribeTaskQueueRequest) XXX_Unmarshal 

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

type DescribeTaskQueueResponse 

type DescribeTaskQueueResponse struct {
	Pollers         []*v14.PollerInfo    `protobuf:"bytes,1,rep,name=pollers,proto3" json:"pollers,omitempty"`
	TaskQueueStatus *v14.TaskQueueStatus `protobuf:"bytes,2,opt,name=task_queue_status,json=taskQueueStatus,proto3" json:"task_queue_status,omitempty"`
}

func (*DescribeTaskQueueResponse) Descriptor 

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

func (*DescribeTaskQueueResponse) Equal 

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

func (*DescribeTaskQueueResponse) GetPollers 

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

func (*DescribeTaskQueueResponse) GetTaskQueueStatus 

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

func (*DescribeTaskQueueResponse) GoString 

func (this *DescribeTaskQueueResponse) GoString() string

func (*DescribeTaskQueueResponse) Marshal 

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

func (*DescribeTaskQueueResponse) MarshalTo 

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

func (*DescribeTaskQueueResponse) MarshalToSizedBuffer 

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

func (*DescribeTaskQueueResponse) ProtoMessage 

func (*DescribeTaskQueueResponse) ProtoMessage()

func (*DescribeTaskQueueResponse) Reset 

func (m *DescribeTaskQueueResponse) Reset()

func (*DescribeTaskQueueResponse) Size 

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

func (*DescribeTaskQueueResponse) String 

func (this *DescribeTaskQueueResponse) String() string

func (*DescribeTaskQueueResponse) Unmarshal 

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

func (*DescribeTaskQueueResponse) XXX_DiscardUnknown 

func (m *DescribeTaskQueueResponse) XXX_DiscardUnknown()

func (*DescribeTaskQueueResponse) XXX_Marshal 

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

func (*DescribeTaskQueueResponse) XXX_Merge 

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

func (*DescribeTaskQueueResponse) XXX_Size 

func (m *DescribeTaskQueueResponse) XXX_Size() int

func (*DescribeTaskQueueResponse) XXX_Unmarshal 

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

type ForceUnloadTaskQueueRequest added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) Descriptor added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) Equal added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) GetNamespaceId added in v1.21.0 

func (m *ForceUnloadTaskQueueRequest) GetNamespaceId() string

func (*ForceUnloadTaskQueueRequest) GetTaskQueue added in v1.21.0 

func (m *ForceUnloadTaskQueueRequest) GetTaskQueue() string

func (*ForceUnloadTaskQueueRequest) GetTaskQueueType added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) GoString added in v1.21.0 

func (this *ForceUnloadTaskQueueRequest) GoString() string

func (*ForceUnloadTaskQueueRequest) Marshal added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) MarshalTo added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) ProtoMessage added in v1.21.0 

func (*ForceUnloadTaskQueueRequest) ProtoMessage()

func (*ForceUnloadTaskQueueRequest) Reset added in v1.21.0 

func (m *ForceUnloadTaskQueueRequest) Reset()

func (*ForceUnloadTaskQueueRequest) Size added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) String added in v1.21.0 

func (this *ForceUnloadTaskQueueRequest) String() string

func (*ForceUnloadTaskQueueRequest) Unmarshal added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *ForceUnloadTaskQueueRequest) XXX_DiscardUnknown()

func (*ForceUnloadTaskQueueRequest) XXX_Marshal added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) XXX_Merge added in v1.21.0 

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

func (*ForceUnloadTaskQueueRequest) XXX_Size added in v1.21.0 

func (m *ForceUnloadTaskQueueRequest) XXX_Size() int

func (*ForceUnloadTaskQueueRequest) XXX_Unmarshal added in v1.21.0 

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

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

func (*ForceUnloadTaskQueueResponse) Descriptor added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) Equal added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) GetWasLoaded added in v1.21.0 

func (m *ForceUnloadTaskQueueResponse) GetWasLoaded() bool

func (*ForceUnloadTaskQueueResponse) GoString added in v1.21.0 

func (this *ForceUnloadTaskQueueResponse) GoString() string

func (*ForceUnloadTaskQueueResponse) Marshal added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) MarshalTo added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) MarshalToSizedBuffer added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) ProtoMessage added in v1.21.0 

func (*ForceUnloadTaskQueueResponse) ProtoMessage()

func (*ForceUnloadTaskQueueResponse) Reset added in v1.21.0 

func (m *ForceUnloadTaskQueueResponse) Reset()

func (*ForceUnloadTaskQueueResponse) Size added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) String added in v1.21.0 

func (this *ForceUnloadTaskQueueResponse) String() string

func (*ForceUnloadTaskQueueResponse) Unmarshal added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) XXX_DiscardUnknown added in v1.21.0 

func (m *ForceUnloadTaskQueueResponse) XXX_DiscardUnknown()

func (*ForceUnloadTaskQueueResponse) XXX_Marshal added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) XXX_Merge added in v1.21.0 

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

func (*ForceUnloadTaskQueueResponse) XXX_Size added in v1.21.0 

func (m *ForceUnloadTaskQueueResponse) XXX_Size() int

func (*ForceUnloadTaskQueueResponse) XXX_Unmarshal added in v1.21.0 

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

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

func (*GetBuildIdTaskQueueMappingRequest) Descriptor added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) Equal added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) GetBuildId added in v1.21.0 

func (m *GetBuildIdTaskQueueMappingRequest) GetBuildId() string

func (*GetBuildIdTaskQueueMappingRequest) GetNamespaceId added in v1.21.0 

func (m *GetBuildIdTaskQueueMappingRequest) GetNamespaceId() string

func (*GetBuildIdTaskQueueMappingRequest) GoString added in v1.21.0 

func (this *GetBuildIdTaskQueueMappingRequest) GoString() string

func (*GetBuildIdTaskQueueMappingRequest) Marshal added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) MarshalTo added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) ProtoMessage added in v1.21.0 

func (*GetBuildIdTaskQueueMappingRequest) ProtoMessage()

func (*GetBuildIdTaskQueueMappingRequest) Reset added in v1.21.0 

func (m *GetBuildIdTaskQueueMappingRequest) Reset()

func (*GetBuildIdTaskQueueMappingRequest) Size added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) String added in v1.21.0 

func (this *GetBuildIdTaskQueueMappingRequest) String() string

func (*GetBuildIdTaskQueueMappingRequest) Unmarshal added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *GetBuildIdTaskQueueMappingRequest) XXX_DiscardUnknown()

func (*GetBuildIdTaskQueueMappingRequest) XXX_Marshal added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) XXX_Merge added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingRequest) XXX_Size added in v1.21.0 

func (m *GetBuildIdTaskQueueMappingRequest) XXX_Size() int

func (*GetBuildIdTaskQueueMappingRequest) XXX_Unmarshal added in v1.21.0 

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

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

func (*GetBuildIdTaskQueueMappingResponse) Descriptor added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) Equal added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) GetTaskQueues added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) GoString added in v1.21.0 

func (this *GetBuildIdTaskQueueMappingResponse) GoString() string

func (*GetBuildIdTaskQueueMappingResponse) Marshal added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) MarshalTo added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) MarshalToSizedBuffer added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) ProtoMessage added in v1.21.0 

func (*GetBuildIdTaskQueueMappingResponse) ProtoMessage()

func (*GetBuildIdTaskQueueMappingResponse) Reset added in v1.21.0 

func (m *GetBuildIdTaskQueueMappingResponse) Reset()

func (*GetBuildIdTaskQueueMappingResponse) Size added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) String added in v1.21.0 

func (this *GetBuildIdTaskQueueMappingResponse) String() string

func (*GetBuildIdTaskQueueMappingResponse) Unmarshal added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) XXX_DiscardUnknown added in v1.21.0 

func (m *GetBuildIdTaskQueueMappingResponse) XXX_DiscardUnknown()

func (*GetBuildIdTaskQueueMappingResponse) XXX_Marshal added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) XXX_Merge added in v1.21.0 

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

func (*GetBuildIdTaskQueueMappingResponse) XXX_Size added in v1.21.0 

func (m *GetBuildIdTaskQueueMappingResponse) XXX_Size() int

func (*GetBuildIdTaskQueueMappingResponse) XXX_Unmarshal added in v1.21.0 

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

type GetTaskQueueUserDataRequest added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) Descriptor added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) Equal added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) GetLastKnownUserDataVersion added in v1.21.0 

func (m *GetTaskQueueUserDataRequest) GetLastKnownUserDataVersion() int64

func (*GetTaskQueueUserDataRequest) GetNamespaceId added in v1.21.0 

func (m *GetTaskQueueUserDataRequest) GetNamespaceId() string

func (*GetTaskQueueUserDataRequest) GetTaskQueue added in v1.21.0 

func (m *GetTaskQueueUserDataRequest) GetTaskQueue() string

func (*GetTaskQueueUserDataRequest) GetTaskQueueType added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) GetWaitNewData added in v1.21.0 

func (m *GetTaskQueueUserDataRequest) GetWaitNewData() bool

func (*GetTaskQueueUserDataRequest) GoString added in v1.21.0 

func (this *GetTaskQueueUserDataRequest) GoString() string

func (*GetTaskQueueUserDataRequest) Marshal added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) MarshalTo added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) ProtoMessage added in v1.21.0 

func (*GetTaskQueueUserDataRequest) ProtoMessage()

func (*GetTaskQueueUserDataRequest) Reset added in v1.21.0 

func (m *GetTaskQueueUserDataRequest) Reset()

func (*GetTaskQueueUserDataRequest) Size added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) String added in v1.21.0 

func (this *GetTaskQueueUserDataRequest) String() string

func (*GetTaskQueueUserDataRequest) Unmarshal added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *GetTaskQueueUserDataRequest) XXX_DiscardUnknown()

func (*GetTaskQueueUserDataRequest) XXX_Marshal added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) XXX_Merge added in v1.21.0 

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

func (*GetTaskQueueUserDataRequest) XXX_Size added in v1.21.0 

func (m *GetTaskQueueUserDataRequest) XXX_Size() int

func (*GetTaskQueueUserDataRequest) XXX_Unmarshal added in v1.21.0 

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

type GetTaskQueueUserDataResponse added in v1.21.0 

type GetTaskQueueUserDataResponse struct {
	// Whether this task queue has any stored user data
	TaskQueueHasUserData bool `` /* 128-byte string literal not displayed */
	// Versioned user data, set if the task queue has user data and the request's last_known_user_data_version is less
	// than the version cached in the root partition.
	UserData *v110.VersionedTaskQueueUserData `protobuf:"bytes,2,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`
}

func (*GetTaskQueueUserDataResponse) Descriptor added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) Equal added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) GetTaskQueueHasUserData added in v1.21.0 

func (m *GetTaskQueueUserDataResponse) GetTaskQueueHasUserData() bool

func (*GetTaskQueueUserDataResponse) GetUserData added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) GoString added in v1.21.0 

func (this *GetTaskQueueUserDataResponse) GoString() string

func (*GetTaskQueueUserDataResponse) Marshal added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) MarshalTo added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) MarshalToSizedBuffer added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) ProtoMessage added in v1.21.0 

func (*GetTaskQueueUserDataResponse) ProtoMessage()

func (*GetTaskQueueUserDataResponse) Reset added in v1.21.0 

func (m *GetTaskQueueUserDataResponse) Reset()

func (*GetTaskQueueUserDataResponse) Size added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) String added in v1.21.0 

func (this *GetTaskQueueUserDataResponse) String() string

func (*GetTaskQueueUserDataResponse) Unmarshal added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) XXX_DiscardUnknown added in v1.21.0 

func (m *GetTaskQueueUserDataResponse) XXX_DiscardUnknown()

func (*GetTaskQueueUserDataResponse) XXX_Marshal added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) XXX_Merge added in v1.21.0 

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

func (*GetTaskQueueUserDataResponse) XXX_Size added in v1.21.0 

func (m *GetTaskQueueUserDataResponse) XXX_Size() int

func (*GetTaskQueueUserDataResponse) XXX_Unmarshal added in v1.21.0 

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

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

func (*GetWorkerBuildIdCompatibilityRequest) Descriptor added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) Equal added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) GetNamespaceId added in v1.21.0 

func (m *GetWorkerBuildIdCompatibilityRequest) GetNamespaceId() string

func (*GetWorkerBuildIdCompatibilityRequest) GetRequest added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) GoString added in v1.21.0 

func (this *GetWorkerBuildIdCompatibilityRequest) GoString() string

func (*GetWorkerBuildIdCompatibilityRequest) Marshal added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) MarshalTo added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) ProtoMessage added in v1.21.0 

func (*GetWorkerBuildIdCompatibilityRequest) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityRequest) Reset added in v1.21.0 

func (m *GetWorkerBuildIdCompatibilityRequest) Reset()

func (*GetWorkerBuildIdCompatibilityRequest) Size added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) String added in v1.21.0 

func (this *GetWorkerBuildIdCompatibilityRequest) String() string

func (*GetWorkerBuildIdCompatibilityRequest) Unmarshal added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *GetWorkerBuildIdCompatibilityRequest) XXX_DiscardUnknown()

func (*GetWorkerBuildIdCompatibilityRequest) XXX_Marshal added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) XXX_Merge added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityRequest) XXX_Size added in v1.21.0 

func (m *GetWorkerBuildIdCompatibilityRequest) XXX_Size() int

func (*GetWorkerBuildIdCompatibilityRequest) XXX_Unmarshal added in v1.21.0 

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

type GetWorkerBuildIdCompatibilityResponse added in v1.21.0 

type GetWorkerBuildIdCompatibilityResponse struct {
	Response *v1.GetWorkerBuildIdCompatibilityResponse `protobuf:"bytes,1,opt,name=response,proto3" json:"response,omitempty"`
}

func (*GetWorkerBuildIdCompatibilityResponse) Descriptor added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) Equal added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) GetResponse added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) GoString added in v1.21.0 

func (this *GetWorkerBuildIdCompatibilityResponse) GoString() string

func (*GetWorkerBuildIdCompatibilityResponse) Marshal added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) MarshalTo added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) MarshalToSizedBuffer added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage added in v1.21.0 

func (*GetWorkerBuildIdCompatibilityResponse) ProtoMessage()

func (*GetWorkerBuildIdCompatibilityResponse) Reset added in v1.21.0 

func (m *GetWorkerBuildIdCompatibilityResponse) Reset()

func (*GetWorkerBuildIdCompatibilityResponse) Size added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) String added in v1.21.0 

func (this *GetWorkerBuildIdCompatibilityResponse) String() string

func (*GetWorkerBuildIdCompatibilityResponse) Unmarshal added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) XXX_DiscardUnknown added in v1.21.0 

func (m *GetWorkerBuildIdCompatibilityResponse) XXX_DiscardUnknown()

func (*GetWorkerBuildIdCompatibilityResponse) XXX_Marshal added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) XXX_Merge added in v1.21.0 

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

func (*GetWorkerBuildIdCompatibilityResponse) XXX_Size added in v1.21.0 

func (m *GetWorkerBuildIdCompatibilityResponse) XXX_Size() int

func (*GetWorkerBuildIdCompatibilityResponse) XXX_Unmarshal added in v1.21.0 

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

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

func (*ListTaskQueuePartitionsRequest) Descriptor 

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

func (*ListTaskQueuePartitionsRequest) Equal 

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

func (*ListTaskQueuePartitionsRequest) GetNamespace 

func (m *ListTaskQueuePartitionsRequest) GetNamespace() string

func (*ListTaskQueuePartitionsRequest) GetNamespaceId added in v1.17.3 

func (m *ListTaskQueuePartitionsRequest) GetNamespaceId() string

func (*ListTaskQueuePartitionsRequest) GetTaskQueue 

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

func (*ListTaskQueuePartitionsRequest) GoString 

func (this *ListTaskQueuePartitionsRequest) GoString() string

func (*ListTaskQueuePartitionsRequest) Marshal 

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

func (*ListTaskQueuePartitionsRequest) MarshalTo 

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

func (*ListTaskQueuePartitionsRequest) MarshalToSizedBuffer 

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

func (*ListTaskQueuePartitionsRequest) ProtoMessage 

func (*ListTaskQueuePartitionsRequest) ProtoMessage()

func (*ListTaskQueuePartitionsRequest) Reset 

func (m *ListTaskQueuePartitionsRequest) Reset()

func (*ListTaskQueuePartitionsRequest) Size 

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

func (*ListTaskQueuePartitionsRequest) String 

func (this *ListTaskQueuePartitionsRequest) String() string

func (*ListTaskQueuePartitionsRequest) Unmarshal 

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

func (*ListTaskQueuePartitionsRequest) XXX_DiscardUnknown 

func (m *ListTaskQueuePartitionsRequest) XXX_DiscardUnknown()

func (*ListTaskQueuePartitionsRequest) XXX_Marshal 

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

func (*ListTaskQueuePartitionsRequest) XXX_Merge 

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

func (*ListTaskQueuePartitionsRequest) XXX_Size 

func (m *ListTaskQueuePartitionsRequest) XXX_Size() int

func (*ListTaskQueuePartitionsRequest) XXX_Unmarshal 

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

type ListTaskQueuePartitionsResponse 

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

func (*ListTaskQueuePartitionsResponse) Descriptor 

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

func (*ListTaskQueuePartitionsResponse) Equal 

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

func (*ListTaskQueuePartitionsResponse) GetActivityTaskQueuePartitions 

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

func (*ListTaskQueuePartitionsResponse) GetWorkflowTaskQueuePartitions 

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

func (*ListTaskQueuePartitionsResponse) GoString 

func (this *ListTaskQueuePartitionsResponse) GoString() string

func (*ListTaskQueuePartitionsResponse) Marshal 

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

func (*ListTaskQueuePartitionsResponse) MarshalTo 

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

func (*ListTaskQueuePartitionsResponse) MarshalToSizedBuffer 

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

func (*ListTaskQueuePartitionsResponse) ProtoMessage 

func (*ListTaskQueuePartitionsResponse) ProtoMessage()

func (*ListTaskQueuePartitionsResponse) Reset 

func (m *ListTaskQueuePartitionsResponse) Reset()

func (*ListTaskQueuePartitionsResponse) Size 

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

func (*ListTaskQueuePartitionsResponse) String 

func (this *ListTaskQueuePartitionsResponse) String() string

func (*ListTaskQueuePartitionsResponse) Unmarshal 

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

func (*ListTaskQueuePartitionsResponse) XXX_DiscardUnknown 

func (m *ListTaskQueuePartitionsResponse) XXX_DiscardUnknown()

func (*ListTaskQueuePartitionsResponse) XXX_Marshal 

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

func (*ListTaskQueuePartitionsResponse) XXX_Merge 

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

func (*ListTaskQueuePartitionsResponse) XXX_Size 

func (m *ListTaskQueuePartitionsResponse) XXX_Size() int

func (*ListTaskQueuePartitionsResponse) XXX_Unmarshal 

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

type 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://godoc.org/google.golang.org/grpc#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)
}

MatchingServiceServer is the server API for MatchingService service.

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

func (*PollActivityTaskQueueRequest) Descriptor 

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

func (*PollActivityTaskQueueRequest) Equal 

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

func (*PollActivityTaskQueueRequest) GetForwardedSource added in v0.28.0 

func (m *PollActivityTaskQueueRequest) GetForwardedSource() string

func (*PollActivityTaskQueueRequest) GetNamespaceId 

func (m *PollActivityTaskQueueRequest) GetNamespaceId() string

func (*PollActivityTaskQueueRequest) GetPollRequest 

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

func (*PollActivityTaskQueueRequest) GetPollerId 

func (m *PollActivityTaskQueueRequest) GetPollerId() string

func (*PollActivityTaskQueueRequest) GoString 

func (this *PollActivityTaskQueueRequest) GoString() string

func (*PollActivityTaskQueueRequest) Marshal 

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

func (*PollActivityTaskQueueRequest) MarshalTo 

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

func (*PollActivityTaskQueueRequest) MarshalToSizedBuffer 

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

func (*PollActivityTaskQueueRequest) ProtoMessage 

func (*PollActivityTaskQueueRequest) ProtoMessage()

func (*PollActivityTaskQueueRequest) Reset 

func (m *PollActivityTaskQueueRequest) Reset()

func (*PollActivityTaskQueueRequest) Size 

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

func (*PollActivityTaskQueueRequest) String 

func (this *PollActivityTaskQueueRequest) String() string

func (*PollActivityTaskQueueRequest) Unmarshal 

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

func (*PollActivityTaskQueueRequest) XXX_DiscardUnknown 

func (m *PollActivityTaskQueueRequest) XXX_DiscardUnknown()

func (*PollActivityTaskQueueRequest) XXX_Marshal 

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

func (*PollActivityTaskQueueRequest) XXX_Merge 

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

func (*PollActivityTaskQueueRequest) XXX_Size 

func (m *PollActivityTaskQueueRequest) XXX_Size() int

func (*PollActivityTaskQueueRequest) XXX_Unmarshal 

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

type PollActivityTaskQueueResponse 

type PollActivityTaskQueueResponse struct {
	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     *time.Time             `protobuf:"bytes,6,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	ScheduleToCloseTimeout *time.Duration `` /* 143-byte string literal not displayed */
	StartedTime            *time.Time     `protobuf:"bytes,8,opt,name=started_time,json=startedTime,proto3,stdtime" json:"started_time,omitempty"`
	// (-- api-linter: core::0140::prepositions=disabled
	//     aip.dev/not-precedent: "to" is used to indicate interval. --)
	StartToCloseTimeout         *time.Duration    `` /* 134-byte string literal not displayed */
	HeartbeatTimeout            *time.Duration    `protobuf:"bytes,10,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3,stdduration" json:"heartbeat_timeout,omitempty"`
	Attempt                     int32             `protobuf:"varint,11,opt,name=attempt,proto3" json:"attempt,omitempty"`
	CurrentAttemptScheduledTime *time.Time        `` /* 155-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"`
}

func (*PollActivityTaskQueueResponse) Descriptor 

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

func (*PollActivityTaskQueueResponse) Equal 

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

func (*PollActivityTaskQueueResponse) GetActivityId 

func (m *PollActivityTaskQueueResponse) GetActivityId() string

func (*PollActivityTaskQueueResponse) GetActivityType 

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

func (*PollActivityTaskQueueResponse) GetAttempt 

func (m *PollActivityTaskQueueResponse) GetAttempt() int32

func (*PollActivityTaskQueueResponse) GetCurrentAttemptScheduledTime added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetHeader 

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

func (*PollActivityTaskQueueResponse) GetHeartbeatDetails 

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

func (*PollActivityTaskQueueResponse) GetHeartbeatTimeout added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetInput 

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

func (*PollActivityTaskQueueResponse) GetScheduleToCloseTimeout added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetScheduledTime added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetStartToCloseTimeout added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetStartedTime added in v0.28.0 

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

func (*PollActivityTaskQueueResponse) GetTaskToken 

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

func (*PollActivityTaskQueueResponse) GetWorkflowExecution 

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

func (*PollActivityTaskQueueResponse) GetWorkflowNamespace 

func (m *PollActivityTaskQueueResponse) GetWorkflowNamespace() string

func (*PollActivityTaskQueueResponse) GetWorkflowType 

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

func (*PollActivityTaskQueueResponse) GoString 

func (this *PollActivityTaskQueueResponse) GoString() string

func (*PollActivityTaskQueueResponse) Marshal 

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

func (*PollActivityTaskQueueResponse) MarshalTo 

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

func (*PollActivityTaskQueueResponse) MarshalToSizedBuffer 

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

func (*PollActivityTaskQueueResponse) ProtoMessage 

func (*PollActivityTaskQueueResponse) ProtoMessage()

func (*PollActivityTaskQueueResponse) Reset 

func (m *PollActivityTaskQueueResponse) Reset()

func (*PollActivityTaskQueueResponse) Size 

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

func (*PollActivityTaskQueueResponse) String 

func (this *PollActivityTaskQueueResponse) String() string

func (*PollActivityTaskQueueResponse) Unmarshal 

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

func (*PollActivityTaskQueueResponse) XXX_DiscardUnknown 

func (m *PollActivityTaskQueueResponse) XXX_DiscardUnknown()

func (*PollActivityTaskQueueResponse) XXX_Marshal 

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

func (*PollActivityTaskQueueResponse) XXX_Merge 

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

func (*PollActivityTaskQueueResponse) XXX_Size 

func (m *PollActivityTaskQueueResponse) XXX_Size() int

func (*PollActivityTaskQueueResponse) XXX_Unmarshal 

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

type PollWorkflowTaskQueueRequest 

type PollWorkflowTaskQueueRequest struct {
	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"`
}

func (*PollWorkflowTaskQueueRequest) Descriptor 

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

func (*PollWorkflowTaskQueueRequest) Equal 

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

func (*PollWorkflowTaskQueueRequest) GetForwardedSource added in v0.28.0 

func (m *PollWorkflowTaskQueueRequest) GetForwardedSource() string

func (*PollWorkflowTaskQueueRequest) GetNamespaceId 

func (m *PollWorkflowTaskQueueRequest) GetNamespaceId() string

func (*PollWorkflowTaskQueueRequest) GetPollRequest 

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

func (*PollWorkflowTaskQueueRequest) GetPollerId 

func (m *PollWorkflowTaskQueueRequest) GetPollerId() string

func (*PollWorkflowTaskQueueRequest) GoString 

func (this *PollWorkflowTaskQueueRequest) GoString() string

func (*PollWorkflowTaskQueueRequest) Marshal 

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

func (*PollWorkflowTaskQueueRequest) MarshalTo 

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

func (*PollWorkflowTaskQueueRequest) MarshalToSizedBuffer 

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

func (*PollWorkflowTaskQueueRequest) ProtoMessage 

func (*PollWorkflowTaskQueueRequest) ProtoMessage()

func (*PollWorkflowTaskQueueRequest) Reset 

func (m *PollWorkflowTaskQueueRequest) Reset()

func (*PollWorkflowTaskQueueRequest) Size 

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

func (*PollWorkflowTaskQueueRequest) String 

func (this *PollWorkflowTaskQueueRequest) String() string

func (*PollWorkflowTaskQueueRequest) Unmarshal 

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

func (*PollWorkflowTaskQueueRequest) XXX_DiscardUnknown 

func (m *PollWorkflowTaskQueueRequest) XXX_DiscardUnknown()

func (*PollWorkflowTaskQueueRequest) XXX_Marshal 

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

func (*PollWorkflowTaskQueueRequest) XXX_Merge 

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

func (*PollWorkflowTaskQueueRequest) XXX_Size 

func (m *PollWorkflowTaskQueueRequest) XXX_Size() int

func (*PollWorkflowTaskQueueRequest) XXX_Unmarshal 

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

type PollWorkflowTaskQueueResponse 

type PollWorkflowTaskQueueResponse struct {
	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              *time.Time                     `protobuf:"bytes,15,opt,name=scheduled_time,json=scheduledTime,proto3,stdtime" json:"scheduled_time,omitempty"`
	StartedTime                *time.Time                     `protobuf:"bytes,16,opt,name=started_time,json=startedTime,proto3,stdtime" 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"`
}

func (*PollWorkflowTaskQueueResponse) Descriptor 

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

func (*PollWorkflowTaskQueueResponse) Equal 

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

func (*PollWorkflowTaskQueueResponse) GetAttempt 

func (m *PollWorkflowTaskQueueResponse) GetAttempt() int32

func (*PollWorkflowTaskQueueResponse) GetBacklogCountHint 

func (m *PollWorkflowTaskQueueResponse) GetBacklogCountHint() int64

func (*PollWorkflowTaskQueueResponse) GetBranchToken 

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

func (*PollWorkflowTaskQueueResponse) GetMessages added in v1.20.0 

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

func (*PollWorkflowTaskQueueResponse) GetNextEventId 

func (m *PollWorkflowTaskQueueResponse) GetNextEventId() int64

func (*PollWorkflowTaskQueueResponse) GetPreviousStartedEventId 

func (m *PollWorkflowTaskQueueResponse) GetPreviousStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetQueries 

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

func (*PollWorkflowTaskQueueResponse) GetQuery 

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

func (*PollWorkflowTaskQueueResponse) GetScheduledTime added in v0.28.0 

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

func (*PollWorkflowTaskQueueResponse) GetStartedEventId 

func (m *PollWorkflowTaskQueueResponse) GetStartedEventId() int64

func (*PollWorkflowTaskQueueResponse) GetStartedTime added in v0.28.0 

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

func (*PollWorkflowTaskQueueResponse) GetStickyExecutionEnabled 

func (m *PollWorkflowTaskQueueResponse) GetStickyExecutionEnabled() bool

func (*PollWorkflowTaskQueueResponse) GetTaskToken 

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

func (*PollWorkflowTaskQueueResponse) GetTransientWorkflowTask added in v1.17.3 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecution 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowType 

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

func (*PollWorkflowTaskQueueResponse) GoString 

func (this *PollWorkflowTaskQueueResponse) GoString() string

func (*PollWorkflowTaskQueueResponse) Marshal 

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

func (*PollWorkflowTaskQueueResponse) MarshalTo 

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

func (*PollWorkflowTaskQueueResponse) MarshalToSizedBuffer 

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

func (*PollWorkflowTaskQueueResponse) ProtoMessage 

func (*PollWorkflowTaskQueueResponse) ProtoMessage()

func (*PollWorkflowTaskQueueResponse) Reset 

func (m *PollWorkflowTaskQueueResponse) Reset()

func (*PollWorkflowTaskQueueResponse) Size 

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

func (*PollWorkflowTaskQueueResponse) String 

func (this *PollWorkflowTaskQueueResponse) String() string

func (*PollWorkflowTaskQueueResponse) Unmarshal 

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

func (*PollWorkflowTaskQueueResponse) XXX_DiscardUnknown 

func (m *PollWorkflowTaskQueueResponse) XXX_DiscardUnknown()

func (*PollWorkflowTaskQueueResponse) XXX_Marshal 

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

func (*PollWorkflowTaskQueueResponse) XXX_Merge 

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

func (*PollWorkflowTaskQueueResponse) XXX_Size 

func (m *PollWorkflowTaskQueueResponse) XXX_Size() int

func (*PollWorkflowTaskQueueResponse) XXX_Unmarshal 

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

type QueryWorkflowRequest 

type QueryWorkflowRequest struct {
	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 *v18.TaskVersionDirective `protobuf:"bytes,5,opt,name=version_directive,json=versionDirective,proto3" json:"version_directive,omitempty"`
}

func (*QueryWorkflowRequest) Descriptor 

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

func (*QueryWorkflowRequest) Equal 

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

func (*QueryWorkflowRequest) GetForwardedSource added in v0.28.0 

func (m *QueryWorkflowRequest) GetForwardedSource() string

func (*QueryWorkflowRequest) GetNamespaceId 

func (m *QueryWorkflowRequest) GetNamespaceId() string

func (*QueryWorkflowRequest) GetQueryRequest 

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

func (*QueryWorkflowRequest) GetTaskQueue 

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

func (*QueryWorkflowRequest) GetVersionDirective added in v1.21.0 

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

func (*QueryWorkflowRequest) GoString 

func (this *QueryWorkflowRequest) GoString() string

func (*QueryWorkflowRequest) Marshal 

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

func (*QueryWorkflowRequest) MarshalTo 

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

func (*QueryWorkflowRequest) MarshalToSizedBuffer 

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

func (*QueryWorkflowRequest) ProtoMessage 

func (*QueryWorkflowRequest) ProtoMessage()

func (*QueryWorkflowRequest) Reset 

func (m *QueryWorkflowRequest) Reset()

func (*QueryWorkflowRequest) Size 

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

func (*QueryWorkflowRequest) String 

func (this *QueryWorkflowRequest) String() string

func (*QueryWorkflowRequest) Unmarshal 

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

func (*QueryWorkflowRequest) XXX_DiscardUnknown 

func (m *QueryWorkflowRequest) XXX_DiscardUnknown()

func (*QueryWorkflowRequest) XXX_Marshal 

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

func (*QueryWorkflowRequest) XXX_Merge 

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

func (*QueryWorkflowRequest) XXX_Size 

func (m *QueryWorkflowRequest) XXX_Size() int

func (*QueryWorkflowRequest) XXX_Unmarshal 

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

type QueryWorkflowResponse 

type QueryWorkflowResponse struct {
	QueryResult   *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"`
}

func (*QueryWorkflowResponse) Descriptor 

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

func (*QueryWorkflowResponse) Equal 

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

func (*QueryWorkflowResponse) GetQueryRejected 

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

func (*QueryWorkflowResponse) GetQueryResult 

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

func (*QueryWorkflowResponse) GoString 

func (this *QueryWorkflowResponse) GoString() string

func (*QueryWorkflowResponse) Marshal 

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

func (*QueryWorkflowResponse) MarshalTo 

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

func (*QueryWorkflowResponse) MarshalToSizedBuffer 

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

func (*QueryWorkflowResponse) ProtoMessage 

func (*QueryWorkflowResponse) ProtoMessage()

func (*QueryWorkflowResponse) Reset 

func (m *QueryWorkflowResponse) Reset()

func (*QueryWorkflowResponse) Size 

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

func (*QueryWorkflowResponse) String 

func (this *QueryWorkflowResponse) String() string

func (*QueryWorkflowResponse) Unmarshal 

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

func (*QueryWorkflowResponse) XXX_DiscardUnknown 

func (m *QueryWorkflowResponse) XXX_DiscardUnknown()

func (*QueryWorkflowResponse) XXX_Marshal 

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

func (*QueryWorkflowResponse) XXX_Merge 

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

func (*QueryWorkflowResponse) XXX_Size 

func (m *QueryWorkflowResponse) XXX_Size() int

func (*QueryWorkflowResponse) XXX_Unmarshal 

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

type ReplicateTaskQueueUserDataRequest added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) Descriptor added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) Equal added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) GetNamespaceId added in v1.21.0 

func (m *ReplicateTaskQueueUserDataRequest) GetNamespaceId() string

func (*ReplicateTaskQueueUserDataRequest) GetTaskQueue added in v1.21.0 

func (m *ReplicateTaskQueueUserDataRequest) GetTaskQueue() string

func (*ReplicateTaskQueueUserDataRequest) GetUserData added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) GoString added in v1.21.0 

func (this *ReplicateTaskQueueUserDataRequest) GoString() string

func (*ReplicateTaskQueueUserDataRequest) Marshal added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) MarshalTo added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) ProtoMessage added in v1.21.0 

func (*ReplicateTaskQueueUserDataRequest) ProtoMessage()

func (*ReplicateTaskQueueUserDataRequest) Reset added in v1.21.0 

func (m *ReplicateTaskQueueUserDataRequest) Reset()

func (*ReplicateTaskQueueUserDataRequest) Size added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) String added in v1.21.0 

func (this *ReplicateTaskQueueUserDataRequest) String() string

func (*ReplicateTaskQueueUserDataRequest) Unmarshal added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *ReplicateTaskQueueUserDataRequest) XXX_DiscardUnknown()

func (*ReplicateTaskQueueUserDataRequest) XXX_Marshal added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) XXX_Merge added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataRequest) XXX_Size added in v1.21.0 

func (m *ReplicateTaskQueueUserDataRequest) XXX_Size() int

func (*ReplicateTaskQueueUserDataRequest) XXX_Unmarshal added in v1.21.0 

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

type ReplicateTaskQueueUserDataResponse added in v1.21.0 

type ReplicateTaskQueueUserDataResponse struct {
}

func (*ReplicateTaskQueueUserDataResponse) Descriptor added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) Equal added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) GoString added in v1.21.0 

func (this *ReplicateTaskQueueUserDataResponse) GoString() string

func (*ReplicateTaskQueueUserDataResponse) Marshal added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) MarshalTo added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) MarshalToSizedBuffer added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) ProtoMessage added in v1.21.0 

func (*ReplicateTaskQueueUserDataResponse) ProtoMessage()

func (*ReplicateTaskQueueUserDataResponse) Reset added in v1.21.0 

func (m *ReplicateTaskQueueUserDataResponse) Reset()

func (*ReplicateTaskQueueUserDataResponse) Size added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) String added in v1.21.0 

func (this *ReplicateTaskQueueUserDataResponse) String() string

func (*ReplicateTaskQueueUserDataResponse) Unmarshal added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) XXX_DiscardUnknown added in v1.21.0 

func (m *ReplicateTaskQueueUserDataResponse) XXX_DiscardUnknown()

func (*ReplicateTaskQueueUserDataResponse) XXX_Marshal added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) XXX_Merge added in v1.21.0 

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

func (*ReplicateTaskQueueUserDataResponse) XXX_Size added in v1.21.0 

func (m *ReplicateTaskQueueUserDataResponse) XXX_Size() int

func (*ReplicateTaskQueueUserDataResponse) XXX_Unmarshal added in v1.21.0 

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

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

func (*RespondQueryTaskCompletedRequest) Descriptor 

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

func (*RespondQueryTaskCompletedRequest) Equal 

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

func (*RespondQueryTaskCompletedRequest) GetCompletedRequest 

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

func (*RespondQueryTaskCompletedRequest) GetNamespaceId 

func (m *RespondQueryTaskCompletedRequest) GetNamespaceId() string

func (*RespondQueryTaskCompletedRequest) GetTaskId 

func (m *RespondQueryTaskCompletedRequest) GetTaskId() string

func (*RespondQueryTaskCompletedRequest) GetTaskQueue 

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

func (*RespondQueryTaskCompletedRequest) GoString 

func (this *RespondQueryTaskCompletedRequest) GoString() string

func (*RespondQueryTaskCompletedRequest) Marshal 

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

func (*RespondQueryTaskCompletedRequest) MarshalTo 

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

func (*RespondQueryTaskCompletedRequest) MarshalToSizedBuffer 

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

func (*RespondQueryTaskCompletedRequest) ProtoMessage 

func (*RespondQueryTaskCompletedRequest) ProtoMessage()

func (*RespondQueryTaskCompletedRequest) Reset 

func (m *RespondQueryTaskCompletedRequest) Reset()

func (*RespondQueryTaskCompletedRequest) Size 

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

func (*RespondQueryTaskCompletedRequest) String 

func (this *RespondQueryTaskCompletedRequest) String() string

func (*RespondQueryTaskCompletedRequest) Unmarshal 

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

func (*RespondQueryTaskCompletedRequest) XXX_DiscardUnknown 

func (m *RespondQueryTaskCompletedRequest) XXX_DiscardUnknown()

func (*RespondQueryTaskCompletedRequest) XXX_Marshal 

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

func (*RespondQueryTaskCompletedRequest) XXX_Merge 

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

func (*RespondQueryTaskCompletedRequest) XXX_Size 

func (m *RespondQueryTaskCompletedRequest) XXX_Size() int

func (*RespondQueryTaskCompletedRequest) XXX_Unmarshal 

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

type RespondQueryTaskCompletedResponse 

type RespondQueryTaskCompletedResponse struct {
}

func (*RespondQueryTaskCompletedResponse) Descriptor 

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

func (*RespondQueryTaskCompletedResponse) Equal 

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

func (*RespondQueryTaskCompletedResponse) GoString 

func (this *RespondQueryTaskCompletedResponse) GoString() string

func (*RespondQueryTaskCompletedResponse) Marshal 

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

func (*RespondQueryTaskCompletedResponse) MarshalTo 

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

func (*RespondQueryTaskCompletedResponse) MarshalToSizedBuffer 

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

func (*RespondQueryTaskCompletedResponse) ProtoMessage 

func (*RespondQueryTaskCompletedResponse) ProtoMessage()

func (*RespondQueryTaskCompletedResponse) Reset 

func (m *RespondQueryTaskCompletedResponse) Reset()

func (*RespondQueryTaskCompletedResponse) Size 

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

func (*RespondQueryTaskCompletedResponse) String 

func (this *RespondQueryTaskCompletedResponse) String() string

func (*RespondQueryTaskCompletedResponse) Unmarshal 

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

func (*RespondQueryTaskCompletedResponse) XXX_DiscardUnknown 

func (m *RespondQueryTaskCompletedResponse) XXX_DiscardUnknown()

func (*RespondQueryTaskCompletedResponse) XXX_Marshal 

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

func (*RespondQueryTaskCompletedResponse) XXX_Merge 

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

func (*RespondQueryTaskCompletedResponse) XXX_Size 

func (m *RespondQueryTaskCompletedResponse) XXX_Size() int

func (*RespondQueryTaskCompletedResponse) XXX_Unmarshal 

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

type UnimplementedMatchingServiceServer 

type UnimplementedMatchingServiceServer struct {
}

UnimplementedMatchingServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMatchingServiceServer) AddActivityTask 

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

func (*UnimplementedMatchingServiceServer) AddWorkflowTask 

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

func (*UnimplementedMatchingServiceServer) ApplyTaskQueueUserDataReplicationEvent added in v1.21.0 

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

func (*UnimplementedMatchingServiceServer) CancelOutstandingPoll 

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

func (*UnimplementedMatchingServiceServer) DescribeTaskQueue 

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

func (*UnimplementedMatchingServiceServer) ForceUnloadTaskQueue added in v1.21.0 

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

func (*UnimplementedMatchingServiceServer) GetBuildIdTaskQueueMapping added in v1.21.0 

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

func (*UnimplementedMatchingServiceServer) GetTaskQueueUserData added in v1.21.0 

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

func (*UnimplementedMatchingServiceServer) GetWorkerBuildIdCompatibility added in v1.21.0 

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

func (*UnimplementedMatchingServiceServer) ListTaskQueuePartitions 

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

func (*UnimplementedMatchingServiceServer) PollActivityTaskQueue 

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

func (*UnimplementedMatchingServiceServer) PollWorkflowTaskQueue 

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

func (*UnimplementedMatchingServiceServer) QueryWorkflow 

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

func (*UnimplementedMatchingServiceServer) ReplicateTaskQueueUserData added in v1.21.0 

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

func (*UnimplementedMatchingServiceServer) RespondQueryTaskCompleted 

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

func (*UnimplementedMatchingServiceServer) UpdateTaskQueueUserData added in v1.21.0 

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

func (*UnimplementedMatchingServiceServer) UpdateWorkerBuildIdCompatibility added in v1.21.0 

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

type UpdateTaskQueueUserDataRequest added in v1.21.0 

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

(-- 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 added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) Equal added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) GetBuildIdsAdded added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) GetBuildIdsRemoved added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) GetNamespaceId added in v1.21.0 

func (m *UpdateTaskQueueUserDataRequest) GetNamespaceId() string

func (*UpdateTaskQueueUserDataRequest) GetTaskQueue added in v1.21.0 

func (m *UpdateTaskQueueUserDataRequest) GetTaskQueue() string

func (*UpdateTaskQueueUserDataRequest) GetUserData added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) GoString added in v1.21.0 

func (this *UpdateTaskQueueUserDataRequest) GoString() string

func (*UpdateTaskQueueUserDataRequest) Marshal added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) MarshalTo added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) ProtoMessage added in v1.21.0 

func (*UpdateTaskQueueUserDataRequest) ProtoMessage()

func (*UpdateTaskQueueUserDataRequest) Reset added in v1.21.0 

func (m *UpdateTaskQueueUserDataRequest) Reset()

func (*UpdateTaskQueueUserDataRequest) Size added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) String added in v1.21.0 

func (this *UpdateTaskQueueUserDataRequest) String() string

func (*UpdateTaskQueueUserDataRequest) Unmarshal added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *UpdateTaskQueueUserDataRequest) XXX_DiscardUnknown()

func (*UpdateTaskQueueUserDataRequest) XXX_Marshal added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) XXX_Merge added in v1.21.0 

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

func (*UpdateTaskQueueUserDataRequest) XXX_Size added in v1.21.0 

func (m *UpdateTaskQueueUserDataRequest) XXX_Size() int

func (*UpdateTaskQueueUserDataRequest) XXX_Unmarshal added in v1.21.0 

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

type UpdateTaskQueueUserDataResponse added in v1.21.0 

type UpdateTaskQueueUserDataResponse struct {
}

func (*UpdateTaskQueueUserDataResponse) Descriptor added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) Equal added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) GoString added in v1.21.0 

func (this *UpdateTaskQueueUserDataResponse) GoString() string

func (*UpdateTaskQueueUserDataResponse) Marshal added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) MarshalTo added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) MarshalToSizedBuffer added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) ProtoMessage added in v1.21.0 

func (*UpdateTaskQueueUserDataResponse) ProtoMessage()

func (*UpdateTaskQueueUserDataResponse) Reset added in v1.21.0 

func (m *UpdateTaskQueueUserDataResponse) Reset()

func (*UpdateTaskQueueUserDataResponse) Size added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) String added in v1.21.0 

func (this *UpdateTaskQueueUserDataResponse) String() string

func (*UpdateTaskQueueUserDataResponse) Unmarshal added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) XXX_DiscardUnknown added in v1.21.0 

func (m *UpdateTaskQueueUserDataResponse) XXX_DiscardUnknown()

func (*UpdateTaskQueueUserDataResponse) XXX_Marshal added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) XXX_Merge added in v1.21.0 

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

func (*UpdateTaskQueueUserDataResponse) XXX_Size added in v1.21.0 

func (m *UpdateTaskQueueUserDataResponse) XXX_Size() int

func (*UpdateTaskQueueUserDataResponse) XXX_Unmarshal added in v1.21.0 

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

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 valid to be assigned to Operation:
	//	*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_
	//	*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_
	//	*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId
	Operation isUpdateWorkerBuildIdCompatibilityRequest_Operation `protobuf_oneof:"operation"`
}

(-- 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 added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) Equal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) GetApplyPublicRequest added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest) GetApplyPublicRequest() *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest

func (*UpdateWorkerBuildIdCompatibilityRequest) GetNamespaceId added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) GetRemoveBuildIds added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest) GetRemoveBuildIds() *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds

func (*UpdateWorkerBuildIdCompatibilityRequest) GetTaskQueue added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest) GetTaskQueue() string

func (*UpdateWorkerBuildIdCompatibilityRequest) GoString added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest) GoString() string

func (*UpdateWorkerBuildIdCompatibilityRequest) Marshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) MarshalTo added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoMessage added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityRequest) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityRequest) Reset added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest) Reset()

func (*UpdateWorkerBuildIdCompatibilityRequest) Size added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) String added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest) String() string

func (*UpdateWorkerBuildIdCompatibilityRequest) Unmarshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest) XXX_DiscardUnknown()

func (*UpdateWorkerBuildIdCompatibilityRequest) XXX_Marshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) XXX_Merge added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest) XXX_OneofWrappers added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpdateWorkerBuildIdCompatibilityRequest) XXX_Size added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest) XXX_Size() int

func (*UpdateWorkerBuildIdCompatibilityRequest) XXX_Unmarshal added in v1.21.0 

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

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

Apply request from public API.

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Descriptor added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Equal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) GetRequest added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) GoString added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) GoString() string

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Marshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) MarshalTo added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) MarshalToSizedBuffer added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) ProtoMessage added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Reset added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Reset()

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Size added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) String added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) String() string

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) Unmarshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) XXX_DiscardUnknown added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) XXX_DiscardUnknown()

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) XXX_Marshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) XXX_Merge added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) XXX_Size added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) XXX_Size() int

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest) XXX_Unmarshal added in v1.21.0 

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

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" json:"apply_public_request,omitempty"`
}

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_) Equal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_) GoString added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_) GoString() string

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_) MarshalTo added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_) MarshalToSizedBuffer added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_) Size added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_) String added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_ApplyPublicRequest_) String() string

type UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId added in v1.22.0 

type UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId struct {
	PersistUnknownBuildId string `` /* 134-byte string literal not displayed */
}

func (*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId) Equal added in v1.22.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId) GoString added in v1.22.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId) GoString() string

func (*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId) MarshalTo added in v1.22.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId) MarshalToSizedBuffer added in v1.22.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId) Size added in v1.22.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId) String added in v1.22.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_PersistUnknownBuildId) String() string

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

Remove build ids (internal only)

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Descriptor added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Equal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) GetBuildIds added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) GetKnownUserDataVersion added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) GetKnownUserDataVersion() int64

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) GoString added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) GoString() string

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Marshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) MarshalTo added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) MarshalToSizedBuffer added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) ProtoMessage added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Reset added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Reset()

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Size added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) String added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) String() string

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) Unmarshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) XXX_DiscardUnknown added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) XXX_DiscardUnknown()

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) XXX_Marshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) XXX_Merge added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) XXX_Size added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) XXX_Size() int

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds) XXX_Unmarshal added in v1.21.0 

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

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" json:"remove_build_ids,omitempty"`
}

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_) Equal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_) GoString added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_) GoString() string

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_) MarshalTo added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_) MarshalToSizedBuffer added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_) Size added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_) String added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityRequest_RemoveBuildIds_) String() string

type UpdateWorkerBuildIdCompatibilityResponse added in v1.21.0 

type UpdateWorkerBuildIdCompatibilityResponse struct {
}

func (*UpdateWorkerBuildIdCompatibilityResponse) Descriptor added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) Equal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) GoString added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityResponse) GoString() string

func (*UpdateWorkerBuildIdCompatibilityResponse) Marshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) MarshalTo added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) MarshalToSizedBuffer added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoMessage added in v1.21.0 

func (*UpdateWorkerBuildIdCompatibilityResponse) ProtoMessage()

func (*UpdateWorkerBuildIdCompatibilityResponse) Reset added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityResponse) Reset()

func (*UpdateWorkerBuildIdCompatibilityResponse) Size added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) String added in v1.21.0 

func (this *UpdateWorkerBuildIdCompatibilityResponse) String() string

func (*UpdateWorkerBuildIdCompatibilityResponse) Unmarshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) XXX_DiscardUnknown added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityResponse) XXX_DiscardUnknown()

func (*UpdateWorkerBuildIdCompatibilityResponse) XXX_Marshal added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) XXX_Merge added in v1.21.0 

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

func (*UpdateWorkerBuildIdCompatibilityResponse) XXX_Size added in v1.21.0 

func (m *UpdateWorkerBuildIdCompatibilityResponse) XXX_Size() int

func (*UpdateWorkerBuildIdCompatibilityResponse) XXX_Unmarshal added in v1.21.0 

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

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.