Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAntreaClientProvider ¶
func NewAntreaClientProvider(config config.ClientConnectionConfiguration, kubeClient kubernetes.Interface) (*antreaClientProvider, error)
Types ¶
type AntreaClientProvider ¶
AntreaClientProvider provides a method to get Antrea client.
type EndpointResolver ¶
type EndpointResolver struct {
// contains filtered or unexported fields
}
EndpointResolver is in charge of resolving a specific Service Endpoint, which can then be accessed directly instead of depending on the ClusterIP functionality provided by K8s proxies (whether it's kube-proxy or AntreaProxy). A new Endpoint is resolved every time the Service's Spec or the Endpoints' Subsets are updated, and registered listeners are notified. While this EndpointResolver is somewhat generic, at the moment it is only meant to be used for the Antrea Service.
func NewEndpointResolver ¶
func NewEndpointResolver(kubeClient kubernetes.Interface, namespace, serviceName string, servicePort int32) *EndpointResolver
func (*EndpointResolver) AddListener ¶
func (r *EndpointResolver) AddListener(listener Listener)
func (*EndpointResolver) CurrentEndpointURL ¶
func (r *EndpointResolver) CurrentEndpointURL() *url.URL
func (*EndpointResolver) Run ¶
func (r *EndpointResolver) Run(ctx context.Context)
Source Files
Click to show internal directories.
Click to hide internal directories.