Versions in this module Expand all Collapse all v0 v0.9.2 Oct 9, 2024 v0.9.1 Jun 11, 2024 Changes in this version + const DelayBetweenDispatchAssignment + const MaxDelayCap + const MinUnitCountForDelay + const PerUnitDelaySeconds + var Module = fx.Module("centrum_bot_manager", fx.Provide(NewManager)) + type Bot struct + func NewBot(ctx context.Context, logger *zap.Logger, job string, state *manager.Manager, ...) *Bot + func (b *Bot) Run() + func (b *Bot) Stop() + type Manager struct + func NewManager(p Params) *Manager + func (b *Manager) Start(ctx context.Context, job string) error + func (b *Manager) Stop(job string) error + func (s *Manager) Run(ctx context.Context) + type Params struct + JS *events.JSWrapper + LC fx.Lifecycle + Logger *zap.Logger + State *manager.Manager + TP *tracesdk.TracerProvider + Tracker tracker.ITracker
Go to main page