Documentation
¶
Index ¶
- type Database
- type Dimension
- type MagneticStoreWriteProperties
- type Record
- type RetentionProperties
- type Store
- func (s *Store) CreateDatabase(name, kmsKeyId string, tags map[string]string) (*Database, bool)
- func (s *Store) CreateTable(dbName, tableName string, retention RetentionProperties, ...) (*Table, bool)
- func (s *Store) DeleteDatabase(name string) bool
- func (s *Store) DeleteTable(dbName, tableName string) bool
- func (s *Store) GetDatabase(name string) (*Database, bool)
- func (s *Store) GetRecordCount(dbName, tableName string) int
- func (s *Store) GetTable(dbName, tableName string) (*Table, bool)
- func (s *Store) ListDatabases() []*Database
- func (s *Store) ListTables(dbName string) []*Table
- func (s *Store) ListTagsForResource(arn string) (map[string]string, bool)
- func (s *Store) QueryRecords(dbName, tableName, startTime, endTime string) ([]Record, bool)
- func (s *Store) TagResource(arn string, tags map[string]string) bool
- func (s *Store) UntagResource(arn string, keys []string) bool
- func (s *Store) UpdateDatabase(name, kmsKeyId string) (*Database, bool)
- func (s *Store) UpdateTable(dbName, tableName string, retention *RetentionProperties, ...) (*Table, bool)
- func (s *Store) WriteRecords(dbName, tableName string, records []Record) bool
- type Table
- type TimestreamWriteService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Database ¶
type Database struct {
Name string
ARN string
Status string
KmsKeyId string
TableCount int
CreationTime time.Time
LastUpdatedTime time.Time
Tags map[string]string
Lifecycle *lifecycle.Machine
}
Database represents a Timestream database.
type MagneticStoreWriteProperties ¶
type MagneticStoreWriteProperties struct {
EnableMagneticStoreWrites bool
}
MagneticStoreWriteProperties holds magnetic store config.
type Record ¶
type Record struct {
Dimensions []Dimension
MeasureName string
MeasureValue string
MeasureValueType string
Time string
TimeUnit string
}
Record represents a Timestream record (simplified).
type RetentionProperties ¶
type RetentionProperties struct {
MemoryStoreRetentionPeriodInHours int64
MagneticStoreRetentionPeriodInDays int64
}
RetentionProperties holds data retention config.
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store manages all Timestream resources.
func (*Store) CreateDatabase ¶
func (*Store) CreateTable ¶
func (s *Store) CreateTable(dbName, tableName string, retention RetentionProperties, magnetic MagneticStoreWriteProperties, tags map[string]string) (*Table, bool)
func (*Store) DeleteDatabase ¶
func (*Store) DeleteTable ¶
func (*Store) GetRecordCount ¶
GetRecordCount returns the number of records in a table.
func (*Store) ListDatabases ¶
func (*Store) ListTables ¶
func (*Store) ListTagsForResource ¶
func (*Store) QueryRecords ¶
QueryRecords performs a basic query against stored records with optional time range filtering.
func (*Store) UpdateDatabase ¶
func (*Store) UpdateTable ¶
func (s *Store) UpdateTable(dbName, tableName string, retention *RetentionProperties, magnetic *MagneticStoreWriteProperties) (*Table, bool)
type Table ¶
type Table struct {
Name string
ARN string
DatabaseName string
Status string
RetentionProperties RetentionProperties
MagneticStoreWriteProperties MagneticStoreWriteProperties
CreationTime time.Time
LastUpdatedTime time.Time
Tags map[string]string
Lifecycle *lifecycle.Machine
}
Table represents a Timestream table.
type TimestreamWriteService ¶
type TimestreamWriteService struct {
// contains filtered or unexported fields
}
TimestreamWriteService is the cloudmock implementation of the AWS Timestream Write API.
func New ¶
func New(accountID, region string) *TimestreamWriteService
New returns a new TimestreamWriteService.
func (*TimestreamWriteService) Actions ¶
func (s *TimestreamWriteService) Actions() []service.Action
Actions returns the list of API actions supported.
func (*TimestreamWriteService) HandleRequest ¶
func (s *TimestreamWriteService) HandleRequest(ctx *service.RequestContext) (*service.Response, error)
HandleRequest routes an incoming request to the appropriate handler.
func (*TimestreamWriteService) HealthCheck ¶
func (s *TimestreamWriteService) HealthCheck() error
HealthCheck always returns nil.
func (*TimestreamWriteService) Name ¶
func (s *TimestreamWriteService) Name() string
Name returns the AWS service name used for routing.
Source Files
Click to show internal directories.
Click to hide internal directories.