1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598
|
// Code generated by smithy-go-codegen DO NOT EDIT.
package types
import (
smithydocument "github.com/aws/smithy-go/document"
"time"
)
// Contains the metadata for query results such as the column names, data types,
// and other attributes.
type ColumnInfo struct {
// The data type of the result set column. The data type can be a scalar or
// complex. Scalar data types are integers, strings, doubles, Booleans, and others.
// Complex data types are types such as arrays, rows, and others.
//
// This member is required.
Type *Type
// The name of the result set column. The name of the result set is available for
// columns of all data types except for arrays.
Name *string
noSmithyDocumentSerde
}
// Datum represents a single data point in a query result.
type Datum struct {
// Indicates if the data point is an array.
ArrayValue []Datum
// Indicates if the data point is null.
NullValue *bool
// Indicates if the data point is a row.
RowValue *Row
// Indicates if the data point is a scalar value such as integer, string, double,
// or Boolean.
ScalarValue *string
// Indicates if the data point is a timeseries data type.
TimeSeriesValue []TimeSeriesDataPoint
noSmithyDocumentSerde
}
// This type is used to map column(s) from the query result to a dimension in the
// destination table.
type DimensionMapping struct {
// Type for the dimension.
//
// This member is required.
DimensionValueType DimensionValueType
// Column name from query result.
//
// This member is required.
Name *string
noSmithyDocumentSerde
}
// Represents an available endpoint against which to make API calls against, as
// well as the TTL for that endpoint.
type Endpoint struct {
// An endpoint address.
//
// This member is required.
Address *string
// The TTL for the endpoint, in minutes.
//
// This member is required.
CachePeriodInMinutes int64
noSmithyDocumentSerde
}
// Configuration required for error reporting.
type ErrorReportConfiguration struct {
// The S3 configuration for the error reports.
//
// This member is required.
S3Configuration *S3Configuration
noSmithyDocumentSerde
}
// This contains the location of the error report for a single scheduled query
// call.
type ErrorReportLocation struct {
// The S3 location where error reports are written.
S3ReportLocation *S3ReportLocation
noSmithyDocumentSerde
}
// Statistics for a single scheduled query run.
type ExecutionStats struct {
// Bytes metered for a single scheduled query run.
BytesMetered int64
// Data writes metered for records ingested in a single scheduled query run.
DataWrites int64
// Total time, measured in milliseconds, that was needed for the scheduled query
// run to complete.
ExecutionTimeInMillis int64
// Number of rows present in the output from running a query before ingestion to
// destination data source.
QueryResultRows int64
// The number of records ingested for a single scheduled query run.
RecordsIngested int64
noSmithyDocumentSerde
}
// MixedMeasureMappings are mappings that can be used to ingest data into a
// mixture of narrow and multi measures in the derived table.
type MixedMeasureMapping struct {
// Type of the value that is to be read from sourceColumn. If the mapping is for
// MULTI, use MeasureValueType.MULTI.
//
// This member is required.
MeasureValueType MeasureValueType
// Refers to the value of measure_name in a result row. This field is required if
// MeasureNameColumn is provided.
MeasureName *string
// Required when measureValueType is MULTI. Attribute mappings for MULTI value
// measures.
MultiMeasureAttributeMappings []MultiMeasureAttributeMapping
// This field refers to the source column from which measure-value is to be read
// for result materialization.
SourceColumn *string
// Target measure name to be used. If not provided, the target measure name by
// default would be measure-name if provided, or sourceColumn otherwise.
TargetMeasureName *string
noSmithyDocumentSerde
}
// Attribute mapping for MULTI value measures.
type MultiMeasureAttributeMapping struct {
// Type of the attribute to be read from the source column.
//
// This member is required.
MeasureValueType ScalarMeasureValueType
// Source column from where the attribute value is to be read.
//
// This member is required.
SourceColumn *string
// Custom name to be used for attribute name in derived table. If not provided,
// source column name would be used.
TargetMultiMeasureAttributeName *string
noSmithyDocumentSerde
}
// Only one of MixedMeasureMappings or MultiMeasureMappings is to be provided.
// MultiMeasureMappings can be used to ingest data as multi measures in the derived
// table.
type MultiMeasureMappings struct {
// Required. Attribute mappings to be used for mapping query results to ingest
// data for multi-measure attributes.
//
// This member is required.
MultiMeasureAttributeMappings []MultiMeasureAttributeMapping
// The name of the target multi-measure name in the derived table. This input is
// required when measureNameColumn is not provided. If MeasureNameColumn is
// provided, then value from that column will be used as multi-measure name.
TargetMultiMeasureName *string
noSmithyDocumentSerde
}
// Notification configuration for a scheduled query. A notification is sent by
// Timestream when a scheduled query is created, its state is updated or when it is
// deleted.
type NotificationConfiguration struct {
// Details on SNS configuration.
//
// This member is required.
SnsConfiguration *SnsConfiguration
noSmithyDocumentSerde
}
// Mapping for named parameters.
type ParameterMapping struct {
// Parameter name.
//
// This member is required.
Name *string
// Contains the data type of a column in a query result set. The data type can be
// scalar or complex. The supported scalar data types are integers, Boolean,
// string, double, timestamp, date, time, and intervals. The supported complex data
// types are arrays, rows, and timeseries.
//
// This member is required.
Type *Type
noSmithyDocumentSerde
}
// Information about the status of the query, including progress and bytes scanned.
type QueryStatus struct {
// The amount of data scanned by the query in bytes that you will be charged for.
// This is a cumulative sum and represents the total amount of data that you will
// be charged for since the query was started. The charge is applied only once and
// is either applied when the query completes running or when the query is
// cancelled.
CumulativeBytesMetered int64
// The amount of data scanned by the query in bytes. This is a cumulative sum and
// represents the total amount of bytes scanned since the query was started.
CumulativeBytesScanned int64
// The progress of the query, expressed as a percentage.
ProgressPercentage float64
noSmithyDocumentSerde
}
// Represents a single row in the query results.
type Row struct {
// List of data points in a single row of the result set.
//
// This member is required.
Data []Datum
noSmithyDocumentSerde
}
// Details on S3 location for error reports that result from running a query.
type S3Configuration struct {
// Name of the S3 bucket under which error reports will be created.
//
// This member is required.
BucketName *string
// Encryption at rest options for the error reports. If no encryption option is
// specified, Timestream will choose SSE_S3 as default.
EncryptionOption S3EncryptionOption
// Prefix for the error report key. Timestream by default adds the following
// prefix to the error report path.
ObjectKeyPrefix *string
noSmithyDocumentSerde
}
// S3 report location for the scheduled query run.
type S3ReportLocation struct {
// S3 bucket name.
BucketName *string
// S3 key.
ObjectKey *string
noSmithyDocumentSerde
}
// Configuration of the schedule of the query.
type ScheduleConfiguration struct {
// An expression that denotes when to trigger the scheduled query run. This can be
// a cron expression or a rate expression.
//
// This member is required.
ScheduleExpression *string
noSmithyDocumentSerde
}
// Scheduled Query
type ScheduledQuery struct {
// The Amazon Resource Name.
//
// This member is required.
Arn *string
// The name of the scheduled query.
//
// This member is required.
Name *string
// State of scheduled query.
//
// This member is required.
State ScheduledQueryState
// The creation time of the scheduled query.
CreationTime *time.Time
// Configuration for scheduled query error reporting.
ErrorReportConfiguration *ErrorReportConfiguration
// Status of the last scheduled query run.
LastRunStatus ScheduledQueryRunStatus
// The next time the scheduled query is to be run.
NextInvocationTime *time.Time
// The last time the scheduled query was run.
PreviousInvocationTime *time.Time
// Target data source where final scheduled query result will be written.
TargetDestination *TargetDestination
noSmithyDocumentSerde
}
// Structure that describes scheduled query.
type ScheduledQueryDescription struct {
// Scheduled query ARN.
//
// This member is required.
Arn *string
// Name of the scheduled query.
//
// This member is required.
Name *string
// Notification configuration.
//
// This member is required.
NotificationConfiguration *NotificationConfiguration
// The query to be run.
//
// This member is required.
QueryString *string
// Schedule configuration.
//
// This member is required.
ScheduleConfiguration *ScheduleConfiguration
// State of the scheduled query.
//
// This member is required.
State ScheduledQueryState
// Creation time of the scheduled query.
CreationTime *time.Time
// Error-reporting configuration for the scheduled query.
ErrorReportConfiguration *ErrorReportConfiguration
// A customer provided KMS key used to encrypt the scheduled query resource.
KmsKeyId *string
// Runtime summary for the last scheduled query run.
LastRunSummary *ScheduledQueryRunSummary
// The next time the scheduled query is scheduled to run.
NextInvocationTime *time.Time
// Last time the query was run.
PreviousInvocationTime *time.Time
// Runtime summary for the last five failed scheduled query runs.
RecentlyFailedRuns []ScheduledQueryRunSummary
// IAM role that Timestream uses to run the schedule query.
ScheduledQueryExecutionRoleArn *string
// Scheduled query target store configuration.
TargetConfiguration *TargetConfiguration
noSmithyDocumentSerde
}
// Run summary for the scheduled query
type ScheduledQueryRunSummary struct {
// S3 location for error report.
ErrorReportLocation *ErrorReportLocation
// Runtime statistics for a scheduled run.
ExecutionStats *ExecutionStats
// Error message for the scheduled query in case of failure. You might have to
// look at the error report to get more detailed error reasons.
FailureReason *string
// InvocationTime for this run. This is the time at which the query is scheduled
// to run. Parameter @scheduled_runtime can be used in the query to get the value.
InvocationTime *time.Time
// The status of a scheduled query run.
RunStatus ScheduledQueryRunStatus
// The actual time when the query was run.
TriggerTime *time.Time
noSmithyDocumentSerde
}
// Details of the column that is returned by the query.
type SelectColumn struct {
// True, if the column name was aliased by the query. False otherwise.
Aliased *bool
// Database that has this column.
DatabaseName *string
// Name of the column.
Name *string
// Table within the database that has this column.
TableName *string
// Contains the data type of a column in a query result set. The data type can be
// scalar or complex. The supported scalar data types are integers, Boolean,
// string, double, timestamp, date, time, and intervals. The supported complex data
// types are arrays, rows, and timeseries.
Type *Type
noSmithyDocumentSerde
}
// Details on SNS that are required to send the notification.
type SnsConfiguration struct {
// SNS topic ARN that the scheduled query status notifications will be sent to.
//
// This member is required.
TopicArn *string
noSmithyDocumentSerde
}
// A tag is a label that you assign to a Timestream database and/or table. Each
// tag consists of a key and an optional value, both of which you define. Tags
// enable you to categorize databases and/or tables, for example, by purpose,
// owner, or environment.
type Tag struct {
// The key of the tag. Tag keys are case sensitive.
//
// This member is required.
Key *string
// The value of the tag. Tag values are case sensitive and can be null.
//
// This member is required.
Value *string
noSmithyDocumentSerde
}
// Configuration used for writing the output of a query.
type TargetConfiguration struct {
// Configuration needed to write data into the Timestream database and table.
//
// This member is required.
TimestreamConfiguration *TimestreamConfiguration
noSmithyDocumentSerde
}
// Destination details to write data for a target data source. Current supported
// data source is Timestream.
type TargetDestination struct {
// Query result destination details for Timestream data source.
TimestreamDestination *TimestreamDestination
noSmithyDocumentSerde
}
// The timeseries data type represents the values of a measure over time. A time
// series is an array of rows of timestamps and measure values, with rows sorted in
// ascending order of time. A TimeSeriesDataPoint is a single data point in the
// time series. It represents a tuple of (time, measure value) in a time series.
type TimeSeriesDataPoint struct {
// The timestamp when the measure value was collected.
//
// This member is required.
Time *string
// The measure value for the data point.
//
// This member is required.
Value *Datum
noSmithyDocumentSerde
}
// Configuration to write data into Timestream database and table. This
// configuration allows the user to map the query result select columns into the
// destination table columns.
type TimestreamConfiguration struct {
// Name of Timestream database to which the query result will be written.
//
// This member is required.
DatabaseName *string
// This is to allow mapping column(s) from the query result to the dimension in
// the destination table.
//
// This member is required.
DimensionMappings []DimensionMapping
// Name of Timestream table that the query result will be written to. The table
// should be within the same database that is provided in Timestream configuration.
//
// This member is required.
TableName *string
// Column from query result that should be used as the time column in destination
// table. Column type for this should be TIMESTAMP.
//
// This member is required.
TimeColumn *string
// Name of the measure column.
MeasureNameColumn *string
// Specifies how to map measures to multi-measure records.
MixedMeasureMappings []MixedMeasureMapping
// Multi-measure mappings.
MultiMeasureMappings *MultiMeasureMappings
noSmithyDocumentSerde
}
// Destination for scheduled query.
type TimestreamDestination struct {
// Timestream database name.
DatabaseName *string
// Timestream table name.
TableName *string
noSmithyDocumentSerde
}
// Contains the data type of a column in a query result set. The data type can be
// scalar or complex. The supported scalar data types are integers, Boolean,
// string, double, timestamp, date, time, and intervals. The supported complex data
// types are arrays, rows, and timeseries.
type Type struct {
// Indicates if the column is an array.
ArrayColumnInfo *ColumnInfo
// Indicates if the column is a row.
RowColumnInfo []ColumnInfo
// Indicates if the column is of type string, integer, Boolean, double, timestamp,
// date, time.
ScalarType ScalarType
// Indicates if the column is a timeseries data type.
TimeSeriesMeasureValueColumnInfo *ColumnInfo
noSmithyDocumentSerde
}
type noSmithyDocumentSerde = smithydocument.NoSerde
|