Struct fluvio_stream_dispatcher::store::StoreContext

pub struct StoreContext<S, MetaContext = K8MetaItem> where
    S: Spec,
    MetaContext: MetadataItem + Debug,  { /* fields omitted */ }

Implementations

impl<S, MetaContext> StoreContext<S, MetaContext> where
    S: Spec,
    MetaContext: MetadataItem, 

pub fn new() -> Self

create new store context

pub fn new_with_store(store: Arc<LocalStore<S, MetaContext>>) -> Self

create new store context with store

pub async fn send(
    &mut self,
    actions: Vec<WSAction<S, MetaContext>>
) -> Result<(), SendError<WSAction<S, MetaContext>>>

pub fn change_listener(&self) -> ChangeListener<S, MetaContext>

create new listener

pub fn store(&self) -> &Arc<LocalStore<S, MetaContext>>

pub fn receiver(&self) -> Receiver<WSAction<S, MetaContext>>

impl<S, MetaContext> StoreContext<S, MetaContext> where
    S: Spec + PartialEq,
    MetaContext: MetadataItem, 

pub async fn apply(
    &self,
    input: MetadataStoreObject<S, MetaContext>
) -> Result<MetadataStoreObject<S, MetaContext>, IoError> where
    S::IndexKey: Display, 

Wait for the termination of the apply action object, this is similar to kubectl apply

pub async fn create_spec(
    &self,
    key: S::IndexKey,
    spec: S
) -> Result<MetadataStoreObject<S, MetaContext>, IoError> where
    S::IndexKey: Display, 

Wait for creation/update of spec. There is no guarantee that this spec has been applied. Only that spec has been changed.

This should only used in the imperative code such as API Server where confirmation is needed.
Controller should only use Action.

pub async fn update_status(
    &self,
    key: S::IndexKey,
    status: S::Status
) -> Result<MetadataStoreObject<S, MetaContext>, IoError> where
    S::IndexKey: Display, 

Wait for status update. There is no guarantee that this status valus has been applied. Only that status has been changed.

This should only used in the imperative code such as API Server where confirmation is needed.
Controller should only use Action.

pub async fn delete(&self, key: S::IndexKey) -> Result<(), IoError>

Wait for object deletion.

This should only used in the imperative code such as API Server where confirmation is needed.
Controller should only use Action.

pub async fn wait_action(
    &self,
    key: &S::IndexKey,
    action: WSAction<S, MetaContext>
) -> Result<MetadataStoreObject<S, MetaContext>, IoError> where
    S::IndexKey: Display, 

Wait for action to finish with default duration

pub async fn wait_action_with_timeout(
    &self,
    key: &S::IndexKey,
    action: WSAction<S, MetaContext>,
    timeout: Duration
) -> Result<MetadataStoreObject<S, MetaContext>, IoError> where
    S::IndexKey: Display, 

Wait for action to finish. There is no guarantee that the status valus has been applied. Only that status has been changed.

This should only used in the imperative code such as API Server where confirmation is needed.
Controller should only use Action.

pub async fn send_action(&self, action: WSAction<S, MetaContext>)

send action

Trait Implementations

impl<S: Clone, MetaContext: Clone> Clone for StoreContext<S, MetaContext> where
    S: Spec,
    MetaContext: MetadataItem + Debug, 

fn clone(&self) -> StoreContext<S, MetaContext>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S: Debug, MetaContext: Debug> Debug for StoreContext<S, MetaContext> where
    S: Spec,
    MetaContext: MetadataItem + Debug, 

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

Formats the value using the given formatter.

impl<S, MetaContext> Default for StoreContext<S, MetaContext> where
    S: Spec,
    MetaContext: MetadataItem, 

fn default() -> Self

Returns the “default value” for a type.