probe

Documentation

Index

• func NewAmqpProbe(cfg *config.Amqp) *amqpProbe
• func NewHttpProbe(cfg *config.HttpGet) *httpGetProbe
• func NewMongoDBProbe(cfg *config.MongoDB) (*mongoDBProbe, error)
• func NewMySQLProbe(cfg *config.MySQL) *mySQLProbe
• func NewRedisProbe(cfg *config.Redis) *redisProbe
• func NewSmtpProbe(cfg *config.SMTP) *smtpProbe
• func RunProbeServer(ph *Handler, signals chan os.Signal, probePort int) error
• type Handler
  • func NewProbeHandler(cfg *config.Ignition) (*Handler, error)
  • func (h *Handler) HandleStatus(res http.ResponseWriter, req *http.Request)
  • func (h *Handler) Wait(interrupt chan os.Signal) error
• type Probe
• type ProbeResult
• type StatusResponse

Functions

func NewAmqpProbe

func NewAmqpProbe(cfg *config.Amqp) *amqpProbe

func NewHttpProbe

func NewHttpProbe(cfg *config.HttpGet) *httpGetProbe

func NewMongoDBProbe

func NewMongoDBProbe(cfg *config.MongoDB) (*mongoDBProbe, error)

func NewMySQLProbe

func NewMySQLProbe(cfg *config.MySQL) *mySQLProbe

func NewRedisProbe

func NewRedisProbe(cfg *config.Redis) *redisProbe

func NewSmtpProbe

func NewSmtpProbe(cfg *config.SMTP) *smtpProbe

func RunProbeServer

func RunProbeServer(ph *Handler, signals chan os.Signal, probePort int) error

Types

type Handler

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

func NewProbeHandler

func NewProbeHandler(cfg *config.Ignition) (*Handler, error)

func (*Handler) HandleStatus

func (h *Handler) HandleStatus(res http.ResponseWriter, req *http.Request)

func (*Handler) Wait

func (h *Handler) Wait(interrupt chan os.Signal) error

type Probe

type Probe interface {
	Exec() error
}

type ProbeResult

type ProbeResult struct {
	Name    string `json:"-"`
	OK      bool   `json:"ok"`
	Message string `json:"message,omitempty"`
}

type StatusResponse

type StatusResponse struct {
	Probes map[string]*ProbeResult `json:"probes"`
}