Versions in this module Expand all Collapse all v0 v0.2.0 Dec 5, 2023 Changes in this version + func Bool(val bool) *bool + func Encode(m *Message) []byte + func Float64(val float64) *float64 + func Int64(val int64) *int64 + func Time(v time.Duration) *time.Duration + type AllowOption struct + Jitter *bool + RetryCount *int64 + RetryDelay *time.Duration + RetryFactor *float64 + RetryMax *time.Duration + RetryMin *time.Duration + Timeout *time.Duration + type Message struct + Data []byte + Jitter bool + Payload []byte + RetryCount int64 + RetryDelay time.Duration + RetryFactor float64 + RetryMax time.Duration + RetryMin time.Duration + Task TaskFunc + Timeout time.Duration + func Decode(m []byte) *Message + func NewMessage(m core.QueuedMessage, opts ...AllowOption) Message + func NewTask(task TaskFunc, opts ...AllowOption) Message + func (m *Message) Bytes() []byte + func (m *Message) Encode() + type Options struct + func NewOptions(opts ...AllowOption) Options + type TaskFunc func(context.Context) error
Go to main page