redisqueue

func Enabled ¶

func Enabled() bool

func Enqueue ¶

func Enqueue(payload []byte)

func EnqueueError ¶ added in v7.1.44

func EnqueueError(payload []byte)

func NotifyUsageRefresh ¶ added in v7.1.39

func NotifyUsageRefresh()

func PopOldest ¶

func PopOldest(count int) [][]byte

func SetEnabled ¶

func SetEnabled(value bool)

func SetRetentionSeconds ¶

func SetRetentionSeconds(value int)

func SetUsageStatisticsEnabled ¶

func SetUsageStatisticsEnabled(enabled bool)

SetUsageStatisticsEnabled toggles whether usage records are enqueued into the redisqueue payload buffer. This is controlled by the config field `usage-statistics-enabled` and the corresponding management API.

func SubscribeErrors ¶ added in v7.1.44

func SubscribeErrors() (<-chan []byte, func())

func SubscribeUsage ¶ added in v7.0.7

func SubscribeUsage() (<-chan []byte, func())

func UsageStatisticsEnabled ¶

func UsageStatisticsEnabled() bool

UsageStatisticsEnabled reports whether the usage queue plugin should publish records.