cache

Documentation

Overview

* This file is part of the KubeVirt project * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. * * Copyright The KubeVirt Authors *

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
• type IterableCheckpointManager
• 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

Types

type IterableCheckpointManager

type IterableCheckpointManager interface {
	ListKeys() []string
	checkpoint.CheckpointManager
}

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)