matchingservice

package
v1.14.4 Latest Latest
Warning

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

 Go to latest Published: Jan 21, 2022 License: MIT Imports: 23 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"`
	SourceNamespaceId string                 `protobuf:"bytes,3,opt,name=source_namespace_id,json=sourceNamespaceId,proto3" json:"source_namespace_id,omitempty"`
	TaskQueue         *v14.TaskQueue         `protobuf:"bytes,4,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
	ScheduleId        int64                  `protobuf:"varint,5,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_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                 v15.TaskSource `protobuf:"varint,8,opt,name=source,proto3,enum=temporal.server.api.enums.v1.TaskSource" json:"source,omitempty"`
}

func (*AddActivityTaskRequest) Descriptor 

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

func (*AddActivityTaskRequest) Equal 

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

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

func (m *AddActivityTaskRequest) GetScheduleId() int64

func (*AddActivityTaskRequest) GetScheduleToStartTimeout added in v0.28.0 

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

func (*AddActivityTaskRequest) GetSource 

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

func (*AddActivityTaskRequest) GetSourceNamespaceId 

func (m *AddActivityTaskRequest) GetSourceNamespaceId() string

func (*AddActivityTaskRequest) GetTaskQueue 

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

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"`
	ScheduleId  int64                  `protobuf:"varint,4,opt,name=schedule_id,json=scheduleId,proto3" json:"schedule_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                 v15.TaskSource `protobuf:"varint,7,opt,name=source,proto3,enum=temporal.server.api.enums.v1.TaskSource" json:"source,omitempty"`
}

func (*AddWorkflowTaskRequest) Descriptor 

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

func (*AddWorkflowTaskRequest) Equal 

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

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

func (m *AddWorkflowTaskRequest) GetScheduleId() int64

func (*AddWorkflowTaskRequest) GetScheduleToStartTimeout added in v0.28.0 

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

func (*AddWorkflowTaskRequest) GetSource 

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

func (*AddWorkflowTaskRequest) GetTaskQueue 

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

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 CancelOutstandingPollRequest 

type CancelOutstandingPollRequest struct {
	NamespaceId   string            `protobuf:"bytes,1,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
	TaskQueueType v16.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() v16.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 ListTaskQueuePartitionsRequest 

type ListTaskQueuePartitionsRequest struct {
	Namespace string         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	TaskQueue *v14.TaskQueue `protobuf:"bytes,2,opt,name=task_queue,json=taskQueue,proto3" json:"task_queue,omitempty"`
}

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

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.ClientConn) 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)
}

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"`
	WorkflowTaskInfo           *v13.TransientWorkflowTaskInfo `protobuf:"bytes,11,opt,name=workflow_task_info,json=workflowTaskInfo,proto3" json:"workflow_task_info,omitempty"`
	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 */
}

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

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowExecutionTaskQueue 

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

func (*PollWorkflowTaskQueueResponse) GetWorkflowTaskInfo 

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

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

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

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