Documentation ¶
Index ¶
- Constants
- type TBufferedReadTransport
- func (p *TBufferedReadTransport) Close() error
- func (p *TBufferedReadTransport) Flush(ctx context.Context) error
- func (p *TBufferedReadTransport) IsOpen() bool
- func (p *TBufferedReadTransport) Open() error
- func (p *TBufferedReadTransport) Read(buf []byte) (int, error)
- func (p *TBufferedReadTransport) RemainingBytes() uint64
- func (p *TBufferedReadTransport) Write(buf []byte) (int, error)
- type TUDPTransport
- 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) Write(buf []byte) (int, error)
Constants ¶
const MaxLength = 65000
MaxLength of UDP packet
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TBufferedReadTransport ¶
type TBufferedReadTransport struct {
// contains filtered or unexported fields
}
TBufferedReadTransport is a thrift.TTransport that reads from a buffer
func NewTBufferedReadTransport ¶
func NewTBufferedReadTransport(readBuf *bytes.Buffer) (*TBufferedReadTransport, error)
NewTBufferedReadTransport creates a buffer backed TTransport
func (*TBufferedReadTransport) Close ¶
func (p *TBufferedReadTransport) Close() error
Close does nothing as transport is not maintaining the connection Required to maintain thrift.TTransport interface
func (*TBufferedReadTransport) Flush ¶
func (p *TBufferedReadTransport) Flush(ctx context.Context) error
Flush does nothing as udp server does not write responses back Required to maintain thrift.TTransport interface
func (*TBufferedReadTransport) IsOpen ¶
func (p *TBufferedReadTransport) IsOpen() bool
IsOpen does nothing as transport is not maintaining the connection Required to maintain thrift.TTransport interface
func (*TBufferedReadTransport) Open ¶
func (p *TBufferedReadTransport) Open() error
Open does nothing as transport is not maintaining the connection Required to maintain thrift.TTransport interface
func (*TBufferedReadTransport) Read ¶
func (p *TBufferedReadTransport) Read(buf []byte) (int, error)
Read reads bytes from the local buffer and puts them in the specified buf
func (*TBufferedReadTransport) RemainingBytes ¶
func (p *TBufferedReadTransport) RemainingBytes() uint64
RemainingBytes returns the number of bytes left to be read from the readBuf
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) 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.