Versions in this module Expand all Collapse all v0 v0.7.0 Oct 19, 2024 Changes in this version + const MaxPortNum + const MaxServiceNum + func CleanupFakeWorkloadMap(maps bpf2go.KmeshCgroupSockWorkloadMaps) + func LookupAll[K any, V any](bpfMap *ebpf.Map) []V + func NewFakeWorkloadMap(t *testing.T) bpf2go.KmeshCgroupSockWorkloadMaps + type BackendKey struct + BackendUid uint32 + type BackendValue struct + Ip [16]byte + ServiceCount uint32 + Services ServiceList + WaypointAddr [16]byte + WaypointPort uint32 + type Cache struct + func NewCache(workloadMap bpf2go.KmeshCgroupSockWorkloadMaps) *Cache + func (c *Cache) BackendCount() int + func (c *Cache) BackendDelete(key *BackendKey) error + func (c *Cache) BackendLookup(key *BackendKey, value *BackendValue) error + func (c *Cache) BackendLookupAll() []BackendValue + func (c *Cache) BackendUpdate(key *BackendKey, value *BackendValue) error + func (c *Cache) EndpointCount() int + func (c *Cache) EndpointDelete(key *EndpointKey) error + func (c *Cache) EndpointLookup(key *EndpointKey, value *EndpointValue) error + func (c *Cache) EndpointLookupAll() []EndpointValue + func (c *Cache) EndpointSwap(currentIndex, lastIndex uint32, serviceId uint32) error + func (c *Cache) EndpointUpdate(key *EndpointKey, value *EndpointValue) error + func (c *Cache) FrontendCount() int + func (c *Cache) FrontendDelete(key *FrontendKey) error + func (c *Cache) FrontendIterFindKey(upstreamId uint32) []FrontendKey + func (c *Cache) FrontendLookup(key *FrontendKey, value *FrontendValue) error + func (c *Cache) FrontendLookupAll() []FrontendValue + func (c *Cache) FrontendUpdate(key *FrontendKey, value *FrontendValue) error + func (c *Cache) GetAllEndpointsForService(serviceId uint32) []EndpointValue + func (c *Cache) GetEndpointKeys(workloadID uint32) sets.Set[EndpointKey] + func (c *Cache) RestoreEndpointKeys() + func (c *Cache) ServiceCount() int + func (c *Cache) ServiceDelete(key *ServiceKey) error + func (c *Cache) ServiceLookup(key *ServiceKey, value *ServiceValue) error + func (c *Cache) ServiceLookupAll() []ServiceValue + func (c *Cache) ServiceUpdate(key *ServiceKey, value *ServiceValue) error + func (c *Cache) WorkloadPolicyDelete(key *WorkloadPolicyKey) error + func (c *Cache) WorkloadPolicyLookup(key *WorkloadPolicyKey, value *WorkloadPolicyValue) error + func (c *Cache) WorkloadPolicyLookupAll() []WorkloadPolicyValue + func (c *Cache) WorkloadPolicyUpdate(key *WorkloadPolicyKey, value *WorkloadPolicyValue) error + type EndpointKey struct + BackendIndex uint32 + ServiceId uint32 + type EndpointValue struct + BackendUid uint32 + type FrontendKey struct + Ip [16]byte + type FrontendValue struct + UpstreamId uint32 + type ServiceKey struct + ServiceId uint32 + type ServiceList [MaxServiceNum]uint32 + type ServicePorts [MaxPortNum]uint32 + type ServiceValue struct + EndpointCount uint32 + LbPolicy uint32 + ServicePort ServicePorts + TargetPort TargetPorts + WaypointAddr [16]byte + WaypointPort uint32 + type TargetPorts [MaxPortNum]uint32 + type WorkloadPolicyKey struct + WorklodId uint32 + type WorkloadPolicyValue struct + PolicyIds [4]uint32
Go to main page