Versions in this module Expand all Collapse all v2 v2.0.0 Jun 14, 2023 Changes in this version + const BoltDBShipperType + const ObjectStorageIndexRequiredPeriod + const StorageTypeAWS + const StorageTypeAWSDynamo + const StorageTypeAlibabaCloud + const StorageTypeAzure + const StorageTypeBOS + const StorageTypeBigTable + const StorageTypeBigTableHashed + const StorageTypeBoltDB + const StorageTypeCOS + const StorageTypeCassandra + const StorageTypeFileSystem + const StorageTypeGCP + const StorageTypeGCPColumnKey + const StorageTypeGCS + const StorageTypeGrpc + const StorageTypeInMemory + const StorageTypeLocal + const StorageTypeS3 + const StorageTypeSwift + const TSDBType + func ActivePeriodConfig(configs []PeriodConfig) int + func ExtractTableNumberFromName(tableName string) (int64, error) + func IsObjectStorageIndex(indexType string) bool + func UsingObjectStorageIndex(configs []PeriodConfig) bool + type ActiveTableProvisionConfig struct + ProvisionedReadThroughput int64 + ProvisionedThroughputOnDemandMode bool + ProvisionedWriteThroughput int64 + ReadScale AutoScalingConfig + WriteScale AutoScalingConfig + func (cfg *ActiveTableProvisionConfig) RegisterFlags(argPrefix string, f *flag.FlagSet) + func (cfg ActiveTableProvisionConfig) BuildTableDesc(tableName string, tags Tags) TableDesc + type AutoScalingConfig struct + Enabled bool + InCooldown int64 + MaxCapacity int64 + MinCapacity int64 + OutCooldown int64 + RoleARN string + TargetValue float64 + func (cfg *AutoScalingConfig) RegisterFlags(argPrefix string, f *flag.FlagSet) + type ChunkStoreConfig struct + CacheLookupsOlderThan model.Duration + ChunkCacheConfig cache.Config + DisableIndexDeduplication bool + MaxLookBackPeriod model.Duration + WriteDedupeCacheConfig cache.Config + func (cfg *ChunkStoreConfig) ChunkCacheStubs() bool + func (cfg *ChunkStoreConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *ChunkStoreConfig) Validate(logger log.Logger) error + type DayTime struct + func (d *DayTime) String() string + func (d *DayTime) UnmarshalYAML(unmarshal func(interface{}) error) error + func (d DayTime) MarshalYAML() (interface{}, error) + type InactiveTableProvisionConfig struct + InactiveReadScale AutoScalingConfig + InactiveReadScaleLastN int64 + InactiveReadThroughput int64 + InactiveThroughputOnDemandMode bool + InactiveWriteScale AutoScalingConfig + InactiveWriteScaleLastN int64 + InactiveWriteThroughput int64 + func (cfg *InactiveTableProvisionConfig) RegisterFlags(argPrefix string, f *flag.FlagSet) + func (cfg InactiveTableProvisionConfig) BuildTableDesc(tableName string, tags Tags, disableAutoscale bool) TableDesc + type PeriodConfig struct + ChunkTables PeriodicTableConfig + From DayTime + IndexTables PeriodicTableConfig + IndexType string + ObjectType string + RowShards uint32 + Schema string + func (cfg *PeriodConfig) GetIndexTableNumberRange(schemaEndDate DayTime) TableRange + func (cfg *PeriodConfig) UnmarshalYAML(unmarshal func(interface{}) error) error + func (cfg *PeriodConfig) VersionAsInt() (int, error) + type PeriodicTableConfig struct + Period time.Duration + Prefix string + Tags Tags + func (cfg *PeriodicTableConfig) PeriodicTables(from, through model.Time, pCfg ProvisionConfig, ...) []TableDesc + func (cfg *PeriodicTableConfig) TableFor(t model.Time) string + func (cfg *PeriodicTableConfig) UnmarshalYAML(unmarshal func(interface{}) error) error + func (cfg PeriodicTableConfig) MarshalYAML() (interface{}, error) + type ProvisionConfig struct + func (cfg *ProvisionConfig) RegisterFlags(argPrefix string, f *flag.FlagSet) + type SchemaConfig struct + Configs []PeriodConfig + func (cfg *SchemaConfig) ForEachAfter(t model.Time, f func(config *PeriodConfig)) + func (cfg *SchemaConfig) Load() error + func (cfg *SchemaConfig) RegisterFlags(f *flag.FlagSet) + func (cfg *SchemaConfig) Validate() error + func (cfg SchemaConfig) ChunkTableFor(t model.Time) (string, error) + func (cfg SchemaConfig) ExternalKey(ref logproto.ChunkRef) string + func (cfg SchemaConfig) SchemaForTime(t model.Time) (PeriodConfig, error) + func (cfg SchemaConfig) VersionForChunk(ref logproto.ChunkRef) int + type TableDesc struct + Name string + ProvisionedRead int64 + ProvisionedWrite int64 + ReadScale AutoScalingConfig + Tags Tags + UseOnDemandIOMode bool + WriteScale AutoScalingConfig + func (desc TableDesc) Equals(other TableDesc) bool + type TableRange struct + End int64 + PeriodConfig *PeriodConfig + Start int64 + func (t TableRange) ConfigForTableNumber(tableNumber int64) *PeriodConfig + func (t TableRange) TableInRange(tableName string) (bool, error) + type TableRanges []TableRange + func GetIndexStoreTableRanges(indexType string, periodicConfigs []PeriodConfig) TableRanges + func (t TableRanges) ConfigForTableNumber(tableNumber int64) *PeriodConfig + func (t TableRanges) TableInRange(tableName string) (bool, error) + func (t TableRanges) TableNameFor(table int64) (string, bool) + type Tags map[string]string + func (ts *Tags) Set(s string) error + func (ts *Tags) UnmarshalYAML(unmarshal func(interface{}) error) error + func (ts Tags) Equals(other Tags) bool + func (ts Tags) String() string
Go to main page