transport

type Connection ¶

type Connection struct {
	SendConn []*net.UDPConn
	// contains filtered or unexported fields
}

Connection is the state and working memory references for a simple reliable UDP lan transport, encrypted by a GCM AES cipher, with the simple protocol of sending out 9 packets containing encrypted FEC shards containing a slice of bytes. This protocol probably won't work well outside of a multicast lan in adverse conditions but it is designed for local network control systems

func NewConnection(send, listen, preSharedKey string, maxDatagramSize int, ctx context.Context, multicast bool) (c *Connection, err error)

func (c *Connection) CreateShards(b, magic []byte) (shards [][]byte,
	err error)

func (c *Connection) Listen(handlers HandleFunc, ifc interface{},
	lastSent *time.Time, firstSender *string) (err error)

func (c *Connection) Send(b, magic []byte) (err error)

func (c *Connection) SendShards(shards [][]byte) (err error)

func (c *Connection) SendShardsTo(shards [][]byte, addr *net.UDPAddr) (err error)

func (c *Connection) SendTo(addr *net.UDPAddr, b, magic []byte) (err error)

func (c *Connection) SetSendConn(ad ...string) (err error)

type HandleFunc ¶

type HandleFunc map[string]func(ctx interface{}) func(b []byte) (err error)

type MsgBuffer ¶

type MsgBuffer struct {
	Buffers [][]byte
	First   time.Time
	Decoded bool
	Source  *net.Addr
}