Versions in this module Expand all Collapse all v0 v0.5.0 Apr 7, 2025 Changes in this version type RedisConnectOptions + Addrs []string + ClientName string + ConnMaxIdleTime time.Duration + ConnMaxLifetime time.Duration + ContextTimeout bool + DialTimeout time.Duration + DisableIdentity bool + IdentitySuffix string + MasterName string + MaxActiveConns int + MaxIdleConns int + MaxRedirects int + MaxRetryBackoff time.Duration + MinIdleConns int + MinRetryBackoff time.Duration + PoolFIFO bool + PoolTimeout time.Duration + Protocol int + ReadOnly bool + ReadTimeout time.Duration + RouteByLatency bool + RouteRandomly bool + SentinelPassword string + SentinelUsername string + TLS *TLS + UnstableResp3 bool + WriteTimeout time.Duration v0.4.0 Mar 21, 2025 v0.3.0 Mar 20, 2025 v0.2.9 Feb 7, 2025 Changes in this version + const PrefixKey + func GetRedisClient() *redis.Client + func SetRedisClient(c *redis.Client) + type AdapterCache interface + Decrease func(ctx context.Context, key string) error + Del func(ctx context.Context, key string) error + Expire func(ctx context.Context, key string, dur time.Duration) error + Get func(ctx context.Context, key string) (string, error) + HashDel func(ctx context.Context, hk, key string) error + HashGet func(ctx context.Context, hk, key string) (string, error) + Increase func(ctx context.Context, key string) error + Initialize func(*gorm.DB) error + Name func() string + RemoveFromTag func(ctx context.Context, tag string) error + Set func(ctx context.Context, key string, val interface{}, expire time.Duration) error + String func() string + type AdapterLocker interface + Lock func(ctx context.Context, key string, ttl time.Duration, options *redislock.Options) (*redislock.Lock, error) + String func() string + type AdapterQueue interface + Append func(opts ...Option) error + Register func(opts ...Option) + Run func(context.Context) + Shutdown func() + String func() string + type ConsumerFunc func(Messager) error + type Messager interface + GetContext func() context.Context + GetErrorCount func() int + GetID func() string + GetPrefix func() string + GetStream func() string + GetValues func() map[string]interface{} + SetContext func(ctx context.Context) + SetErrorCount func(count int) + SetID func(string) + SetPrefix func(string) + SetStream func(string) + SetValues func(map[string]interface{}) + type NSQOptions struct + Addresses []string + AdminAddr string + AuthSecret string + BackoffMultiplier time.Duration + ClientID string + DefaultRequeueDelay time.Duration + Deflate bool + DeflateLevel int + DialTimeout time.Duration + HeartbeatInterval time.Duration + Hostname string + LookupdAddr string + LookupdPollInterval time.Duration + LookupdPollJitter float64 + LowRdyIdleTimeout time.Duration + LowRdyTimeout time.Duration + MaxAttempts uint16 + MaxBackoffDuration time.Duration + MaxInFlight int + MaxRequeueDelay time.Duration + MsgTimeout time.Duration + OutputBufferSize int64 + OutputBufferTimeout time.Duration + RDYRedistributeInterval time.Duration + ReadTimeout time.Duration + SampleRate int32 + Snappy bool + Tls *TLS + UserAgent string + WriteTimeout time.Duration + func (e NSQOptions) GetNSQOptions() (*nsq.Config, error) + type Option func(*Options) + func WithConsumerFunc(f ConsumerFunc) Option + func WithGroupID(groupID string) Option + func WithKafkaConfig(c *sarama.Config) Option + func WithMessage(message Messager) Option + func WithPartition(partition int) Option + func WithStrategy(f sarama.BalanceStrategy) Option + func WithTopic(topic string) Option + type Options struct + F ConsumerFunc + GroupID string + KafkaConfig *sarama.Config + Message Messager + Partition int + PartitionAssignmentStrategy sarama.BalanceStrategy + Topic string + func DefaultOptions() *Options + func SetOptions(opts ...Option) *Options + type RedisConnectOptions struct + Addr string + DB int + MaxRetries int + Network string + Password string + PoolSize int + Tls *TLS + Username string + func (e RedisConnectOptions) GetRedisOptions() (*redis.Options, error) + type TLS struct + Ca string + Cert string + Key string
Go to main page