isolationgroup

Documentation

Overview

Package isolationgroup is a generated GoMock package.

Index

• type MockState
  • func NewMockState(ctrl *gomock.Controller) *MockState
  • func (m *MockState) AvailableIsolationGroupsByDomainID(ctx context.Context, domainID, tasklistName string, ...) (types.IsolationGroupConfiguration, error)
  • 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
  • func (mr *MockStateMockRecorder) AvailableIsolationGroupsByDomainID(ctx, domainID, tasklistName, availableIsolationGroups interface{}) *gomock.Call
  • func (mr *MockStateMockRecorder) IsDrained(ctx, Domain, IsolationGroup interface{}) *gomock.Call
  • func (mr *MockStateMockRecorder) IsDrainedByDomainID(ctx, DomainID, IsolationGroup interface{}) *gomock.Call
  • func (mr *MockStateMockRecorder) Start() *gomock.Call
  • func (mr *MockStateMockRecorder) Stop() *gomock.Call
• type State

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

func (m *MockState) AvailableIsolationGroupsByDomainID(ctx context.Context, domainID, tasklistName string, availableIsolationGroups []string) (types.IsolationGroupConfiguration, error)

AvailableIsolationGroupsByDomainID mocks base method.

func (*MockState) EXPECT

func (m *MockState) EXPECT() *MockStateMockRecorder

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

func (*MockState) IsDrained

func (m *MockState) IsDrained(ctx context.Context, Domain, IsolationGroup string) (bool, error)

IsDrained mocks base method.

func (*MockState) IsDrainedByDomainID

func (m *MockState) IsDrainedByDomainID(ctx context.Context, DomainID, IsolationGroup string) (bool, error)

IsDrainedByDomainID mocks base method.

func (*MockState) Start

func (m *MockState) Start()

Start mocks base method.

func (*MockState) Stop

func (m *MockState) Stop()

Stop mocks base method.

type MockStateMockRecorder

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

MockStateMockRecorder is the mock recorder for MockState.

func (*MockStateMockRecorder) AvailableIsolationGroupsByDomainID

func (mr *MockStateMockRecorder) AvailableIsolationGroupsByDomainID(ctx, domainID, tasklistName, availableIsolationGroups interface{}) *gomock.Call

AvailableIsolationGroupsByDomainID indicates an expected call of AvailableIsolationGroupsByDomainID.

func (*MockStateMockRecorder) IsDrained

func (mr *MockStateMockRecorder) IsDrained(ctx, Domain, IsolationGroup interface{}) *gomock.Call

IsDrained indicates an expected call of IsDrained.

func (*MockStateMockRecorder) IsDrainedByDomainID

func (mr *MockStateMockRecorder) IsDrainedByDomainID(ctx, DomainID, IsolationGroup interface{}) *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)

	// AvailableIsolationGroupsByDomainID returns the available isolation zones for a domain.
	// Takes into account global and domain zones
	AvailableIsolationGroupsByDomainID(ctx context.Context, domainID string, tasklistName string, availableIsolationGroups []string) (types.IsolationGroupConfiguration, 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.