util

Documentation

Index

• func Close[T any](ch chan T) (ok bool)
• func ConnBGP(s *core.StageBase, conn net.Conn, in *pipe.Input) error
• func ConnPublish(s *core.StageBase, conn net.Conn)
• func DialRetry(s *core.StageBase, dialer *net.Dialer, network, address string) (net.Conn, error)
• func Send[T any](ch chan T, v T) (ok bool)
• func TcpMd5(md5pass string) func(net, addr string, c syscall.RawConn) error
• type Stdlog
  • func (l *Stdlog) Debugf(format string, args ...any)
  • func (l *Stdlog) Errorf(format string, args ...any)
  • func (l *Stdlog) Infof(format string, args ...any)
  • func (l *Stdlog) Printf(format string, args ...any)
  • func (l *Stdlog) Warnf(format string, args ...any)

Functions

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

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

Types

type Stdlog

type Stdlog struct {
	zerolog.Logger
}

Stdlog adapts zerolog to standard log interface

func (*Stdlog) Debugf

func (l *Stdlog) Debugf(format string, args ...any)

func (*Stdlog) Errorf

func (l *Stdlog) Errorf(format string, args ...any)

func (*Stdlog) Infof

func (l *Stdlog) Infof(format string, args ...any)

func (*Stdlog) Printf

func (l *Stdlog) Printf(format string, args ...any)

func (*Stdlog) Warnf

func (l *Stdlog) Warnf(format string, args ...any)