The highest tagged major version is v3.

apiserver

package

v1.26.9 Latest Latest Go to latest Published: Dec 2, 2020 License: Apache-2.0 Imports: 8 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

This section is empty.

This section is empty.

This section is empty.

type Client interface {
	GetNodeInfo(nodeName string) (*NodeInfo, error)
	GetServerVersion() (*version.Info, error)
}

Client an interface for querying the k8s API server

func NewClient(client client.Kubernetes) Client

NewClient creates a new API Server client

func NewFileCacheClientWrapper(client Client, cacheDir string, cacheDuration time.Duration, options ...Option) Client

NewFileCacheClientWrapper wraps the given Client and caches the responses for the given cacheDuration.

type NodeInfo struct {
	NodeName    string
	Labels      map[string]string
	Allocatable v1.ResourceList
	Capacity    v1.ResourceList
}

NodeInfo contains information about a specific node

func (i *NodeInfo) IsMasterNode() bool

IsMasterNode returns true if the NodeInfo contains the labels that identify a node as master.

type Option func(*fileCacheClient)

Option is a func that configures the fileCacheClient

func WithTimeProvider(timeProvider TimeProvider) Option

WithTimeProvider overrides the default TimeProvider (which returns the current time). This is useful for testing cache durations/evictions

type TestAPIServer struct {
	Mem map[string]*NodeInfo
}

TestAPIServer is for testing purposes. It implements the apiserver.Client interface with an in-memory list of objects

func (t TestAPIServer) GetNodeInfo(nodeName string) (*NodeInfo, error)

func (t TestAPIServer) GetServerVersion() (*version.Info, error)

type TimeProvider interface {
	Time() time.Time
}

TimeProvider defines an interface that returns the current time. It's used for testing.