peer

type Connected struct {
	Peer Peer
}

type Direction int

type DuplicateChecker interface {
	Add([]byte) (isNew bool)
}

type HandlerParams struct {
	Ctx              context.Context
	ID               string
	Connection       conn.Connection
	Remote           Remote
	Parent           Parent
	Peer             Peer
	DuplicateChecker DuplicateChecker
}

type ID interface {
	fmt.Stringer
}

type InfoMessage struct {
	Peer  Peer
	Value interface{}
}

type Parent struct {
	MessageCh       chan ProtoMessage
	InfoCh          chan InfoMessage
	SkipMessageList *messages.SkipMessageList
}

type Peer interface {
	Direction() Direction
	Close() error
	SendMessage(proto.Message)
	ID() ID
	Connection() conn.Connection
	Handshake() proto.Handshake
	RemoteAddr() proto.TCPAddr
}

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

type ProtoMessage struct {
	ID      Peer
	Message proto.Message
}

type Remote struct {
	ToCh   chan []byte
	FromCh chan *bytebufferpool.ByteBuffer
	ErrCh  chan error
}