fibcnet

Documentation

Index

• Constants
• func ReadBytes(r io.Reader, length int64) ([]byte, error)
• func SockAddr(ifindex int) syscall.Sockaddr
• func Write(w io.Writer, t uint16, xid uint32, b []byte) error
• func WriteMessage(w io.Writer, msg Message, xid uint32) error
• type Client
  • func NewClient(addr string) *Client
  • func (c *Client) Conn() <-chan bool
  • func (c *Client) Read() (*Header, []byte, error)
  • func (c *Client) SetRetyTime(msec time.Duration)
  • func (c *Client) Start(callback ClientConnectedCallback)
  • func (c *Client) Stop()
  • func (c *Client) Write(msg Message, xid uint32) error
• type ClientConnectedCallback
• type Connection
  • func NewConnection(addr string) *Connection
  • func (c *Connection) Close()
  • func (c *Connection) Connect() error
  • func (c *Connection) Read() (*Header, []byte, error)
  • func (c *Connection) Write(msg Message, xid uint32) error
• type EthHdr
• type FFPacket
  • func NewFFPacket(reId string, hwAddr net.HardwareAddr, ifname string) *FFPacket
  • func (p *FFPacket) Bytes() ([]byte, error)
• type Header
  • func ParseHeader(data []byte) (*Header, error)
  • func Read(r io.Reader) (*Header, []byte, error)
  • func ReadHeader(r io.Reader) (*Header, error)
• type Message

Constants

const (
	FFPACKET_ETHTYPE uint16 = 0x0a0a
)

const HEADER_LEN = 8

Functions

func ReadBytes

func ReadBytes(r io.Reader, length int64) ([]byte, error)

func SockAddr

func SockAddr(ifindex int) syscall.Sockaddr

func Write

func Write(w io.Writer, t uint16, xid uint32, b []byte) error

func WriteMessage

func WriteMessage(w io.Writer, msg Message, xid uint32) error

Types

type Client

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

Client

func NewClient

func NewClient(addr string) *Client

func (*Client) Conn

func (c *Client) Conn() <-chan bool

func (*Client) Read

func (c *Client) Read() (*Header, []byte, error)

func (*Client) SetRetyTime

func (c *Client) SetRetyTime(msec time.Duration)

func (*Client) Start

func (c *Client) Start(callback ClientConnectedCallback)

func (*Client) Stop

func (c *Client) Stop()

func (*Client) Write

func (c *Client) Write(msg Message, xid uint32) error

type ClientConnectedCallback

type ClientConnectedCallback func(client *Client)

type Connection

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

Connection

func NewConnection

func NewConnection(addr string) *Connection

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) Connect

func (c *Connection) Connect() error

func (*Connection) Read

func (c *Connection) Read() (*Header, []byte, error)

func (*Connection) Write

func (c *Connection) Write(msg Message, xid uint32) error

type EthHdr

type EthHdr struct {
	EthDst  [6]byte
	EthSrc  [6]byte
	EthType uint16
}

type FFPacket

type FFPacket struct {
	EthHdr

	ReId   [24]byte
	Ifname [24]byte
	// contains filtered or unexported fields
}

func NewFFPacket

func NewFFPacket(reId string, hwAddr net.HardwareAddr, ifname string) *FFPacket

func (*FFPacket) Bytes

func (p *FFPacket) Bytes() ([]byte, error)

type Header

type Header struct {
	Type   uint16
	Length uint16
	Xid    uint32
}

func ParseHeader

func ParseHeader(data []byte) (*Header, error)

func Read

func Read(r io.Reader) (*Header, []byte, error)

func ReadHeader

func ReadHeader(r io.Reader) (*Header, error)

type Message

type Message interface {
	Bytes() ([]byte, error)
	Type() uint16
}