cnstore

Documentation

Index

• Constants
• type Controller
  • func NewController(mgr *mocli.MORPCClientManager, qc *querycli.Client) *Controller
  • func (c *Controller) Finalize(ctx *recon.Context[*corev1.Pod]) (bool, error)
  • func (c *Controller) Observe(ctx *recon.Context[*corev1.Pod]) (recon.Action[*corev1.Pod], error)
  • func (c *Controller) OnDeleted(ctx *recon.Context[*corev1.Pod]) error
  • func (c *Controller) Reconcile(mgr manager.Manager) error

Constants

const (
	LockRestartSet = "matrixorigin.io/lock-restart"
)

Types

type Controller

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

func NewController

func NewController(mgr *mocli.MORPCClientManager, qc *querycli.Client) *Controller

func (*Controller) Finalize

func (c *Controller) Finalize(ctx *recon.Context[*corev1.Pod]) (bool, error)

func (*Controller) Observe

func (c *Controller) Observe(ctx *recon.Context[*corev1.Pod]) (recon.Action[*corev1.Pod], error)

func (*Controller) OnDeleted

func (c *Controller) OnDeleted(ctx *recon.Context[*corev1.Pod]) error

OnDeleted delete CNStore and cleanup finalizer on Pod deletion

func (*Controller) Reconcile

func (c *Controller) Reconcile(mgr manager.Manager) error