kubenurse

Documentation

Overview

Package kubenurse contains the server code for the kubenurse service.

Index

• type CacheEntry
• type Server
  • func New(c client.Client) (*Server, error)
  • func (s *Server) Run(ctx context.Context) error
  • func (s *Server) Shutdown() error
• type TTLCache
  • func (c *TTLCache[K]) ActiveEntries() int
  • func (c *TTLCache[K]) Init(ttl time.Duration)
  • func (c *TTLCache[K]) Insert(k K)

Types

type CacheEntry

type CacheEntry[K comparable] struct {
	// contains filtered or unexported fields
}

type Server

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

Server is used to build the kubenurse http/https server(s).

func New

func New(c client.Client) (*Server, error)

New creates a new kubenurse server. The server can be configured with the following environment variables: * KUBENURSE_USE_TLS * KUBENURSE_ALLOW_UNSCHEDULABLE * KUBENURSE_INGRESS_URL * KUBENURSE_SERVICE_URL * KUBERNETES_SERVICE_HOST * KUBERNETES_SERVICE_PORT * KUBENURSE_NAMESPACE * KUBENURSE_NEIGHBOUR_FILTER * KUBENURSE_NEIGHBOUR_LIMIT * KUBENURSE_SHUTDOWN_DURATION * KUBENURSE_CHECK_API_SERVER_DIRECT * KUBENURSE_CHECK_API_SERVER_DNS * KUBENURSE_CHECK_ME_INGRESS * KUBENURSE_CHECK_ME_SERVICE * KUBENURSE_CHECK_NEIGHBOURHOOD * KUBENURSE_CHECK_INTERVAL

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

Run starts the periodic checker and the http/https server(s) and blocks until Shutdown was called.

func (*Server) Shutdown

func (s *Server) Shutdown() error

Shutdown disables the readiness probe and then gracefully halts the kubenurse http/https server(s).

type TTLCache

type TTLCache[K comparable] struct {
	TTL time.Duration
	// contains filtered or unexported fields
}

func (*TTLCache[K]) ActiveEntries

func (c *TTLCache[K]) ActiveEntries() int

func (*TTLCache[K]) Init

func (c *TTLCache[K]) Init(ttl time.Duration)

func (*TTLCache[K]) Insert

func (c *TTLCache[K]) Insert(k K)