runners

package

v0.27.0 Latest Latest Go to latest Published: Mar 19, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Details

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

Repository

github.com/kvaster/topols

Links

Open Source Insights

Documentation ¶

Index ¶

func NewGRPCRunner(srv *grpc.Server, sockFile string, leaderElection bool) manager.Runnable
func NewMetricsExporter(client client.Client, lsmc lsm.Client, nodeName string) manager.Runnable
type Checker
- func NewChecker(check func() error, interval time.Duration) Checker

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewGRPCRunner ¶

func NewGRPCRunner(srv *grpc.Server, sockFile string, leaderElection bool) manager.Runnable

NewGRPCRunner creates controller-runtime's manager.Runnable for a gRPC server. The server will listen on UNIX domain socket at sockFile. If leaderElection is true, the server will run only when it is elected as leader.

func NewMetricsExporter ¶

func NewMetricsExporter(client client.Client, lsmc lsm.Client, nodeName string) manager.Runnable

NewMetricsExporter creates controller-runtime's manager.Runnable to run a metrics exporter for a node.

Types ¶

type Checker ¶

type Checker interface {
	manager.Runnable
	Ready() (bool, error)
}

Checker is the interface to check plugin readiness.

func NewChecker ¶

func NewChecker(check func() error, interval time.Duration) Checker

NewChecker creates controller-runtime's manager.Runnable to run health check function periodically at given interval.

Source Files ¶

View all Source files

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