config

Documentation

Index

• Constants
• func APIServers(ctx context.Context, node *config.Node, proxy proxy.Proxy) []string
• func Get(ctx context.Context, agent cmds.Agent, proxy proxy.Proxy) (*config.Node, error)
• func KubeProxyDisabled(ctx context.Context, node *config.Node, proxy proxy.Proxy) bool
• func Request(path string, info *clientaccess.Info, requester HTTPRequester) ([]byte, error)
• type HTTPRequester

Constants

const (
	DefaultPodManifestPath = "pod-manifests"
)

Functions

func APIServers

func APIServers(ctx context.Context, node *config.Node, proxy proxy.Proxy) []string

APIServers returns a list of apiserver endpoints, suitable for seeding client loadbalancer configurations. This function will block until it can return a populated list of apiservers, or if the remote server returns an error (indicating that it does not support this functionality).

func Get

func Get(ctx context.Context, agent cmds.Agent, proxy proxy.Proxy) (*config.Node, error)

Get returns a pointer to a completed Node configuration struct, containing a merging of the local CLI configuration with settings from the server. Node configuration includes client certificates, which requires node password verification, so this is somewhat computationally expensive on the server side, and is retried with jitter to avoid having clients hammer on the server at fixed periods. A call to this will bock until agent configuration is successfully returned by the server, or the context is cancelled.

func KubeProxyDisabled

func KubeProxyDisabled(ctx context.Context, node *config.Node, proxy proxy.Proxy) bool

KubeProxyDisabled returns a bool indicating whether or not kube-proxy has been disabled in the server configuration. The server may not have a complete view of cluster configuration until after all startup hooks have completed, so a call to this will block until after the server's readyz endpoint returns OK.

func Request

func Request(path string, info *clientaccess.Info, requester HTTPRequester) ([]byte, error)

Types

type HTTPRequester

type HTTPRequester func(u string, client *http.Client, username, password, token string) ([]byte, error)