Documentation ¶
Index ¶
- func NewDynamoDataStore(logger *log.Logger, region string, datasetTable string, metadataTable string) (persistence.DataStore, error)
- func NewS3FileStore(logger *log.Logger, region string, metadataBucket string) (persistence.FileStore, error)
- type DynamoDataStore
- func (d DynamoDataStore) CheckDatasetIdExists(datasetId string) (bool, error)
- func (d DynamoDataStore) GetDataset(datasetId string) (model.Dataset, error)
- func (d DynamoDataStore) GetMetadata(datasetId string, metadataId string) (model.Metadata, error)
- func (d DynamoDataStore) ListDatasets() ([]model.Dataset, error)
- func (d DynamoDataStore) ListMetadata(datasetId string) ([]model.Metadata, error)
- func (d DynamoDataStore) PersistDataset(dataset model.Dataset) (err error)
- func (d DynamoDataStore) PersistMetadata(metadata model.Metadata) (err error)
- type S3FileStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDynamoDataStore ¶
func NewS3FileStore ¶
Types ¶
type DynamoDataStore ¶
type DynamoDataStore struct {
// contains filtered or unexported fields
}
func (DynamoDataStore) CheckDatasetIdExists ¶
func (d DynamoDataStore) CheckDatasetIdExists(datasetId string) (bool, error)
func (DynamoDataStore) GetDataset ¶
func (d DynamoDataStore) GetDataset(datasetId string) (model.Dataset, error)
func (DynamoDataStore) GetMetadata ¶
func (DynamoDataStore) ListDatasets ¶
func (d DynamoDataStore) ListDatasets() ([]model.Dataset, error)
func (DynamoDataStore) ListMetadata ¶
func (d DynamoDataStore) ListMetadata(datasetId string) ([]model.Metadata, error)
func (DynamoDataStore) PersistDataset ¶
func (d DynamoDataStore) PersistDataset(dataset model.Dataset) (err error)
func (DynamoDataStore) PersistMetadata ¶
func (d DynamoDataStore) PersistMetadata(metadata model.Metadata) (err error)
type S3FileStore ¶
type S3FileStore struct {
// contains filtered or unexported fields
}
func (S3FileStore) RetrieveMetadata ¶
func (f S3FileStore) RetrieveMetadata(key string) (string, error)
func (S3FileStore) StoreMetadata ¶
func (f S3FileStore) StoreMetadata(key string, bodyJson string) (string, error)
Click to show internal directories.
Click to hide internal directories.