websocket

type Broadcast struct {
	// contains filtered or unexported fields
}

type Client struct {
	// contains filtered or unexported fields
}

type DispatchFunc func(uid int64, msg []byte)

type Hub struct {
	// contains filtered or unexported fields
}

type Logger interface {
	Info(logs ...interface{})
	Warn(logs ...interface{})
	Debug(logs ...interface{})
	Error(logs ...interface{})
}

type LoginFunc func(w http.ResponseWriter, r *http.Request) (int64, error)

type Option func(d *Hub)

type Redis interface {
	ZAdd(key string, members ...redis.Z) *redis.IntCmd
	Get(key string) *redis.StringCmd
	Set(key string, value interface{}, expiration time.Duration) *redis.StatusCmd
	ZRange(key string, start, stop int64) *redis.StringSliceCmd
	ZRem(key string, members ...interface{}) *redis.IntCmd
	ZCard(key string) *redis.IntCmd
	ZRemRangeByRank(key string, start, stop int64) *redis.IntCmd
	MGet(keys ...string) *redis.SliceCmd
	Pipeline() redis.Pipeliner
}

type RedisClient struct {
	MaxCount int
	MaxTtl   int
	// contains filtered or unexported fields
}