Documentation ¶
Index ¶
- func ApiServerProxyPath(namespace, schema, svcname, port string) string
- type APIServerInfoClient
- type Client
- type ClientSet
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ApiServerProxyPath ¶
Types ¶
type APIServerInfoClient ¶ added in v1.23.12
type APIServerInfoClient struct { APIServerHost *url.URL Discovery discovery.DiscoveryInterface }
func NewAPIServerInfoClient ¶ added in v1.23.12
func NewAPIServerInfoClient(cfg *rest.Config) (*APIServerInfoClient, error)
func NewAPIServerInfoClientOrEmpty ¶ added in v1.23.12
func NewAPIServerInfoClientOrEmpty(cfg *rest.Config) *APIServerInfoClient
func (*APIServerInfoClient) APIServerAddr ¶ added in v1.23.12
func (c *APIServerInfoClient) APIServerAddr() string
func (*APIServerInfoClient) APIServerVersion ¶ added in v1.23.12
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 }
type ClientSet ¶
type ClientSet struct {
// contains filtered or unexported fields
}
func (*ClientSet) ClientOfManager ¶ added in v1.22.0
func (*ClientSet) ClientOptionsOf ¶ added in v1.23.12
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 (c *DelegateClient) Info() *APIServerInfoClient
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
Click to show internal directories.
Click to hide internal directories.