store

package
v0.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 17, 2017 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	BucketKeyRaftState = []byte("raft_hard_state")

	BucketKeyData = []byte("data")
)
View Source
var (
	ErrAppUnknown              = errors.New("boltdb: app unknown")
	ErrTaskUnknown             = errors.New("boltdb: task unknown")
	ErrVersionUnknown          = errors.New("boltdb: version unknown")
	ErrSlotUnknown             = errors.New("boltdb: slot unknow")
	ErrNodeUnknown             = errors.New("boltdb: node unknow")
	ErrNilStoreAction          = errors.New("boltdb: nil store action")
	ErrUndefineStoreAction     = errors.New("boltdb: undefined store action")
	ErrUndefineAppStoreAction  = errors.New("boltdb: undefined app store action")
	ErrUndefineFrameworkAction = errors.New("boltdb: undefined framework store action")
	ErrUndefineTaskAction      = errors.New("boltdb: undefined task store action")
	ErrUndefineVersionAction   = errors.New("boltdb: undefined version store action")
	ErrUndefineSlotAction      = errors.New("boltdb: undefined slot store action")
	ErrUndefineNodeAction      = errors.New("boltdb: undefined node store action")
)

Functions

func GetAppBucket

func GetAppBucket(tx *bolt.Tx, id string) *bolt.Bucket

func GetAppsBucket

func GetAppsBucket(tx *bolt.Tx) *bolt.Bucket

func GetFrameworkBucket

func GetFrameworkBucket(tx *bolt.Tx) *bolt.Bucket

func GetOfferAllocatorItemBucket

func GetOfferAllocatorItemBucket(tx *bolt.Tx) *bolt.Bucket

func GetSlotBucket

func GetSlotBucket(tx *bolt.Tx, appId, slotId string) *bolt.Bucket

func GetSlotsBucket

func GetSlotsBucket(tx *bolt.Tx, appId string) *bolt.Bucket

func GetTaskBucket

func GetTaskBucket(tx *bolt.Tx, appID, slotID, taskID string) *bolt.Bucket

func GetTasksBucket

func GetTasksBucket(tx *bolt.Tx, appID, slotID string) *bolt.Bucket

func GetVersionBucket

func GetVersionBucket(tx *bolt.Tx, appID, versionID string) *bolt.Bucket

func GetVersionsBucket

func GetVersionsBucket(tx *bolt.Tx, appID string) *bolt.Bucket

func WithAppBucket

func WithAppBucket(tx *bolt.Tx, id string, fn func(bkt *bolt.Bucket) error) error

func WithFrameworkBucket

func WithFrameworkBucket(tx *bolt.Tx, fn func(bkt *bolt.Bucket) error) error

func WithOfferAllocatorItemBucket

func WithOfferAllocatorItemBucket(tx *bolt.Tx, fn func(bkt *bolt.Bucket) error) error

func WithSlotBucket

func WithSlotBucket(tx *bolt.Tx, appID, slotID string, fn func(bkt *bolt.Bucket) error) error

func WithTaskBucket

func WithTaskBucket(tx *bolt.Tx, appID, slotID, taskID string, fn func(bkt *bolt.Bucket) error) error

func WithVersionBucket

func WithVersionBucket(tx *bolt.Tx, appID, versionID string, fn func(bkt *bolt.Bucket) error) error

Types

type BoltbDb

type BoltbDb struct {
	*bolt.DB
}

func NewBoltbdStore

func NewBoltbdStore(db *bolt.DB) (*BoltbDb, error)

func (*BoltbDb) DoStoreActions

func (db *BoltbDb) DoStoreActions(actions []*types.StoreAction) error

func (*BoltbDb) GetNodes added in v0.1.3

func (db *BoltbDb) GetNodes() ([]*types.Node, error)

func (*BoltbDb) GetRaftState

func (db *BoltbDb) GetRaftState() (raftpb.HardState, error)

func (*BoltbDb) SaveRaftState

func (db *BoltbDb) SaveRaftState(state raftpb.HardState) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL