input

package

v0.8.0 Latest Latest Go to latest Published: Mar 31, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var TCPTimeout = time.Minute

TCPTimeout defines the maximum time between Reads

func StartTCP(addr string, cb WriteLineFunc) (io.Closer, error)

StartTCP ...

func StartUDP(addr string, cb WriteLineFunc) (io.Closer, error)

StartUDP ...

type NotifyCloser struct {
	// contains filtered or unexported fields
}

NotifyCloser ...

func NewNotifyCloser(toClose io.Closer) *NotifyCloser

NewNotifyCloser ...

func (c *NotifyCloser) Close() error

Close ...

func (c *NotifyCloser) CloseChan() chan struct{}

CloseChan ...

func (c *NotifyCloser) WasClosed() bool

WasClosed returns true if this Closable was closed

type WriteLineFunc func(line []byte, remoteIP string)

WriteLineFunc ...