thriftudp

Documentation

Index

• Constants
• type TUDPTransport
  • func NewTUDPClientTransport(destHostPort string, locHostPort string) (*TUDPTransport, error)
  • func NewTUDPServerTransport(hostPort string) (*TUDPTransport, error)
  • func (p *TUDPTransport) Addr() net.Addr
  • func (p *TUDPTransport) Close() error
  • func (p *TUDPTransport) Conn() *net.UDPConn
  • func (p *TUDPTransport) Flush(_ context.Context) error
  • func (p *TUDPTransport) IsOpen() bool
  • func (p *TUDPTransport) Open() error
  • func (p *TUDPTransport) Read(buf []byte) (int, error)
  • func (p *TUDPTransport) RemainingBytes() uint64
  • func (p *TUDPTransport) SetSocketBufferSize(bufferSize int) error
  • func (p *TUDPTransport) Write(buf []byte) (int, error)

Constants

const (
	MaxLength = 65000
)

MaxLength of UDP packet

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

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