servicetopology

Documentation

Index

• Constants
• func NewFilter() *serviceTopologyFilter
• func NewServiceTopologyFilterHandler(nodeName string, serializer *serializer.Serializer, ...) filter.Handler
• func Register(filters *filter.Filters)

Constants

const (
	AnnotationServiceTopologyKey           = "openyurt.io/topologyKeys"
	AnnotationServiceTopologyValueNode     = "kubernetes.io/hostname"
	AnnotationServiceTopologyValueZone     = "kubernetes.io/zone"
	AnnotationServiceTopologyValueNodePool = "openyurt.io/nodepool"
)

const FilterName = "servicetopology"

servicetopology filter is used to reassemble endpointslice in order to make the service traffic under the topology that defined by service.Annotation["openyurt.io/topologyKeys"]

Functions

func NewFilter

func NewFilter() *serviceTopologyFilter

func NewServiceTopologyFilterHandler

func NewServiceTopologyFilterHandler(
	nodeName string,
	serializer *serializer.Serializer,
	serviceLister listers.ServiceLister,
	nodePoolLister appslisters.NodePoolLister,
	nodeGetter filter.NodeGetter) filter.Handler

func Register

func Register(filters *filter.Filters)

Register registers a filter