mocks

package
v0.5.0-rc.1 Latest Latest
Warning

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

Go to latest
Published: Oct 7, 2022 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Overview

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Package mocks is a generated GoMock package.

Index

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

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

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

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

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.

func (*MockRateLimiter) TakeN added in v0.5.0

func (m *MockRateLimiter) TakeN(labels map[string]string, count int) (string, bool, int, int)

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

Jump to

Keyboard shortcuts

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