redis_storage

package

v1.0.2 Latest Latest Go to latest Published: Oct 3, 2023 License: Apache-2.0 Imports: 7 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type RedisNode struct {
	RedisConf *redis.Options
	Position  int64 //the position of hash ring
}

type RedisStorage struct {
	session_storage.SessionStorage
	// contains filtered or unexported fields
}

func NewRedisStorage(redisClient *eredis.RedisClient) *RedisStorage

NewRedisStorage return a RedisStorage

func (this *RedisStorage) BindClientId(nodeAddr string, clientId string) error

BindClientId set online with clientId

func (this *RedisStorage) ClientIdsOnline(clientIds []string) []string

ClientIdsOnline Get online users in the group

func (this *RedisStorage) ClientIdsOnlineWithLua(clientIds []string) []string

ClientIdsOnlineWithLua Get online users in the group

func (this *RedisStorage) GetClientsIps(clientIds []string) (map[string][]string, error)

GetIps get ip list by clientId list

func (this *RedisStorage) GetIps(clientId string) ([]string, error)

GetIps get ip list by clientId

func (this *RedisStorage) IsOnline(clientId string) bool

IsOnline determine if a clientId is online

func (this *RedisStorage) OnClientPing(nodeAddr string, clientId string) error

OnClientPing receive client heartbeat