k8sdefaultendpoint

Documentation

Index

• func Register(ctx *synccontext.ControllerContext) error
• func ShouldUseLegacy(discoveryClient discovery.DiscoveryInterface) (bool, error)
• type EndpointController
  • func NewEndpointController(ctx *synccontext.ControllerContext, provider provider) *EndpointController
  • func (e *EndpointController) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, error)
  • func (e *EndpointController) Register(mgr ctrl.Manager) error
  • func (e *EndpointController) SetupWithManager(mgr ctrl.Manager) error
• type EndpointsV1BetaProvider
  • func (p *EndpointsV1BetaProvider) CreateClientObject() client.Object
  • func (p *EndpointsV1BetaProvider) CreateOrPatch(ctx context.Context, virtualClient client.Client, vEndpoints *corev1.Endpoints) error
• type EndpointsV1Provider
  • func (p *EndpointsV1Provider) CreateClientObject() client.Object
  • func (p *EndpointsV1Provider) CreateOrPatch(ctx context.Context, virtualClient client.Client, vEndpoints *corev1.Endpoints) error

Functions

func Register

func Register(ctx *synccontext.ControllerContext) error

func ShouldUseLegacy

func ShouldUseLegacy(discoveryClient discovery.DiscoveryInterface) (bool, error)

Types

type EndpointController

type EndpointController struct {
	ServiceName      string
	ServiceNamespace string
	ServiceClient    client.Client

	VirtualClient       client.Client
	VirtualManagerCache cache.Cache

	Log loghelper.Logger
	// contains filtered or unexported fields
}

func NewEndpointController

func NewEndpointController(ctx *synccontext.ControllerContext, provider provider) *EndpointController

func (*EndpointController) Reconcile

func (e *EndpointController) Reconcile(ctx context.Context, _ ctrl.Request) (ctrl.Result, error)

func (*EndpointController) Register

func (e *EndpointController) Register(mgr ctrl.Manager) error

func (*EndpointController) SetupWithManager

func (e *EndpointController) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager adds the controller to the manager

type EndpointsV1BetaProvider

type EndpointsV1BetaProvider struct{}

func (*EndpointsV1BetaProvider) CreateClientObject

func (p *EndpointsV1BetaProvider) CreateClientObject() client.Object

func (*EndpointsV1BetaProvider) CreateOrPatch

func (p *EndpointsV1BetaProvider) CreateOrPatch(ctx context.Context, virtualClient client.Client, vEndpoints *corev1.Endpoints) error

type EndpointsV1Provider

type EndpointsV1Provider struct{}

func (*EndpointsV1Provider) CreateClientObject

func (p *EndpointsV1Provider) CreateClientObject() client.Object

func (*EndpointsV1Provider) CreateOrPatch

func (p *EndpointsV1Provider) CreateOrPatch(ctx context.Context, virtualClient client.Client, vEndpoints *corev1.Endpoints) error