coredb

Documentation

Index

• type DB
  • func NewDb() (*DB, error)
  • func (c DB) CacheData(table_name string, partition_key string, sort_key string, ...) error
  • func (c DB) DeleteRecord(table_name string, partition_key string, sort_key *string) error
  • func (c DB) MutateDatabase(table_name string, partition_key string, sort_key string, ...) error
  • func (c DB) QueryDatabase(table_name string, partition_key string, sort_key *string) (*dynamodb.GetItemOutput, error)
  • func (c DB) QueryDatabasePartition(table_name string, partition_key string) (*dynamodb.QueryOutput, error)
  • func (c DB) UpdateRecord(table_name string, partition_key string, sort_key string, ...) error

Types

type DB

type DB struct {
	Client *dynamodb.DynamoDB
}

func NewDb

func NewDb() (*DB, error)

CreateDynamoDBClient creates a new DynamoDB client and session

func (DB) CacheData

func (c DB) CacheData(table_name string, partition_key string, sort_key string, attributes interface{}, ttl int64) error

func (DB) DeleteRecord

func (c DB) DeleteRecord(table_name string, partition_key string, sort_key *string) error

func (DB) MutateDatabase

func (c DB) MutateDatabase(table_name string, partition_key string, sort_key string, attributes interface{}) error

func (DB) QueryDatabase

func (c DB) QueryDatabase(table_name string, partition_key string, sort_key *string) (*dynamodb.GetItemOutput, error)

func (DB) QueryDatabasePartition

func (c DB) QueryDatabasePartition(table_name string, partition_key string) (*dynamodb.QueryOutput, error)

func (DB) UpdateRecord

func (c DB) UpdateRecord(table_name string, partition_key string, sort_key string, attributes interface{}) error