Documentation
¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockClassificationEngine
- func (m *MockClassificationEngine) EXPECT() *MockClassificationEngineMockRecorder
- func (m *MockClassificationEngine) GetClassifier(classifierID iface.ClassifierID) iface.Classifier
- func (m *MockClassificationEngine) RegisterClassifier(classifier iface.Classifier) error
- func (m *MockClassificationEngine) UnregisterClassifier(classifier iface.Classifier) error
- type MockClassificationEngineMockRecorder
- func (mr *MockClassificationEngineMockRecorder) GetClassifier(classifierID interface{}) *gomock.Call
- func (mr *MockClassificationEngineMockRecorder) RegisterClassifier(classifier interface{}) *gomock.Call
- func (mr *MockClassificationEngineMockRecorder) UnregisterClassifier(classifier interface{}) *gomock.Call
- type MockClassifier
- type MockClassifierMockRecorder
- type MockConcurrencyLimiter
- func (m *MockConcurrencyLimiter) Decide(arg0 context.Context, arg1 labels.Labels) *checkv1.LimiterDecision
- func (m *MockConcurrencyLimiter) EXPECT() *MockConcurrencyLimiterMockRecorder
- func (m *MockConcurrencyLimiter) GetLimiterID() iface.LimiterID
- func (m *MockConcurrencyLimiter) GetPolicyName() string
- func (m *MockConcurrencyLimiter) GetRampMode() bool
- func (m *MockConcurrencyLimiter) GetRequestCounter(labels map[string]string) prometheus.Counter
- func (m *MockConcurrencyLimiter) GetSelectors() []*languagev1.Selector
- func (m *MockConcurrencyLimiter) Return(ctx context.Context, label string, tokens float64, requestID string) (bool, error)
- func (m *MockConcurrencyLimiter) Revert(arg0 context.Context, arg1 labels.Labels, arg2 *checkv1.LimiterDecision)
- type MockConcurrencyLimiterMockRecorder
- func (mr *MockConcurrencyLimiterMockRecorder) Decide(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) GetLimiterID() *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) GetPolicyName() *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) GetRampMode() *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) GetRequestCounter(labels interface{}) *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) GetSelectors() *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) Return(ctx, label, tokens, requestID interface{}) *gomock.Call
- func (mr *MockConcurrencyLimiterMockRecorder) Revert(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockConcurrencyScheduler
- func (m *MockConcurrencyScheduler) Decide(arg0 context.Context, arg1 labels.Labels) *checkv1.LimiterDecision
- func (m *MockConcurrencyScheduler) EXPECT() *MockConcurrencySchedulerMockRecorder
- func (m *MockConcurrencyScheduler) GetLatencyObserver(labels map[string]string) prometheus.Observer
- func (m *MockConcurrencyScheduler) GetLimiterID() iface.LimiterID
- func (m *MockConcurrencyScheduler) GetPolicyName() string
- func (m *MockConcurrencyScheduler) GetRampMode() bool
- func (m *MockConcurrencyScheduler) GetRequestCounter(labels map[string]string) prometheus.Counter
- func (m *MockConcurrencyScheduler) GetSelectors() []*languagev1.Selector
- func (m *MockConcurrencyScheduler) Return(ctx context.Context, label string, tokens float64, requestID string) (bool, error)
- func (m *MockConcurrencyScheduler) Revert(arg0 context.Context, arg1 labels.Labels, arg2 *checkv1.LimiterDecision)
- type MockConcurrencySchedulerMockRecorder
- func (mr *MockConcurrencySchedulerMockRecorder) Decide(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockConcurrencySchedulerMockRecorder) GetLatencyObserver(labels interface{}) *gomock.Call
- func (mr *MockConcurrencySchedulerMockRecorder) GetLimiterID() *gomock.Call
- func (mr *MockConcurrencySchedulerMockRecorder) GetPolicyName() *gomock.Call
- func (mr *MockConcurrencySchedulerMockRecorder) GetRampMode() *gomock.Call
- func (mr *MockConcurrencySchedulerMockRecorder) GetRequestCounter(labels interface{}) *gomock.Call
- func (mr *MockConcurrencySchedulerMockRecorder) GetSelectors() *gomock.Call
- func (mr *MockConcurrencySchedulerMockRecorder) Return(ctx, label, tokens, requestID interface{}) *gomock.Call
- func (mr *MockConcurrencySchedulerMockRecorder) Revert(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockEngine
- func (m *MockEngine) EXPECT() *MockEngineMockRecorder
- func (m *MockEngine) FlowEnd(ctx context.Context, request *checkv1.FlowEndRequest) *checkv1.FlowEndResponse
- func (m *MockEngine) GetAgentInfo() *agentinfo.AgentInfo
- func (m *MockEngine) GetFlowEnder(limiterID iface.LimiterID) iface.FlowEnder
- func (m *MockEngine) GetFluxMeter(fluxMeterName string) iface.FluxMeter
- func (m *MockEngine) GetRateLimiter(limiterID iface.LimiterID) iface.Limiter
- func (m *MockEngine) GetSampler(limiterID iface.LimiterID) iface.Limiter
- func (m *MockEngine) GetScheduler(limiterID iface.LimiterID) iface.Scheduler
- func (m *MockEngine) ProcessRequest(ctx context.Context, requestContext iface.RequestContext) *checkv1.CheckResponse
- func (m *MockEngine) RegisterCache(c iface.Cache)
- func (m *MockEngine) RegisterConcurrencyLimiter(l iface.ConcurrencyLimiter) error
- func (m *MockEngine) RegisterConcurrencyScheduler(l iface.ConcurrencyScheduler) error
- func (m *MockEngine) RegisterFluxMeter(fm iface.FluxMeter) error
- func (m *MockEngine) RegisterLabelPreview(l iface.LabelPreview) error
- func (m *MockEngine) RegisterRateLimiter(l iface.Limiter) error
- func (m *MockEngine) RegisterSampler(l iface.Limiter) error
- func (m *MockEngine) RegisterScheduler(ls iface.Scheduler) error
- func (m *MockEngine) UnregisterConcurrencyLimiter(l iface.ConcurrencyLimiter) error
- func (m *MockEngine) UnregisterConcurrencyScheduler(l iface.ConcurrencyScheduler) error
- func (m *MockEngine) UnregisterFluxMeter(fm iface.FluxMeter) error
- func (m *MockEngine) UnregisterLabelPreview(l iface.LabelPreview) error
- func (m *MockEngine) UnregisterRateLimiter(l iface.Limiter) error
- func (m *MockEngine) UnregisterSampler(l iface.Limiter) error
- func (m *MockEngine) UnregisterScheduler(ls iface.Scheduler) error
- type MockEngineMockRecorder
- func (mr *MockEngineMockRecorder) FlowEnd(ctx, request interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetAgentInfo() *gomock.Call
- func (mr *MockEngineMockRecorder) GetFlowEnder(limiterID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetFluxMeter(fluxMeterName interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetRateLimiter(limiterID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetSampler(limiterID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) GetScheduler(limiterID interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) ProcessRequest(ctx, requestContext interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterCache(c interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterConcurrencyLimiter(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterConcurrencyScheduler(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterFluxMeter(fm interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterLabelPreview(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterRateLimiter(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterSampler(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) RegisterScheduler(ls interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterConcurrencyLimiter(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterConcurrencyScheduler(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterFluxMeter(fm interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterLabelPreview(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterRateLimiter(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterSampler(l interface{}) *gomock.Call
- func (mr *MockEngineMockRecorder) UnregisterScheduler(ls interface{}) *gomock.Call
- type MockFlowEnder
- type MockFlowEnderMockRecorder
- 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(labels map[string]string) prometheus.Observer
- func (m *MockFluxMeter) GetInvalidFluxMeterTotal(labels map[string]string) (prometheus.Counter, error)
- func (m *MockFluxMeter) GetSelectors() []*languagev1.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(labels interface{}) *gomock.Call
- func (mr *MockFluxMeterMockRecorder) GetInvalidFluxMeterTotal(labels interface{}) *gomock.Call
- func (mr *MockFluxMeterMockRecorder) GetSelectors() *gomock.Call
- type MockHandlerWithValues
- type MockHandlerWithValuesMockRecorder
- type MockLimiter
- func (m *MockLimiter) Decide(arg0 context.Context, arg1 labels.Labels) *checkv1.LimiterDecision
- func (m *MockLimiter) EXPECT() *MockLimiterMockRecorder
- func (m *MockLimiter) GetLimiterID() iface.LimiterID
- func (m *MockLimiter) GetPolicyName() string
- func (m *MockLimiter) GetRampMode() bool
- func (m *MockLimiter) GetRequestCounter(labels map[string]string) prometheus.Counter
- func (m *MockLimiter) GetSelectors() []*languagev1.Selector
- func (m *MockLimiter) Revert(arg0 context.Context, arg1 labels.Labels, arg2 *checkv1.LimiterDecision)
- type MockLimiterMockRecorder
- func (mr *MockLimiterMockRecorder) Decide(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockLimiterMockRecorder) GetLimiterID() *gomock.Call
- func (mr *MockLimiterMockRecorder) GetPolicyName() *gomock.Call
- func (mr *MockLimiterMockRecorder) GetRampMode() *gomock.Call
- func (mr *MockLimiterMockRecorder) GetRequestCounter(labels interface{}) *gomock.Call
- func (mr *MockLimiterMockRecorder) GetSelectors() *gomock.Call
- func (mr *MockLimiterMockRecorder) Revert(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockScheduler
- func (m *MockScheduler) Decide(arg0 context.Context, arg1 labels.Labels) *checkv1.LimiterDecision
- func (m *MockScheduler) EXPECT() *MockSchedulerMockRecorder
- func (m *MockScheduler) GetLatencyObserver(labels map[string]string) prometheus.Observer
- func (m *MockScheduler) GetLimiterID() iface.LimiterID
- func (m *MockScheduler) GetPolicyName() string
- func (m *MockScheduler) GetRampMode() bool
- func (m *MockScheduler) GetRequestCounter(labels map[string]string) prometheus.Counter
- func (m *MockScheduler) GetSelectors() []*languagev1.Selector
- func (m *MockScheduler) Revert(arg0 context.Context, arg1 labels.Labels, arg2 *checkv1.LimiterDecision)
- type MockSchedulerMockRecorder
- func (mr *MockSchedulerMockRecorder) Decide(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockSchedulerMockRecorder) GetLatencyObserver(labels interface{}) *gomock.Call
- func (mr *MockSchedulerMockRecorder) GetLimiterID() *gomock.Call
- func (mr *MockSchedulerMockRecorder) GetPolicyName() *gomock.Call
- func (mr *MockSchedulerMockRecorder) GetRampMode() *gomock.Call
- func (mr *MockSchedulerMockRecorder) GetRequestCounter(labels interface{}) *gomock.Call
- func (mr *MockSchedulerMockRecorder) GetSelectors() *gomock.Call
- func (mr *MockSchedulerMockRecorder) Revert(arg0, arg1, arg2 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClassificationEngine ¶
type MockClassificationEngine struct {
// contains filtered or unexported fields
}
MockClassificationEngine is a mock of ClassificationEngine interface.
func NewMockClassificationEngine ¶
func NewMockClassificationEngine(ctrl *gomock.Controller) *MockClassificationEngine
NewMockClassificationEngine creates a new mock instance.
func (*MockClassificationEngine) EXPECT ¶
func (m *MockClassificationEngine) EXPECT() *MockClassificationEngineMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClassificationEngine) GetClassifier ¶
func (m *MockClassificationEngine) GetClassifier(classifierID iface.ClassifierID) iface.Classifier
GetClassifier mocks base method.
func (*MockClassificationEngine) RegisterClassifier ¶
func (m *MockClassificationEngine) RegisterClassifier(classifier iface.Classifier) error
RegisterClassifier mocks base method.
func (*MockClassificationEngine) UnregisterClassifier ¶
func (m *MockClassificationEngine) UnregisterClassifier(classifier iface.Classifier) error
UnregisterClassifier mocks base method.
type MockClassificationEngineMockRecorder ¶
type MockClassificationEngineMockRecorder struct {
// contains filtered or unexported fields
}
MockClassificationEngineMockRecorder is the mock recorder for MockClassificationEngine.
func (*MockClassificationEngineMockRecorder) GetClassifier ¶
func (mr *MockClassificationEngineMockRecorder) GetClassifier(classifierID interface{}) *gomock.Call
GetClassifier indicates an expected call of GetClassifier.
func (*MockClassificationEngineMockRecorder) RegisterClassifier ¶
func (mr *MockClassificationEngineMockRecorder) RegisterClassifier(classifier interface{}) *gomock.Call
RegisterClassifier indicates an expected call of RegisterClassifier.
func (*MockClassificationEngineMockRecorder) UnregisterClassifier ¶
func (mr *MockClassificationEngineMockRecorder) UnregisterClassifier(classifier interface{}) *gomock.Call
UnregisterClassifier indicates an expected call of UnregisterClassifier.
type MockClassifier ¶
type MockClassifier struct {
// contains filtered or unexported fields
}
MockClassifier is a mock of Classifier interface.
func NewMockClassifier ¶
func NewMockClassifier(ctrl *gomock.Controller) *MockClassifier
NewMockClassifier creates a new mock instance.
func (*MockClassifier) EXPECT ¶
func (m *MockClassifier) EXPECT() *MockClassifierMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClassifier) GetClassifierID ¶
func (m *MockClassifier) GetClassifierID() iface.ClassifierID
GetClassifierID mocks base method.
func (*MockClassifier) GetRequestCounter ¶
func (m *MockClassifier) GetRequestCounter() prometheus.Counter
GetRequestCounter mocks base method.
func (*MockClassifier) GetSelectors ¶
func (m *MockClassifier) GetSelectors() []*languagev1.Selector
GetSelectors mocks base method.
type MockClassifierMockRecorder ¶
type MockClassifierMockRecorder struct {
// contains filtered or unexported fields
}
MockClassifierMockRecorder is the mock recorder for MockClassifier.
func (*MockClassifierMockRecorder) GetClassifierID ¶
func (mr *MockClassifierMockRecorder) GetClassifierID() *gomock.Call
GetClassifierID indicates an expected call of GetClassifierID.
func (*MockClassifierMockRecorder) GetRequestCounter ¶
func (mr *MockClassifierMockRecorder) GetRequestCounter() *gomock.Call
GetRequestCounter indicates an expected call of GetRequestCounter.
func (*MockClassifierMockRecorder) GetSelectors ¶
func (mr *MockClassifierMockRecorder) GetSelectors() *gomock.Call
GetSelectors indicates an expected call of GetSelectors.
type MockConcurrencyLimiter ¶ added in v2.29.0
type MockConcurrencyLimiter struct {
// contains filtered or unexported fields
}
MockConcurrencyLimiter is a mock of ConcurrencyLimiter interface.
func NewMockConcurrencyLimiter ¶ added in v2.29.0
func NewMockConcurrencyLimiter(ctrl *gomock.Controller) *MockConcurrencyLimiter
NewMockConcurrencyLimiter creates a new mock instance.
func (*MockConcurrencyLimiter) Decide ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) Decide(arg0 context.Context, arg1 labels.Labels) *checkv1.LimiterDecision
Decide mocks base method.
func (*MockConcurrencyLimiter) EXPECT ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) EXPECT() *MockConcurrencyLimiterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConcurrencyLimiter) GetLimiterID ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) GetLimiterID() iface.LimiterID
GetLimiterID mocks base method.
func (*MockConcurrencyLimiter) GetPolicyName ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) GetPolicyName() string
GetPolicyName mocks base method.
func (*MockConcurrencyLimiter) GetRampMode ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) GetRampMode() bool
GetRampMode mocks base method.
func (*MockConcurrencyLimiter) GetRequestCounter ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) GetRequestCounter(labels map[string]string) prometheus.Counter
GetRequestCounter mocks base method.
func (*MockConcurrencyLimiter) GetSelectors ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) GetSelectors() []*languagev1.Selector
GetSelectors mocks base method.
func (*MockConcurrencyLimiter) Return ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) Return(ctx context.Context, label string, tokens float64, requestID string) (bool, error)
Return mocks base method.
func (*MockConcurrencyLimiter) Revert ¶ added in v2.29.0
func (m *MockConcurrencyLimiter) Revert(arg0 context.Context, arg1 labels.Labels, arg2 *checkv1.LimiterDecision)
Revert mocks base method.
type MockConcurrencyLimiterMockRecorder ¶ added in v2.29.0
type MockConcurrencyLimiterMockRecorder struct {
// contains filtered or unexported fields
}
MockConcurrencyLimiterMockRecorder is the mock recorder for MockConcurrencyLimiter.
func (*MockConcurrencyLimiterMockRecorder) Decide ¶ added in v2.29.0
func (mr *MockConcurrencyLimiterMockRecorder) Decide(arg0, arg1 interface{}) *gomock.Call
Decide indicates an expected call of Decide.
func (*MockConcurrencyLimiterMockRecorder) GetLimiterID ¶ added in v2.29.0
func (mr *MockConcurrencyLimiterMockRecorder) GetLimiterID() *gomock.Call
GetLimiterID indicates an expected call of GetLimiterID.
func (*MockConcurrencyLimiterMockRecorder) GetPolicyName ¶ added in v2.29.0
func (mr *MockConcurrencyLimiterMockRecorder) GetPolicyName() *gomock.Call
GetPolicyName indicates an expected call of GetPolicyName.
func (*MockConcurrencyLimiterMockRecorder) GetRampMode ¶ added in v2.29.0
func (mr *MockConcurrencyLimiterMockRecorder) GetRampMode() *gomock.Call
GetRampMode indicates an expected call of GetRampMode.
func (*MockConcurrencyLimiterMockRecorder) GetRequestCounter ¶ added in v2.29.0
func (mr *MockConcurrencyLimiterMockRecorder) GetRequestCounter(labels interface{}) *gomock.Call
GetRequestCounter indicates an expected call of GetRequestCounter.
func (*MockConcurrencyLimiterMockRecorder) GetSelectors ¶ added in v2.29.0
func (mr *MockConcurrencyLimiterMockRecorder) GetSelectors() *gomock.Call
GetSelectors indicates an expected call of GetSelectors.
func (*MockConcurrencyLimiterMockRecorder) Return ¶ added in v2.29.0
func (mr *MockConcurrencyLimiterMockRecorder) Return(ctx, label, tokens, requestID interface{}) *gomock.Call
Return indicates an expected call of Return.
func (*MockConcurrencyLimiterMockRecorder) Revert ¶ added in v2.29.0
func (mr *MockConcurrencyLimiterMockRecorder) Revert(arg0, arg1, arg2 interface{}) *gomock.Call
Revert indicates an expected call of Revert.
type MockConcurrencyScheduler ¶ added in v2.29.0
type MockConcurrencyScheduler struct {
// contains filtered or unexported fields
}
MockConcurrencyScheduler is a mock of ConcurrencyScheduler interface.
func NewMockConcurrencyScheduler ¶ added in v2.29.0
func NewMockConcurrencyScheduler(ctrl *gomock.Controller) *MockConcurrencyScheduler
NewMockConcurrencyScheduler creates a new mock instance.
func (*MockConcurrencyScheduler) Decide ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) Decide(arg0 context.Context, arg1 labels.Labels) *checkv1.LimiterDecision
Decide mocks base method.
func (*MockConcurrencyScheduler) EXPECT ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) EXPECT() *MockConcurrencySchedulerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockConcurrencyScheduler) GetLatencyObserver ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) GetLatencyObserver(labels map[string]string) prometheus.Observer
GetLatencyObserver mocks base method.
func (*MockConcurrencyScheduler) GetLimiterID ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) GetLimiterID() iface.LimiterID
GetLimiterID mocks base method.
func (*MockConcurrencyScheduler) GetPolicyName ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) GetPolicyName() string
GetPolicyName mocks base method.
func (*MockConcurrencyScheduler) GetRampMode ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) GetRampMode() bool
GetRampMode mocks base method.
func (*MockConcurrencyScheduler) GetRequestCounter ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) GetRequestCounter(labels map[string]string) prometheus.Counter
GetRequestCounter mocks base method.
func (*MockConcurrencyScheduler) GetSelectors ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) GetSelectors() []*languagev1.Selector
GetSelectors mocks base method.
func (*MockConcurrencyScheduler) Return ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) Return(ctx context.Context, label string, tokens float64, requestID string) (bool, error)
Return mocks base method.
func (*MockConcurrencyScheduler) Revert ¶ added in v2.29.0
func (m *MockConcurrencyScheduler) Revert(arg0 context.Context, arg1 labels.Labels, arg2 *checkv1.LimiterDecision)
Revert mocks base method.
type MockConcurrencySchedulerMockRecorder ¶ added in v2.29.0
type MockConcurrencySchedulerMockRecorder struct {
// contains filtered or unexported fields
}
MockConcurrencySchedulerMockRecorder is the mock recorder for MockConcurrencyScheduler.
func (*MockConcurrencySchedulerMockRecorder) Decide ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) Decide(arg0, arg1 interface{}) *gomock.Call
Decide indicates an expected call of Decide.
func (*MockConcurrencySchedulerMockRecorder) GetLatencyObserver ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) GetLatencyObserver(labels interface{}) *gomock.Call
GetLatencyObserver indicates an expected call of GetLatencyObserver.
func (*MockConcurrencySchedulerMockRecorder) GetLimiterID ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) GetLimiterID() *gomock.Call
GetLimiterID indicates an expected call of GetLimiterID.
func (*MockConcurrencySchedulerMockRecorder) GetPolicyName ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) GetPolicyName() *gomock.Call
GetPolicyName indicates an expected call of GetPolicyName.
func (*MockConcurrencySchedulerMockRecorder) GetRampMode ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) GetRampMode() *gomock.Call
GetRampMode indicates an expected call of GetRampMode.
func (*MockConcurrencySchedulerMockRecorder) GetRequestCounter ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) GetRequestCounter(labels interface{}) *gomock.Call
GetRequestCounter indicates an expected call of GetRequestCounter.
func (*MockConcurrencySchedulerMockRecorder) GetSelectors ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) GetSelectors() *gomock.Call
GetSelectors indicates an expected call of GetSelectors.
func (*MockConcurrencySchedulerMockRecorder) Return ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) Return(ctx, label, tokens, requestID interface{}) *gomock.Call
Return indicates an expected call of Return.
func (*MockConcurrencySchedulerMockRecorder) Revert ¶ added in v2.29.0
func (mr *MockConcurrencySchedulerMockRecorder) Revert(arg0, arg1, arg2 interface{}) *gomock.Call
Revert indicates an expected call of Revert.
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) FlowEnd ¶ added in v2.29.0
func (m *MockEngine) FlowEnd(ctx context.Context, request *checkv1.FlowEndRequest) *checkv1.FlowEndResponse
FlowEnd mocks base method.
func (*MockEngine) GetAgentInfo ¶
func (m *MockEngine) GetAgentInfo() *agentinfo.AgentInfo
GetAgentInfo mocks base method.
func (*MockEngine) GetFlowEnder ¶ added in v2.29.0
func (m *MockEngine) GetFlowEnder(limiterID iface.LimiterID) iface.FlowEnder
GetFlowEnder mocks base method.
func (*MockEngine) GetFluxMeter ¶
func (m *MockEngine) GetFluxMeter(fluxMeterName string) iface.FluxMeter
GetFluxMeter mocks base method.
func (*MockEngine) GetRateLimiter ¶
func (m *MockEngine) GetRateLimiter(limiterID iface.LimiterID) iface.Limiter
GetRateLimiter mocks base method.
func (*MockEngine) GetSampler ¶ added in v2.5.0
func (m *MockEngine) GetSampler(limiterID iface.LimiterID) iface.Limiter
GetSampler mocks base method.
func (*MockEngine) GetScheduler ¶ added in v2.2.0
func (m *MockEngine) GetScheduler(limiterID iface.LimiterID) iface.Scheduler
GetScheduler mocks base method.
func (*MockEngine) ProcessRequest ¶
func (m *MockEngine) ProcessRequest(ctx context.Context, requestContext iface.RequestContext) *checkv1.CheckResponse
ProcessRequest mocks base method.
func (*MockEngine) RegisterCache ¶ added in v2.24.0
func (m *MockEngine) RegisterCache(c iface.Cache)
RegisterCache mocks base method.
func (*MockEngine) RegisterConcurrencyLimiter ¶ added in v2.29.0
func (m *MockEngine) RegisterConcurrencyLimiter(l iface.ConcurrencyLimiter) error
RegisterConcurrencyLimiter mocks base method.
func (*MockEngine) RegisterConcurrencyScheduler ¶ added in v2.29.0
func (m *MockEngine) RegisterConcurrencyScheduler(l iface.ConcurrencyScheduler) error
RegisterConcurrencyScheduler mocks base method.
func (*MockEngine) RegisterFluxMeter ¶
func (m *MockEngine) RegisterFluxMeter(fm iface.FluxMeter) error
RegisterFluxMeter mocks base method.
func (*MockEngine) RegisterLabelPreview ¶
func (m *MockEngine) RegisterLabelPreview(l iface.LabelPreview) error
RegisterLabelPreview mocks base method.
func (*MockEngine) RegisterRateLimiter ¶
func (m *MockEngine) RegisterRateLimiter(l iface.Limiter) error
RegisterRateLimiter mocks base method.
func (*MockEngine) RegisterSampler ¶ added in v2.5.0
func (m *MockEngine) RegisterSampler(l iface.Limiter) error
RegisterSampler mocks base method.
func (*MockEngine) RegisterScheduler ¶ added in v2.2.0
func (m *MockEngine) RegisterScheduler(ls iface.Scheduler) error
RegisterScheduler mocks base method.
func (*MockEngine) UnregisterConcurrencyLimiter ¶ added in v2.29.0
func (m *MockEngine) UnregisterConcurrencyLimiter(l iface.ConcurrencyLimiter) error
UnregisterConcurrencyLimiter mocks base method.
func (*MockEngine) UnregisterConcurrencyScheduler ¶ added in v2.29.0
func (m *MockEngine) UnregisterConcurrencyScheduler(l iface.ConcurrencyScheduler) error
UnregisterConcurrencyScheduler mocks base method.
func (*MockEngine) UnregisterFluxMeter ¶
func (m *MockEngine) UnregisterFluxMeter(fm iface.FluxMeter) error
UnregisterFluxMeter mocks base method.
func (*MockEngine) UnregisterLabelPreview ¶
func (m *MockEngine) UnregisterLabelPreview(l iface.LabelPreview) error
UnregisterLabelPreview mocks base method.
func (*MockEngine) UnregisterRateLimiter ¶
func (m *MockEngine) UnregisterRateLimiter(l iface.Limiter) error
UnregisterRateLimiter mocks base method.
func (*MockEngine) UnregisterSampler ¶ added in v2.5.0
func (m *MockEngine) UnregisterSampler(l iface.Limiter) error
UnregisterSampler mocks base method.
func (*MockEngine) UnregisterScheduler ¶ added in v2.2.0
func (m *MockEngine) UnregisterScheduler(ls iface.Scheduler) error
UnregisterScheduler mocks base method.
type MockEngineMockRecorder ¶
type MockEngineMockRecorder struct {
// contains filtered or unexported fields
}
MockEngineMockRecorder is the mock recorder for MockEngine.
func (*MockEngineMockRecorder) FlowEnd ¶ added in v2.29.0
func (mr *MockEngineMockRecorder) FlowEnd(ctx, request interface{}) *gomock.Call
FlowEnd indicates an expected call of FlowEnd.
func (*MockEngineMockRecorder) GetAgentInfo ¶
func (mr *MockEngineMockRecorder) GetAgentInfo() *gomock.Call
GetAgentInfo indicates an expected call of GetAgentInfo.
func (*MockEngineMockRecorder) GetFlowEnder ¶ added in v2.29.0
func (mr *MockEngineMockRecorder) GetFlowEnder(limiterID interface{}) *gomock.Call
GetFlowEnder indicates an expected call of GetFlowEnder.
func (*MockEngineMockRecorder) GetFluxMeter ¶
func (mr *MockEngineMockRecorder) GetFluxMeter(fluxMeterName interface{}) *gomock.Call
GetFluxMeter indicates an expected call of GetFluxMeter.
func (*MockEngineMockRecorder) GetRateLimiter ¶
func (mr *MockEngineMockRecorder) GetRateLimiter(limiterID interface{}) *gomock.Call
GetRateLimiter indicates an expected call of GetRateLimiter.
func (*MockEngineMockRecorder) GetSampler ¶ added in v2.5.0
func (mr *MockEngineMockRecorder) GetSampler(limiterID interface{}) *gomock.Call
GetSampler indicates an expected call of GetSampler.
func (*MockEngineMockRecorder) GetScheduler ¶ added in v2.2.0
func (mr *MockEngineMockRecorder) GetScheduler(limiterID interface{}) *gomock.Call
GetScheduler indicates an expected call of GetScheduler.
func (*MockEngineMockRecorder) ProcessRequest ¶
func (mr *MockEngineMockRecorder) ProcessRequest(ctx, requestContext interface{}) *gomock.Call
ProcessRequest indicates an expected call of ProcessRequest.
func (*MockEngineMockRecorder) RegisterCache ¶ added in v2.24.0
func (mr *MockEngineMockRecorder) RegisterCache(c interface{}) *gomock.Call
RegisterCache indicates an expected call of RegisterCache.
func (*MockEngineMockRecorder) RegisterConcurrencyLimiter ¶ added in v2.29.0
func (mr *MockEngineMockRecorder) RegisterConcurrencyLimiter(l interface{}) *gomock.Call
RegisterConcurrencyLimiter indicates an expected call of RegisterConcurrencyLimiter.
func (*MockEngineMockRecorder) RegisterConcurrencyScheduler ¶ added in v2.29.0
func (mr *MockEngineMockRecorder) RegisterConcurrencyScheduler(l interface{}) *gomock.Call
RegisterConcurrencyScheduler indicates an expected call of RegisterConcurrencyScheduler.
func (*MockEngineMockRecorder) RegisterFluxMeter ¶
func (mr *MockEngineMockRecorder) RegisterFluxMeter(fm interface{}) *gomock.Call
RegisterFluxMeter indicates an expected call of RegisterFluxMeter.
func (*MockEngineMockRecorder) RegisterLabelPreview ¶
func (mr *MockEngineMockRecorder) RegisterLabelPreview(l interface{}) *gomock.Call
RegisterLabelPreview indicates an expected call of RegisterLabelPreview.
func (*MockEngineMockRecorder) RegisterRateLimiter ¶
func (mr *MockEngineMockRecorder) RegisterRateLimiter(l interface{}) *gomock.Call
RegisterRateLimiter indicates an expected call of RegisterRateLimiter.
func (*MockEngineMockRecorder) RegisterSampler ¶ added in v2.5.0
func (mr *MockEngineMockRecorder) RegisterSampler(l interface{}) *gomock.Call
RegisterSampler indicates an expected call of RegisterSampler.
func (*MockEngineMockRecorder) RegisterScheduler ¶ added in v2.2.0
func (mr *MockEngineMockRecorder) RegisterScheduler(ls interface{}) *gomock.Call
RegisterScheduler indicates an expected call of RegisterScheduler.
func (*MockEngineMockRecorder) UnregisterConcurrencyLimiter ¶ added in v2.29.0
func (mr *MockEngineMockRecorder) UnregisterConcurrencyLimiter(l interface{}) *gomock.Call
UnregisterConcurrencyLimiter indicates an expected call of UnregisterConcurrencyLimiter.
func (*MockEngineMockRecorder) UnregisterConcurrencyScheduler ¶ added in v2.29.0
func (mr *MockEngineMockRecorder) UnregisterConcurrencyScheduler(l interface{}) *gomock.Call
UnregisterConcurrencyScheduler indicates an expected call of UnregisterConcurrencyScheduler.
func (*MockEngineMockRecorder) UnregisterFluxMeter ¶
func (mr *MockEngineMockRecorder) UnregisterFluxMeter(fm interface{}) *gomock.Call
UnregisterFluxMeter indicates an expected call of UnregisterFluxMeter.
func (*MockEngineMockRecorder) UnregisterLabelPreview ¶
func (mr *MockEngineMockRecorder) UnregisterLabelPreview(l interface{}) *gomock.Call
UnregisterLabelPreview indicates an expected call of UnregisterLabelPreview.
func (*MockEngineMockRecorder) UnregisterRateLimiter ¶
func (mr *MockEngineMockRecorder) UnregisterRateLimiter(l interface{}) *gomock.Call
UnregisterRateLimiter indicates an expected call of UnregisterRateLimiter.
func (*MockEngineMockRecorder) UnregisterSampler ¶ added in v2.5.0
func (mr *MockEngineMockRecorder) UnregisterSampler(l interface{}) *gomock.Call
UnregisterSampler indicates an expected call of UnregisterSampler.
func (*MockEngineMockRecorder) UnregisterScheduler ¶ added in v2.2.0
func (mr *MockEngineMockRecorder) UnregisterScheduler(ls interface{}) *gomock.Call
UnregisterScheduler indicates an expected call of UnregisterScheduler.
type MockFlowEnder ¶ added in v2.29.0
type MockFlowEnder struct {
// contains filtered or unexported fields
}
MockFlowEnder is a mock of FlowEnder interface.
func NewMockFlowEnder ¶ added in v2.29.0
func NewMockFlowEnder(ctrl *gomock.Controller) *MockFlowEnder
NewMockFlowEnder creates a new mock instance.
func (*MockFlowEnder) EXPECT ¶ added in v2.29.0
func (m *MockFlowEnder) EXPECT() *MockFlowEnderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockFlowEnderMockRecorder ¶ added in v2.29.0
type MockFlowEnderMockRecorder struct {
// contains filtered or unexported fields
}
MockFlowEnderMockRecorder is the mock recorder for MockFlowEnder.
func (*MockFlowEnderMockRecorder) Return ¶ added in v2.29.0
func (mr *MockFlowEnderMockRecorder) Return(ctx, label, tokens, requestID interface{}) *gomock.Call
Return indicates an expected call of Return.
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 ¶
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(labels map[string]string) prometheus.Observer
GetHistogram mocks base method.
func (*MockFluxMeter) GetInvalidFluxMeterTotal ¶
func (m *MockFluxMeter) GetInvalidFluxMeterTotal(labels map[string]string) (prometheus.Counter, error)
GetInvalidFluxMeterTotal mocks base method.
func (*MockFluxMeter) GetSelectors ¶
func (m *MockFluxMeter) GetSelectors() []*languagev1.Selector
GetSelectors mocks base method.
type MockFluxMeterMockRecorder ¶
type MockFluxMeterMockRecorder struct {
// contains filtered or unexported fields
}
MockFluxMeterMockRecorder is the mock recorder for MockFluxMeter.
func (*MockFluxMeterMockRecorder) GetAttributeKey ¶
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(labels interface{}) *gomock.Call
GetHistogram indicates an expected call of GetHistogram.
func (*MockFluxMeterMockRecorder) GetInvalidFluxMeterTotal ¶
func (mr *MockFluxMeterMockRecorder) GetInvalidFluxMeterTotal(labels interface{}) *gomock.Call
GetInvalidFluxMeterTotal indicates an expected call of GetInvalidFluxMeterTotal.
func (*MockFluxMeterMockRecorder) GetSelectors ¶
func (mr *MockFluxMeterMockRecorder) GetSelectors() *gomock.Call
GetSelectors indicates an expected call of GetSelectors.
type MockHandlerWithValues ¶ added in v2.8.0
type MockHandlerWithValues struct {
// contains filtered or unexported fields
}
MockHandlerWithValues is a mock of HandlerWithValues interface.
func NewMockHandlerWithValues ¶ added in v2.8.0
func NewMockHandlerWithValues(ctrl *gomock.Controller) *MockHandlerWithValues
NewMockHandlerWithValues creates a new mock instance.
func (*MockHandlerWithValues) CheckRequest ¶ added in v2.8.0
func (m *MockHandlerWithValues) CheckRequest(arg0 context.Context, arg1 iface.RequestContext) *checkv1.CheckResponse
CheckRequest mocks base method.
func (*MockHandlerWithValues) EXPECT ¶ added in v2.8.0
func (m *MockHandlerWithValues) EXPECT() *MockHandlerWithValuesMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockHandlerWithValuesMockRecorder ¶ added in v2.8.0
type MockHandlerWithValuesMockRecorder struct {
// contains filtered or unexported fields
}
MockHandlerWithValuesMockRecorder is the mock recorder for MockHandlerWithValues.
func (*MockHandlerWithValuesMockRecorder) CheckRequest ¶ added in v2.8.0
func (mr *MockHandlerWithValuesMockRecorder) CheckRequest(arg0, arg1 interface{}) *gomock.Call
CheckRequest indicates an expected call of CheckRequest.
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) Decide ¶
func (m *MockLimiter) Decide(arg0 context.Context, arg1 labels.Labels) *checkv1.LimiterDecision
Decide mocks base method.
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) GetRampMode ¶ added in v2.17.0
func (m *MockLimiter) GetRampMode() bool
GetRampMode mocks base method.
func (*MockLimiter) GetRequestCounter ¶
func (m *MockLimiter) GetRequestCounter(labels map[string]string) prometheus.Counter
GetRequestCounter mocks base method.
func (*MockLimiter) GetSelectors ¶
func (m *MockLimiter) GetSelectors() []*languagev1.Selector
GetSelectors mocks base method.
func (*MockLimiter) Revert ¶
func (m *MockLimiter) Revert(arg0 context.Context, arg1 labels.Labels, arg2 *checkv1.LimiterDecision)
Revert mocks base method.
type MockLimiterMockRecorder ¶
type MockLimiterMockRecorder struct {
// contains filtered or unexported fields
}
MockLimiterMockRecorder is the mock recorder for MockLimiter.
func (*MockLimiterMockRecorder) Decide ¶
func (mr *MockLimiterMockRecorder) Decide(arg0, arg1 interface{}) *gomock.Call
Decide indicates an expected call of Decide.
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) GetRampMode ¶ added in v2.17.0
func (mr *MockLimiterMockRecorder) GetRampMode() *gomock.Call
GetRampMode indicates an expected call of GetRampMode.
func (*MockLimiterMockRecorder) GetRequestCounter ¶
func (mr *MockLimiterMockRecorder) GetRequestCounter(labels interface{}) *gomock.Call
GetRequestCounter indicates an expected call of GetRequestCounter.
func (*MockLimiterMockRecorder) GetSelectors ¶
func (mr *MockLimiterMockRecorder) GetSelectors() *gomock.Call
GetSelectors indicates an expected call of GetSelectors.
func (*MockLimiterMockRecorder) Revert ¶
func (mr *MockLimiterMockRecorder) Revert(arg0, arg1, arg2 interface{}) *gomock.Call
Revert indicates an expected call of Revert.
type MockScheduler ¶ added in v2.2.0
type MockScheduler struct {
// contains filtered or unexported fields
}
MockScheduler is a mock of Scheduler interface.
func NewMockScheduler ¶ added in v2.2.0
func NewMockScheduler(ctrl *gomock.Controller) *MockScheduler
NewMockScheduler creates a new mock instance.
func (*MockScheduler) Decide ¶ added in v2.2.0
func (m *MockScheduler) Decide(arg0 context.Context, arg1 labels.Labels) *checkv1.LimiterDecision
Decide mocks base method.
func (*MockScheduler) EXPECT ¶ added in v2.2.0
func (m *MockScheduler) EXPECT() *MockSchedulerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockScheduler) GetLatencyObserver ¶ added in v2.2.0
func (m *MockScheduler) GetLatencyObserver(labels map[string]string) prometheus.Observer
GetLatencyObserver mocks base method.
func (*MockScheduler) GetLimiterID ¶ added in v2.2.0
func (m *MockScheduler) GetLimiterID() iface.LimiterID
GetLimiterID mocks base method.
func (*MockScheduler) GetPolicyName ¶ added in v2.2.0
func (m *MockScheduler) GetPolicyName() string
GetPolicyName mocks base method.
func (*MockScheduler) GetRampMode ¶ added in v2.17.0
func (m *MockScheduler) GetRampMode() bool
GetRampMode mocks base method.
func (*MockScheduler) GetRequestCounter ¶ added in v2.2.0
func (m *MockScheduler) GetRequestCounter(labels map[string]string) prometheus.Counter
GetRequestCounter mocks base method.
func (*MockScheduler) GetSelectors ¶ added in v2.2.0
func (m *MockScheduler) GetSelectors() []*languagev1.Selector
GetSelectors mocks base method.
func (*MockScheduler) Revert ¶ added in v2.2.0
func (m *MockScheduler) Revert(arg0 context.Context, arg1 labels.Labels, arg2 *checkv1.LimiterDecision)
Revert mocks base method.
type MockSchedulerMockRecorder ¶ added in v2.2.0
type MockSchedulerMockRecorder struct {
// contains filtered or unexported fields
}
MockSchedulerMockRecorder is the mock recorder for MockScheduler.
func (*MockSchedulerMockRecorder) Decide ¶ added in v2.2.0
func (mr *MockSchedulerMockRecorder) Decide(arg0, arg1 interface{}) *gomock.Call
Decide indicates an expected call of Decide.
func (*MockSchedulerMockRecorder) GetLatencyObserver ¶ added in v2.2.0
func (mr *MockSchedulerMockRecorder) GetLatencyObserver(labels interface{}) *gomock.Call
GetLatencyObserver indicates an expected call of GetLatencyObserver.
func (*MockSchedulerMockRecorder) GetLimiterID ¶ added in v2.2.0
func (mr *MockSchedulerMockRecorder) GetLimiterID() *gomock.Call
GetLimiterID indicates an expected call of GetLimiterID.
func (*MockSchedulerMockRecorder) GetPolicyName ¶ added in v2.2.0
func (mr *MockSchedulerMockRecorder) GetPolicyName() *gomock.Call
GetPolicyName indicates an expected call of GetPolicyName.
func (*MockSchedulerMockRecorder) GetRampMode ¶ added in v2.17.0
func (mr *MockSchedulerMockRecorder) GetRampMode() *gomock.Call
GetRampMode indicates an expected call of GetRampMode.
func (*MockSchedulerMockRecorder) GetRequestCounter ¶ added in v2.2.0
func (mr *MockSchedulerMockRecorder) GetRequestCounter(labels interface{}) *gomock.Call
GetRequestCounter indicates an expected call of GetRequestCounter.
func (*MockSchedulerMockRecorder) GetSelectors ¶ added in v2.2.0
func (mr *MockSchedulerMockRecorder) GetSelectors() *gomock.Call
GetSelectors indicates an expected call of GetSelectors.
func (*MockSchedulerMockRecorder) Revert ¶ added in v2.2.0
func (mr *MockSchedulerMockRecorder) Revert(arg0, arg1, arg2 interface{}) *gomock.Call
Revert indicates an expected call of Revert.