options

type CatalogCfg struct {
	GCInterval time.Duration
	DisableGC  bool
}

type CheckpointCfg struct {
	FlushInterval             time.Duration `toml:"flush-inerterval"`
	TransferInterval          time.Duration `toml:"transfer-interval"`
	MetadataCheckInterval     time.Duration `toml:"metadata-check-inerterval"`
	MinCount                  int64         `toml:"checkpoint-min-count"`
	ScanInterval              time.Duration `toml:"scan-interval"`
	IncrementalInterval       time.Duration `toml:"checkpoint-incremental-interval"`
	GlobalMinCount            int64         `toml:"checkpoint-global-interval"`
	OverallFlushMemControl    uint64        `toml:"overall-flush-mem-control"`
	ForceUpdateGlobalInterval bool
	GlobalVersionInterval     time.Duration `toml:"global-version-interval"`
	GCCheckpointInterval      time.Duration
	DisableGCCheckpoint       bool
	ReservedWALEntryCount     uint64
	TableIDHistoryDuration    time.Duration `toml:"table-id-history-duration"`
	TableIDSinkerThreshold    int           `toml:"table-id-sinker-threshold"`

	// only for test
	// it is used to control the block rows of the checkpoint
	BlockRows int
	Size      int
}

type GCCfg struct {
	GCTTL             time.Duration `toml:"gc-ttl"`
	GCInMemoryTTL     time.Duration `toml:"gc-in-memory-ttl"`
	ScanGCInterval    time.Duration `toml:"scan-gc-interval"`
	DisableGC         bool          `toml:"disable-gc"`
	CheckGC           bool          `toml:"check-gc"`
	CacheSize         int           `toml:"cache-size"`
	GCMergeCount      int           `toml:"gc-merge-count"`
	GCScanCount       int           `toml:"gc-scan-count"`
	GCestimateRows    int           `toml:"gc-estimate-rows"`
	GCProbility       float64       `toml:"gc-probility"`
	GCDeleteTimeout   time.Duration `toml:"gc-delete-timeout"`
	GCDeleteBatchSize int           `toml:"gc-delete-batch-size"`
	GCDeleteWorkerNum int           `toml:"gc-delete-worker-num"`
}

type LogtailCfg struct {
	PageSize int32 `toml:"page-size"`
}

type LogtailServerCfg struct {
	RpcMaxMessageSize      int64
	RpcEnableChecksum      bool
	RPCStreamPoisonTime    time.Duration
	LogtailCollectInterval time.Duration
	ResponseSendTimeout    time.Duration
	// PullWorkerPoolSize is the size of the pull worker pool.
	// Means there are x pull workers working at most.
	// Default value is defaultPullWorkerPoolSize=50.
	PullWorkerPoolSize int64
}

type MergeConfig struct {
	CNMergeMemControlHint uint64
	CNTakeOverAll         bool
	CNTakeOverExceed      uint64
	CNStandaloneTake      bool
	DisableZMBasedMerge   bool
}

type Options struct {
	StorageCfg    *StorageCfg    `toml:"storage-cfg"`
	CheckpointCfg *CheckpointCfg `toml:"checkpoint-cfg"`
	SchedulerCfg  *SchedulerCfg  `toml:"scheduler-cfg"`
	GCCfg         *GCCfg         `toml:"gc-cfg"`
	LogtailCfg    *LogtailCfg
	MergeCfg      *MergeConfig
	CatalogCfg    *CatalogCfg

	BulkTomestoneTxnThreshold uint64
	TransferTableTTL          time.Duration
	IncrementalDedup          bool
	IsStandalone              bool
	EnableApplyTableData      bool
	GCTimeCheckerFactory      func(any) func(*types.TS) bool

	Fs                fileservice.FileService                  `toml:"-"`
	LocalFs           fileservice.FileService                  `toml:"-"`
	TmpFs             *fileservice.TmpFileService              `toml:"-"`
	WalClientFactory  logservicedriver.LogServiceClientFactory `toml:"-"`
	Ctx               context.Context                          `toml:"-"`
	Shard             metadata.TNShard                         `toml:"-"`
	Clock             clock.Clock                              `toml:"-"`
	TaskServiceGetter taskservice.Getter                       `toml:"-"`
	SID               string                                   `toml:"-"`
}

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

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