Documentation
¶
Index ¶
- Variables
- func NewCleanupJobCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewGatherCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewIgnitionCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewManagerControllerCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewMustGatherCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewNodeSetupCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewOperatorCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewOperatorCommand(streams genericclioptions.IOStreams) *cobra.Command
- func NewRlimitsJobCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewSidecarCmd(streams genericclioptions.IOStreams) *cobra.Command
- func NewWebhookCmd(streams genericclioptions.IOStreams, ...) *cobra.Command
- type CleanupJobOptions
- type GatherBaseOptions
- func (o *GatherBaseOptions) AddFlags(flagset *pflag.FlagSet)
- func (o *GatherBaseOptions) Complete() error
- func (o *GatherBaseOptions) GetPrinters() []collect.ResourcePrinterInterface
- func (o *GatherBaseOptions) RunInit(originalStreams genericclioptions.IOStreams, cmd *cobra.Command) error
- func (o *GatherBaseOptions) Validate() error
- type GatherOptions
- type GenericValidator
- func (v *GenericValidator[T]) GetGroupKind(obj runtime.Object) schema.GroupKind
- func (v *GenericValidator[T]) GetName(obj runtime.Object) string
- func (v *GenericValidator[T]) ValidateCreate(obj runtime.Object) field.ErrorList
- func (v *GenericValidator[T]) ValidateUpdate(obj, oldObj runtime.Object) field.ErrorList
- type GroupResourceSpec
- type IgnitionOptions
- func (o *IgnitionOptions) AddFlags(cmd *cobra.Command)
- func (o *IgnitionOptions) Complete(args []string) error
- func (o *IgnitionOptions) Execute(cmdCtx context.Context, originalStreams genericclioptions.IOStreams, ...) error
- func (o *IgnitionOptions) Run(originalStreams genericclioptions.IOStreams, cmd *cobra.Command) (returnErr error)
- func (o *IgnitionOptions) Validate(args []string) error
- type ManagerControllerOptions
- type MustGatherOptions
- type NodeSetupDaemonOptions
- type OperatorOptions
- func (o *OperatorOptions) AddFlags(cmd *cobra.Command)
- func (o *OperatorOptions) Complete(cmd *cobra.Command) error
- func (o *OperatorOptions) Execute(ctx context.Context, streams genericclioptions.IOStreams, cmd *cobra.Command) error
- func (o *OperatorOptions) Run(streams genericclioptions.IOStreams, cmd *cobra.Command) error
- func (o *OperatorOptions) Validate() error
- type RlimitsJobOptions
- type SidecarOptions
- type ValidatableObject
- type Validator
- type WebhookOptions
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, }, scyllav1alpha1.GroupVersion.WithResource("scylladbclusters"): &GenericValidator[*scyllav1alpha1.ScyllaDBCluster]{ ValidateCreateFunc: validation.ValidateScyllaDBCluster, ValidateUpdateFunc: validation.ValidateScyllaDBClusterUpdate, }, } )
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 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
¶
Click to show internal directories.
Click to hide internal directories.