daemondb

Documentation

Index

• Constants
• type DaemonDB
  • func NewDaemonDB(db_file string) (*DaemonDB, error)
  • func (d *DaemonDB) Close() error
  • func (d *DaemonDB) Delete(key []byte) error
  • func (d *DaemonDB) DeletePodVolume(podId, volName string) error
  • func (d *DaemonDB) DeletePodVolumes(podId string) error
  • func (d *DaemonDB) Get(key []byte) ([]byte, error)
  • func (d *DaemonDB) GetPodVolume(podId, volname string) ([]byte, error)
  • func (d *DaemonDB) GetString(key []byte) (string, error)
  • func (d *DaemonDB) LagecyDeleteAllP2V() error
  • func (d *DaemonDB) LagecyDeleteP2C(id string) error
  • func (d *DaemonDB) LagecyDeleteP2V(id string) error
  • func (d *DaemonDB) LagecyDeletePod(id string) error
  • func (d *DaemonDB) LagecyDeleteVM(id string) error
  • func (d *DaemonDB) LagecyDeleteVMByPod(id string) error
  • func (d *DaemonDB) LagecyGetAllPods() chan *KVPair
  • func (d *DaemonDB) LagecyGetP2C(id string) ([]string, error)
  • func (d *DaemonDB) LagecyGetP2V(id string) (string, error)
  • func (d *DaemonDB) LagecyGetPod(id string) ([]byte, error)
  • func (d *DaemonDB) LagecyGetVM(id string) ([]byte, error)
  • func (d *DaemonDB) LagecyListPod() ([][]byte, error)
  • func (d *DaemonDB) LagecyUpdateP2C(id string, containers []string) error
  • func (d *DaemonDB) LagecyUpdateP2V(id, vm string) error
  • func (d *DaemonDB) LagecyUpdatePod(id string, data []byte) error
  • func (d *DaemonDB) LagecyUpdateVM(id string, data []byte) error
  • func (d *DaemonDB) ListPodVolumes(podId string) ([][]byte, error)
  • func (d *DaemonDB) PrefixDelete(prefix []byte) error
  • func (d *DaemonDB) PrefixList(prefix []byte, keyFilter KeyFilter) ([][]byte, error)
  • func (d *DaemonDB) PrefixList2Chan(prefix []byte, keyFilter KeyFilter) chan *KVPair
  • func (d *DaemonDB) PrefixListKey(prefix []byte, keyFilter KeyFilter) ([][]byte, error)
  • func (d *DaemonDB) Update(key, data []byte) error
  • func (d *DaemonDB) UpdatePodVolume(podId, volname string, data []byte) error
• type KVPair
• type KeyFilter

Constants

const (
	VM_KEY            = "vmdata-%s"
	POD_KEY           = "pod-%s"
	POD_VM_KEY        = "vm-%s"
	POD_CONTAINER_KEY = "pod-container-%s"
	POD_VOLUME_KEY    = "vol-%s-%s"

	POD_PREFIX           = "pod-"
	POD_CONTAINER_PREFIX = "pod-container-"
	POD_VOLUME_PREFIX    = "vol-%s"
	POD_VM_PREFIX        = "vm-"
)

Types

type DaemonDB

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

func NewDaemonDB

func NewDaemonDB(db_file string) (*DaemonDB, error)

func (*DaemonDB) Close

func (d *DaemonDB) Close() error

Low level util

func (*DaemonDB) Delete

func (d *DaemonDB) Delete(key []byte) error

func (*DaemonDB) DeletePodVolume

func (d *DaemonDB) DeletePodVolume(podId, volName string) error

func (*DaemonDB) DeletePodVolumes

func (d *DaemonDB) DeletePodVolumes(podId string) error

func (*DaemonDB) Get

func (d *DaemonDB) Get(key []byte) ([]byte, error)

func (*DaemonDB) GetPodVolume

func (d *DaemonDB) GetPodVolume(podId, volname string) ([]byte, error)

func (*DaemonDB) GetString

func (d *DaemonDB) GetString(key []byte) (string, error)

func (*DaemonDB) LagecyDeleteAllP2V

func (d *DaemonDB) LagecyDeleteAllP2V() error

func (*DaemonDB) LagecyDeleteP2C

func (d *DaemonDB) LagecyDeleteP2C(id string) error

func (*DaemonDB) LagecyDeleteP2V

func (d *DaemonDB) LagecyDeleteP2V(id string) error

func (*DaemonDB) LagecyDeletePod

func (d *DaemonDB) LagecyDeletePod(id string) error

func (*DaemonDB) LagecyDeleteVM

func (d *DaemonDB) LagecyDeleteVM(id string) error

func (*DaemonDB) LagecyDeleteVMByPod

func (d *DaemonDB) LagecyDeleteVMByPod(id string) error

Composition Process

func (*DaemonDB) LagecyGetAllPods

func (d *DaemonDB) LagecyGetAllPods() chan *KVPair

func (*DaemonDB) LagecyGetP2C

func (d *DaemonDB) LagecyGetP2C(id string) ([]string, error)

POD to Containers (string to string list)

func (*DaemonDB) LagecyGetP2V

func (d *DaemonDB) LagecyGetP2V(id string) (string, error)

POD to VM (string to string)

func (*DaemonDB) LagecyGetPod

func (d *DaemonDB) LagecyGetPod(id string) ([]byte, error)

Pods podId and args

func (*DaemonDB) LagecyGetVM

func (d *DaemonDB) LagecyGetVM(id string) ([]byte, error)

VM DATA (string to data)

func (*DaemonDB) LagecyListPod

func (d *DaemonDB) LagecyListPod() ([][]byte, error)

func (*DaemonDB) LagecyUpdateP2C

func (d *DaemonDB) LagecyUpdateP2C(id string, containers []string) error

func (*DaemonDB) LagecyUpdateP2V

func (d *DaemonDB) LagecyUpdateP2V(id, vm string) error

func (*DaemonDB) LagecyUpdatePod

func (d *DaemonDB) LagecyUpdatePod(id string, data []byte) error

func (*DaemonDB) LagecyUpdateVM

func (d *DaemonDB) LagecyUpdateVM(id string, data []byte) error

func (*DaemonDB) ListPodVolumes

func (d *DaemonDB) ListPodVolumes(podId string) ([][]byte, error)

func (*DaemonDB) PrefixDelete

func (d *DaemonDB) PrefixDelete(prefix []byte) error

func (*DaemonDB) PrefixList

func (d *DaemonDB) PrefixList(prefix []byte, keyFilter KeyFilter) ([][]byte, error)

func (*DaemonDB) PrefixList2Chan

func (d *DaemonDB) PrefixList2Chan(prefix []byte, keyFilter KeyFilter) chan *KVPair

func (*DaemonDB) PrefixListKey

func (d *DaemonDB) PrefixListKey(prefix []byte, keyFilter KeyFilter) ([][]byte, error)

func (*DaemonDB) Update

func (d *DaemonDB) Update(key, data []byte) error

func (*DaemonDB) UpdatePodVolume

func (d *DaemonDB) UpdatePodVolume(podId, volname string, data []byte) error

Pod Volumes

type KVPair

type KVPair struct {
	K []byte
	V []byte
}

type KeyFilter

type KeyFilter func([]byte) bool