dynamodb

Documentation

Index

• type DynamoDB
  • func New(cfg aws.Config, tableName string, registry Registry) *DynamoDB
  • func (d *DynamoDB) CreateTable(ctx context.Context, rcu, wcu int64) error
  • func (d *DynamoDB) DeleteResource(ctx context.Context, project string, res *resource.Deployed) error
  • func (d *DynamoDB) GetGraph(ctx context.Context, project string) (*resource.Graph, error)
  • func (d *DynamoDB) ListResources(ctx context.Context, project string) ([]*resource.Deployed, error)
  • func (d *DynamoDB) PutGraph(ctx context.Context, project string, g *resource.Graph) error
  • func (d *DynamoDB) PutResource(ctx context.Context, project string, res *resource.Deployed) error
• type Registry

Types

type DynamoDB

type DynamoDB struct {
	Client    dynamodbiface.ClientAPI
	TableName string
	Registry  Registry
}

DynamoDB stores data in AWS DynamoDB

func New

func New(cfg aws.Config, tableName string, registry Registry) *DynamoDB

New creates a new DynamoDB client.

func (*DynamoDB) CreateTable

func (d *DynamoDB) CreateTable(ctx context.Context, rcu, wcu int64) error

CreateTable creates the DynamoDB table.

func (*DynamoDB) DeleteResource

func (d *DynamoDB) DeleteResource(ctx context.Context, project string, res *resource.Deployed) error

DeleteResource deletes a resource. Returns an error if the resource does not exist.

func (*DynamoDB) GetGraph

func (d *DynamoDB) GetGraph(ctx context.Context, project string) (*resource.Graph, error)

GetGraph returns a graph for a project. Returns nil if the project does not have a graph.

func (*DynamoDB) ListResources

func (d *DynamoDB) ListResources(ctx context.Context, project string) ([]*resource.Deployed, error)

ListResources lists all resources in a project. The order of the results is not guaranteed.

func (*DynamoDB) PutGraph

func (d *DynamoDB) PutGraph(ctx context.Context, project string, g *resource.Graph) error

PutGraph creates or updates a graph.

func (*DynamoDB) PutResource

func (d *DynamoDB) PutResource(ctx context.Context, project string, res *resource.Deployed) error

PutResource creates or updates a resource.

type Registry

type Registry interface {
	Type(typename string) reflect.Type
}

The Registry returns types for unmarshalling resource inputs/outputs.