client

Aug 31, 2022

Changes in this version

type FakeClient

+ func (fc *FakeClient) RedisConfigSet(ctx context.Context, parameter, value string) error

+ func (fc *FakeClient) RedisDebugSleep(ctx context.Context, duration time.Duration) error

type GoRedisClient

+ func (c *GoRedisClient) RedisConfigSet(ctx context.Context, parameter, value string) error

+ func (c *GoRedisClient) RedisDebugSleep(ctx context.Context, duration time.Duration) error

Apr 1, 2022

Changes in this version

type FakeClient

+ func (fc *FakeClient) Close() error

type GoRedisClient

+ func (c *GoRedisClient) Close() error

+ func (c *GoRedisClient) CloseRedis() error

+ func (c *GoRedisClient) CloseSentinel() error

Jan 27, 2022

Changes in this version

type FakeClient

+ func (fc *FakeClient) SentinelInfoCache(ctx context.Context) (interface{}, error)

type GoRedisClient

+ func (c *GoRedisClient) SentinelInfoCache(ctx context.Context) (interface{}, error)

+ type RedisServerInfoCache struct

+ CacheAge time.Duration

+ Info map[string]string

+ type SentinelInfoCache map[string]map[string]RedisServerInfoCache

+ func (sic SentinelInfoCache) GetValue(shard, runID, key string, maxCacheAge time.Duration) (string, error)

Jan 12, 2022

Changes in this version

+ type FakeClient struct

+ Responses []FakeResponse

+ func (fc *FakeClient) RedisConfigGet(ctx context.Context, parameter string) ([]interface{}, error)

+ func (fc *FakeClient) RedisRole(ctx context.Context) (interface{}, error)

+ func (fc *FakeClient) RedisSlaveOf(ctx context.Context, host, port string) error

+ func (fc *FakeClient) SentinelMaster(ctx context.Context, shard string) (*SentinelMasterCmdResult, error)

+ func (fc *FakeClient) SentinelMasters(ctx context.Context) ([]interface{}, error)

+ func (fc *FakeClient) SentinelMonitor(ctx context.Context, name, host string, port string, quorum int) error

+ func (fc *FakeClient) SentinelPSubscribe(ctx context.Context, events ...string) (<-chan *redis.Message, func() error)

+ func (fc *FakeClient) SentinelSet(ctx context.Context, shard, parameter, value string) error

+ func (fc *FakeClient) SentinelSlaves(ctx context.Context, shard string) ([]interface{}, error)

+ type FakeResponse struct

+ InjectError func() error

+ InjectResponse func() interface{}

+ type GoRedisClient struct

+ func NewFromConnectionString(connectionString string) (*GoRedisClient, error)

+ func NewFromOptions(opt *redis.Options) *GoRedisClient

+ func (c *GoRedisClient) RedisConfigGet(ctx context.Context, parameter string) ([]interface{}, error)

+ func (c *GoRedisClient) RedisRole(ctx context.Context) (interface{}, error)

+ func (c *GoRedisClient) RedisSlaveOf(ctx context.Context, host, port string) error

+ func (c *GoRedisClient) SentinelMaster(ctx context.Context, shard string) (*SentinelMasterCmdResult, error)

+ func (c *GoRedisClient) SentinelMasters(ctx context.Context) ([]interface{}, error)

+ func (c *GoRedisClient) SentinelMonitor(ctx context.Context, name, host string, port string, quorum int) error

+ func (c *GoRedisClient) SentinelPSubscribe(ctx context.Context, events ...string) (<-chan *redis.Message, func() error)

+ func (c *GoRedisClient) SentinelSet(ctx context.Context, shard, parameter, value string) error

+ func (c *GoRedisClient) SentinelSlaves(ctx context.Context, shard string) ([]interface{}, error)

+ type Role string

+ const Master

+ const Slave

+ const Unknown

+ type SentinelMasterCmdResult struct

+ ConfigEpoch int

+ DownAfterMilliseconds int

+ FailoverTimeout int

+ Flags string

+ IP string

+ InfoRefresh int

+ LastOkPingReply int

+ LastPingReply int

+ LastPingSent int

+ LinkPendingCommands int

+ LinkRefcount int

+ Name string

+ NumOtherSentinels int

+ NumSlaves int

+ ParallelSyncs int

+ Port int

+ Quorum int

+ RoleReported string

+ RoleReportedTime int

+ RunID string

+ type SentinelSlaveCmdResult struct

+ DownAfterMilliseconds int

+ Flags string

+ IP string

+ InfoRefresh int

+ LastOkPingReply int

+ LastPingReply int

+ LastPingSent int

+ LinkPendingCommands int

+ LinkRefcount int

+ MasterHost string

+ MasterLinkDownTime int

+ MasterLinkStatus string

+ MasterPort int

+ Name string

+ Port int

+ RoleReported string

+ RoleReportedTime int

+ RunID string

+ SlavePriority int

+ SlaveReplOffset int