agents

Documentation

Index

• func ApiServerProxyPath(namespace, schema, svcname, port string) string
• func ClientOptionsOf(ctx context.Context, cluster *models.Cluster) (*client.Config, *rest.Config, error)
• type APIServerInfoClient
  • func NewAPIServerInfoClientOrEmpty(ext *extend.ExtendClient, cfg *rest.Config) APIServerInfoClient
• type AgentAPIServerInfoClient
  • func (a AgentAPIServerInfoClient) APIServerAddr() string
  • func (a AgentAPIServerInfoClient) APIServerVersion() string
• type Client
  • func NewClientFor(ctx context.Context, cluster *models.Cluster) (Client, error)
  • func NewDelegateClientClient(name string, cfg *agentcli.Config, kubecfg *rest.Config, ...) (Client, error)
• type ClientSet
  • func NewClientSet(database *database.Database) (*ClientSet, error)
  • func (h *ClientSet) ClientOf(ctx context.Context, name string) (Client, error)
  • func (h *ClientSet) ClientOfManager(ctx context.Context) (Client, error)
  • func (h *ClientSet) Clusters() []string
  • func (h *ClientSet) ExecuteInEachCluster(ctx context.Context, f func(ctx context.Context, cli Client) error) error
  • func (h *ClientSet) Invalidate(ctx context.Context, name string)
• type DelegateClient
  • func (c *DelegateClient) Config() *agentcli.Config
  • func (c *DelegateClient) Extend() *extend.ExtendClient
  • func (c *DelegateClient) Info() APIServerInfoClient
  • func (c *DelegateClient) KubeConfig() *rest.Config
  • func (c *DelegateClient) Name() string
  • func (c *DelegateClient) ProxyTransport() http.RoundTripper
  • func (c *DelegateClient) ReverseProxy(dests ...*url.URL) *httputil.ReverseProxy
  • func (c *DelegateClient) Transport() http.RoundTripper
  • func (c *DelegateClient) Websocket() *agentcli.WebsocketClient
• type EmptyAPIServerInfoClient
  • func (c EmptyAPIServerInfoClient) APIServerAddr() string
  • func (c EmptyAPIServerInfoClient) APIServerVersion() string
• type KubeConfigAPIServerInfoClient
  • func NewAPIServerInfoClient(cfg *rest.Config) (*KubeConfigAPIServerInfoClient, error)
  • func (c *KubeConfigAPIServerInfoClient) APIServerAddr() string
  • func (c *KubeConfigAPIServerInfoClient) APIServerVersion() string

Functions

func ApiServerProxyPath

func ApiServerProxyPath(namespace, schema, svcname, port string) string

func ClientOptionsOf

func ClientOptionsOf(ctx context.Context, cluster *models.Cluster) (*client.Config, *rest.Config, error)

Types

type APIServerInfoClient

type APIServerInfoClient interface {
	APIServerAddr() string
	APIServerVersion() string
}

func NewAPIServerInfoClientOrEmpty

func NewAPIServerInfoClientOrEmpty(ext *extend.ExtendClient, cfg *rest.Config) APIServerInfoClient

type AgentAPIServerInfoClient

type AgentAPIServerInfoClient struct {
	ExtendClient *extend.ExtendClient
}

func (AgentAPIServerInfoClient) APIServerAddr

func (a AgentAPIServerInfoClient) APIServerAddr() string

APIServerAddr implements APIServerInfoClient.

func (AgentAPIServerInfoClient) APIServerVersion

func (a AgentAPIServerInfoClient) APIServerVersion() string

APIServerVersion implements APIServerInfoClient.

type Client

type Client interface {
	client.WithWatch
	Name() string
	Info() APIServerInfoClient
	Websocket() *agentcli.WebsocketClient
	Extend() *extend.ExtendClient
	// ReverseProxy return a new reverse proxy that proxy requests to the agent.
	// if target set, proxy to target instead of agent.
	ReverseProxy(destOverride ...*url.URL) *httputil.ReverseProxy
	// Config return the config to build a client.
	Config() *agentcli.Config
	// ProxyTransport return a transport that handle requests like it happens in the agent pod.
	ProxyTransport() http.RoundTripper
	KubeConfig() *rest.Config
}

func NewClientFor

func NewClientFor(ctx context.Context, cluster *models.Cluster) (Client, error)

func NewDelegateClientClient

func NewDelegateClientClient(name string, cfg *agentcli.Config, kubecfg *rest.Config, schema *runtime.Scheme) (Client, error)

type ClientSet

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

func NewClientSet

func NewClientSet(database *database.Database) (*ClientSet, error)

func (*ClientSet) ClientOf

func (h *ClientSet) ClientOf(ctx context.Context, name string) (Client, error)

func (*ClientSet) ClientOfManager

func (h *ClientSet) ClientOfManager(ctx context.Context) (Client, error)

func (*ClientSet) Clusters

func (h *ClientSet) Clusters() []string

func (*ClientSet) ExecuteInEachCluster

func (h *ClientSet) ExecuteInEachCluster(ctx context.Context, f func(ctx context.Context, cli Client) error) error

ExecuteInEachCluster Execute in each cluster concurrently

func (*ClientSet) Invalidate

func (h *ClientSet) Invalidate(ctx context.Context, name string)

Invalidate a client of name cluster and recreate after.

type DelegateClient

type DelegateClient struct {
	*agentcli.TypedClient
	// contains filtered or unexported fields
}

func (*DelegateClient) Config

func (c *DelegateClient) Config() *agentcli.Config

func (*DelegateClient) Extend

func (c *DelegateClient) Extend() *extend.ExtendClient

func (*DelegateClient) Info

func (c *DelegateClient) Info() APIServerInfoClient

func (*DelegateClient) KubeConfig

func (c *DelegateClient) KubeConfig() *rest.Config

func (*DelegateClient) Name

func (c *DelegateClient) Name() string

func (*DelegateClient) ProxyTransport

func (c *DelegateClient) ProxyTransport() http.RoundTripper

func (*DelegateClient) ReverseProxy

func (c *DelegateClient) ReverseProxy(dests ...*url.URL) *httputil.ReverseProxy

ReverseProxy return a http.Handler that proxy requests to the agent. if target set, proxy to target instead of to agent.

func (*DelegateClient) Transport

func (c *DelegateClient) Transport() http.RoundTripper

func (*DelegateClient) Websocket

func (c *DelegateClient) Websocket() *agentcli.WebsocketClient

type EmptyAPIServerInfoClient

type EmptyAPIServerInfoClient struct{}

func (EmptyAPIServerInfoClient) APIServerAddr

func (c EmptyAPIServerInfoClient) APIServerAddr() string

func (EmptyAPIServerInfoClient) APIServerVersion

func (c EmptyAPIServerInfoClient) APIServerVersion() string

type KubeConfigAPIServerInfoClient

type KubeConfigAPIServerInfoClient struct {
	APIServerHost *url.URL
	Discovery     discovery.DiscoveryInterface
}

func NewAPIServerInfoClient

func NewAPIServerInfoClient(cfg *rest.Config) (*KubeConfigAPIServerInfoClient, error)

func (*KubeConfigAPIServerInfoClient) APIServerAddr

func (c *KubeConfigAPIServerInfoClient) APIServerAddr() string

func (*KubeConfigAPIServerInfoClient) APIServerVersion

func (c *KubeConfigAPIServerInfoClient) APIServerVersion() string