#[non_exhaustive]pub struct CreateKxChangesetInput {
pub environment_id: Option<String>,
pub database_name: Option<String>,
pub change_requests: Option<Vec<ChangeRequest>>,
pub client_token: Option<String>,
}Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.environment_id: Option<String>A unique identifier of the kdb environment.
database_name: Option<String>The name of the kdb database.
change_requests: Option<Vec<ChangeRequest>>A list of change request objects that are run in order. A change request object consists of changeType , s3Path, and dbPath. A changeType can have the following values:
-
PUT – Adds or updates files in a database.
-
DELETE – Deletes files in a database.
All the change requests require a mandatory dbPath attribute that defines the path within the database directory. All database paths must start with a leading / and end with a trailing /. The s3Path attribute defines the s3 source file path and is required for a PUT change type. The s3path must end with a trailing / if it is a directory and must end without a trailing / if it is a file.
Here are few examples of how you can use the change request object:
-
This request adds a single sym file at database root location.
{ "changeType": "PUT", "s3Path":"s3://bucket/db/sym", "dbPath":"/"} -
This request adds files in the given
s3Pathunder the 2020.01.02 partition of the database.{ "changeType": "PUT", "s3Path":"s3://bucket/db/2020.01.02/", "dbPath":"/2020.01.02/"} -
This request adds files in the given
s3Pathunder the taq table partition of the database.[ { "changeType": "PUT", "s3Path":"s3://bucket/db/2020.01.02/taq/", "dbPath":"/2020.01.02/taq/"}] -
This request deletes the 2020.01.02 partition of the database.
[{ "changeType": "DELETE", "dbPath": "/2020.01.02/"} ] -
The DELETE request allows you to delete the existing files under the 2020.01.02 partition of the database, and the PUT request adds a new taq table under it.
[ {"changeType": "DELETE", "dbPath":"/2020.01.02/"}, {"changeType": "PUT", "s3Path":"s3://bucket/db/2020.01.02/taq/", "dbPath":"/2020.01.02/taq/"}]
client_token: Option<String>A token that ensures idempotency. This token expires in 10 minutes.
Implementations§
source§impl CreateKxChangesetInput
impl CreateKxChangesetInput
sourcepub fn environment_id(&self) -> Option<&str>
pub fn environment_id(&self) -> Option<&str>
A unique identifier of the kdb environment.
sourcepub fn database_name(&self) -> Option<&str>
pub fn database_name(&self) -> Option<&str>
The name of the kdb database.
sourcepub fn change_requests(&self) -> &[ChangeRequest]
pub fn change_requests(&self) -> &[ChangeRequest]
A list of change request objects that are run in order. A change request object consists of changeType , s3Path, and dbPath. A changeType can have the following values:
-
PUT – Adds or updates files in a database.
-
DELETE – Deletes files in a database.
All the change requests require a mandatory dbPath attribute that defines the path within the database directory. All database paths must start with a leading / and end with a trailing /. The s3Path attribute defines the s3 source file path and is required for a PUT change type. The s3path must end with a trailing / if it is a directory and must end without a trailing / if it is a file.
Here are few examples of how you can use the change request object:
-
This request adds a single sym file at database root location.
{ "changeType": "PUT", "s3Path":"s3://bucket/db/sym", "dbPath":"/"} -
This request adds files in the given
s3Pathunder the 2020.01.02 partition of the database.{ "changeType": "PUT", "s3Path":"s3://bucket/db/2020.01.02/", "dbPath":"/2020.01.02/"} -
This request adds files in the given
s3Pathunder the taq table partition of the database.[ { "changeType": "PUT", "s3Path":"s3://bucket/db/2020.01.02/taq/", "dbPath":"/2020.01.02/taq/"}] -
This request deletes the 2020.01.02 partition of the database.
[{ "changeType": "DELETE", "dbPath": "/2020.01.02/"} ] -
The DELETE request allows you to delete the existing files under the 2020.01.02 partition of the database, and the PUT request adds a new taq table under it.
[ {"changeType": "DELETE", "dbPath":"/2020.01.02/"}, {"changeType": "PUT", "s3Path":"s3://bucket/db/2020.01.02/taq/", "dbPath":"/2020.01.02/taq/"}]
If no value was sent for this field, a default will be set. If you want to determine if no value was sent, use .change_requests.is_none().
sourcepub fn client_token(&self) -> Option<&str>
pub fn client_token(&self) -> Option<&str>
A token that ensures idempotency. This token expires in 10 minutes.
source§impl CreateKxChangesetInput
impl CreateKxChangesetInput
sourcepub fn builder() -> CreateKxChangesetInputBuilder
pub fn builder() -> CreateKxChangesetInputBuilder
Creates a new builder-style object to manufacture CreateKxChangesetInput.
Trait Implementations§
source§impl Clone for CreateKxChangesetInput
impl Clone for CreateKxChangesetInput
source§fn clone(&self) -> CreateKxChangesetInput
fn clone(&self) -> CreateKxChangesetInput
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moresource§impl Debug for CreateKxChangesetInput
impl Debug for CreateKxChangesetInput
source§impl PartialEq for CreateKxChangesetInput
impl PartialEq for CreateKxChangesetInput
source§fn eq(&self, other: &CreateKxChangesetInput) -> bool
fn eq(&self, other: &CreateKxChangesetInput) -> bool
self and other values to be equal, and is used
by ==.impl StructuralPartialEq for CreateKxChangesetInput
Auto Trait Implementations§
impl Freeze for CreateKxChangesetInput
impl RefUnwindSafe for CreateKxChangesetInput
impl Send for CreateKxChangesetInput
impl Sync for CreateKxChangesetInput
impl Unpin for CreateKxChangesetInput
impl UnwindSafe for CreateKxChangesetInput
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