mqueue

README

Simple message queue based on postgres, this is for more realiably sending messages with retry on failure, accepting long failture durations such as discord being down.

Documentation

Index

• Constants
• Variables
• func IncrIDCounter() (next int64)
• func QueueMessage(source, sourceID string, guildID, channel int64, msgStr string, ...)
• func QueueMessageEmbed(source, sourceID string, guildID, channel int64, embed *discordgo.MessageEmbed)
• func QueueMessageString(source, sourceID string, guildID, channel int64, message string)
• func QueueMessageWebhook(source, sourceID string, guildID, channel int64, msgStr string, ...)
• func RegisterPlugin()
• func RegisterSource(name string, source PluginWithErrorHandler)
• type CacheKeyWebhook
• type Plugin
  • func (p *Plugin) LateBotInit()
  • func (p *Plugin) PluginInfo() *common.PluginInfo
  • func (p *Plugin) StopBot(wg *sync.WaitGroup)
• type PluginWithErrorHandler
• type PluginWithWebhookAvatar
• type QueuedElement
• type Webhook
  • func CreateWebhook(guildID int64, channelID int64, plugin string, avatar string) (*Webhook, error)
  • func FindCreateWebhook(guildID int64, channelID int64, plugin string, avatar string) (*Webhook, error)
• type WorkItem

Constants

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

Variables

var ErrGuildNotFound = errors.New("Guild not found")

Functions

func IncrIDCounter

func IncrIDCounter() (next int64)

func QueueMessage

func QueueMessage(source, sourceID string, guildID, channel int64, msgStr string, embed *discordgo.MessageEmbed)

func QueueMessageEmbed

func QueueMessageEmbed(source, sourceID string, guildID, channel int64, embed *discordgo.MessageEmbed)

func QueueMessageString

func QueueMessageString(source, sourceID string, guildID, channel int64, message string)

func QueueMessageWebhook

func QueueMessageWebhook(source, sourceID string, guildID, channel int64, msgStr string, embed *discordgo.MessageEmbed, webhook bool, webhookUsername string)

func RegisterPlugin

func RegisterPlugin()

func RegisterSource

func RegisterSource(name string, source PluginWithErrorHandler)

Types

type CacheKeyWebhook

type CacheKeyWebhook int64

type Plugin

type Plugin struct {
}

func (*Plugin) LateBotInit

func (p *Plugin) LateBotInit()

func (*Plugin) PluginInfo

func (p *Plugin) PluginInfo() *common.PluginInfo

func (*Plugin) StopBot

func (p *Plugin) StopBot(wg *sync.WaitGroup)

type PluginWithErrorHandler

type PluginWithErrorHandler interface {
	DisableFeed(elem *QueuedElement, err error)
}

type PluginWithWebhookAvatar

type PluginWithWebhookAvatar interface {
	WebhookAvatar() string
}

type QueuedElement

type QueuedElement struct {
	Channel int64
	Guild   int64

	ID int64

	// Where this feed originated from, responsible for handling discord specific errors
	Source string
	// Could be stuff like reddit feed element id, youtube feed element id and so on
	SourceID string

	// The actual message as a simple string
	MessageStr string `json:",omitempty"`

	// The actual message as an embed
	MessageEmbed *discordgo.MessageEmbed `json:",omitempty"`

	UseWebhook      bool
	WebhookUsername string
}

type Webhook

type Webhook struct {
	ID    int64
	Token string

	GuildID   int64
	ChannelID int64

	Plugin string
}

func CreateWebhook

func CreateWebhook(guildID int64, channelID int64, plugin string, avatar string) (*Webhook, error)

func FindCreateWebhook

func FindCreateWebhook(guildID int64, channelID int64, plugin string, avatar string) (*Webhook, error)

type WorkItem

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