cache

package

v0.0.0-...-e9f4c3e Latest Latest Go to latest Published: Dec 26, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

View Source

const (
	UnexistFlowID  uint64 = 0
	UnexistGroupID uint32 = 0
)

This section is empty.

func GenDnatMapKey(ip, protocol string, port int32) string

type CreateGroupFunc func() (*ofctrl.Group, error)

type DeleteGroupFunc func(gpID uint32)

type SvcFlowEntry struct {
	LBIP     string
	PortName string
	FlowID   uint64
}

type SvcGroupEntry struct {
	PortName      string
	TrafficPolicy ertype.TrafficPolicyType
	GroupID       uint32
}

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

func NewSvcIndex() *SvcIndex

func (s *SvcIndex) DeleteDnatFlow(backend string)

func (s *SvcIndex) GetDnatFlow(backend string) uint64

func (s *SvcIndex) GetSvcOvsInfo(svcID string) *SvcOvsInfo

func (s *SvcIndex) GetSvcOvsInfoAndInitIfEmpty(svcID string) *SvcOvsInfo

func (s *SvcIndex) IsSvcInfoNil(svcID string) bool

used by unittest

func (s *SvcIndex) SetDnatFlow(backend string, flowID uint64)

func (s *SvcIndex) TryCleanSvcOvsInfoCache(svcID string)

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

func NewSvcOvsInfo(svcID string) *SvcOvsInfo

func (s *SvcOvsInfo) DeleteGroupIfExist(portName string, groupType ertype.TrafficPolicyType, f DeleteGroupFunc)

func (s *SvcOvsInfo) DeleteLBFlowsByPortName(portName string)

func (s *SvcOvsInfo) GetAllGroups() []SvcGroupEntry

func (s *SvcOvsInfo) GetAllLBFlows() []SvcFlowEntry

func (s *SvcOvsInfo) GetAllSessionAffinityFlows() []SvcFlowEntry

func (s *SvcOvsInfo) GetGroup(portName string, groupType ertype.TrafficPolicyType) uint32

func (s *SvcOvsInfo) GetGroupAndCreateIfEmpty(portName string, groupType ertype.TrafficPolicyType, f CreateGroupFunc) (uint32, error)

func (s *SvcOvsInfo) GetLBFlow(lbIP, portName string) uint64

func (s *SvcOvsInfo) GetSessionAffinityFlow(lbIP, portName string) uint64

func (s *SvcOvsInfo) IsEmpty() bool

func (s *SvcOvsInfo) SetLBFlow(lbIP, portName string, flowID uint64)

func (s *SvcOvsInfo) SetSessionAffinityFlow(lbIP, portName string, flowID uint64)