privateendpoints

Documentation

Index

• type PrivateLinksScope
• type Scope
  • func NewScope(ctx context.Context, cluster *capz.AzureCluster, client client.Client, ...) (Scope, error)
• type Service
  • func NewService(privateEndpointsScope Scope, privateLinksScope PrivateLinksScope) (*Service, error)
  • func (s *Service) DeleteMcToWcApi(_ context.Context) error
  • func (s *Service) ReconcileMcToWcApi(ctx context.Context) error
  • func (s *Service) ReconcileWcToMcIngress(ctx context.Context, wcToMcSpec capz.PrivateEndpointSpec) error

Types

type PrivateLinksScope

type PrivateLinksScope interface {
	GetClusterName() types.NamespacedName
	GetSubscriptionID() string
	GetLocation() string
	GetResourceGroup() string
	GetPrivateLinksWithAllowedSubscription(managementClusterSubscriptionID string) []capz.PrivateLink
	LookupPrivateLink(privateLinkResourceID string) (capz.PrivateLink, bool)
	PatchObject(ctx context.Context) error
	PrivateLinksReady() bool
	SetPrivateEndpointIPAddressForWcApi(ip net.IP)
	SetPrivateEndpointIPAddressForMcIngress(ip net.IP)
	Close(ctx context.Context) error
}

PrivateLinksScope is the interface for getting private links for which the private endpoints are needed.

type Scope

type Scope interface {
	GetClusterName() types.NamespacedName
	GetSubscriptionID() string
	GetLocation() string
	GetResourceGroup() string
	GetPrivateEndpoints() []capz.PrivateEndpointSpec
	GetPrivateEndpointsToWorkloadCluster(workloadClusterSubscriptionID, workloadClusterResourceGroup string) []capz.PrivateEndpointSpec
	GetPrivateEndpointIPAddress(ctx context.Context, privateEndpointName string) (net.IP, error)
	ContainsPrivateEndpointSpec(capz.PrivateEndpointSpec) bool
	AddPrivateEndpointSpec(capz.PrivateEndpointSpec)
	RemovePrivateEndpointByName(string)
	PatchObject(ctx context.Context) error
	Close(ctx context.Context) error
}

Scope is the interface for working with private endpoints.

func NewScope

func NewScope(ctx context.Context, cluster *capz.AzureCluster, client client.Client, privateEndpointClient azure.PrivateEndpointsClient) (Scope, error)

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewService

func NewService(privateEndpointsScope Scope, privateLinksScope PrivateLinksScope) (*Service, error)

func (*Service) DeleteMcToWcApi

func (s *Service) DeleteMcToWcApi(_ context.Context) error

func (*Service) ReconcileMcToWcApi

func (s *Service) ReconcileMcToWcApi(ctx context.Context) error

func (*Service) ReconcileWcToMcIngress

func (s *Service) ReconcileWcToMcIngress(ctx context.Context, wcToMcSpec capz.PrivateEndpointSpec) error