Documentation
¶
Index ¶
Constants ¶
View Source
const ( BufferSize = 1 << 18 // 256K elements per shard FlushInterval = 2 * time.Microsecond // Batching interval MaxBackPressure = 1 << 20 // 1MB buffer CacheLineSize = 64 )
Variables ¶
This section is empty.
Functions ¶
func Uint64LessThan ¶
func Uint64LessThan(a, b interface{}) bool
Types ¶
type SequenceGenerator ¶
type SequenceGenerator struct {
// contains filtered or unexported fields
}
func (*SequenceGenerator) Next ¶
func (sg *SequenceGenerator) Next() uint64
type SequenceManager ¶
type SequenceManager struct {
// contains filtered or unexported fields
}
func NewSequenceManager ¶
func NewSequenceManager() *SequenceManager
func (*SequenceManager) Close ¶
func (sm *SequenceManager) Close()
func (*SequenceManager) CurrentSequence ¶
func (sm *SequenceManager) CurrentSequence() uint64
func (*SequenceManager) OutputChan ¶
func (sm *SequenceManager) OutputChan() chan []byte
func (*SequenceManager) Submit ¶
func (sm *SequenceManager) Submit(seq uint64, data []byte)
Source Files
Click to show internal directories.
Click to hide internal directories.