udplistener

Documentation

Index

• type UDPListener
  • func New(listenAddress string, bufferSize int, pipeline pipeline.Pipeline) *UDPListener
  • func (u *UDPListener) Shutdown()
  • func (u *UDPListener) Start() error
  • func (u *UDPListener) WaitForShutdown()

Types

type UDPListener

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

UDPListener listens for UDP packets on a given listenAddress

func New

func New(listenAddress string, bufferSize int, pipeline pipeline.Pipeline) *UDPListener

New creates a new UDPListener instance

func (*UDPListener) Shutdown

func (u *UDPListener) Shutdown()

Shutdown initiates shutdown of the UDPListener

func (*UDPListener) Start

func (u *UDPListener) Start() error

Start UDPListener instance

func (*UDPListener) WaitForShutdown

func (u *UDPListener) WaitForShutdown()

WaitForShutdown waits for the UDP listener to shut down