Versions in this module Expand all Collapse all v2 v2.4.3 Feb 9, 2022 Changes in this version + const BoltDBShipperType + const FilesystemObjectStoreType + const ModeReadOnly + const ModeReadWrite + const ModeWriteOnly + const UploadInterval + func NewBoltDBShipperTableClient(objectClient chunk.ObjectClient, storageKeyPrefix string) chunk.TableClient + func NewShipper(cfg Config, storageClient chunk.ObjectClient, registerer prometheus.Registerer) (chunk.IndexClient, error) + type Config struct + ActiveIndexDirectory string + BuildPerTenantIndex bool + CacheLocation string + CacheTTL time.Duration + IndexGatewayClientConfig IndexGatewayClientConfig + IngesterDBRetainPeriod time.Duration + IngesterName string + Mode int + QueryReadyNumDays int + ResyncInterval time.Duration + SharedStoreKeyPrefix string + SharedStoreType string + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + type GatewayClient struct + func NewGatewayClient(cfg IndexGatewayClientConfig, r prometheus.Registerer) (*GatewayClient, error) + func (s *GatewayClient) BatchWrite(ctx context.Context, batch chunk.WriteBatch) error + func (s *GatewayClient) NewWriteBatch() chunk.WriteBatch + func (s *GatewayClient) QueryPages(ctx context.Context, queries []chunk.IndexQuery, ...) error + func (s *GatewayClient) Stop() + type IndexGatewayClientConfig struct + Address string + GRPCClientConfig grpcclient.Config + func (cfg *IndexGatewayClientConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *IndexGatewayClientConfig) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet) + type Shipper struct + func (s *Shipper) BatchWrite(ctx context.Context, batch chunk.WriteBatch) error + func (s *Shipper) NewWriteBatch() chunk.WriteBatch + func (s *Shipper) QueryPages(ctx context.Context, queries []chunk.IndexQuery, ...) error + func (s *Shipper) Stop()
Go to main page