Versions in this module Expand all Collapse all v1 v1.1.2 Oct 23, 2021 v1.1.1 Oct 22, 2021 v1.1.0 Oct 22, 2021 v1.0.0 Oct 21, 2021 Changes in this version + const BoltDBShipperType + const FilesystemObjectStoreType + const ModeReadOnly + const ModeReadWrite + const ModeWriteOnly + const StorageKeyPrefix + const UploadInterval + func NewBoltDBShipperTableClient(objectClient chunk.ObjectClient) chunk.TableClient + type Config struct + ActiveIndexDirectory string + CacheLocation string + CacheTTL time.Duration + IngesterName string + Mode int + ResyncInterval time.Duration + SharedStoreType string + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + type Shipper struct + func NewShipper(cfg Config, storageClient chunk.ObjectClient, registerer prometheus.Registerer) (*Shipper, error) + func (s *Shipper) BatchWrite(ctx context.Context, batch *bluge_db.BlugeWriteBatch) error + func (s *Shipper) NewWriteBatch() *bluge_db.BlugeWriteBatch + func (s *Shipper) QueryPages(ctx context.Context, queries []bluge_db.IndexQuery, ...) error + func (s *Shipper) Stop()
Go to main page