packet

package

v0.0.0-...-27c307a Latest Latest Go to latest Published: Jan 4, 2022 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/PeerXu/meepo

Links

Open Source Insights

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
- func InvertBroadcastHeader(in BroadcastHeader) (out BroadcastHeader)
- func NewBroadcastHeader(sess int32, src, dst string, typ Type, meth string, hop int32) BroadcastHeader
type BroadcastPacket
- func NewBroadcastPacket(h BroadcastHeader, opts ...NewBroadcastPacketOption) (BroadcastPacket, error)
- func PacketToBroadcastPacketE(p Packet) (bp BroadcastPacket, err error)
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 MarshalHeader(h Header) ([]byte, error)

func MarshalPacket ¶

func MarshalPacket(p Packet) ([]byte, error)

func WithData ¶

func WithData(v interface{}) ofn.OFN

func WithError ¶

func WithError(err error) ofn.OFN

func WithPacket ¶

func WithPacket(p Packet) ofn.OFN

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 ¶

func NewBroadcastHeader(sess int32, src, dst string, typ Type, meth string, hop int32) BroadcastHeader

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 InvertHeader(in Header) Header

func NewHeader ¶

func NewHeader(sess int32, src, dst string, typ Type, meth string) Header

func UnmarshalHeader ¶

func UnmarshalHeader(b []byte) (Header, error)

type NewBroadcastPacketOption ¶

type NewBroadcastPacketOption = ofn.OFN

type NewPacketOption ¶

type NewPacketOption = ofn.OFN

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 NewPacket ¶

func NewPacket(h Header, opts ...NewPacketOption) (Packet, error)

func UnmarshalPacket ¶

func UnmarshalPacket(b []byte) (Packet, error)

type Type ¶

type Type string

const (
	Request           Type = "request"
	Response          Type = "response"
	BroadcastRequest  Type = "broadcastRequest"
	BroadcastResponse Type = "broadcastResponse"
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL