customtransport

Documentation

Index

• type TBufferedReadTransport
  • func NewTBufferedReadTransport(readBuf *bytes.Buffer) (*TBufferedReadTransport, error)
  • func (p *TBufferedReadTransport) Close() error
  • func (p *TBufferedReadTransport) Flush(_ 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)

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(_ 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

func (*TBufferedReadTransport) Write

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

Write writes bytes into the read buffer Required to maintain thrift.TTransport interface