router

Documentation

Index

• Variables
• type Broker
  • func NewBroker(routerID string, storage routerShared.Storage, logger *slog.Logger) *Broker
  • func (broker *Broker) Serve(newcomers *wampShared.Observable[*wamp.Peer])
• type Dealer
  • func NewDealer(routerID string, storage routerShared.Storage, logger *slog.Logger) *Dealer
  • func (dealer *Dealer) Serve(newcomers *wampShared.Observable[*wamp.Peer])
• type Referee
• type RegistrationList
• type Router
  • func NewRouter(ID string, storage routerShared.Storage, keyRing *routerShared.KeyRing, ...) *Router
  • func (router *Router) Serve()
  • func (router *Router) Shutdown()
• type Server
• type SubscriptionList

Variables

var (
	SomethingWentWrong = errors.New("SomethingWentWrong")
)

Types

type Broker

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

func NewBroker

func NewBroker(
	routerID string,
	storage routerShared.Storage,
	logger *slog.Logger,
) *Broker

func (*Broker) Serve

func (broker *Broker) Serve(newcomers *wampShared.Observable[*wamp.Peer])

type Dealer

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

func NewDealer

func NewDealer(
	routerID string,
	storage routerShared.Storage,
	logger *slog.Logger,
) *Dealer

func (*Dealer) Serve

func (dealer *Dealer) Serve(newcomers *wampShared.Observable[*wamp.Peer])

type Referee

type Referee struct {
	ID string
	// contains filtered or unexported fields
}

type RegistrationList

type RegistrationList = routerShared.ResourceList[*wamp.RegisterOptions]

type Router

type Router struct {
	ID string

	Session   *wamp.Session
	KeyRing   *routerShared.KeyRing
	Storage   routerShared.Storage
	Broker    *Broker
	Dealer    *Dealer
	Newcomers *wampShared.Observable[*wamp.Peer]
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(
	ID string,
	storage routerShared.Storage,
	keyRing *routerShared.KeyRing,
	logger *slog.Logger,
) *Router

func (*Router) Serve

func (router *Router) Serve()

func (*Router) Shutdown

func (router *Router) Shutdown()

type Server

type Server interface {
	Serve() error
	Shutdown() error
}

type SubscriptionList

type SubscriptionList = routerShared.ResourceList[*wamp.SubscribeOptions]