util

func Close ¶

func Close[T any](ch chan T) (ok bool)

Close closes channel ch if ch != nil. It recovers from panic if the channel is already closed. It returns ok=true if the channel was closed successfully.

func ConnBGP ¶ added in v0.15.1

func ConnBGP(s *core.StageBase, conn net.Conn, in *pipe.Input) error

ConnBGP handles an opened BGP connection conn for stage s

func ConnPublish ¶

func ConnPublish(s *core.StageBase, conn net.Conn)

func DialRetry ¶

func DialRetry(s *core.StageBase, dialer *net.Dialer, network, address string) (net.Conn, error)

DialRetry is a dialer.DialContext wrapper that adds connection timeout and retry with exponential backoff and jitter. Stage s can have many konfig options to tune the dialing.

func Send ¶

func Send[T any](ch chan T, v T) (ok bool)

Send sends value v to channel ch, if ch != nil. It recovers from panic if the channel is closed. It returns ok=true if the value was sent successfully.

func TcpMd5 ¶

func TcpMd5(md5pass string) func(net, addr string, c syscall.RawConn) error