rediszsetdriver

package module
v0.0.0-...-3dc6625 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RedisZSetDriver

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

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) Start

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

func (*RedisZSetDriver) Stop

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

func (*RedisZSetDriver) WithOption

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL