Struct fluvio::metadata::tableformat::TableFormatSpec

pub struct TableFormatSpec {
    pub name: String,
    pub input_format: Option<DataFormat>,
    pub columns: Option<Vec<TableFormatColumnConfig>>,
    pub smartmodule: Option<String>,
}

Fields

name: String

input_format: Option<DataFormat>

columns: Option<Vec<TableFormatColumnConfig>>

smartmodule: Option<String>

Implementations

impl TableFormatSpec

pub fn get_primary_keys(&self) -> Vec<String>

Trait Implementations

impl AdminSpec for TableFormatSpec

fn convert_from<C>(obj: &MetadataStoreObject<Self, C>) -> Metadata<Self>

where C: MetadataItem, Metadata<Self>: From<MetadataStoreObject<Self, C>>, Self::Status: Encoder + Decoder + Debug,

convert metadata object to list type object

fn summary(self) -> Self

return summary version of myself

impl Clone for TableFormatSpec

fn clone(&self) -> TableFormatSpec

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TableFormatSpec

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

Formats the value using the given formatter.

impl Decoder for TableFormatSpec

fn decode<T>(&mut self, src: &mut T, version: i16) -> Result<(), Error>

where T: Buf,

fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error>

where T: Buf,

decode Fluvio compliant protocol values from buf

impl Default for TableFormatSpec

fn default() -> TableFormatSpec

Returns the “default value” for a type.

impl DeletableAdminSpec for TableFormatSpec

type DeleteKey = String

impl<'de> Deserialize<'de> for TableFormatSpec

fn deserialize<__D>( __deserializer: __D ) -> Result<TableFormatSpec, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Encoder for TableFormatSpec

fn encode<T>(&self, dest: &mut T, version: i16) -> Result<(), Error>

where T: BufMut,

encoding contents for buffer

fn write_size(&self, version: i16) -> usize

size of this object in bytes

fn as_bytes(&self, version: i16) -> Result<Bytes, Error>

impl K8ExtendedSpec for TableFormatSpec

type K8Spec = TableFormatSpec

fn convert_from_k8( k8_obj: K8Obj<<TableFormatSpec as K8ExtendedSpec>::K8Spec>, multi_namespace_context: bool ) -> Result<MetadataStoreObject<TableFormatSpec, K8MetaItem>, K8ConvertError<<TableFormatSpec as K8ExtendedSpec>::K8Spec>>

fn convert_status_from_k8( status: <TableFormatSpec as Spec>::Status ) -> <TableFormatSpec as Spec>::Status

fn into_k8(self) -> <TableFormatSpec as K8ExtendedSpec>::K8Spec

const DELETE_WAIT_DEPENDENTS: bool = false

const FINALIZER: Option<&'static str> = None

impl PartialEq for TableFormatSpec

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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl Removable for TableFormatSpec

type DeleteKey = String

impl Serialize for TableFormatSpec

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Spec for TableFormatSpec

type Status = TableFormatStatus

type Header = DefaultHeader

fn metadata() -> &'static Crd

return uri for single instance

const NAME_SPACED: bool = true

if true, spec is namespaced

fn label() -> &'static str

fn api_version() -> String

fn kind() -> String

fn make_same(&mut self, _other: &Self)

in case of applying, we have some fields that are generated or override. So need to special logic to reset them so we can do proper comparison

impl Spec for TableFormatSpec

const LABEL: &'static str = "TableFormat"

type Status = TableFormatStatus

type Owner = TableFormatSpec

type IndexKey = String

impl SpecExt for TableFormatSpec

const OBJECT_TYPE: ObjectType = ObjectType::TableFormat

impl Creatable for TableFormatSpec

impl CreatableAdminSpec for TableFormatSpec

impl Eq for TableFormatSpec

impl StructuralPartialEq for TableFormatSpec