rwc

README

rwc

(Re)connnects a /timdrysdale.hub stream to a dynamically reconfigurable ws endpoint

Documentation

Index

• type Client
  • func (c *Client) RelayIn(ctx context.Context)
  • func (c *Client) RelayOut(ctx context.Context)
• type Hub
  • func New(messages *agg.Hub) *Hub
  • func (h *Hub) Run(closed chan struct{})
• type Rule

Types

type Client

type Client struct {
	Hub       *Hub //can access messaging hub via <client>.Hub.Messages
	Messages  *hub.Client
	Context   context.Context
	Cancel    context.CancelFunc
	Websocket *reconws.ReconWs
	File      string
}

Client represents a client for sending outgoing messages

func (*Client) RelayIn

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

RelayIn relays from websocket server to the hub until stopped

func (*Client) RelayOut

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

RelayOut relays messages from the hub to the websocket client until stopped

type Hub

type Hub struct {
	Messages  *agg.Hub
	Clients   map[string]*Client //map Id string to client
	Rules     map[string]Rule    //map Id string to Rule
	Add       chan Rule
	Delete    chan string      //Id string
	Broadcast chan hub.Message //for messages incoming from the websocket server(s)
}

Hub represents a messaging hub

func New

func New(messages *agg.Hub) *Hub

New returns a pointer to a new Hub pass in the messaging hub as a parameter assume it is already running

func (*Hub) Run

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

Run starts the Hub

type Rule

type Rule struct {
	ID          string `json:"id"`
	Stream      string `json:"stream"`
	Destination string `json:"destination"`
	Token       string `json:"token"`
	File        string `json:"file"`
}

Rule represents a rule for outgoing messages