helpers

func ADBCNXNPacket() []byte

func After(timeout int) <-chan time.Time

func CloseConnOnCancel(ctx context.Context, conn net.Conn) func()

func Context(ctx context.Context, timeout int) (context.Context, context.CancelFunc)

func ContextDuration(ctx context.Context, timeout time.Duration) (context.Context, context.CancelFunc)

func Dial(ctx context.Context, network, address string, timeout int) (net.Conn, error)

func DialDuration(ctx context.Context, network, address string, timeout time.Duration) (net.Conn, error)

func FirstLine(s string) string

func GenericResult(host string, ip net.IP, port int, transport common.TransportType, appProtocol string, version string, metadata map[string]string) *discoverfern.ServiceDetails

func HasTimeout(timeout int) bool

func IsRMIEndpointHost(b []byte) bool

func LooksLikeGitDaemon(resp []byte) bool

func LooksLikeIRC(s string) bool

func SetDeadline(conn net.Conn, timeout int) error

func SetDeadlineDuration(conn net.Conn, timeout time.Duration) error

func SetReadDeadline(conn net.Conn, timeout int) error

func SetReadDeadlineDuration(conn net.Conn, timeout time.Duration) error

func SetWriteDeadline(conn net.Conn, timeout int) error

func SetWriteDeadlineDuration(conn net.Conn, timeout time.Duration) error

func TCPConn(ctx context.Context, ip net.IP, port int, timeout int) (net.Conn, error)

func TCPExchange(ctx context.Context, ip net.IP, port int, timeout int, probe []byte, maxRead int) ([]byte, error)

func TCPReadBanner(ctx context.Context, ip net.IP, port int, timeout int, maxRead int) ([]byte, error)

func Timeout(timeout int) time.Duration

func UDPConn(ctx context.Context, ip net.IP, port int, timeout int) (net.Conn, error)

func UDPExchange(ctx context.Context, ip net.IP, port int, timeout int, probe []byte, maxRead int) ([]byte, error)

func ValidADBPacket(packet []byte) bool

func ValidGopherItem(s string) bool