dynamodb

package
v2.0.1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 17, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
	// TeacherSharingRuleTable configuration.
	TeacherSharingRuleTable TeacherSharingRuleTable
	// ThingTable configuration.
	ThingTable ThingTable
	// ThingWithCompositeAttributesTable configuration.
	ThingWithCompositeAttributesTable ThingWithCompositeAttributesTable
	// ThingWithCompositeEnumAttributesTable configuration.
	ThingWithCompositeEnumAttributesTable ThingWithCompositeEnumAttributesTable
	// ThingWithDateRangeTable configuration.
	ThingWithDateRangeTable ThingWithDateRangeTable
	// ThingWithDateTimeCompositeTable configuration.
	ThingWithDateTimeCompositeTable ThingWithDateTimeCompositeTable
	// ThingWithRequiredFieldsTable configuration.
	ThingWithRequiredFieldsTable ThingWithRequiredFieldsTable
	// 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) DeleteTeacherSharingRule added in v1.12.0 

func (d DB) DeleteTeacherSharingRule(ctx context.Context, teacher string, school string, app string) error

DeleteTeacherSharingRule deletes a TeacherSharingRule 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) DeleteThingWithCompositeAttributes added in v1.12.0 

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

DeleteThingWithCompositeAttributes deletes a ThingWithCompositeAttributes from the database.

func (DB) DeleteThingWithCompositeEnumAttributes added in v1.14.0 

func (d DB) DeleteThingWithCompositeEnumAttributes(ctx context.Context, name string, branchID models.Branch, date strfmt.DateTime) error

DeleteThingWithCompositeEnumAttributes deletes a ThingWithCompositeEnumAttributes 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) DeleteThingWithDateTimeComposite added in v1.14.1 

func (d DB) DeleteThingWithDateTimeComposite(ctx context.Context, typeVar string, id string, created strfmt.DateTime, resource string) error

DeleteThingWithDateTimeComposite deletes a ThingWithDateTimeComposite from the database.

func (DB) DeleteThingWithRequiredFields added in v1.13.0 

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

DeleteThingWithRequiredFields deletes a ThingWithRequiredFields from the database.

func (DB) DeleteThingWithUnderscores added in v1.7.1 

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) GetTeacherSharingRule added in v1.12.0 

func (d DB) GetTeacherSharingRule(ctx context.Context, teacher string, school string, app string) (*models.TeacherSharingRule, error)

GetTeacherSharingRule retrieves a TeacherSharingRule from the database.

func (DB) GetTeacherSharingRulesByDistrictAndSchoolTeacherApp added in v1.12.0 

func (d DB) GetTeacherSharingRulesByDistrictAndSchoolTeacherApp(ctx context.Context, input db.GetTeacherSharingRulesByDistrictAndSchoolTeacherAppInput, fn func(m *models.TeacherSharingRule, lastTeacherSharingRule bool) bool) error

GetTeacherSharingRulesByDistrictAndSchoolTeacherApp retrieves a page of TeacherSharingRules from the database.

func (DB) GetTeacherSharingRulesByTeacherAndSchoolApp added in v1.12.0 

func (d DB) GetTeacherSharingRulesByTeacherAndSchoolApp(ctx context.Context, input db.GetTeacherSharingRulesByTeacherAndSchoolAppInput, fn func(m *models.TeacherSharingRule, lastTeacherSharingRule bool) bool) error

GetTeacherSharingRulesByTeacherAndSchoolApp retrieves a page of TeacherSharingRules 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 added in v1.8.0 

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

GetThingByID retrieves a Thing from the database.

func (DB) GetThingWithCompositeAttributes added in v1.12.0 

func (d DB) GetThingWithCompositeAttributes(ctx context.Context, name string, branch string, date strfmt.DateTime) (*models.ThingWithCompositeAttributes, error)

GetThingWithCompositeAttributes retrieves a ThingWithCompositeAttributes from the database.

func (DB) GetThingWithCompositeAttributessByNameBranchAndDate added in v1.12.0 

func (d DB) GetThingWithCompositeAttributessByNameBranchAndDate(ctx context.Context, input db.GetThingWithCompositeAttributessByNameBranchAndDateInput, fn func(m *models.ThingWithCompositeAttributes, lastThingWithCompositeAttributes bool) bool) error

GetThingWithCompositeAttributessByNameBranchAndDate retrieves a page of ThingWithCompositeAttributess from the database.

func (DB) GetThingWithCompositeAttributessByNameVersionAndDate added in v1.12.0 

func (d DB) GetThingWithCompositeAttributessByNameVersionAndDate(ctx context.Context, input db.GetThingWithCompositeAttributessByNameVersionAndDateInput, fn func(m *models.ThingWithCompositeAttributes, lastThingWithCompositeAttributes bool) bool) error

GetThingWithCompositeAttributessByNameVersionAndDate retrieves a page of ThingWithCompositeAttributess from the database.

func (DB) GetThingWithCompositeEnumAttributes added in v1.14.0 

func (d DB) GetThingWithCompositeEnumAttributes(ctx context.Context, name string, branchID models.Branch, date strfmt.DateTime) (*models.ThingWithCompositeEnumAttributes, error)

GetThingWithCompositeEnumAttributes retrieves a ThingWithCompositeEnumAttributes from the database.

func (DB) GetThingWithCompositeEnumAttributessByNameBranchAndDate added in v1.14.0 

func (d DB) GetThingWithCompositeEnumAttributessByNameBranchAndDate(ctx context.Context, input db.GetThingWithCompositeEnumAttributessByNameBranchAndDateInput, fn func(m *models.ThingWithCompositeEnumAttributes, lastThingWithCompositeEnumAttributes bool) bool) error

GetThingWithCompositeEnumAttributessByNameBranchAndDate retrieves a page of ThingWithCompositeEnumAttributess 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 added in v1.8.0 

func (d DB) GetThingWithDateRangesByNameAndDate(ctx context.Context, input db.GetThingWithDateRangesByNameAndDateInput, fn func(m *models.ThingWithDateRange, lastThingWithDateRange bool) bool) error

GetThingWithDateRangesByNameAndDate retrieves a page of ThingWithDateRanges from the database.

func (DB) GetThingWithDateTimeComposite added in v1.14.1 

func (d DB) GetThingWithDateTimeComposite(ctx context.Context, typeVar string, id string, created strfmt.DateTime, resource string) (*models.ThingWithDateTimeComposite, error)

GetThingWithDateTimeComposite retrieves a ThingWithDateTimeComposite from the database.

func (DB) GetThingWithDateTimeCompositesByTypeIDAndCreatedResource added in v1.14.1 

func (d DB) GetThingWithDateTimeCompositesByTypeIDAndCreatedResource(ctx context.Context, input db.GetThingWithDateTimeCompositesByTypeIDAndCreatedResourceInput, fn func(m *models.ThingWithDateTimeComposite, lastThingWithDateTimeComposite bool) bool) error

GetThingWithDateTimeCompositesByTypeIDAndCreatedResource retrieves a page of ThingWithDateTimeComposites from the database.

func (DB) GetThingWithRequiredFields added in v1.13.0 

func (d DB) GetThingWithRequiredFields(ctx context.Context, name string) (*models.ThingWithRequiredFields, error)

GetThingWithRequiredFields retrieves a ThingWithRequiredFields from the database.

func (DB) GetThingWithUnderscores added in v1.7.1 

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

GetThingWithUnderscores retrieves a ThingWithUnderscores from the database.

func (DB) GetThingsByNameAndCreatedAt added in v1.8.0 

func (d DB) GetThingsByNameAndCreatedAt(ctx context.Context, input db.GetThingsByNameAndCreatedAtInput, fn func(m *models.Thing, lastThing bool) bool) error

GetThingsByNameAndCreatedAt retrieves a page of Things from the database.

func (DB) GetThingsByNameAndVersion added in v1.8.0 

func (d DB) GetThingsByNameAndVersion(ctx context.Context, input db.GetThingsByNameAndVersionInput, fn func(m *models.Thing, lastThing bool) bool) error

GetThingsByNameAndVersion retrieves a page 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) SaveTeacherSharingRule added in v1.12.0 

func (d DB) SaveTeacherSharingRule(ctx context.Context, m models.TeacherSharingRule) error

SaveTeacherSharingRule saves a TeacherSharingRule 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) SaveThingWithCompositeAttributes added in v1.12.0 

func (d DB) SaveThingWithCompositeAttributes(ctx context.Context, m models.ThingWithCompositeAttributes) error

SaveThingWithCompositeAttributes saves a ThingWithCompositeAttributes to the database.

func (DB) SaveThingWithCompositeEnumAttributes added in v1.14.0 

func (d DB) SaveThingWithCompositeEnumAttributes(ctx context.Context, m models.ThingWithCompositeEnumAttributes) error

SaveThingWithCompositeEnumAttributes saves a ThingWithCompositeEnumAttributes 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) SaveThingWithDateTimeComposite added in v1.14.1 

func (d DB) SaveThingWithDateTimeComposite(ctx context.Context, m models.ThingWithDateTimeComposite) error

SaveThingWithDateTimeComposite saves a ThingWithDateTimeComposite to the database.

func (DB) SaveThingWithRequiredFields added in v1.13.0 

func (d DB) SaveThingWithRequiredFields(ctx context.Context, m models.ThingWithRequiredFields) error

SaveThingWithRequiredFields saves a ThingWithRequiredFields to the database.

func (DB) SaveThingWithUnderscores added in v1.7.1 

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

SaveThingWithUnderscores saves a ThingWithUnderscores to the database.

func (DB) ScanThings added in v1.13.1 

func (d DB) ScanThings(ctx context.Context, input db.ScanThingsInput, fn func(m *models.Thing, lastThing bool) bool) error

ScanThings runs a scan on the Things table.

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 TeacherSharingRuleTable added in v1.12.0 

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

TeacherSharingRuleTable represents the user-configurable properties of the TeacherSharingRule 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 ThingWithCompositeAttributesTable added in v1.12.0 

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

ThingWithCompositeAttributesTable represents the user-configurable properties of the ThingWithCompositeAttributes table.

type ThingWithCompositeEnumAttributesTable added in v1.14.0 

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

ThingWithCompositeEnumAttributesTable represents the user-configurable properties of the ThingWithCompositeEnumAttributes 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 ThingWithDateTimeCompositeTable added in v1.14.1 

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

ThingWithDateTimeCompositeTable represents the user-configurable properties of the ThingWithDateTimeComposite table.

type ThingWithRequiredFieldsTable added in v1.13.0 

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

ThingWithRequiredFieldsTable represents the user-configurable properties of the ThingWithRequiredFields table.

type ThingWithUnderscoresTable added in v1.7.1 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.