agents

Documentation

Index

• func ApiServerProxyPath(namespace, schema, svcname, port string) string
• type APIServerInfoClient
  • func NewAPIServerInfoClient(cfg *rest.Config) (*APIServerInfoClient, error)
  • func NewAPIServerInfoClientOrEmpty(cfg *rest.Config) *APIServerInfoClient
  • func (c *APIServerInfoClient) APIServerAddr() string
  • func (c *APIServerInfoClient) APIServerVersion() string
• type Client
  • 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) ClientOptionsOf(ctx context.Context, name string) (*client.Config, *rest.Config, 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) 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

Functions

func ApiServerProxyPath

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

Types

type APIServerInfoClient

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

func NewAPIServerInfoClient

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

func NewAPIServerInfoClientOrEmpty

func NewAPIServerInfoClientOrEmpty(cfg *rest.Config) *APIServerInfoClient

func (*APIServerInfoClient) APIServerAddr

func (c *APIServerInfoClient) APIServerAddr() string

func (*APIServerInfoClient) APIServerVersion

func (c *APIServerInfoClient) APIServerVersion() string

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
}

func NewDelegateClientClient

func NewDelegateClientClient(name string, cfg *agentcli.Config, kubecfg *rest.Config, schema *runtime.Scheme, tracer trace.Tracer) (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) ClientOptionsOf

func (h *ClientSet) ClientOptionsOf(ctx context.Context, name string) (*client.Config, *rest.Config, 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) 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