cache

Documentation

Index

• func AddGhostRecord(namespace string, name string, socketFile string, uid types.UID) (err error)
• func DeleteGhostRecord(namespace string, name string) error
• func HasGhostRecord(namespace string, name string) bool
• func InitializeGhostRecordCache(directoryPath string) error
• func LastKnownUIDFromGhostRecordCache(key string) types.UID
• func NewSharedInformer(virtShareDir string, watchdogTimeout int, recorder record.EventRecorder, ...) (cache.SharedInformer, error)
• type DomainWatcher
  • func (d *DomainWatcher) List(_ k8sv1.ListOptions) (runtime.Object, error)
  • func (d *DomainWatcher) ResultChan() <-chan watch.Event
  • func (d *DomainWatcher) Stop()
  • func (d *DomainWatcher) Watch(_ k8sv1.ListOptions) (watch.Interface, error)
• type LauncherClientInfo
• type LauncherClientInfoByVMI
  • func (l *LauncherClientInfoByVMI) Delete(vmiUID types.UID)
  • func (l *LauncherClientInfoByVMI) Load(vmiUID types.UID) (*LauncherClientInfo, bool)
  • func (l *LauncherClientInfoByVMI) Store(vmiUID types.UID, launcherClientInfo *LauncherClientInfo)

Functions

func AddGhostRecord

func AddGhostRecord(namespace string, name string, socketFile string, uid types.UID) (err error)

func DeleteGhostRecord

func DeleteGhostRecord(namespace string, name string) error

func HasGhostRecord

func HasGhostRecord(namespace string, name string) bool

func InitializeGhostRecordCache

func InitializeGhostRecordCache(directoryPath string) error

func LastKnownUIDFromGhostRecordCache

func LastKnownUIDFromGhostRecordCache(key string) types.UID

func NewSharedInformer

func NewSharedInformer(virtShareDir string, watchdogTimeout int, recorder record.EventRecorder, vmiStore cache.Store, resyncPeriod time.Duration) (cache.SharedInformer, error)

Types

type DomainWatcher

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

func (*DomainWatcher) List

func (d *DomainWatcher) List(_ k8sv1.ListOptions) (runtime.Object, error)

func (*DomainWatcher) ResultChan

func (d *DomainWatcher) ResultChan() <-chan watch.Event

func (*DomainWatcher) Stop

func (d *DomainWatcher) Stop()

func (*DomainWatcher) Watch

func (d *DomainWatcher) Watch(_ k8sv1.ListOptions) (watch.Interface, error)

type LauncherClientInfo

type LauncherClientInfo struct {
	Client              cmdclient.LauncherClient
	SocketFile          string
	DomainPipeStopChan  chan struct{}
	NotInitializedSince time.Time
	Ready               bool
}

type LauncherClientInfoByVMI

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

func (*LauncherClientInfoByVMI) Delete

func (l *LauncherClientInfoByVMI) Delete(vmiUID types.UID)

func (*LauncherClientInfoByVMI) Load

func (l *LauncherClientInfoByVMI) Load(vmiUID types.UID) (*LauncherClientInfo, bool)

func (*LauncherClientInfoByVMI) Store

func (l *LauncherClientInfoByVMI) Store(vmiUID types.UID, launcherClientInfo *LauncherClientInfo)