rtio

README

RTIO (Real Time Input Output)

Engine for broadcasting based communication.

Documentation

Index

• type Client
  • func (c *Client) CloseConn()
  • func (c *Client) ReadMessages()
  • func (c *Client) WriteMessages()
• type Hub
  • func CreateHub() *Hub
  • func (h *Hub) ClearClient(c *Client)
  • func (h *Hub) Run()

Types

type Client

type Client struct {
	Hub             *Hub
	Conn            *ws.Conn
	ReadSizeLimit   int64
	PingInterval    time.Duration
	PongWait        time.Duration
	MessagesToSend  chan []byte
	ValidateMessage func(msg []byte, client *Client) (bool, []byte)
}

func (*Client) CloseConn

func (c *Client) CloseConn()

func (*Client) ReadMessages

func (c *Client) ReadMessages()

func (*Client) WriteMessages

func (c *Client) WriteMessages()

type Hub

type Hub struct {
	Clients     map[*Client]bool
	Subscribe   chan *Client
	Unsubscribe chan *Client
}

func CreateHub

func CreateHub() *Hub

func (*Hub) ClearClient

func (h *Hub) ClearClient(c *Client)

func (*Hub) Run

func (h *Hub) Run()