dynamodb

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

type ItemIdentifier struct {
	Id         string `json:"Id"`
	ObjectType string `json:"ObjectType"`
}

type ItemKey interface {
	GetId() string
	GetObjectType() string
}

type ItemLock struct {

	// ItemIdentifier for locked item.
	*ItemIdentifier

	// ExpiresAt is the life time of a lock in epoch seconds.
	ExpiresAt int64

	// LockId is an id to identify a lock.
	LockId string
}

type QueryRequest struct {

	// ObjectType items should be read for.
	ObjectType string

	// Items will contain a pointer to a slice of desired items.
	// It's used to define the type of items which should be returned.
	Items interface{}
}

type Repository interface {

	// Add or update an item in DynamoDb.
	Add(ItemKey) error

	// Get will try to read an item by specified key from DynamoDb.
	Get(ItemKey) error

	// Query will list all items for an object type.
	Query(string, interface{}) error

	// Delete will remove an item with specified key from DynamoDb.
	Delete(ItemKey) error

	// Lock will try to obtain a lock for an items identified by passed key.
	Lock(ItemKey) (*ItemLock, error)

	// Renew can be used to extend lease of an item lock.
	Renew(*ItemLock) (*ItemLock, error)

	// Unlock will delete passed object lock from DynamoDb.
	Unlock(*ItemLock) error
}