Versions in this module Expand all Collapse all v0 v0.5.1 Jul 4, 2017 v0.5.0 Jul 1, 2017 Changes in this version + type ReadBuf struct + func (r *ReadBuf) GetBytes() []byte + func (r *ReadBuf) Read(p []byte) (int, error) + type Server interface + DataChan func() chan *ReadBuf + DataRecd func(*ReadBuf) + IsServing func() bool + Serve func() + Stop func() + type TBufferedServer struct + func NewTBufferedServer(transport thrift.TTransport, maxQueueSize int, maxPacketSize int, ...) (*TBufferedServer, error) + func (s *TBufferedServer) DataChan() chan *ReadBuf + func (s *TBufferedServer) DataRecd(buf *ReadBuf) + func (s *TBufferedServer) IsServing() bool + func (s *TBufferedServer) Serve() + func (s *TBufferedServer) Stop()