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>,
}

Fields

id: i32

spu_type: SpuType

public_endpoint: IngressPort

private_endpoint: Endpoint

rack: Option<String>

Implementations

impl SpuSpec

pub fn new(id: i32) -> SpuSpec

Given an Spu id generate a new 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 Clone for SpuSpec

pub fn clone(&self) -> SpuSpec

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SpuSpec

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

Formats the value using the given formatter.

impl Decoder for SpuSpec

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

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

decode Kafka compliant protocol values from buf

impl Default for SpuSpec

pub fn default() -> SpuSpec

Returns the “default value” for a type.

impl Display for SpuSpec

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

Formats the value using the given formatter.

impl Encoder for SpuSpec

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

encoding contents for buffer

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

size of this object in bytes

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

impl From<CustomSpuSpec> for SpuSpec

pub fn from(spec: CustomSpuSpec) -> SpuSpec

Performs the conversion.

impl From<SpuSpec> for CustomSpuSpec

pub fn from(spu: SpuSpec) -> CustomSpuSpec

Performs the conversion.

impl From<i32> for SpuSpec

pub fn from(spec: i32) -> SpuSpec

Performs the conversion.

impl ListSpec for SpuSpec

type Filter = String

filter type

pub fn into_list_request(
    filters: Vec<<SpuSpec as ListSpec>::Filter, Global>
) -> ListRequest

convert to list request with filters

impl PartialEq<SpuSpec> for SpuSpec

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

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

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

This method tests for !=.

impl Spec for SpuSpec

pub const LABEL: &'static str

type IndexKey = String

type Owner = SpuSpec

type Status = SpuStatus

impl SpecExt for SpuSpec

pub const OBJECT_TYPE: ObjectType

impl StructuralPartialEq for SpuSpec