dynamo

Documentation

Index

• type Storage
  • func New(table, region string) (s *Storage, err error)
  • func NewFromExisting(table string, svc dynamodbiface.DynamoDBAPI) (s *Storage, err error)
  • func (s *Storage) AddKeygroupTrigger(kg string, id string, host string) error
  • func (s *Storage) Append(kg, val string, expiry int) (string, error)
  • func (s *Storage) Close() error
  • func (s *Storage) CreateKeygroup(kg string) error
  • func (s *Storage) Delete(kg string, id string) error
  • func (s *Storage) DeleteKeygroup(kg string) error
  • func (s *Storage) DeleteKeygroupTrigger(kg string, id string) error
  • func (s *Storage) Exists(kg string, id string) bool
  • func (s *Storage) ExistsKeygroup(kg string) bool
  • func (s *Storage) GetKeygroupTrigger(kg string) (map[string]string, error)
  • func (s *Storage) IDs(kg string) ([]string, error)
  • func (s *Storage) Read(kg string, id string) (string, error)
  • func (s *Storage) ReadAll(kg string) (map[string]string, error)
  • func (s *Storage) ReadSome(kg, id string, count uint64) (map[string]string, error)
  • func (s *Storage) Update(kg, id, val string, _ bool, expiry int) error

Types

type Storage

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

Storage is a struct that saves all necessary information to access the database, in this case the session for DynamoDB and the table name.

func New

func New(table, region string) (s *Storage, err error)

New creates a new Session for DynamoDB.

func NewFromExisting

func NewFromExisting(table string, svc dynamodbiface.DynamoDBAPI) (s *Storage, err error)

func (*Storage) AddKeygroupTrigger

func (s *Storage) AddKeygroupTrigger(kg string, id string, host string) error

AddKeygroupTrigger stores a trigger node in the dynamodb database.

func (*Storage) Append

func (s *Storage) Append(kg, val string, expiry int) (string, error)

Append appends the item to the specified keygroup by incrementing the latest key by one.

func (*Storage) Close

func (s *Storage) Close() error

Close closes the underlying DynamoDB connection (no cleanup needed at the moment).

func (*Storage) CreateKeygroup

func (s *Storage) CreateKeygroup(kg string) error

CreateKeygroup creates the given keygroup in the DynamoDB database.

func (*Storage) Delete

func (s *Storage) Delete(kg string, id string) error

Delete deletes the item with the specified id from the specified keygroup.

func (*Storage) DeleteKeygroup

func (s *Storage) DeleteKeygroup(kg string) error

DeleteKeygroup deletes the given keygroup from the DynamoDB database.

func (*Storage) DeleteKeygroupTrigger

func (s *Storage) DeleteKeygroupTrigger(kg string, id string) error

DeleteKeygroupTrigger removes a trigger node from the dynamodb database.

func (*Storage) Exists

func (s *Storage) Exists(kg string, id string) bool

Exists checks if the given data item exists in the dynamodb database.

func (*Storage) ExistsKeygroup

func (s *Storage) ExistsKeygroup(kg string) bool

ExistsKeygroup checks if the given keygroup exists in the DynamoDB database.

func (*Storage) GetKeygroupTrigger

func (s *Storage) GetKeygroupTrigger(kg string) (map[string]string, error)

GetKeygroupTrigger returns a map of all trigger nodes from the dynamodb database.

func (*Storage) IDs

func (s *Storage) IDs(kg string) ([]string, error)

IDs returns the keys of all items in the specified keygroup.

func (*Storage) Read

func (s *Storage) Read(kg string, id string) (string, error)

Read returns an item with the specified id from the specified keygroup.

func (*Storage) ReadAll

func (s *Storage) ReadAll(kg string) (map[string]string, error)

ReadAll returns all items in the specified keygroup.

func (*Storage) ReadSome

func (s *Storage) ReadSome(kg, id string, count uint64) (map[string]string, error)

func (*Storage) Update

func (s *Storage) Update(kg, id, val string, _ bool, expiry int) error

Update updates the item with the specified id in the specified keygroup.