Versions in this module Expand all Collapse all v1 v1.15.1 Jun 9, 2025 Changes in this version + const ClusterType + const NodeType + func ClientHasJSONSupport(c RedisClient) bool + func GetConnectedSlaves(ctx context.Context, c RedisClient) (int, error) + func GetServerVersion(c RedisClient) (string, error) + func ParseClientFromProperties(properties map[string]string, componentType metadata.ComponentType, ...) (RedisClient, *Settings, error) + func StartEntraIDTokenRefreshBackgroundRoutine(client RedisClient, username string, nextExpiration time.Time, ...) + type ConfigurationSubscribeArgs struct + HandleSubscribedChange func(ctx context.Context, req *configuration.SubscribeRequest, ...) + Handler configuration.UpdateHandler + ID string + IsAllKeysChannel bool + RedisChannel string + Req *configuration.SubscribeRequest + type Duration time.Duration + func (r *Duration) DecodeString(value string) error + type RedisClient interface + AuthACL func(ctx context.Context, username, password string) error + Close func() error + ConfigurationSubscribe func(ctx context.Context, args *ConfigurationSubscribeArgs) + 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) + GetDel 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, streamTTL string, ...) (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 + type Settings struct + ClientCert string + ClientKey string + Concurrency uint + ConsumerID string + DB int + DialTimeout Duration + EnableTLS bool + Failover bool + Host string + IdleCheckFrequency Duration + IdleTimeout Duration + MaxConnAge Duration + MaxLenApprox int64 + MinIdleConns int + Password string + PoolSize int + PoolTimeout Duration + ProcessingTimeout time.Duration + QueryIndexes string + QueueDepth uint + ReadTimeout Duration + RedeliverInterval time.Duration + RedisMaxRetries int + RedisMaxRetryInterval Duration + RedisMinRetryInterval Duration + RedisType string + SentinelMasterName string + StreamTTL time.Duration + TTLInSeconds *int + UseEntraID bool + Username string + WriteTimeout Duration + func (s *Settings) Decode(in interface{}) error + func (s *Settings) GetEntraIDCredentialAndSetInitialTokenAsPassword(ctx context.Context, properties *map[string]string) (*time.Time, *azcore.TokenCredential, error) + func (s *Settings) GetMinID(now time.Time) string + func (s *Settings) SetCertificate(fn func(cert *tls.Certificate)) error
Go to main page