Struct golem_rpc_api::comp::GolemComp

pub struct GolemComp<'a, Inner: RpcEndpoint + ?Sized>(_);

Methods

impl<'a, Inner: RpcEndpoint + ?Sized + 'static> GolemComp<'a, Inner>

pub fn create_task_int(
    &self,
    task_spec: Value
) -> impl Future<Output = Result<(Option<String>, Option<Value>), Error>>

Calls comp.task.create RPC URI.

pub fn create_dry_run_int(
    &self,
    task_spec: Value
) -> impl Future<Output = Result<(Option<TaskInfo>, Option<Value>), Error>>

Calls comp.task.create.dry_run RPC URI.

pub fn get_task(
    &self,
    task_id: String
) -> impl Future<Output = Result<Option<TaskInfo>, Error>>

Calls comp.task RPC URI.

pub fn get_tasks<'b>(
    &'b self
) -> impl Future<Output = Result<Vec<TaskInfo>, Error>> + 'static

Calls comp.tasks RPC URI.

pub fn get_tasks_unsupported(
    &self,
    last_days: i32
) -> impl Future<Output = Result<Vec<UnsupportInfo>, Error>>

Show statistics for unsupported tasks.

Arguments

• last_days - Number of last days to compute statistics on.

Returns

Vec of UnsupportInfo. With stats for each reason.

Calls comp.tasks.unsupport RPC URI.

pub fn abort_task(
    &self,
    task_id: String
) -> impl Future<Output = Result<(), Error>>

Abort task with given id.

Arguments

• task_id - Task id to abort.

Calls comp.task.abort RPC URI.

pub fn delete_task(
    &self,
    taks_id: String
) -> impl Future<Output = Result<(), Error>>

Calls comp.task.delete RPC URI.

pub fn restart_subtask(
    &self,
    subtask_id: String
) -> impl Future<Output = Result<(), Error>>

Calls comp.task.subtask.restart RPC URI.

pub fn get_subtask(
    &self,
    subtask_id: String
) -> impl Future<Output = Result<(Option<SubtaskInfo>, Option<String>), Error>>

Calls comp.task.subtask RPC URI.

pub fn get_subtasks(
    &self,
    task_id: String
) -> impl Future<Output = Result<Option<Vec<SubtaskInfo>>, Error>>

Calls comp.task.subtasks RPC URI.

pub fn purge_tasks<'b>(
    &'b self
) -> impl Future<Output = Result<(), Error>> + 'static

Calls comp.task.purge RPC URI.

pub fn restart_task(
    &self,
    task_id: String
) -> impl Future<Output = Result<(Option<String>, Option<String>), Error>>

Calls comp.task.restart RPC URI.

pub fn restart_frame_subtasks(
    &self,
    task_id: String,
    frame: u32
) -> impl Future<Output = Result<(), Error>>

Calls comp.task.subtasks.frame.restart RPC URI.

pub fn restart_subtasks_from_task(
    &self,
    task_id: String,
    subtask_ids: Vec<String>
) -> impl Future<Output = Result<Value, Error>>

Restarts a set of subtasks from the given task. If the specified task is already finished, all failed subtasks will be restarted along with the set provided as a parameter. Finished subtasks will have their results copied over to the newly created task.

Parameters

• task_id the ID of the task which contains the given subtasks.
• subtask_ids the set of subtask IDs which should be restarted. If this is empty and the task is finished, all of the task's subtasks marked as failed will be restarted.
• ignore_gas_price if True, this will ignore long transaction time errors and proceed with the restart.
• disable_concent setting this flag to True will result in forcing Concent to be disabled for the task. This only has effect when the task is already finished and needs to be restarted.

##Returns

In case of any errors, returns the representation of the error (either a string or a dict). Otherwise, returns None.

Calls comp.task.subtasks.restart RPC URI.

pub fn run_test_task(
    &self,
    task_spec: Value
) -> impl Future<Output = Result<bool, Error>>

Calls comp.tasks.check RPC URI.

pub fn check_test_status<'b>(
    &'b self
) -> impl Future<Output = Result<TaskTestResult, Error>> + 'static

Calls comp.task.test.status RPC URI.

pub fn abort_test_task<'b>(
    &'b self
) -> impl Future<Output = Result<bool, Error>> + 'static

Returns true if there was task to cancel Calls comp.tasks.check.abort RPC URI.

pub fn get_tasks_stats<'b>(
    &'b self
) -> impl Future<Output = Result<SubtaskStats, Error>> + 'static

Calls comp.tasks.stats RPC URI.

pub fn get_environments<'b>(
    &'b self
) -> impl Future<Output = Result<Vec<CompEnvStatus>, Error>> + 'static

Calls comp.environments RPC URI.

pub fn enable_environment(
    &self,
    env_id: String
) -> impl Future<Output = Result<Option<String>, Error>>

Enables enviroment Returns None or Error message. Calls comp.environment.enable RPC URI.

pub fn disable_environment(
    &self,
    env_id: String
) -> impl Future<Output = Result<Option<String>, Error>>

Enables enviroment Returns None or Error message. Calls comp.environment.disable RPC URI.

pub fn run_benchmark(
    &self,
    env_id: String
) -> impl Future<Output = Result<Value, Error>>

Calls comp.environment.benchmark RPC URI.

pub fn perf_mult_set(
    &self,
    multiplier: f64
) -> impl Future<Output = Result<(), Error>>

Calls performance.multiplier.update RPC URI.

pub fn perf_mult<'b>(
    &'b self
) -> impl Future<Output = Result<f64, Error>> + 'static

Calls performance.multiplier RPC URI.

impl<'a, Inner: RpcEndpoint + ?Sized + 'static> GolemComp<'a, Inner>

pub fn create_task(
    &self,
    task_spec: Value
) -> impl Future<Output = Result<String, Error>> + 'static

pub fn create_dry_run(
    &self,
    task_spec: Value
) -> impl Future<Output = Result<TaskInfo, Error>>