healthy

package

v1.2.0 Latest Latest Go to latest Published: Mar 14, 2023 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gowins/dionysus

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func CheckCtlHealthyStat(healthType string) error
func CheckGrpcHealthy(grpcAddr, checkType string) error
func CheckHttpHealthyStat(url string, checkType string) error
func CheckerFuncRun(checkType string) error
func RegLivenessCheckers(checkers ...Checker)
func RegReadinessCheckers(checkers ...Checker)
func RegStartupCheckers(checkers ...Checker)
func SetGrpcHealthy(grpcAddr string, checkType string, status bool) error
func SetGrpcHealthyClose(grpcAddr string, checkType string) error
func SetGrpcHealthyOpen(grpcAddr string, checkType string) error
func SetHttpHealthy(url string, checkType string, status string) error
func SetHttpHealthyClose(url string, checkType string) error
func SetHttpHealthyOpen(url string, checkType string) error
type Checker
type GrpcHealthyServer
- func GetGrpcHealthyServer() *GrpcHealthyServer
- func (h *GrpcHealthyServer) HealthLiveness(context.Context, *pb.HealthyRequest) (*pb.HealthyResponse, error)
- func (h *GrpcHealthyServer) HealthLivenessSet(ctx context.Context, req *pb.HealthyStatus) (*pb.HealthyResponse, error)
- func (h *GrpcHealthyServer) HealthReadiness(context.Context, *pb.HealthyRequest) (*pb.HealthyResponse, error)
- func (h *GrpcHealthyServer) HealthReadinessSet(ctx context.Context, req *pb.HealthyStatus) (*pb.HealthyResponse, error)
- func (h *GrpcHealthyServer) HealthStartup(context.Context, *pb.HealthyRequest) (*pb.HealthyResponse, error)
- func (h *GrpcHealthyServer) HealthStartupSet(ctx context.Context, req *pb.HealthyStatus) (*pb.HealthyResponse, error)
type Health
- func New() *Health
- func (h *Health) FileObserve(d time.Duration) error
- func (h *Health) Stat() (err error)

Constants ¶

View Source

const (
	HealthGroupPath      = "/healthx"
	HealthLivenessPath   = "/liveness"
	HealthReadinessPath  = "/readiness"
	HealthStartupPath    = "/startup"
	HealthLiveness       = "liveness"
	HealthReadiness      = "readiness"
	HealthStartup        = "startup"
	CheckInterval        = time.Second * 5
	CheckIntervalTimeOut = CheckInterval * 3
	HealthStatus         = "HEALTH_STATUS"
	StatusOpen           = "open"
	StatusClose          = "close"
)

Variables ¶

View Source

var (
	HealthyFile = filepath.Join(os.TempDir(), "dio.healthy")
)

Functions ¶

func CheckCtlHealthyStat ¶

func CheckCtlHealthyStat(healthType string) error

func CheckGrpcHealthy ¶

func CheckGrpcHealthy(grpcAddr, checkType string) error

func CheckHttpHealthyStat ¶

func CheckHttpHealthyStat(url string, checkType string) error

func CheckerFuncRun ¶

func CheckerFuncRun(checkType string) error

func RegLivenessCheckers ¶

func RegLivenessCheckers(checkers ...Checker)

func RegReadinessCheckers ¶

func RegReadinessCheckers(checkers ...Checker)

func RegStartupCheckers ¶

func RegStartupCheckers(checkers ...Checker)

func SetGrpcHealthy ¶

func SetGrpcHealthy(grpcAddr string, checkType string, status bool) error

func SetGrpcHealthyClose ¶

func SetGrpcHealthyClose(grpcAddr string, checkType string) error

func SetGrpcHealthyOpen ¶

func SetGrpcHealthyOpen(grpcAddr string, checkType string) error

func SetHttpHealthy ¶

func SetHttpHealthy(url string, checkType string, status string) error

func SetHttpHealthyClose ¶

func SetHttpHealthyClose(url string, checkType string) error

func SetHttpHealthyOpen ¶

func SetHttpHealthyOpen(url string, checkType string) error

Types ¶

type Checker ¶

type Checker func() error

type GrpcHealthyServer ¶

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

func GetGrpcHealthyServer ¶

func GetGrpcHealthyServer() *GrpcHealthyServer

func (*GrpcHealthyServer) HealthLiveness ¶

func (h *GrpcHealthyServer) HealthLiveness(context.Context, *pb.HealthyRequest) (*pb.HealthyResponse, error)

func (*GrpcHealthyServer) HealthLivenessSet ¶

func (h *GrpcHealthyServer) HealthLivenessSet(ctx context.Context, req *pb.HealthyStatus) (*pb.HealthyResponse, error)

func (*GrpcHealthyServer) HealthReadiness ¶

func (h *GrpcHealthyServer) HealthReadiness(context.Context, *pb.HealthyRequest) (*pb.HealthyResponse, error)

func (*GrpcHealthyServer) HealthReadinessSet ¶

func (h *GrpcHealthyServer) HealthReadinessSet(ctx context.Context, req *pb.HealthyStatus) (*pb.HealthyResponse, error)

func (*GrpcHealthyServer) HealthStartup ¶

func (h *GrpcHealthyServer) HealthStartup(context.Context, *pb.HealthyRequest) (*pb.HealthyResponse, error)

func (*GrpcHealthyServer) HealthStartupSet ¶

func (h *GrpcHealthyServer) HealthStartupSet(ctx context.Context, req *pb.HealthyStatus) (*pb.HealthyResponse, error)

type Health ¶

type Health struct {
}

func New ¶

func New() *Health

func (*Health) FileObserve ¶

func (h *Health) FileObserve(d time.Duration) error

func (*Health) Stat ¶

func (h *Health) Stat() (err error)

Source Files ¶

View all Source files

healthy.go

Directories ¶

Path	Synopsis
proto

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