v1alpha1

package
v0.1.9 Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2023 License: Apache-2.0 Imports: 23 Imported by: 1

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the pravega v1alpha1 API group +k8s:deepcopy-gen=package,register +groupName=bookkeeper.pravega.io

Package v1alpha1 contains API Schema definitions for the bookkeeper v1alpha1 API group +kubebuilder:object:generate=true +groupName=bookkeeper.pravega.io

Index

Constants

View Source 
const (
	// DefaultZookeeperUri is the default ZooKeeper URI in the form of "hostname:port"
	DefaultZookeeperUri = "zookeeper-client:2181"

	// DefaultBookkeeperVersion is the default tag used for for the BookKeeper
	// Docker image
	DefaultBookkeeperVersion = "0.11.0"

	// the BookKeeper image
	DefaultBookkeeperImageRepository = "pravega/bookkeeper"

	// DefaultbookkeeperImagePullPolicy is the default image pull policy used
	// for the Bookkeeper Docker image
	DefaultBookkeeperImagePullPolicy = corev1.PullAlways

	// DefaultBookkeeperLedgerVolumeSize is the default volume size for the
	// Bookkeeper ledger volume
	DefaultBookkeeperLedgerVolumeSize = "10Gi"

	// DefaultBookkeeperJournalVolumeSize is the default volume size for the
	// Bookkeeper journal volume
	DefaultBookkeeperJournalVolumeSize = "10Gi"

	// DefaultBookkeeperIndexVolumeSize is the default volume size for the
	// Bookkeeper index volume
	DefaultBookkeeperIndexVolumeSize = "10Gi"

	// MinimumBookkeeperReplicas is the minimum number of Bookkeeper replicas
	// accepted
	MinimumBookkeeperReplicas = 1

	// DefaultBookkeeperReplicas is the default replicas for bookkeeper
	DefaultBookkeeperReplicas = 3

	// DefaultBookkeeperRequestCPU is the default CPU request for BookKeeper
	DefaultBookkeeperRequestCPU = "500m"

	// DefaultBookkeeperLimitCPU is the default CPU limit for BookKeeper
	DefaultBookkeeperLimitCPU = "1"

	// DefaultBookkeeperRequestMemory is the default memory request for BookKeeper
	DefaultBookkeeperRequestMemory = "1Gi"

	// DefaultBookkeeperLimitMemory is the limit memory limit for BookKeeper
	DefaultBookkeeperLimitMemory = "2Gi"

	// DefaultReadinessProbeInitialDelaySeconds is the default initial delay (in seconds)
	// for the readiness probe
	DefaultReadinessProbeInitialDelaySeconds = 20

	// DefaultReadinessProbePeriodSeconds is the default probe period (in seconds)
	// for the readiness probe
	DefaultReadinessProbePeriodSeconds = 10

	// DefaultReadinessProbeFailureThreshold is the default probe failure threshold
	// for the readiness probe
	DefaultReadinessProbeFailureThreshold = 9

	// DefaultReadinessProbeSuccessThreshold is the default probe success threshold
	// for the readiness probe
	DefaultReadinessProbeSuccessThreshold = 1

	// DefaultReadinessProbeTimeoutSeconds is the default probe timeout (in seconds)
	// for the readiness probe
	DefaultReadinessProbeTimeoutSeconds = 5

	// DefaultLivenessProbeInitialDelaySeconds is the default initial delay (in seconds)
	// for the liveness probe
	DefaultLivenessProbeInitialDelaySeconds = 60

	// DefaultLivenessProbePeriodSeconds is the default probe period (in seconds)
	// for the liveness probe
	DefaultLivenessProbePeriodSeconds = 15

	// DefaultLivenessProbeFailureThreshold is the default probe failure threshold
	// for the liveness probe
	DefaultLivenessProbeFailureThreshold = 4

	// DefaultLivenessProbeSuccessThreshold is the default probe success threshold
	// for the liveness probe
	DefaultLivenessProbeSuccessThreshold = 1

	// DefaultLivenessProbeTimeoutSeconds is the default probe timeout (in seconds)
	// for the liveness probe
	DefaultLivenessProbeTimeoutSeconds = 5

	// OperatorNameEnvVar is env variable for operator name
	OperatorNameEnvVar = "OPERATOR_NAME"
)
View Source 
const (
	ClusterConditionPodsReady ClusterConditionType = "PodsReady"
	ClusterConditionUpgrading                      = "Upgrading"
	ClusterConditionRollback                       = "RollbackInProgress"
	ClusterConditionError                          = "Error"

	// Reasons for cluster upgrading condition
	UpdatingBookkeeperReason = "Updating Bookkeeper"
	UpgradeErrorReason       = "Upgrade Error"
	RollbackErrorReason      = "Rollback Error"
)

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "bookkeeper.pravega.io", Version: "v1alpha1"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)
View Source 
var Mgr manager.Manager

Functions

func GetOperatorName 

func GetOperatorName() (string, error)

GetOperatorName returns the operator name

Types

type BookkeeperCluster 

type BookkeeperCluster struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   BookkeeperClusterSpec   `json:"spec,omitempty"`
	Status BookkeeperClusterStatus `json:"status,omitempty"`
}

BookkeeperCluster is the Schema for the BookkeeperClusters API

func (*BookkeeperCluster) AnnotationsForBookie 

func (bk *BookkeeperCluster) AnnotationsForBookie() map[string]string

func (*BookkeeperCluster) BookkeeperImage 

func (bk *BookkeeperCluster) BookkeeperImage() (image string)

func (*BookkeeperCluster) BookkeeperTargetImage 

func (bk *BookkeeperCluster) BookkeeperTargetImage() (string, error)

func (*BookkeeperCluster) DeepCopy 

func (in *BookkeeperCluster) DeepCopy() *BookkeeperCluster

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BookkeeperCluster.

func (*BookkeeperCluster) DeepCopyInto 

func (in *BookkeeperCluster) DeepCopyInto(out *BookkeeperCluster)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BookkeeperCluster) DeepCopyObject 

func (in *BookkeeperCluster) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*BookkeeperCluster) Default 

func (bk *BookkeeperCluster) Default()

Default implements webhook.Defaulter so a webhook will be registered for the type

func (*BookkeeperCluster) GetClusterExpectedSize 

func (bk *BookkeeperCluster) GetClusterExpectedSize() (size int)

func (*BookkeeperCluster) HeadlessServiceNameForBookie 

func (bk *BookkeeperCluster) HeadlessServiceNameForBookie() string

func (*BookkeeperCluster) LabelsForBookie 

func (bk *BookkeeperCluster) LabelsForBookie() map[string]string

func (*BookkeeperCluster) LabelsForBookkeeperCluster 

func (bookkeeperCluster *BookkeeperCluster) LabelsForBookkeeperCluster() map[string]string

func (*BookkeeperCluster) NewApplicationEvent 

func (bk *BookkeeperCluster) NewApplicationEvent(name string, reason string, message string, eventType string) *corev1.Event

func (*BookkeeperCluster) NewEvent 

func (bk *BookkeeperCluster) NewEvent(name string, reason string, message string, eventType string) *corev1.Event

func (*BookkeeperCluster) SetupWebhookWithManager 

func (r *BookkeeperCluster) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*BookkeeperCluster) ValidateAbsolutePath 

func (bk *BookkeeperCluster) ValidateAbsolutePath(dirs []string) error

func (*BookkeeperCluster) ValidateBookkeeperVersion 

func (bk *BookkeeperCluster) ValidateBookkeeperVersion() error

func (*BookkeeperCluster) ValidateCreate 

func (bk *BookkeeperCluster) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*BookkeeperCluster) ValidateDelete 

func (bk *BookkeeperCluster) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*BookkeeperCluster) ValidateUpdate 

func (bk *BookkeeperCluster) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

func (*BookkeeperCluster) WaitForClusterToTerminate 

func (bk *BookkeeperCluster) WaitForClusterToTerminate(kubeClient client.Client) (err error)

Wait for pods in cluster to be terminated

func (*BookkeeperCluster) WithDefaults 

func (bk *BookkeeperCluster) WithDefaults() (changed bool)

WithDefaults set default values when not defined in the spec.

type BookkeeperClusterList 

type BookkeeperClusterList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []BookkeeperCluster `json:"items"`
}

BookkeeperClusterList contains a list of BookkeeperCluster

func (*BookkeeperClusterList) DeepCopy 

func (in *BookkeeperClusterList) DeepCopy() *BookkeeperClusterList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BookkeeperClusterList.

func (*BookkeeperClusterList) DeepCopyInto 

func (in *BookkeeperClusterList) DeepCopyInto(out *BookkeeperClusterList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BookkeeperClusterList) DeepCopyObject 

func (in *BookkeeperClusterList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type BookkeeperClusterSpec 

type BookkeeperClusterSpec struct {
	// ZookeeperUri specifies the hostname/IP address and port in the format
	// "hostname:port".
	// By default, the value "zookeeper-client:2181" is used, that corresponds to the
	// default Zookeeper service created by the Pravega Zookkeeper operator
	// available at: https://github.com/pravega/zookeeper-operator
	// +optional
	ZookeeperUri string `json:"zookeeperUri"`

	// Image defines the BookKeeper Docker image to use.
	// By default, "pravega/bookkeeper" will be used.
	// +optional
	Image *BookkeeperImageSpec `json:"image"`

	// Replicas defines the number of BookKeeper replicas.
	// Minimum is 3. Defaults to 3.
	// If testmode is enabled, 1 replica is allowed.
	// +kubebuilder:validation:Minimum=1
	// +optional
	Replicas int32 `json:"replicas"`

	// MaxUnavailableBookkeeperReplicas defines the
	// MaxUnavailable Bookkeeper Replicas
	// Default is 1.
	// +optional
	MaxUnavailableBookkeeperReplicas int32 `json:"maxUnavailableBookkeeperReplicas"`

	// Storage configures the storage for BookKeeper
	// +optional
	Storage *BookkeeperStorageSpec `json:"storage"`

	// AutoRecovery indicates whether or not BookKeeper auto recovery is enabled.
	// Defaults to true.
	// +optional
	AutoRecovery *bool `json:"autoRecovery"`

	// ServiceAccountName configures the service account used on BookKeeper instances
	ServiceAccountName string `json:"serviceAccountName,omitempty"`

	// Probes specifies the timeout values for the Readiness and Liveness Probes
	// for the bookkeeper pods.
	// +optional
	Probes *Probes `json:"probes"`

	// BookieResources specifies the request and limit of resources that bookie can have.
	// BookieResources includes CPU and memory resources
	Resources *corev1.ResourceRequirements `json:"resources,omitempty"`

	// Options is the Bookkeeper configuration that is to override the bk_server.conf
	// in bookkeeper. Some examples can be found here
	// https://github.com/apache/bookkeeper/blob/master/docker/README.md
	// +optional
	Options map[string]string `json:"options"`

	// JVM is the JVM options for bookkeeper. It will be passed to the JVM for performance tuning.
	// If this field is not specified, the operator will use a set of default
	// options that is good enough for general deployment.
	// +optional
	JVMOptions *JVMOptions `json:"jvmOptions"`

	// Provides the name of the configmap created by the user to provide additional key-value pairs
	// that need to be configured into the bookie pods as environmental variables
	EnvVars string `json:"envVars,omitempty"`

	// Version is the expected version of the Bookkeeper cluster.
	// The bookkeeper-operator will eventually make the Bookkeeper cluster version
	// equal to the expected version.
	//
	// The version must follow the [semver]( http://semver.org) format, for example "3.2.13".
	// Only Bookkeeper released versions are supported: https://hub.docker.com/r/pravega/bookkeeper/tags
	//
	// If version is not set, default is "0.4.0".
	// +optional
	Version string `json:"version"`
	// If true, AND if the owner has the "foregroundDeletion" finalizer, then
	// the owner cannot be deleted from the key-value store until this
	// reference is removed.
	// Defaults to true
	BlockOwnerDeletion *bool `json:"blockOwnerDeletion,omitempty"`

	// The scheduling constraints on Bookie pods.
	Affinity *corev1.Affinity `json:"affinity,omitempty"`

	// Labels to be added to the bookie pods
	// +optional
	Labels map[string]string `json:"labels"`

	// Annotations to be added to the bookie pods
	// +optional
	Annotations map[string]string `json:"annotations"`

	// InitContainers to be added to the bookie pods
	// +optional
	InitContainers []corev1.Container `json:"initContainers,omitempty"`

	// This is used as suffix for bookkeeper headless service name
	// +optional
	HeadlessSvcNameSuffix string `json:"headlessSvcNameSuffix,omitempty"`

	//This is set to run the container as root user
	RunAsPrivilegedUser *bool `json:"runAsPrivilegedUser,omitempty"`

	// Tolerations for the bookie pods.
	Tolerations []corev1.Toleration `json:"tolerations,omitempty"`

	// This is used to schedule the timeout value in minutes for rollback/upgrade
	UpgradeTimeout int32 `json:"upgradeTimeout,omitempty"`
}

ClusterSpec defines the desired state of BookkeeperCluster

func (*BookkeeperClusterSpec) DeepCopy 

func (in *BookkeeperClusterSpec) DeepCopy() *BookkeeperClusterSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BookkeeperClusterSpec.

func (*BookkeeperClusterSpec) DeepCopyInto 

func (in *BookkeeperClusterSpec) DeepCopyInto(out *BookkeeperClusterSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BookkeeperClusterStatus 

type BookkeeperClusterStatus struct {
	// Conditions list all the applied conditions
	Conditions []ClusterCondition `json:"conditions,omitempty"`

	// CurrentVersion is the current cluster version
	CurrentVersion string `json:"currentVersion,omitempty"`

	// TargetVersion is the version the cluster upgrading to.
	// If the cluster is not upgrading, TargetVersion is empty.
	TargetVersion string `json:"targetVersion,omitempty"`

	VersionHistory []string `json:"versionHistory,omitempty"`

	// Replicas is the number of desired replicas in the cluster
	// +optional
	Replicas int32 `json:"replicas"`

	// CurrentReplicas is the number of current replicas in the cluster
	// +optional
	CurrentReplicas int32 `json:"currentReplicas"`

	// ReadyReplicas is the number of ready replicas in the cluster
	// +optional
	ReadyReplicas int32 `json:"readyReplicas"`

	// Members is the Bookkeeper members in the cluster
	// +optional
	Members MembersStatus `json:"members"`
}

BookkeeperClusterStatus defines the observed state of BookkeeperCluster

func (*BookkeeperClusterStatus) AddToVersionHistory 

func (ps *BookkeeperClusterStatus) AddToVersionHistory(version string)

func (*BookkeeperClusterStatus) DeepCopy 

func (in *BookkeeperClusterStatus) DeepCopy() *BookkeeperClusterStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BookkeeperClusterStatus.

func (*BookkeeperClusterStatus) DeepCopyInto 

func (in *BookkeeperClusterStatus) DeepCopyInto(out *BookkeeperClusterStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*BookkeeperClusterStatus) GetClusterCondition 

func (ps *BookkeeperClusterStatus) GetClusterCondition(t ClusterConditionType) (int, *ClusterCondition)

func (*BookkeeperClusterStatus) GetLastCondition 

func (ps *BookkeeperClusterStatus) GetLastCondition() (lastCondition *ClusterCondition)

func (*BookkeeperClusterStatus) GetLastVersion 

func (ps *BookkeeperClusterStatus) GetLastVersion() (previousVersion string)

func (*BookkeeperClusterStatus) Init 

func (ps *BookkeeperClusterStatus) Init()

func (*BookkeeperClusterStatus) IsClusterInErrorState 

func (ps *BookkeeperClusterStatus) IsClusterInErrorState() bool

func (*BookkeeperClusterStatus) IsClusterInReadyState 

func (ps *BookkeeperClusterStatus) IsClusterInReadyState() bool

func (*BookkeeperClusterStatus) IsClusterInRollbackFailedState 

func (ps *BookkeeperClusterStatus) IsClusterInRollbackFailedState() bool

func (*BookkeeperClusterStatus) IsClusterInRollbackState 

func (ps *BookkeeperClusterStatus) IsClusterInRollbackState() bool

func (*BookkeeperClusterStatus) IsClusterInUpgradeFailedOrRollbackState 

func (ps *BookkeeperClusterStatus) IsClusterInUpgradeFailedOrRollbackState() bool

func (*BookkeeperClusterStatus) IsClusterInUpgradeFailedState 

func (ps *BookkeeperClusterStatus) IsClusterInUpgradeFailedState() bool

func (*BookkeeperClusterStatus) IsClusterInUpgradingState 

func (ps *BookkeeperClusterStatus) IsClusterInUpgradingState() bool

func (*BookkeeperClusterStatus) SetErrorConditionFalse 

func (ps *BookkeeperClusterStatus) SetErrorConditionFalse()

func (*BookkeeperClusterStatus) SetErrorConditionTrue 

func (ps *BookkeeperClusterStatus) SetErrorConditionTrue(reason, message string)

func (*BookkeeperClusterStatus) SetPodsReadyConditionFalse 

func (ps *BookkeeperClusterStatus) SetPodsReadyConditionFalse()

func (*BookkeeperClusterStatus) SetPodsReadyConditionTrue 

func (ps *BookkeeperClusterStatus) SetPodsReadyConditionTrue()

func (*BookkeeperClusterStatus) SetRollbackConditionFalse 

func (ps *BookkeeperClusterStatus) SetRollbackConditionFalse()

func (*BookkeeperClusterStatus) SetRollbackConditionTrue 

func (ps *BookkeeperClusterStatus) SetRollbackConditionTrue(reason, message string)

func (*BookkeeperClusterStatus) SetUpgradingConditionFalse 

func (ps *BookkeeperClusterStatus) SetUpgradingConditionFalse()

func (*BookkeeperClusterStatus) SetUpgradingConditionTrue 

func (ps *BookkeeperClusterStatus) SetUpgradingConditionTrue(reason, message string)

func (*BookkeeperClusterStatus) UpdateProgress 

func (ps *BookkeeperClusterStatus) UpdateProgress(reason, updatedReplicas string)

type BookkeeperImageSpec 

type BookkeeperImageSpec struct {
	ImageSpec `json:"imageSpec,omitempty"`
}

BookkeeperImageSpec defines the fields needed for a BookKeeper Docker image

func (*BookkeeperImageSpec) DeepCopy 

func (in *BookkeeperImageSpec) DeepCopy() *BookkeeperImageSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BookkeeperImageSpec.

func (*BookkeeperImageSpec) DeepCopyInto 

func (in *BookkeeperImageSpec) DeepCopyInto(out *BookkeeperImageSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type BookkeeperStorageSpec 

type BookkeeperStorageSpec struct {
	// LedgerVolumeClaimTemplate is the spec to describe PVC for the BookKeeper ledger
	// This field is optional. If no PVC spec and there is no default storage class,
	// stateful containers will use emptyDir as volume
	// +optional
	LedgerVolumeClaimTemplate *corev1.PersistentVolumeClaimSpec `json:"ledgerVolumeClaimTemplate"`

	// JournalVolumeClaimTemplate is the spec to describe PVC for the BookKeeper journal
	// This field is optional. If no PVC spec and there is no default storage class,
	// stateful containers will use emptyDir as volume
	// +optional
	JournalVolumeClaimTemplate *corev1.PersistentVolumeClaimSpec `json:"journalVolumeClaimTemplate"`

	// IndexVolumeClaimTemplate is the spec to describe PVC for the BookKeeper index
	// This field is optional. If no PVC spec and there is no default storage class,
	// stateful containers will use emptyDir as volume
	// +optional
	IndexVolumeClaimTemplate *corev1.PersistentVolumeClaimSpec `json:"indexVolumeClaimTemplate"`
}

BookkeeperStorageSpec is the configuration of the volumes used in BookKeeper

func (*BookkeeperStorageSpec) DeepCopy 

func (in *BookkeeperStorageSpec) DeepCopy() *BookkeeperStorageSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BookkeeperStorageSpec.

func (*BookkeeperStorageSpec) DeepCopyInto 

func (in *BookkeeperStorageSpec) DeepCopyInto(out *BookkeeperStorageSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterCondition 

type ClusterCondition struct {
	// Type of Bookkeeper cluster condition.
	// +optional
	Type ClusterConditionType `json:"type"`

	// Status of the condition, one of True, False, Unknown.
	// +optional
	Status corev1.ConditionStatus `json:"status"`

	// The reason for the condition's last transition.
	Reason string `json:"reason,omitempty"`

	// A human readable message indicating details about the transition.
	Message string `json:"message,omitempty"`

	// The last time this condition was updated.
	LastUpdateTime string `json:"lastUpdateTime,omitempty"`

	// Last time the condition transitioned from one status to another.
	LastTransitionTime string `json:"lastTransitionTime,omitempty"`
}

ClusterCondition shows the current condition of a Bookkeeper cluster. Comply with k8s API conventions

func (*ClusterCondition) DeepCopy 

func (in *ClusterCondition) DeepCopy() *ClusterCondition

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterCondition.

func (*ClusterCondition) DeepCopyInto 

func (in *ClusterCondition) DeepCopyInto(out *ClusterCondition)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ClusterConditionType 

type ClusterConditionType string

type ImageSpec 

type ImageSpec struct {
	Repository string `json:"repository"`

	// Deprecated: Use `spec.Version` instead
	Tag string `json:"tag,omitempty"`
	// +kubebuilder:validation:Enum="Always";"Never";"IfNotPresent"
	PullPolicy corev1.PullPolicy `json:"pullPolicy"`
}

ImageSpec defines the fields needed for a Docker repository image

func (*ImageSpec) DeepCopy 

func (in *ImageSpec) DeepCopy() *ImageSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ImageSpec.

func (*ImageSpec) DeepCopyInto 

func (in *ImageSpec) DeepCopyInto(out *ImageSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type JVMOptions 

type JVMOptions struct {
	// +optional
	MemoryOpts []string `json:"memoryOpts"`
	// +optional
	GcOpts []string `json:"gcOpts"`
	// +optional
	GcLoggingOpts []string `json:"gcLoggingOpts"`
	// +optional
	ExtraOpts []string `json:"extraOpts"`
}

func (*JVMOptions) DeepCopy 

func (in *JVMOptions) DeepCopy() *JVMOptions

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JVMOptions.

func (*JVMOptions) DeepCopyInto 

func (in *JVMOptions) DeepCopyInto(out *JVMOptions)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type MembersStatus 

type MembersStatus struct {
	// +optional
	// +nullable
	Ready []string `json:"ready"`
	// +optional
	// +nullable
	Unready []string `json:"unready"`
}

MembersStatus is the status of the members of the cluster with both ready and unready node membership lists

func (*MembersStatus) DeepCopy 

func (in *MembersStatus) DeepCopy() *MembersStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MembersStatus.

func (*MembersStatus) DeepCopyInto 

func (in *MembersStatus) DeepCopyInto(out *MembersStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Probe 

type Probe struct {
	// +kubebuilder:validation:Minimum=0
	// +optional
	InitialDelaySeconds int32 `json:"initialDelaySeconds"`
	// +kubebuilder:validation:Minimum=0
	// +optional
	PeriodSeconds int32 `json:"periodSeconds"`
	// +kubebuilder:validation:Minimum=0
	// +optional
	FailureThreshold int32 `json:"failureThreshold"`
	// +kubebuilder:validation:Minimum=0
	// +optional
	SuccessThreshold int32 `json:"successThreshold"`
	// +kubebuilder:validation:Minimum=0
	// +optional
	TimeoutSeconds int32 `json:"timeoutSeconds"`
}

func (*Probe) DeepCopy 

func (in *Probe) DeepCopy() *Probe

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Probe.

func (*Probe) DeepCopyInto 

func (in *Probe) DeepCopyInto(out *Probe)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Probes 

type Probes struct {
	// +optional
	ReadinessProbe *Probe `json:"readinessProbe"`
	// +optional
	LivenessProbe *Probe `json:"livenessProbe"`
}

func (*Probes) DeepCopy 

func (in *Probes) DeepCopy() *Probes

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Probes.

func (*Probes) DeepCopyInto 

func (in *Probes) DeepCopyInto(out *Probes)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

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.