state

type AccountAdapter interface {
	Save(account *types.Account) error
	Get(base.Bytes) (*types.Account, error)
	KeyFor(base.Bytes) base.Bytes
}

type CacheState interface {
	State
	Write() error
}

type CommitState interface {
	Version() int64
	Hash() []byte
	Commit() ([]byte, int64, error)
	Get(key []byte) []byte
	GetRange([]byte, []byte, int) ([][]byte, [][]byte, error)
	Set(key, val []byte)
	Remove(key []byte)

	Account() AccountAdapter
	Deployment() DeploymentAdapter
	Provider() ProviderAdapter
	Order() OrderAdapter
	DeploymentGroup() DeploymentGroupAdapter
	Fulfillment() FulfillmentAdapter
	Lease() LeaseAdapter
}

type DB interface {
	DBReader
	Commit() ([]byte, int64, error)
	Set(key, val []byte)
	Remove(key []byte)
}

type DBReader interface {
	IsEmpty() bool
	Version() int64
	Hash() []byte
	Get(key []byte) []byte
	GetRange([]byte, []byte, int) ([][]byte, [][]byte, error)
}

type DeploymentAdapter interface {
	Save(deployment *types.Deployment) error
	Get(base.Bytes) (*types.Deployment, error)
	GetMaxRange() (*types.Deployments, error)
	KeyFor(base.Bytes) base.Bytes
	SequenceFor(base.Bytes) Sequence
}

type DeploymentGroupAdapter interface {
	Save(*types.DeploymentGroup) error
	Get(id types.DeploymentGroupID) (*types.DeploymentGroup, error)
	All() ([]*types.DeploymentGroup, error)
	ForDeployment(addr base.Bytes) ([]*types.DeploymentGroup, error)
}

type FulfillmentAdapter interface {
	Save(*types.Fulfillment) error
	Get(id types.FulfillmentID) (*types.Fulfillment, error)
	ForDeployment(base.Bytes) ([]*types.Fulfillment, error)
	ForGroup(types.DeploymentGroupID) ([]*types.Fulfillment, error)
	ForOrder(types.OrderID) ([]*types.Fulfillment, error)
	All() ([]*types.Fulfillment, error)
}

type LeaseAdapter interface {
	Save(*types.Lease) error
	Get(types.LeaseID) (*types.Lease, error)
	ForDeployment(deployment base.Bytes) ([]*types.Lease, error)
	All() ([]*types.Lease, error)
}

type OrderAdapter interface {
	Save(*types.Order) error
	Get(types.OrderID) (*types.Order, error)
	ForDeployment(base.Bytes) ([]*types.Order, error)
	ForGroup(types.DeploymentGroupID) ([]*types.Order, error)
	All() ([]*types.Order, error)
}

type ProviderAdapter interface {
	Save(provider *types.Provider) error
	Get(base.Bytes) (*types.Provider, error)
	GetMaxRange() (*types.Providers, error)
	GetRange(base.Bytes, base.Bytes, int) ([][]byte, *types.Providers, error)
	KeyFor(base.Bytes) base.Bytes
}

type Sequence interface {
	Current() uint64
	Advance() uint64
	Next() uint64
}

type State interface {
	Get(key []byte) []byte
	Set(key, val []byte)
	Remove(key []byte)
	GetRange([]byte, []byte, int) ([][]byte, [][]byte, error)
	Version() int64

	Account() AccountAdapter
	Deployment() DeploymentAdapter
	Provider() ProviderAdapter
	Order() OrderAdapter
	DeploymentGroup() DeploymentGroupAdapter
	Fulfillment() FulfillmentAdapter
	Lease() LeaseAdapter
}