party

package

v0.0.0-...-839ea1c Latest Latest Go to latest Published: Jul 16, 2024 License: GPL-3.0 Imports: 8 Imported by: 0

Details

Package party implements the logic to route clients into Rooms

View Source

const RouterBufSize = 1024

RouterBufSize router's channel size (handles Join/leave requests)

This section is empty.

This section is empty.

type InboxChan <-chan []byte

InboxChan is a read only message channel

type PostChan chan<- []byte

PostChan is a write only message channel

type Router struct {
	// contains filtered or unexported fields
}

Router routes messages according to rooms

func NewRouter(c <-chan event.Query) Router

NewRouter creates a New party Router

func (rt *Router) Run(ctx context.Context)

Run the Router's loop

Path	Synopsis
comms Package comms for internal message passing	Package comms for internal message passing
event Package event contains incoming notifications for parties	Package event contains incoming notifications for parties
notifier Package notifier wraps how to notify router of queries	Package notifier wraps how to notify router of queries
room Package room contains the code to multicast between clients	Package room contains the code to multicast between clients