coredb

Documentation

Index

• Constants
• type DB
  • func NewDb(s *session.Session) (*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

Constants

const (
	AXON_TABLE              string = "axon"
	AXON_USER_SESSION_TABLE string = "axon_user_session"
)

Types

type DB

type DB struct {
	Client *dynamodb.DynamoDB
}

func NewDb

func NewDb(s *session.Session) (*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