conncheck

Oct 25, 2022

Changes in this version

+ var PingInterval time.Duration

+ var PingLossThreshold uint

+ type ConnChecker struct

+ func NewConnChecker() (*ConnChecker, error)

+ func (c *ConnChecker) AddAndRunSender(clusterID, ip string, updateCallback UpdateFunc)

+ func (c *ConnChecker) DelAndStopSender(clusterID string)

+ func (c *ConnChecker) GetConnected(clusterID string) (bool, error)

+ func (c *ConnChecker) GetLatency(clusterID string) (time.Duration, error)

+ func (c *ConnChecker) RunReceiver()

+ func (c *ConnChecker) RunReceiverDisconnectObserver()

+ type Msg struct

+ ClusterID string

+ MsgType MsgTypes

+ TimeStamp time.Time

+ func (msg Msg) String() string

+ type MsgTypes string

+ const PING

+ const PONG

+ type Peer struct

+ type Receiver struct

+ func NewReceiver(conn *net.UDPConn) *Receiver

+ func (r *Receiver) InitPeer(clusterID string, updateCallback UpdateFunc) error

+ func (r *Receiver) ReceivePong(msg *Msg) error

+ func (r *Receiver) Run()

+ func (r *Receiver) RunDisconnectObserver()

+ func (r *Receiver) SendPong(raddr *net.UDPAddr, msg *Msg) error

+ type Sender struct

+ func NewSender(ctx context.Context, clusterID string, cancel func(), conn *net.UDPConn, ...) *Sender

+ func (s *Sender) SendPing(ctx context.Context) error

+ type UpdateFunc func(connected bool, latency time.Duration, time time.Time) error