endpoint

Documentation

Index

• Constants
• func NeedDeploymentToPodAnnotation(key string) bool
• type ClusterAssignmentInfo
  • func NewClusterAssignmentInfo(svc string, ns string, port uint32) *ClusterAssignmentInfo
  • func (info *ClusterAssignmentInfo) Clone() common.EnvoyResourceClonable
  • func (info *ClusterAssignmentInfo) Name() string
  • func (info *ClusterAssignmentInfo) String() string
  • func (info *ClusterAssignmentInfo) Type() string
  • func (info *ClusterAssignmentInfo) Version() string
• type EndpointInfo
  • func (info *EndpointInfo) Config(pod *kubernetes.PodInfo)
  • func (info *EndpointInfo) CreateLoadBalanceEndpoint(port uint32) *endpoint.LbEndpoint
  • func (info EndpointInfo) String() string
• type EndpointsControlPlaneService
  • func NewEndpointsControlPlaneService(k8sManager *kubernetes.K8sResourceManager) *EndpointsControlPlaneService
  • func (cps *EndpointsControlPlaneService) BuildResource(resourceMap map[string]common.EnvoyResource, version string, node *core.Node) (*envoy_api_v2.DiscoveryResponse, error)
  • func (cps *EndpointsControlPlaneService) PodAdded(pod *kubernetes.PodInfo)
  • func (cps *EndpointsControlPlaneService) PodDeleted(pod *kubernetes.PodInfo)
  • func (cps *EndpointsControlPlaneService) PodUpdated(oldPod, newPod *kubernetes.PodInfo)
  • func (manager *EndpointsControlPlaneService) PodValid(pod *kubernetes.PodInfo) bool

Constants

const (
	WEIGHT_LABEL            = "traffic.endpoint.weight"
	DEPLOYMENT_WEIGHT_LABEL = kubernetes.POD_DEPLOYMENT_PREFIX + "endpoint.weight"
)

Functions

func NeedDeploymentToPodAnnotation

func NeedDeploymentToPodAnnotation(key string) bool

Types

type ClusterAssignmentInfo

type ClusterAssignmentInfo struct {
	Service     string
	Namespace   string
	Port        uint32
	EndpointMap map[string]*EndpointInfo
}

func NewClusterAssignmentInfo

func NewClusterAssignmentInfo(svc string, ns string, port uint32) *ClusterAssignmentInfo

func (*ClusterAssignmentInfo) Clone

func (info *ClusterAssignmentInfo) Clone() common.EnvoyResourceClonable

func (*ClusterAssignmentInfo) Name

func (info *ClusterAssignmentInfo) Name() string

func (*ClusterAssignmentInfo) String

func (info *ClusterAssignmentInfo) String() string

func (*ClusterAssignmentInfo) Type

func (info *ClusterAssignmentInfo) Type() string

func (*ClusterAssignmentInfo) Version

func (info *ClusterAssignmentInfo) Version() string

type EndpointInfo

type EndpointInfo struct {
	PodIP   string
	Weight  uint32
	Version string
}

func (*EndpointInfo) Config

func (info *EndpointInfo) Config(pod *kubernetes.PodInfo)

func (*EndpointInfo) CreateLoadBalanceEndpoint

func (info *EndpointInfo) CreateLoadBalanceEndpoint(port uint32) *endpoint.LbEndpoint

func (EndpointInfo) String

func (info EndpointInfo) String() string

type EndpointsControlPlaneService

type EndpointsControlPlaneService struct {
	*common.ControlPlaneService
}

func NewEndpointsControlPlaneService

func NewEndpointsControlPlaneService(k8sManager *kubernetes.K8sResourceManager) *EndpointsControlPlaneService

func (*EndpointsControlPlaneService) BuildResource

func (cps *EndpointsControlPlaneService) BuildResource(resourceMap map[string]common.EnvoyResource, version string, node *core.Node) (*envoy_api_v2.DiscoveryResponse, error)

func (*EndpointsControlPlaneService) PodAdded

func (cps *EndpointsControlPlaneService) PodAdded(pod *kubernetes.PodInfo)

func (*EndpointsControlPlaneService) PodDeleted

func (cps *EndpointsControlPlaneService) PodDeleted(pod *kubernetes.PodInfo)

func (*EndpointsControlPlaneService) PodUpdated

func (cps *EndpointsControlPlaneService) PodUpdated(oldPod, newPod *kubernetes.PodInfo)

func (*EndpointsControlPlaneService) PodValid

func (manager *EndpointsControlPlaneService) PodValid(pod *kubernetes.PodInfo) bool