buffer

type Buffer struct {
	*Config

	sync.RWMutex
	// contains filtered or unexported fields
}

type Config struct {
	TempDir       string        // Where to store temporary files
	FlushWrites   int64         // Flush after N writes, zero to disable
	FlushBytes    int64         // Flush after N bytes, zero to disable
	FlushInterval time.Duration // Flush after duration, zero to disable
	BufferSize    int           // Buffer size for writes
	Queue         chan *Flush   // Queue of flushed files
}

type Flush struct {
	Reason     Reason
	Path       string
	Writes     int64
	Bytes      int64
	Opened     time.Time
	Closed     time.Time
	Age        time.Duration
	Topic      string
	Partition  int32
	LastOffset int64
	Ctx        context.Context
}

type Reason string