Documentation ¶
Index ¶
- Variables
- func GetAppBucket(tx *bolt.Tx, id string) *bolt.Bucket
- func GetAppsBucket(tx *bolt.Tx) *bolt.Bucket
- func GetFrameworkBucket(tx *bolt.Tx) *bolt.Bucket
- func GetOfferAllocatorItemBucket(tx *bolt.Tx) *bolt.Bucket
- func GetSlotBucket(tx *bolt.Tx, appId, slotId string) *bolt.Bucket
- func GetSlotsBucket(tx *bolt.Tx, appId string) *bolt.Bucket
- func GetTaskBucket(tx *bolt.Tx, appID, slotID, taskID string) *bolt.Bucket
- func GetTasksBucket(tx *bolt.Tx, appID, slotID string) *bolt.Bucket
- func GetVersionBucket(tx *bolt.Tx, appID, versionID string) *bolt.Bucket
- func GetVersionsBucket(tx *bolt.Tx, appID string) *bolt.Bucket
- func WithAppBucket(tx *bolt.Tx, id string, fn func(bkt *bolt.Bucket) error) error
- func WithFrameworkBucket(tx *bolt.Tx, fn func(bkt *bolt.Bucket) error) error
- func WithSlotBucket(tx *bolt.Tx, appID, slotID string, fn func(bkt *bolt.Bucket) error) error
- func WithTaskBucket(tx *bolt.Tx, appID, slotID, taskID string, fn func(bkt *bolt.Bucket) error) error
- func WithVersionBucket(tx *bolt.Tx, appID, versionID string, fn func(bkt *bolt.Bucket) error) error
- type BoltbDb
- func (db *BoltbDb) DoStoreActions(actions []*types.StoreAction) error
- func (db *BoltbDb) GetNode(nodeID string) (*types.Node, error)
- func (db *BoltbDb) GetNodes() ([]*types.Node, error)
- func (db *BoltbDb) GetRaftState() (raftpb.HardState, error)
- func (db *BoltbDb) SaveRaftState(state raftpb.HardState) error
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 WithAppBucket ¶
func WithFrameworkBucket ¶
func WithSlotBucket ¶
func WithTaskBucket ¶
Types ¶
type BoltbDb ¶
func NewBoltbdStore ¶
func (*BoltbDb) DoStoreActions ¶
func (db *BoltbDb) DoStoreActions(actions []*types.StoreAction) error
Click to show internal directories.
Click to hide internal directories.