Documentation ¶
Index ¶
- Variables
- func MarshalHeader(h Header) ([]byte, error)
- func MarshalPacket(p Packet) ([]byte, error)
- func WithData(v interface{}) ofn.OFN
- func WithError(err error) ofn.OFN
- func WithPacket(p Packet) ofn.OFN
- type BroadcastHeader
- type BroadcastPacket
- type Header
- type NewBroadcastPacketOption
- type NewPacketOption
- type Packet
- type Type
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidPacket = fmt.Errorf("invalid packet") ErrPacketIsNil = fmt.Errorf("packet is nil") )
Functions ¶
func MarshalHeader ¶
func MarshalPacket ¶
func WithPacket ¶
Types ¶
type BroadcastHeader ¶
type BroadcastHeader interface { Session() int32 Source() string Destination() string Type() Type Method() string Hop() int32 }
func InvertBroadcastHeader ¶
func InvertBroadcastHeader(in BroadcastHeader) (out BroadcastHeader)
func NewBroadcastHeader ¶
type BroadcastPacket ¶
type BroadcastPacket interface { Header() BroadcastHeader Err() error Packet() Packet SetPacket(Packet) BroadcastPacket }
func NewBroadcastPacket ¶
func NewBroadcastPacket(h BroadcastHeader, opts ...NewBroadcastPacketOption) (BroadcastPacket, error)
func PacketToBroadcastPacketE ¶
func PacketToBroadcastPacketE(p Packet) (bp BroadcastPacket, err error)
type Header ¶
type Header interface { Session() int32 Source() string Destination() string Type() Type Method() string Signature() []byte SetSignature([]byte) Header UnsetSignature() Header msgpack.Marshaler msgpack.Unmarshaler }
func InvertHeader ¶
func UnmarshalHeader ¶
type NewPacketOption ¶
type Packet ¶
type Packet interface { Header() Header Err() error Data(out interface{}) error SetSignature([]byte) Packet UnsetSignature() Packet msgpack.Marshaler msgpack.Unmarshaler }
func BroadcastPacketToPacket ¶
func BroadcastPacketToPacket(bp BroadcastPacket) (p Packet)
func BroadcastPacketToPacketE ¶
func BroadcastPacketToPacketE(bp BroadcastPacket) (p Packet, err error)
func UnmarshalPacket ¶
Click to show internal directories.
Click to hide internal directories.