state

Documentation

Index

• type StateStore
  • func NewInmemStore(t *testing.T) *StateStore
  • func NewStateStore(path string) (*StateStore, error)
  • func NewStateStoreWithBoltDB(db *bolt.DB) (*StateStore, error)
  • func (s *StateStore) AllocationList(ws memdb.WatchSet) ([]*proto.Allocation, error)
  • func (s *StateStore) AllocationListByNodeId(nodeId string, ws memdb.WatchSet) ([]*proto.Allocation, error)
  • func (s *StateStore) AllocationsByIDPrefix(prefix string) ([]*proto.Allocation, error)
  • func (s *StateStore) Close() error
  • func (s *StateStore) DestroyAllocation(id string) error
  • func (s *StateStore) GetAllocation(id string) (*proto.Allocation, error)
  • func (s *StateStore) UpsertAllocation(alloc *proto.Allocation) error

Types

type StateStore

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

func NewInmemStore

func NewInmemStore(t *testing.T) *StateStore

func NewStateStore

func NewStateStore(path string) (*StateStore, error)

func NewStateStoreWithBoltDB

func NewStateStoreWithBoltDB(db *bolt.DB) (*StateStore, error)

func (*StateStore) AllocationList

func (s *StateStore) AllocationList(ws memdb.WatchSet) ([]*proto.Allocation, error)

func (*StateStore) AllocationListByNodeId

func (s *StateStore) AllocationListByNodeId(nodeId string, ws memdb.WatchSet) ([]*proto.Allocation, error)

func (*StateStore) AllocationsByIDPrefix

func (s *StateStore) AllocationsByIDPrefix(prefix string) ([]*proto.Allocation, error)

func (*StateStore) Close

func (s *StateStore) Close() error

func (*StateStore) DestroyAllocation

func (s *StateStore) DestroyAllocation(id string) error

func (*StateStore) GetAllocation

func (s *StateStore) GetAllocation(id string) (*proto.Allocation, error)

func (*StateStore) UpsertAllocation

func (s *StateStore) UpsertAllocation(alloc *proto.Allocation) error