pub enum ApiCall {
Show 26 variants
Me,
Nodes,
ClusterStatus,
NodeMetrics(String),
NodeBackup(String),
DrainStatus(String),
DrainStart(String),
DrainCancel(String),
FlushNode(String),
FlushCluster,
StopCluster,
Tokens(Option<String>),
TokenCreate(String),
TokenUpdate(String, String),
TokenRevoke(String),
Topics(Option<String>),
TopicStats(Option<String>),
TopicCreate(String),
TopicUpdate(String, String),
TopicDelete(String),
TopicDetail(String),
Publish(PublishSpec),
Receive(String, u32, u32),
Ack(String, String, String),
Visibility(String, String, String, u32),
Prune(String),
}Expand description
What a call is for; it comes back with the reply so update knows what to do with it.
Variants§
Me
Nodes
ClusterStatus
NodeMetrics(String)
NodeBackup(String)
DrainStatus(String)
DrainStart(String)
DrainCancel(String)
FlushNode(String)
FlushCluster
StopCluster
Tokens(Option<String>)
One page of GET /tokens, from a cursor.
TokenCreate(String)
POST /tokens with the JSON body of the form.
TokenUpdate(String, String)
PATCH /tokens/{id} with the changed fields.
TokenRevoke(String)
Topics(Option<String>)
One page of GET /topics, from a cursor.
TopicStats(Option<String>)
One page of GET /stats/topics (the numbers of the list), from a cursor.
TopicCreate(String)
POST /topics with the JSON body of the form.
TopicUpdate(String, String)
PATCH /topics/{name} with the changed fields.
TopicDelete(String)
TopicDetail(String)
GET /stats/topics/{name}: one reading of a queue for its charts.
Publish(PublishSpec)
POST /topics/{name}/messages.
Receive(String, u32, u32)
GET /topics/{name}/messages: reads up to RECEIVE_MAX messages and holds them for the given seconds (the form offers RECEIVE_HOLD_SECS).
Ack(String, String, String)
DELETE /topics/{name}/messages/{id} with the receipt: topic, id, receipt.
Visibility(String, String, String, u32)
PUT /topics/{name}/messages/{id}/visibility with 0: gives the message back to the queue now.
Changes the time a held message stays invisible; 0 gives it back to the queue now.
Prune(String)
DELETE /topics/{name}/messages: empties the queue on every node.
Implementations§
Trait Implementations§
impl Eq for ApiCall
impl StructuralPartialEq for ApiCall
Auto Trait Implementations§
impl Freeze for ApiCall
impl RefUnwindSafe for ApiCall
impl Send for ApiCall
impl Sync for ApiCall
impl Unpin for ApiCall
impl UnsafeUnpin for ApiCall
impl UnwindSafe for ApiCall
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more