func DimensionValueType_Values() []string
DimensionValueType_Values returns all elements of the DimensionValueType enum
func MeasureValueType_Values() []string
MeasureValueType_Values returns all elements of the MeasureValueType enum
func S3EncryptionOption_Values() []string
S3EncryptionOption_Values returns all elements of the S3EncryptionOption enum
func ScalarMeasureValueType_Values() []string
ScalarMeasureValueType_Values returns all elements of the ScalarMeasureValueType enum
func ScalarType_Values() []string
ScalarType_Values returns all elements of the ScalarType enum
func ScheduledQueryRunStatus_Values() []string
ScheduledQueryRunStatus_Values returns all elements of the ScheduledQueryRunStatus enum
func ScheduledQueryState_Values() []string
ScheduledQueryState_Values returns all elements of the ScheduledQueryState enum
type AccessDeniedException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
You are not authorized to perform this action.
func (s *AccessDeniedException) Code() string
Code returns the exception type name.
func (s *AccessDeniedException) Error() string
func (s AccessDeniedException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *AccessDeniedException) Message() string
Message returns the exception's message.
func (s *AccessDeniedException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *AccessDeniedException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *AccessDeniedException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s AccessDeniedException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CancelQueryInput struct {
// The ID of the query that needs to be cancelled. QueryID is returned as part
// of the query result.
//
// QueryId is a required field
QueryId *string `min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s CancelQueryInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CancelQueryInput) SetQueryId(v string) *CancelQueryInput
SetQueryId sets the QueryId field's value.
func (s CancelQueryInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CancelQueryInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CancelQueryOutput struct {
// A CancellationMessage is returned when a CancelQuery request for the query
// specified by QueryId has already been issued.
CancellationMessage *string `type:"string"`
// contains filtered or unexported fields
}
func (s CancelQueryOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CancelQueryOutput) SetCancellationMessage(v string) *CancelQueryOutput
SetCancellationMessage sets the CancellationMessage field's value.
func (s CancelQueryOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ColumnInfo struct {
// 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 `type:"string"`
// 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.
//
// Type is a required field
Type *Type `type:"structure" required:"true"`
// contains filtered or unexported fields
}
Contains the metadata for query results such as the column names, data types, and other attributes.
func (s ColumnInfo) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ColumnInfo) SetName(v string) *ColumnInfo
SetName sets the Name field's value.
func (s *ColumnInfo) SetType(v *Type) *ColumnInfo
SetType sets the Type field's value.
func (s ColumnInfo) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ConflictException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
Unable to poll results for a cancelled query.
func (s *ConflictException) Code() string
Code returns the exception type name.
func (s *ConflictException) Error() string
func (s ConflictException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ConflictException) Message() string
Message returns the exception's message.
func (s *ConflictException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ConflictException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ConflictException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ConflictException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type CreateScheduledQueryInput struct {
// Using a ClientToken makes the call to CreateScheduledQuery idempotent, in
// other words, making the same request repeatedly will produce the same result.
// Making multiple identical CreateScheduledQuery requests has the same effect
// as making a single request.
//
// * If CreateScheduledQuery is called without a ClientToken, the Query SDK
// generates a ClientToken on your behalf.
//
// * After 8 hours, any request with the same ClientToken is treated as a
// new request.
//
// ClientToken is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by CreateScheduledQueryInput's
// String and GoString methods.
ClientToken *string `min:"32" type:"string" idempotencyToken:"true" sensitive:"true"`
// Configuration for error reporting. Error reports will be generated when a
// problem is encountered when writing the query results.
//
// ErrorReportConfiguration is a required field
ErrorReportConfiguration *ErrorReportConfiguration `type:"structure" required:"true"`
// The Amazon KMS key used to encrypt the scheduled query resource, at-rest.
// If the Amazon KMS key is not specified, the scheduled query resource will
// be encrypted with a Timestream owned Amazon KMS key. To specify a KMS key,
// use the key ID, key ARN, alias name, or alias ARN. When using an alias name,
// prefix the name with alias/
//
// If ErrorReportConfiguration uses SSE_KMS as encryption type, the same KmsKeyId
// is used to encrypt the error report at rest.
KmsKeyId *string `min:"1" type:"string"`
// Name of the scheduled query.
//
// Name is a required field
Name *string `min:"1" type:"string" required:"true"`
// Notification configuration for the scheduled query. A notification is sent
// by Timestream when a query run finishes, when the state is updated or when
// you delete it.
//
// NotificationConfiguration is a required field
NotificationConfiguration *NotificationConfiguration `type:"structure" required:"true"`
// The query string to run. Parameter names can be specified in the query string
// @ character followed by an identifier. The named Parameter @scheduled_runtime
// is reserved and can be used in the query to get the time at which the query
// is scheduled to run.
//
// The timestamp calculated according to the ScheduleConfiguration parameter,
// will be the value of @scheduled_runtime paramater for each query run. For
// example, consider an instance of a scheduled query executing on 2021-12-01
// 00:00:00. For this instance, the @scheduled_runtime parameter is initialized
// to the timestamp 2021-12-01 00:00:00 when invoking the query.
//
// QueryString is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by CreateScheduledQueryInput's
// String and GoString methods.
//
// QueryString is a required field
QueryString *string `min:"1" type:"string" required:"true" sensitive:"true"`
// The schedule configuration for the query.
//
// ScheduleConfiguration is a required field
ScheduleConfiguration *ScheduleConfiguration `type:"structure" required:"true"`
// The ARN for the IAM role that Timestream will assume when running the scheduled
// query.
//
// ScheduledQueryExecutionRoleArn is a required field
ScheduledQueryExecutionRoleArn *string `min:"1" type:"string" required:"true"`
// A list of key-value pairs to label the scheduled query.
Tags []*Tag `type:"list"`
// Configuration used for writing the result of a query.
TargetConfiguration *TargetConfiguration `type:"structure"`
// contains filtered or unexported fields
}
func (s CreateScheduledQueryInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateScheduledQueryInput) SetClientToken(v string) *CreateScheduledQueryInput
SetClientToken sets the ClientToken field's value.
func (s *CreateScheduledQueryInput) SetErrorReportConfiguration(v *ErrorReportConfiguration) *CreateScheduledQueryInput
SetErrorReportConfiguration sets the ErrorReportConfiguration field's value.
func (s *CreateScheduledQueryInput) SetKmsKeyId(v string) *CreateScheduledQueryInput
SetKmsKeyId sets the KmsKeyId field's value.
func (s *CreateScheduledQueryInput) SetName(v string) *CreateScheduledQueryInput
SetName sets the Name field's value.
func (s *CreateScheduledQueryInput) SetNotificationConfiguration(v *NotificationConfiguration) *CreateScheduledQueryInput
SetNotificationConfiguration sets the NotificationConfiguration field's value.
func (s *CreateScheduledQueryInput) SetQueryString(v string) *CreateScheduledQueryInput
SetQueryString sets the QueryString field's value.
func (s *CreateScheduledQueryInput) SetScheduleConfiguration(v *ScheduleConfiguration) *CreateScheduledQueryInput
SetScheduleConfiguration sets the ScheduleConfiguration field's value.
func (s *CreateScheduledQueryInput) SetScheduledQueryExecutionRoleArn(v string) *CreateScheduledQueryInput
SetScheduledQueryExecutionRoleArn sets the ScheduledQueryExecutionRoleArn field's value.
func (s *CreateScheduledQueryInput) SetTags(v []*Tag) *CreateScheduledQueryInput
SetTags sets the Tags field's value.
func (s *CreateScheduledQueryInput) SetTargetConfiguration(v *TargetConfiguration) *CreateScheduledQueryInput
SetTargetConfiguration sets the TargetConfiguration field's value.
func (s CreateScheduledQueryInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateScheduledQueryInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateScheduledQueryOutput struct {
// ARN for the created scheduled query.
//
// Arn is a required field
Arn *string `min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s CreateScheduledQueryOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *CreateScheduledQueryOutput) SetArn(v string) *CreateScheduledQueryOutput
SetArn sets the Arn field's value.
func (s CreateScheduledQueryOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type Datum struct {
// Indicates if the data point is an array.
ArrayValue []*Datum `type:"list"`
// Indicates if the data point is null.
NullValue *bool `type:"boolean"`
// Indicates if the data point is a row.
RowValue *Row `type:"structure"`
// Indicates if the data point is a scalar value such as integer, string, double,
// or Boolean.
ScalarValue *string `type:"string"`
// Indicates if the data point is a timeseries data type.
TimeSeriesValue []*TimeSeriesDataPoint `type:"list"`
// contains filtered or unexported fields
}
Datum represents a single data point in a query result.
func (s Datum) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Datum) SetArrayValue(v []*Datum) *Datum
SetArrayValue sets the ArrayValue field's value.
func (s *Datum) SetNullValue(v bool) *Datum
SetNullValue sets the NullValue field's value.
func (s *Datum) SetRowValue(v *Row) *Datum
SetRowValue sets the RowValue field's value.
func (s *Datum) SetScalarValue(v string) *Datum
SetScalarValue sets the ScalarValue field's value.
func (s *Datum) SetTimeSeriesValue(v []*TimeSeriesDataPoint) *Datum
SetTimeSeriesValue sets the TimeSeriesValue field's value.
func (s Datum) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DeleteScheduledQueryInput struct {
// The ARN of the scheduled query.
//
// ScheduledQueryArn is a required field
ScheduledQueryArn *string `min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s DeleteScheduledQueryInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteScheduledQueryInput) SetScheduledQueryArn(v string) *DeleteScheduledQueryInput
SetScheduledQueryArn sets the ScheduledQueryArn field's value.
func (s DeleteScheduledQueryInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DeleteScheduledQueryInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteScheduledQueryOutput struct {
// contains filtered or unexported fields
}
func (s DeleteScheduledQueryOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s DeleteScheduledQueryOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DescribeEndpointsInput struct {
// contains filtered or unexported fields
}
func (s DescribeEndpointsInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s DescribeEndpointsInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DescribeEndpointsOutput struct {
// An Endpoints object is returned when a DescribeEndpoints request is made.
//
// Endpoints is a required field
Endpoints []*Endpoint `type:"list" required:"true"`
// contains filtered or unexported fields
}
func (s DescribeEndpointsOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeEndpointsOutput) SetEndpoints(v []*Endpoint) *DescribeEndpointsOutput
SetEndpoints sets the Endpoints field's value.
func (s DescribeEndpointsOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DescribeScheduledQueryInput struct {
// The ARN of the scheduled query.
//
// ScheduledQueryArn is a required field
ScheduledQueryArn *string `min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s DescribeScheduledQueryInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeScheduledQueryInput) SetScheduledQueryArn(v string) *DescribeScheduledQueryInput
SetScheduledQueryArn sets the ScheduledQueryArn field's value.
func (s DescribeScheduledQueryInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeScheduledQueryInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeScheduledQueryOutput struct {
// The scheduled query.
//
// ScheduledQuery is a required field
ScheduledQuery *ScheduledQueryDescription `type:"structure" required:"true"`
// contains filtered or unexported fields
}
func (s DescribeScheduledQueryOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DescribeScheduledQueryOutput) SetScheduledQuery(v *ScheduledQueryDescription) *DescribeScheduledQueryOutput
SetScheduledQuery sets the ScheduledQuery field's value.
func (s DescribeScheduledQueryOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type DimensionMapping struct {
// Type for the dimension.
//
// DimensionValueType is a required field
DimensionValueType *string `type:"string" required:"true" enum:"DimensionValueType"`
// Column name from query result.
//
// Name is a required field
Name *string `type:"string" required:"true"`
// contains filtered or unexported fields
}
This type is used to map column(s) from the query result to a dimension in the destination table.
func (s DimensionMapping) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DimensionMapping) SetDimensionValueType(v string) *DimensionMapping
SetDimensionValueType sets the DimensionValueType field's value.
func (s *DimensionMapping) SetName(v string) *DimensionMapping
SetName sets the Name field's value.
func (s DimensionMapping) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *DimensionMapping) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type Endpoint struct {
// An endpoint address.
//
// Address is a required field
Address *string `type:"string" required:"true"`
// The TTL for the endpoint, in minutes.
//
// CachePeriodInMinutes is a required field
CachePeriodInMinutes *int64 `type:"long" required:"true"`
// contains filtered or unexported fields
}
Represents an available endpoint against which to make API calls against, as well as the TTL for that endpoint.
func (s Endpoint) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Endpoint) SetAddress(v string) *Endpoint
SetAddress sets the Address field's value.
func (s *Endpoint) SetCachePeriodInMinutes(v int64) *Endpoint
SetCachePeriodInMinutes sets the CachePeriodInMinutes field's value.
func (s Endpoint) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ErrorReportConfiguration struct {
// The S3 configuration for the error reports.
//
// S3Configuration is a required field
S3Configuration *S3Configuration `type:"structure" required:"true"`
// contains filtered or unexported fields
}
Configuration required for error reporting.
func (s ErrorReportConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ErrorReportConfiguration) SetS3Configuration(v *S3Configuration) *ErrorReportConfiguration
SetS3Configuration sets the S3Configuration field's value.
func (s ErrorReportConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ErrorReportConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ErrorReportLocation struct {
// The S3 location where error reports are written.
S3ReportLocation *S3ReportLocation `type:"structure"`
// contains filtered or unexported fields
}
This contains the location of the error report for a single scheduled query call.
func (s ErrorReportLocation) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ErrorReportLocation) SetS3ReportLocation(v *S3ReportLocation) *ErrorReportLocation
SetS3ReportLocation sets the S3ReportLocation field's value.
func (s ErrorReportLocation) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ExecuteScheduledQueryInput struct {
// Not used.
//
// ClientToken is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by ExecuteScheduledQueryInput's
// String and GoString methods.
ClientToken *string `min:"32" type:"string" idempotencyToken:"true" sensitive:"true"`
// The timestamp in UTC. Query will be run as if it was invoked at this timestamp.
//
// InvocationTime is a required field
InvocationTime *time.Time `type:"timestamp" required:"true"`
// ARN of the scheduled query.
//
// ScheduledQueryArn is a required field
ScheduledQueryArn *string `min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s ExecuteScheduledQueryInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ExecuteScheduledQueryInput) SetClientToken(v string) *ExecuteScheduledQueryInput
SetClientToken sets the ClientToken field's value.
func (s *ExecuteScheduledQueryInput) SetInvocationTime(v time.Time) *ExecuteScheduledQueryInput
SetInvocationTime sets the InvocationTime field's value.
func (s *ExecuteScheduledQueryInput) SetScheduledQueryArn(v string) *ExecuteScheduledQueryInput
SetScheduledQueryArn sets the ScheduledQueryArn field's value.
func (s ExecuteScheduledQueryInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ExecuteScheduledQueryInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ExecuteScheduledQueryOutput struct {
// contains filtered or unexported fields
}
func (s ExecuteScheduledQueryOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s ExecuteScheduledQueryOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ExecutionStats struct {
// Bytes metered for a single scheduled query run.
BytesMetered *int64 `type:"long"`
// Data writes metered for records ingested in a single scheduled query run.
DataWrites *int64 `type:"long"`
// Total time, measured in milliseconds, that was needed for the scheduled query
// run to complete.
ExecutionTimeInMillis *int64 `type:"long"`
// Number of rows present in the output from running a query before ingestion
// to destination data source.
QueryResultRows *int64 `type:"long"`
// The number of records ingested for a single scheduled query run.
RecordsIngested *int64 `type:"long"`
// contains filtered or unexported fields
}
Statistics for a single scheduled query run.
func (s ExecutionStats) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ExecutionStats) SetBytesMetered(v int64) *ExecutionStats
SetBytesMetered sets the BytesMetered field's value.
func (s *ExecutionStats) SetDataWrites(v int64) *ExecutionStats
SetDataWrites sets the DataWrites field's value.
func (s *ExecutionStats) SetExecutionTimeInMillis(v int64) *ExecutionStats
SetExecutionTimeInMillis sets the ExecutionTimeInMillis field's value.
func (s *ExecutionStats) SetQueryResultRows(v int64) *ExecutionStats
SetQueryResultRows sets the QueryResultRows field's value.
func (s *ExecutionStats) SetRecordsIngested(v int64) *ExecutionStats
SetRecordsIngested sets the RecordsIngested field's value.
func (s ExecutionStats) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type InternalServerException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
Timestream was unable to fully process this request because of an internal server error.
func (s *InternalServerException) Code() string
Code returns the exception type name.
func (s *InternalServerException) Error() string
func (s InternalServerException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *InternalServerException) Message() string
Message returns the exception's message.
func (s *InternalServerException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *InternalServerException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *InternalServerException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s InternalServerException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type InvalidEndpointException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
The requested endpoint was not valid.
func (s *InvalidEndpointException) Code() string
Code returns the exception type name.
func (s *InvalidEndpointException) Error() string
func (s InvalidEndpointException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *InvalidEndpointException) Message() string
Message returns the exception's message.
func (s *InvalidEndpointException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *InvalidEndpointException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *InvalidEndpointException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s InvalidEndpointException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListScheduledQueriesInput struct {
// The maximum number of items to return in the output. If the total number
// of items available is more than the value specified, a NextToken is provided
// in the output. To resume pagination, provide the NextToken value as the argument
// to the subsequent call to ListScheduledQueriesRequest.
MaxResults *int64 `min:"1" type:"integer"`
// A pagination token to resume pagination.
NextToken *string `type:"string"`
// contains filtered or unexported fields
}
func (s ListScheduledQueriesInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListScheduledQueriesInput) SetMaxResults(v int64) *ListScheduledQueriesInput
SetMaxResults sets the MaxResults field's value.
func (s *ListScheduledQueriesInput) SetNextToken(v string) *ListScheduledQueriesInput
SetNextToken sets the NextToken field's value.
func (s ListScheduledQueriesInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListScheduledQueriesInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListScheduledQueriesOutput struct {
// A token to specify where to start paginating. This is the NextToken from
// a previously truncated response.
NextToken *string `type:"string"`
// A list of scheduled queries.
//
// ScheduledQueries is a required field
ScheduledQueries []*ScheduledQuery `type:"list" required:"true"`
// contains filtered or unexported fields
}
func (s ListScheduledQueriesOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListScheduledQueriesOutput) SetNextToken(v string) *ListScheduledQueriesOutput
SetNextToken sets the NextToken field's value.
func (s *ListScheduledQueriesOutput) SetScheduledQueries(v []*ScheduledQuery) *ListScheduledQueriesOutput
SetScheduledQueries sets the ScheduledQueries field's value.
func (s ListScheduledQueriesOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ListTagsForResourceInput struct {
// The maximum number of tags to return.
MaxResults *int64 `min:"1" type:"integer"`
// A pagination token to resume pagination.
NextToken *string `type:"string"`
// The Timestream resource with tags to be listed. This value is an Amazon Resource
// Name (ARN).
//
// ResourceARN is a required field
ResourceARN *string `min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
func (s ListTagsForResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceInput) SetMaxResults(v int64) *ListTagsForResourceInput
SetMaxResults sets the MaxResults field's value.
func (s *ListTagsForResourceInput) SetNextToken(v string) *ListTagsForResourceInput
SetNextToken sets the NextToken field's value.
func (s *ListTagsForResourceInput) SetResourceARN(v string) *ListTagsForResourceInput
SetResourceARN sets the ResourceARN field's value.
func (s ListTagsForResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListTagsForResourceOutput struct {
// A pagination token to resume pagination with a subsequent call to ListTagsForResourceResponse.
NextToken *string `type:"string"`
// The tags currently associated with the Timestream resource.
//
// Tags is a required field
Tags []*Tag `type:"list" required:"true"`
// contains filtered or unexported fields
}
func (s ListTagsForResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ListTagsForResourceOutput) SetNextToken(v string) *ListTagsForResourceOutput
SetNextToken sets the NextToken field's value.
func (s *ListTagsForResourceOutput) SetTags(v []*Tag) *ListTagsForResourceOutput
SetTags sets the Tags field's value.
func (s ListTagsForResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type MixedMeasureMapping struct {
// Refers to the value of measure_name in a result row. This field is required
// if MeasureNameColumn is provided.
MeasureName *string `type:"string"`
// Type of the value that is to be read from sourceColumn. If the mapping is
// for MULTI, use MeasureValueType.MULTI.
//
// MeasureValueType is a required field
MeasureValueType *string `type:"string" required:"true" enum:"MeasureValueType"`
// Required when measureValueType is MULTI. Attribute mappings for MULTI value
// measures.
MultiMeasureAttributeMappings []*MultiMeasureAttributeMapping `min:"1" type:"list"`
// This field refers to the source column from which measure-value is to be
// read for result materialization.
SourceColumn *string `type:"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 `type:"string"`
// contains filtered or unexported fields
}
MixedMeasureMappings are mappings that can be used to ingest data into a mixture of narrow and multi measures in the derived table.
func (s MixedMeasureMapping) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *MixedMeasureMapping) SetMeasureName(v string) *MixedMeasureMapping
SetMeasureName sets the MeasureName field's value.
func (s *MixedMeasureMapping) SetMeasureValueType(v string) *MixedMeasureMapping
SetMeasureValueType sets the MeasureValueType field's value.
func (s *MixedMeasureMapping) SetMultiMeasureAttributeMappings(v []*MultiMeasureAttributeMapping) *MixedMeasureMapping
SetMultiMeasureAttributeMappings sets the MultiMeasureAttributeMappings field's value.
func (s *MixedMeasureMapping) SetSourceColumn(v string) *MixedMeasureMapping
SetSourceColumn sets the SourceColumn field's value.
func (s *MixedMeasureMapping) SetTargetMeasureName(v string) *MixedMeasureMapping
SetTargetMeasureName sets the TargetMeasureName field's value.
func (s MixedMeasureMapping) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *MixedMeasureMapping) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type MultiMeasureAttributeMapping struct {
// Type of the attribute to be read from the source column.
//
// MeasureValueType is a required field
MeasureValueType *string `type:"string" required:"true" enum:"ScalarMeasureValueType"`
// Source column from where the attribute value is to be read.
//
// SourceColumn is a required field
SourceColumn *string `type:"string" required:"true"`
// Custom name to be used for attribute name in derived table. If not provided,
// source column name would be used.
TargetMultiMeasureAttributeName *string `type:"string"`
// contains filtered or unexported fields
}
Attribute mapping for MULTI value measures.
func (s MultiMeasureAttributeMapping) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *MultiMeasureAttributeMapping) SetMeasureValueType(v string) *MultiMeasureAttributeMapping
SetMeasureValueType sets the MeasureValueType field's value.
func (s *MultiMeasureAttributeMapping) SetSourceColumn(v string) *MultiMeasureAttributeMapping
SetSourceColumn sets the SourceColumn field's value.
func (s *MultiMeasureAttributeMapping) SetTargetMultiMeasureAttributeName(v string) *MultiMeasureAttributeMapping
SetTargetMultiMeasureAttributeName sets the TargetMultiMeasureAttributeName field's value.
func (s MultiMeasureAttributeMapping) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *MultiMeasureAttributeMapping) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type MultiMeasureMappings struct {
// Required. Attribute mappings to be used for mapping query results to ingest
// data for multi-measure attributes.
//
// MultiMeasureAttributeMappings is a required field
MultiMeasureAttributeMappings []*MultiMeasureAttributeMapping `min:"1" type:"list" required:"true"`
// 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 `type:"string"`
// contains filtered or unexported fields
}
Only one of MixedMeasureMappings or MultiMeasureMappings is to be provided. MultiMeasureMappings can be used to ingest data as multi measures in the derived table.
func (s MultiMeasureMappings) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *MultiMeasureMappings) SetMultiMeasureAttributeMappings(v []*MultiMeasureAttributeMapping) *MultiMeasureMappings
SetMultiMeasureAttributeMappings sets the MultiMeasureAttributeMappings field's value.
func (s *MultiMeasureMappings) SetTargetMultiMeasureName(v string) *MultiMeasureMappings
SetTargetMultiMeasureName sets the TargetMultiMeasureName field's value.
func (s MultiMeasureMappings) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *MultiMeasureMappings) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type NotificationConfiguration struct {
// Details on SNS configuration.
//
// SnsConfiguration is a required field
SnsConfiguration *SnsConfiguration `type:"structure" required:"true"`
// contains filtered or unexported fields
}
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.
func (s NotificationConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *NotificationConfiguration) SetSnsConfiguration(v *SnsConfiguration) *NotificationConfiguration
SetSnsConfiguration sets the SnsConfiguration field's value.
func (s NotificationConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *NotificationConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ParameterMapping struct {
// Parameter name.
//
// Name is a required field
Name *string `type:"string" required:"true"`
// 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 is a required field
Type *Type `type:"structure" required:"true"`
// contains filtered or unexported fields
}
Mapping for named parameters.
func (s ParameterMapping) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ParameterMapping) SetName(v string) *ParameterMapping
SetName sets the Name field's value.
func (s *ParameterMapping) SetType(v *Type) *ParameterMapping
SetType sets the Type field's value.
func (s ParameterMapping) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type PrepareQueryInput struct {
// The Timestream query string that you want to use as a prepared statement.
// Parameter names can be specified in the query string @ character followed
// by an identifier.
//
// QueryString is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by PrepareQueryInput's
// String and GoString methods.
//
// QueryString is a required field
QueryString *string `min:"1" type:"string" required:"true" sensitive:"true"`
// By setting this value to true, Timestream will only validate that the query
// string is a valid Timestream query, and not store the prepared query for
// later use.
ValidateOnly *bool `type:"boolean"`
// contains filtered or unexported fields
}
func (s PrepareQueryInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *PrepareQueryInput) SetQueryString(v string) *PrepareQueryInput
SetQueryString sets the QueryString field's value.
func (s *PrepareQueryInput) SetValidateOnly(v bool) *PrepareQueryInput
SetValidateOnly sets the ValidateOnly field's value.
func (s PrepareQueryInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *PrepareQueryInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type PrepareQueryOutput struct {
// A list of SELECT clause columns of the submitted query string.
//
// Columns is a required field
Columns []*SelectColumn `type:"list" required:"true"`
// A list of parameters used in the submitted query string.
//
// Parameters is a required field
Parameters []*ParameterMapping `type:"list" required:"true"`
// The query string that you want prepare.
//
// QueryString is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by PrepareQueryOutput's
// String and GoString methods.
//
// QueryString is a required field
QueryString *string `min:"1" type:"string" required:"true" sensitive:"true"`
// contains filtered or unexported fields
}
func (s PrepareQueryOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *PrepareQueryOutput) SetColumns(v []*SelectColumn) *PrepareQueryOutput
SetColumns sets the Columns field's value.
func (s *PrepareQueryOutput) SetParameters(v []*ParameterMapping) *PrepareQueryOutput
SetParameters sets the Parameters field's value.
func (s *PrepareQueryOutput) SetQueryString(v string) *PrepareQueryOutput
SetQueryString sets the QueryString field's value.
func (s PrepareQueryOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type QueryExecutionException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
Timestream was unable to run the query successfully.
func (s *QueryExecutionException) Code() string
Code returns the exception type name.
func (s *QueryExecutionException) Error() string
func (s QueryExecutionException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *QueryExecutionException) Message() string
Message returns the exception's message.
func (s *QueryExecutionException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *QueryExecutionException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *QueryExecutionException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s QueryExecutionException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type QueryInput struct {
// Unique, case-sensitive string of up to 64 ASCII characters specified when
// a Query request is made. Providing a ClientToken makes the call to Query
// idempotent. This means that running the same query repeatedly will produce
// the same result. In other words, making multiple identical Query requests
// has the same effect as making a single request. When using ClientToken in
// a query, note the following:
//
// * If the Query API is instantiated without a ClientToken, the Query SDK
// generates a ClientToken on your behalf.
//
// * If the Query invocation only contains the ClientToken but does not include
// a NextToken, that invocation of Query is assumed to be a new query run.
//
// * If the invocation contains NextToken, that particular invocation is
// assumed to be a subsequent invocation of a prior call to the Query API,
// and a result set is returned.
//
// * After 4 hours, any request with the same ClientToken is treated as a
// new request.
//
// ClientToken is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by QueryInput's
// String and GoString methods.
ClientToken *string `min:"32" type:"string" idempotencyToken:"true" sensitive:"true"`
// The total number of rows to be returned in the Query output. The initial
// run of Query with a MaxRows value specified will return the result set of
// the query in two cases:
//
// * The size of the result is less than 1MB.
//
// * The number of rows in the result set is less than the value of maxRows.
//
// Otherwise, the initial invocation of Query only returns a NextToken, which
// can then be used in subsequent calls to fetch the result set. To resume pagination,
// provide the NextToken value in the subsequent command.
//
// If the row size is large (e.g. a row has many columns), Timestream may return
// fewer rows to keep the response size from exceeding the 1 MB limit. If MaxRows
// is not provided, Timestream will send the necessary number of rows to meet
// the 1 MB limit.
MaxRows *int64 `min:"1" type:"integer"`
// A pagination token used to return a set of results. When the Query API is
// invoked using NextToken, that particular invocation is assumed to be a subsequent
// invocation of a prior call to Query, and a result set is returned. However,
// if the Query invocation only contains the ClientToken, that invocation of
// Query is assumed to be a new query run.
//
// Note the following when using NextToken in a query:
//
// * A pagination token can be used for up to five Query invocations, OR
// for a duration of up to 1 hour – whichever comes first.
//
// * Using the same NextToken will return the same set of records. To keep
// paginating through the result set, you must to use the most recent nextToken.
//
// * Suppose a Query invocation returns two NextToken values, TokenA and
// TokenB. If TokenB is used in a subsequent Query invocation, then TokenA
// is invalidated and cannot be reused.
//
// * To request a previous result set from a query after pagination has begun,
// you must re-invoke the Query API.
//
// * The latest NextToken should be used to paginate until null is returned,
// at which point a new NextToken should be used.
//
// * If the IAM principal of the query initiator and the result reader are
// not the same and/or the query initiator and the result reader do not have
// the same query string in the query requests, the query will fail with
// an Invalid pagination token error.
NextToken *string `min:"1" type:"string"`
// The query to be run by Timestream.
//
// QueryString is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by QueryInput's
// String and GoString methods.
//
// QueryString is a required field
QueryString *string `min:"1" type:"string" required:"true" sensitive:"true"`
// contains filtered or unexported fields
}
func (s QueryInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *QueryInput) SetClientToken(v string) *QueryInput
SetClientToken sets the ClientToken field's value.
func (s *QueryInput) SetMaxRows(v int64) *QueryInput
SetMaxRows sets the MaxRows field's value.
func (s *QueryInput) SetNextToken(v string) *QueryInput
SetNextToken sets the NextToken field's value.
func (s *QueryInput) SetQueryString(v string) *QueryInput
SetQueryString sets the QueryString field's value.
func (s QueryInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *QueryInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type QueryOutput struct {
// The column data types of the returned result set.
//
// ColumnInfo is a required field
ColumnInfo []*ColumnInfo `type:"list" required:"true"`
// A pagination token that can be used again on a Query call to get the next
// set of results.
NextToken *string `min:"1" type:"string"`
// A unique ID for the given query.
//
// QueryId is a required field
QueryId *string `min:"1" type:"string" required:"true"`
// Information about the status of the query, including progress and bytes scanned.
QueryStatus *QueryStatus `type:"structure"`
// The result set rows returned by the query.
//
// Rows is a required field
Rows []*Row `type:"list" required:"true"`
// contains filtered or unexported fields
}
func (s QueryOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *QueryOutput) SetColumnInfo(v []*ColumnInfo) *QueryOutput
SetColumnInfo sets the ColumnInfo field's value.
func (s *QueryOutput) SetNextToken(v string) *QueryOutput
SetNextToken sets the NextToken field's value.
func (s *QueryOutput) SetQueryId(v string) *QueryOutput
SetQueryId sets the QueryId field's value.
func (s *QueryOutput) SetQueryStatus(v *QueryStatus) *QueryOutput
SetQueryStatus sets the QueryStatus field's value.
func (s *QueryOutput) SetRows(v []*Row) *QueryOutput
SetRows sets the Rows field's value.
func (s QueryOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
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 `type:"long"`
// 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 `type:"long"`
// The progress of the query, expressed as a percentage.
ProgressPercentage *float64 `type:"double"`
// contains filtered or unexported fields
}
Information about the status of the query, including progress and bytes scanned.
func (s QueryStatus) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *QueryStatus) SetCumulativeBytesMetered(v int64) *QueryStatus
SetCumulativeBytesMetered sets the CumulativeBytesMetered field's value.
func (s *QueryStatus) SetCumulativeBytesScanned(v int64) *QueryStatus
SetCumulativeBytesScanned sets the CumulativeBytesScanned field's value.
func (s *QueryStatus) SetProgressPercentage(v float64) *QueryStatus
SetProgressPercentage sets the ProgressPercentage field's value.
func (s QueryStatus) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ResourceNotFoundException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// The ARN of the scheduled query.
ScheduledQueryArn *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
The requested resource could not be found.
func (s *ResourceNotFoundException) Code() string
Code returns the exception type name.
func (s *ResourceNotFoundException) Error() string
func (s ResourceNotFoundException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ResourceNotFoundException) Message() string
Message returns the exception's message.
func (s *ResourceNotFoundException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ResourceNotFoundException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ResourceNotFoundException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ResourceNotFoundException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type Row struct {
// List of data points in a single row of the result set.
//
// Data is a required field
Data []*Datum `type:"list" required:"true"`
// contains filtered or unexported fields
}
Represents a single row in the query results.
func (s Row) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Row) SetData(v []*Datum) *Row
SetData sets the Data field's value.
func (s Row) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type S3Configuration struct {
// Name of the S3 bucket under which error reports will be created.
//
// BucketName is a required field
BucketName *string `min:"3" type:"string" required:"true"`
// Encryption at rest options for the error reports. If no encryption option
// is specified, Timestream will choose SSE_S3 as default.
EncryptionOption *string `type:"string" enum:"S3EncryptionOption"`
// Prefix for the error report key. Timestream by default adds the following
// prefix to the error report path.
ObjectKeyPrefix *string `min:"1" type:"string"`
// contains filtered or unexported fields
}
Details on S3 location for error reports that result from running a query.
func (s S3Configuration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3Configuration) SetBucketName(v string) *S3Configuration
SetBucketName sets the BucketName field's value.
func (s *S3Configuration) SetEncryptionOption(v string) *S3Configuration
SetEncryptionOption sets the EncryptionOption field's value.
func (s *S3Configuration) SetObjectKeyPrefix(v string) *S3Configuration
SetObjectKeyPrefix sets the ObjectKeyPrefix field's value.
func (s S3Configuration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3Configuration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type S3ReportLocation struct {
// S3 bucket name.
BucketName *string `min:"3" type:"string"`
// S3 key.
ObjectKey *string `type:"string"`
// contains filtered or unexported fields
}
S3 report location for the scheduled query run.
func (s S3ReportLocation) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *S3ReportLocation) SetBucketName(v string) *S3ReportLocation
SetBucketName sets the BucketName field's value.
func (s *S3ReportLocation) SetObjectKey(v string) *S3ReportLocation
SetObjectKey sets the ObjectKey field's value.
func (s S3ReportLocation) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ScheduleConfiguration struct {
// An expression that denotes when to trigger the scheduled query run. This
// can be a cron expression or a rate expression.
//
// ScheduleExpression is a required field
ScheduleExpression *string `min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
Configuration of the schedule of the query.
func (s ScheduleConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScheduleConfiguration) SetScheduleExpression(v string) *ScheduleConfiguration
SetScheduleExpression sets the ScheduleExpression field's value.
func (s ScheduleConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScheduleConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ScheduledQuery struct {
// The Amazon Resource Name.
//
// Arn is a required field
Arn *string `min:"1" type:"string" required:"true"`
// The creation time of the scheduled query.
CreationTime *time.Time `type:"timestamp"`
// Configuration for scheduled query error reporting.
ErrorReportConfiguration *ErrorReportConfiguration `type:"structure"`
// Status of the last scheduled query run.
LastRunStatus *string `type:"string" enum:"ScheduledQueryRunStatus"`
// The name of the scheduled query.
//
// Name is a required field
Name *string `min:"1" type:"string" required:"true"`
// The next time the scheduled query is to be run.
NextInvocationTime *time.Time `type:"timestamp"`
// The last time the scheduled query was run.
PreviousInvocationTime *time.Time `type:"timestamp"`
// State of scheduled query.
//
// State is a required field
State *string `type:"string" required:"true" enum:"ScheduledQueryState"`
// Target data source where final scheduled query result will be written.
TargetDestination *TargetDestination `type:"structure"`
// contains filtered or unexported fields
}
Scheduled Query
func (s ScheduledQuery) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScheduledQuery) SetArn(v string) *ScheduledQuery
SetArn sets the Arn field's value.
func (s *ScheduledQuery) SetCreationTime(v time.Time) *ScheduledQuery
SetCreationTime sets the CreationTime field's value.
func (s *ScheduledQuery) SetErrorReportConfiguration(v *ErrorReportConfiguration) *ScheduledQuery
SetErrorReportConfiguration sets the ErrorReportConfiguration field's value.
func (s *ScheduledQuery) SetLastRunStatus(v string) *ScheduledQuery
SetLastRunStatus sets the LastRunStatus field's value.
func (s *ScheduledQuery) SetName(v string) *ScheduledQuery
SetName sets the Name field's value.
func (s *ScheduledQuery) SetNextInvocationTime(v time.Time) *ScheduledQuery
SetNextInvocationTime sets the NextInvocationTime field's value.
func (s *ScheduledQuery) SetPreviousInvocationTime(v time.Time) *ScheduledQuery
SetPreviousInvocationTime sets the PreviousInvocationTime field's value.
func (s *ScheduledQuery) SetState(v string) *ScheduledQuery
SetState sets the State field's value.
func (s *ScheduledQuery) SetTargetDestination(v *TargetDestination) *ScheduledQuery
SetTargetDestination sets the TargetDestination field's value.
func (s ScheduledQuery) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ScheduledQueryDescription struct {
// Scheduled query ARN.
//
// Arn is a required field
Arn *string `min:"1" type:"string" required:"true"`
// Creation time of the scheduled query.
CreationTime *time.Time `type:"timestamp"`
// Error-reporting configuration for the scheduled query.
ErrorReportConfiguration *ErrorReportConfiguration `type:"structure"`
// A customer provided KMS key used to encrypt the scheduled query resource.
KmsKeyId *string `min:"1" type:"string"`
// Runtime summary for the last scheduled query run.
LastRunSummary *ScheduledQueryRunSummary `type:"structure"`
// Name of the scheduled query.
//
// Name is a required field
Name *string `min:"1" type:"string" required:"true"`
// The next time the scheduled query is scheduled to run.
NextInvocationTime *time.Time `type:"timestamp"`
// Notification configuration.
//
// NotificationConfiguration is a required field
NotificationConfiguration *NotificationConfiguration `type:"structure" required:"true"`
// Last time the query was run.
PreviousInvocationTime *time.Time `type:"timestamp"`
// The query to be run.
//
// QueryString is a sensitive parameter and its value will be
// replaced with "sensitive" in string returned by ScheduledQueryDescription's
// String and GoString methods.
//
// QueryString is a required field
QueryString *string `min:"1" type:"string" required:"true" sensitive:"true"`
// Runtime summary for the last five failed scheduled query runs.
RecentlyFailedRuns []*ScheduledQueryRunSummary `type:"list"`
// Schedule configuration.
//
// ScheduleConfiguration is a required field
ScheduleConfiguration *ScheduleConfiguration `type:"structure" required:"true"`
// IAM role that Timestream uses to run the schedule query.
ScheduledQueryExecutionRoleArn *string `min:"1" type:"string"`
// State of the scheduled query.
//
// State is a required field
State *string `type:"string" required:"true" enum:"ScheduledQueryState"`
// Scheduled query target store configuration.
TargetConfiguration *TargetConfiguration `type:"structure"`
// contains filtered or unexported fields
}
Structure that describes scheduled query.
func (s ScheduledQueryDescription) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScheduledQueryDescription) SetArn(v string) *ScheduledQueryDescription
SetArn sets the Arn field's value.
func (s *ScheduledQueryDescription) SetCreationTime(v time.Time) *ScheduledQueryDescription
SetCreationTime sets the CreationTime field's value.
func (s *ScheduledQueryDescription) SetErrorReportConfiguration(v *ErrorReportConfiguration) *ScheduledQueryDescription
SetErrorReportConfiguration sets the ErrorReportConfiguration field's value.
func (s *ScheduledQueryDescription) SetKmsKeyId(v string) *ScheduledQueryDescription
SetKmsKeyId sets the KmsKeyId field's value.
func (s *ScheduledQueryDescription) SetLastRunSummary(v *ScheduledQueryRunSummary) *ScheduledQueryDescription
SetLastRunSummary sets the LastRunSummary field's value.
func (s *ScheduledQueryDescription) SetName(v string) *ScheduledQueryDescription
SetName sets the Name field's value.
func (s *ScheduledQueryDescription) SetNextInvocationTime(v time.Time) *ScheduledQueryDescription
SetNextInvocationTime sets the NextInvocationTime field's value.
func (s *ScheduledQueryDescription) SetNotificationConfiguration(v *NotificationConfiguration) *ScheduledQueryDescription
SetNotificationConfiguration sets the NotificationConfiguration field's value.
func (s *ScheduledQueryDescription) SetPreviousInvocationTime(v time.Time) *ScheduledQueryDescription
SetPreviousInvocationTime sets the PreviousInvocationTime field's value.
func (s *ScheduledQueryDescription) SetQueryString(v string) *ScheduledQueryDescription
SetQueryString sets the QueryString field's value.
func (s *ScheduledQueryDescription) SetRecentlyFailedRuns(v []*ScheduledQueryRunSummary) *ScheduledQueryDescription
SetRecentlyFailedRuns sets the RecentlyFailedRuns field's value.
func (s *ScheduledQueryDescription) SetScheduleConfiguration(v *ScheduleConfiguration) *ScheduledQueryDescription
SetScheduleConfiguration sets the ScheduleConfiguration field's value.
func (s *ScheduledQueryDescription) SetScheduledQueryExecutionRoleArn(v string) *ScheduledQueryDescription
SetScheduledQueryExecutionRoleArn sets the ScheduledQueryExecutionRoleArn field's value.
func (s *ScheduledQueryDescription) SetState(v string) *ScheduledQueryDescription
SetState sets the State field's value.
func (s *ScheduledQueryDescription) SetTargetConfiguration(v *TargetConfiguration) *ScheduledQueryDescription
SetTargetConfiguration sets the TargetConfiguration field's value.
func (s ScheduledQueryDescription) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ScheduledQueryRunSummary struct {
// S3 location for error report.
ErrorReportLocation *ErrorReportLocation `type:"structure"`
// Runtime statistics for a scheduled run.
ExecutionStats *ExecutionStats `type:"structure"`
// 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 `type:"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 `type:"timestamp"`
// The status of a scheduled query run.
RunStatus *string `type:"string" enum:"ScheduledQueryRunStatus"`
// The actual time when the query was run.
TriggerTime *time.Time `type:"timestamp"`
// contains filtered or unexported fields
}
Run summary for the scheduled query
func (s ScheduledQueryRunSummary) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ScheduledQueryRunSummary) SetErrorReportLocation(v *ErrorReportLocation) *ScheduledQueryRunSummary
SetErrorReportLocation sets the ErrorReportLocation field's value.
func (s *ScheduledQueryRunSummary) SetExecutionStats(v *ExecutionStats) *ScheduledQueryRunSummary
SetExecutionStats sets the ExecutionStats field's value.
func (s *ScheduledQueryRunSummary) SetFailureReason(v string) *ScheduledQueryRunSummary
SetFailureReason sets the FailureReason field's value.
func (s *ScheduledQueryRunSummary) SetInvocationTime(v time.Time) *ScheduledQueryRunSummary
SetInvocationTime sets the InvocationTime field's value.
func (s *ScheduledQueryRunSummary) SetRunStatus(v string) *ScheduledQueryRunSummary
SetRunStatus sets the RunStatus field's value.
func (s *ScheduledQueryRunSummary) SetTriggerTime(v time.Time) *ScheduledQueryRunSummary
SetTriggerTime sets the TriggerTime field's value.
func (s ScheduledQueryRunSummary) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type SelectColumn struct {
// True, if the column name was aliased by the query. False otherwise.
Aliased *bool `type:"boolean"`
// Database that has this column.
DatabaseName *string `type:"string"`
// Name of the column.
Name *string `type:"string"`
// Table within the database that has this column.
TableName *string `type:"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 `type:"structure"`
// contains filtered or unexported fields
}
Details of the column that is returned by the query.
func (s SelectColumn) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *SelectColumn) SetAliased(v bool) *SelectColumn
SetAliased sets the Aliased field's value.
func (s *SelectColumn) SetDatabaseName(v string) *SelectColumn
SetDatabaseName sets the DatabaseName field's value.
func (s *SelectColumn) SetName(v string) *SelectColumn
SetName sets the Name field's value.
func (s *SelectColumn) SetTableName(v string) *SelectColumn
SetTableName sets the TableName field's value.
func (s *SelectColumn) SetType(v *Type) *SelectColumn
SetType sets the Type field's value.
func (s SelectColumn) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ServiceQuotaExceededException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
You have exceeded the service quota.
func (s *ServiceQuotaExceededException) Code() string
Code returns the exception type name.
func (s *ServiceQuotaExceededException) Error() string
func (s ServiceQuotaExceededException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ServiceQuotaExceededException) Message() string
Message returns the exception's message.
func (s *ServiceQuotaExceededException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ServiceQuotaExceededException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ServiceQuotaExceededException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ServiceQuotaExceededException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type SnsConfiguration struct {
// SNS topic ARN that the scheduled query status notifications will be sent
// to.
//
// TopicArn is a required field
TopicArn *string `min:"1" type:"string" required:"true"`
// contains filtered or unexported fields
}
Details on SNS that are required to send the notification.
func (s SnsConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *SnsConfiguration) SetTopicArn(v string) *SnsConfiguration
SetTopicArn sets the TopicArn field's value.
func (s SnsConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *SnsConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type Tag struct {
// The key of the tag. Tag keys are case sensitive.
//
// Key is a required field
Key *string `min:"1" type:"string" required:"true"`
// The value of the tag. Tag values are case sensitive and can be null.
//
// Value is a required field
Value *string `type:"string" required:"true"`
// contains filtered or unexported fields
}
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.
func (s Tag) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Tag) SetKey(v string) *Tag
SetKey sets the Key field's value.
func (s *Tag) SetValue(v string) *Tag
SetValue sets the Value field's value.
func (s Tag) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Tag) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TagResourceInput struct {
// Identifies the Timestream resource to which tags should be added. This value
// is an Amazon Resource Name (ARN).
//
// ResourceARN is a required field
ResourceARN *string `min:"1" type:"string" required:"true"`
// The tags to be assigned to the Timestream resource.
//
// Tags is a required field
Tags []*Tag `type:"list" required:"true"`
// contains filtered or unexported fields
}
func (s TagResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TagResourceInput) SetResourceARN(v string) *TagResourceInput
SetResourceARN sets the ResourceARN field's value.
func (s *TagResourceInput) SetTags(v []*Tag) *TagResourceInput
SetTags sets the Tags field's value.
func (s TagResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TagResourceOutput struct {
// contains filtered or unexported fields
}
func (s TagResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s TagResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type TargetConfiguration struct {
// Configuration needed to write data into the Timestream database and table.
//
// TimestreamConfiguration is a required field
TimestreamConfiguration *TimestreamConfiguration `type:"structure" required:"true"`
// contains filtered or unexported fields
}
Configuration used for writing the output of a query.
func (s TargetConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TargetConfiguration) SetTimestreamConfiguration(v *TimestreamConfiguration) *TargetConfiguration
SetTimestreamConfiguration sets the TimestreamConfiguration field's value.
func (s TargetConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TargetConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TargetDestination struct {
// Query result destination details for Timestream data source.
TimestreamDestination *TimestreamDestination `type:"structure"`
// contains filtered or unexported fields
}
Destination details to write data for a target data source. Current supported data source is Timestream.
func (s TargetDestination) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TargetDestination) SetTimestreamDestination(v *TimestreamDestination) *TargetDestination
SetTimestreamDestination sets the TimestreamDestination field's value.
func (s TargetDestination) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ThrottlingException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
The request was denied due to request throttling.
func (s *ThrottlingException) Code() string
Code returns the exception type name.
func (s *ThrottlingException) Error() string
func (s ThrottlingException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ThrottlingException) Message() string
Message returns the exception's message.
func (s *ThrottlingException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ThrottlingException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ThrottlingException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ThrottlingException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type TimeSeriesDataPoint struct {
// The timestamp when the measure value was collected.
//
// Time is a required field
Time *string `type:"string" required:"true"`
// The measure value for the data point.
//
// Value is a required field
Value *Datum `type:"structure" required:"true"`
// contains filtered or unexported fields
}
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.
func (s TimeSeriesDataPoint) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TimeSeriesDataPoint) SetTime(v string) *TimeSeriesDataPoint
SetTime sets the Time field's value.
func (s *TimeSeriesDataPoint) SetValue(v *Datum) *TimeSeriesDataPoint
SetValue sets the Value field's value.
func (s TimeSeriesDataPoint) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type TimestreamConfiguration struct {
// Name of Timestream database to which the query result will be written.
//
// DatabaseName is a required field
DatabaseName *string `type:"string" required:"true"`
// This is to allow mapping column(s) from the query result to the dimension
// in the destination table.
//
// DimensionMappings is a required field
DimensionMappings []*DimensionMapping `type:"list" required:"true"`
// Name of the measure column.
MeasureNameColumn *string `type:"string"`
// Specifies how to map measures to multi-measure records.
MixedMeasureMappings []*MixedMeasureMapping `min:"1" type:"list"`
// Multi-measure mappings.
MultiMeasureMappings *MultiMeasureMappings `type:"structure"`
// 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.
//
// TableName is a required field
TableName *string `type:"string" required:"true"`
// Column from query result that should be used as the time column in destination
// table. Column type for this should be TIMESTAMP.
//
// TimeColumn is a required field
TimeColumn *string `type:"string" required:"true"`
// contains filtered or unexported fields
}
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.
func (s TimestreamConfiguration) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TimestreamConfiguration) SetDatabaseName(v string) *TimestreamConfiguration
SetDatabaseName sets the DatabaseName field's value.
func (s *TimestreamConfiguration) SetDimensionMappings(v []*DimensionMapping) *TimestreamConfiguration
SetDimensionMappings sets the DimensionMappings field's value.
func (s *TimestreamConfiguration) SetMeasureNameColumn(v string) *TimestreamConfiguration
SetMeasureNameColumn sets the MeasureNameColumn field's value.
func (s *TimestreamConfiguration) SetMixedMeasureMappings(v []*MixedMeasureMapping) *TimestreamConfiguration
SetMixedMeasureMappings sets the MixedMeasureMappings field's value.
func (s *TimestreamConfiguration) SetMultiMeasureMappings(v *MultiMeasureMappings) *TimestreamConfiguration
SetMultiMeasureMappings sets the MultiMeasureMappings field's value.
func (s *TimestreamConfiguration) SetTableName(v string) *TimestreamConfiguration
SetTableName sets the TableName field's value.
func (s *TimestreamConfiguration) SetTimeColumn(v string) *TimestreamConfiguration
SetTimeColumn sets the TimeColumn field's value.
func (s TimestreamConfiguration) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TimestreamConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TimestreamDestination struct {
// Timestream database name.
DatabaseName *string `type:"string"`
// Timestream table name.
TableName *string `type:"string"`
// contains filtered or unexported fields
}
Destination for scheduled query.
func (s TimestreamDestination) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *TimestreamDestination) SetDatabaseName(v string) *TimestreamDestination
SetDatabaseName sets the DatabaseName field's value.
func (s *TimestreamDestination) SetTableName(v string) *TimestreamDestination
SetTableName sets the TableName field's value.
func (s TimestreamDestination) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type TimestreamQuery struct {
*client.Client
// contains filtered or unexported fields
}
TimestreamQuery provides the API operation methods for making requests to Amazon Timestream Query. See this package's package overview docs for details on the service.
TimestreamQuery methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.
func New(p client.ConfigProvider, cfgs ...*aws.Config) *TimestreamQuery
New creates a new instance of the TimestreamQuery client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.
Example:
mySession := session.Must(session.NewSession())
// Create a TimestreamQuery client from just a session.
svc := timestreamquery.New(mySession)
// Create a TimestreamQuery client with additional configuration
svc := timestreamquery.New(mySession, aws.NewConfig().WithRegion("us-west-2"))
func (c *TimestreamQuery) CancelQuery(input *CancelQueryInput) (*CancelQueryOutput, error)
CancelQuery API operation for Amazon Timestream Query.
Cancels a query that has been issued. Cancellation is provided only if the query has not completed running before the cancellation request was issued. Because cancellation is an idempotent operation, subsequent cancellation requests will return a CancellationMessage, indicating that the query has already been canceled. See code sample (https://docs.aws.amazon.com/timestream/latest/developerguide/code-samples.cancel-query.html) for details.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation CancelQuery for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/CancelQuery
func (c *TimestreamQuery) CancelQueryRequest(input *CancelQueryInput) (req *request.Request, output *CancelQueryOutput)
CancelQueryRequest generates a "aws/request.Request" representing the client's request for the CancelQuery operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CancelQuery for more information on using the CancelQuery API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CancelQueryRequest method.
req, resp := client.CancelQueryRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/CancelQuery
func (c *TimestreamQuery) CancelQueryWithContext(ctx aws.Context, input *CancelQueryInput, opts ...request.Option) (*CancelQueryOutput, error)
CancelQueryWithContext is the same as CancelQuery with the addition of the ability to pass a context and additional request options.
See CancelQuery for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) CreateScheduledQuery(input *CreateScheduledQueryInput) (*CreateScheduledQueryOutput, error)
CreateScheduledQuery API operation for Amazon Timestream Query.
Create a scheduled query that will be run on your behalf at the configured schedule. Timestream assumes the execution role provided as part of the ScheduledQueryExecutionRoleArn parameter to run the query. You can use the NotificationConfiguration parameter to configure notification for your scheduled query operations.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation CreateScheduledQuery for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
ConflictException Unable to poll results for a cancelled query.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ServiceQuotaExceededException You have exceeded the service quota.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/CreateScheduledQuery
func (c *TimestreamQuery) CreateScheduledQueryRequest(input *CreateScheduledQueryInput) (req *request.Request, output *CreateScheduledQueryOutput)
CreateScheduledQueryRequest generates a "aws/request.Request" representing the client's request for the CreateScheduledQuery operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See CreateScheduledQuery for more information on using the CreateScheduledQuery API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the CreateScheduledQueryRequest method.
req, resp := client.CreateScheduledQueryRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/CreateScheduledQuery
func (c *TimestreamQuery) CreateScheduledQueryWithContext(ctx aws.Context, input *CreateScheduledQueryInput, opts ...request.Option) (*CreateScheduledQueryOutput, error)
CreateScheduledQueryWithContext is the same as CreateScheduledQuery with the addition of the ability to pass a context and additional request options.
See CreateScheduledQuery for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) DeleteScheduledQuery(input *DeleteScheduledQueryInput) (*DeleteScheduledQueryOutput, error)
DeleteScheduledQuery API operation for Amazon Timestream Query.
Deletes a given scheduled query. This is an irreversible operation.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation DeleteScheduledQuery for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ResourceNotFoundException The requested resource could not be found.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/DeleteScheduledQuery
func (c *TimestreamQuery) DeleteScheduledQueryRequest(input *DeleteScheduledQueryInput) (req *request.Request, output *DeleteScheduledQueryOutput)
DeleteScheduledQueryRequest generates a "aws/request.Request" representing the client's request for the DeleteScheduledQuery operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DeleteScheduledQuery for more information on using the DeleteScheduledQuery API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DeleteScheduledQueryRequest method.
req, resp := client.DeleteScheduledQueryRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/DeleteScheduledQuery
func (c *TimestreamQuery) DeleteScheduledQueryWithContext(ctx aws.Context, input *DeleteScheduledQueryInput, opts ...request.Option) (*DeleteScheduledQueryOutput, error)
DeleteScheduledQueryWithContext is the same as DeleteScheduledQuery with the addition of the ability to pass a context and additional request options.
See DeleteScheduledQuery for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) DescribeEndpoints(input *DescribeEndpointsInput) (*DescribeEndpointsOutput, error)
DescribeEndpoints API operation for Amazon Timestream Query.
DescribeEndpoints returns a list of available endpoints to make Timestream API calls against. This API is available through both Write and Query.
Because the Timestream SDKs are designed to transparently work with the service’s architecture, including the management and mapping of the service endpoints, it is not recommended that you use this API unless:
You are using VPC endpoints (Amazon Web Services PrivateLink) with Timestream (https://docs.aws.amazon.com/timestream/latest/developerguide/VPCEndpoints)
Your application uses a programming language that does not yet have SDK support
You require better control over the client-side implementation
For detailed information on how and when to use and implement DescribeEndpoints, see The Endpoint Discovery Pattern (https://docs.aws.amazon.com/timestream/latest/developerguide/Using.API.html#Using-API.endpoint-discovery).
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation DescribeEndpoints for usage and error information.
Returned Error Types:
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ValidationException Invalid or malformed request.
ThrottlingException The request was denied due to request throttling.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/DescribeEndpoints
func (c *TimestreamQuery) DescribeEndpointsRequest(input *DescribeEndpointsInput) (req *request.Request, output *DescribeEndpointsOutput)
DescribeEndpointsRequest generates a "aws/request.Request" representing the client's request for the DescribeEndpoints operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeEndpoints for more information on using the DescribeEndpoints API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeEndpointsRequest method.
req, resp := client.DescribeEndpointsRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/DescribeEndpoints
func (c *TimestreamQuery) DescribeEndpointsWithContext(ctx aws.Context, input *DescribeEndpointsInput, opts ...request.Option) (*DescribeEndpointsOutput, error)
DescribeEndpointsWithContext is the same as DescribeEndpoints with the addition of the ability to pass a context and additional request options.
See DescribeEndpoints for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) DescribeScheduledQuery(input *DescribeScheduledQueryInput) (*DescribeScheduledQueryOutput, error)
DescribeScheduledQuery API operation for Amazon Timestream Query.
Provides detailed information about a scheduled query.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation DescribeScheduledQuery for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ResourceNotFoundException The requested resource could not be found.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/DescribeScheduledQuery
func (c *TimestreamQuery) DescribeScheduledQueryRequest(input *DescribeScheduledQueryInput) (req *request.Request, output *DescribeScheduledQueryOutput)
DescribeScheduledQueryRequest generates a "aws/request.Request" representing the client's request for the DescribeScheduledQuery operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See DescribeScheduledQuery for more information on using the DescribeScheduledQuery API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the DescribeScheduledQueryRequest method.
req, resp := client.DescribeScheduledQueryRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/DescribeScheduledQuery
func (c *TimestreamQuery) DescribeScheduledQueryWithContext(ctx aws.Context, input *DescribeScheduledQueryInput, opts ...request.Option) (*DescribeScheduledQueryOutput, error)
DescribeScheduledQueryWithContext is the same as DescribeScheduledQuery with the addition of the ability to pass a context and additional request options.
See DescribeScheduledQuery for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) ExecuteScheduledQuery(input *ExecuteScheduledQueryInput) (*ExecuteScheduledQueryOutput, error)
ExecuteScheduledQuery API operation for Amazon Timestream Query.
You can use this API to run a scheduled query manually.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation ExecuteScheduledQuery for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ResourceNotFoundException The requested resource could not be found.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/ExecuteScheduledQuery
func (c *TimestreamQuery) ExecuteScheduledQueryRequest(input *ExecuteScheduledQueryInput) (req *request.Request, output *ExecuteScheduledQueryOutput)
ExecuteScheduledQueryRequest generates a "aws/request.Request" representing the client's request for the ExecuteScheduledQuery operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ExecuteScheduledQuery for more information on using the ExecuteScheduledQuery API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ExecuteScheduledQueryRequest method.
req, resp := client.ExecuteScheduledQueryRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/ExecuteScheduledQuery
func (c *TimestreamQuery) ExecuteScheduledQueryWithContext(ctx aws.Context, input *ExecuteScheduledQueryInput, opts ...request.Option) (*ExecuteScheduledQueryOutput, error)
ExecuteScheduledQueryWithContext is the same as ExecuteScheduledQuery with the addition of the ability to pass a context and additional request options.
See ExecuteScheduledQuery for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) ListScheduledQueries(input *ListScheduledQueriesInput) (*ListScheduledQueriesOutput, error)
ListScheduledQueries API operation for Amazon Timestream Query.
Gets a list of all scheduled queries in the caller's Amazon account and Region. ListScheduledQueries is eventually consistent.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation ListScheduledQueries for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/ListScheduledQueries
func (c *TimestreamQuery) ListScheduledQueriesPages(input *ListScheduledQueriesInput, fn func(*ListScheduledQueriesOutput, bool) bool) error
ListScheduledQueriesPages iterates over the pages of a ListScheduledQueries operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListScheduledQueries method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListScheduledQueries operation.
pageNum := 0
err := client.ListScheduledQueriesPages(params,
func(page *timestreamquery.ListScheduledQueriesOutput, lastPage bool) bool {
pageNum++
fmt.Println(page)
return pageNum <= 3
})
func (c *TimestreamQuery) ListScheduledQueriesPagesWithContext(ctx aws.Context, input *ListScheduledQueriesInput, fn func(*ListScheduledQueriesOutput, bool) bool, opts ...request.Option) error
ListScheduledQueriesPagesWithContext same as ListScheduledQueriesPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) ListScheduledQueriesRequest(input *ListScheduledQueriesInput) (req *request.Request, output *ListScheduledQueriesOutput)
ListScheduledQueriesRequest generates a "aws/request.Request" representing the client's request for the ListScheduledQueries operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListScheduledQueries for more information on using the ListScheduledQueries API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListScheduledQueriesRequest method.
req, resp := client.ListScheduledQueriesRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/ListScheduledQueries
func (c *TimestreamQuery) ListScheduledQueriesWithContext(ctx aws.Context, input *ListScheduledQueriesInput, opts ...request.Option) (*ListScheduledQueriesOutput, error)
ListScheduledQueriesWithContext is the same as ListScheduledQueries with the addition of the ability to pass a context and additional request options.
See ListScheduledQueries for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) ListTagsForResource(input *ListTagsForResourceInput) (*ListTagsForResourceOutput, error)
ListTagsForResource API operation for Amazon Timestream Query.
List all tags on a Timestream query resource.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation ListTagsForResource for usage and error information.
Returned Error Types:
ResourceNotFoundException The requested resource could not be found.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/ListTagsForResource
func (c *TimestreamQuery) ListTagsForResourcePages(input *ListTagsForResourceInput, fn func(*ListTagsForResourceOutput, bool) bool) error
ListTagsForResourcePages iterates over the pages of a ListTagsForResource operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See ListTagsForResource method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a ListTagsForResource operation.
pageNum := 0
err := client.ListTagsForResourcePages(params,
func(page *timestreamquery.ListTagsForResourceOutput, lastPage bool) bool {
pageNum++
fmt.Println(page)
return pageNum <= 3
})
func (c *TimestreamQuery) ListTagsForResourcePagesWithContext(ctx aws.Context, input *ListTagsForResourceInput, fn func(*ListTagsForResourceOutput, bool) bool, opts ...request.Option) error
ListTagsForResourcePagesWithContext same as ListTagsForResourcePages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) ListTagsForResourceRequest(input *ListTagsForResourceInput) (req *request.Request, output *ListTagsForResourceOutput)
ListTagsForResourceRequest generates a "aws/request.Request" representing the client's request for the ListTagsForResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See ListTagsForResource for more information on using the ListTagsForResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the ListTagsForResourceRequest method.
req, resp := client.ListTagsForResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/ListTagsForResource
func (c *TimestreamQuery) ListTagsForResourceWithContext(ctx aws.Context, input *ListTagsForResourceInput, opts ...request.Option) (*ListTagsForResourceOutput, error)
ListTagsForResourceWithContext is the same as ListTagsForResource with the addition of the ability to pass a context and additional request options.
See ListTagsForResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) PrepareQuery(input *PrepareQueryInput) (*PrepareQueryOutput, error)
PrepareQuery API operation for Amazon Timestream Query.
A synchronous operation that allows you to submit a query with parameters to be stored by Timestream for later running. Timestream only supports using this operation with ValidateOnly set to true.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation PrepareQuery for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/PrepareQuery
func (c *TimestreamQuery) PrepareQueryRequest(input *PrepareQueryInput) (req *request.Request, output *PrepareQueryOutput)
PrepareQueryRequest generates a "aws/request.Request" representing the client's request for the PrepareQuery operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See PrepareQuery for more information on using the PrepareQuery API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the PrepareQueryRequest method.
req, resp := client.PrepareQueryRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/PrepareQuery
func (c *TimestreamQuery) PrepareQueryWithContext(ctx aws.Context, input *PrepareQueryInput, opts ...request.Option) (*PrepareQueryOutput, error)
PrepareQueryWithContext is the same as PrepareQuery with the addition of the ability to pass a context and additional request options.
See PrepareQuery for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) Query(input *QueryInput) (*QueryOutput, error)
Query API operation for Amazon Timestream Query.
Query is a synchronous operation that enables you to run a query against your Amazon Timestream data. Query will time out after 60 seconds. You must update the default timeout in the SDK to support a timeout of 60 seconds. See the code sample (https://docs.aws.amazon.com/timestream/latest/developerguide/code-samples.run-query.html) for details.
Your query request will fail in the following cases:
If you submit a Query request with the same client token outside of the 5-minute idempotency window.
If you submit a Query request with the same client token, but change other parameters, within the 5-minute idempotency window.
If the size of the row (including the query metadata) exceeds 1 MB, then the query will fail with the following error message: Query aborted as max page response size has been exceeded by the output result row
If the IAM principal of the query initiator and the result reader are not the same and/or the query initiator and the result reader do not have the same query string in the query requests, the query will fail with an Invalid pagination token error.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation Query for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
ConflictException Unable to poll results for a cancelled query.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
QueryExecutionException Timestream was unable to run the query successfully.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/Query
func (c *TimestreamQuery) QueryPages(input *QueryInput, fn func(*QueryOutput, bool) bool) error
QueryPages iterates over the pages of a Query operation, calling the "fn" function with the response data for each page. To stop iterating, return false from the fn function.
See Query method for more information on how to use this operation.
Note: This operation can generate multiple requests to a service.
// Example iterating over at most 3 pages of a Query operation.
pageNum := 0
err := client.QueryPages(params,
func(page *timestreamquery.QueryOutput, lastPage bool) bool {
pageNum++
fmt.Println(page)
return pageNum <= 3
})
func (c *TimestreamQuery) QueryPagesWithContext(ctx aws.Context, input *QueryInput, fn func(*QueryOutput, bool) bool, opts ...request.Option) error
QueryPagesWithContext same as QueryPages except it takes a Context and allows setting request options on the pages.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) QueryRequest(input *QueryInput) (req *request.Request, output *QueryOutput)
QueryRequest generates a "aws/request.Request" representing the client's request for the Query operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See Query for more information on using the Query API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the QueryRequest method.
req, resp := client.QueryRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/Query
func (c *TimestreamQuery) QueryWithContext(ctx aws.Context, input *QueryInput, opts ...request.Option) (*QueryOutput, error)
QueryWithContext is the same as Query with the addition of the ability to pass a context and additional request options.
See Query for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) TagResource(input *TagResourceInput) (*TagResourceOutput, error)
TagResource API operation for Amazon Timestream Query.
Associate a set of tags with a Timestream resource. You can then activate these user-defined tags so that they appear on the Billing and Cost Management console for cost allocation tracking.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation TagResource for usage and error information.
Returned Error Types:
ResourceNotFoundException The requested resource could not be found.
ServiceQuotaExceededException You have exceeded the service quota.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/TagResource
func (c *TimestreamQuery) TagResourceRequest(input *TagResourceInput) (req *request.Request, output *TagResourceOutput)
TagResourceRequest generates a "aws/request.Request" representing the client's request for the TagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See TagResource for more information on using the TagResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the TagResourceRequest method.
req, resp := client.TagResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/TagResource
func (c *TimestreamQuery) TagResourceWithContext(ctx aws.Context, input *TagResourceInput, opts ...request.Option) (*TagResourceOutput, error)
TagResourceWithContext is the same as TagResource with the addition of the ability to pass a context and additional request options.
See TagResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) UntagResource(input *UntagResourceInput) (*UntagResourceOutput, error)
UntagResource API operation for Amazon Timestream Query.
Removes the association of tags from a Timestream query resource.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation UntagResource for usage and error information.
Returned Error Types:
ValidationException Invalid or malformed request.
ThrottlingException The request was denied due to request throttling.
ResourceNotFoundException The requested resource could not be found.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/UntagResource
func (c *TimestreamQuery) UntagResourceRequest(input *UntagResourceInput) (req *request.Request, output *UntagResourceOutput)
UntagResourceRequest generates a "aws/request.Request" representing the client's request for the UntagResource operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UntagResource for more information on using the UntagResource API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UntagResourceRequest method.
req, resp := client.UntagResourceRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/UntagResource
func (c *TimestreamQuery) UntagResourceWithContext(ctx aws.Context, input *UntagResourceInput, opts ...request.Option) (*UntagResourceOutput, error)
UntagResourceWithContext is the same as UntagResource with the addition of the ability to pass a context and additional request options.
See UntagResource for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (c *TimestreamQuery) UpdateScheduledQuery(input *UpdateScheduledQueryInput) (*UpdateScheduledQueryOutput, error)
UpdateScheduledQuery API operation for Amazon Timestream Query.
Update a scheduled query.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for Amazon Timestream Query's API operation UpdateScheduledQuery for usage and error information.
Returned Error Types:
AccessDeniedException You are not authorized to perform this action.
InternalServerException Timestream was unable to fully process this request because of an internal server error.
ResourceNotFoundException The requested resource could not be found.
ThrottlingException The request was denied due to request throttling.
ValidationException Invalid or malformed request.
InvalidEndpointException The requested endpoint was not valid.
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/UpdateScheduledQuery
func (c *TimestreamQuery) UpdateScheduledQueryRequest(input *UpdateScheduledQueryInput) (req *request.Request, output *UpdateScheduledQueryOutput)
UpdateScheduledQueryRequest generates a "aws/request.Request" representing the client's request for the UpdateScheduledQuery operation. The "output" return value will be populated with the request's response once the request completes successfully.
Use "Send" method on the returned Request to send the API call to the service. the "output" return value is not valid until after Send returns without error.
See UpdateScheduledQuery for more information on using the UpdateScheduledQuery API call, and error handling.
This method is useful when you want to inject custom logic or configuration into the SDK's request lifecycle. Such as custom headers, or retry logic.
// Example sending a request using the UpdateScheduledQueryRequest method.
req, resp := client.UpdateScheduledQueryRequest(params)
err := req.Send()
if err == nil { // resp is now filled
fmt.Println(resp)
}
See also, https://docs.aws.amazon.com/goto/WebAPI/timestream-query-2018-11-01/UpdateScheduledQuery
func (c *TimestreamQuery) UpdateScheduledQueryWithContext(ctx aws.Context, input *UpdateScheduledQueryInput, opts ...request.Option) (*UpdateScheduledQueryOutput, error)
UpdateScheduledQueryWithContext is the same as UpdateScheduledQuery with the addition of the ability to pass a context and additional request options.
See UpdateScheduledQuery for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
type Type struct {
// Indicates if the column is an array.
ArrayColumnInfo *ColumnInfo `type:"structure"`
// Indicates if the column is a row.
RowColumnInfo []*ColumnInfo `type:"list"`
// Indicates if the column is of type string, integer, Boolean, double, timestamp,
// date, time. For more information, see Supported data types (https://docs.aws.amazon.com/timestream/latest/developerguide/supported-data-types.html).
ScalarType *string `type:"string" enum:"ScalarType"`
// Indicates if the column is a timeseries data type.
TimeSeriesMeasureValueColumnInfo *ColumnInfo `type:"structure"`
// contains filtered or unexported fields
}
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.
func (s Type) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *Type) SetArrayColumnInfo(v *ColumnInfo) *Type
SetArrayColumnInfo sets the ArrayColumnInfo field's value.
func (s *Type) SetRowColumnInfo(v []*ColumnInfo) *Type
SetRowColumnInfo sets the RowColumnInfo field's value.
func (s *Type) SetScalarType(v string) *Type
SetScalarType sets the ScalarType field's value.
func (s *Type) SetTimeSeriesMeasureValueColumnInfo(v *ColumnInfo) *Type
SetTimeSeriesMeasureValueColumnInfo sets the TimeSeriesMeasureValueColumnInfo field's value.
func (s Type) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UntagResourceInput struct {
// The Timestream resource that the tags will be removed from. This value is
// an Amazon Resource Name (ARN).
//
// ResourceARN is a required field
ResourceARN *string `min:"1" type:"string" required:"true"`
// A list of tags keys. Existing tags of the resource whose keys are members
// of this list will be removed from the Timestream resource.
//
// TagKeys is a required field
TagKeys []*string `type:"list" required:"true"`
// contains filtered or unexported fields
}
func (s UntagResourceInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UntagResourceInput) SetResourceARN(v string) *UntagResourceInput
SetResourceARN sets the ResourceARN field's value.
func (s *UntagResourceInput) SetTagKeys(v []*string) *UntagResourceInput
SetTagKeys sets the TagKeys field's value.
func (s UntagResourceInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UntagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UntagResourceOutput struct {
// contains filtered or unexported fields
}
func (s UntagResourceOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s UntagResourceOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type UpdateScheduledQueryInput struct {
// ARN of the scheuled query.
//
// ScheduledQueryArn is a required field
ScheduledQueryArn *string `min:"1" type:"string" required:"true"`
// State of the scheduled query.
//
// State is a required field
State *string `type:"string" required:"true" enum:"ScheduledQueryState"`
// contains filtered or unexported fields
}
func (s UpdateScheduledQueryInput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateScheduledQueryInput) SetScheduledQueryArn(v string) *UpdateScheduledQueryInput
SetScheduledQueryArn sets the ScheduledQueryArn field's value.
func (s *UpdateScheduledQueryInput) SetState(v string) *UpdateScheduledQueryInput
SetState sets the State field's value.
func (s UpdateScheduledQueryInput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *UpdateScheduledQueryInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateScheduledQueryOutput struct {
// contains filtered or unexported fields
}
func (s UpdateScheduledQueryOutput) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s UpdateScheduledQueryOutput) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
type ValidationException struct {
RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"`
Message_ *string `locationName:"Message" type:"string"`
// contains filtered or unexported fields
}
Invalid or malformed request.
func (s *ValidationException) Code() string
Code returns the exception type name.
func (s *ValidationException) Error() string
func (s ValidationException) GoString() string
GoString returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".
func (s *ValidationException) Message() string
Message returns the exception's message.
func (s *ValidationException) OrigErr() error
OrigErr always returns nil, satisfies awserr.Error interface.
func (s *ValidationException) RequestID() string
RequestID returns the service's response RequestID for request.
func (s *ValidationException) StatusCode() int
Status code returns the HTTP status code for the request's response error.
func (s ValidationException) String() string
String returns the string representation.
API parameter values that are decorated as "sensitive" in the API will not be included in the string output. The member name will be present, but the value will be replaced with "sensitive".