router

Documentation

Index

• func Close()
• func SetRateLimiter(l *rate.Limiter)
• type Router
  • func (r *Router) Sweep()
• type Switch
  • func NewSwitch(f func(uint32, []byte)) Switch
  • func (s *Switch) Received(id uint32, message []byte, h func([]byte))

Functions

func Close

func Close()

func SetRateLimiter

func SetRateLimiter(l *rate.Limiter)

Types

type Router

type Router struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Router) Sweep

func (r *Router) Sweep()

type Switch

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

func NewSwitch

func NewSwitch(f func(uint32, []byte)) Switch

func (*Switch) Received

func (s *Switch) Received(id uint32, message []byte, h func([]byte))