events

package

v0.0.0-...-8b91daf Latest Latest Go to latest Published: Apr 19, 2025 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var ErrSinkTooSmall = errors.New("sink to small")

func ProcessOldSinks(logger telemetry.Logger, s storage.System, index Index) error

type Estimator interface {
	OnWriteData(bytesWritten int64)
	ShouldTryFlush() bool
	OnFlush(compressedSize int64, success bool)
}

type Event struct {
	Timestamp time.Time
	Key       string
	Data      []byte
	Delete    bool
}

func GetEvents(s storage.System, eventFile string) ([]Event, error)

func (e Event) Apply(ret map[string][]byte)

type Index interface {
	GetStateAt(timestamp time.Time) (map[string][]byte, error)
	UpdateIndex(header chunks.Header) error
}

type Meta interface {
	GetEventFiles() ([]string, error)
}

func NewMeta(storage storage.System) (Meta, error)

type Sink interface {
	Append(event Event) (bool, error)
}

func NewSink(s storage.System, i Index, chunkTargetSize int64, maxChunkAge time.Duration, logger telemetry.Logger, metrics telemetry.Metrics) Sink