MCPcopy Create free account

hub / github.com/eth-easl/dirigent / functions

Functions1,276 in github.com/eth-easl/dirigent

⨍ Functions 1,276◇ Types & classes 154
↓ 77 callersMethodUnlock
()
pkg/synchronization/control_plane_sync.go:34
↓ 72 callersMethodLock
()
pkg/synchronization/control_plane_sync.go:32
↓ 39 callersMethodGet
Not thread safe
pkg/synchronization/control_plane_sync.go:42
↓ 32 callersMethodSet
Not thread safe
pkg/synchronization/control_plane_sync.go:41
↓ 31 callersMethodGetMap
()
pkg/synchronization/control_plane_sync.go:37
↓ 23 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
mock/mock_core/mock_core.go:43
↓ 23 callersMethodGetNumberConnectedWorkers
* * Functions used for testing */
internal/control_plane/helpers.go:122
↓ 23 callersMethodGetNumberDataplanes
()
internal/control_plane/helpers.go:126
↓ 23 callersMethodGetNumberServices
()
internal/control_plane/helpers.go:130
↓ 21 callersFunctionCreateResourceMap
CreateResourceMap CPU in milliCPUs.
internal/control_plane/placement_policy/resource_map.go:85
↓ 21 callersMethodGetName
()
internal/control_plane/core/interface.go:55
↓ 21 callersFunctionNewRandomPlacement
()
internal/control_plane/placement_policy/random.go:35
↓ 20 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
mock/mock_persistence/mock_persistence.go:39
↓ 20 callersMethodLen
()
pkg/synchronization/control_plane_sync.go:52
↓ 20 callersFunctionNewControlPlane
(client persistence.PersistenceLayer, outputFile string, placementPolicy placement_policy.PlacementPolicy, da
internal/control_plane/control_plane.go:62
↓ 20 callersMethodString
()
internal/control_plane/leader_election/state.go:38
↓ 19 callersMethodRUnlock
()
pkg/synchronization/control_plane_sync.go:35
↓ 18 callersMethodGetUpstreamEndpoints
()
internal/data_plane/function_metadata/function_metadata.go:129
↓ 17 callersMethodRLock
()
pkg/synchronization/control_plane_sync.go:33
↓ 17 callersMethodReconstructState
ReconstructState Single threaded function - reconstruction happend before starting the control plane
internal/control_plane/reconstruction.go:42
↓ 16 callersMethodIsLeader
()
internal/control_plane/leader_election/server.go:91
↓ 14 callersFunctionNewAtomicMap
()
pkg/atomic_map/atomic_map.go:37
↓ 14 callersFunctiondeleteNetworkNamespaceByName
(name string)
internal/worker_node/sandbox/firecracker/networking.go:348
↓ 14 callersFunctionsimplePersistenceLayer
Smoke test
internal/control_plane/control_plane_test.go:65
↓ 12 callersMethodGetLeader
()
internal/control_plane/leader_election/server.go:95
↓ 12 callersMethodGetStatistics
()
internal/data_plane/function_metadata/function_metadata.go:121
↓ 11 callersMethodGetEndpointMap
()
internal/control_plane/core/interface.go:67
↓ 11 callersMethodRemove
Not thread safe
pkg/synchronization/control_plane_sync.go:44
↓ 10 callersFunctionExtendCPU
(resourceMap *ResourceMap)
internal/control_plane/placement_policy/resource_map.go:96
↓ 10 callersMethodGetMemory
()
internal/control_plane/core/interface.go:61
↓ 10 callersMethodGetNoCheck
Not thread safe
pkg/synchronization/control_plane_sync.go:43
↓ 10 callersMethodInt
()
internal/worker_node/managers/thread_safe_random.go:45
↓ 10 callersMethodRegisterService
(ctx context.Context, in *ServiceInfo, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:25
↓ 9 callersFunctionNewConsensusModule
NewConsensusModule creates a new CM with the given ID, list of peer IDs and server. The ready channel signals the CM that all peers are connected and
internal/control_plane/leader_election/consensus_module.go:73
↓ 9 callersMethodRegisterNode
(ctx context.Context, in *proto.NodeInfo)
internal/control_plane/control_plane.go:191
↓ 9 callersMethodRegisterService
Service functions
internal/control_plane/control_plane.go:283
↓ 9 callersFunctionfile_common_proto_rawDescGZIP
()
api/proto/common.pb.go:782
↓ 9 callersFunctiongetTestEndpoints
()
internal/data_plane/proxy/load_balancing/load_balancing_test.go:35
↓ 8 callersMethodGetCPUCores
()
internal/control_plane/placement_policy/resource_map.go:38
↓ 8 callersMethodGetIP
()
internal/control_plane/core/interface.go:45
↓ 8 callersMethodHandleFunc
(path string, f func(w http.ResponseWriter, r *http.Request))
workload/http_workload.go:171
↓ 8 callersMethodRegisterDataplane
Dataplanes functions
internal/control_plane/control_plane.go:83
↓ 8 callersFunctiondeleteDeviceByName
(name string)
internal/worker_node/sandbox/firecracker/networking.go:341
↓ 7 callersMethodAppendEntries
(ctx context.Context, in *AppendEntriesArgs, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:35
↓ 7 callersMethodAtomicIncrement
(key K)
pkg/atomic_map/atomic_map_counter.go:74
↓ 7 callersMethodKeys
()
pkg/atomic_map/atomic_map.go:78
↓ 7 callersFunctionNewControlPlaneSyncStructure
()
pkg/synchronization/control_plane_sync.go:61
↓ 7 callersMethodRequestVote
RAFT leader election
api/proto/control_plane_interface_grpc.pb.go:34
↓ 7 callersMethodStart
()
internal/control_plane/autoscaling/controller.go:65
↓ 7 callersMethodStoreServiceInformation
(ctx context.Context, serviceInfo *proto.ServiceInfo)
internal/control_plane/persistence/interface.go:40
↓ 7 callersMethodStoreWorkerNodeInformation
(ctx context.Context, workerNodeInfo *proto.WorkerNodeInformation)
internal/control_plane/persistence/interface.go:37
↓ 7 callersMethodWaitForQuorumWrite
(ctx context.Context)
internal/control_plane/persistence/redis_persistence.go:74
↓ 7 callersFunctionfile_control_plane_interface_proto_rawDescGZIP
()
api/proto/control_plane_interface.pb.go:590
↓ 6 callersMethodDelete
(key K)
pkg/atomic_map/atomic_map_counter.go:82
↓ 6 callersMethodFind
(key K)
pkg/atomic_map/atomic_map.go:41
↓ 6 callersMethodListDataplanes
()
internal/data_plane/haproxy/manager.go:124
↓ 6 callersMethodSetLeader
(ctx context.Context)
internal/control_plane/persistence/interface.go:43
↓ 6 callersFunctionSplitAddress
(address string)
pkg/grpc_helpers/grpc_helpers.go:97
↓ 6 callersMethodStoreDataPlaneInformation
(ctx context.Context, dataplaneInfo *proto.DataplaneInformation)
internal/control_plane/persistence/interface.go:34
↓ 6 callersFunctionSumResources
(a, b *ResourceMap)
internal/control_plane/placement_policy/resource_map.go:102
↓ 6 callersMethodbecomeFollower
becomeFollower makes cm a follower and resets its state. Expects cm.mu to be locked.
internal/control_plane/leader_election/consensus_module.go:323
↓ 5 callersMethodAddDeployment
(context.Context, *proto.ServiceInfo)
internal/control_plane/core/interface.go:38
↓ 5 callersMethodAtomicAdd
(key K, value int64)
pkg/atomic_map/atomic_map_counter.go:55
↓ 5 callersMethodAtomicLen
Atomic operation
pkg/synchronization/control_plane_sync.go:53
↓ 5 callersMethodDeregisterDataplane
(ctx context.Context, in *DataplaneInfo, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:29
↓ 5 callersMethodDeregisterNode
(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:30
↓ 5 callersFunctionEstablishGRPCConnectionPoll
(addresses []string, dialOptions ...grpc.DialOption)
pkg/grpc_helpers/grpc_helpers.go:122
↓ 5 callersMethodGetByKey
(key string)
internal/control_plane/placement_policy/resource_map.go:64
↓ 5 callersMethodGetDataPlaneInformation
(ctx context.Context)
internal/control_plane/persistence/interface.go:36
↓ 5 callersMethodGetDeployment
(name string)
internal/data_plane/function_metadata/deployment.go:60
↓ 5 callersMethodGetProxyPort
()
internal/control_plane/core/interface.go:47
↓ 5 callersMethodGetServiceInformation
(ctx context.Context)
internal/control_plane/persistence/interface.go:42
↓ 5 callersMethodGetWorkerNodeInformation
(ctx context.Context)
internal/control_plane/persistence/interface.go:39
↓ 5 callersMethodGiveUpNetwork
(config *NetworkConfig)
internal/worker_node/sandbox/firecracker/networking.go:96
↓ 5 callersMethodListServices
(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:23
↓ 5 callersFunctionNewControlPlaneConnection
(addresses []string)
pkg/grpc_helpers/grpc_helpers.go:173
↓ 5 callersFunctionNewMockPersistenceLayer
NewMockPersistenceLayer creates a new mock instance.
mock/mock_persistence/mock_persistence.go:32
↓ 5 callersMethodNodeHeartbeat
(ctx context.Context, in *NodeHeartbeatMessage, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:27
↓ 5 callersMethodOnMetricsReceive
(ctx context.Context, in *AutoscalingMetric, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:22
↓ 5 callersMethodRegisterDataplane
(ctx context.Context, in *DataplaneInfo, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:24
↓ 5 callersMethodRegisterNode
(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:26
↓ 5 callersMethodRestartHAProxy
RestartHAProxy Should be called to commit every action to the running instance of HAProxy
internal/data_plane/haproxy/manager.go:100
↓ 5 callersFunctionScanKeys
(ctx context.Context, client *redis.Client, prefix string)
pkg/redis_helpers/redis_helpers.go:71
↓ 5 callersMethodStartTracingService
()
internal/data_plane/proxy/proxy.go:31
↓ 5 callersMethodStop
Stop stops this CM, cleaning up its state. This method returns quickly, but it may take a bit of time (up to ~election timeout) for all goroutines to
internal/control_plane/leader_election/consensus_module.go:115
↓ 5 callersFunctiongetResult
(load, rootPath)
scripts/plotting/common.py:49
↓ 4 callersMethodAddSandbox
(key string, metadata *Metadata)
internal/worker_node/managers/sandbox_manager.go:60
↓ 4 callersFunctionCreateContainer
(ctx context.Context, client *containerd.Client, image containerd.Image)
internal/worker_node/sandbox/containerd/iface.go:75
↓ 4 callersMethodDeleteWorkerNodeInformation
(ctx context.Context, name string)
internal/control_plane/persistence/interface.go:38
↓ 4 callersMethodDeregisterDataplane
(ctx context.Context, in *proto.DataplaneInfo)
internal/control_plane/control_plane.go:138
↓ 4 callersMethodDeregisterNode
(_ context.Context, in *proto.NodeInfo)
internal/control_plane/control_plane.go:235
↓ 4 callersMethodDeregisterService
(ctx context.Context, in *ServiceInfo, opts ...grpc.CallOption)
api/proto/control_plane_interface_grpc.pb.go:31
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
mock/mock_cp_api/mock_cp_api.go:40
↓ 4 callersMethodEXPECT
EXPECT returns an object that allows the caller to indicate expected use.
mock/mock_core/mock_core.go:223
↓ 4 callersFunctionFetchImage
(ctx context.Context, client *containerd.Client, imageURL string)
internal/worker_node/sandbox/containerd/iface.go:66
↓ 4 callersMethodGetImage
(ctx context.Context, containerdClient *containerd.Client, url string)
internal/worker_node/sandbox/containerd/image_manager.go:43
↓ 4 callersMethodGetKubernetesRoundRobinCounter
()
internal/data_plane/function_metadata/function_metadata.go:145
↓ 4 callersFunctionInt64Ptr
(val int)
internal/data_plane/haproxy/manager.go:207
↓ 4 callersFunctionNewDefaultAutoscalingMetadata
(coldStartSweep bool)
internal/control_plane/autoscaling/autoscaling.go:62
↓ 4 callersFunctionReadWorkedNodeConfiguration
(configPath string)
pkg/config/config.go:166
next →1–100 of 1,276, ranked by callers