healthcheck

Documentation

Index

• func NewHandler(checker Checker, logger zerolog.Logger) http.Handler
• func Start(ctx context.Context, checker Checker, logger zerolog.Logger)
• type Checker
  • func NewChecker(engine string, processor engine.MessageProcessor, encoder encoding.Encoder, ...) Checker
  • func NewRpcChecker(engine string, processor engine.MessageProcessor, encoder encoding.Encoder, ...) Checker
• type Handler
  • func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func NewHandler

func NewHandler(checker Checker, logger zerolog.Logger) http.Handler

func Start

func Start(
	ctx context.Context,
	checker Checker,
	logger zerolog.Logger,
)

Types

type Checker

type Checker interface {
	Check(ctx context.Context) error
}

func NewChecker

func NewChecker(
	engine string,
	processor engine.MessageProcessor,
	encoder encoding.Encoder,
	eventWithEntity bool,
	eventWithAlarm bool,
) Checker

func NewRpcChecker

func NewRpcChecker(
	engine string,
	processor engine.MessageProcessor,
	encoder encoding.Encoder,
	createEvent func(types.Entity, types.Alarm) any,
) Checker

type Handler

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

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)