udp

package

v0.0.0-...-c083cd1 Latest Latest Go to latest Published: Mar 7, 2025 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/apache/plc4x

Documentation ¶

Index ¶

type Transport
- func NewTransport(_options ...options.WithOption) *Transport
type TransportInstance
- func NewTransportInstance(localAddress *net.UDPAddr, remoteAddress *net.UDPAddr, connectTimeout uint32, ...) *TransportInstance

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Transport ¶

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

func NewTransport ¶

func NewTransport(_options ...options.WithOption) *Transport

func (*Transport) Close ¶

func (m *Transport) Close() error

func (*Transport) CreateTransportInstance ¶

func (m *Transport) CreateTransportInstance(transportUrl url.URL, options map[string][]string, _options ...options.WithOption) (transports.TransportInstance, error)

func (*Transport) CreateTransportInstanceForLocalAddress ¶

func (m *Transport) CreateTransportInstanceForLocalAddress(transportUrl url.URL, options map[string][]string, localAddress *net.UDPAddr, _options ...options.WithOption) (transports.TransportInstance, error)

func (*Transport) GetTransportCode ¶

func (m *Transport) GetTransportCode() string

func (*Transport) GetTransportName ¶

func (m *Transport) GetTransportName() string

func (*Transport) String ¶

func (m *Transport) String() string

type TransportInstance ¶

type TransportInstance struct {
	LocalAddress   *net.UDPAddr
	RemoteAddress  *net.UDPAddr
	ConnectTimeout uint32
	SoReUse        bool
	// contains filtered or unexported fields
}

func NewTransportInstance ¶

func NewTransportInstance(localAddress *net.UDPAddr, remoteAddress *net.UDPAddr, connectTimeout uint32, soReUse bool, transport *Transport, _options ...options.WithOption) *TransportInstance

func (*TransportInstance) Close ¶

func (m *TransportInstance) Close() error

func (*TransportInstance) Connect ¶

func (m *TransportInstance) Connect() error

func (*TransportInstance) ConnectWithContext ¶

func (m *TransportInstance) ConnectWithContext(ctx context.Context) error

func (*TransportInstance) FillBuffer ¶

func (m *TransportInstance) FillBuffer(until func(pos uint, currentByte byte, reader transports.ExtendedReader) bool) error

func (*TransportInstance) GetNumBytesAvailableInBuffer ¶

func (m *TransportInstance) GetNumBytesAvailableInBuffer() (uint32, error)

func (*TransportInstance) IsConnected ¶

func (m *TransportInstance) IsConnected() bool

func (*TransportInstance) PeekReadableBytes ¶

func (m *TransportInstance) PeekReadableBytes(numBytes uint32) ([]byte, error)

func (*TransportInstance) Read ¶

func (m *TransportInstance) Read(numBytes uint32) ([]byte, error)

func (*TransportInstance) String ¶

func (m *TransportInstance) String() string

func (*TransportInstance) Write ¶

func (m *TransportInstance) Write(data []byte) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL