v1alpha1

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the v1alpha1 API group +kubebuilder:object:generate=true +groupName=xline.io.datenlord.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "xline.io.datenlord.com", 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
)

Functions

This section is empty.

Types

type NamespacedName 

type NamespacedName struct {
	Name      string `json:"name,omitempty"`
	Namespace string `json:"namespace,omitempty"`
}

NamespacedName is the name and namespace of the kubernetes object +k8s:openapi-gen=true

func NewNamespacedName 

func NewNamespacedName(name types.NamespacedName) NamespacedName

func (*NamespacedName) DeepCopy 

func (in *NamespacedName) DeepCopy() *NamespacedName

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

func (*NamespacedName) DeepCopyInto 

func (in *NamespacedName) DeepCopyInto(out *NamespacedName)

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

type OprStageAction 

type OprStageAction string

OprStageAction represents the action type of controller reconcile stage 

const (
	StageActionApply  OprStageAction = "apply"
	StageActionDelete OprStageAction = "delete"
)

type OprStageStatus 

type OprStageStatus string

OprStageStatus represents the status of controller stage 

const (
	StageResultSucceeded OprStageStatus = "succeeded"
	StageResultFailed    OprStageStatus = "failed"
)

type XlineArgs 

type XlineArgs struct {
	JaegerOffline    bool    `json:"jaeger-offline,omitempty"`
	JaegerOnline     bool    `json:"jaeger-online,omitempty"`
	JaegerLevel      bool    `json:"jaeger-level,omitempty"`
	ClientUseBackoff bool    `json:"client-use-backoff,omitempty"`
	AuthPrivateKey   *string `json:"auth-private-key,omitempty"`
	AuthPublicKey    *string `json:"auth-public-key,omitempty"`
	JaegerOutputDir  *string `json:"jaeger-output-dir,omitempty"`
	LogFile          *string `json:"log-file,omitempty"`
	LogRotate        *string `json:"log-rotate,omitempty"`

	// +kubebuilder:validation:Enum=off;info;error;warn;trace;debug
	LogLevel *string `json:"log-level,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	HeartbeatInterval *string `json:"heartbeat-interval,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	ServerWaitSyncedTimeout *string `json:"server-wait-synced-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	RetryTimeout *string `json:"retry-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	RpcTimeout *string `json:"rpc-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	BatchTimeout *string `json:"batch-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	ClientWaitSyncedTimeout *string `json:"client-wait-synced-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	ClientProposeTimeout *string `json:"client-propose-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	ClientInitialRetryTimeout *string `json:"client-initial-retry-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	ClientMaxRetryTimeout *string `json:"client-max-retry-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	GcInterval *string `json:"gc-interval,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	RangeRetryTimeout *string `json:"range-retry-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	CompactTimeout *string `json:"compact-timeout,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	SyncVictimsInterval *string `json:"sync-victims-interval,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	WatchProgressNotifyInterval *string `json:"watch-progress-notify-interval,omitempty"`
	CurpDir                     *string `json:"curp-dir,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(us|ms|s|m|h|d)
	CompactSleepInterval *string `json:"compact-sleep-interval,omitempty"`
	// +kubebuilder:validation:Pattern=\d+(B|MB|GB)
	BatchMaxSize *string `json:"batch-max-size,omitempty"`
	// +kubebuilder:validation:Minimum=1
	RetryCount int `json:"retry-count,omitempty"`
	// +kubebuilder:validation:Minimum=1
	FollowerTimeoutTicks int `json:"follower-timeout-ticks,omitempty"`
	// +kubebuilder:validation:Minimum=1
	CandidateTimeoutTicks int `json:"candidate-timeout-ticks,omitempty"`
	// +kubebuilder:validation:Minimum=1
	LogEntriesCap int `json:"log-entries-cap,omitempty"`
	// +kubebuilder:validation:Minimum=1
	CmdWorkers int `json:"cmd-workers,omitempty"`
	// +kubebuilder:validation:Minimum=1
	CompactBatchSize int `json:"compact-batch-size,omitempty"`
	// +kubebuilder:validation:Minimum=1
	Quota int `json:"quota,omitempty"`
}

func (*XlineArgs) DeepCopy 

func (in *XlineArgs) DeepCopy() *XlineArgs

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

func (*XlineArgs) DeepCopyInto 

func (in *XlineArgs) DeepCopyInto(out *XlineArgs)

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

type XlineCluster 

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

	Spec   XlineClusterSpec   `json:"spec,omitempty"`
	Status XlineClusterStatus `json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*XlineCluster) DeepCopy 

func (in *XlineCluster) DeepCopy() *XlineCluster

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

func (*XlineCluster) DeepCopyInto 

func (in *XlineCluster) DeepCopyInto(out *XlineCluster)

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

func (*XlineCluster) DeepCopyObject 

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

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

func (*XlineCluster) ObjKey 

func (e *XlineCluster) ObjKey() types.NamespacedName

type XlineClusterList 

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

XlineClusterList contains a list of XlineCluster +kubebuilder:object:root=true

func (*XlineClusterList) DeepCopy 

func (in *XlineClusterList) DeepCopy() *XlineClusterList

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

func (*XlineClusterList) DeepCopyInto 

func (in *XlineClusterList) DeepCopyInto(out *XlineClusterList)

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

func (*XlineClusterList) DeepCopyObject 

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

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

type XlineClusterOprStage 

type XlineClusterOprStage string

XlineClusterOprStage represents XlineCluster operator stage 

const (
	StageXlineService     XlineClusterOprStage = "Xline/Service"
	StageXlineStatefulSet XlineClusterOprStage = "Xline/Statefulset"
	StageComplete         XlineClusterOprStage = "complete"
)

type XlineClusterRecStatus 

type XlineClusterRecStatus struct {
	Stage       XlineClusterOprStage `json:"stage,omitempty"`
	StageStatus OprStageStatus       `json:"stageStatus,omitempty"`
	LastMessage string               `json:"lastMessage,omitempty"`
}

XlineClusterRecStatus represents XlineCluster reconcile status

func (*XlineClusterRecStatus) DeepCopy 

func (in *XlineClusterRecStatus) DeepCopy() *XlineClusterRecStatus

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

func (*XlineClusterRecStatus) DeepCopyInto 

func (in *XlineClusterRecStatus) DeepCopyInto(out *XlineClusterRecStatus)

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

type XlineClusterSpec 

type XlineClusterSpec struct {
	// Xline cluster image
	Image *string `json:"image,omitempty"`

	/// Xline container bootstrap arguments
	/// Set additional arguments except [`--name`, `--members`, `--storage-engine`, `--data-dir`]
	BootstrapArgs XlineArgs `json:"bootstrapArgs,omitempty"`

	// ImagePullPolicy of Xline cluster Pods
	// +optional
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`

	// The replicas of xline nodes
	// +kubebuilder:validation:Minimum=3
	Replicas int32 `json:"replicas"`
}

XlineClusterSpec defines the desired state of XlineCluster +k8s:openapi-gen=true

func (*XlineClusterSpec) BootArgs 

func (s *XlineClusterSpec) BootArgs() []string

func (*XlineClusterSpec) DeepCopy 

func (in *XlineClusterSpec) DeepCopy() *XlineClusterSpec

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

func (*XlineClusterSpec) DeepCopyInto 

func (in *XlineClusterSpec) DeepCopyInto(out *XlineClusterSpec)

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

type XlineClusterStatus 

type XlineClusterStatus struct {
	LastApplySpecHash      *string `json:"lastApplySpecHash,omitempty"`
	XlineClusterRecStatus  `json:",inline"`
	XlineClusterSyncStatus `json:",inline"`
}

XlineClusterStatus defines the observed state of XlineCluster

func (*XlineClusterStatus) DeepCopy 

func (in *XlineClusterStatus) DeepCopy() *XlineClusterStatus

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

func (*XlineClusterStatus) DeepCopyInto 

func (in *XlineClusterStatus) DeepCopyInto(out *XlineClusterStatus)

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

type XlineClusterSyncStatus 

type XlineClusterSyncStatus struct {
	Image          string                       `json:"image,omitempty"`
	StatefulSetRef NamespacedName               `json:"statefulSetRef,omitempty"`
	ServiceRef     NamespacedName               `json:"serviceRef,omitempty"`
	Conditions     []appv1.StatefulSetCondition `json:"conditions,omitempty"`
}

XlineClusterSyncStatus represents XlineCluster sync status

func (*XlineClusterSyncStatus) DeepCopy 

func (in *XlineClusterSyncStatus) DeepCopy() *XlineClusterSyncStatus

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

func (*XlineClusterSyncStatus) DeepCopyInto 

func (in *XlineClusterSyncStatus) DeepCopyInto(out *XlineClusterSyncStatus)

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.