Struct SavedObjectsLoader 

pub struct SavedObjectsLoader { /* private fields */ }

Loader for Kibana saved objects

Imports saved objects into Kibana using the import API. Objects are sent as NDJSON in a multipart form.

Example

use kibana_sync::kibana::saved_objects::SavedObjectsLoader;
use kibana_sync::client::{Auth, KibanaClient};
use kibana_sync::etl::Loader;
use serde_json::json;
use url::Url;

let url = Url::parse("http://localhost:5601")?;
let client = KibanaClient::new(url, Auth::None)?;
let space_client = client.space("default")?;
let loader = SavedObjectsLoader::new(space_client);

let objects = vec![
    json!({
        "type": "dashboard",
        "id": "my-dashboard",
        "attributes": {"title": "My Dashboard"}
    })
];

let count = loader.load(objects).await?;

Implementations

impl SavedObjectsLoader

pub fn new(client: KibanaClient) -> Self

Create a new saved objects loader

Arguments

• client - Space-scoped Kibana client

pub fn with_overwrite(self, overwrite: bool) -> Self

Set whether to overwrite existing objects (default: true)

Trait Implementations

impl Loader for SavedObjectsLoader

type Item = Value

The type of items to load

async fn load(&self, items: Vec<Self::Item>) -> Result<usize>

Load items to the destination