redis

Oct 9, 2023

Changes in this version

+ func GetConnectedSlaves(ctx context.Context, c RedisClient) (int, error)

Jun 6, 2023

Changes in this version

+ type ConfigurationSubscribeArgs struct

+ HandleSubscribedChange func(ctx context.Context, req *configuration.SubscribeRequest, ...)

+ Handler configuration.UpdateHandler

+ ID string

+ IsAllKeysChannel bool

+ RedisChannel string

+ Req *configuration.SubscribeRequest

+ Stop chan struct{}

type RedisClient

+ ConfigurationSubscribe func(ctx context.Context, args *ConfigurationSubscribeArgs)

+ GetDel func(ctx context.Context, key string) (string, error)

type Settings

+ Concurrency uint

+ ConsumerID string

+ MaxLenApprox int64

+ ProcessingTimeout time.Duration

+ QueryIndexes string

+ QueueDepth uint

+ RedeliverInterval time.Duration

+ TTLInSeconds *int

Mar 8, 2023

Changes in this version

+ func ClientHasJSONSupport(c RedisClient) bool

+ func GetServerVersion(c RedisClient) (string, error)

+ type RedisClient interface

+ Close func() error

+ Context func() context.Context

+ Del func(ctx context.Context, keys ...string) error

+ DoRead func(ctx context.Context, args ...interface{}) (interface{}, error)

+ DoWrite func(ctx context.Context, args ...interface{}) error

+ EvalInt func(ctx context.Context, script string, keys []string, args ...interface{}) (*int, error, error)

+ Get func(ctx context.Context, key string) (string, error)

+ GetNilValueError func() RedisError

+ PingResult func(ctx context.Context) (string, error)

+ SetNX func(ctx context.Context, key string, value interface{}, expiration time.Duration) (*bool, error)

+ TTLResult func(ctx context.Context, key string) (time.Duration, error)

+ TxPipeline func() RedisPipeliner

+ XAck func(ctx context.Context, stream string, group string, messageID string) error

+ XAdd func(ctx context.Context, stream string, maxLenApprox int64, ...) (string, error)

+ XClaimResult func(ctx context.Context, stream string, group string, consumer string, ...) ([]RedisXMessage, error)

+ XGroupCreateMkStream func(ctx context.Context, stream string, group string, start string) error

+ XPendingExtResult func(ctx context.Context, stream string, group string, start string, end string, ...) ([]RedisXPendingExt, error)

+ XReadGroupResult func(ctx context.Context, group string, consumer string, streams []string, ...) ([]RedisXStream, error)

+ func ClientFromV8Client(client v8.UniversalClient) RedisClient

+ type RedisError string

+ func (RedisError) RedisError()

+ func (e RedisError) Error() string

+ type RedisPipeliner interface

+ Do func(ctx context.Context, args ...interface{})

+ Exec func(ctx context.Context) error

+ type RedisXMessage struct

+ ID string

+ Values map[string]interface{}

+ type RedisXPendingExt struct

+ Consumer string

+ ID string

+ Idle time.Duration

+ RetryCount int64

+ type RedisXStream struct

+ Messages []RedisXMessage

+ Stream string

Jul 5, 2022

Changes in this version

+ type Metadata struct

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ QueryIndexes string

+ TTLInSeconds *int

+ func ParseRedisMetadata(properties map[string]string) (Metadata, error)

Nov 11, 2021

Changes in this version

type Settings

+ Username string

Nov 29, 2021

Changes in this version

+ const ClusterType

+ const NodeType

+ type Duration time.Duration

+ func (r *Duration) DecodeString(value string) error

+ type Settings struct

+ DB int

+ DialTimeout Duration

+ EnableTLS bool

+ Failover bool

+ Host string

+ IdleCheckFrequency Duration

+ IdleTimeout Duration

+ MaxConnAge Duration

+ MinIdleConns int

+ Password string

+ PoolSize int

+ PoolTimeout Duration

+ ReadTimeout Duration

+ RedisMaxRetries int

+ RedisMaxRetryInterval Duration

+ RedisMinRetryInterval Duration

+ RedisType string

+ SentinelMasterName string

+ WriteTimeout Duration

+ func ParseClientFromProperties(properties map[string]string, defaultSettings *Settings) (client redis.UniversalClient, settings *Settings, err error)

+ func (s *Settings) Decode(in interface{}) error