redisdriver

Documentation

Index

• type RedisDriver
  • func NewDriver(redisClient redis.UniversalClient) *RedisDriver
  • func (rd *RedisDriver) GetNodes(ctx context.Context) (nodes []string, err error)
  • func (rd *RedisDriver) Init(serviceName string, opts ...commons.Option)
  • func (rd *RedisDriver) NodeID() string
  • func (rd *RedisDriver) Start(ctx context.Context) (err error)
  • func (rd *RedisDriver) Stop(ctx context.Context) (err error)
  • func (rd *RedisDriver) WithOption(opt commons.Option) (err error)

Types

type RedisDriver

type RedisDriver struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewDriver

func NewDriver(redisClient redis.UniversalClient) *RedisDriver

func (*RedisDriver) GetNodes

func (rd *RedisDriver) GetNodes(ctx context.Context) (nodes []string, err error)

func (*RedisDriver) Init

func (rd *RedisDriver) Init(serviceName string, opts ...commons.Option)

func (*RedisDriver) NodeID

func (rd *RedisDriver) NodeID() string

func (*RedisDriver) Start

func (rd *RedisDriver) Start(ctx context.Context) (err error)

func (*RedisDriver) Stop

func (rd *RedisDriver) Stop(ctx context.Context) (err error)

func (*RedisDriver) WithOption

func (rd *RedisDriver) WithOption(opt commons.Option) (err error)