pub struct TasksService {
pub shared: Arc<Shared>,
}Expand description
cronoq.v1.Tasks.
Fields§
Server state.
Trait Implementations§
Source§impl Tasks for TasksService
impl Tasks for TasksService
Source§type WatchStream = Pin<Box<dyn Stream<Item = Result<StatusEvent, Status>> + Send>>
type WatchStream = Pin<Box<dyn Stream<Item = Result<StatusEvent, Status>> + Send>>
Server streaming response type for the Watch method.
fn submit<'life0, 'async_trait>(
&'life0 self,
req: Request<SubmitRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SubmitResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn submit_batch<'life0, 'async_trait>(
&'life0 self,
req: Request<SubmitBatchRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<SubmitBatchResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn cancel<'life0, 'async_trait>(
&'life0 self,
req: Request<CancelRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<CancelResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get<'life0, 'async_trait>(
&'life0 self,
req: Request<GetRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TaskInfo>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn list_tasks<'life0, 'async_trait>(
&'life0 self,
req: Request<ListTasksRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<ListTasksResponse>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn wait<'life0, 'async_trait>(
&'life0 self,
req: Request<WaitRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<TaskResult>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn watch<'life0, 'async_trait>(
&'life0 self,
req: Request<WatchRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::WatchStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn watch<'life0, 'async_trait>(
&'life0 self,
req: Request<WatchRequest>,
) -> Pin<Box<dyn Future<Output = Result<Response<Self::WatchStream>, Status>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Ends with UNAVAILABLE when the server shuts down or loses leadership, and with
DATA_LOSS if the client falls too far behind.
Auto Trait Implementations§
impl !RefUnwindSafe for TasksService
impl !UnwindSafe for TasksService
impl Freeze for TasksService
impl Send for TasksService
impl Sync for TasksService
impl Unpin for TasksService
impl UnsafeUnpin for TasksService
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
Mutably borrows from an owned value. Read more
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
Source§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
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> ⓘ
Converts
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> ⓘ
Converts
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 moreSource§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request