Documentation
¶
Index ¶
- Constants
- func WithCheckpointGlobalInterval(interval time.Duration) func(*Options)
- func WithCheckpointIncrementaInterval(interval time.Duration) func(*Options)
- func WithCheckpointMinCount(count int64) func(*Options)
- func WithCheckpointScanInterval(interval time.Duration) func(*Options)
- func WithTransferTableTTL(ttl time.Duration) func(*Options)
- type CacheCfg
- type CheckpointCfg
- type LogstoreType
- type LogtailCfg
- type Options
- type SchedulerCfg
- type StorageCfg
Constants ¶
View Source
const ( // Temp unlimit the txn cache size. // In v0.6, we will limit the cache to a reasonable value DefaultTxnCacheSize = mpool.TB DefaultIndexCacheSize = 128 * common.M DefaultMTCacheSize = 4 * common.G DefaultBlockMaxRows = uint32(40000) DefaultBlocksPerSegment = uint16(40) DefaultScannerInterval = time.Second * 5 DefaultCheckpointFlushInterval = time.Minute DefaultCheckpointMinCount = int64(100) DefaultCheckpointIncremetalInterval = time.Minute DefaultCheckpointGlobalInterval = time.Minute * 60 DefaultIOWorkers = int(8) DefaultAsyncWorkers = int(16) DefaultLogtailTxnPageSize = 1024 DefaultLogstoreType = LogstoreBatchStore )
Variables ¶
This section is empty.
Functions ¶
func WithCheckpointGlobalInterval ¶ added in v0.6.0
func WithCheckpointIncrementaInterval ¶ added in v0.6.0
func WithCheckpointMinCount ¶ added in v0.6.0
func WithCheckpointScanInterval ¶ added in v0.6.0
func WithTransferTableTTL ¶ added in v0.6.0
Types ¶
type CheckpointCfg ¶
type CheckpointCfg struct {
FlushInterval time.Duration `toml:"flush-inerterval"`
MinCount int64 `toml:"checkpoint-min-count"`
ScanInterval time.Duration `toml:"scan-interval"`
IncrementalInterval time.Duration `toml:"checkpoint-incremental-interval"`
GlobalInterval time.Duration `toml:"checkpoint-global-interval"`
}
type LogstoreType ¶ added in v0.6.0
type LogstoreType string
const ( LogstoreBatchStore LogstoreType = "batchstore" LogstoreLogservice LogstoreType = "logservice" )
type LogtailCfg ¶ added in v0.6.0
type LogtailCfg struct {
PageSize int32 `toml:"page-size"`
}
type Options ¶
type Options struct {
CacheCfg *CacheCfg `toml:"cache-cfg"`
StorageCfg *StorageCfg `toml:"storage-cfg"`
CheckpointCfg *CheckpointCfg `toml:"checkpoint-cfg"`
SchedulerCfg *SchedulerCfg `toml:"scheduler-cfg"`
LogtailCfg *LogtailCfg
Catalog *catalog.Catalog
TransferTableTTL time.Duration
Clock clock.Clock
Fs fileservice.FileService
Lc logservicedriver.LogServiceClientFactory
Shard metadata.DNShard
LogStoreT LogstoreType
}
func (*Options) FillDefaults ¶
type SchedulerCfg ¶
type StorageCfg ¶
Click to show internal directories.
Click to hide internal directories.