warehouse

Documentation

Index

• Variables
• type StoreRequest
  • func (req StoreRequest) Loggable() map[string]any
• type Warehouse
  • 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

Variables

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

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

Types

type StoreRequest

type StoreRequest struct {
	DataType  string
	Data      []byte
	Slot      uint64
	Id        string
	Timestamp time.Time
	// contains filtered or unexported fields
}

func (StoreRequest) Loggable

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

type Warehouse

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

func NewWarehouse

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

func (*Warehouse) AttachMetrics

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

func (*Warehouse) Close

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

func (*Warehouse) Run

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

func (*Warehouse) RunParallel

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

func (*Warehouse) StoreAsync

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

type WarehouseMetrics

type WarehouseMetrics struct {
	Writes       *prometheus.CounterVec
	FailedWrites *prometheus.CounterVec
}