network

type Codec interface {
	Encode(w io.Writer, i interface{}) error
	Decode(r io.Reader) (interface{}, error)
}

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

type Connected struct {
	Address   string
	Timestamp time.Time
}

type Disconnected struct {
	Address   string
	Timestamp time.Time
}

type Discover struct {
}

type Listener interface {
	Accept() (net.Conn, error)
	Close() error
	SetDeadline(t time.Time) error
}

type MsgType uint16

type Network interface {
	Add(address string)
	Send(address string, msg interface{}) error
	Broadcast(msg interface{}, exclude ...string) error
	Stop()
	Stats()
}

type Peers struct {
	Addresses []string
}

type Ping struct {
	Nonce uint32
}

type Pong struct {
	Nonce uint32
}

type Received struct {
	Address   string
	Timestamp time.Time
	Message   interface{}
}