internal

type Conn struct {
	sync.Mutex
	Opts     *Options
	RawConn  net.Conn
	UserData interface{}

	SendDropped uint32
	// contains filtered or unexported fields
}

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

type Fork struct {
	Longest          bool           `json:"longest"`            // Indicates that the fork is the longest
	Height           int            `json:"height"`             // The height of the last block in the fork
	HeadBlock        proto.BlockID  `json:"head_block"`         // The last block of the fork
	LastCommonHeight int            `json:"last_common_height"` // The height of the last common block
	LastCommonBlock  proto.BlockID  `json:"last_common_block"`  // The last common block with the longest fork
	Length           int            `json:"length"`             // The number of blocks since the last common block
	Peers            []PeerForkInfo `json:"peers"`              // Peers that seen on the fork
}

type ForkByHeightLengthAndPeersCount []Fork

type Handler interface {
	OnAccept(*Conn)          // OnAccept occurs then server accepts new connection.
	OnConnect(*Conn)         // OnConnect happens on new client connection.
	OnReceive(*Conn, []byte) // OnReceive executes on new bytes arrival.
	OnClose(*Conn)           // OnClose fires then connection is closed.
}

type NodeForkInfo struct {
	Address    net.IP        `json:"address"`
	Nonce      int           `json:"nonce"`
	Name       string        `json:"name"`
	Version    proto.Version `json:"version"`
	OnFork     Fork          `json:"on_fork"`
	OtherForks []Fork        `json:"other_forks"`
}

type NodeState byte

type Options struct {
	Handler         Handler
	RecvBufSize     int           // default is DefaultRecvBufSize if you don't set.
	SendQueueLen    int           // default is DefaultSendQueueLen if you don't set.
	AsyncWrite      bool          // default is DefaultAsyncWrite  if you don't set.
	NoDelay         bool          // default is true
	KeepAlive       bool          // default is false
	KeepAlivePeriod time.Duration // default is 0, mean use system setting.
	ReadDeadline    time.Duration // default is 0, means Read will not time out.
	WriteDeadline   time.Duration // default is 0, means Write will not time out.
}

type PeerForkInfo struct {
	Peer    net.IP        `json:"peer"`
	Lag     int           `json:"lag"`
	Name    string        `json:"name"`
	Version proto.Version `json:"version"`
}

type PeerNode struct {
	Address     net.IP        `json:"address"`
	Port        uint16        `json:"port"`
	Nonce       uint64        `json:"nonce"`
	Name        string        `json:"name"`
	Version     proto.Version `json:"version"`
	Attempts    int           `json:"attempts"`
	NextAttempt time.Time     `json:"next_attempt"`
	State       NodeState     `json:"state"`
}

type PeerNodesByName []PeerNode

type PublicAddressInfo struct {
	Address         string    `json:"address"`
	Version         string    `json:"version"`
	Status          string    `json:"status"`
	Attempts        int       `json:"attempts"`
	NextAttemptTime time.Time `json:"next_attempt_time"`
}

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

type Server struct {
	Opts *Options
	// contains filtered or unexported fields
}