summaryrefslogtreecommitdiff
path: root/libpod/boltdb_state_internal.go
diff options
context:
space:
mode:
Diffstat (limited to 'libpod/boltdb_state_internal.go')
-rw-r--r--libpod/boltdb_state_internal.go20
1 files changed, 20 insertions, 0 deletions
diff --git a/libpod/boltdb_state_internal.go b/libpod/boltdb_state_internal.go
index 8b4e8e28c..c8aa4adbf 100644
--- a/libpod/boltdb_state_internal.go
+++ b/libpod/boltdb_state_internal.go
@@ -17,6 +17,8 @@ const (
netNSName = "net-ns"
runtimeConfigName = "runtime-config"
ctrDependsName = "container-depends"
+ podName = "pod"
+ podContainersName = "pod-containers"
)
var (
@@ -27,6 +29,8 @@ var (
netNSBkt = []byte(netNSName)
runtimeConfigBkt = []byte(runtimeConfigName)
ctrDependsBkt = []byte(ctrDependsName)
+ podBkt = []byte(podName)
+ podContainersBkt = []byte(podContainersName)
)
// Check if the configuration of the database is compatible with the
@@ -158,6 +162,22 @@ func getCtrDependsBucket(tx *bolt.Tx) (*bolt.Bucket, error) {
return bkt, nil
}
+func getPodBucket(tx *bolt.Tx) (*bolt.Bucket, error) {
+ bkt := tx.Bucket(podBkt)
+ if bkt == nil {
+ return nil, errors.Wrapf(ErrDBBadConfig, "pods bucket not found in DB")
+ }
+ return bkt, nil
+}
+
+func getPodContainersBucket(tx *bolt.Tx) (*bolt.Bucket, error) {
+ bkt := tx.Bucket(podContainersBkt)
+ if bkt == nil {
+ return nil, errors.Wrapf(ErrDBBadConfig, "pod containers bucket not found in DB")
+ }
+ return bkt, nil
+}
+
func (s *BoltState) getContainerFromDB(id []byte, ctr *Container, config, state, netNS *bolt.Bucket) error {
configBytes := config.Get(id)
if configBytes == nil {