matching

package
v1.2.11-prerelease6 Latest Latest
Warning

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

Go to latest
Published: Jun 21, 2024 License: MIT Imports: 14 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.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

Client is the interface exposed by types service client

func NewClient

func NewClient(
	client Client,
	peerResolver PeerResolver,
	lb LoadBalancer,
) 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
}

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

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

GetTaskListsByDomain mocks base method.

func (*MockClient) ListTaskListPartitions added in v0.17.0

ListTaskListPartitions mocks base method.

func (*MockClient) PollForActivityTask added in v0.17.0

PollForActivityTask mocks base method.

func (*MockClient) PollForDecisionTask added in v0.17.0

PollForDecisionTask mocks base method.

func (*MockClient) QueryWorkflow added in v0.17.0

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

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

func (*MockLoadBalancer) PickReadPartition added in v1.2.10

func (m *MockLoadBalancer) PickReadPartition(arg0 string, arg1 types.TaskList, arg2 int, arg3 string) string

PickReadPartition mocks base method.

func (*MockLoadBalancer) PickWritePartition added in v1.2.10

func (m *MockLoadBalancer) PickWritePartition(arg0 string, arg1 types.TaskList, arg2 int, arg3 string) string

PickWritePartition 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(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

PickReadPartition indicates an expected call of PickReadPartition.

func (*MockLoadBalancerMockRecorder) PickWritePartition added in v1.2.10

func (mr *MockLoadBalancerMockRecorder) PickWritePartition(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

PickWritePartition indicates an expected call of PickWritePartition.

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL