parquetconverter

type Config struct {
	MetaSyncConcurrency int           `yaml:"meta_sync_concurrency"`
	ConversionInterval  time.Duration `yaml:"conversion_interval"`
	MaxRowsPerRowGroup  int           `yaml:"max_rows_per_row_group"`
	FileBufferEnabled   bool          `yaml:"file_buffer_enabled"`

	DataDir string `yaml:"data_dir"`

	Ring RingConfig `yaml:"ring"`
}

type Converter struct {
	services.Service
	// contains filtered or unexported fields
}

type RingConfig struct {
	KVStore          kv.Config     `yaml:"kvstore"`
	HeartbeatPeriod  time.Duration `yaml:"heartbeat_period"`
	HeartbeatTimeout time.Duration `yaml:"heartbeat_timeout"`
	AutoForgetDelay  time.Duration `yaml:"auto_forget_delay"`

	// Instance details
	InstanceID     string `yaml:"instance_id" doc:"hidden"`
	InstancePort   int    `yaml:"instance_port" doc:"hidden"`
	InstanceAddr   string `yaml:"instance_addr" doc:"hidden"`
	TokensFilePath string `yaml:"tokens_file_path"`

	// Injected internally
	ListenPort int `yaml:"-"`
}