Struct aws_sdk_neptunedata::operation::get_sparql_stream::builders::GetSparqlStreamFluentBuilder
source · pub struct GetSparqlStreamFluentBuilder { /* private fields */ }
Expand description
Fluent builder constructing a request to GetSparqlStream
.
Gets a stream for an RDF graph.
With the Neptune Streams feature, you can generate a complete sequence of change-log entries that record every change made to your graph data as it happens. GetSparqlStream
lets you collect these change-log entries for an RDF graph.
The Neptune streams feature needs to be enabled on your Neptune DBcluster. To enable streams, set the neptune_streams DB cluster parameter to 1
.
See Capturing graph changes in real time using Neptune streams.
When invoking this operation in a Neptune cluster that has IAM authentication enabled, the IAM user or role making the request must have a policy attached that allows the neptune-db:GetStreamRecords IAM action in that cluster.
Note that the neptune-db:QueryLanguage:Sparql IAM condition key can be used in the policy document to restrict the use of SPARQL queries (see Condition keys available in Neptune IAM data-access policy statements).
Implementations§
source§impl GetSparqlStreamFluentBuilder
impl GetSparqlStreamFluentBuilder
sourcepub fn as_input(&self) -> &GetSparqlStreamInputBuilder
pub fn as_input(&self) -> &GetSparqlStreamInputBuilder
Access the GetSparqlStream as a reference.
sourcepub async fn send(
self
) -> Result<GetSparqlStreamOutput, SdkError<GetSparqlStreamError, HttpResponse>>
pub async fn send( self ) -> Result<GetSparqlStreamOutput, SdkError<GetSparqlStreamError, HttpResponse>>
Sends the request and returns the response.
If an error occurs, an SdkError
will be returned with additional details that
can be matched against.
By default, any retryable failures will be retried twice. Retry behavior is configurable with the RetryConfig, which can be set when configuring the client.
sourcepub fn customize(
self
) -> CustomizableOperation<GetSparqlStreamOutput, GetSparqlStreamError, Self>
pub fn customize( self ) -> CustomizableOperation<GetSparqlStreamOutput, GetSparqlStreamError, Self>
Consumes this builder, creating a customizable operation that can be modified before being sent.
sourcepub fn limit(self, input: i64) -> Self
pub fn limit(self, input: i64) -> Self
Specifies the maximum number of records to return. There is also a size limit of 10 MB on the response that can't be modified and that takes precedence over the number of records specified in the limit
parameter. The response does include a threshold-breaching record if the 10 MB limit was reached.
The range for limit
is 1 to 100,000, with a default of 10.
sourcepub fn set_limit(self, input: Option<i64>) -> Self
pub fn set_limit(self, input: Option<i64>) -> Self
Specifies the maximum number of records to return. There is also a size limit of 10 MB on the response that can't be modified and that takes precedence over the number of records specified in the limit
parameter. The response does include a threshold-breaching record if the 10 MB limit was reached.
The range for limit
is 1 to 100,000, with a default of 10.
sourcepub fn get_limit(&self) -> &Option<i64>
pub fn get_limit(&self) -> &Option<i64>
Specifies the maximum number of records to return. There is also a size limit of 10 MB on the response that can't be modified and that takes precedence over the number of records specified in the limit
parameter. The response does include a threshold-breaching record if the 10 MB limit was reached.
The range for limit
is 1 to 100,000, with a default of 10.
sourcepub fn iterator_type(self, input: IteratorType) -> Self
pub fn iterator_type(self, input: IteratorType) -> Self
Can be one of:
-
AT_SEQUENCE_NUMBER
– Indicates that reading should start from the event sequence number specified jointly by thecommitNum
andopNum
parameters. -
AFTER_SEQUENCE_NUMBER
– Indicates that reading should start right after the event sequence number specified jointly by thecommitNum
andopNum
parameters. -
TRIM_HORIZON
– Indicates that reading should start at the last untrimmed record in the system, which is the oldest unexpired (not yet deleted) record in the change-log stream. -
LATEST
– Indicates that reading should start at the most recent record in the system, which is the latest unexpired (not yet deleted) record in the change-log stream.
sourcepub fn set_iterator_type(self, input: Option<IteratorType>) -> Self
pub fn set_iterator_type(self, input: Option<IteratorType>) -> Self
Can be one of:
-
AT_SEQUENCE_NUMBER
– Indicates that reading should start from the event sequence number specified jointly by thecommitNum
andopNum
parameters. -
AFTER_SEQUENCE_NUMBER
– Indicates that reading should start right after the event sequence number specified jointly by thecommitNum
andopNum
parameters. -
TRIM_HORIZON
– Indicates that reading should start at the last untrimmed record in the system, which is the oldest unexpired (not yet deleted) record in the change-log stream. -
LATEST
– Indicates that reading should start at the most recent record in the system, which is the latest unexpired (not yet deleted) record in the change-log stream.
sourcepub fn get_iterator_type(&self) -> &Option<IteratorType>
pub fn get_iterator_type(&self) -> &Option<IteratorType>
Can be one of:
-
AT_SEQUENCE_NUMBER
– Indicates that reading should start from the event sequence number specified jointly by thecommitNum
andopNum
parameters. -
AFTER_SEQUENCE_NUMBER
– Indicates that reading should start right after the event sequence number specified jointly by thecommitNum
andopNum
parameters. -
TRIM_HORIZON
– Indicates that reading should start at the last untrimmed record in the system, which is the oldest unexpired (not yet deleted) record in the change-log stream. -
LATEST
– Indicates that reading should start at the most recent record in the system, which is the latest unexpired (not yet deleted) record in the change-log stream.
sourcepub fn commit_num(self, input: i64) -> Self
pub fn commit_num(self, input: i64) -> Self
The commit number of the starting record to read from the change-log stream. This parameter is required when iteratorType
isAT_SEQUENCE_NUMBER
or AFTER_SEQUENCE_NUMBER
, and ignored when iteratorType
is TRIM_HORIZON
or LATEST
.
sourcepub fn set_commit_num(self, input: Option<i64>) -> Self
pub fn set_commit_num(self, input: Option<i64>) -> Self
The commit number of the starting record to read from the change-log stream. This parameter is required when iteratorType
isAT_SEQUENCE_NUMBER
or AFTER_SEQUENCE_NUMBER
, and ignored when iteratorType
is TRIM_HORIZON
or LATEST
.
sourcepub fn get_commit_num(&self) -> &Option<i64>
pub fn get_commit_num(&self) -> &Option<i64>
The commit number of the starting record to read from the change-log stream. This parameter is required when iteratorType
isAT_SEQUENCE_NUMBER
or AFTER_SEQUENCE_NUMBER
, and ignored when iteratorType
is TRIM_HORIZON
or LATEST
.
sourcepub fn op_num(self, input: i64) -> Self
pub fn op_num(self, input: i64) -> Self
The operation sequence number within the specified commit to start reading from in the change-log stream data. The default is 1
.
sourcepub fn set_op_num(self, input: Option<i64>) -> Self
pub fn set_op_num(self, input: Option<i64>) -> Self
The operation sequence number within the specified commit to start reading from in the change-log stream data. The default is 1
.
sourcepub fn get_op_num(&self) -> &Option<i64>
pub fn get_op_num(&self) -> &Option<i64>
The operation sequence number within the specified commit to start reading from in the change-log stream data. The default is 1
.
sourcepub fn encoding(self, input: Encoding) -> Self
pub fn encoding(self, input: Encoding) -> Self
If set to TRUE, Neptune compresses the response using gzip encoding.
sourcepub fn set_encoding(self, input: Option<Encoding>) -> Self
pub fn set_encoding(self, input: Option<Encoding>) -> Self
If set to TRUE, Neptune compresses the response using gzip encoding.
sourcepub fn get_encoding(&self) -> &Option<Encoding>
pub fn get_encoding(&self) -> &Option<Encoding>
If set to TRUE, Neptune compresses the response using gzip encoding.
Trait Implementations§
source§impl Clone for GetSparqlStreamFluentBuilder
impl Clone for GetSparqlStreamFluentBuilder
source§fn clone(&self) -> GetSparqlStreamFluentBuilder
fn clone(&self) -> GetSparqlStreamFluentBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl Freeze for GetSparqlStreamFluentBuilder
impl !RefUnwindSafe for GetSparqlStreamFluentBuilder
impl Send for GetSparqlStreamFluentBuilder
impl Sync for GetSparqlStreamFluentBuilder
impl Unpin for GetSparqlStreamFluentBuilder
impl !UnwindSafe for GetSparqlStreamFluentBuilder
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
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>
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>
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 more