adapter

Documentation

Index

• func AdaptUDP(adapter Adapter)
• func AdaptWS(adapter Adapter)
• func ReceiveUDP(ID string, event pipes.Event, msg []byte)
• func ReceiveWeb(ID string, event pipes.Event, msg []byte)
• func RemoveUDP(ID string)
• func RemoveWS(ID string)
• func SetupCaching()
• type Adapter
• type Context

Functions

func AdaptUDP

func AdaptUDP(adapter Adapter)

Register a new adapter for UDP

func AdaptWS

func AdaptWS(adapter Adapter)

Register a new adapter for websocket/sl (all safe protocols)

func ReceiveUDP

func ReceiveUDP(ID string, event pipes.Event, msg []byte)

Handles receiving messages from the target and passes them to the adapter

func ReceiveWeb

func ReceiveWeb(ID string, event pipes.Event, msg []byte)

Handles receiving messages from the target and passes them to the adapter

func RemoveUDP

func RemoveUDP(ID string)

Remove a UDP adapter

func RemoveWS

func RemoveWS(ID string)

Remove a websocket/sl adapter

func SetupCaching

func SetupCaching()

Types

type Adapter

type Adapter struct {
	ID    string      // Identifier of the client
	Mutex *sync.Mutex // Mutex to prevent concurrent sending (WHY DO I NEED TO DO THIS??)
	Data  interface{} // Custom data (not required)

	// Functions
	Receive func(*Context) error
}

type Context

type Context struct {
	Event   *pipes.Event
	Message []byte
	Adapter *Adapter
}