agent

Documentation

Index

• type Agent
  • func NewAgent(clusterName string, kubeClient kubernetes.Interface) *Agent
  • func (k *Agent) ListenAndServe(address net.IP, port uint, tlsOptions *TLSOptions, auth AuthInterface, ...)
  • func (k *Agent) RefreshServerIfNeeded(clusterInfo *v1beta1.ManagedClusterInfo)
• type AuthInterface
• type Handle
  • func NewHandle(driverFactory *drivers.DriverFactory, auth AuthInterface) Handle
  • func (h *Handle) InstallAuthFilter()
  • func (h *Handle) InstallDefaultHandlers()
  • func (h *Handle) ServeHTTP(w http.ResponseWriter, req *http.Request)
• type Server
• type TLSOptions

Types

type Agent

type Agent struct {
	RunServer chan v1beta1.ManagedClusterInfo
	// contains filtered or unexported fields
}

Agent is the main struct for agent server

func NewAgent

func NewAgent(clusterName string, kubeClient kubernetes.Interface) *Agent

NewAgent create a new Agent

func (*Agent) ListenAndServe

func (k *Agent) ListenAndServe(
	address net.IP,
	port uint,
	tlsOptions *TLSOptions,
	auth AuthInterface,
	insecure bool,
)

ListenAndServe start Agent server

func (*Agent) RefreshServerIfNeeded

func (k *Agent) RefreshServerIfNeeded(clusterInfo *v1beta1.ManagedClusterInfo)

type AuthInterface

type AuthInterface interface {
	authenticator.Request
	authorizer.RequestAttributesGetter
	authorizer.Authorizer
}

AuthInterface contains all methods required by the auth filters

type Handle

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

Handle is a http.Handler which exposes kubelet functionality over HTTP.

func NewHandle

func NewHandle(driverFactory *drivers.DriverFactory, auth AuthInterface) Handle

NewHandle initializes and configures a kubelet.Handle object to handle HTTP requests.

func (*Handle) InstallAuthFilter

func (h *Handle) InstallAuthFilter()

InstallAuthFilter installs authentication filters with the restful Container.

func (*Handle) InstallDefaultHandlers

func (h *Handle) InstallDefaultHandlers()

InstallDefaultHandlers registers the default set of supported HTTP request patterns with the restful Container.

func (*Handle) ServeHTTP

func (h *Handle) ServeHTTP(w http.ResponseWriter, req *http.Request)

ServeHTTP responds to HTTP requests on the Kubelet.

type Server

type Server struct {
	CAData []byte
	// contains filtered or unexported fields
}

type TLSOptions

type TLSOptions struct {
	Config   *tls.Config
	CertFile string
	KeyFile  string
}