Documentation
¶
Index ¶
Constants ¶
View Source
const ( // ModeReadWrite is to allow both read and write ModeReadWrite = iota // ModeReadOnly is to allow only read operations ModeReadOnly // ModeWriteOnly is to allow only write operations ModeWriteOnly // BoltDBShipperType holds the index type for using boltdb with shipper which keeps flushing them to a shared storage BoltDBShipperType = "boltdb-shipper" // FilesystemObjectStoreType holds the periodic config type for the filesystem store FilesystemObjectStoreType = "filesystem" StorageKeyPrefix = "index/" // UploadInterval defines interval for when we check if there are new index files to upload. // It's also used to snapshot the currently written index tables so the snapshots can be used for reads. UploadInterval = 1 * time.Minute )
Variables ¶
This section is empty.
Functions ¶
func NewBoltDBShipperTableClient ¶
func NewBoltDBShipperTableClient(objectClient chunk.ObjectClient) chunk.TableClient
func NewShipper ¶
func NewShipper(cfg Config, storageClient chunk.ObjectClient, registerer prometheus.Registerer) (chunk.IndexClient, error)
NewShipper creates a shipper for syncing local objects with a store
Types ¶
type Config ¶
type Config struct {
ActiveIndexDirectory string `yaml:"active_index_directory"`
CacheLocation string `yaml:"cache_location"`
CacheTTL time.Duration `yaml:"cache_ttl"`
ResyncInterval time.Duration `yaml:"resync_interval"`
QueryReadyNumDays int `yaml:"query_ready_num_days"`
IngesterName string `yaml:"-"`
Mode int `yaml:"-"`
IngesterDBRetainPeriod time.Duration `yaml:"-"`
}
func (*Config) RegisterFlags ¶
RegisterFlags registers flags.
type Shipper ¶
type Shipper struct {
// contains filtered or unexported fields
}
func (*Shipper) BatchWrite ¶
func (*Shipper) NewWriteBatch ¶
func (s *Shipper) NewWriteBatch() chunk.WriteBatch
func (*Shipper) QueryPages ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.