Struct GcConfig 

pub struct GcConfig {
    pub enable: bool,
    pub lingering_time: Duration,
    pub unknown_file_lingering_time: Duration,
    pub max_concurrent_lister_per_gc_job: usize,
    pub max_concurrent_gc_job: usize,
}

Fields

enable: bool

Whether GC is enabled.

lingering_time: Duration

Lingering time before deleting files. Should be long enough to allow long running queries to finish.

TODO(discord9): long running queries should actively write tmp manifest files to prevent deletion of files they are using.

unknown_file_lingering_time: Duration

Lingering time before deleting unknown files(files with undetermine expel time). expel time is the time when the file is considered as removed, as in removed from the manifest. This should only occur rarely, as manifest keep tracks in removed_files field unless something goes wrong.

max_concurrent_lister_per_gc_job: usize

Maximum concurrent list operations per GC job. This is used to limit the number of concurrent listing operations and speed up listing.

max_concurrent_gc_job: usize

Maximum concurrent GC jobs. This is used to limit the number of concurrent GC jobs running on the datanode to prevent too many concurrent GC jobs from overwhelming the datanode.

Trait Implementations

impl Clone for GcConfig

fn clone(&self) -> GcConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for GcConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for GcConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for GcConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for GcConfig

fn eq(&self, other: &GcConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for GcConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for GcConfig

impl StructuralPartialEq for GcConfig