app

Documentation

Index

• func CancelOnInterrupt(ctx context.Context, f context.CancelFunc)
• type App
  • func NewFromFlags(name string, controllers []ctrl.Constructor, flagset *flag.FlagSet, ...) (*App, error)
  • func (a *App) Run(ctx context.Context) (retErr error)
• type AuxServer
  • func (a *AuxServer) Run(ctx context.Context) error
• type PrometheusRegistry

Functions

func CancelOnInterrupt

func CancelOnInterrupt(ctx context.Context, f context.CancelFunc)

CancelOnInterrupt calls f when os.Interrupt or SIGTERM is received. It ignores subsequent interrupts on purpose - program should exit correctly after the first signal.

Types

type App

type App struct {
	Logger *zap.Logger

	options.GenericNamespacedControllerOptions
	options.LeaderElectionOptions
	options.RestClientOptions
	options.LoggerOptions

	MainClient         kubernetes.Interface
	PrometheusRegistry PrometheusRegistry

	// Name is the name of the application. It must only contain alphanumeric
	// characters.
	Name        string
	RestConfig  *rest.Config
	Controllers []ctrl.Constructor
	AuxListenOn string
	Debug       bool
}

func NewFromFlags

func NewFromFlags(name string, controllers []ctrl.Constructor, flagset *flag.FlagSet, arguments []string) (*App, error)

func (*App) Run

func (a *App) Run(ctx context.Context) (retErr error)

type AuxServer

type AuxServer struct {
	Logger *zap.Logger
	// Name is the name of the application.
	Name     string
	Addr     string // TCP address to listen on, ":http" if empty
	Gatherer prometheus.Gatherer
	IsReady  func() bool
	Debug    bool
}

func (*AuxServer) Run

func (a *AuxServer) Run(ctx context.Context) error

type PrometheusRegistry

type PrometheusRegistry interface {
	prometheus.Registerer
	prometheus.Gatherer
}