matching

package
v1.2.15-prerelease06 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2024 License: MIT Imports: 24 Imported by: 10

Documentation

Overview

Package matching is a generated GoMock package.

Package matching is a generated GoMock package.

Package matching is a generated GoMock package.

Package matching is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client 

type Client interface {
	AddActivityTask(context.Context, *types.AddActivityTaskRequest, ...yarpc.CallOption) (*types.AddActivityTaskResponse, error)
	AddDecisionTask(context.Context, *types.AddDecisionTaskRequest, ...yarpc.CallOption) (*types.AddDecisionTaskResponse, 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.MatchingPollForActivityTaskResponse, 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
	UpdateTaskListPartitionConfig(context.Context, *types.MatchingUpdateTaskListPartitionConfigRequest, ...yarpc.CallOption) (*types.MatchingUpdateTaskListPartitionConfigResponse, error)
	RefreshTaskListPartitionConfig(context.Context, *types.MatchingRefreshTaskListPartitionConfigRequest, ...yarpc.CallOption) (*types.MatchingRefreshTaskListPartitionConfigResponse, error)
}

Client is the interface exposed by types service client

func NewClient 

func NewClient(
	client Client,
	peerResolver PeerResolver,
	lb LoadBalancer,
	provider PartitionConfigProvider,
) Client

NewClient creates a new history service TChannel client

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

	// UpdateWeight updates the weight of a task list partition.
	// Input is name of the original task list as specified by caller. When
	// the original task list is a partition, no update should be done.
	UpdateWeight(
		domainID string,
		taskList types.TaskList,
		taskListType int,
		forwardedFrom string,
		partition string,
		info *types.LoadBalancerHints,
	)
}

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(
	provider PartitionConfigProvider,
) LoadBalancer

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

func NewMultiLoadBalancer added in v1.2.14 

func NewMultiLoadBalancer(
	defaultLoadBalancer LoadBalancer,
	loadBalancers map[string]LoadBalancer,
	domainIDToName func(string) (string, error),
	dc *dynamicconfig.Collection,
	logger log.Logger,
) LoadBalancer

func NewRoundRobinLoadBalancer added in v1.2.14 

func NewRoundRobinLoadBalancer(
	provider PartitionConfigProvider,
) LoadBalancer

func NewWeightedLoadBalancer added in v1.2.14 

func NewWeightedLoadBalancer(
	lb LoadBalancer,
	provider PartitionConfigProvider,
	logger log.Logger,
) LoadBalancer

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) (*types.AddActivityTaskResponse, 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) (*types.AddDecisionTaskResponse, 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.MatchingPollForActivityTaskResponse, 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) RefreshTaskListPartitionConfig 

func (m *MockClient) RefreshTaskListPartitionConfig(arg0 context.Context, arg1 *types.MatchingRefreshTaskListPartitionConfigRequest, arg2 ...yarpc.CallOption) (*types.MatchingRefreshTaskListPartitionConfigResponse, error)

RefreshTaskListPartitionConfig 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.

func (*MockClient) UpdateTaskListPartitionConfig 

func (m *MockClient) UpdateTaskListPartitionConfig(arg0 context.Context, arg1 *types.MatchingUpdateTaskListPartitionConfigRequest, arg2 ...yarpc.CallOption) (*types.MatchingUpdateTaskListPartitionConfigResponse, error)

UpdateTaskListPartitionConfig 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) RefreshTaskListPartitionConfig 

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

RefreshTaskListPartitionConfig indicates an expected call of RefreshTaskListPartitionConfig.

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.

func (*MockClientMockRecorder) UpdateTaskListPartitionConfig 

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

UpdateTaskListPartitionConfig indicates an expected call of UpdateTaskListPartitionConfig.

type MockLoadBalancer added in v1.2.10 

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

MockLoadBalancer is a mock of LoadBalancer interface.

func NewMockLoadBalancer added in v1.2.10 

func NewMockLoadBalancer(ctrl *gomock.Controller) *MockLoadBalancer

NewMockLoadBalancer creates a new mock instance.

func (*MockLoadBalancer) EXPECT added in v1.2.10 

func (m *MockLoadBalancer) EXPECT() *MockLoadBalancerMockRecorder

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

func (*MockLoadBalancer) PickReadPartition added in v1.2.10 

func (m *MockLoadBalancer) PickReadPartition(domainID string, taskList types.TaskList, taskListType int, forwardedFrom string) string

PickReadPartition mocks base method.

func (*MockLoadBalancer) PickWritePartition added in v1.2.10 

func (m *MockLoadBalancer) PickWritePartition(domainID string, taskList types.TaskList, taskListType int, forwardedFrom string) string

PickWritePartition mocks base method.

func (*MockLoadBalancer) UpdateWeight added in v1.2.14 

func (m *MockLoadBalancer) UpdateWeight(domainID string, taskList types.TaskList, taskListType int, forwardedFrom, partition string, info *types.LoadBalancerHints)

UpdateWeight mocks base method.

type MockLoadBalancerMockRecorder added in v1.2.10 

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

MockLoadBalancerMockRecorder is the mock recorder for MockLoadBalancer.

func (*MockLoadBalancerMockRecorder) PickReadPartition added in v1.2.10 

func (mr *MockLoadBalancerMockRecorder) PickReadPartition(domainID, taskList, taskListType, forwardedFrom interface{}) *gomock.Call

PickReadPartition indicates an expected call of PickReadPartition.

func (*MockLoadBalancerMockRecorder) PickWritePartition added in v1.2.10 

func (mr *MockLoadBalancerMockRecorder) PickWritePartition(domainID, taskList, taskListType, forwardedFrom interface{}) *gomock.Call

PickWritePartition indicates an expected call of PickWritePartition.

func (*MockLoadBalancerMockRecorder) UpdateWeight added in v1.2.14 

func (mr *MockLoadBalancerMockRecorder) UpdateWeight(domainID, taskList, taskListType, forwardedFrom, partition, info interface{}) *gomock.Call

UpdateWeight indicates an expected call of UpdateWeight.

type MockPartitionConfigProvider 

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

MockPartitionConfigProvider is a mock of PartitionConfigProvider interface.

func NewMockPartitionConfigProvider 

func NewMockPartitionConfigProvider(ctrl *gomock.Controller) *MockPartitionConfigProvider

NewMockPartitionConfigProvider creates a new mock instance.

func (*MockPartitionConfigProvider) EXPECT 

func (m *MockPartitionConfigProvider) EXPECT() *MockPartitionConfigProviderMockRecorder

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

func (*MockPartitionConfigProvider) GetNumberOfReadPartitions 

func (m *MockPartitionConfigProvider) GetNumberOfReadPartitions(domainID string, taskList types.TaskList, taskListType int) int

GetNumberOfReadPartitions mocks base method.

func (*MockPartitionConfigProvider) GetNumberOfWritePartitions 

func (m *MockPartitionConfigProvider) GetNumberOfWritePartitions(domainID string, taskList types.TaskList, taskListType int) int

GetNumberOfWritePartitions mocks base method.

func (*MockPartitionConfigProvider) UpdatePartitionConfig 

func (m *MockPartitionConfigProvider) UpdatePartitionConfig(domainID string, taskList types.TaskList, taskListType int, config *types.TaskListPartitionConfig)

UpdatePartitionConfig mocks base method.

type MockPartitionConfigProviderMockRecorder 

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

MockPartitionConfigProviderMockRecorder is the mock recorder for MockPartitionConfigProvider.

func (*MockPartitionConfigProviderMockRecorder) GetNumberOfReadPartitions 

func (mr *MockPartitionConfigProviderMockRecorder) GetNumberOfReadPartitions(domainID, taskList, taskListType interface{}) *gomock.Call

GetNumberOfReadPartitions indicates an expected call of GetNumberOfReadPartitions.

func (*MockPartitionConfigProviderMockRecorder) GetNumberOfWritePartitions 

func (mr *MockPartitionConfigProviderMockRecorder) GetNumberOfWritePartitions(domainID, taskList, taskListType interface{}) *gomock.Call

GetNumberOfWritePartitions indicates an expected call of GetNumberOfWritePartitions.

func (*MockPartitionConfigProviderMockRecorder) UpdatePartitionConfig 

func (mr *MockPartitionConfigProviderMockRecorder) UpdatePartitionConfig(domainID, taskList, taskListType, config interface{}) *gomock.Call

UpdatePartitionConfig indicates an expected call of UpdatePartitionConfig.

type MockPeerResolver added in v1.2.10 

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

MockPeerResolver is a mock of PeerResolver interface.

func NewMockPeerResolver added in v1.2.10 

func NewMockPeerResolver(ctrl *gomock.Controller) *MockPeerResolver

NewMockPeerResolver creates a new mock instance.

func (*MockPeerResolver) EXPECT added in v1.2.10 

func (m *MockPeerResolver) EXPECT() *MockPeerResolverMockRecorder

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

func (*MockPeerResolver) FromHostAddress added in v1.2.10 

func (m *MockPeerResolver) FromHostAddress(hostAddress string) (string, error)

FromHostAddress mocks base method.

func (*MockPeerResolver) FromTaskList added in v1.2.10 

func (m *MockPeerResolver) FromTaskList(taskListName string) (string, error)

FromTaskList mocks base method.

func (*MockPeerResolver) GetAllPeers added in v1.2.10 

func (m *MockPeerResolver) GetAllPeers() ([]string, error)

GetAllPeers mocks base method.

type MockPeerResolverMockRecorder added in v1.2.10 

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

MockPeerResolverMockRecorder is the mock recorder for MockPeerResolver.

func (*MockPeerResolverMockRecorder) FromHostAddress added in v1.2.10 

func (mr *MockPeerResolverMockRecorder) FromHostAddress(hostAddress interface{}) *gomock.Call

FromHostAddress indicates an expected call of FromHostAddress.

func (*MockPeerResolverMockRecorder) FromTaskList added in v1.2.10 

func (mr *MockPeerResolverMockRecorder) FromTaskList(taskListName interface{}) *gomock.Call

FromTaskList indicates an expected call of FromTaskList.

func (*MockPeerResolverMockRecorder) GetAllPeers added in v1.2.10 

func (mr *MockPeerResolverMockRecorder) GetAllPeers() *gomock.Call

GetAllPeers indicates an expected call of GetAllPeers.

type PartitionConfigProvider 

type PartitionConfigProvider interface {
	// GetNumberOfReadPartitions returns the number of read partitions
	GetNumberOfReadPartitions(domainID string, taskList types.TaskList, taskListType int) int
	// GetNumberOfWritePartitions returns the number of write partitions
	GetNumberOfWritePartitions(domainID string, taskList types.TaskList, taskListType int) int
	// UpdatePartitionConfig updates the partition configuration for a task list
	UpdatePartitionConfig(domainID string, taskList types.TaskList, taskListType int, config *types.TaskListPartitionConfig)
}

PartitionConfigProvider is the interface for implementers of component that provides partition configuration for task list partitions

func NewPartitionConfigProvider 

func NewPartitionConfigProvider(
	logger log.Logger,
	metricsClient metrics.Client,
	domainIDToName func(string) (string, error),
	dc *dynamicconfig.Collection,
) PartitionConfigProvider

type PeerResolver added in v0.24.0 

type PeerResolver interface {
	FromTaskList(taskListName string) (string, error)
	GetAllPeers() ([]string, error)
	FromHostAddress(hostAddress string) (string, error)
}

func NewPeerResolver added in v0.24.0 

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

NewPeerResolver creates a new matching peer resolver.

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.