mq

Sep 20, 2023

Changes in this version

+ var InvalidStoreType = errors.New("invalid StoreType type")

+ func WithMq(ctx context.Context, c *Config) context.Context

+ func WithMqContext(c *Config) contextx.WithContext

+ type Config struct

+ Channel string

+ Limit int

+ PushQueueTimeout types.Duration

+ Store StoreType

+ WorkerCount int

+ func MqFromContext(ctx context.Context) (*Config, bool)

+ func MustMqFromContext(ctx context.Context) *Config

+ func (c *Config) Init() error

+ func (c *Config) Name() string

+ func (c *Config) SetDefault()

+ type StoreType uint8

+ const STORE_TYPE_UNKNOWN

+ const STORE_TYPE__MEM

+ const STORE_TYPE__REDIS

+ func ParseStoreTypeFromLabel(s string) (StoreType, error)

+ func ParseStoreTypeFromString(s string) (StoreType, error)

+ func (v *StoreType) Scan(src interface{}) error

+ func (v *StoreType) UnmarshalText(data []byte) error

+ func (v StoreType) ConstValues() []enum.IntStringerEnum

+ func (v StoreType) Int() int

+ func (v StoreType) Label() string

+ func (v StoreType) MarshalText() ([]byte, error)

+ func (v StoreType) String() string

+ func (v StoreType) TypeName() string

+ func (v StoreType) Value() (driver.Value, error)