cluster

Documentation

Index

• type KVRocksClusterHandler
  • func NewKVRocksClusterHandler(k8s *k8s.Client, kvrocks *kvrocks.Client, log logr.Logger, ...) *KVRocksClusterHandler
  • func (h *KVRocksClusterHandler) Finializer() error
  • func (h *KVRocksClusterHandler) Handle() (error, bool)
  • func (h *KVRocksClusterHandler) Requeue() bool

Types

type KVRocksClusterHandler

type KVRocksClusterHandler struct {
	// contains filtered or unexported fields
}

func NewKVRocksClusterHandler

func NewKVRocksClusterHandler(
	k8s *k8s.Client,
	kvrocks *kvrocks.Client,
	log logr.Logger,
	key types.NamespacedName,
	instance *kvrocksv1alpha1.KVRocks) *KVRocksClusterHandler

func (*KVRocksClusterHandler) Finializer

func (h *KVRocksClusterHandler) Finializer() error

func (*KVRocksClusterHandler) Handle

func (h *KVRocksClusterHandler) Handle() (error, bool)

func (*KVRocksClusterHandler) Requeue

func (h *KVRocksClusterHandler) Requeue() bool