Documentation
¶
Overview ¶
Package isolationgroup is a generated GoMock package.
Index ¶
- Constants
- func ConfigFromContext(ctx context.Context) map[string]string
- func ContextWithConfig(ctx context.Context, partitionConfig map[string]string) context.Context
- func ContextWithIsolationGroup(ctx context.Context, isolationGroup string) context.Context
- func IsolationGroupFromContext(ctx context.Context) string
- type MockState
- func (m *MockState) EXPECT() *MockStateMockRecorder
- func (m *MockState) IsDrained(ctx context.Context, Domain, IsolationGroup string) (bool, error)
- func (m *MockState) IsDrainedByDomainID(ctx context.Context, DomainID, IsolationGroup string) (bool, error)
- func (m *MockState) Start()
- func (m *MockState) Stop()
- type MockStateMockRecorder
- type State
Constants ¶
const ( GroupKey = "isolation-group" OriginalGroupKey = "original-isolation-group" WorkflowIDKey = "wf-id" )
Variables ¶
This section is empty.
Functions ¶
func ConfigFromContext ¶ added in v1.3.0
ConfigFromContext retrieves infomation about the partition config of the context which is used for tasklist isolation
func ContextWithConfig ¶ added in v1.3.0
ContextWithConfig stores the partition config of tasklist isolation into the given context
func ContextWithIsolationGroup ¶ added in v1.3.0
ContextWithIsolationGroup stores the isolation group into the given context
func IsolationGroupFromContext ¶ added in v1.3.0
IsolationGroupFromContext retrieves the isolation group from the given context, which is used to identify which isolation group the poller is from
Types ¶
type MockState ¶
type MockState struct {
// contains filtered or unexported fields
}
MockState is a mock of State interface.
func NewMockState ¶
func NewMockState(ctrl *gomock.Controller) *MockState
NewMockState creates a new mock instance.
func (*MockState) EXPECT ¶
func (m *MockState) EXPECT() *MockStateMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockStateMockRecorder ¶
type MockStateMockRecorder struct {
// contains filtered or unexported fields
}
MockStateMockRecorder is the mock recorder for MockState.
func (*MockStateMockRecorder) IsDrained ¶
func (mr *MockStateMockRecorder) IsDrained(ctx, Domain, IsolationGroup any) *gomock.Call
IsDrained indicates an expected call of IsDrained.
func (*MockStateMockRecorder) IsDrainedByDomainID ¶
func (mr *MockStateMockRecorder) IsDrainedByDomainID(ctx, DomainID, IsolationGroup any) *gomock.Call
IsDrainedByDomainID indicates an expected call of IsDrainedByDomainID.
func (*MockStateMockRecorder) Start ¶
func (mr *MockStateMockRecorder) Start() *gomock.Call
Start indicates an expected call of Start.
func (*MockStateMockRecorder) Stop ¶
func (mr *MockStateMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
type State ¶
type State interface {
common.Daemon
// IsDrained answers the question - "is this particular isolationGroup drained?". Used by startWorkflow calls
// and similar sync frontend calls to make routing decisions
IsDrained(ctx context.Context, Domain string, IsolationGroup string) (bool, error)
IsDrainedByDomainID(ctx context.Context, DomainID string, IsolationGroup string) (bool, error)
}
State is a heavily cached in-memory library for returning the state of what zones are healthy or drained presently. It may return an inclusive (allow-list based) or an exclusive (deny-list based) set of IsolationGroups depending on the implementation.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package isolationgroupapi is a generated GoMock package.
|
Package isolationgroupapi is a generated GoMock package. |