#[derive(
Debug,
Clone,
conjure_object::serde::Serialize,
conjure_object::serde::Deserialize,
PartialEq,
Eq,
PartialOrd,
Ord,
Hash
)]
#[serde(crate = "conjure_object::serde")]
#[conjure_object::private::staged_builder::staged_builder]
#[builder(crate = conjure_object::private::staged_builder, update, inline)]
pub struct ContainerizedOpts {
#[builder(
default,
map(key(type = super::EnvironmentVariable), value(type = super::IngestSource))
)]
#[serde(
rename = "sources",
skip_serializing_if = "std::collections::BTreeMap::is_empty",
default
)]
sources: std::collections::BTreeMap<super::EnvironmentVariable, super::IngestSource>,
#[builder(
default,
map(key(type = super::EnvironmentVariable), value(type = String, into))
)]
#[serde(
rename = "arguments",
skip_serializing_if = "std::collections::BTreeMap::is_empty",
default
)]
arguments: std::collections::BTreeMap<super::EnvironmentVariable, String>,
#[serde(rename = "extractorRid")]
extractor_rid: super::ContainerizedExtractorRid,
#[builder(
default,
custom(
type = impl
Into<Option<super::TimestampMetadata>>,
convert = |v|v.into().map(Box::new)
)
)]
#[serde(
rename = "timestampMetadata",
skip_serializing_if = "Option::is_none",
default
)]
timestamp_metadata: Option<Box<super::TimestampMetadata>>,
#[builder(default, into)]
#[serde(rename = "tag", skip_serializing_if = "Option::is_none", default)]
tag: Option<String>,
#[builder(custom(type = super::DatasetIngestTarget, convert = Box::new))]
#[serde(rename = "target")]
target: Box<super::DatasetIngestTarget>,
#[builder(
default,
map(
key(type = super::super::super::api::TagName),
value(type = super::super::super::api::TagValue)
)
)]
#[serde(
rename = "additionalFileTags",
skip_serializing_if = "std::collections::BTreeMap::is_empty",
default
)]
additional_file_tags: std::collections::BTreeMap<
super::super::super::api::TagName,
super::super::super::api::TagValue,
>,
}
impl ContainerizedOpts {
#[inline]
pub fn new(
extractor_rid: super::ContainerizedExtractorRid,
target: super::DatasetIngestTarget,
) -> Self {
Self::builder().extractor_rid(extractor_rid).target(target).build()
}
#[inline]
pub fn sources(
&self,
) -> &std::collections::BTreeMap<super::EnvironmentVariable, super::IngestSource> {
&self.sources
}
#[inline]
pub fn arguments(
&self,
) -> &std::collections::BTreeMap<super::EnvironmentVariable, String> {
&self.arguments
}
#[inline]
pub fn extractor_rid(&self) -> &super::ContainerizedExtractorRid {
&self.extractor_rid
}
#[inline]
pub fn timestamp_metadata(&self) -> Option<&super::TimestampMetadata> {
self.timestamp_metadata.as_ref().map(|o| &**o)
}
#[inline]
pub fn tag(&self) -> Option<&str> {
self.tag.as_ref().map(|o| &**o)
}
#[inline]
pub fn target(&self) -> &super::DatasetIngestTarget {
&*self.target
}
#[inline]
pub fn additional_file_tags(
&self,
) -> &std::collections::BTreeMap<
super::super::super::api::TagName,
super::super::super::api::TagValue,
> {
&self.additional_file_tags
}
}