Versions in this module Expand all Collapse all v0 v0.0.2 May 15, 2023 Changes in this version + func Assemble(chunks <-chan Chunk, maxMessageSize int, assembleTimeout time.Duration) <-chan Chunk + func Extract(encodedMsgs <-chan Chunk, decompressSizeLimit int) <-chan []byte + type Assembler struct + func NewAssembler(maxMessageSize int, timeout time.Duration) (res *Assembler) + func (a *Assembler) Bytes() []byte + func (a *Assembler) Expired() bool + func (a *Assembler) Update(chunk Chunk) bool + type Chunk []byte + func (c Chunk) Body() []byte + func (c Chunk) Data(decompressSizeLimit int) (res []byte, err error) + func (c Chunk) ID() string + func (c Chunk) IsGELF() bool + func (c Chunk) Sequence() (number, count int)