dynamodb

Documentation

Index

• type Config
• type DB
  • func New(config Config) (*DB, error)
  • func (d DB) CreateTables(ctx context.Context) error
  • func (d DB) DeleteSimpleThing(ctx context.Context, name string) error
  • func (d DB) DeleteThing(ctx context.Context, name string, version int64) error
  • func (d DB) DeleteThingWithDateRange(ctx context.Context, name string, date strfmt.DateTime) error
  • func (d DB) DeleteThingWithUnderscores(ctx context.Context, idApp string) error
  • func (d DB) GetSimpleThing(ctx context.Context, name string) (*models.SimpleThing, error)
  • func (d DB) GetThing(ctx context.Context, name string, version int64) (*models.Thing, error)
  • func (d DB) GetThingByID(ctx context.Context, id string) (*models.Thing, error)
  • func (d DB) GetThingWithDateRange(ctx context.Context, name string, date strfmt.DateTime) (*models.ThingWithDateRange, error)
  • func (d DB) GetThingWithDateRangesByNameAndDate(ctx context.Context, input db.GetThingWithDateRangesByNameAndDateInput) ([]models.ThingWithDateRange, error)
  • func (d DB) GetThingWithUnderscores(ctx context.Context, idApp string) (*models.ThingWithUnderscores, error)
  • func (d DB) GetThingsByNameAndCreatedAt(ctx context.Context, input db.GetThingsByNameAndCreatedAtInput) ([]models.Thing, error)
  • func (d DB) GetThingsByNameAndVersion(ctx context.Context, input db.GetThingsByNameAndVersionInput) ([]models.Thing, error)
  • func (d DB) SaveSimpleThing(ctx context.Context, m models.SimpleThing) error
  • func (d DB) SaveThing(ctx context.Context, m models.Thing) error
  • func (d DB) SaveThingWithDateRange(ctx context.Context, m models.ThingWithDateRange) error
  • func (d DB) SaveThingWithUnderscores(ctx context.Context, m models.ThingWithUnderscores) error
• type SimpleThingTable
• type ThingTable
• type ThingWithDateRangeTable
• type ThingWithUnderscoresTable

Types

type Config

type Config struct {
	// DynamoDBAPI is used to communicate with DynamoDB. It is required.
	// It can be overriden on a table-by-table basis.
	DynamoDBAPI dynamodbiface.DynamoDBAPI

	// DefaultPrefix configures a prefix on all table names. It is required.
	// It can be overriden on a table-by-table basis.
	DefaultPrefix string

	// DefaultWriteCapacityUnits configures a default write capacity when creating tables. It defaults to 1.
	// It can be overriden on a table-by-table basis.
	DefaultWriteCapacityUnits int64

	// DefaultReadCapacityUnits configures a default read capacity when creating tables. It defaults to 1.
	// It can be overriden on a table-by-table basis.
	DefaultReadCapacityUnits int64
	// SimpleThingTable configuration.
	SimpleThingTable SimpleThingTable
	// ThingTable configuration.
	ThingTable ThingTable
	// ThingWithDateRangeTable configuration.
	ThingWithDateRangeTable ThingWithDateRangeTable
	// ThingWithUnderscoresTable configuration.
	ThingWithUnderscoresTable ThingWithUnderscoresTable
}

Config is used to create a new DB struct.

type DB

type DB struct {
	// contains filtered or unexported fields
}

DB implements the database interface using DynamoDB to store data.

func New

func New(config Config) (*DB, error)

New creates a new DB object.

func (DB) CreateTables

func (d DB) CreateTables(ctx context.Context) error

CreateTables creates all tables.

func (DB) DeleteSimpleThing

func (d DB) DeleteSimpleThing(ctx context.Context, name string) error

DeleteSimpleThing deletes a SimpleThing from the database.

func (DB) DeleteThing

func (d DB) DeleteThing(ctx context.Context, name string, version int64) error

DeleteThing deletes a Thing from the database.

func (DB) DeleteThingWithDateRange

func (d DB) DeleteThingWithDateRange(ctx context.Context, name string, date strfmt.DateTime) error

DeleteThingWithDateRange deletes a ThingWithDateRange from the database.

func (DB) DeleteThingWithUnderscores

func (d DB) DeleteThingWithUnderscores(ctx context.Context, idApp string) error

DeleteThingWithUnderscores deletes a ThingWithUnderscores from the database.

func (DB) GetSimpleThing

func (d DB) GetSimpleThing(ctx context.Context, name string) (*models.SimpleThing, error)

GetSimpleThing retrieves a SimpleThing from the database.

func (DB) GetThing

func (d DB) GetThing(ctx context.Context, name string, version int64) (*models.Thing, error)

GetThing retrieves a Thing from the database.

func (DB) GetThingByID

func (d DB) GetThingByID(ctx context.Context, id string) (*models.Thing, error)

GetThingByID retrieves a Thing from the database.

func (DB) GetThingWithDateRange

func (d DB) GetThingWithDateRange(ctx context.Context, name string, date strfmt.DateTime) (*models.ThingWithDateRange, error)

GetThingWithDateRange retrieves a ThingWithDateRange from the database.

func (DB) GetThingWithDateRangesByNameAndDate

func (d DB) GetThingWithDateRangesByNameAndDate(ctx context.Context, input db.GetThingWithDateRangesByNameAndDateInput) ([]models.ThingWithDateRange, error)

GetThingWithDateRangesByNameAndDate retrieves a list of ThingWithDateRanges from the database.

func (DB) GetThingWithUnderscores

func (d DB) GetThingWithUnderscores(ctx context.Context, idApp string) (*models.ThingWithUnderscores, error)

GetThingWithUnderscores retrieves a ThingWithUnderscores from the database.

func (DB) GetThingsByNameAndCreatedAt

func (d DB) GetThingsByNameAndCreatedAt(ctx context.Context, input db.GetThingsByNameAndCreatedAtInput) ([]models.Thing, error)

GetThingsByNameAndCreatedAt retrieves a list of Things from the database.

func (DB) GetThingsByNameAndVersion

func (d DB) GetThingsByNameAndVersion(ctx context.Context, input db.GetThingsByNameAndVersionInput) ([]models.Thing, error)

GetThingsByNameAndVersion retrieves a list of Things from the database.

func (DB) SaveSimpleThing

func (d DB) SaveSimpleThing(ctx context.Context, m models.SimpleThing) error

SaveSimpleThing saves a SimpleThing to the database.

func (DB) SaveThing

func (d DB) SaveThing(ctx context.Context, m models.Thing) error

SaveThing saves a Thing to the database.

func (DB) SaveThingWithDateRange

func (d DB) SaveThingWithDateRange(ctx context.Context, m models.ThingWithDateRange) error

SaveThingWithDateRange saves a ThingWithDateRange to the database.

func (DB) SaveThingWithUnderscores

func (d DB) SaveThingWithUnderscores(ctx context.Context, m models.ThingWithUnderscores) error

SaveThingWithUnderscores saves a ThingWithUnderscores to the database.

type SimpleThingTable

type SimpleThingTable struct {
	DynamoDBAPI        dynamodbiface.DynamoDBAPI
	Prefix             string
	TableName          string
	ReadCapacityUnits  int64
	WriteCapacityUnits int64
}

SimpleThingTable represents the user-configurable properties of the SimpleThing table.

type ThingTable

type ThingTable struct {
	DynamoDBAPI        dynamodbiface.DynamoDBAPI
	Prefix             string
	TableName          string
	ReadCapacityUnits  int64
	WriteCapacityUnits int64
}

ThingTable represents the user-configurable properties of the Thing table.

type ThingWithDateRangeTable

type ThingWithDateRangeTable struct {
	DynamoDBAPI        dynamodbiface.DynamoDBAPI
	Prefix             string
	TableName          string
	ReadCapacityUnits  int64
	WriteCapacityUnits int64
}

ThingWithDateRangeTable represents the user-configurable properties of the ThingWithDateRange table.

type ThingWithUnderscoresTable

type ThingWithUnderscoresTable struct {
	DynamoDBAPI        dynamodbiface.DynamoDBAPI
	Prefix             string
	TableName          string
	ReadCapacityUnits  int64
	WriteCapacityUnits int64
}

ThingWithUnderscoresTable represents the user-configurable properties of the ThingWithUnderscores table.