dns

Documentation

Index

• func MakeDeployment(name, namespace, image string) *appsv1.Deployment
• func MakeNetworkPolicy(name, namespace, tenantID string, kubeEndpoints *corev1.EndpointSubset) *networkingv1.NetworkPolicy
• func MakeRole(name, namespace string) *rbacv1.Role
• func MakeRoleBinding(name, namespace string) *rbacv1.RoleBinding
• func MakeService(name, namespace string) *corev1.Service
• func MakeServiceAccount(name, namespace string) *corev1.ServiceAccount
• type DNSProcessor
  • func NewDNSProcessor(downstreamKubeClient kubernetes.Interface, ...) *DNSProcessor
  • func (d *DNSProcessor) EnsureDNSUpAndReady(ctx context.Context, namespaceLocator shared.NamespaceLocator) (bool, error)
  • func (d *DNSProcessor) ServiceLister() listerscorev1.ServiceLister

Functions

func MakeDeployment

func MakeDeployment(name, namespace, image string) *appsv1.Deployment

func MakeNetworkPolicy

func MakeNetworkPolicy(name, namespace, tenantID string, kubeEndpoints *corev1.EndpointSubset) *networkingv1.NetworkPolicy

func MakeRole

func MakeRole(name, namespace string) *rbacv1.Role

func MakeRoleBinding

func MakeRoleBinding(name, namespace string) *rbacv1.RoleBinding

func MakeService

func MakeService(name, namespace string) *corev1.Service

func MakeServiceAccount

func MakeServiceAccount(name, namespace string) *corev1.ServiceAccount

Types

type DNSProcessor

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

func NewDNSProcessor

func NewDNSProcessor(
	downstreamKubeClient kubernetes.Interface,
	syncerNamespaceInformerFactory kubernetesinformers.SharedInformerFactory,
	syncTargetName string,
	syncTargetUID types.UID,
	dnsNamespace string,
	dnsImage string) *DNSProcessor

func (*DNSProcessor) EnsureDNSUpAndReady

func (d *DNSProcessor) EnsureDNSUpAndReady(ctx context.Context, namespaceLocator shared.NamespaceLocator) (bool, error)

EnsureDNSUpAndReady creates all DNS-related resources if necessary. It also checks that the DNS Deployment for this workspace are effectively reachable through the Service. It returns true if the DNS is setup and reachable, and returns an error if there was an error during the check or creation of the DNS-related resources.

func (*DNSProcessor) ServiceLister

func (d *DNSProcessor) ServiceLister() listerscorev1.ServiceLister