Versions in this module Expand all Collapse all v1 v1.0.1 Sep 8, 2023 Changes in this version + const ApiGroupName + const WebsocketMessageBufferSize + var Codecs serializer.CodecFactory + var GetKubevirtClientFromClientConfig = func(cmdConfig clientcmd.ClientConfig) (KubevirtClient, error) + var ParameterCodec runtime.ParameterCodec + var Scheme *runtime.Scheme + var SchemeBuilder runtime.SchemeBuilder + func Copy(dst *websocket.Conn, src *websocket.Conn) (int64, error) + func CopyFrom(dst io.Writer, src *websocket.Conn) (written int64, err error) + func CopyTo(dst *websocket.Conn, src io.Reader) (written int64, err error) + func DefaultClientConfig(flags *pflag.FlagSet) clientcmd.ClientConfig + func Dial(address string, tlsConfig *tls.Config) (*websocket.Conn, *http.Response, error) + func FlagSet() *flag.FlagSet + func GetConfig() (*restclient.Config, error) + func GetKubevirtClientConfig() (*rest.Config, error) + func Init() + func NewUpgrader() *websocket.Upgrader + func NewWebsocketStreamer(conn *websocket.Conn, done chan struct{}) *wsStreamer + func RegisterRestConfigHook(fn RestConfigHookFunc) + func RequestFromConfig(config *rest.Config, resource, name, namespace, subresource string, ...) (*http.Request, error) + type AsyncSubresourceError struct + StatusCode int + func (a *AsyncSubresourceError) Error() string + func (a *AsyncSubresourceError) GetStatusCode() int + type ClusterProfiler struct + func (v *ClusterProfiler) Dump(cpRequest *v1.ClusterProfilerRequest) (*v1.ClusterProfilerResults, error) + func (v *ClusterProfiler) Start() error + func (v *ClusterProfiler) Stop() error + type ExpandSpecInterface interface + ForVirtualMachine func(vm *v1.VirtualMachine) (*v1.VirtualMachine, error) + type GuestfsInfo struct + Digest string + GsImage string + ImagePrefix string + Registry string + Tag string + type GuestfsVersion struct + func (v *GuestfsVersion) Get() (*GuestfsInfo, error) + type KubeVirtInterface interface + Create func(instance *v1.KubeVirt) (*v1.KubeVirt, error) + Delete func(name string, options *metav1.DeleteOptions) error + Get func(name string, options *metav1.GetOptions) (*v1.KubeVirt, error) + List func(opts *metav1.ListOptions) (*v1.KubeVirtList, error) + Patch func(name string, pt types.PatchType, data []byte, ...) (result *v1.KubeVirt, err error) + PatchStatus func(name string, pt types.PatchType, data []byte, ...) (result *v1.KubeVirt, err error) + Update func(*v1.KubeVirt) (*v1.KubeVirt, error) + UpdateStatus func(*v1.KubeVirt) (*v1.KubeVirt, error) + type KubevirtClient interface + CdiClient func() cdiclient.Interface + ClusterProfiler func() *ClusterProfiler + Config func() *rest.Config + DiscoveryClient func() discovery.DiscoveryInterface + DynamicClient func() dynamic.Interface + ExpandSpec func(namespace string) ExpandSpecInterface + ExtensionsClient func() extclient.Interface + GeneratedKubeVirtClient func() generatedclient.Interface + GuestfsVersion func() *GuestfsVersion + KubeVirt func(namespace string) KubeVirtInterface + KubernetesSnapshotClient func() k8ssnapshotclient.Interface + MigrationPolicy func() migrationsv1.MigrationPolicyInterface + MigrationPolicyClient func() *migrationsv1.MigrationsV1alpha1Client + NetworkClient func() networkclient.Interface + PrometheusClient func() promclient.Interface + ReplicaSet func(namespace string) ReplicaSetInterface + RestClient func() *rest.RESTClient + RouteClient func() routev1.RouteV1Interface + SecClient func() secv1.SecurityV1Interface + ServerVersion func() ServerVersionInterface + VirtualMachine func(namespace string) VirtualMachineInterface + VirtualMachineClone func(namespace string) clonev1alpha1.VirtualMachineCloneInterface + VirtualMachineClusterInstancetype func() instancetypev1beta1.VirtualMachineClusterInstancetypeInterface + VirtualMachineClusterPreference func() instancetypev1beta1.VirtualMachineClusterPreferenceInterface + VirtualMachineExport func(namespace string) vmexportv1alpha1.VirtualMachineExportInterface + VirtualMachineInstance func(namespace string) VirtualMachineInstanceInterface + VirtualMachineInstanceMigration func(namespace string) VirtualMachineInstanceMigrationInterface + VirtualMachineInstancePreset func(namespace string) VirtualMachineInstancePresetInterface + VirtualMachineInstancetype func(namespace string) instancetypev1beta1.VirtualMachineInstancetypeInterface + VirtualMachinePool func(namespace string) poolv1.VirtualMachinePoolInterface + VirtualMachinePreference func(namespace string) instancetypev1beta1.VirtualMachinePreferenceInterface + VirtualMachineRestore func(namespace string) vmsnapshotv1alpha1.VirtualMachineRestoreInterface + VirtualMachineSnapshot func(namespace string) vmsnapshotv1alpha1.VirtualMachineSnapshotInterface + VirtualMachineSnapshotContent func(namespace string) vmsnapshotv1alpha1.VirtualMachineSnapshotContentInterface + func GetKubevirtClient() (KubevirtClient, error) + func GetKubevirtClientFromFlags(master string, kubeconfig string) (KubevirtClient, error) + func GetKubevirtClientFromRESTConfig(config *rest.Config) (KubevirtClient, error) + func GetKubevirtSubresourceClient() (KubevirtClient, error) + func GetKubevirtSubresourceClientFromFlags(master string, kubeconfig string) (KubevirtClient, error) + type ReplicaSetInterface interface + Create func(*v1.VirtualMachineInstanceReplicaSet) (*v1.VirtualMachineInstanceReplicaSet, error) + Delete func(name string, options *metav1.DeleteOptions) error + Get func(name string, options metav1.GetOptions) (*v1.VirtualMachineInstanceReplicaSet, error) + GetScale func(replicaSetName string, options metav1.GetOptions) (*autov1.Scale, error) + List func(opts metav1.ListOptions) (*v1.VirtualMachineInstanceReplicaSetList, error) + Patch func(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.VirtualMachineInstanceReplicaSet, err error) + PatchStatus func(name string, pt types.PatchType, data []byte) (result *v1.VirtualMachineInstanceReplicaSet, err error) + Update func(*v1.VirtualMachineInstanceReplicaSet) (*v1.VirtualMachineInstanceReplicaSet, error) + UpdateScale func(replicaSetName string, scale *autov1.Scale) (*autov1.Scale, error) + UpdateStatus func(*v1.VirtualMachineInstanceReplicaSet) (*v1.VirtualMachineInstanceReplicaSet, error) + type RestConfigHookFunc func(*rest.Config) + type RoundTripCallback func(conn *websocket.Conn, resp *http.Response, err error) error + type SerialConsoleOptions struct + ConnectionTimeout time.Duration + type ServerVersion struct + func (v *ServerVersion) Get() (*version.Info, error) + type ServerVersionInterface interface + Get func() (*version.Info, error) + type StreamInterface interface + AsConn func() net.Conn + Stream func(options StreamOptions) error + type StreamOptions struct + In io.Reader + Out io.Writer + type VirtHandlerClient interface + ForNode func(nodeName string) VirtHandlerConn + Namespace func(namespace string) VirtHandlerClient + Port func(port int) VirtHandlerClient + func NewVirtHandlerClient(virtCli KubevirtClient, httpCli *http.Client) VirtHandlerClient + type VirtHandlerConn interface + ConnectionDetails func() (ip string, port int, err error) + ConsoleURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + FilesystemListURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + FreezeURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + Get func(url string) (string, error) + GuestInfoURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + PauseURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + Pod func() (pod *v1.Pod, err error) + Put func(url string, body io.ReadCloser) error + SEVFetchCertChainURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + SEVInjectLaunchSecretURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + SEVQueryLaunchMeasurementURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + SoftRebootURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + USBRedirURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + UnfreezeURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + UnpauseURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + UserListURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + VNCURI func(vmi *virtv1.VirtualMachineInstance) (string, error) + VSOCKURI func(vmi *virtv1.VirtualMachineInstance, port string, tls string) (string, error) + type VirtualMachineInstanceInterface interface + AddVolume func(ctx context.Context, name string, addVolumeOptions *v1.AddVolumeOptions) error + Create func(ctx context.Context, instance *v1.VirtualMachineInstance) (*v1.VirtualMachineInstance, error) + Delete func(ctx context.Context, name string, options *metav1.DeleteOptions) error + FilesystemList func(ctx context.Context, name string) (v1.VirtualMachineInstanceFileSystemList, error) + Freeze func(ctx context.Context, name string, unfreezeTimeout time.Duration) error + Get func(ctx context.Context, name string, options *metav1.GetOptions) (*v1.VirtualMachineInstance, error) + GuestOsInfo func(ctx context.Context, name string) (v1.VirtualMachineInstanceGuestAgentInfo, error) + List func(ctx context.Context, opts *metav1.ListOptions) (*v1.VirtualMachineInstanceList, error) + Patch func(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (result *v1.VirtualMachineInstance, err error) + Pause func(ctx context.Context, name string, pauseOptions *v1.PauseOptions) error + PortForward func(name string, port int, protocol string) (StreamInterface, error) + RemoveVolume func(ctx context.Context, name string, removeVolumeOptions *v1.RemoveVolumeOptions) error + SEVFetchCertChain func(name string) (v1.SEVPlatformInfo, error) + SEVInjectLaunchSecret func(name string, sevSecretOptions *v1.SEVSecretOptions) error + SEVQueryLaunchMeasurement func(name string) (v1.SEVMeasurementInfo, error) + SEVSetupSession func(name string, sevSessionOptions *v1.SEVSessionOptions) error + Screenshot func(ctx context.Context, name string, options *v1.ScreenshotOptions) ([]byte, error) + SerialConsole func(name string, options *SerialConsoleOptions) (StreamInterface, error) + SoftReboot func(ctx context.Context, name string) error + USBRedir func(vmiName string) (StreamInterface, error) + Unfreeze func(ctx context.Context, name string) error + Unpause func(ctx context.Context, name string, unpauseOptions *v1.UnpauseOptions) error + Update func(ctx context.Context, instance *v1.VirtualMachineInstance) (*v1.VirtualMachineInstance, error) + UserList func(ctx context.Context, name string) (v1.VirtualMachineInstanceGuestOSUserList, error) + VNC func(name string) (StreamInterface, error) + VSOCK func(name string, options *v1.VSOCKOptions) (StreamInterface, error) + Watch func(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error) + type VirtualMachineInstanceMigrationInterface interface + Create func(migration *v1.VirtualMachineInstanceMigration, options *metav1.CreateOptions) (*v1.VirtualMachineInstanceMigration, error) + Delete func(name string, options *metav1.DeleteOptions) error + Get func(name string, options *metav1.GetOptions) (*v1.VirtualMachineInstanceMigration, error) + List func(opts *metav1.ListOptions) (*v1.VirtualMachineInstanceMigrationList, error) + Patch func(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.VirtualMachineInstanceMigration, err error) + PatchStatus func(name string, pt types.PatchType, data []byte) (result *v1.VirtualMachineInstanceMigration, err error) + Update func(*v1.VirtualMachineInstanceMigration) (*v1.VirtualMachineInstanceMigration, error) + UpdateStatus func(*v1.VirtualMachineInstanceMigration) (*v1.VirtualMachineInstanceMigration, error) + type VirtualMachineInstancePresetInterface interface + Create func(*v1.VirtualMachineInstancePreset) (*v1.VirtualMachineInstancePreset, error) + Delete func(name string, options *metav1.DeleteOptions) error + Get func(name string, options metav1.GetOptions) (*v1.VirtualMachineInstancePreset, error) + List func(opts metav1.ListOptions) (*v1.VirtualMachineInstancePresetList, error) + Patch func(name string, pt types.PatchType, data []byte, subresources ...string) (result *v1.VirtualMachineInstancePreset, err error) + Update func(*v1.VirtualMachineInstancePreset) (*v1.VirtualMachineInstancePreset, error) + type VirtualMachineInterface interface + AddVolume func(ctx context.Context, name string, addVolumeOptions *v1.AddVolumeOptions) error + Create func(ctx context.Context, vm *v1.VirtualMachine) (*v1.VirtualMachine, error) + Delete func(ctx context.Context, name string, options *metav1.DeleteOptions) error + ForceRestart func(ctx context.Context, name string, restartOptions *v1.RestartOptions) error + ForceStop func(ctx context.Context, name string, stopOptions *v1.StopOptions) error + Get func(ctx context.Context, name string, options *metav1.GetOptions) (*v1.VirtualMachine, error) + GetWithExpandedSpec func(ctx context.Context, name string) (*v1.VirtualMachine, error) + List func(ctx context.Context, opts *metav1.ListOptions) (*v1.VirtualMachineList, error) + MemoryDump func(ctx context.Context, name string, ...) error + Migrate func(ctx context.Context, name string, migrateOptions *v1.MigrateOptions) error + Patch func(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (result *v1.VirtualMachine, err error) + PatchStatus func(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (result *v1.VirtualMachine, err error) + PortForward func(name string, port int, protocol string) (StreamInterface, error) + RemoveMemoryDump func(ctx context.Context, name string) error + RemoveVolume func(ctx context.Context, name string, removeVolumeOptions *v1.RemoveVolumeOptions) error + Restart func(ctx context.Context, name string, restartOptions *v1.RestartOptions) error + Start func(ctx context.Context, name string, startOptions *v1.StartOptions) error + Stop func(ctx context.Context, name string, stopOptions *v1.StopOptions) error + Update func(ctx context.Context, vm *v1.VirtualMachine) (*v1.VirtualMachine, error) + UpdateStatus func(ctx context.Context, vm *v1.VirtualMachine) (*v1.VirtualMachine, error) + type WebsocketRoundTripper struct + Dialer *websocket.Dialer + Do RoundTripCallback + func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)