runner

Documentation

Overview

Package runner is a generated GoMock package.

Index

• func Start(runners int, tasksCh chan model.Tasks, blocker blocker, metric metricser, ...)
• type Mockblocker
  • func NewMockblocker(ctrl *gomock.Controller) *Mockblocker
  • func (m *Mockblocker) BlockForTTL(executor, fingerprint string, ttl time.Duration) error
  • func (m *Mockblocker) BlockInProgress(executor, fingerprint string) (bool, error)
  • func (m *Mockblocker) EXPECT() *MockblockerMockRecorder
  • func (m *Mockblocker) Unblock(executor, fingerprint string)
• type MockblockerMockRecorder
  • func (mr *MockblockerMockRecorder) BlockForTTL(executor, fingerprint, ttl interface{}) *gomock.Call
  • func (mr *MockblockerMockRecorder) BlockInProgress(executor, fingerprint interface{}) *gomock.Call
  • func (mr *MockblockerMockRecorder) Unblock(executor, fingerprint interface{}) *gomock.Call
• type Mockmetricser
  • func NewMockmetricser(ctrl *gomock.Controller) *Mockmetricser
  • func (m *Mockmetricser) EXPECT() *MockmetricserMockRecorder
  • func (m *Mockmetricser) ExecutedTaskObserve(rule, alert, executor, result string, err error, duration time.Duration)
• type MockmetricserMockRecorder
  • func (mr *MockmetricserMockRecorder) ExecutedTaskObserve(rule, alert, executor, result, err, duration interface{}) *gomock.Call

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

func (m *Mockmetricser) EXPECT() *MockmetricserMockRecorder

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