agents

package
v1.24.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 16, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ApiServerProxyPath

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

func ClientOptionsOf added in v1.24.4

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

Types

type APIServerInfoClient added in v1.23.12

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

func NewAPIServerInfoClientOrEmpty added in v1.23.12

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

type AgentAPIServerInfoClient added in v1.24.4

type AgentAPIServerInfoClient struct {
	ExtendClient *extend.ExtendClient
}

func (AgentAPIServerInfoClient) APIServerAddr added in v1.24.4

func (a AgentAPIServerInfoClient) APIServerAddr() string

APIServerAddr implements APIServerInfoClient.

func (AgentAPIServerInfoClient) APIServerVersion added in v1.24.4

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 added in v1.24.4

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

func NewDelegateClientClient added in v1.23.8

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 added in v1.22.0

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 added in v1.22.0

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 added in v1.23.12

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

func (*DelegateClient) Extend

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

func (*DelegateClient) Info added in v1.23.12

func (*DelegateClient) KubeConfig added in v1.24.4

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

func (*DelegateClient) Name

func (c *DelegateClient) Name() string

func (*DelegateClient) ProxyTransport added in v1.23.12

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

func (*DelegateClient) ReverseProxy added in v1.23.12

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 added in v1.23.12

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

func (*DelegateClient) Websocket added in v1.23.12

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

type EmptyAPIServerInfoClient added in v1.24.4

type EmptyAPIServerInfoClient struct{}

func (EmptyAPIServerInfoClient) APIServerAddr added in v1.24.4

func (c EmptyAPIServerInfoClient) APIServerAddr() string

func (EmptyAPIServerInfoClient) APIServerVersion added in v1.24.4

func (c EmptyAPIServerInfoClient) APIServerVersion() string

type KubeConfigAPIServerInfoClient added in v1.24.4

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

func NewAPIServerInfoClient added in v1.23.12

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

func (*KubeConfigAPIServerInfoClient) APIServerAddr added in v1.24.4

func (c *KubeConfigAPIServerInfoClient) APIServerAddr() string

func (*KubeConfigAPIServerInfoClient) APIServerVersion added in v1.24.4

func (c *KubeConfigAPIServerInfoClient) APIServerVersion() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL