rctx

type Ctx struct {
	// Conf contains the router state for this context.
	Conf *conf.Conf
	// LockSockIn is a slice of Sock's for receiving packets from the local AS,
	// indexed by the local address index.
	LocSockIn []*Sock
	// LocSockOut is a slice of Sock's for sending packets to the local AS,
	// indexed by the local address index.
	LocSockOut []*Sock
	// ExtSockIn is a map of Sock's for receiving packets from neighbouring
	// ASes, keyed by the interface ID of the relevant link.
	ExtSockIn map[common.IFIDType]*Sock
	// ExtSockOut is a map of Sock's for sending packets to neighbouring ASes,
	// keyed by the interface ID of the relevant link.
	ExtSockOut map[common.IFIDType]*Sock
}

type Sock struct {
	// Ring is a ring-buffer that's written to by writers, and read from by readers.
	Ring *ringbuf.Ring
	// Conn is the underlying connection that this Sock represents.
	Conn conn.Conn
	// Dir is the direction that a packet is being read from/written to.
	Dir rcmn.Dir
	// Ifids is the list of interface IDs associated with a connection.
	Ifids []common.IFIDType
	// LocIdx is the local address index. It is only meaningful for packets
	// received from the local AS.
	LocIdx int
	// Labels holds the exported prometheus labels.
	Labels prometheus.Labels
	// Reader is an optional function that reads from Sock.Ring. It is spawned
	// in a go routine when Sock.Start() is called.
	Reader SockFunc
	// Writer is an optional function that writes to Sock.Ring. It is spawned
	// in a go routine when Sock.Start() is called.
	Writer SockFunc
	// contains filtered or unexported fields
}

type SockFunc func(sock *Sock, stop, stopped chan struct{})