ws

Dec 20, 2024

Changes in this version

+ const ERR_ADAPTER_NOT_FOUND

+ const ERR_NOT_SIGNATURE

+ func TypeMessages() et.Json

type Adapter

+ func NewWSAdapter() Adapter

+ Close func()

+ ConnectTo func(hub *Hub, params et.Json) error

+ Publish func(channel string, msg Message) error

+ Subscribed func(channel string)

+ UnSubscribed func(channel string)

+ type AdapterRedis struct

+ func (s *AdapterRedis) Close()

+ func (s *AdapterRedis) ConnectTo(hub *Hub, params et.Json) error

+ func (s *AdapterRedis) Publish(channel string, msg Message) error

+ func (s *AdapterRedis) Subscribed(channel string)

+ func (s *AdapterRedis) UnSubscribed(channel string)

+ type AdapterWS struct

+ func (s *AdapterWS) Close()

+ func (s *AdapterWS) ConnectTo(hub *Hub, params et.Json) error

+ func (s *AdapterWS) Publish(channel string, msg Message) error

+ func (s *AdapterWS) Subscribed(channel string)

+ func (s *AdapterWS) UnSubscribed(channel string)

type Client

+ ClientId string

+ func Login(config *ClientConfig) (*Client, error)

+ func (c *Client) ConnectTo(path string) error

type Hub

+ func (h *Hub) HttpLogin(w http.ResponseWriter, r *http.Request)

+ func (h *Hub) JoinTo(master et.Json) error

type TpMessage

+ func (s TpMessage) Int() int

Nov 27, 2024

Changes in this version

+ const ERR_CLIENT_DISCONNECTED

+ const ERR_INVALID_ID

+ const ERR_INVALID_NAME

+ const ERR_QUEUE_EMPTY

+ const MSG_CONNECT_SUCCESSFULLY

+ const MSG_DISCONNECT_SUCCESSFULLY

+ const ServiceName

+ type Adapter struct

+ type AdapterConfig struct

+ Header http.Header

+ Reconcect int

+ TypeNode TypeNode

+ Url string

type Client

+ Attempts *race.Value

+ Connected *race.Value

+ func NewClient(config *ClientConfig) (*Client, error)

+ func (c *Client) Close()

+ func (c *Client) Connect() error

+ func (c *Client) DirectMessage(msg Message)

+ func (c *Client) From() et.Json

+ func (c *Client) Listener()

+ func (c *Client) Ping()

+ func (c *Client) Publish(channel string, message interface{})

+ func (c *Client) Queue(channel, queue string, reciveFn func(Message))

+ func (c *Client) Reconnect()

+ func (c *Client) ReconnectCallback()

+ func (c *Client) SendMessage(clientId string, message interface{}) error

+ func (c *Client) SetDirectMessageCallback(reciveFn func(Message))

+ func (c *Client) SetFrom(name string) error

+ func (c *Client) SetReconnectCallback(reciveFn func(c *Client))

+ func (c *Client) Stack(channel string, reciveFn func(Message))

+ func (c *Client) Subscribe(channel string, reciveFn func(Message))

+ func (c *Client) Unsubscribe(channel string)

+ type ClientConfig struct

+ ClientId string

+ Header http.Header

+ Name string

+ Reconnect int

+ Url string

+ func (s *ClientConfig) From() et.Json

type Hub

+ Host string

+ func ServerHttp(port int, mode, masterURL string) *Hub

+ func (h *Hub) Close()

+ func (h *Hub) ClusterPublish(channel string, msg Message)

+ func (h *Hub) ClusterSubscribed(channel string)

+ func (h *Hub) ClusterUnSubscribed(channel string)

+ func (h *Hub) Describe() et.Json

+ func (h *Hub) DrainChannel(channel, queue string) error

+ func (h *Hub) From() et.Json

+ func (h *Hub) GetChanel(name string) *Channel

+ func (h *Hub) GetChannels(name, queue string) et.Items

+ func (h *Hub) GetClients(key string) et.Items

+ func (h *Hub) HttpConnect(w http.ResponseWriter, r *http.Request)

+ func (h *Hub) HttpDescribe(w http.ResponseWriter, r *http.Request)

+ func (h *Hub) HttpGetPublications(w http.ResponseWriter, r *http.Request)

+ func (h *Hub) HttpGetSubscribers(w http.ResponseWriter, r *http.Request)

+ func (h *Hub) HttpStream(w http.ResponseWriter, r *http.Request)

+ func (h *Hub) InitMaster()

+ func (h *Hub) IsRun() bool

+ func (h *Hub) Join(config AdapterConfig) error

+ func (h *Hub) Live()

+ func (h *Hub) NewChannel(name string, duration time.Duration) *Channel

+ func (h *Hub) NewQueue(name, queue string, duration time.Duration) *Queue

+ func (h *Hub) QueueSubscribe(clientId string, channel, queue string) error

+ func (h *Hub) Start()

type Message

+ Queue string

+ To string

+ func (e Message) ToJson() et.Json

+ type Queue struct

+ Name string

+ Queue string

+ Subscribers []*Subscriber

+ Turn int

+ func (c *Queue) Count() int

+ type Subscriber struct

+ Addr string

+ Channels map[string]*Channel

+ Created_at time.Time

+ Id string

+ Name string

+ Queue map[string]*Queue

+ func (c *Subscriber) From() et.Json

+ type TpMessage int

+ const TpConnect

+ const TpDisconnect

+ const TpPing

+ const TpPublish

+ const TpQueueSubscribe

+ const TpSetFrom

+ const TpStack

+ const TpSubscribe

+ const TpUnsubscribe

+ func ToTpMessage(s string) TpMessage

+ func (s TpMessage) String() string

+ func (s TpMessage) ToJson() et.Json

+ type TypeNode int

+ const NodeMaster

+ const NodeWorker

+ func (t TypeNode) String() string

+ func (t TypeNode) ToJson() et.Json

Aug 19, 2024

Changes in this version

+ const ERR_SERVER_NOT_FOUND

type Channel

+ Group map[string]int

+ func (ch *Channel) Broadcast(message []byte)

+ func (ch *Channel) QueueSubscribe(client *Client, queue string)

Jun 29, 2024

Changes in this version

+ const ERR_CHANNEL_EMPTY

+ const ERR_CHANNEL_NOT_FOUND

+ const ERR_CHANNEL_NOT_SUBSCRIBERS

+ const ERR_CLIENT_ID_EMPTY

+ const ERR_CLIENT_IS_CLOSED

+ const ERR_CLIENT_NOT_FOUND

+ const ERR_MESSAGE_UNFORMATTED

+ const ERR_NOT_CONNECT_WS

+ const ERR_NOT_DEFINE_CLIENTID

+ const ERR_NOT_DEFINE_USERNAME

+ const ERR_NOT_WS_SERVICE

+ const ERR_PARAM_NOT_FOUND

+ const ERR_REDISADAPTER_NOT_FOUND

+ const MSG_CLIENT_CONNECT

+ const MSG_CLIENT_DISCONNECT

+ const PARAMS_UPDATED

+ func Close() error

+ func ConnectWs(host, scheme, clientId, name string) (*websocket.Conn, error)

+ type Channel struct

+ Name string

+ Subscribers []*Client

+ TpBroadcast TpBroadcast

+ func (ch *Channel) Count() int

+ func (ch *Channel) Low() string

+ func (ch *Channel) NextTurn() *Client

+ func (ch *Channel) Subscribe(client *Client)

+ func (ch *Channel) Unsubcribe(clientId string) error

+ func (ch *Channel) Up() string

+ type Client struct

+ Addr string

+ Channels []string

+ Created_at time.Time

+ Id string

+ Name string

+ func ConnectHttp(w http.ResponseWriter, r *http.Request) (*Client, error)

+ func (c *Client) Identify() et.Json

+ type Conn struct

+ func Server() (*Conn, error)

+ type Hub struct

+ Id string

+ Name string

+ Params *HubParams

+ func NewHub() *Hub

+ func (h *Hub) GetSubscribers(channel string) []*Client

+ func (h *Hub) Identify() et.Json

+ func (h *Hub) Mute(channel string, msg Message, ignored []string, from et.Json) error

+ func (h *Hub) Publish(channel string, msg Message, ignored []string, from et.Json) error

+ func (h *Hub) RedisAdapter(params *RedisAdapterParams) error

+ func (h *Hub) Run()

+ func (h *Hub) SendMessage(clientId string, msg Message) error

+ func (h *Hub) SetName(name string)

+ func (h *Hub) Stack(clientId string, channel string) error

+ func (h *Hub) Subscribe(clientId string, channel string) error

+ func (h *Hub) Unsubscribe(clientId string, channel string) error

+ type HubParams struct

+ Id string

+ Name string

+ type Message struct

+ Channel string

+ Created_at time.Time

+ Data interface{}

+ From et.Json

+ Id string

+ Ignored []string

+ Tp m.TpMessage

+ func DecodeMessage(data []byte) (Message, error)

+ func NewMessage(from et.Json, message interface{}, tp m.TpMessage) Message

+ func (e Message) Encode() ([]byte, error)

+ func (e Message) Json() (et.Json, error)

+ func (e Message) ToString() string

+ func (e Message) Type() m.TpMessage

+ type MessageBroadcast struct

+ From et.Json

+ Ignored []string

+ Kind TpBroadcast

+ Msg Message

+ To string

+ func (m MessageBroadcast) Encode() ([]byte, error)

+ type PubSub struct

+ ClientId string

+ Name string

+ func NewPubSub() (*PubSub, error)

+ func (p *PubSub) Close()

+ func (p *PubSub) Connect() (bool, error)

+ func (p *PubSub) IsConnected() bool

+ func (p *PubSub) Params(params et.Json) error

+ func (p *PubSub) Ping()

+ func (p *PubSub) Publish(channel string, message interface{})

+ func (p *PubSub) SendMessage(clientId string, message interface{}) error

+ func (p *PubSub) Stack(channel string, reciveFn func(m.Message))

+ func (p *PubSub) Subscribe(channel string, reciveFn func(m.Message))

+ func (p *PubSub) Type() string

+ func (p *PubSub) Unsubscribe(channel string)

+ type RedisAdapter struct

+ func NewRedisAdapter(params *RedisAdapterParams) (*RedisAdapter, error)

+ func (a *RedisAdapter) Broadcast(to string, msg Message, ignored []string, from et.Json) error

+ func (a *RedisAdapter) Close() error

+ func (a *RedisAdapter) Command(command string, params et.Json) error

+ func (a *RedisAdapter) Direct(to string, msg Message) error

+ type RedisAdapterParams struct

+ Addr string

+ DB int

+ Password string

+ type TpBroadcast int

+ const TpAll

+ const TpCommand

+ const TpDirect

+ const TpRoundRobin

+ func (tp TpBroadcast) String() string

+ type WsMessage struct

+ Payload interface{}

+ Type string