rwc

Feb 23, 2022

Changes in this version

+ type Client struct

+ Cancel context.CancelFunc

+ Context context.Context

+ File string

+ Hub *Hub

+ Messages *hub.Client

+ Websocket *reconws.ReconWs

+ func (c *Client) RelayIn(ctx context.Context)

+ func (c *Client) RelayOut(ctx context.Context)

+ type Hub struct

+ Add chan Rule

+ Broadcast chan hub.Message

+ Clients map[string]*Client

+ Delete chan string

+ Messages *agg.Hub

+ Rules map[string]Rule

+ func New(messages *agg.Hub) *Hub

+ func (h *Hub) Run(closed chan struct{})

+ type Rule struct

+ Destination string

+ File string

+ ID string

+ Stream string

+ Token string