mux

Documentation

Index

• Variables
• type ShardQueue
  • func NewShardQueue(size int, conn netpoll.Connection) (queue *ShardQueue)
  • func (q *ShardQueue) Add(gts ...WriterGetter)
  • func (q *ShardQueue) Close() error
• type WriterGetter

Variables

var ShardSize int

DOC: * ShardQueue uses the netpoll's nocopy API to merge and send data. * The Data Flush is passively triggered by ShardQueue.Add and does not require user operations. * If there is an error in the data transmission, the connection will be closed. * * ShardQueue.Add: add the data to be sent. * NewShardQueue: create a queue with netpoll.Connection. * ShardSize: the recommended number of shards is 32.

Types

type ShardQueue

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

ShardQueue uses the netpoll's nocopy API to merge and send data. The Data Flush is passively triggered by ShardQueue.Add and does not require user operations. If there is an error in the data transmission, the connection will be closed. ShardQueue.Add: add the data to be sent.

func NewShardQueue

func NewShardQueue(size int, conn netpoll.Connection) (queue *ShardQueue)

NewShardQueue .

func (*ShardQueue) Add

func (q *ShardQueue) Add(gts ...WriterGetter)

Add adds to q.getters[shard]

func (*ShardQueue) Close

func (q *ShardQueue) Close() error

type WriterGetter

type WriterGetter func() (buf netpoll.Writer, isNil bool)

WriterGetter is used to get a netpoll.Writer.