package kube

import "istio.io/istio/pilot/pkg/serviceregistry/kube"

Index ¶

• Constants
• func ConvertProbePort(c *coreV1.Container, handler *coreV1.Handler) (*model.Port, error)
• func ConvertProbesToPorts(t *coreV1.PodSpec) (model.PortList, error)
• func ConvertService(svc coreV1.Service, domainSuffix string, clusterID string) *model.Service
• func DeRegisterEndpoint(client kubernetes.Interface, namespace string, svcName string, ip string) error
• func ExternalNameServiceInstances(k8sSvc coreV1.Service, svc *model.Service) []*model.ServiceInstance
• func KeyFunc(name, namespace string) string
• func PodTLSMode(pod *coreV1.Pod) string
• func RegisterEndpoint(client kubernetes.Interface, namespace string, svcName string, ip string, portsList []NamedPort, labels []string, annotations []string) error
• func SecureNamingSAN(pod *coreV1.Pod) string
• func ServiceHostname(name, namespace, domainSuffix string) host.Name
• type NamedPort
• func Str2NamedPort(str string) (NamedPort, error)

Package Files ¶

conversion.go deregister.go register.go

Constants ¶

const (
    // IngressClassAnnotation is the annotation on ingress resources for the class of controllers
    // responsible for it
    IngressClassAnnotation = "kubernetes.io/ingress.class"
)

func ConvertProbePort ¶ Uses

func ConvertProbePort(c *coreV1.Container, handler *coreV1.Handler) (*model.Port, error)

func ConvertProbesToPorts ¶ Uses

func ConvertProbesToPorts(t *coreV1.PodSpec) (model.PortList, error)

ConvertProbesToPorts returns a PortList consisting of the ports where the pod is configured to do Liveness and Readiness probes

func ConvertService ¶ Uses

func ConvertService(svc coreV1.Service, domainSuffix string, clusterID string) *model.Service

func DeRegisterEndpoint ¶ Uses

func DeRegisterEndpoint(client kubernetes.Interface, namespace string, svcName string,
    ip string) error

DeRegisterEndpoint removes the endpoint (and the service if it already exists) from Kubernetes. It creates or updates as needed.

func ExternalNameServiceInstances ¶ Uses

func ExternalNameServiceInstances(k8sSvc coreV1.Service, svc *model.Service) []*model.ServiceInstance

func KeyFunc ¶ Uses

func KeyFunc(name, namespace string) string

KeyFunc is the internal API key function that returns "namespace"/"name" or "name" if "namespace" is empty

func PodTLSMode ¶ Uses

func PodTLSMode(pod *coreV1.Pod) string

PodTLSMode returns the tls mode associated with the pod if pod has been injected with sidecar

func RegisterEndpoint ¶ Uses

func RegisterEndpoint(client kubernetes.Interface, namespace string, svcName string,
    ip string, portsList []NamedPort, labels []string, annotations []string) error

RegisterEndpoint registers the endpoint (and the service if it doesn't already exists). It creates or updates as needed. When creating it adds the optional labels.

func SecureNamingSAN ¶ Uses

func SecureNamingSAN(pod *coreV1.Pod) string

SecureNamingSAN creates the secure naming used for SAN verification from pod metadata

func ServiceHostname ¶ Uses

func ServiceHostname(name, namespace, domainSuffix string) host.Name

ServiceHostname produces FQDN for a k8s service

type NamedPort ¶ Uses

type NamedPort struct {
    Port int32
    Name string
}

NamedPort defines the Port and Name tuple needed for services and endpoints.

func Str2NamedPort ¶ Uses

func Str2NamedPort(str string) (NamedPort, error)

Str2NamedPort parses a proto:port string into a namePort struct.

Directories ¶