bot

Feb 28, 2024

Changes in this version

type Bot

+ func (b *Bot) Stop()

Jan 27, 2024

Changes in this version

type Params

+ Tracker tracker.ITracker

Nov 24, 2023

Changes in this version

type Params

+ JS nats.JetStreamContext

Nov 15, 2023

Changes in this version

+ const MinUnitCountForDelay

+ const PerUnitDelaySeconds

Oct 31, 2023

Changes in this version

+ const DelayMinUnits

Oct 25, 2023

Changes in this version

+ const DelayBetweenDispatchAssignment

+ const MaxDelayCap

+ const PerUnitDelay

Oct 16, 2023

Changes in this version

+ var Module = fx.Module("centrum_bot_manager", fx.Provide(NewManager))

+ type Bot struct

+ func NewBot(job string, state *manager.Manager) *Bot

+ func (b *Bot) Run(ctx context.Context) error

+ type Manager struct

+ func NewManager(p Params) *Manager

+ func (b *Manager) Start(job string) error

+ func (b *Manager) Stop(job string) error

+ func (s *Manager) Run()

+ type Params struct

+ Eventus *events.Eventus

+ LC fx.Lifecycle

+ Logger *zap.Logger

+ State *manager.Manager

+ TP *tracesdk.TracerProvider