Struct near_lake_framework::LakeConfig
source · pub struct LakeConfig {
pub s3_region_name: String,
pub s3_config: Option<Config>,
/* private fields */
}
Expand description
Configuration struct for NEAR Lake Framework
NB! Consider using LakeConfigBuilder
Building the LakeConfig
example:
use near_lake_framework::LakeConfigBuilder;
let config = LakeConfigBuilder::default()
.testnet()
.start_block_height(82422587)
.build()
.expect("Failed to build LakeConfig");
Fields§
§s3_region_name: String
AWS S3 Region name
s3_config: Option<Config>
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");
This field is mutually exclusive with LakeConfigBuilder::s3_client.
Trait Implementations§
source§impl Default for LakeConfig
impl Default for LakeConfig
source§fn default() -> LakeConfig
fn default() -> LakeConfig
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for LakeConfig
impl !RefUnwindSafe for LakeConfig
impl Send for LakeConfig
impl Sync for LakeConfig
impl Unpin for LakeConfig
impl !UnwindSafe for LakeConfig
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreCreates a shared type from an unshared type.