Struct fluvio::metadata::spu::SpuSpec

pub struct SpuSpec {
    pub id: i32,
    pub spu_type: SpuType,
    pub public_endpoint: IngressPort,
    pub private_endpoint: Endpoint,
    pub rack: Option<String>,
    pub public_endpoint_local: Option<Endpoint>,
}

Fields

id: i32

spu_type: SpuType

public_endpoint: IngressPort

private_endpoint: Endpoint

rack: Option<String>

public_endpoint_local: Option<Endpoint>

Implementations

impl SpuSpec

pub fn new(id: i32) -> SpuSpec

Given an Spu id generate a new SpuSpec

pub fn new_public_addr(id: i32, port: u16, host: String) -> SpuSpec

pub fn new_private_addr(id: i32, port: u16, host: String) -> SpuSpec

pub fn set_custom(self) -> SpuSpec

pub fn is_custom(&self) -> bool

Return custom type: true for custom, false otherwise

pub fn private_server_address(&self) -> ServerAddress

pub fn update(&mut self, other: &SpuSpec)

Trait Implementations

impl AdminSpec for SpuSpec

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 SpuSpec

fn clone(&self) -> SpuSpec

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SpuSpec

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

Formats the value using the given formatter.

impl Decoder for SpuSpec

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 SpuSpec

fn default() -> SpuSpec

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for SpuSpec

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Display for SpuSpec

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

Formats the value using the given formatter.

impl Encoder for SpuSpec

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 From<CustomSpuSpec> for SpuSpec

fn from(spec: CustomSpuSpec) -> SpuSpec

Converts to this type from the input type.

impl From<SpuSpec> for CustomSpuSpec

fn from(spu: SpuSpec) -> CustomSpuSpec

Converts to this type from the input type.

impl From<i32> for SpuSpec

fn from(spec: i32) -> SpuSpec

Converts to this type from the input type.

impl K8ExtendedSpec for SpuSpec

type K8Spec = SpuSpec

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

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

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

const DELETE_WAIT_DEPENDENTS: bool = false

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

impl PartialEq for SpuSpec

fn eq(&self, other: &SpuSpec) -> 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 Serialize for SpuSpec

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 SpuSpec

type Status = SpuStatus

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 SpuSpec

const LABEL: &'static str = "SPU"

type IndexKey = String

type Owner = SpuGroupSpec

type Status = SpuStatus

impl SpecExt for SpuSpec

const OBJECT_TYPE: ObjectType = ObjectType::Spu

impl Eq for SpuSpec

impl StructuralPartialEq for SpuSpec