store

package
v0.1.9 Latest Latest
Warning

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

Go to latest
Published: Mar 20, 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")
	ErrUndefineOfferAllocatorItemAction = errors.New("boltdb: undefined offer_allocator_item 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 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

func (*BoltbDb) DoStoreActions

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

func (*BoltbDb) GetNode added in v0.1.7

func (db *BoltbDb) GetNode(nodeID string) (*types.Node, 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