utils

Documentation

Index

• func FindContainerPort(pod *api.Pod, svcPort *api.ServicePort) int
• func FindServicePort(svc *api.Service, servicePort string) *api.ServicePort
• func RebalanceWeight(clusters []*WeightCluster, initialWeight int)
• type Endpoint
  • func CreateEndpoints(cache types.Cache, svc *api.Service, svcPort *api.ServicePort, ...) (ready, notReady []*Endpoint, err error)
  • func CreateSvcEndpoint(svc *api.Service, svcPort *api.ServicePort) (endpoint *Endpoint, err error)
  • func (e *Endpoint) String() string
• type WeightCluster

Functions

func FindContainerPort

func FindContainerPort(pod *api.Pod, svcPort *api.ServicePort) int

FindContainerPort Find the container's port number of a known servicePort Search criteria: 1. svcPort.TargetPort is a number: this is the right container's port 2. svcPort.TargetPort is a named port (not a number): find a container's port with that name and use its ContainerPort If targetPort is neither a valid port number nor a declared named port, return zero which means that the port was not found

func FindServicePort

func FindServicePort(svc *api.Service, servicePort string) *api.ServicePort

FindServicePort ...

func RebalanceWeight

func RebalanceWeight(clusters []*WeightCluster, initialWeight int)

RebalanceWeight ...

Types

type Endpoint

type Endpoint struct {
	IP        string
	Port      int
	Target    string
	TargetRef string
}

Endpoint ...

func CreateEndpoints

func CreateEndpoints(cache types.Cache, svc *api.Service, svcPort *api.ServicePort, useEndpointSlices bool) (ready, notReady []*Endpoint, err error)

CreateEndpoints ...

func CreateSvcEndpoint

func CreateSvcEndpoint(svc *api.Service, svcPort *api.ServicePort) (endpoint *Endpoint, err error)

CreateSvcEndpoint ...

func (*Endpoint) String

func (e *Endpoint) String() string

type WeightCluster

type WeightCluster struct {
	Weight int
	Length int
}

WeightCluster ...