matching

package
v1.2.7-prerelease1 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2023 License: MIT Imports: 24 Imported by: 10

Documentation

Overview

Package matching is a generated GoMock package.

Index

Constants

View Source 
const (
	// DefaultTimeout is the default timeout used to make calls
	DefaultTimeout = time.Minute
	// DefaultLongPollTimeout is the long poll default timeout used to make calls
	DefaultLongPollTimeout = time.Minute * 2
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client interface {
	AddActivityTask(context.Context, *types.AddActivityTaskRequest, ...yarpc.CallOption) error
	AddDecisionTask(context.Context, *types.AddDecisionTaskRequest, ...yarpc.CallOption) error
	CancelOutstandingPoll(context.Context, *types.CancelOutstandingPollRequest, ...yarpc.CallOption) error
	DescribeTaskList(context.Context, *types.MatchingDescribeTaskListRequest, ...yarpc.CallOption) (*types.DescribeTaskListResponse, error)
	ListTaskListPartitions(context.Context, *types.MatchingListTaskListPartitionsRequest, ...yarpc.CallOption) (*types.ListTaskListPartitionsResponse, error)
	GetTaskListsByDomain(context.Context, *types.GetTaskListsByDomainRequest, ...yarpc.CallOption) (*types.GetTaskListsByDomainResponse, error)
	PollForActivityTask(context.Context, *types.MatchingPollForActivityTaskRequest, ...yarpc.CallOption) (*types.PollForActivityTaskResponse, error)
	PollForDecisionTask(context.Context, *types.MatchingPollForDecisionTaskRequest, ...yarpc.CallOption) (*types.MatchingPollForDecisionTaskResponse, error)
	QueryWorkflow(context.Context, *types.MatchingQueryWorkflowRequest, ...yarpc.CallOption) (*types.QueryWorkflowResponse, error)
	RespondQueryTaskCompleted(context.Context, *types.MatchingRespondQueryTaskCompletedRequest, ...yarpc.CallOption) error
}

Client is the interface exposed by types service client

func NewClient 

func NewClient(
	timeout time.Duration,
	longPollTimeout time.Duration,
	client Client,
	peerResolver PeerResolver,
	lb LoadBalancer,
) Client

NewClient creates a new history service TChannel client

func NewErrorInjectionClient added in v0.18.0 

func NewErrorInjectionClient(
	client Client,
	errorRate float64,
	logger log.Logger,
) Client

NewErrorInjectionClient creates a new instance of Client that injects fake error

func NewGRPCClient added in v0.21.0 

func NewGRPCClient(c matchingv1.MatchingAPIYARPCClient) Client

func NewMetricClient 

func NewMetricClient(client Client, metricsClient metrics.Client) Client

NewMetricClient creates a new instance of Client that emits metrics

func NewRetryableClient added in v0.3.14 

func NewRetryableClient(
	client Client,
	policy backoff.RetryPolicy,
	isRetryable backoff.IsRetryable,
) Client

NewRetryableClient creates a new instance of Client with retry policy

func NewThriftClient added in v0.17.0 

func NewThriftClient(c matchingserviceclient.Interface) Client

NewThriftClient creates a new instance of Client with thrift protocol

type LoadBalancer added in v0.7.0 

type LoadBalancer interface {
	// PickWritePartition returns the task list partition for adding
	// an activity or decision task. The input is the name of the
	// original task list (with no partition info). When forwardedFrom
	// is non-empty, this call is forwardedFrom from a child partition
	// to a parent partition in which case, no load balancing should be
	// performed
	PickWritePartition(
		domainID string,
		taskList types.TaskList,
		taskListType int,
		forwardedFrom string,
	) string

	// PickReadPartition returns the task list partition to send a poller to.
	// Input is name of the original task list as specified by caller. When
	// forwardedFrom is non-empty, no load balancing should be done.
	PickReadPartition(
		domainID string,
		taskList types.TaskList,
		taskListType int,
		forwardedFrom string,
	) string
}

LoadBalancer is the interface for implementers of component that distributes add/poll api calls across available task list partitions when possible

func NewLoadBalancer added in v0.7.0 

func NewLoadBalancer(
	domainIDToName func(string) (string, error),
	dc *dynamicconfig.Collection,
) LoadBalancer

NewLoadBalancer returns an instance of matching load balancer that can help distribute api calls across task list partitions

type MockClient added in v0.17.0 

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

MockClient is a mock of Client interface.

func NewMockClient added in v0.17.0 

func NewMockClient(ctrl *gomock.Controller) *MockClient

NewMockClient creates a new mock instance.

func (*MockClient) AddActivityTask added in v0.17.0 

func (m *MockClient) AddActivityTask(arg0 context.Context, arg1 *types.AddActivityTaskRequest, arg2 ...yarpc.CallOption) error

AddActivityTask mocks base method.

func (*MockClient) AddDecisionTask added in v0.17.0 

func (m *MockClient) AddDecisionTask(arg0 context.Context, arg1 *types.AddDecisionTaskRequest, arg2 ...yarpc.CallOption) error

AddDecisionTask mocks base method.

func (*MockClient) CancelOutstandingPoll added in v0.17.0 

func (m *MockClient) CancelOutstandingPoll(arg0 context.Context, arg1 *types.CancelOutstandingPollRequest, arg2 ...yarpc.CallOption) error

CancelOutstandingPoll mocks base method.

func (*MockClient) DescribeTaskList added in v0.17.0 

func (m *MockClient) DescribeTaskList(arg0 context.Context, arg1 *types.MatchingDescribeTaskListRequest, arg2 ...yarpc.CallOption) (*types.DescribeTaskListResponse, error)

DescribeTaskList mocks base method.

func (*MockClient) EXPECT added in v0.17.0 

func (m *MockClient) EXPECT() *MockClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockClient) GetTaskListsByDomain added in v0.23.1 

func (m *MockClient) GetTaskListsByDomain(arg0 context.Context, arg1 *types.GetTaskListsByDomainRequest, arg2 ...yarpc.CallOption) (*types.GetTaskListsByDomainResponse, error)

GetTaskListsByDomain mocks base method.

func (*MockClient) ListTaskListPartitions added in v0.17.0 

func (m *MockClient) ListTaskListPartitions(arg0 context.Context, arg1 *types.MatchingListTaskListPartitionsRequest, arg2 ...yarpc.CallOption) (*types.ListTaskListPartitionsResponse, error)

ListTaskListPartitions mocks base method.

func (*MockClient) PollForActivityTask added in v0.17.0 

func (m *MockClient) PollForActivityTask(arg0 context.Context, arg1 *types.MatchingPollForActivityTaskRequest, arg2 ...yarpc.CallOption) (*types.PollForActivityTaskResponse, error)

PollForActivityTask mocks base method.

func (*MockClient) PollForDecisionTask added in v0.17.0 

func (m *MockClient) PollForDecisionTask(arg0 context.Context, arg1 *types.MatchingPollForDecisionTaskRequest, arg2 ...yarpc.CallOption) (*types.MatchingPollForDecisionTaskResponse, error)

PollForDecisionTask mocks base method.

func (*MockClient) QueryWorkflow added in v0.17.0 

func (m *MockClient) QueryWorkflow(arg0 context.Context, arg1 *types.MatchingQueryWorkflowRequest, arg2 ...yarpc.CallOption) (*types.QueryWorkflowResponse, error)

QueryWorkflow mocks base method.

func (*MockClient) RespondQueryTaskCompleted added in v0.17.0 

func (m *MockClient) RespondQueryTaskCompleted(arg0 context.Context, arg1 *types.MatchingRespondQueryTaskCompletedRequest, arg2 ...yarpc.CallOption) error

RespondQueryTaskCompleted mocks base method.

type MockClientMockRecorder added in v0.17.0 

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

MockClientMockRecorder is the mock recorder for MockClient.

func (*MockClientMockRecorder) AddActivityTask added in v0.17.0 

func (mr *MockClientMockRecorder) AddActivityTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

AddActivityTask indicates an expected call of AddActivityTask.

func (*MockClientMockRecorder) AddDecisionTask added in v0.17.0 

func (mr *MockClientMockRecorder) AddDecisionTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

AddDecisionTask indicates an expected call of AddDecisionTask.

func (*MockClientMockRecorder) CancelOutstandingPoll added in v0.17.0 

func (mr *MockClientMockRecorder) CancelOutstandingPoll(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

CancelOutstandingPoll indicates an expected call of CancelOutstandingPoll.

func (*MockClientMockRecorder) DescribeTaskList added in v0.17.0 

func (mr *MockClientMockRecorder) DescribeTaskList(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

DescribeTaskList indicates an expected call of DescribeTaskList.

func (*MockClientMockRecorder) GetTaskListsByDomain added in v0.23.1 

func (mr *MockClientMockRecorder) GetTaskListsByDomain(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetTaskListsByDomain indicates an expected call of GetTaskListsByDomain.

func (*MockClientMockRecorder) ListTaskListPartitions added in v0.17.0 

func (mr *MockClientMockRecorder) ListTaskListPartitions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

ListTaskListPartitions indicates an expected call of ListTaskListPartitions.

func (*MockClientMockRecorder) PollForActivityTask added in v0.17.0 

func (mr *MockClientMockRecorder) PollForActivityTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PollForActivityTask indicates an expected call of PollForActivityTask.

func (*MockClientMockRecorder) PollForDecisionTask added in v0.17.0 

func (mr *MockClientMockRecorder) PollForDecisionTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

PollForDecisionTask indicates an expected call of PollForDecisionTask.

func (*MockClientMockRecorder) QueryWorkflow added in v0.17.0 

func (mr *MockClientMockRecorder) QueryWorkflow(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

QueryWorkflow indicates an expected call of QueryWorkflow.

func (*MockClientMockRecorder) RespondQueryTaskCompleted added in v0.17.0 

func (mr *MockClientMockRecorder) RespondQueryTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RespondQueryTaskCompleted indicates an expected call of RespondQueryTaskCompleted.

type PeerResolver added in v0.24.0 

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

PeerResolver is used to resolve matching peers. Those are deployed instances of Cadence matching services that participate in the cluster ring. The resulting peer is simply an address of form ip:port where RPC calls can be routed to.

func NewPeerResolver added in v0.24.0 

func NewPeerResolver(membership membership.Resolver, namedPort string) PeerResolver

NewPeerResolver creates a new matching peer resolver.

func (PeerResolver) FromHostAddress added in v0.24.0 

func (pr PeerResolver) FromHostAddress(hostAddress string) (string, error)

FromHostAddress resolves the final matching peer responsible for the given host address. The address may be used as is, or processed with additional address mapper. In case of gRPC transport, the port within the address is replaced with gRPC port.

func (PeerResolver) FromTaskList added in v0.24.0 

func (pr PeerResolver) FromTaskList(taskListName string) (string, error)

FromTaskList resolves the matching peer responsible for the given task list name. It uses our membership provider to lookup which instance currently owns the given task list. FromHostAddress is used for further resolving.

func (PeerResolver) GetAllPeers added in v0.24.0 

func (pr PeerResolver) GetAllPeers() ([]string, error)

GetAllPeers returns all matching service peers in the cluster ring.

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.