alfred

type AnnounceMasterV0 struct {
	Header *TLV
}

type ChangeInterfaceV0 struct {
	Header *TLV
	Ifaces *[ALFRED_IFNAMSIZ * 16]byte
}

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

type Content interface {
	GetPacketType() uint8
	ReadAlfred(Data) error
}

type Data struct {
	// origin of the data
	Source HardwareAddr
	// descriptor for the data
	Header *TLV
	// the actual data
	Data []byte
}

type HardwareAddr net.HardwareAddr

type ModeSwitchV0 struct {
	Header *TLV
	Mode   uint8
}

type Packet interface {
	// write the packet to the io.Writer, return an error if anything
	// went wrong.
	Write(io.Writer) error
	// return the size of the packet when put onto wire.
	Size() int
}

type PushDataV0 struct {
	Header *TLV
	Tx     *TransactionMgmt
	Data   []Data
}

type ReqGetAll struct {
	// if PACKETTYPE_ALL, return data of all types, otherwise
	// specify type to return
	TypeFilter uint8
	// if set to true, return only data that has its origin
	// locally, i.e. was not propagated by another master server
	LocalOnly bool
	// data will be sent back via this channel, it will get
	// closed as soon as all data has been sent
	Return chan<- Data
}

type ReqPut struct {
	// flag that tells if the data origin is the local server
	// instance (i.e. not propagated by another master server)
	IsLocal bool
	// actual data item
	Data
}

type RequestV0 struct {
	Header        *TLV
	RequestedType uint8
	TxId          uint16
}

type Server struct {
	// this will typically be auto-calculated
	MaxPayload int
	// interval between sending master announcements in master modes
	AnnouncementInterval time.Duration
	// keep information about known masters for this duration after having last
	// heard of them
	MasterMaxAge time.Duration
	// interval between checks
	MasterPurgeInterval time.Duration
	// wait for outstanding packets for this time after
	// receiving final packet (which might arrive out of band)
	TransactionWaitComplete time.Duration
	// after this time, a started transaction is removed
	// from the list, regardless in what state it is
	TransactionMaxAge time.Duration
	// interval between checks
	TransactionPurgeInterval time.Duration
	// wait this duration for a reply of a master server
	// after forwarding a (client) request to it
	WaitForMasterReply time.Duration
	// interval between data synchronization pushes to other
	// master servers
	SyncInterval time.Duration
	// should we drop transactions that are not complete?
	// defaults to true, and should better be left that way
	// except your data/network policy mandates differently
	DropIncompleteTransactions bool
	// operation mode
	Mode int

	sync.Mutex
	// contains filtered or unexported fields
}

type StatusV0 struct {
	Header *TLV
	Tx     *TransactionMgmt
}

type Store struct {
	NotifyUpdates *topic.Topic
	// contains filtered or unexported fields
}

type TLV struct {
	// type of the data following (or the information expressed by
	// just the TLV itself)
	Type uint8
	// version of the typed data
	Version uint8
	// length of the data following
	Length uint16
}

type TransactionMgmt struct {
	// Transaction ID
	Id uint16
	// Sequence number
	SeqNo uint16
}