Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockConcurrencyLimiter
- func (m *MockConcurrencyLimiter) EXPECT() *MockConcurrencyLimiterMockRecorder
- func (m *MockConcurrencyLimiter) GetLimiterID() iface.LimiterID
- func (m *MockConcurrencyLimiter) GetObserver(labels map[string]string) prometheus.Observer
- func (m *MockConcurrencyLimiter) GetPolicyName() string
- func (m *MockConcurrencyLimiter) GetSelector() *selectorv1.Selector
- func (m *MockConcurrencyLimiter) RunLimiter(labels map[string]string) *flowcontrolv1.LimiterDecision
- type MockConcurrencyLimiterMockRecorder
- func (mr *MockConcurrencyLimiterMockRecorder) GetLimiterID() *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) GetObserver(labels interface{}) *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) GetPolicyName() *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) GetSelector() *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) RunLimiter(labels interface{}) *gomock.Call
- type MockEngine
- func (m *MockEngine) EXPECT() *MockEngineMockRecorder
- func (m *MockEngine) GetConcurrencyLimiter(limiterID iface.LimiterID) iface.ConcurrencyLimiter
- func (m *MockEngine) GetFluxMeter(fluxMeterName string) iface.FluxMeter
- func (m *MockEngine) GetRateLimiter(limiterID iface.LimiterID) iface.RateLimiter
- func (m *MockEngine) ProcessRequest(controlPoint selectors.ControlPoint, serviceIDs []string, ...) *flowcontrolv1.CheckResponse
- func (m *MockEngine) RegisterConcurrencyLimiter(sa iface.ConcurrencyLimiter) error
- func (m *MockEngine) RegisterFluxMeter(fm iface.FluxMeter) error
- func (m *MockEngine) RegisterRateLimiter(l iface.RateLimiter) error
- func (m *MockEngine) UnregisterConcurrencyLimiter(sa iface.ConcurrencyLimiter) error
- func (m *MockEngine) UnregisterFluxMeter(fm iface.FluxMeter) error
- func (m *MockEngine) UnregisterRateLimiter(l iface.RateLimiter) error
- type MockEngineMockRecorder
- func (mr *MockEngineMockRecorder) GetConcurrencyLimiter(limiterID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetFluxMeter(fluxMeterName interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetRateLimiter(limiterID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ProcessRequest(controlPoint, serviceIDs, labels interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterConcurrencyLimiter(sa interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterFluxMeter(fm interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterRateLimiter(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterConcurrencyLimiter(sa interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterFluxMeter(fm interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterRateLimiter(l interface{}) *gomock.Call
- type MockFluxMeter
- func (m *MockFluxMeter) EXPECT() *MockFluxMeterMockRecorder
- func (m *MockFluxMeter) GetAttributeKey() string
- func (m *MockFluxMeter) GetFluxMeterID() iface.FluxMeterID
- func (m *MockFluxMeter) GetFluxMeterName() string
- func (m *MockFluxMeter) GetHistogram(decisionType flowcontrolv1.CheckResponse_DecisionType, ...) prometheus.Observer
- func (m *MockFluxMeter) GetSelector() *selectorv1.Selector
- type MockFluxMeterMockRecorder
- func (mr *MockFluxMeterMockRecorder) GetAttributeKey() *gomock.Call
- func (mr *MockFluxMeterMockRecorder) GetFluxMeterID() *gomock.Call
- func (mr *MockFluxMeterMockRecorder) GetFluxMeterName() *gomock.Call
- func (mr *MockFluxMeterMockRecorder) GetHistogram(decisionType, statusCode, featureStatus interface{}) *gomock.Call
- func (mr *MockFluxMeterMockRecorder) GetSelector() *gomock.Call
- type MockLimiter
- func (m *MockLimiter) EXPECT() *MockLimiterMockRecorder
- func (m *MockLimiter) GetLimiterID() iface.LimiterID
- func (m *MockLimiter) GetPolicyName() string
- func (m *MockLimiter) GetSelector() *selectorv1.Selector
- func (m *MockLimiter) RunLimiter(labels map[string]string) *flowcontrolv1.LimiterDecision
- type MockLimiterMockRecorder
- type MockRateLimiter
- func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder
- func (m *MockRateLimiter) GetCounter() prometheus.Counter
- func (m *MockRateLimiter) GetLimiterID() iface.LimiterID
- func (m *MockRateLimiter) GetPolicyName() string
- func (m *MockRateLimiter) GetSelector() *selectorv1.Selector
- func (m *MockRateLimiter) RunLimiter(labels map[string]string) *flowcontrolv1.LimiterDecision
- func (m *MockRateLimiter) TakeN(labels map[string]string, count int) (string, bool, int, int)
- type MockRateLimiterMockRecorder
- func (mr *MockRateLimiterMockRecorder) GetCounter() *gomock.Call
- func (mr *MockRateLimiterMockRecorder) GetLimiterID() *gomock.Call
- func (mr *MockRateLimiterMockRecorder) GetPolicyName() *gomock.Call
- func (mr *MockRateLimiterMockRecorder) GetSelector() *gomock.Call
- func (mr *MockRateLimiterMockRecorder) RunLimiter(labels interface{}) *gomock.Call
- func (mr *MockRateLimiterMockRecorder) TakeN(labels, count interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockConcurrencyLimiter ¶ added in v0.5.0
type MockConcurrencyLimiter struct {
// contains filtered or unexported fields
}
MockConcurrencyLimiter is a mock of ConcurrencyLimiter interface.
func NewMockConcurrencyLimiter ¶ added in v0.5.0
func NewMockConcurrencyLimiter(ctrl *gomock.Controller) *MockConcurrencyLimiter
NewMockConcurrencyLimiter creates a new mock instance.
func (*MockConcurrencyLimiter) EXPECT ¶ added in v0.5.0
func (m *MockConcurrencyLimiter) EXPECT() *MockConcurrencyLimiterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConcurrencyLimiter) GetLimiterID ¶ added in v0.5.0
func (m *MockConcurrencyLimiter) GetLimiterID() iface.LimiterID
GetLimiterID mocks base method.
func (*MockConcurrencyLimiter) GetObserver ¶ added in v0.5.0
func (m *MockConcurrencyLimiter) GetObserver(labels map[string]string) prometheus.Observer
GetObserver mocks base method.
func (*MockConcurrencyLimiter) GetPolicyName ¶ added in v0.5.0
func (m *MockConcurrencyLimiter) GetPolicyName() string
GetPolicyName mocks base method.
func (*MockConcurrencyLimiter) GetSelector ¶ added in v0.5.0
func (m *MockConcurrencyLimiter) GetSelector() *selectorv1.Selector
GetSelector mocks base method.
func (*MockConcurrencyLimiter) RunLimiter ¶ added in v0.5.0
func (m *MockConcurrencyLimiter) RunLimiter(labels map[string]string) *flowcontrolv1.LimiterDecision
RunLimiter mocks base method.
type MockConcurrencyLimiterMockRecorder ¶ added in v0.5.0
type MockConcurrencyLimiterMockRecorder struct {
// contains filtered or unexported fields
}
MockConcurrencyLimiterMockRecorder is the mock recorder for MockConcurrencyLimiter.
func (*MockConcurrencyLimiterMockRecorder) GetLimiterID ¶ added in v0.5.0
func (mr *MockConcurrencyLimiterMockRecorder) GetLimiterID() *gomock.Call
GetLimiterID indicates an expected call of GetLimiterID.
func (*MockConcurrencyLimiterMockRecorder) GetObserver ¶ added in v0.5.0
func (mr *MockConcurrencyLimiterMockRecorder) GetObserver(labels interface{}) *gomock.Call
GetObserver indicates an expected call of GetObserver.
func (*MockConcurrencyLimiterMockRecorder) GetPolicyName ¶ added in v0.5.0
func (mr *MockConcurrencyLimiterMockRecorder) GetPolicyName() *gomock.Call
GetPolicyName indicates an expected call of GetPolicyName.
func (*MockConcurrencyLimiterMockRecorder) GetSelector ¶ added in v0.5.0
func (mr *MockConcurrencyLimiterMockRecorder) GetSelector() *gomock.Call
GetSelector indicates an expected call of GetSelector.
func (*MockConcurrencyLimiterMockRecorder) RunLimiter ¶ added in v0.5.0
func (mr *MockConcurrencyLimiterMockRecorder) RunLimiter(labels interface{}) *gomock.Call
RunLimiter indicates an expected call of RunLimiter.
type MockEngine ¶
type MockEngine struct {
// contains filtered or unexported fields
}
MockEngine is a mock of Engine interface.
func NewMockEngine ¶
func NewMockEngine(ctrl *gomock.Controller) *MockEngine
NewMockEngine creates a new mock instance.
func (*MockEngine) EXPECT ¶
func (m *MockEngine) EXPECT() *MockEngineMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockEngine) GetConcurrencyLimiter ¶ added in v0.4.0
func (m *MockEngine) GetConcurrencyLimiter(limiterID iface.LimiterID) iface.ConcurrencyLimiter
GetConcurrencyLimiter mocks base method.
func (*MockEngine) GetFluxMeter ¶ added in v0.1.3
func (m *MockEngine) GetFluxMeter(fluxMeterName string) iface.FluxMeter
GetFluxMeter mocks base method.
func (*MockEngine) GetRateLimiter ¶ added in v0.5.0
func (m *MockEngine) GetRateLimiter(limiterID iface.LimiterID) iface.RateLimiter
GetRateLimiter mocks base method.
func (*MockEngine) ProcessRequest ¶
func (m *MockEngine) ProcessRequest(controlPoint selectors.ControlPoint, serviceIDs []string, labels map[string]string) *flowcontrolv1.CheckResponse
ProcessRequest mocks base method.
func (*MockEngine) RegisterConcurrencyLimiter ¶
func (m *MockEngine) RegisterConcurrencyLimiter(sa iface.ConcurrencyLimiter) error
RegisterConcurrencyLimiter mocks base method.
func (*MockEngine) RegisterFluxMeter ¶
func (m *MockEngine) RegisterFluxMeter(fm iface.FluxMeter) error
RegisterFluxMeter mocks base method.
func (*MockEngine) RegisterRateLimiter ¶
func (m *MockEngine) RegisterRateLimiter(l iface.RateLimiter) error
RegisterRateLimiter mocks base method.
func (*MockEngine) UnregisterConcurrencyLimiter ¶
func (m *MockEngine) UnregisterConcurrencyLimiter(sa iface.ConcurrencyLimiter) error
UnregisterConcurrencyLimiter mocks base method.
func (*MockEngine) UnregisterFluxMeter ¶
func (m *MockEngine) UnregisterFluxMeter(fm iface.FluxMeter) error
UnregisterFluxMeter mocks base method.
func (*MockEngine) UnregisterRateLimiter ¶
func (m *MockEngine) UnregisterRateLimiter(l iface.RateLimiter) error
UnregisterRateLimiter mocks base method.
type MockEngineMockRecorder ¶
type MockEngineMockRecorder struct {
// contains filtered or unexported fields
}
MockEngineMockRecorder is the mock recorder for MockEngine.
func (*MockEngineMockRecorder) GetConcurrencyLimiter ¶ added in v0.4.0
func (mr *MockEngineMockRecorder) GetConcurrencyLimiter(limiterID interface{}) *gomock.Call
GetConcurrencyLimiter indicates an expected call of GetConcurrencyLimiter.
func (*MockEngineMockRecorder) GetFluxMeter ¶ added in v0.1.3
func (mr *MockEngineMockRecorder) GetFluxMeter(fluxMeterName interface{}) *gomock.Call
GetFluxMeter indicates an expected call of GetFluxMeter.
func (*MockEngineMockRecorder) GetRateLimiter ¶ added in v0.5.0
func (mr *MockEngineMockRecorder) GetRateLimiter(limiterID interface{}) *gomock.Call
GetRateLimiter indicates an expected call of GetRateLimiter.
func (*MockEngineMockRecorder) ProcessRequest ¶
func (mr *MockEngineMockRecorder) ProcessRequest(controlPoint, serviceIDs, labels interface{}) *gomock.Call
ProcessRequest indicates an expected call of ProcessRequest.
func (*MockEngineMockRecorder) RegisterConcurrencyLimiter ¶
func (mr *MockEngineMockRecorder) RegisterConcurrencyLimiter(sa interface{}) *gomock.Call
RegisterConcurrencyLimiter indicates an expected call of RegisterConcurrencyLimiter.
func (*MockEngineMockRecorder) RegisterFluxMeter ¶
func (mr *MockEngineMockRecorder) RegisterFluxMeter(fm interface{}) *gomock.Call
RegisterFluxMeter indicates an expected call of RegisterFluxMeter.
func (*MockEngineMockRecorder) RegisterRateLimiter ¶
func (mr *MockEngineMockRecorder) RegisterRateLimiter(l interface{}) *gomock.Call
RegisterRateLimiter indicates an expected call of RegisterRateLimiter.
func (*MockEngineMockRecorder) UnregisterConcurrencyLimiter ¶
func (mr *MockEngineMockRecorder) UnregisterConcurrencyLimiter(sa interface{}) *gomock.Call
UnregisterConcurrencyLimiter indicates an expected call of UnregisterConcurrencyLimiter.
func (*MockEngineMockRecorder) UnregisterFluxMeter ¶
func (mr *MockEngineMockRecorder) UnregisterFluxMeter(fm interface{}) *gomock.Call
UnregisterFluxMeter indicates an expected call of UnregisterFluxMeter.
func (*MockEngineMockRecorder) UnregisterRateLimiter ¶
func (mr *MockEngineMockRecorder) UnregisterRateLimiter(l interface{}) *gomock.Call
UnregisterRateLimiter indicates an expected call of UnregisterRateLimiter.
type MockFluxMeter ¶
type MockFluxMeter struct {
// contains filtered or unexported fields
}
MockFluxMeter is a mock of FluxMeter interface.
func NewMockFluxMeter ¶
func NewMockFluxMeter(ctrl *gomock.Controller) *MockFluxMeter
NewMockFluxMeter creates a new mock instance.
func (*MockFluxMeter) EXPECT ¶
func (m *MockFluxMeter) EXPECT() *MockFluxMeterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockFluxMeter) GetAttributeKey ¶ added in v0.1.3
func (m *MockFluxMeter) GetAttributeKey() string
GetAttributeKey mocks base method.
func (*MockFluxMeter) GetFluxMeterID ¶
func (m *MockFluxMeter) GetFluxMeterID() iface.FluxMeterID
GetFluxMeterID mocks base method.
func (*MockFluxMeter) GetFluxMeterName ¶
func (m *MockFluxMeter) GetFluxMeterName() string
GetFluxMeterName mocks base method.
func (*MockFluxMeter) GetHistogram ¶
func (m *MockFluxMeter) GetHistogram(decisionType flowcontrolv1.CheckResponse_DecisionType, statusCode, featureStatus string) prometheus.Observer
GetHistogram mocks base method.
func (*MockFluxMeter) GetSelector ¶
func (m *MockFluxMeter) GetSelector() *selectorv1.Selector
GetSelector mocks base method.
type MockFluxMeterMockRecorder ¶
type MockFluxMeterMockRecorder struct {
// contains filtered or unexported fields
}
MockFluxMeterMockRecorder is the mock recorder for MockFluxMeter.
func (*MockFluxMeterMockRecorder) GetAttributeKey ¶ added in v0.1.3
func (mr *MockFluxMeterMockRecorder) GetAttributeKey() *gomock.Call
GetAttributeKey indicates an expected call of GetAttributeKey.
func (*MockFluxMeterMockRecorder) GetFluxMeterID ¶
func (mr *MockFluxMeterMockRecorder) GetFluxMeterID() *gomock.Call
GetFluxMeterID indicates an expected call of GetFluxMeterID.
func (*MockFluxMeterMockRecorder) GetFluxMeterName ¶
func (mr *MockFluxMeterMockRecorder) GetFluxMeterName() *gomock.Call
GetFluxMeterName indicates an expected call of GetFluxMeterName.
func (*MockFluxMeterMockRecorder) GetHistogram ¶
func (mr *MockFluxMeterMockRecorder) GetHistogram(decisionType, statusCode, featureStatus interface{}) *gomock.Call
GetHistogram indicates an expected call of GetHistogram.
func (*MockFluxMeterMockRecorder) GetSelector ¶
func (mr *MockFluxMeterMockRecorder) GetSelector() *gomock.Call
GetSelector indicates an expected call of GetSelector.
type MockLimiter ¶
type MockLimiter struct {
// contains filtered or unexported fields
}
MockLimiter is a mock of Limiter interface.
func NewMockLimiter ¶
func NewMockLimiter(ctrl *gomock.Controller) *MockLimiter
NewMockLimiter creates a new mock instance.
func (*MockLimiter) EXPECT ¶
func (m *MockLimiter) EXPECT() *MockLimiterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockLimiter) GetLimiterID ¶
func (m *MockLimiter) GetLimiterID() iface.LimiterID
GetLimiterID mocks base method.
func (*MockLimiter) GetPolicyName ¶
func (m *MockLimiter) GetPolicyName() string
GetPolicyName mocks base method.
func (*MockLimiter) GetSelector ¶
func (m *MockLimiter) GetSelector() *selectorv1.Selector
GetSelector mocks base method.
func (*MockLimiter) RunLimiter ¶
func (m *MockLimiter) RunLimiter(labels map[string]string) *flowcontrolv1.LimiterDecision
RunLimiter mocks base method.
type MockLimiterMockRecorder ¶
type MockLimiterMockRecorder struct {
// contains filtered or unexported fields
}
MockLimiterMockRecorder is the mock recorder for MockLimiter.
func (*MockLimiterMockRecorder) GetLimiterID ¶
func (mr *MockLimiterMockRecorder) GetLimiterID() *gomock.Call
GetLimiterID indicates an expected call of GetLimiterID.
func (*MockLimiterMockRecorder) GetPolicyName ¶
func (mr *MockLimiterMockRecorder) GetPolicyName() *gomock.Call
GetPolicyName indicates an expected call of GetPolicyName.
func (*MockLimiterMockRecorder) GetSelector ¶
func (mr *MockLimiterMockRecorder) GetSelector() *gomock.Call
GetSelector indicates an expected call of GetSelector.
func (*MockLimiterMockRecorder) RunLimiter ¶
func (mr *MockLimiterMockRecorder) RunLimiter(labels interface{}) *gomock.Call
RunLimiter indicates an expected call of RunLimiter.
type MockRateLimiter ¶ added in v0.5.0
type MockRateLimiter struct {
// contains filtered or unexported fields
}
MockRateLimiter is a mock of RateLimiter interface.
func NewMockRateLimiter ¶ added in v0.5.0
func NewMockRateLimiter(ctrl *gomock.Controller) *MockRateLimiter
NewMockRateLimiter creates a new mock instance.
func (*MockRateLimiter) EXPECT ¶ added in v0.5.0
func (m *MockRateLimiter) EXPECT() *MockRateLimiterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRateLimiter) GetCounter ¶ added in v0.5.0
func (m *MockRateLimiter) GetCounter() prometheus.Counter
GetCounter mocks base method.
func (*MockRateLimiter) GetLimiterID ¶ added in v0.5.0
func (m *MockRateLimiter) GetLimiterID() iface.LimiterID
GetLimiterID mocks base method.
func (*MockRateLimiter) GetPolicyName ¶ added in v0.5.0
func (m *MockRateLimiter) GetPolicyName() string
GetPolicyName mocks base method.
func (*MockRateLimiter) GetSelector ¶ added in v0.5.0
func (m *MockRateLimiter) GetSelector() *selectorv1.Selector
GetSelector mocks base method.
func (*MockRateLimiter) RunLimiter ¶ added in v0.5.0
func (m *MockRateLimiter) RunLimiter(labels map[string]string) *flowcontrolv1.LimiterDecision
RunLimiter mocks base method.
type MockRateLimiterMockRecorder ¶ added in v0.5.0
type MockRateLimiterMockRecorder struct {
// contains filtered or unexported fields
}
MockRateLimiterMockRecorder is the mock recorder for MockRateLimiter.
func (*MockRateLimiterMockRecorder) GetCounter ¶ added in v0.5.0
func (mr *MockRateLimiterMockRecorder) GetCounter() *gomock.Call
GetCounter indicates an expected call of GetCounter.
func (*MockRateLimiterMockRecorder) GetLimiterID ¶ added in v0.5.0
func (mr *MockRateLimiterMockRecorder) GetLimiterID() *gomock.Call
GetLimiterID indicates an expected call of GetLimiterID.
func (*MockRateLimiterMockRecorder) GetPolicyName ¶ added in v0.5.0
func (mr *MockRateLimiterMockRecorder) GetPolicyName() *gomock.Call
GetPolicyName indicates an expected call of GetPolicyName.
func (*MockRateLimiterMockRecorder) GetSelector ¶ added in v0.5.0
func (mr *MockRateLimiterMockRecorder) GetSelector() *gomock.Call
GetSelector indicates an expected call of GetSelector.
func (*MockRateLimiterMockRecorder) RunLimiter ¶ added in v0.5.0
func (mr *MockRateLimiterMockRecorder) RunLimiter(labels interface{}) *gomock.Call
RunLimiter indicates an expected call of RunLimiter.
func (*MockRateLimiterMockRecorder) TakeN ¶ added in v0.5.0
func (mr *MockRateLimiterMockRecorder) TakeN(labels, count interface{}) *gomock.Call
TakeN indicates an expected call of TakeN.