v1beta1

Aug 8, 2023

Changes in this version

+ const PodServiceLabelAddedAnnotation

+ const ReasonMilvusStopping

+ const ServiceLabel

+ var DeploymentPausedReason = "DeploymentPaused"

type DeploymentState

+ const DeploymentPaused

type Milvus

+ func (m *Milvus) IsChangingMode() bool

+ func (m *Milvus) IsFirstTimeStarting() bool

+ func (m *Milvus) IsPodServiceLabelAdded() bool

type ServiceComponent

+ ServiceRestfulPort int32

Jul 5, 2023

Changes in this version

type Values

+ func (v *Values) FromObject(obj interface{}) error

Jun 15, 2023

Changes in this version

type ComponentSpec

+ PriorityClassName string

Jun 5, 2023

Changes in this version

type Component

+ InitContainers []Values

+ SideCars []Values

Apr 14, 2023

Changes in this version

+ type MilvusConditionType string

Feb 15, 2023

Changes in this version

+ const EnableActiveStandByConfig

+ const MilvusUpdated

+ const ReasonMilvusComponentsUpdated

+ const ReasonMilvusComponentsUpdating

+ const ReasonMilvusDowngradingImage

+ const ReasonMilvusUpgradingImage

type ComponentDeployStatus

+ Image string

+ type ImageUpdateMode string

+ const ImageUpdateModeAll

+ const ImageUpdateModeRollingDowngrade

+ const ImageUpdateModeRollingUpgrade

type Milvus

+ func (m *Milvus) IsRollingUpdateEnabled() bool

type MilvusComponents

+ EnableRollingUpdate *bool

+ ImageUpdateMode ImageUpdateMode

Feb 10, 2023

Changes in this version

+ const ReasonMilvusStopped

+ const StatusPending

+ const StatusStopped

+ const StatusUnhealthy

+ var NewReplicaSetAvailableReason = "NewReplicaSetAvailable"

type ComponentDeployStatus

+ func (c ComponentDeployStatus) GetState() DeploymentState

+ type DeploymentState string

+ const DeploymentComplete

+ const DeploymentFailed

+ const DeploymentProgressing

type MilvusSpec

+ func (ms MilvusSpec) IsStopping() bool

Jan 13, 2023

Changes in this version

+ type ComponentDeployStatus struct

+ Generation int64

+ Status appsv1.DeploymentStatus

+ func (in *ComponentDeployStatus) DeepCopy() *ComponentDeployStatus

+ func (in *ComponentDeployStatus) DeepCopyInto(out *ComponentDeployStatus)

type ComponentSpec

+ Paused bool

type MilvusStatus

+ ComponentsDeployStatus map[string]ComponentDeployStatus

+ DeprecatedReplicas MilvusReplicas

type MilvusUpgradeState

+ func (s MilvusUpgradeState) NeedRequeue() bool

Nov 18, 2022

Changes in this version

+ const AnnotationUpgraded

+ const AnnotationUpgrading

+ const StoppedAtAnnotation

+ const UpgradeAnnotation

+ var MilvusUpgradeKind = reflect.TypeOf(MilvusUpgrade{}).Name()

+ func AddPrefixV(version string) string

+ func InitLabelAnnotation(obj client.Object)

+ func RemovePrefixV(version string) string

type Milvus

+ func (m *Milvus) RemoveStoppedAtAnnotation()

+ func (m *Milvus) SetStoppedAtAnnotation(t time.Time)

type MilvusCondition

+ func GetMilvusConditionByType(status *MilvusStatus, conditionType MiluvsConditionType) *MilvusCondition

+ type MilvusOperation string

+ const OperationRollback

+ const OperationUpgrade

+ type MilvusUpgrade struct

+ Spec MilvusUpgradeSpec

+ Status MilvusUpgradeStatus

+ func (in *MilvusUpgrade) DeepCopy() *MilvusUpgrade

+ func (in *MilvusUpgrade) DeepCopyInto(out *MilvusUpgrade)

+ func (in *MilvusUpgrade) DeepCopyObject() runtime.Object

+ func (r *MilvusUpgrade) Default()

+ func (r *MilvusUpgrade) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *MilvusUpgrade) ValidateCreate() error

+ func (r *MilvusUpgrade) ValidateDelete() error

+ func (r *MilvusUpgrade) ValidateUpdate(old runtime.Object) error

+ func (r MilvusUpgrade) Validate() error

+ type MilvusUpgradeList struct

+ Items []MilvusUpgrade

+ func (in *MilvusUpgradeList) DeepCopy() *MilvusUpgradeList

+ func (in *MilvusUpgradeList) DeepCopyInto(out *MilvusUpgradeList)

+ func (in *MilvusUpgradeList) DeepCopyObject() runtime.Object

+ type MilvusUpgradeSpec struct

+ BackupPVC string

+ MaxRetry int

+ Milvus ObjectReference

+ Operation MilvusOperation

+ RollbackIfFailed bool

+ SourceVersion string

+ TargetImage string

+ TargetVersion string

+ ToolImage string

+ func (in *MilvusUpgradeSpec) DeepCopy() *MilvusUpgradeSpec

+ func (in *MilvusUpgradeSpec) DeepCopyInto(out *MilvusUpgradeSpec)

+ type MilvusUpgradeState string

+ const UpgradeStateBackupMeta

+ const UpgradeStateBakupMetaFailed

+ const UpgradeStateNewVersionStarting

+ const UpgradeStateOldVersionStopping

+ const UpgradeStatePending

+ const UpgradeStateRollbackFailed

+ const UpgradeStateRollbackNewVersionStopping

+ const UpgradeStateRollbackOldVersionStarting

+ const UpgradeStateRollbackRestoringOldMeta

+ const UpgradeStateRollbackSucceeded

+ const UpgradeStateSucceeded

+ const UpgradeStateUpdateMetaFailed

+ const UpgradeStateUpdatingMeta

+ type MilvusUpgradeStatus struct

+ BackupPVC string

+ Conditions []metav1.Condition

+ IsRollbacking bool

+ MetaBackuped bool

+ MetaStorageChanged bool

+ ReplicasBeforeUpgrade *MilvusReplicas

+ RetriedTimes int

+ SourceImage string

+ State MilvusUpgradeState

+ func (in *MilvusUpgradeStatus) DeepCopy() *MilvusUpgradeStatus

+ func (in *MilvusUpgradeStatus) DeepCopyInto(out *MilvusUpgradeStatus)

+ type ObjectReference struct

+ Name string

+ Namespace string

+ func (in *ObjectReference) DeepCopy() *ObjectReference

+ func (in *ObjectReference) DeepCopyInto(out *ObjectReference)

+ func (o ObjectReference) Object() types.NamespacedName

Oct 11, 2022

Changes in this version

type ComponentSpec

+ SchedulerName string

Oct 9, 2022

Changes in this version

type ComponentSpec

+ PodAnnotations map[string]string

+ PodLabels map[string]string

Sep 16, 2022

Changes in this version

type ComponentSpec

+ Commands []string

Aug 30, 2022

Changes in this version

type ComponentSpec

+ VolumeMounts []corev1.VolumeMount

+ Volumes []Values

type Values

+ func (v Values) AsObject(obj interface{}) error

+ func (v Values) MustAsObj(obj interface{})

Jul 22, 2022

Changes in this version

type MilvusStatus

+ ObservedGeneration int64

Jul 12, 2022

Changes in this version

+ const DependencyValuesLegacySyncedAnnotation

+ const DependencyValuesMergedAnnotation

+ const FalseStr

+ const LegacyVersion

+ const MilvusIO

+ const OperatorVersionLabel

+ const TrueStr

+ var MilvusHelmVersion = "unknown"

+ var Version = "unknown"

type Milvus

+ func (r *Milvus) DefaultComponents()

+ func (r *Milvus) DefaultConf()

+ func (r *Milvus) DefaultDependencies()

+ func (r *Milvus) DefaultMeta()

+ func (r *Milvus) DefaultMode()

+ func (r *Milvus) LegacyNeedSyncValues() bool

+ func (r *Milvus) SetLegacySynced()

Jun 24, 2022

Changes in this version

+ const EtcdReady

+ const MilvusReady

+ const MsgStreamReady

+ const ReasonClientErr

+ const ReasonDependencyNotReady

+ const ReasonEndpointsHealthy

+ const ReasonEtcdNotReady

+ const ReasonEtcdReady

+ const ReasonMilvusComponentNotHealthy

+ const ReasonMilvusHealthy

+ const ReasonMsgStreamNotReady

+ const ReasonMsgStreamReady

+ const ReasonS3Ready

+ const ReasonSecretDecodeErr

+ const ReasonSecretErr

+ const ReasonSecretNotExist

+ const ReasonStorageNotReady

+ const ReasonStorageReady

+ const RocksMQPersistPath

+ const StatusCreating

+ const StatusDeleting

+ const StatusHealthy

+ const StatusUnHealthy

+ const StorageReady

+ const StorageTypeMinIO

+ const StorageTypeS3

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var GroupVersion = schema.GroupVersion

+ var MilvusComponentTypes = []ComponentType

+ var MilvusCoordTypes = []ComponentType

+ var SchemeBuilder = &scheme.Builder

+ var SchemeGroupVersion = GroupVersion

+ func Resource(resource string) schema.GroupResource

+ type Component struct

+ Port int32

+ Replicas *int32

+ func (in *Component) DeepCopy() *Component

+ func (in *Component) DeepCopyInto(out *Component)

+ type ComponentSpec struct

+ Affinity *corev1.Affinity

+ Env []corev1.EnvVar

+ Image string

+ ImagePullPolicy *corev1.PullPolicy

+ ImagePullSecrets []corev1.LocalObjectReference

+ NodeSelector map[string]string

+ Resources *corev1.ResourceRequirements

+ ServiceAccountName string

+ Tolerations []corev1.Toleration

+ func (in *ComponentSpec) DeepCopy() *ComponentSpec

+ func (in *ComponentSpec) DeepCopyInto(out *ComponentSpec)

+ type ComponentType string

+ const DataCoord

+ const DataNode

+ const IndexCoord

+ const IndexNode

+ const Proxy

+ const QueryCoord

+ const QueryNode

+ const RootCoord

+ func (t ComponentType) String() string

+ type DependencyDeletionPolicy string

+ const DeletionPolicyDelete

+ const DeletionPolicyRetain

+ type InClusterConfig struct

+ DeletionPolicy DependencyDeletionPolicy

+ PVCDeletion bool

+ Values Values

+ func (in *InClusterConfig) DeepCopy() *InClusterConfig

+ func (in *InClusterConfig) DeepCopyInto(out *InClusterConfig)

+ type MiluvsConditionType string

+ type Milvus struct

+ Spec MilvusSpec

+ Status MilvusStatus

+ func (*Milvus) Hub()

+ func (in *Milvus) DeepCopy() *Milvus

+ func (in *Milvus) DeepCopyInto(out *Milvus)

+ func (in *Milvus) DeepCopyObject() runtime.Object

+ func (r *Milvus) Default()

+ func (r *Milvus) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Milvus) ValidateCreate() error

+ func (r *Milvus) ValidateDelete() error

+ func (r *Milvus) ValidateUpdate(old runtime.Object) error

+ type MilvusComponents struct

+ DataCoord *MilvusDataCoord

+ DataNode *MilvusDataNode

+ DisableMetric bool

+ IndexCoord *MilvusIndexCoord

+ IndexNode *MilvusIndexNode

+ MetricInterval string

+ MixCoord *MilvusMixCoord

+ Proxy *MilvusProxy

+ QueryCoord *MilvusQueryCoord

+ QueryNode *MilvusQueryNode

+ RootCoord *MilvusRootCoord

+ Standalone *MilvusStandalone

+ ToolImage string

+ UpdateToolImage bool

+ func (in *MilvusComponents) DeepCopy() *MilvusComponents

+ func (in *MilvusComponents) DeepCopyInto(out *MilvusComponents)

+ type MilvusCondition struct

+ LastTransitionTime *metav1.Time

+ Message string

+ Reason string

+ Status corev1.ConditionStatus

+ Type MiluvsConditionType

+ func (in *MilvusCondition) DeepCopy() *MilvusCondition

+ func (in *MilvusCondition) DeepCopyInto(out *MilvusCondition)

+ type MilvusDataCoord struct

+ func (in *MilvusDataCoord) DeepCopy() *MilvusDataCoord

+ func (in *MilvusDataCoord) DeepCopyInto(out *MilvusDataCoord)

+ type MilvusDataNode struct

+ func (in *MilvusDataNode) DeepCopy() *MilvusDataNode

+ func (in *MilvusDataNode) DeepCopyInto(out *MilvusDataNode)

+ type MilvusDependencies struct

+ Etcd MilvusEtcd

+ Kafka MilvusKafka

+ MsgStreamType MsgStreamType

+ Pulsar MilvusPulsar

+ RocksMQ MilvusRocksMQ

+ Storage MilvusStorage

+ func (in *MilvusDependencies) DeepCopy() *MilvusDependencies

+ func (in *MilvusDependencies) DeepCopyInto(out *MilvusDependencies)

+ type MilvusEtcd struct

+ Endpoints []string

+ External bool

+ InCluster *InClusterConfig

+ func (in *MilvusEtcd) DeepCopy() *MilvusEtcd

+ func (in *MilvusEtcd) DeepCopyInto(out *MilvusEtcd)

+ type MilvusHealthStatus string

+ type MilvusIndexCoord struct

+ func (in *MilvusIndexCoord) DeepCopy() *MilvusIndexCoord

+ func (in *MilvusIndexCoord) DeepCopyInto(out *MilvusIndexCoord)

+ type MilvusIndexNode struct

+ func (in *MilvusIndexNode) DeepCopy() *MilvusIndexNode

+ func (in *MilvusIndexNode) DeepCopyInto(out *MilvusIndexNode)

+ type MilvusIngress struct

+ Annotations map[string]string

+ Hosts []string

+ IngressClassName *string

+ Labels map[string]string

+ TLSSecretRefs map[string][]string

+ func (in *MilvusIngress) DeepCopy() *MilvusIngress

+ func (in *MilvusIngress) DeepCopyInto(out *MilvusIngress)

+ type MilvusKafka struct

+ BrokerList []string

+ External bool

+ InCluster *InClusterConfig

+ func (in *MilvusKafka) DeepCopy() *MilvusKafka

+ func (in *MilvusKafka) DeepCopyInto(out *MilvusKafka)

+ type MilvusList struct

+ Items []Milvus

+ func (in *MilvusList) DeepCopy() *MilvusList

+ func (in *MilvusList) DeepCopyInto(out *MilvusList)

+ func (in *MilvusList) DeepCopyObject() runtime.Object

+ type MilvusMixCoord struct

+ func (in *MilvusMixCoord) DeepCopy() *MilvusMixCoord

+ func (in *MilvusMixCoord) DeepCopyInto(out *MilvusMixCoord)

+ type MilvusMode string

+ const MilvusModeCluster

+ const MilvusModeStandalone

+ type MilvusProxy struct

+ func (in *MilvusProxy) DeepCopy() *MilvusProxy

+ func (in *MilvusProxy) DeepCopyInto(out *MilvusProxy)

+ type MilvusPulsar struct

+ Endpoint string

+ External bool

+ InCluster *InClusterConfig

+ func (in *MilvusPulsar) DeepCopy() *MilvusPulsar

+ func (in *MilvusPulsar) DeepCopyInto(out *MilvusPulsar)

+ type MilvusQueryCoord struct

+ func (in *MilvusQueryCoord) DeepCopy() *MilvusQueryCoord

+ func (in *MilvusQueryCoord) DeepCopyInto(out *MilvusQueryCoord)

+ type MilvusQueryNode struct

+ func (in *MilvusQueryNode) DeepCopy() *MilvusQueryNode

+ func (in *MilvusQueryNode) DeepCopyInto(out *MilvusQueryNode)

+ type MilvusReplicas struct

+ DataCoord int

+ DataNode int

+ IndexCoord int

+ IndexNode int

+ MixCoord int

+ Proxy int

+ QueryCoord int

+ QueryNode int

+ RootCoord int

+ Standalone int

+ func (in *MilvusReplicas) DeepCopy() *MilvusReplicas

+ func (in *MilvusReplicas) DeepCopyInto(out *MilvusReplicas)

+ type MilvusRocksMQ struct

+ Persistence Persistence

+ func (in *MilvusRocksMQ) DeepCopy() *MilvusRocksMQ

+ func (in *MilvusRocksMQ) DeepCopyInto(out *MilvusRocksMQ)

+ type MilvusRootCoord struct

+ func (in *MilvusRootCoord) DeepCopy() *MilvusRootCoord

+ func (in *MilvusRootCoord) DeepCopyInto(out *MilvusRootCoord)

+ type MilvusSpec struct

+ Com MilvusComponents

+ Conf Values

+ Dep MilvusDependencies

+ Mode MilvusMode

+ func (in *MilvusSpec) DeepCopy() *MilvusSpec

+ func (in *MilvusSpec) DeepCopyInto(out *MilvusSpec)

+ func (ms MilvusSpec) GetServiceComponent() *ServiceComponent

+ type MilvusStandalone struct

+ func (in *MilvusStandalone) DeepCopy() *MilvusStandalone

+ func (in *MilvusStandalone) DeepCopyInto(out *MilvusStandalone)

+ type MilvusStatus struct

+ Conditions []MilvusCondition

+ Endpoint string

+ IngressStatus networkv1.IngressStatus

+ Replicas MilvusReplicas

+ Status MilvusHealthStatus

+ func (in *MilvusStatus) DeepCopy() *MilvusStatus

+ func (in *MilvusStatus) DeepCopyInto(out *MilvusStatus)

+ type MilvusStorage struct

+ Endpoint string

+ External bool

+ InCluster *InClusterConfig

+ SecretRef string

+ Type string

+ func (in *MilvusStorage) DeepCopy() *MilvusStorage

+ func (in *MilvusStorage) DeepCopyInto(out *MilvusStorage)

+ type MsgStreamType string

+ const MsgStreamTypeKafka

+ const MsgStreamTypePulsar

+ const MsgStreamTypeRocksMQ

+ type Persistence struct

+ Enabled bool

+ PVCDeletion bool

+ PersistentVolumeClaim PersistentVolumeClaim

+ func (in *Persistence) DeepCopy() *Persistence

+ func (in *Persistence) DeepCopyInto(out *Persistence)

+ type PersistentVolumeClaim struct

+ Annotations map[string]string

+ ExistingClaim string

+ Labels map[string]string

+ Spec corev1.PersistentVolumeClaimSpec

+ func (in *PersistentVolumeClaim) DeepCopy() *PersistentVolumeClaim

+ func (in *PersistentVolumeClaim) DeepCopyInto(out *PersistentVolumeClaim)

+ type ServiceComponent struct

+ Ingress *MilvusIngress

+ ServiceAnnotations map[string]string

+ ServiceLabels map[string]string

+ ServiceType corev1.ServiceType

+ func (in *ServiceComponent) DeepCopy() *ServiceComponent

+ func (in *ServiceComponent) DeepCopyInto(out *ServiceComponent)

+ type Values struct

+ Data map[string]interface{}

+ func (in *Values) DeepCopy() *Values

+ func (v *Values) DeepCopyInto(out *Values)

+ func (v *Values) UnmarshalJSON(data []byte) error

+ func (v Values) MarshalJSON() ([]byte, error)