Documentation ¶
Overview ¶
Package matching is a generated GoMock package.
Package matching is a generated GoMock package.
Package matching is a generated GoMock package.
Index ¶
- type Client
- type LoadBalancer
- func NewLoadBalancer(domainIDToName func(string) (string, error), dc *dynamicconfig.Collection) LoadBalancer
- func NewMultiLoadBalancer(defaultLoadBalancer LoadBalancer, loadBalancers map[string]LoadBalancer, ...) LoadBalancer
- func NewRoundRobinLoadBalancer(domainIDToName func(string) (string, error), dc *dynamicconfig.Collection) LoadBalancer
- func NewWeightedLoadBalancer(lb LoadBalancer, domainIDToName func(string) (string, error), ...) LoadBalancer
- type MockClient
- func (m *MockClient) AddActivityTask(arg0 context.Context, arg1 *types.AddActivityTaskRequest, ...) error
- func (m *MockClient) AddDecisionTask(arg0 context.Context, arg1 *types.AddDecisionTaskRequest, ...) error
- func (m *MockClient) CancelOutstandingPoll(arg0 context.Context, arg1 *types.CancelOutstandingPollRequest, ...) error
- func (m *MockClient) DescribeTaskList(arg0 context.Context, arg1 *types.MatchingDescribeTaskListRequest, ...) (*types.DescribeTaskListResponse, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) GetTaskListsByDomain(arg0 context.Context, arg1 *types.GetTaskListsByDomainRequest, ...) (*types.GetTaskListsByDomainResponse, error)
- func (m *MockClient) ListTaskListPartitions(arg0 context.Context, arg1 *types.MatchingListTaskListPartitionsRequest, ...) (*types.ListTaskListPartitionsResponse, error)
- func (m *MockClient) PollForActivityTask(arg0 context.Context, arg1 *types.MatchingPollForActivityTaskRequest, ...) (*types.MatchingPollForActivityTaskResponse, error)
- func (m *MockClient) PollForDecisionTask(arg0 context.Context, arg1 *types.MatchingPollForDecisionTaskRequest, ...) (*types.MatchingPollForDecisionTaskResponse, error)
- func (m *MockClient) QueryWorkflow(arg0 context.Context, arg1 *types.MatchingQueryWorkflowRequest, ...) (*types.QueryWorkflowResponse, error)
- func (m *MockClient) RespondQueryTaskCompleted(arg0 context.Context, arg1 *types.MatchingRespondQueryTaskCompletedRequest, ...) error
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) AddActivityTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) AddDecisionTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CancelOutstandingPoll(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DescribeTaskList(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetTaskListsByDomain(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) ListTaskListPartitions(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) PollForActivityTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) PollForDecisionTask(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryWorkflow(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) RespondQueryTaskCompleted(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- type MockLoadBalancer
- func (m *MockLoadBalancer) EXPECT() *MockLoadBalancerMockRecorder
- func (m *MockLoadBalancer) PickReadPartition(domainID string, taskList types.TaskList, taskListType int, ...) string
- func (m *MockLoadBalancer) PickWritePartition(domainID string, taskList types.TaskList, taskListType int, ...) string
- func (m *MockLoadBalancer) UpdateWeight(domainID string, taskList types.TaskList, taskListType int, ...)
- type MockLoadBalancerMockRecorder
- func (mr *MockLoadBalancerMockRecorder) PickReadPartition(domainID, taskList, taskListType, forwardedFrom interface{}) *gomock.Call
- func (mr *MockLoadBalancerMockRecorder) PickWritePartition(domainID, taskList, taskListType, forwardedFrom interface{}) *gomock.Call
- func (mr *MockLoadBalancerMockRecorder) UpdateWeight(domainID, taskList, taskListType, forwardedFrom, partition, weight interface{}) *gomock.Call
- type MockPeerResolver
- type MockPeerResolverMockRecorder
- type PeerResolver
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) 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.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 }
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 // 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, weight int64, ) }
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
func NewMultiLoadBalancer ¶
func NewMultiLoadBalancer( defaultLoadBalancer LoadBalancer, loadBalancers map[string]LoadBalancer, domainIDToName func(string) (string, error), dc *dynamicconfig.Collection, logger log.Logger, ) LoadBalancer
func NewRoundRobinLoadBalancer ¶
func NewRoundRobinLoadBalancer( domainIDToName func(string) (string, error), dc *dynamicconfig.Collection, ) LoadBalancer
func NewWeightedLoadBalancer ¶
func NewWeightedLoadBalancer( lb LoadBalancer, domainIDToName func(string) (string, error), dc *dynamicconfig.Collection, 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) 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.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) 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
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 ¶
func (m *MockLoadBalancer) UpdateWeight(domainID string, taskList types.TaskList, taskListType int, forwardedFrom, partition string, weight int64)
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 ¶
func (mr *MockLoadBalancerMockRecorder) UpdateWeight(domainID, taskList, taskListType, forwardedFrom, partition, weight interface{}) *gomock.Call
UpdateWeight indicates an expected call of UpdateWeight.
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 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.