handler

Documentation

Index

• type HealthCheckHandler
  • func (h *HealthCheckHandler) Handler(ctx iris.Context)
  • func (h *HealthCheckHandler) Init(zkModules []internal.ZkOperatorModule)
• type ZkCRDProbeHandler
  • func (h *ZkCRDProbeHandler) CleanUpOnKill() error
  • func (h *ZkCRDProbeHandler) CreateCRDProbe(zerokProbe *operatorv1alpha1.ZerokProbe) (string, error)
  • func (h *ZkCRDProbeHandler) DeleteCRDProbe(zkCRDProbeId string) (string, error)
  • func (h *ZkCRDProbeHandler) Init(cfg config.ZkOperatorConfig) error
  • func (h *ZkCRDProbeHandler) IsHealthy() bool
  • func (h *ZkCRDProbeHandler) UpdateCRDProbe(zerokProbe *operatorv1alpha1.ZerokProbe) (string, error)

Types

type HealthCheckHandler

type HealthCheckHandler struct {
	ZkModules []internal.ZkOperatorModule
}

func (*HealthCheckHandler) Handler

func (h *HealthCheckHandler) Handler(ctx iris.Context)

func (*HealthCheckHandler) Init

func (h *HealthCheckHandler) Init(zkModules []internal.ZkOperatorModule)

type ZkCRDProbeHandler

type ZkCRDProbeHandler struct {
	VersionedStore *zkredis.VersionedStore[model.Scenario]
	// contains filtered or unexported fields
}

func (*ZkCRDProbeHandler) CleanUpOnKill

func (h *ZkCRDProbeHandler) CleanUpOnKill() error

func (*ZkCRDProbeHandler) CreateCRDProbe

func (h *ZkCRDProbeHandler) CreateCRDProbe(zerokProbe *operatorv1alpha1.ZerokProbe) (string, error)

func (*ZkCRDProbeHandler) DeleteCRDProbe

func (h *ZkCRDProbeHandler) DeleteCRDProbe(zkCRDProbeId string) (string, error)

func (*ZkCRDProbeHandler) Init

func (h *ZkCRDProbeHandler) Init(cfg config.ZkOperatorConfig) error

func (*ZkCRDProbeHandler) IsHealthy

func (h *ZkCRDProbeHandler) IsHealthy() bool

func (*ZkCRDProbeHandler) UpdateCRDProbe

func (h *ZkCRDProbeHandler) UpdateCRDProbe(zerokProbe *operatorv1alpha1.ZerokProbe) (string, error)