Struct AdminClient

pub struct AdminClient { /* private fields */ }

A high-level client for interacting with the Ora server admin endpoints.

Implementations

impl AdminClient

pub fn new(client: AdminServiceClient<Channel>) -> Self

Create a new admin client from a gRPC client.

pub async fn add_job<J>( &self, definition: TypedJobDefinition<J>, ) -> Result<JobHandle<J>, AdminClientError>

Add a new job to be executed.

pub async fn add_jobs<J>( &self, definitions: impl IntoIterator<Item = TypedJobDefinition<J>>, ) -> Result<Vec<JobHandle<J>>, AdminClientError>

Add multiple new jobs to be executed.

pub fn job(&self, job_id: Uuid) -> JobHandle

Create a job handle for a specific job.

Note that this method does not check if the job exists.

pub fn jobs_of_type<J>( &self, filter: JobFilter, order_by: JobOrder, ) -> impl Stream<Item = Result<JobHandle<J>, AdminClientError>> + Send + Unpin + 'static

where J: JobType,

Retrieve a list of jobs of a specific type with a specific filter and order.

The returned job handles will have their details pre-fetched.

pub fn jobs( &self, filter: JobFilter, order_by: JobOrder, ) -> impl Stream<Item = Result<JobHandle, AdminClientError>> + Send + Unpin + 'static

Retrieve a list of jobs with a specific filter and order.

The returned job handles will have their details pre-fetched.

pub async fn job_count( &self, filter: JobFilter, ) -> Result<u64, AdminClientError>

Count the number of jobs with a specific filter.

pub async fn job_count_of_type<J>( &self, filter: JobFilter, ) -> Result<u64, AdminClientError>

where J: JobType,

Count the number of jobs of a specific type with a specific filter.

pub async fn cancel_jobs( &self, filter: JobFilter, ) -> Result<Vec<JobHandle>, AdminClientError>

Cancel jobs with a specific filter.

Returns handles to jobs that were successfully cancelled.

pub async fn delete_inactive_jobs( &self, filter: JobFilter, ) -> Result<Vec<Uuid>, AdminClientError>

Delete inactive jobs and associated with a specific filter, returning the deleted job IDs.

pub async fn add_schedule( &self, schedule: ScheduleDefinition, ) -> Result<ScheduleHandle, AdminClientError>

Add a new schedule.

pub async fn add_schedules( &self, schedules: impl IntoIterator<Item = ScheduleDefinition>, ) -> Result<Vec<ScheduleHandle>, AdminClientError>

Add multiple new schedules.

Returns handles to the created schedules.

pub fn schedule(&self, schedule_id: Uuid) -> ScheduleHandle

Create a new schedule handle for a specific schedule.

Note that this method does not check if the schedule exists.

pub fn schedules( &self, filter: ScheduleFilter, order: ScheduleOrder, ) -> impl Stream<Item = Result<ScheduleHandle, AdminClientError>> + Send + Unpin + 'static

Retrieve a list of schedules with a specific filter and order.

The returned schedule handles will have their details pre-fetched.

pub async fn schedule_count( &self, filter: ScheduleFilter, ) -> Result<u64, AdminClientError>

Return the number of schedules that match a specific filter.

pub async fn cancel_schedules( &self, filter: ScheduleFilter, cancel_jobs: bool, ) -> Result<ScheduleCancellationResult, AdminClientError>

Cancel schedules with a specific filter, optionally cancelling the jobs associated with them.

Trait Implementations

impl Clone for AdminClient

fn clone(&self) -> AdminClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AdminClient

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

Formats the value using the given formatter.

impl From<AdminServiceClient<Channel>> for AdminClient

fn from(client: AdminServiceClient<Channel>) -> Self

Converts to this type from the input type.