Struct LakekeeperService

pub struct LakekeeperService {
    config: LakekeeperConfig,
}

Fields

config: LakekeeperConfig

Implementations

impl LakekeeperService

pub fn new(config: LakekeeperConfig) -> Result<Self>

fn lakekeeper_path(&self) -> Result<PathBuf>

fn lakekeeper(&self) -> Result<Command>

fn base_uri(&self) -> String

pub fn apply_command_args( cmd: &mut Command, config: &LakekeeperConfig, ) -> Result<()>

Apply command args according to config

fn initialize_lakekeeper_database( &self, ctx: &mut ExecuteContext<impl Write>, ) -> Result<()>

fn run_migrate(&mut self, ctx: &mut ExecuteContext<impl Write>) -> Result<()>

fn bootstrap_lakekeeper( &self, ctx: &mut ExecuteContext<impl Write>, ) -> Result<()>

fn create_default_warehouse( &self, ctx: &mut ExecuteContext<impl Write>, ) -> Result<()>

Trait Implementations

impl Task for LakekeeperService

fn execute(&mut self, ctx: &mut ExecuteContext<impl Write>) -> Result<()>

Execute the task

fn id(&self) -> String

Get task id used in progress bar