types

package

Go to main page

Versions in this module

v1

v1.1.0

Mar 16, 2026

Changes in this version

type ClusterInstance

+ Shard func(index int) ClusterShard

type FailoverInstance

+ Replication func() Replication

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL