mqueue

type DiscordProcessor struct {
}

type ItemProcessor interface {
	ProcessItem(resp chan *workResult, wi *workItem)
}

type MqueueServer struct {
	PushWork chan *workItem

	Stop chan *sync.WaitGroup
	// contains filtered or unexported fields
}

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

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

type PluginWithWebhookAvatar interface {
	WebhookAvatar() string
}

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

type QueuedElement struct {
	// The channel to send the message in
	ChannelID int64 `json:"Channel"`
	GuildID   int64 `json:"Guild"`

	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
	SourceItemID string `json:"SourceID"`

	// 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

	AllowedMentions discordgo.AllowedMentions `json:"allowed_mentions"`

	// Publish the message if the channel is an announcement channel
	PublishAnnouncement bool

	// When the queue grows, the feeds with the highest priority gets sent first
	Priority int

	CreatedAt time.Time
}

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

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

type Storage interface {
	GetFullQueue() ([]*workItem, error)
	AppendItem(elem *QueuedElement) error
	DelItem(elem *workItem) error
	NextID() (int64, error)
}