Struct near_lake_framework::LakeConfigBuilder

source · [−]

pub struct LakeConfigBuilder { /* private fields */ }

Expand description

Builder for LakeConfig.

Implementations

source

impl LakeConfigBuilder

source

pub fn s3_bucket_name<VALUE: Into<String>>(self, value: VALUE) -> Self

AWS S3 Bucket name

source

pub fn s3_region_name<VALUE: Into<String>>(self, value: VALUE) -> Self

AWS S3 Region name

source

pub fn start_block_height(self, value: u64) -> Self

Defines the block height to start indexing from

source

pub fn s3_config(self, value: Config) -> Self

Custom aws_sdk_s3::config::Config

Use-case: custom endpoint

You might want to stream data from the custom S3-compatible source () . In order to do that you’d need to pass aws_sdk_s3::config::Config configured

use aws_sdk_s3::Endpoint;
use http::Uri;
use near_lake_framework::LakeConfigBuilder;

    let aws_config = aws_config::from_env().load().await;
    let mut s3_conf = aws_sdk_s3::config::Builder::from(&aws_config);
    s3_conf = s3_conf
        .endpoint_resolver(
            Endpoint::immutable("http://0.0.0.0:9000".parse::<Uri>().unwrap()))
        .build();

    let config = LakeConfigBuilder::default()
        .s3_config(s3_conf)
        .s3_bucket_name("near-lake-data-custom")
        .start_block_height(1)
        .build()
        .expect("Failed to build LakeConfig");

source

pub fn build(self) -> Result<LakeConfig, LakeConfigBuilderError>

Builds a new LakeConfig.

Errors

If a required field has not been initialized.

source

impl LakeConfigBuilder

source

pub fn mainnet(self) -> Self

Shortcut to set up LakeConfigBuilder::s3_bucket_name for mainnet

use near_lake_framework::LakeConfigBuilder;

   let config = LakeConfigBuilder::default()
       .mainnet()
       .start_block_height(65231161)
       .build()
       .expect("Failed to build LakeConfig");

source

pub fn testnet(self) -> Self

Shortcut to set up LakeConfigBuilder::s3_bucket_name for testnet

use near_lake_framework::LakeConfigBuilder;

   let config = LakeConfigBuilder::default()
       .testnet()
       .start_block_height(82422587)
       .build()
       .expect("Failed to build LakeConfig");