Documentation
¶
Index ¶
- Constants
- func NeedDeploymentToPodAnnotation(key string) bool
- type ClusterAssignmentInfo
- type EndpointInfo
- type 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 ¶
View Source
const ( WEIGHT_LABEL = "traffic.endpoint.weight" DEPLOYMENT_WEIGHT_LABEL = kubernetes.POD_DEPLOYMENT_PREFIX + "endpoint.weight" )
Variables ¶
This section is empty.
Functions ¶
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 ¶
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
Click to show internal directories.
Click to hide internal directories.