batchcompress

package

v0.0.0-...-2a72a2f Latest Latest Go to latest Published: Dec 18, 2022 License: Unlicense Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Batch is a size constrained batch.

func NewBatch(maxSize int) *Batch

NewBatch creates a size constrained batch.

func (batch *Batch) Add(d []byte) bool

Add message to batch. Returns false if new message makes batch too big.

func (batch *Batch) Flush(w io.Writer)

Flush compresses the batch and writes it to w.

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

Batcher is a time and size constrained batch generator.

func NewBatcher(maxSize int, maxAge time.Duration, receiver func([]byte)) *Batcher

NewBatcher creates a new batcher that flushes after maxSize or maxAge are reached. Calls receiver with the result.

func (batcher *Batcher) Add(d []byte)

Add message to batcher.

func (batcher *Batcher) Close()

Close the batch processing and flush current content..

func (batcher *Batcher) Flush()

Flush the batch: Write output forcefully.

type IntegerType interface {
	int | int8 | int16 | int32 | int64 | uint | uint8 | uint16 | uint32 | uint64
}