healthcheck

Documentation

Index

• Constants
• Variables
• func HealthCheckMongodLiveness(session *mgo.Session, startupDelaySeconds int64) (*status.MemberState, error)
• func HealthCheckMongosLiveness(session *mgo.Session) error
• func MongosReadinessCheck(session *mgo.Session) error
• type InitialSyncStatus
• type IsMasterResp
• type OplogRs
• type ReplSetStatus
  • func (rs ReplSetStatus) CheckState(startupDelaySeconds int64, oplogSize int64) error
• type ServerStatus
• type State
  • func HealthCheck(session *mgo.Session, okMemberStates []status.MemberState) (State, *status.MemberState, error)
  • func ReadinessCheck(session *mgo.Session) (State, error)
  • func (s State) ExitCode() int

Constants

const (
	Version = "0.5.0"
)

Variables

var OkMemberStates = []status.MemberState{
	status.MemberStatePrimary,
	status.MemberStateSecondary,
	status.MemberStateRecovering,
	status.MemberStateArbiter,
	status.MemberStateStartup2,
	status.MemberStateRollback,
}

OkMemberStates is a slice of acceptable replication member states

Functions

func HealthCheckMongodLiveness

func HealthCheckMongodLiveness(session *mgo.Session, startupDelaySeconds int64) (*status.MemberState, error)

func HealthCheckMongosLiveness

func HealthCheckMongosLiveness(session *mgo.Session) error

func MongosReadinessCheck

func MongosReadinessCheck(session *mgo.Session) error

Types

type InitialSyncStatus

type InitialSyncStatus interface{}

type IsMasterResp

type IsMasterResp struct {
	IsMaster bool   `bson:"ismaster" json:"ismaster"`
	Msg      string `bson:"msg" json:"msg"`

	Ok     int    `bson:"ok" json:"ok"`
	Errmsg string `bson:"errmsg,omitempty" json:"errmsg,omitempty"`
}

type OplogRs

type OplogRs struct {
	StorageSize int64 `bson:"storageSize" json:"storageSize"`

	Ok     int    `bson:"ok" json:"ok"`
	Errmsg string `bson:"errmsg,omitempty" json:"errmsg,omitempty"`
}

type ReplSetStatus

type ReplSetStatus struct {
	status.Status     `bson:",inline"`
	InitialSyncStatus InitialSyncStatus `bson:"initialSyncStatus" json:"initialSyncStatus"`
}

func (ReplSetStatus) CheckState

func (rs ReplSetStatus) CheckState(startupDelaySeconds int64, oplogSize int64) error

type ServerStatus

type ServerStatus struct {
	Ok     int    `bson:"ok" json:"ok"`
	Errmsg string `bson:"errmsg,omitempty" json:"errmsg,omitempty"`
}

type State

type State int

const (
	StateOk State = iota
	StateFailed
)

func HealthCheck

func HealthCheck(session *mgo.Session, okMemberStates []status.MemberState) (State, *status.MemberState, error)

HealthCheck checks the replication member state of the local MongoDB member

func ReadinessCheck

func ReadinessCheck(session *mgo.Session) (State, error)

ReadinessCheck runs a ping on a pmgo.SessionManager to check server readiness

func (State) ExitCode

func (s State) ExitCode() int

ExitCode returns an integer reflecting the State, to be used as an exit code