scheduledevents2

README

The sucessor of the original scheduled events system for yagpdb that was running on redis, this one however is running on postgres.

The old system did not support things like clustering and was overall a bit messy and unstructured.

Documentation

Index

• Constants
• func CheckDiscordErrRetry(err error) bool
• func InitSchema() error
• func RegisterHandler(eventName string, dataFormat interface{}, handler HandlerFunc)
• func RegisterLegacyMigrater(eventName string, migrationHandler func(t time.Time, data string) error)
• func RegisterPlugin()
• func ScheduleEvent(evtName string, guildID int64, runAt time.Time, data interface{}) error
• type HandlerFunc
• type RegisteredHandler
• type ScheduledEvents
  • func (se *ScheduledEvents) LateBotInit()
  • func (se *ScheduledEvents) MigrateLegacyEvents()
  • func (se *ScheduledEvents) Name() string
  • func (p *ScheduledEvents) RunBackgroundWorker()
  • func (p *ScheduledEvents) StopBackgroundWorker(wg *sync.WaitGroup)
  • func (se *ScheduledEvents) StopBot(wg *sync.WaitGroup)

Constants

const DBSchema = `` /* 406-byte string literal not displayed */

Functions

func CheckDiscordErrRetry

func CheckDiscordErrRetry(err error) bool

func InitSchema

func InitSchema() error

func RegisterHandler

func RegisterHandler(eventName string, dataFormat interface{}, handler HandlerFunc)

RegisterHandler registers a handler for the scpecified event name dataFormat is optional and should not be a pointer, it should match the type you're passing into ScheduleEvent

func RegisterLegacyMigrater

func RegisterLegacyMigrater(eventName string, migrationHandler func(t time.Time, data string) error)

RegisterHandler registers a handler for the scpecified event name dataFormat is optional and should not be a pointer, it should match the type you're passing into ScheduleEvent

func RegisterPlugin

func RegisterPlugin()

func ScheduleEvent

func ScheduleEvent(evtName string, guildID int64, runAt time.Time, data interface{}) error

Types

type HandlerFunc

type HandlerFunc func(evt *models.ScheduledEvent, data interface{}) (retry bool, err error)

type RegisteredHandler

type RegisteredHandler struct {
	EvtName    string
	DataFormat interface{}
	Handler    HandlerFunc
}

type ScheduledEvents

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

func (*ScheduledEvents) LateBotInit

func (se *ScheduledEvents) LateBotInit()

func (*ScheduledEvents) MigrateLegacyEvents

func (se *ScheduledEvents) MigrateLegacyEvents()

func (*ScheduledEvents) Name

func (se *ScheduledEvents) Name() string

func (*ScheduledEvents) RunBackgroundWorker

func (p *ScheduledEvents) RunBackgroundWorker()

func (*ScheduledEvents) StopBackgroundWorker

func (p *ScheduledEvents) StopBackgroundWorker(wg *sync.WaitGroup)

func (*ScheduledEvents) StopBot

func (se *ScheduledEvents) StopBot(wg *sync.WaitGroup)