bot

Documentation

Index

• Constants
• Variables
• type Bot
  • func NewBot(logger *zap.Logger, job string, state *manager.Manager) *Bot
  • func (b *Bot) Run(ctx context.Context) error
• type Manager
  • func NewManager(p Params) *Manager
  • func (s *Manager) Run()
  • func (b *Manager) Start(job string) error
  • func (b *Manager) Stop(job string) error
• type Params

Constants

const (
	DelayBetweenDispatchAssignment = 35 * time.Second
	MinUnitCountForDelay           = 3
	PerUnitDelaySeconds            = 6
	MaxDelayCap                    = 80 * time.Second
)

Variables

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

Types

type Bot

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

func NewBot

func NewBot(logger *zap.Logger, job string, state *manager.Manager) *Bot

func (*Bot) Run

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

type Manager

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

func NewManager

func NewManager(p Params) *Manager

func (*Manager) Run

func (s *Manager) Run()

func (*Manager) Start

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

func (*Manager) Stop

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

type Params

type Params struct {
	fx.In

	LC fx.Lifecycle

	Logger  *zap.Logger
	TP      *tracesdk.TracerProvider
	State   *manager.Manager
	Eventus *events.Eventus
}