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 ConnHandle ¶

func ConnHandle(s *core.StageBase, conn net.Conn, in *pipe.Input, timeout time.Duration) error

func ConnPublish ¶

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

func DialRetry ¶

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

DialRetry is a dialer.DialContext wrapper that adds connection timeout and retry with exponential backoff and jitter. stage s can have konfig options: "retry" (bool), "retry-max" (int), "timeout" (duration), and "insecure" (bool).

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