types

Documentation

Index

• Constants
• type Parser
• type RedisClient
  • func NewRedisClient(ctx context.Context, redis redis.UniversalClient) *RedisClient
• type RedisPacket
• type RedisRequest
• type RedisResponse
• type String
  • func (s *String) CompareAndSwap(old, new string) (swapped bool)
  • func (s *String) Load() string
  • func (s *String) Store(val string)
  • func (s *String) Swap(new string) (old string)

Constants

const (
	SOCKETS adapter.MessageType = iota
	ALL_ROOMS
	REMOTE_JOIN
	REMOTE_LEAVE
	REMOTE_DISCONNECT
	REMOTE_FETCH
	SERVER_SIDE_EMIT
	BROADCAST
	BROADCAST_CLIENT_COUNT
	BROADCAST_ACK
)

Types

type Parser

type Parser interface {
	Encode(any) ([]byte, error)
	Decode([]byte, any) error
}

type RedisClient

type RedisClient struct {
	events.EventEmitter

	Client  redis.UniversalClient
	Context context.Context
}

func NewRedisClient

func NewRedisClient(ctx context.Context, redis redis.UniversalClient) *RedisClient

type RedisPacket

type RedisPacket struct {
	Uid    adapter.ServerId       `json:"uid,omitempty" msgpack:"uid,omitempty"`
	Packet *parser.Packet         `json:"packet,omitempty" msgpack:"packet,omitempty"`
	Opts   *adapter.PacketOptions `json:"opts,omitempty" msgpack:"opts,omitempty"`
}

type RedisRequest

type RedisRequest struct {
	Type      adapter.MessageType    `json:"type,omitempty" msgpack:"type,omitempty"`
	RequestId string                 `json:"requestId,omitempty" msgpack:"requestId,omitempty"`
	Rooms     []socket.Room          `json:"rooms,omitempty" msgpack:"rooms,omitempty"`
	Opts      *adapter.PacketOptions `json:"opts,omitempty" msgpack:"opts,omitempty"`
	Sid       socket.SocketId        `json:"sid,omitempty" msgpack:"sid,omitempty"`
	Room      socket.Room            `json:"room,omitempty" msgpack:"room,omitempty"`
	Close     bool                   `json:"close,omitempty" msgpack:"close,omitempty"`
	Uid       adapter.ServerId       `json:"uid,omitempty" msgpack:"uid,omitempty"`
	Data      []any                  `json:"data,omitempty" msgpack:"data,omitempty"`
	Packet    *parser.Packet         `json:"packet,omitempty" msgpack:"packet,omitempty"`
}

type RedisResponse

type RedisResponse struct {
	Type        adapter.MessageType       `json:"type,omitempty" msgpack:"type,omitempty"`
	RequestId   string                    `json:"requestId,omitempty" msgpack:"requestId,omitempty"`
	Rooms       []socket.Room             `json:"rooms,omitempty" msgpack:"rooms,omitempty"`
	Sockets     []*adapter.SocketResponse `json:"sockets,omitempty" msgpack:"sockets,omitempty"`
	Data        []any                     `json:"data,omitempty" msgpack:"data,omitempty"`
	ClientCount uint64                    `json:"clientcount,omitempty" msgpack:"clientcount,omitempty"`
	Packet      []any                     `json:"packet,omitempty" msgpack:"packet,omitempty"`
}

type String

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

A String is an atomic string value. The zero value is "".

func (*String) CompareAndSwap

func (s *String) CompareAndSwap(old, new string) (swapped bool)

CompareAndSwap executes the compare-and-swap operation for the string value x.

func (*String) Load

func (s *String) Load() string

Load atomically loads and returns the value stored in x.

func (*String) Store

func (s *String) Store(val string)

Store atomically stores val into x.

func (*String) Swap

func (s *String) Swap(new string) (old string)

Swap atomically stores new into x and returns the previous value.