v1alpha1

Documentation

Overview

Package v1alpha1 contains API Schema definitions for the kvrocks.apache.org v1alpha1 API group +kubebuilder:object:generate=true +groupName=kvrocks.apache.org

Index

• Constants
• Variables
• type ImportMsg
  • func (in *ImportMsg) DeepCopy() *ImportMsg
  • func (in *ImportMsg) DeepCopyInto(out *ImportMsg)
• type KVRocks
  • func (in *KVRocks) DeepCopy() *KVRocks
  • func (in *KVRocks) DeepCopyInto(out *KVRocks)
  • func (in *KVRocks) DeepCopyObject() runtime.Object
• type KVRocksList
  • func (in *KVRocksList) DeepCopy() *KVRocksList
  • func (in *KVRocksList) DeepCopyInto(out *KVRocksList)
  • func (in *KVRocksList) DeepCopyObject() runtime.Object
• type KVRocksShrinkMsg
  • func (in *KVRocksShrinkMsg) DeepCopy() *KVRocksShrinkMsg
  • func (in *KVRocksShrinkMsg) DeepCopyInto(out *KVRocksShrinkMsg)
• type KVRocksSpec
  • func (in *KVRocksSpec) DeepCopy() *KVRocksSpec
  • func (in *KVRocksSpec) DeepCopyInto(out *KVRocksSpec)
• type KVRocksStatus
  • func (in *KVRocksStatus) DeepCopy() *KVRocksStatus
  • func (in *KVRocksStatus) DeepCopyInto(out *KVRocksStatus)
• type KVRocksStatusType
• type KVRocksStorage
  • func (in *KVRocksStorage) DeepCopy() *KVRocksStorage
  • func (in *KVRocksStorage) DeepCopyInto(out *KVRocksStorage)
• type KVRocksTopoPartitions
  • func (in *KVRocksTopoPartitions) DeepCopy() *KVRocksTopoPartitions
  • func (in *KVRocksTopoPartitions) DeepCopyInto(out *KVRocksTopoPartitions)
• type KVRocksTopology
  • func (in *KVRocksTopology) DeepCopy() *KVRocksTopology
  • func (in *KVRocksTopology) DeepCopyInto(out *KVRocksTopology)
• type KVRocksType
• type MigrateMsg
  • func (in *MigrateMsg) DeepCopy() *MigrateMsg
  • func (in *MigrateMsg) DeepCopyInto(out *MigrateMsg)

Constants

const KVRocksFinalizer = "kvrocks/finalizer"

Variables

var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "kvrocks.apache.org", 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
)

Types

type ImportMsg

type ImportMsg struct {
	SrcNode string   `json:"srcNode"`
	Slots   []string `json:"slots"`
}

func (*ImportMsg) DeepCopy

func (in *ImportMsg) DeepCopy() *ImportMsg

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

func (*ImportMsg) DeepCopyInto

func (in *ImportMsg) DeepCopyInto(out *ImportMsg)

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

type KVRocks

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

	Spec   KVRocksSpec   `json:"spec,omitempty"`
	Status KVRocksStatus `json:"status,omitempty"`
}

KVRocks is the Schema for the kvrocks API

func (*KVRocks) DeepCopy

func (in *KVRocks) DeepCopy() *KVRocks

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

func (*KVRocks) DeepCopyInto

func (in *KVRocks) DeepCopyInto(out *KVRocks)

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

func (*KVRocks) DeepCopyObject

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

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

type KVRocksList

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

KVRocksList contains a list of KVRocks

func (*KVRocksList) DeepCopy

func (in *KVRocksList) DeepCopy() *KVRocksList

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

func (*KVRocksList) DeepCopyInto

func (in *KVRocksList) DeepCopyInto(out *KVRocksList)

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

func (*KVRocksList) DeepCopyObject

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

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

type KVRocksShrinkMsg

type KVRocksShrinkMsg struct {
	Partition  []int            `json:"partition,omitempty"`
	ReserveMsg map[string][]int `json:"reserveMsg,omitempty"`
}

func (*KVRocksShrinkMsg) DeepCopy

func (in *KVRocksShrinkMsg) DeepCopy() *KVRocksShrinkMsg

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

func (*KVRocksShrinkMsg) DeepCopyInto

func (in *KVRocksShrinkMsg) DeepCopyInto(out *KVRocksShrinkMsg)

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

type KVRocksSpec

type KVRocksSpec struct {
	Image           string            `json:"image"`
	ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy,omitempty"`
	Type            KVRocksType       `json:"type"`
	KVRocksConfig   map[string]string `json:"kvrocksConfig,omitempty"`
	// RocksDBConfig   map[string]string            `json:"rocksDBConfig,omitempty"`
	Replicas int32 `json:"replicas"`
	// +optional
	Master       uint                         `json:"master"`
	Password     string                       `json:"password"`
	Resources    *corev1.ResourceRequirements `json:"resources"`
	NodeSelector map[string]string            `json:"nodeSelector,omitempty"`
	Toleration   []corev1.Toleration          `json:"toleration,omitempty"`
	Affinity     *corev1.Affinity             `json:"affinity,omitempty"`
	Storage      *KVRocksStorage              `json:"storage,omitempty"`
}

KVRocksSpec defines the desired state of KVRocks

func (*KVRocksSpec) DeepCopy

func (in *KVRocksSpec) DeepCopy() *KVRocksSpec

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

func (*KVRocksSpec) DeepCopyInto

func (in *KVRocksSpec) DeepCopyInto(out *KVRocksSpec)

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

type KVRocksStatus

type KVRocksStatus struct {
	Status    KVRocksStatusType       `json:"status,omitempty"`
	Reason    string                  `json:"reason,omitempty"`
	Version   int                     `json:"version,omitempty"`
	Rebalance bool                    `json:"rebalance,omitempty"`
	Topo      []KVRocksTopoPartitions `json:"topo,omitempty"`
	Shrink    *KVRocksShrinkMsg       `json:"shrink,omitempty"`
}

KVRocksStatus defines the observed state of KVRocks

func (*KVRocksStatus) DeepCopy

func (in *KVRocksStatus) DeepCopy() *KVRocksStatus

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

func (*KVRocksStatus) DeepCopyInto

func (in *KVRocksStatus) DeepCopyInto(out *KVRocksStatus)

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

type KVRocksStatusType

type KVRocksStatusType string

const (
	StatusNone     KVRocksStatusType = ""
	StatusCreating KVRocksStatusType = "Creating"
	StatusRunning  KVRocksStatusType = "Running"
	StatusFailed   KVRocksStatusType = "Failed"
)

type KVRocksStorage

type KVRocksStorage struct {
	Size  resource.Quantity `json:"size"`
	Class string            `json:"class"`
}

func (*KVRocksStorage) DeepCopy

func (in *KVRocksStorage) DeepCopy() *KVRocksStorage

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

func (*KVRocksStorage) DeepCopyInto

func (in *KVRocksStorage) DeepCopyInto(out *KVRocksStorage)

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

type KVRocksTopoPartitions

type KVRocksTopoPartitions struct {
	PartitionName string            `json:"partitionName"`
	Topology      []KVRocksTopology `json:"topology"`
}

func (*KVRocksTopoPartitions) DeepCopy

func (in *KVRocksTopoPartitions) DeepCopy() *KVRocksTopoPartitions

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

func (*KVRocksTopoPartitions) DeepCopyInto

func (in *KVRocksTopoPartitions) DeepCopyInto(out *KVRocksTopoPartitions)

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

type KVRocksTopology

type KVRocksTopology struct {
	Pod      string       `json:"pod"`
	Role     string       `json:"role"`
	NodeId   string       `json:"nodeId"`
	Ip       string       `json:"ip"`
	Port     uint32       `json:"port"`
	Slots    []string     `json:"slots,omitempty"`
	MasterId string       `json:"masterId,omitempty"`
	Migrate  []MigrateMsg `json:"migrate,omitempty"`
	Import   []ImportMsg  `json:"import,omitempty"`
	Failover bool         `json:"failover,omitempty"`
}

func (*KVRocksTopology) DeepCopy

func (in *KVRocksTopology) DeepCopy() *KVRocksTopology

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

func (*KVRocksTopology) DeepCopyInto

func (in *KVRocksTopology) DeepCopyInto(out *KVRocksTopology)

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

type KVRocksType

type KVRocksType string

const (
	SentinelType KVRocksType = "sentinel"
	StandardType KVRocksType = "standard"
	ClusterType  KVRocksType = "cluster"
)

type MigrateMsg

type MigrateMsg struct {
	DstNode string   `json:"dstNode"`
	Slots   []string `json:"slots"`
}

func (*MigrateMsg) DeepCopy

func (in *MigrateMsg) DeepCopy() *MigrateMsg

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

func (*MigrateMsg) DeepCopyInto

func (in *MigrateMsg) DeepCopyInto(out *MigrateMsg)

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