healthcheck

package

v1.15.0 Latest Latest Go to latest Published: Oct 9, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/percona/percona-server-mongodb-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CheckState(rs ReplSetStatus, startupDelaySeconds int64, oplogSize int64) error
func HealthCheckMongodLiveness(ctx context.Context, cnf *db.Config, startupDelaySeconds int64) (_ *mongo.MemberState, err error)
func HealthCheckMongosLiveness(ctx context.Context, cnf *db.Config) (err error)
func MongodReadinessCheck(ctx context.Context, addr string) error
func MongosReadinessCheck(ctx context.Context, cnf *db.Config) (err error)
type InitialSyncStatus
type OplogRs
type ReplSetStatus
type ServerStatus
type State
- func HealthCheck(client mongo.Client, okMemberStates []mongo.MemberState) (State, *mongo.MemberState, error)
- func (s State) ExitCode() int

Constants ¶

View Source

const (
	Version = "0.5.0"
)

Variables ¶

View Source

var ErrNoReplsetConfigStr string = "(NotYetInitialized) no replset config has been received"

View Source

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

OkMemberStates is a slice of acceptable replication member states

Functions ¶

func CheckState ¶ added in v1.10.0

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

func HealthCheckMongodLiveness ¶

func HealthCheckMongodLiveness(ctx context.Context, cnf *db.Config, startupDelaySeconds int64) (_ *mongo.MemberState, err error)

func HealthCheckMongosLiveness ¶

func HealthCheckMongosLiveness(ctx context.Context, cnf *db.Config) (err error)

func MongodReadinessCheck ¶ added in v1.15.0

func MongodReadinessCheck(ctx context.Context, addr string) error

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

func MongosReadinessCheck ¶

func MongosReadinessCheck(ctx context.Context, cnf *db.Config) (err error)

Types ¶

type InitialSyncStatus ¶

type InitialSyncStatus interface{}

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 {
	mongo.Status      `bson:",inline"`
	InitialSyncStatus InitialSyncStatus `bson:"initialSyncStatus" json:"initialSyncStatus"`
}

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(client mongo.Client, okMemberStates []mongo.MemberState) (State, *mongo.MemberState, error)

HealthCheck checks the replication member state of the local MongoDB member

func (State) ExitCode ¶

func (s State) ExitCode() int

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
pkg
db
pod
pod/k8s
pod/mocks Code generated by mockery v1.0.0.	Code generated by mockery v1.0.0.
tools
command
db
testutils
tool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL