storage

Documentation

Index

• Constants
• func NewStorageCache(hostName string, wrapperInCluster, serviceAutonomyEnhancementEnabled bool, ...) *storageCache
• type Cache
• type CacheEventHandler
• type CacheList
• type LocalNodeInfoHandler

Constants

const (
	TopologyAnnotationsKey = "topologyKeys"

	EdgeLocalEndpoint  = "superedge.io/local-endpoint"
	EdgeLocalPort      = "superedge.io/local-port"
	MasterEndpointName = "kubernetes"
)

Functions

func NewStorageCache

func NewStorageCache(hostName string, wrapperInCluster, serviceAutonomyEnhancementEnabled bool, serviceBroadcaster, endpointSliceV1Broadcaster, endpointSliceV1Beta1Broadcaster, endpointBroadcaster, nodeBroadcaster *watch.Broadcaster, supportEndpointSlice bool) *storageCache

Types

type Cache

type Cache interface {
	CacheList
	CacheEventHandler
	LocalNodeInfoHandler
	GetNodeName() string
}

type CacheEventHandler

type CacheEventHandler interface {
	NodeEventHandler() cache.ResourceEventHandler
	ServiceEventHandler() cache.ResourceEventHandler
	EndpointsEventHandler() cache.ResourceEventHandler
	EndpointSliceV1EventHandler() cache.ResourceEventHandler
	EndpointSliceV1Beta1EventHandler() cache.ResourceEventHandler
}

type CacheList

type CacheList interface {
	GetNode(hostName string) *v1.Node
	GetServices() []*v1.Service
	GetEndpoints() []*v1.Endpoints
	GetEndpointSliceV1() []*discoveryv1.EndpointSlice
	GetEndpointSliceV1Beta1() []*discoveryv1beta1.EndpointSlice
}

type LocalNodeInfoHandler

type LocalNodeInfoHandler interface {
	GetLocalNodeInfo() map[string]data.ResultDetail
	SetLocalNodeInfo(map[string]data.ResultDetail)
	ClearLocalNodeInfo()
}