peer

Documentation

Index

• func Handle(params HandlerParams) error
• type Connected
• type Direction
  • func (a Direction) String() string
• type DuplicateChecker
• type HandlerParams
• type ID
• type InfoMessage
• type Parent
  • func NewParent() Parent
• type Peer
• type PeerImpl
  • func NewPeerImpl(handshake proto.Handshake, conn conn.Connection, direction Direction, ...) *PeerImpl
  • func (a *PeerImpl) Close() error
  • func (a *PeerImpl) Connection() conn.Connection
  • func (a *PeerImpl) Direction() Direction
  • func (a *PeerImpl) Handshake() proto.Handshake
  • func (a *PeerImpl) ID() ID
  • func (a *PeerImpl) RemoteAddr() proto.TCPAddr
  • func (a *PeerImpl) SendMessage(m proto.Message)
• type ProtoMessage
• type Remote
  • func NewRemote() Remote

Functions

func Handle

func Handle(params HandlerParams) error

Handle sends and receives messages no matter outgoing or incoming connection.

Types

type Connected

type Connected struct {
	Peer Peer
}

type Direction

type Direction int

const Incoming Direction = 1

const Outgoing Direction = 2

func (Direction) String

func (a Direction) String() string

type DuplicateChecker

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

type HandlerParams

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

type ID

type ID interface {
	fmt.Stringer
}

type InfoMessage

type InfoMessage struct {
	Peer  Peer
	Value interface{}
}

type Parent

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

func NewParent

func NewParent() Parent

type Peer

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

type PeerImpl

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

func NewPeerImpl

func NewPeerImpl(handshake proto.Handshake, conn conn.Connection, direction Direction, remote Remote, cancel context.CancelFunc) *PeerImpl

func (*PeerImpl) Close

func (a *PeerImpl) Close() error

func (*PeerImpl) Connection

func (a *PeerImpl) Connection() conn.Connection

func (*PeerImpl) Direction

func (a *PeerImpl) Direction() Direction

func (*PeerImpl) Handshake

func (a *PeerImpl) Handshake() proto.Handshake

func (*PeerImpl) ID

func (a *PeerImpl) ID() ID

func (*PeerImpl) RemoteAddr

func (a *PeerImpl) RemoteAddr() proto.TCPAddr

func (*PeerImpl) SendMessage

func (a *PeerImpl) SendMessage(m proto.Message)

type ProtoMessage

type ProtoMessage struct {
	ID      Peer
	Message proto.Message
}

type Remote

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

func NewRemote

func NewRemote() Remote