options

type CacheCfg struct {
	IndexCapacity uint64 `toml:"index-cache-size"`
}

type CatalogCfg struct {
	GCInterval time.Duration
	DisableGC  bool
}

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"`
	GlobalMinCount            int64         `toml:"checkpoint-global-interval"`
	ForceUpdateGlobalInterval bool
	GlobalVersionInterval     time.Duration
	GCCheckpointInterval      time.Duration
	DisableGCCheckpoint       bool

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

type GCCfg struct {
	GCTTL          time.Duration
	ScanGCInterval time.Duration
}

type LogstoreType string

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

type LogtailServerCfg struct {
	RpcMaxMessageSize      int64
	RpcEnableChecksum      bool
	LogtailCollectInterval time.Duration
	ResponseSendTimeout    time.Duration
}

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

	TransferTableTTL time.Duration

	IncrementalDedup bool

	Clock     clock.Clock
	Fs        fileservice.FileService
	Lc        logservicedriver.LogServiceClientFactory
	Shard     metadata.TNShard
	LogStoreT LogstoreType
	Ctx       context.Context
	// MaxMessageSize is the size of max message which is sent to log-service.
	MaxMessageSize uint64
}

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

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