server

Documentation

Index

• Variables
• func RegisterClient(conn *websocket.Conn, id string)
• func RemoveClient(conn *websocket.Conn)
• func SetSubscription(conn *websocket.Conn, patterns []string)
• func Start(cfg Config) error
• type ClientConn
• type Config

Variables

var (
	EventChannel = make(chan protocol.EventMsg, 100)
)

Functions

func RegisterClient

func RegisterClient(conn *websocket.Conn, id string)

RegisterClient adds a client after successful auth.

func RemoveClient

func RemoveClient(conn *websocket.Conn)

RemoveClient removes a disconnected client.

func SetSubscription

func SetSubscription(conn *websocket.Conn, patterns []string)

SetSubscription updates the client's subscription patterns.

func Start

func Start(cfg Config) error

Types

type ClientConn

type ClientConn struct {
	Conn     *websocket.Conn
	ID       string
	Patterns []string
}

ClientConn represents a connected client.

type Config

type Config struct {
	WebhookSecret string
	ClientTokens  map[string]bool
	CommsTokens   map[string]bool
	ListenAddr    string
}