state

Documentation

Index

• type BoltdbStore
  • func NewBoltdbStore(path string) (*BoltdbStore, error)
  • func NewBoltdbStoreWithDB(db *bolt.DB) (*BoltdbStore, error)
  • func NewInmemStore(t *testing.T) *BoltdbStore
  • func (s *BoltdbStore) Close() error
  • func (s *BoltdbStore) DeleteAllocationBucket(allocID string) error
  • func (s *BoltdbStore) GetAllocations() ([]*proto.Allocation, error)
  • func (s *BoltdbStore) GetTaskState(allocID, taskName string) (*proto.TaskState, *proto.TaskHandle, error)
  • func (s *BoltdbStore) PutAllocation(a *proto.Allocation) error
  • func (s *BoltdbStore) PutTaskLocalState(allocID string, taskName string, handle *proto.TaskHandle) error
  • func (s *BoltdbStore) PutTaskState(allocID string, taskName string, state *proto.TaskState) error
• type State

Types

type BoltdbStore

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

func NewBoltdbStore

func NewBoltdbStore(path string) (*BoltdbStore, error)

func NewBoltdbStoreWithDB

func NewBoltdbStoreWithDB(db *bolt.DB) (*BoltdbStore, error)

func NewInmemStore

func NewInmemStore(t *testing.T) *BoltdbStore

func (*BoltdbStore) Close

func (s *BoltdbStore) Close() error

func (*BoltdbStore) DeleteAllocationBucket

func (s *BoltdbStore) DeleteAllocationBucket(allocID string) error

func (*BoltdbStore) GetAllocations

func (s *BoltdbStore) GetAllocations() ([]*proto.Allocation, error)

func (*BoltdbStore) GetTaskState

func (s *BoltdbStore) GetTaskState(allocID, taskName string) (*proto.TaskState, *proto.TaskHandle, error)

func (*BoltdbStore) PutAllocation

func (s *BoltdbStore) PutAllocation(a *proto.Allocation) error

func (*BoltdbStore) PutTaskLocalState

func (s *BoltdbStore) PutTaskLocalState(allocID string, taskName string, handle *proto.TaskHandle) error

func (*BoltdbStore) PutTaskState

func (s *BoltdbStore) PutTaskState(allocID string, taskName string, state *proto.TaskState) error

type State

type State interface {
	PutTaskLocalState(allocID string, taskName string, handle *proto.TaskHandle) error
	GetTaskState(allocID, taskName string) (*proto.TaskState, *proto.TaskHandle, error)
	PutTaskState(allocID string, taskName string, state *proto.TaskState) error
	GetAllocations() ([]*proto.Allocation, error)
	PutAllocation(a *proto.Allocation) error
	DeleteAllocationBucket(allocId string) error
	Close() error
}