scheduler

package

Go to main page

Versions in this module

v0

v0.2.12

Jun 21, 2023

Changes in this version

+ const ThrottledWholeCollectionType

type Cycle

+ Name func() string

+ Type func() string

type CycleMetadata

+ Attempts int

+ CurrentPublishError string

+ CurrentPublishRef string

type DefaultThrottle

+ func (d *DefaultThrottle) MarshalJSON() ([]byte, error)

+ func (d *DefaultThrottle) UnmarshalJSON(in []byte) error

type MockCycle

+ func (m *MockCycle) Name() string

+ func (m *MockCycle) Type() string

type MockScheduler

+ func (m *MockScheduler) AutomaticToggleHandler(toggleValue string)

+ func (m *MockScheduler) IsAutomaticallyDisabled() bool

+ func (m *MockScheduler) IsEnabled() bool

+ func (m *MockScheduler) IsRunning() bool

+ func (m *MockScheduler) ManualToggleHandler(toggleValue string)

+ func (m *MockScheduler) WasAutomaticallyDisabled() bool

type Scheduler

+ AutomaticToggleHandler func(toggleValue string)

+ IsAutomaticallyDisabled func() bool

+ IsEnabled func() bool

+ IsRunning func() bool

+ ManualToggleHandler func(toggleValue string)

+ WasAutomaticallyDisabled func() bool

+ type State struct

+ func NewState() *State

+ func (s *State) MarshalJSON() ([]byte, error)

+ func (s *State) UnmarshalJSON(b []byte) error

+ func (s *State) Update(states ...string)

type ThrottledWholeCollectionCycle

+ Throttle Throttle

+ func (a ThrottledWholeCollectionCycle) Name() string

+ func (a ThrottledWholeCollectionCycle) Type() string

v0.2.12-dev-switch-to-doppler-rc2

Jun 9, 2023

v0.2.12-dev-switch-to-doppler-rc1

Jun 1, 2023

v0.2.9-dev-added-immutable-flag-to-cm-rc1

Sep 30, 2021

v0.0.2

Apr 13, 2017

Changes in this version

+ type Cycle interface

+ ID func() string

+ Metadata func() CycleMetadata

+ Reset func()

+ SetMetadata func(state CycleMetadata)

+ Start func()

+ State func() []string

+ Stop func()

+ TransformToConfig func() *CycleConfig

+ func NewFixedWindowCycle(name string, db native.DB, dbCollection string, origin string, ...) Cycle

+ func NewScalingWindowCycle(name string, db native.DB, dbCollection string, origin string, ...) Cycle

+ func NewThrottledWholeCollectionCycle(name string, db native.DB, dbCollection string, origin string, ...) Cycle

+ type CycleConfig struct

+ Collection string

+ CoolDown string

+ MaximumThrottle string

+ MinimumThrottle string

+ Name string

+ Origin string

+ Throttle string

+ TimeWindow string

+ Type string

+ func (c CycleConfig) Validate() error

+ type CycleMetadata struct

+ Completed int

+ CurrentPublishUUID string

+ End *time.Time

+ Errors int

+ Iteration int

+ Progress float64

+ Start *time.Time

+ State []string

+ Total int

+ type DefaultThrottle struct

+ Context context.Context

+ Limiter *rate.Limiter

+ func (d *DefaultThrottle) Interval() time.Duration

+ func (d *DefaultThrottle) Queue() error

+ func (d *DefaultThrottle) Stop()

+ type FixedWindowCycle struct

+ func (s *FixedWindowCycle) Start()

+ func (s *FixedWindowCycle) TransformToConfig() *CycleConfig

+ type MetadataReadWriter interface

+ LoadMetadata func(id string) (CycleMetadata, error)

+ WriteMetadata func(id string, state Cycle) error

+ func NewS3MetadataReadWriter(rw s3.ReadWriter) MetadataReadWriter

+ type MockCycle struct

+ func (m *MockCycle) ID() string

+ func (m *MockCycle) Metadata() CycleMetadata

+ func (m *MockCycle) Reset()

+ func (m *MockCycle) SetMetadata(state CycleMetadata)

+ func (m *MockCycle) Start()

+ func (m *MockCycle) State() []string

+ func (m *MockCycle) Stop()

+ func (m *MockCycle) TransformToConfig() *CycleConfig

+ type MockMetadataRW struct

+ func (m *MockMetadataRW) LoadMetadata(id string) (CycleMetadata, error)

+ func (m *MockMetadataRW) WriteMetadata(id string, state Cycle) error

+ type MockScheduler struct

+ func (m *MockScheduler) AddCycle(cycle Cycle) error

+ func (m *MockScheduler) AddThrottle(name string, throttleInterval string) error

+ func (m *MockScheduler) Cycles() map[string]Cycle

+ func (m *MockScheduler) DeleteCycle(cycleID string) error

+ func (m *MockScheduler) DeleteThrottle(name string) error

+ func (m *MockScheduler) NewCycle(config CycleConfig) (Cycle, error)

+ func (m *MockScheduler) RestorePreviousState()

+ func (m *MockScheduler) SaveCycleMetadata()

+ func (m *MockScheduler) Shutdown() error

+ func (m *MockScheduler) Start() error

+ func (m *MockScheduler) Throttles() map[string]Throttle

+ func (m *MockScheduler) ToggleHandler(toggleValue string)

+ type MockThrottle struct

+ func (m *MockThrottle) Interval() time.Duration

+ func (m *MockThrottle) Queue() error

+ func (m *MockThrottle) Stop()

+ type ScalingWindowCycle struct

+ MaximumThrottle string

+ func (s *ScalingWindowCycle) Start()

+ func (s *ScalingWindowCycle) TransformToConfig() *CycleConfig

+ type Scheduler interface

+ AddCycle func(cycle Cycle) error

+ Cycles func() map[string]Cycle

+ DeleteCycle func(cycleID string) error

+ NewCycle func(config CycleConfig) (Cycle, error)

+ RestorePreviousState func()

+ SaveCycleMetadata func()

+ Shutdown func() error

+ Start func() error

+ ToggleHandler func(toggleValue string)

+ func LoadSchedulerFromFile(configFile string, mongo native.DB, publishTask tasks.Task, ...) (Scheduler, error)

+ func NewScheduler(database native.DB, publishTask tasks.Task, ...) Scheduler

+ type Throttle interface

+ Interval func() time.Duration

+ Queue func() error

+ Stop func()

+ func NewCappedDynamicThrottle(interval time.Duration, minThrottle time.Duration, maxThrottle time.Duration, ...) (Throttle, context.CancelFunc)

+ func NewDynamicThrottle(interval time.Duration, minimumThrottle time.Duration, publishes int, ...) (Throttle, context.CancelFunc)

+ func NewThrottle(interval time.Duration, burst int) (Throttle, context.CancelFunc)

+ type ThrottledWholeCollectionCycle struct

+ func (a ThrottledWholeCollectionCycle) ID() string

+ func (a ThrottledWholeCollectionCycle) Metadata() CycleMetadata

+ func (a ThrottledWholeCollectionCycle) PublishedItems() int

+ func (a ThrottledWholeCollectionCycle) Reset()

+ func (a ThrottledWholeCollectionCycle) SetMetadata(metadata CycleMetadata)

+ func (a ThrottledWholeCollectionCycle) State() []string

+ func (a ThrottledWholeCollectionCycle) Stop()

+ func (a ThrottledWholeCollectionCycle) UpdateState(states ...string)

+ func (l *ThrottledWholeCollectionCycle) Start()

+ func (s *ThrottledWholeCollectionCycle) TransformToConfig() *CycleConfig

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