options

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
  • func (o *Options) FillDefaults(dirname string) *Options
• type SchedulerCfg
• type StorageCfg

Constants

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
)

Functions

func WithCheckpointGlobalInterval

func WithCheckpointGlobalInterval(interval time.Duration) func(*Options)

func WithCheckpointIncrementaInterval

func WithCheckpointIncrementaInterval(interval time.Duration) func(*Options)

func WithCheckpointMinCount

func WithCheckpointMinCount(count int64) func(*Options)

func WithCheckpointScanInterval

func WithCheckpointScanInterval(interval time.Duration) func(*Options)

func WithTransferTableTTL

func WithTransferTableTTL(ttl time.Duration) func(*Options)

Types

type CacheCfg

type CacheCfg struct {
	IndexCapacity  uint64 `toml:"index-cache-size"`
	InsertCapacity uint64 `toml:"insert-cache-size"`
	TxnCapacity    uint64 `toml:"txn-cache-size"`
}

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

type LogstoreType string

const (
	LogstoreBatchStore LogstoreType = "batchstore"
	LogstoreLogservice LogstoreType = "logservice"
)

type LogtailCfg

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

func (o *Options) FillDefaults(dirname string) *Options

type SchedulerCfg

type SchedulerCfg struct {
	IOWorkers    int `toml:"io-workers"`
	AsyncWorkers int `toml:"async-workers"`
}

type StorageCfg

type StorageCfg struct {
	BlockMaxRows     uint32 `toml:"block-max-rows"`
	SegmentMaxBlocks uint16 `toml:"segment-max-blocks"`
}