Struct switchboard_utils::runner::TaskRunner

pub struct TaskRunner {
    pub config: TaskRunnerConfig,
    pub solana_rpc_url: String,
}

Fields

config: TaskRunnerConfig

solana_rpc_url: String

Implementations

impl TaskRunner

pub fn new(solana_rpc_url: String, config: Option<TaskRunnerConfig>) -> Self

pub async fn run( &self, oracle_job: &OracleJob, config: Option<TaskRunnerConfig> ) -> TaskResult<TaskOutput>

pub async fn run_oracle_job( &self, oracle_job: &OracleJob ) -> TaskResult<TaskOutput>

pub async fn run_task( &self, ctx: &TaskRunnerContext, task: &Task ) -> TaskResult<TaskOutput>

pub async fn http_task( &self, _ctx: &TaskRunnerContext, task: &HttpTask ) -> TaskResult<TaskOutput>

pub async fn json_parse_task( &self, ctx: &TaskRunnerContext, task: &JsonParseTask ) -> TaskResult<TaskOutput>

pub async fn jupiter_swap_task( &self, _ctx: &TaskRunnerContext, task: &JupiterSwapTask ) -> TaskResult<TaskOutput>