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(options k8sv1.ListOptions) (runtime.Object, error)
  • func (d *DomainWatcher) ResultChan() <-chan watch.Event
  • func (d *DomainWatcher) Stop()
  • func (d *DomainWatcher) Watch(options k8sv1.ListOptions) (watch.Interface, error)

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(options 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(options k8sv1.ListOptions) (watch.Interface, error)