thriftudp

package
v1.34.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 11, 2022 License: Apache-2.0 Imports: 7 Imported by: 64

Documentation

Index

Constants

View Source
const (
	MaxLength = 65000
)

MaxLength of UDP packet

Variables

This section is empty.

Functions

This section is empty.

Types

type TUDPTransport

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

TUDPTransport does UDP as a thrift.TTransport

func NewTUDPClientTransport

func NewTUDPClientTransport(destHostPort string, locHostPort string) (*TUDPTransport, error)

NewTUDPClientTransport creates a net.UDPConn-backed TTransport for Thrift clients All writes are buffered and flushed in one UDP packet. If locHostPort is not "", it will be used as the local address for the connection Example:

trans, err := thriftudp.NewTUDPClientTransport("192.168.1.1:9090", "")

func NewTUDPServerTransport

func NewTUDPServerTransport(hostPort string) (*TUDPTransport, error)

NewTUDPServerTransport creates a net.UDPConn-backed TTransport for Thrift servers It will listen for incoming udp packets on the specified host/port Example:

trans, err := thriftudp.NewTUDPClientTransport("localhost:9001")

func (*TUDPTransport) Addr

func (p *TUDPTransport) Addr() net.Addr

Addr returns the address that the transport is listening on or writing to

func (*TUDPTransport) Close

func (p *TUDPTransport) Close() error

Close closes the connection

func (*TUDPTransport) Conn

func (p *TUDPTransport) Conn() *net.UDPConn

Conn retrieves the underlying net.UDPConn

func (*TUDPTransport) Flush

func (p *TUDPTransport) Flush(_ context.Context) error

Flush flushes the write buffer as one udp packet

func (*TUDPTransport) IsOpen

func (p *TUDPTransport) IsOpen() bool

IsOpen returns true if the connection is open

func (*TUDPTransport) Open

func (p *TUDPTransport) Open() error

Open does nothing as connection is opened on creation Required to maintain thrift.TTransport interface

func (*TUDPTransport) Read

func (p *TUDPTransport) Read(buf []byte) (int, error)

Read reads one UDP packet and puts it in the specified buf

func (*TUDPTransport) RemainingBytes

func (p *TUDPTransport) RemainingBytes() uint64

RemainingBytes returns the max number of bytes (same as Thrift's StreamTransport) as we do not know how many bytes we have left.

func (*TUDPTransport) SetSocketBufferSize added in v1.19.0

func (p *TUDPTransport) SetSocketBufferSize(bufferSize int) error

SetSocketBufferSize sets udp buffer size

func (*TUDPTransport) Write

func (p *TUDPTransport) Write(buf []byte) (int, error)

Write writes specified buf to the write buffer

Jump to

Keyboard shortcuts

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