runner

package
v0.0.0-...-c092c37 Latest Latest
Warning

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

Go to latest
Published: Sep 12, 2021 License: MIT Imports: 8 Imported by: 1

Documentation

Overview

Package runner is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Start

func Start(runners int, tasksCh chan model.Tasks, blocker blocker, metric metricser, logger *logrus.Logger, nowFunc func() time.Time)

Start starts runners for observe tasks.

Types

type Mockblocker

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

Mockblocker is a mock of blocker interface

func NewMockblocker

func NewMockblocker(ctrl *gomock.Controller) *Mockblocker

NewMockblocker creates a new mock instance

func (*Mockblocker) BlockForTTL

func (m *Mockblocker) BlockForTTL(executor, fingerprint string, ttl time.Duration) error

BlockForTTL mocks base method

func (*Mockblocker) BlockInProgress

func (m *Mockblocker) BlockInProgress(executor, fingerprint string) (bool, error)

BlockInProgress mocks base method

func (*Mockblocker) EXPECT

func (m *Mockblocker) EXPECT() *MockblockerMockRecorder

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

func (*Mockblocker) Unblock

func (m *Mockblocker) Unblock(executor, fingerprint string)

Unblock mocks base method

type MockblockerMockRecorder

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

MockblockerMockRecorder is the mock recorder for Mockblocker

func (*MockblockerMockRecorder) BlockForTTL

func (mr *MockblockerMockRecorder) BlockForTTL(executor, fingerprint, ttl interface{}) *gomock.Call

BlockForTTL indicates an expected call of BlockForTTL

func (*MockblockerMockRecorder) BlockInProgress

func (mr *MockblockerMockRecorder) BlockInProgress(executor, fingerprint interface{}) *gomock.Call

BlockInProgress indicates an expected call of BlockInProgress

func (*MockblockerMockRecorder) Unblock

func (mr *MockblockerMockRecorder) Unblock(executor, fingerprint interface{}) *gomock.Call

Unblock indicates an expected call of Unblock

type Mockmetricser

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

Mockmetricser is a mock of metricser interface

func NewMockmetricser

func NewMockmetricser(ctrl *gomock.Controller) *Mockmetricser

NewMockmetricser creates a new mock instance

func (*Mockmetricser) EXPECT

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

func (*Mockmetricser) ExecutedTaskObserve

func (m *Mockmetricser) ExecutedTaskObserve(rule, alert, executor, result string, err error, duration time.Duration)

ExecutedTaskObserve mocks base method

type MockmetricserMockRecorder

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

MockmetricserMockRecorder is the mock recorder for Mockmetricser

func (*MockmetricserMockRecorder) ExecutedTaskObserve

func (mr *MockmetricserMockRecorder) ExecutedTaskObserve(rule, alert, executor, result, err, duration interface{}) *gomock.Call

ExecutedTaskObserve indicates an expected call of ExecutedTaskObserve

Jump to

Keyboard shortcuts

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