Versions in this module Expand all Collapse all v1 v1.0.0 Jun 5, 2025 Changes in this version + func NewNodeRole(v string) core.NodeRole + func NewOperatorUser(secret *v1.Secret) (*user.User, error) + func NewSentinelUser(name string, role user.UserRole, secret *v1.Secret) (*user.User, error) + func NewUserFromValkeyUser(username, ruleStr string, pwd *user.Password) (*user.User, error) + func PatchClusterClientRequiredRules(rule *user.Rule) *user.Rule + func PatchPubsubRules(rule *user.Rule) *user.Rule + type ClusterInstance interface + Definition func() *v1alpha1.Cluster + Masters func() []ValkeyNode + Nodes func() []ValkeyNode + RawNodes func(ctx context.Context) ([]corev1.Pod, error) + RewriteShards func(ctx context.Context, shards []*v1alpha1.ClusterShards) error + Shards func() []ClusterShard + Status func() *v1alpha1.ClusterStatus + type ClusterShard interface + Definition func() *appv1.StatefulSet + Index func() int + IsImporting func() bool + IsMigrating func() bool + Master func() ValkeyNode + Nodes func() []ValkeyNode + Replicas func() []ValkeyNode + Slots func() *slot.Slots + Status func() *appv1.StatefulSetStatus + type FailoverInstance interface + Definition func() *v1alpha1.Failover + IsBindedSentinel func() bool + IsStandalone func() bool + Masters func() []ValkeyNode + Monitor func() FailoverMonitor + Nodes func() []ValkeyNode + RawNodes func(ctx context.Context) ([]corev1.Pod, error) + Selector func() map[string]string + type FailoverMonitor interface + AllNodeMonitored func(ctx context.Context) (bool, error) + Failover func(ctx context.Context) error + Inited func(ctx context.Context) (bool, error) + Master func(ctx context.Context, flags ...bool) (*valkey.SentinelMonitorNode, error) + Monitor func(ctx context.Context, node ValkeyNode) error + Policy func() v1alpha1.FailoverPolicy + Replicas func(ctx context.Context) ([]*valkey.SentinelMonitorNode, error) + Reset func(ctx context.Context) error + UpdateConfig func(ctx context.Context, params map[string]string) error + type Instance interface + Arch func() core.Arch + IsACLAppliedToAll func() bool + IsACLUserExists func() bool + IsInService func() bool + IsResourceFullfilled func(ctx context.Context) (bool, error) + Issuer func() *certmetav1.ObjectReference + Logger func() logr.Logger + SendEventf func(eventtype, reason, messageFmt string, args ...any) + TLSConfig func() *tls.Config + UpdateStatus func(ctx context.Context, st InstanceStatus, message string) error + Users func() Users + type InstanceStatus string + const Any + const Fail + const OK + const Paused + type Object interface + DeepCopyObject func() runtime.Object + GetObjectKind func() schema.ObjectKind + IsReady func() bool + NamespacedName func() client.ObjectKey + Refresh func(ctx context.Context) error + Restart func(ctx context.Context, annotationKeyVal ...string) error + Version func() version.ValkeyVersion + type Replication interface + Definition func() *appv1.StatefulSet + Master func() ValkeyNode + Nodes func() []ValkeyNode + Replicas func() []ValkeyNode + Status func() *appv1.StatefulSetStatus + type Sentinel interface + Definition func() *appv1.Deployment + Nodes func() []SentinelNode + Status func() *appv1.DeploymentStatus + type SentinelInstance interface + Clusters func(ctx context.Context) ([]string, error) + Definition func() *v1alpha1.Sentinel + GetPassword func() (string, error) + Nodes func() []SentinelNode + RawNodes func(ctx context.Context) ([]corev1.Pod, error) + Replication func() SentinelReplication + Selector func() map[string]string + type SentinelNode interface + ContainerStatus func() *corev1.ContainerStatus + DefaultIP func() net.IP + DefaultInternalIP func() net.IP + Definition func() *corev1.Pod + GetObjectKind func() schema.ObjectKind + IPs func() []net.IP + Index func() int + InternalPort func() int + IsACLApplied func() bool + IsReady func() bool + IsTerminating func() bool + NodeIP func() net.IP + Port func() int + Status func() corev1.PodPhase + type SentinelNodeOperation interface + Brothers func(ctx context.Context, name string) ([]*vkcli.SentinelMonitorNode, error) + Config func() map[string]string + CurrentVersion func() version.ValkeyVersion + Info func() vkcli.NodeInfo + MonitoringClusters func(ctx context.Context) (clusters []string, err error) + MonitoringNodes func(ctx context.Context, name string) (master *vkcli.SentinelMonitorNode, replicas []*vkcli.SentinelMonitorNode, ...) + Query func(ctx context.Context, cmd string, args ...any) (any, error) + Refresh func(ctx context.Context) error + SetMonitor func(ctx context.Context, name, ip, port, user, password, quorum string) error + Setup func(ctx context.Context, margs ...[]any) error + type SentinelReplication interface + Definition func() *appv1.StatefulSet + Nodes func() []SentinelNode + Status func() *appv1.StatefulSetStatus + type Users []*core.User + func (us Users) Encode(patch bool) map[string]string + func (us Users) GetDefaultUser() *core.User + func (us Users) GetOpUser() *core.User + func (us Users) IsChanged(n Users) bool + type ValkeyNode interface + ClusterInfo func() vkcli.ClusterNodeInfo + Config func() map[string]string + ConfigedMasterIP func() string + ConfigedMasterPort func() string + ContainerStatus func() *corev1.ContainerStatus + CurrentVersion func() version.ValkeyVersion + DefaultIP func() net.IP + DefaultInternalIP func() net.IP + Definition func() *corev1.Pod + GetObjectKind func() schema.ObjectKind + ID func() string + IPort func() int + IPs func() []net.IP + Index func() int + Info func() vkcli.NodeInfo + InternalIPort func() int + InternalPort func() int + IsACLApplied func() bool + IsConnected func() bool + IsJoined func() bool + IsMasterFailed func() bool + IsMasterLinkUp func() bool + IsReady func() bool + IsTerminating func() bool + MasterID func() string + NodeIP func() net.IP + Port func() int + Query func(ctx context.Context, cmd string, args ...any) (any, error) + Refresh func(ctx context.Context) error + ReplicaOf func(ctx context.Context, ip, port string) error + Role func() core.NodeRole + SetACLUser func(ctx context.Context, username string, passwords []string, rules string) (any, error) + Setup func(ctx context.Context, margs ...[]any) error + Slots func() *slot.Slots + Status func() corev1.PodPhase
Go to main page