operands

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 16, 2022 License: Apache-2.0 Imports: 48 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ErrCDIUninstall = "ErrCDIUninstall"

	ErrVirtUninstall = "ErrVirtUninstall"

	ErrHCOUninstall = "ErrHCOUninstall"
)
View Source
const (
	HonorWaitForFirstConsumerGate = "HonorWaitForFirstConsumer"
)
View Source
const (
	SELinuxLauncherType = "virt_launcher.process"
)

Variables

This section is empty.

Functions

func NewCDI

func NewCDI(hc *hcov1beta1.HyperConverged, opts ...string) (*cdiv1beta1.CDI, error)

func NewCDIWithNameOnly added in v1.4.0

func NewCDIWithNameOnly(hc *hcov1beta1.HyperConverged, opts ...string) *cdiv1beta1.CDI

func NewCdiConfigReaderRole added in v1.6.0

func NewCdiConfigReaderRole(hc *hcov1beta1.HyperConverged) *rbacv1.Role

func NewCdiConfigReaderRoleBinding added in v1.6.0

func NewCdiConfigReaderRoleBinding(hc *hcov1beta1.HyperConverged) *rbacv1.RoleBinding

func NewCliDownloadsRoute added in v1.5.0

func NewCliDownloadsRoute(hc *hcov1beta1.HyperConverged) *routev1.Route

func NewCliDownloadsService added in v1.5.0

func NewCliDownloadsService(hc *hcov1beta1.HyperConverged) *corev1.Service

func NewKubeVirt

func NewKubeVirt(hc *hcov1beta1.HyperConverged, opts ...string) (*kubevirtcorev1.KubeVirt, error)

func NewKubeVirtStorageConfigForCR

func NewKubeVirtStorageConfigForCR(cr *hcov1beta1.HyperConverged, namespace string) *corev1.ConfigMap

func NewKubeVirtWithNameOnly added in v1.4.0

func NewKubeVirtWithNameOnly(hc *hcov1beta1.HyperConverged, opts ...string) *kubevirtcorev1.KubeVirt

func NewMetricsService

func NewMetricsService(hc *hcov1beta1.HyperConverged, namespace string) *corev1.Service

NewMetricsService creates service for prometheus metrics

func NewNetworkAddonsWithNameOnly added in v1.4.0

func NewNetworkAddonsWithNameOnly(hc *hcov1beta1.HyperConverged, opts ...string) *networkaddonsv1.NetworkAddonsConfig

func NewPrometheusRule

func NewPrometheusRule(hc *hcov1beta1.HyperConverged, namespace string) *monitoringv1.PrometheusRule

NewPrometheusRule creates PrometheusRule resource to define alert rules

func NewPrometheusRuleSpec added in v1.4.0

func NewPrometheusRuleSpec() *monitoringv1.PrometheusRuleSpec

NewPrometheusRuleSpec creates PrometheusRuleSpec for alert rules

func NewSSP

func NewSSP(hc *hcov1beta1.HyperConverged, opts ...string) (*sspv1beta1.SSP, error)

func NewSSPWithNameOnly added in v1.6.0

func NewSSPWithNameOnly(hc *hcov1beta1.HyperConverged, opts ...string) *sspv1beta1.SSP

func NewServiceMonitor

func NewServiceMonitor(hc *hcov1beta1.HyperConverged, namespace string) *monitoringv1.ServiceMonitor

NewServiceMonitor creates ServiceMonitor resource to expose metrics endpoint

func NewVirtioWinCm added in v1.6.0

func NewVirtioWinCm(hc *hcov1beta1.HyperConverged) (*corev1.ConfigMap, error)

func NewVirtioWinCmReaderRole added in v1.6.0

func NewVirtioWinCmReaderRole(hc *hcov1beta1.HyperConverged) *rbacv1.Role

func NewVirtioWinCmReaderRoleBinding added in v1.6.0

func NewVirtioWinCmReaderRoleBinding(hc *hcov1beta1.HyperConverged) *rbacv1.RoleBinding

Types

type EnsureResult

type EnsureResult struct {
	Updated     bool
	Overwritten bool
	Created     bool
	UpgradeDone bool
	Deleted     bool
	Err         error
	Type        string
	Name        string
}

func NewEnsureResult

func NewEnsureResult(resource runtime.Object) *EnsureResult

func (*EnsureResult) Error

func (r *EnsureResult) Error(err error) *EnsureResult

func (*EnsureResult) SetCreated

func (r *EnsureResult) SetCreated() *EnsureResult

func (*EnsureResult) SetDeleted added in v1.6.0

func (r *EnsureResult) SetDeleted() *EnsureResult

func (*EnsureResult) SetName

func (r *EnsureResult) SetName(name string) *EnsureResult

func (*EnsureResult) SetOverwritten

func (r *EnsureResult) SetOverwritten(overwritten bool) *EnsureResult

func (*EnsureResult) SetUpdated

func (r *EnsureResult) SetUpdated() *EnsureResult

func (*EnsureResult) SetUpgradeDone

func (r *EnsureResult) SetUpgradeDone(upgradeDone bool) *EnsureResult

type GetHandler added in v1.5.0

type GetHandler func(logger log.Logger, Client client.Client, Scheme *runtime.Scheme, hc *hcov1beta1.HyperConverged) ([]Operand, error)

type Operand

type Operand interface {
	// contains filtered or unexported methods
}

func NewConfigReaderRoleHandler added in v1.6.0

func NewConfigReaderRoleHandler(_ log.Logger, Client client.Client, Scheme *runtime.Scheme, hc *hcov1beta1.HyperConverged) ([]Operand, error)

************** Config Reader Role Handler **************

type OperandHandler

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

func NewOperandHandler

func NewOperandHandler(client client.Client, scheme *runtime.Scheme, isOpenshiftCluster bool, eventEmitter hcoutil.EventEmitter) *OperandHandler

func (OperandHandler) Ensure

func (h OperandHandler) Ensure(req *common.HcoRequest) error

func (OperandHandler) EnsureDeleted

func (h OperandHandler) EnsureDeleted(req *common.HcoRequest) error

func (*OperandHandler) FirstUseInitiation

func (h *OperandHandler) FirstUseInitiation(scheme *runtime.Scheme, isOpenshiftCluster bool, hc *hcov1beta1.HyperConverged)

The k8s client is not available when calling to NewOperandHandler. Initial operations that need to read/write from the cluster can only be done when the client is already working.

func (*OperandHandler) GetQuickStartNames added in v1.6.0

func (h *OperandHandler) GetQuickStartNames() []string

func (*OperandHandler) Reset added in v1.4.0

func (h *OperandHandler) Reset()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL