Skip to main content

ActorClient

Struct ActorClient 

Source
pub struct ActorClient { /* private fields */ }
Expand description

Client for a specific Actor.

Provides CRUD methods plus convenience helpers to start/call the Actor, build it, and access its runs, builds, versions and webhooks.

Implementations§

Source§

impl ActorClient

Source

pub async fn get(&self) -> ApifyClientResult<Option<Actor>>

Fetches the Actor object, or None if it does not exist.

Source

pub async fn update<T: Serialize>( &self, new_fields: &T, ) -> ApifyClientResult<Actor>

Updates the Actor with the given fields and returns the updated object.

Source

pub async fn delete(&self) -> ApifyClientResult<()>

Deletes the Actor.

Source

pub async fn start<T: Serialize>( &self, input: Option<&T>, options: ActorStartOptions, ) -> ApifyClientResult<ActorRun>

Starts the Actor and returns immediately with the created run.

input is any JSON-serializable value (or None for no input).

Source

pub async fn call<T: Serialize>( &self, input: Option<&T>, options: ActorStartOptions, wait_secs: Option<i64>, ) -> ApifyClientResult<ActorRun>

Starts the Actor and waits (client-side polling) for it to finish.

wait_secs controls the wait budget:

  • None polls indefinitely until the run reaches a terminal state.
  • Some(n) bounds the wait to roughly n seconds; if the run has not finished by then, the last fetched (still non-terminal) run is returned rather than an error. Check status / is_terminal() on the result when using Some.
Source

pub async fn build( &self, version_number: &str, options: ActorBuildOptions, ) -> ApifyClientResult<Build>

Builds the given version of the Actor and returns the created build.

Source

pub async fn default_build( &self, wait_for_finish: Option<i64>, ) -> ApifyClientResult<BuildClient>

Resolves the Actor’s default build and returns a client for it.

wait_for_finish optionally bounds how long (in seconds) the API waits for the build to finish before responding, matching the reference client’s defaultBuild(options).

Source

pub async fn validate_input<T: Serialize>( &self, input: &T, ) -> ApifyClientResult<Value>

Validates the given input against the Actor’s input schema.

Uses the Actor’s default build for the input schema. To validate against a specific build, use ActorClient::validate_input_for_build.

Source

pub async fn validate_input_for_build<T: Serialize>( &self, input: &T, build: Option<&str>, ) -> ApifyClientResult<Value>

Validates the given input against the input schema of a specific Actor build.

build is the optional tag or number of the Actor build whose input schema is used for validation (e.g. "latest" or "1.2.34"); passing None uses the default build, which is equivalent to ActorClient::validate_input. This maps to the spec’s optional build query parameter on POST /v2/actors/{actorId}/validate-input.

Source

pub fn last_run(&self, status: Option<&str>) -> RunClient

Returns a client for the last run of this Actor, optionally filtered by run status.

status filters by run status (e.g. "SUCCEEDED", "FAILED", "RUNNING"); pass None to leave it unfiltered. This maps to the status query parameter on GET /v2/actors/{actorId}/runs/last and mirrors the reference client’s lastRun({ status }). To also filter by origin, use ActorClient::last_run_with_options.

Source

pub fn last_run_with_options(&self, options: LastRunOptions) -> RunClient

Returns a client for the last run of this Actor, applying the given LastRunOptions (e.g. LastRunOptions::status and/or LastRunOptions::origin).

status filters by run status (e.g. "SUCCEEDED", "FAILED", "RUNNING") and is the spec’s documented filter on GET /v2/actors/{actorId}/runs/last. origin filters by how the run was started; accepted values are the platform’s run origins (e.g. "DEVELOPMENT", "WEB", "API", "SCHEDULER"). origin is not declared by the OpenAPI spec and is sent only for parity with the reference client’s lastRun({ status, origin }). Both are sent as query parameters; leave a field as None to omit it.

Source

pub fn builds(&self) -> BuildCollectionClient

Returns a client for this Actor’s build collection.

Source

pub fn runs(&self) -> RunCollectionClient

Returns a client for this Actor’s run collection.

Source

pub fn version(&self, version_number: &str) -> ActorVersionClient

Returns a client for a specific version of this Actor.

Source

pub fn versions(&self) -> ActorVersionCollectionClient

Returns a client for this Actor’s version collection.

Source

pub fn webhooks(&self) -> WebhookCollectionClient

Returns a client for this Actor’s webhook collection.

Source

pub fn id(&self) -> &str

The Actor’s ID (or username~name) as provided.

Trait Implementations§

Source§

impl Clone for ActorClient

Source§

fn clone(&self) -> ActorClient

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for ActorClient

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more