db

Documentation

Index

• Variables
• func AddRefPodInfo(nicID, podName, namespace string) error
• func CloseDB()
• func DeleteNetworkInfo(nicID string) error
• func DeleteRefPodInfo(nicID, podName, namespace string) (err error)
• func GetActivePodsByRefNicID(nicID string, podOnNodeMap map[string]bool) ([]string, error)
• func GetPodUniName(podName, namespace string) string
• func Iterator(fn func(key, value []byte) error) error
• func SetNetworkInfo(key string, info *rpc.NICMMessage) error
• func SetupLevelDB(opt *LevelDBOptions) error
• type LevelDBOptions
  • func NewLevelDBOptions() *LevelDBOptions
  • func (opt *LevelDBOptions) AddFlags()

Variables

var (
	LevelDB *leveldb.DB
)

Functions

func AddRefPodInfo

func AddRefPodInfo(nicID, podName, namespace string) error

func CloseDB

func CloseDB()

func DeleteNetworkInfo

func DeleteNetworkInfo(nicID string) error

func DeleteRefPodInfo

func DeleteRefPodInfo(nicID, podName, namespace string) (err error)

set nic reference pod array empty here wait for Sync thread to release Nic resource

func GetActivePodsByRefNicID

func GetActivePodsByRefNicID(nicID string, podOnNodeMap map[string]bool) ([]string, error)

func GetPodUniName

func GetPodUniName(podName, namespace string) string

func Iterator

func Iterator(fn func(key, value []byte) error) error

func SetNetworkInfo

func SetNetworkInfo(key string, info *rpc.NICMMessage) error

func SetupLevelDB

func SetupLevelDB(opt *LevelDBOptions) error

Types

type LevelDBOptions

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

func NewLevelDBOptions

func NewLevelDBOptions() *LevelDBOptions

func (*LevelDBOptions) AddFlags

func (opt *LevelDBOptions) AddFlags()