qos

Documentation

Index

• Constants
• func GetEgressPriorityFromPod(podAnnotation map[string]string) *ccev2.EgressPriorityOpt
• func InitEgressPriorityManager()
• type EgressPriorityManager
  • func (*EgressPriorityManager) AcceptType() event.EndpointProbeEventType
  • func (manager *EgressPriorityManager) ENIUpdateEventHandler(eni *ccev2.ENI)
  • func (manager *EgressPriorityManager) Handle(event *event.EndpointProbeEvent) (*ccev2.ExtFeatureStatus, error)
  • func (manager *EgressPriorityManager) Start(cceEndpointClient *watchers.CCEEndpointClient)

Constants

const (
	AnnotaionPodEgressPriority = "cce.baidubce.com/egress-priority"
)

Functions

func GetEgressPriorityFromPod

func GetEgressPriorityFromPod(podAnnotation map[string]string) *ccev2.EgressPriorityOpt

func InitEgressPriorityManager

func InitEgressPriorityManager()

Types

type EgressPriorityManager

type EgressPriorityManager struct {
	// contains filtered or unexported fields
}

var (
	GlobalManager *EgressPriorityManager
)

func (*EgressPriorityManager) AcceptType

func (*EgressPriorityManager) AcceptType() event.EndpointProbeEventType

AcceptType implements event.EndpointProbeEventHandler.

func (*EgressPriorityManager) ENIUpdateEventHandler

func (manager *EgressPriorityManager) ENIUpdateEventHandler(eni *ccev2.ENI)

func (*EgressPriorityManager) Handle

func (manager *EgressPriorityManager) Handle(event *event.EndpointProbeEvent) (*ccev2.ExtFeatureStatus, error)

Handle implements event.EndpointProbeEventHandler.

func (*EgressPriorityManager) Start

func (manager *EgressPriorityManager) Start(cceEndpointClient *watchers.CCEEndpointClient)