operator

package
v1.15.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 97 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultCollectedResourceGroups = []GroupResourceSpec{
	{
		GroupResource: schema.GroupResource{
			Resource: "scyllaclusters",
			Group:    "scylla.scylladb.com",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "scyllaoperatorconfigs",
			Group:    "scylla.scylladb.com",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "nodeconfigs",
			Group:    "scylla.scylladb.com",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "namespaces",
			Group:    "",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "scylla-operator",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "namespaces",
			Group:    "",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "scylla-manager",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "namespaces",
			Group:    "",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "scylla-operator-node-tuning",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "customresourcedefinitions",
			Group:    "apiextensions.k8s.io",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "nodes",
			Group:    "",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "validatingwebhookconfigurations",
			Group:    "admissionregistration.k8s.io",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "",
	},
	{
		GroupResource: schema.GroupResource{
			Resource: "mutatingwebhookconfigurations",
			Group:    "admissionregistration.k8s.io",
		},
		Namespace: corev1.NamespaceAll,
		Name:      "",
	},
}
View Source 
var (
	DefaultValidators = map[schema.GroupVersionResource]Validator{
		scyllav1.GroupVersion.WithResource("scyllaclusters"): &GenericValidator[*scyllav1.ScyllaCluster]{
			ValidateCreateFunc: validation.ValidateScyllaCluster,
			ValidateUpdateFunc: validation.ValidateScyllaClusterUpdate,
		},
		scyllav1alpha1.GroupVersion.WithResource("nodeconfigs"): &GenericValidator[*scyllav1alpha1.NodeConfig]{
			ValidateCreateFunc: validation.ValidateNodeConfig,
			ValidateUpdateFunc: validation.ValidateNodeConfigUpdate,
		},
		scyllav1alpha1.GroupVersion.WithResource("scyllaoperatorconfigs"): &GenericValidator[*scyllav1alpha1.ScyllaOperatorConfig]{
			ValidateCreateFunc: validation.ValidateScyllaOperatorConfig,
			ValidateUpdateFunc: validation.ValidateScyllaOperatorConfigUpdate,
		},
		scyllav1alpha1.GroupVersion.WithResource("scylladbdatacenters"): &GenericValidator[*scyllav1alpha1.ScyllaDBDatacenter]{
			ValidateCreateFunc: validation.ValidateScyllaDBDatacenter,
			ValidateUpdateFunc: validation.ValidateScyllaDBDatacenterUpdate,
		},
	}
)

Functions

func NewCleanupJobCmd added in v1.10.0 

func NewCleanupJobCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewGatherCmd added in v1.11.0 

func NewGatherCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewIgnitionCmd added in v1.14.0 

func NewIgnitionCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewManagerControllerCmd 

func NewManagerControllerCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewMustGatherCmd added in v1.11.0 

func NewMustGatherCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewNodeSetupCmd added in v1.9.0 

func NewNodeSetupCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewOperatorCmd 

func NewOperatorCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewOperatorCommand added in v1.4.0 

func NewOperatorCommand(streams genericclioptions.IOStreams) *cobra.Command

func NewRlimitsJobCmd added in v1.15.0 

func NewRlimitsJobCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewSidecarCmd 

func NewSidecarCmd(streams genericclioptions.IOStreams) *cobra.Command

func NewWebhookCmd added in v1.4.0 

func NewWebhookCmd(streams genericclioptions.IOStreams, validators map[schema.GroupVersionResource]Validator) *cobra.Command

Types

type CleanupJobOptions added in v1.10.0 

type CleanupJobOptions struct {
	ManagerAuthConfigPath string
	NodeAddress           string
	// contains filtered or unexported fields
}

func NewCleanupJobOptions added in v1.10.0 

func NewCleanupJobOptions(streams genericclioptions.IOStreams) *CleanupJobOptions

func (*CleanupJobOptions) Complete added in v1.10.0 

func (o *CleanupJobOptions) Complete() error

func (*CleanupJobOptions) Run added in v1.10.0 

func (o *CleanupJobOptions) Run(streams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*CleanupJobOptions) Validate added in v1.10.0 

func (o *CleanupJobOptions) Validate() error

type GatherBaseOptions added in v1.11.0 

type GatherBaseOptions struct {
	GathererName string
	ConfigFlags  *kgenericclioptions.ConfigFlags

	DestDir              string
	CollectManagedFields bool
	LogsLimitBytes       int64
	KeepGoing            bool
	// contains filtered or unexported fields
}

func NewGatherBaseOptions added in v1.11.0 

func NewGatherBaseOptions(gathererName string, keepGoing bool) *GatherBaseOptions

func (*GatherBaseOptions) AddFlags added in v1.11.0 

func (o *GatherBaseOptions) AddFlags(flagset *pflag.FlagSet)

func (*GatherBaseOptions) Complete added in v1.11.0 

func (o *GatherBaseOptions) Complete() error

func (*GatherBaseOptions) GetPrinters added in v1.11.0 

func (o *GatherBaseOptions) GetPrinters() []collect.ResourcePrinterInterface

func (*GatherBaseOptions) RunInit added in v1.11.0 

func (o *GatherBaseOptions) RunInit(originalStreams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*GatherBaseOptions) Validate added in v1.11.0 

func (o *GatherBaseOptions) Validate() error

type GatherOptions added in v1.11.0 

type GatherOptions struct {
	*GatherBaseOptions

	CollectRelatedResources bool
	// contains filtered or unexported fields
}

func NewGatherOptions added in v1.11.0 

func NewGatherOptions(streams genericclioptions.IOStreams) *GatherOptions

func (*GatherOptions) AddFlags added in v1.11.0 

func (o *GatherOptions) AddFlags(flagset *pflag.FlagSet)

func (*GatherOptions) Complete added in v1.11.0 

func (o *GatherOptions) Complete(args []string) error

func (*GatherOptions) Run added in v1.11.0 

func (o *GatherOptions) Run(originalStreams genericclioptions.IOStreams, cmd *cobra.Command) (returnErr error)

func (*GatherOptions) Validate added in v1.11.0 

func (o *GatherOptions) Validate(args []string) error

type GenericValidator added in v1.15.0 

type GenericValidator[T ValidatableObject] struct {
	ValidateCreateFunc func(obj T) field.ErrorList
	ValidateUpdateFunc func(obj, oldObj T) field.ErrorList
}

func (*GenericValidator[T]) GetGroupKind added in v1.15.0 

func (v *GenericValidator[T]) GetGroupKind(obj runtime.Object) schema.GroupKind

func (*GenericValidator[T]) GetName added in v1.15.0 

func (v *GenericValidator[T]) GetName(obj runtime.Object) string

func (*GenericValidator[T]) ValidateCreate added in v1.15.0 

func (v *GenericValidator[T]) ValidateCreate(obj runtime.Object) field.ErrorList

func (*GenericValidator[T]) ValidateUpdate added in v1.15.0 

func (v *GenericValidator[T]) ValidateUpdate(obj, oldObj runtime.Object) field.ErrorList

type GroupResourceSpec added in v1.13.0 

type GroupResourceSpec struct {
	schema.GroupResource
	Namespace, Name string
}

type IgnitionOptions added in v1.14.0 

type IgnitionOptions struct {
	genericclioptions.ClientConfig
	genericclioptions.InClusterReflection
	probeserver.ServeProbesOptions

	ServiceName                       string
	NodesBroadcastAddressTypeString   string
	ClientsBroadcastAddressTypeString string
	// contains filtered or unexported fields
}

func NewIgnitionOptions added in v1.14.0 

func NewIgnitionOptions(streams genericclioptions.IOStreams) *IgnitionOptions

func (*IgnitionOptions) AddFlags added in v1.14.0 

func (o *IgnitionOptions) AddFlags(cmd *cobra.Command)

func (*IgnitionOptions) Complete added in v1.14.0 

func (o *IgnitionOptions) Complete(args []string) error

func (*IgnitionOptions) Execute added in v1.14.0 

func (o *IgnitionOptions) Execute(cmdCtx context.Context, originalStreams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*IgnitionOptions) Run added in v1.14.0 

func (o *IgnitionOptions) Run(originalStreams genericclioptions.IOStreams, cmd *cobra.Command) (returnErr error)

func (*IgnitionOptions) Validate added in v1.14.0 

func (o *IgnitionOptions) Validate(args []string) error

type ManagerControllerOptions added in v1.4.0 

type ManagerControllerOptions struct {
	genericclioptions.ClientConfig
	genericclioptions.InClusterReflection
	genericclioptions.LeaderElection

	ConcurrentSyncs int
	// contains filtered or unexported fields
}

func NewManagerControllerOptions added in v1.4.0 

func NewManagerControllerOptions(streams genericclioptions.IOStreams) *ManagerControllerOptions

func (*ManagerControllerOptions) Complete added in v1.4.0 

func (o *ManagerControllerOptions) Complete() error

func (*ManagerControllerOptions) Run added in v1.4.0 

func (o *ManagerControllerOptions) Run(streams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*ManagerControllerOptions) Validate added in v1.4.0 

func (o *ManagerControllerOptions) Validate() error

type MustGatherOptions added in v1.11.0 

type MustGatherOptions struct {
	*GatherBaseOptions

	AllResources            bool
	CollectedResourceGroups []GroupResourceSpec
}

func NewMustGatherOptions added in v1.11.0 

func NewMustGatherOptions(streams genericclioptions.IOStreams) *MustGatherOptions

func (*MustGatherOptions) AddFlags added in v1.11.0 

func (o *MustGatherOptions) AddFlags(flagset *pflag.FlagSet)

func (*MustGatherOptions) Complete added in v1.11.0 

func (o *MustGatherOptions) Complete() error

func (*MustGatherOptions) Run added in v1.11.0 

func (o *MustGatherOptions) Run(originalStreams genericclioptions.IOStreams, cmd *cobra.Command) (returnErr error)

func (*MustGatherOptions) Validate added in v1.11.0 

func (o *MustGatherOptions) Validate() error

type NodeSetupDaemonOptions added in v1.9.0 

type NodeSetupDaemonOptions struct {
	genericclioptions.ClientConfig
	genericclioptions.InClusterReflection

	PodName              string
	NodeName             string
	NodeConfigName       string
	NodeConfigUID        string
	ScyllaImage          string
	OperatorImage        string
	DisableOptimizations bool

	CRIEndpoints                []string
	KubeletPodResourcesEndpoint string
	// contains filtered or unexported fields
}

func NewNodeSetupOptions added in v1.9.0 

func NewNodeSetupOptions(streams genericclioptions.IOStreams) *NodeSetupDaemonOptions

func (*NodeSetupDaemonOptions) Complete added in v1.9.0 

func (o *NodeSetupDaemonOptions) Complete() error

func (*NodeSetupDaemonOptions) Run added in v1.9.0 

func (o *NodeSetupDaemonOptions) Run(streams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*NodeSetupDaemonOptions) Validate added in v1.9.0 

func (o *NodeSetupDaemonOptions) Validate() error

type OperatorOptions added in v1.4.0 

type OperatorOptions struct {
	genericclioptions.ClientConfig
	genericclioptions.InClusterReflection
	genericclioptions.LeaderElection

	ConcurrentSyncs int
	OperatorImage   string
	CQLSIngressPort int

	CryptoKeyBufferSizeMin int
	CryptoKeyBufferSizeMax int
	CryptoKeyBufferDelay   time.Duration
	// contains filtered or unexported fields
}

func NewOperatorOptions added in v1.4.0 

func NewOperatorOptions(streams genericclioptions.IOStreams) *OperatorOptions

func (*OperatorOptions) AddFlags added in v1.14.0 

func (o *OperatorOptions) AddFlags(cmd *cobra.Command)

func (*OperatorOptions) Complete added in v1.4.0 

func (o *OperatorOptions) Complete(cmd *cobra.Command) error

func (*OperatorOptions) Execute added in v1.14.0 

func (o *OperatorOptions) Execute(ctx context.Context, streams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*OperatorOptions) Run added in v1.4.0 

func (o *OperatorOptions) Run(streams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*OperatorOptions) Validate added in v1.4.0 

func (o *OperatorOptions) Validate() error

type RlimitsJobOptions added in v1.15.0 

type RlimitsJobOptions struct {
	PID int
	// contains filtered or unexported fields
}

func NewRlimitsJobOptions added in v1.15.0 

func NewRlimitsJobOptions(streams genericclioptions.IOStreams) *RlimitsJobOptions

func (*RlimitsJobOptions) Complete added in v1.15.0 

func (o *RlimitsJobOptions) Complete() error

func (*RlimitsJobOptions) Run added in v1.15.0 

func (o *RlimitsJobOptions) Run(streams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*RlimitsJobOptions) Validate added in v1.15.0 

func (o *RlimitsJobOptions) Validate() error

type SidecarOptions added in v1.4.0 

type SidecarOptions struct {
	genericclioptions.ClientConfig
	genericclioptions.InClusterReflection

	ServiceName                       string
	CPUCount                          int
	ExternalSeeds                     []string
	NodesBroadcastAddressTypeString   string
	ClientsBroadcastAddressTypeString string
	// contains filtered or unexported fields
}

func NewSidecarOptions added in v1.4.0 

func NewSidecarOptions(streams genericclioptions.IOStreams) *SidecarOptions

func (*SidecarOptions) Complete added in v1.4.0 

func (o *SidecarOptions) Complete() error

func (*SidecarOptions) Run added in v1.4.0 

func (o *SidecarOptions) Run(streams genericclioptions.IOStreams, cmd *cobra.Command, args []string) error

func (*SidecarOptions) Validate added in v1.4.0 

func (o *SidecarOptions) Validate() error

type ValidatableObject added in v1.15.0 

type ValidatableObject interface {
	kubeinterfaces.ObjectInterface
	schema.ObjectKind
}

type Validator added in v1.15.0 

type Validator interface {
	ValidateCreate(obj runtime.Object) field.ErrorList
	ValidateUpdate(obj, oldObj runtime.Object) field.ErrorList
	GetGroupKind(obj runtime.Object) schema.GroupKind
	GetName(obj runtime.Object) string
}

type WebhookOptions added in v1.4.0 

type WebhookOptions struct {
	TLSCertFile, TLSKeyFile        string
	Port                           int
	InsecureGenerateLocalhostCerts bool

	Validators map[schema.GroupVersionResource]Validator

	TLSConfig *tls.Config
	// contains filtered or unexported fields
}

func NewWebhookOptions added in v1.4.0 

func NewWebhookOptions(streams genericclioptions.IOStreams, validators map[schema.GroupVersionResource]Validator) *WebhookOptions

func (*WebhookOptions) Complete added in v1.4.0 

func (o *WebhookOptions) Complete() error

func (*WebhookOptions) Run added in v1.4.0 

func (o *WebhookOptions) Run(streams genericclioptions.IOStreams, cmd *cobra.Command) error

func (*WebhookOptions) Validate added in v1.4.0 

func (o *WebhookOptions) Validate() error

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.