warehouse

May 5, 2023

Changes in this version

+ var ErrClosed = errors.New("closed")

+ var ErrUnknownType = errors.New("unknown data type")

+ type StoreRequest struct

+ Data []byte

+ DataType string

+ Id string

+ Slot uint64

+ Timestamp time.Time

+ func (req StoreRequest) Loggable() map[string]any

+ type Warehouse struct

+ func NewWarehouse(logger log.Logger, bufSize int) *Warehouse

+ func (s *Warehouse) AttachMetrics(m *metrics.Metrics)

+ func (s *Warehouse) Close(ctx context.Context)

+ func (s *Warehouse) Run(ctx context.Context, datadir string, id int)

+ func (s *Warehouse) RunParallel(ctx context.Context, datadir string, numWorkers int) error

+ func (s *Warehouse) StoreAsync(ctx context.Context, req StoreRequest) error

+ type WarehouseMetrics struct

+ FailedWrites *prometheus.CounterVec

+ Writes *prometheus.CounterVec