Documentation ¶
Index ¶
- type RedisZSetDriver
- func (rd *RedisZSetDriver) GetNodes(ctx context.Context) (nodes []string, err error)
- func (rd *RedisZSetDriver) Init(serviceName string, opts ...commons.Option)
- func (rd *RedisZSetDriver) NodeID() string
- func (rd *RedisZSetDriver) Start(ctx context.Context) (err error)
- func (rd *RedisZSetDriver) Stop(ctx context.Context) (err error)
- func (rd *RedisZSetDriver) WithOption(opt commons.Option) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisZSetDriver ¶
func NewDriver ¶
func NewDriver(redisClient redis.UniversalClient) *RedisZSetDriver
func (*RedisZSetDriver) GetNodes ¶
func (rd *RedisZSetDriver) GetNodes(ctx context.Context) (nodes []string, err error)
func (*RedisZSetDriver) Init ¶
func (rd *RedisZSetDriver) Init(serviceName string, opts ...commons.Option)
func (*RedisZSetDriver) NodeID ¶
func (rd *RedisZSetDriver) NodeID() string
func (*RedisZSetDriver) WithOption ¶
func (rd *RedisZSetDriver) WithOption(opt commons.Option) (err error)
Click to show internal directories.
Click to hide internal directories.