failover

package

v1.0.0 Latest Latest Go to latest Published: Jun 5, 2025 License: Apache-2.0 Imports: 34 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/chideat/valkey-operator

Links

Open Source Insights

Documentation ¶

Index ¶

func LoadValkeyReplication(ctx context.Context, client clientset.ClientSet, inst types.FailoverInstance, ...) (types.Replication, error)
func NewValkeyReplication(ctx context.Context, client clientset.ClientSet, inst types.FailoverInstance, ...) (types.Replication, error)
type Failover
- func NewFailover(ctx context.Context, k8sClient clientset.ClientSet, ...) (*Failover, error)
type ValkeyReplication

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func LoadValkeyReplication ¶

func LoadValkeyReplication(ctx context.Context, client clientset.ClientSet, inst types.FailoverInstance, logger logr.Logger) (types.Replication, error)

func NewValkeyReplication ¶

func NewValkeyReplication(ctx context.Context, client clientset.ClientSet, inst types.FailoverInstance, sts *appv1.StatefulSet, logger logr.Logger) (types.Replication, error)

Types ¶

type Failover ¶

type Failover struct {
	v1alpha1.Failover
	// contains filtered or unexported fields
}

func NewFailover ¶

func NewFailover(ctx context.Context, k8sClient clientset.ClientSet, eventRecorder record.EventRecorder, def *v1alpha1.Failover, logger logr.Logger) (*Failover, error)

func (*Failover) Arch ¶

func (s *Failover) Arch() core.Arch

func (*Failover) Definition ¶

func (s *Failover) Definition() *v1alpha1.Failover

func (*Failover) IsACLAppliedToAll ¶

func (s *Failover) IsACLAppliedToAll() bool

func (*Failover) IsACLUserExists ¶

func (s *Failover) IsACLUserExists() bool

func (*Failover) IsBindedSentinel ¶

func (s *Failover) IsBindedSentinel() bool

func (*Failover) IsInService ¶

func (s *Failover) IsInService() bool

func (*Failover) IsReady ¶

func (s *Failover) IsReady() bool

func (*Failover) IsResourceFullfilled ¶

func (s *Failover) IsResourceFullfilled(ctx context.Context) (bool, error)

func (*Failover) IsStandalone ¶

func (c *Failover) IsStandalone() bool

func (*Failover) Issuer ¶

func (c *Failover) Issuer() *certmetav1.ObjectReference

func (*Failover) LoadUsers ¶

func (s *Failover) LoadUsers(ctx context.Context)

func (*Failover) Logger ¶

func (c *Failover) Logger() logr.Logger

func (*Failover) Masters ¶

func (s *Failover) Masters() []types.ValkeyNode

func (*Failover) Monitor ¶

func (s *Failover) Monitor() types.FailoverMonitor

func (*Failover) NamespacedName ¶

func (s *Failover) NamespacedName() client.ObjectKey

func (*Failover) Nodes ¶

func (s *Failover) Nodes() []types.ValkeyNode

func (*Failover) RawNodes ¶

func (s *Failover) RawNodes(ctx context.Context) ([]corev1.Pod, error)

func (*Failover) Refresh ¶

func (s *Failover) Refresh(ctx context.Context) (err error)

func (*Failover) Restart ¶

func (s *Failover) Restart(ctx context.Context, annotationKeyVal ...string) error

func (*Failover) Selector ¶

func (s *Failover) Selector() map[string]string

func (*Failover) SendEventf ¶

func (c *Failover) SendEventf(eventtype, reason, messageFmt string, args ...any)

func (*Failover) TLSConfig ¶

func (s *Failover) TLSConfig() *tls.Config

func (*Failover) UpdateStatus ¶

func (s *Failover) UpdateStatus(ctx context.Context, st types.InstanceStatus, msg string) error

func (*Failover) Users ¶

func (s *Failover) Users() (us types.Users)

func (*Failover) Version ¶

func (s *Failover) Version() version.ValkeyVersion

type ValkeyReplication ¶

type ValkeyReplication struct {
	appv1.StatefulSet
	// contains filtered or unexported fields
}

func (*ValkeyReplication) Definition ¶

func (s *ValkeyReplication) Definition() *appv1.StatefulSet

func (*ValkeyReplication) IsReady ¶

func (s *ValkeyReplication) IsReady() bool

func (*ValkeyReplication) Master ¶

func (s *ValkeyReplication) Master() types.ValkeyNode

func (*ValkeyReplication) NamespacedName ¶

func (s *ValkeyReplication) NamespacedName() client.ObjectKey

func (*ValkeyReplication) Nodes ¶

func (s *ValkeyReplication) Nodes() []types.ValkeyNode

func (*ValkeyReplication) Refresh ¶

func (s *ValkeyReplication) Refresh(ctx context.Context) error

func (*ValkeyReplication) Replicas ¶

func (s *ValkeyReplication) Replicas() []types.ValkeyNode

func (*ValkeyReplication) Restart ¶

func (s *ValkeyReplication) Restart(ctx context.Context, annotationKeyVal ...string) error

func (*ValkeyReplication) Status ¶

func (s *ValkeyReplication) Status() *appv1.StatefulSetStatus

func (*ValkeyReplication) Version ¶

func (s *ValkeyReplication) Version() version.ValkeyVersion

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
monitor

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