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
↓ 1 callersMethodDrainEndpoints
(endpoints []*proto.EndpointInfo)
internal/data_plane/function_metadata/function_metadata.go:234
↓ 1 callersMethodEstablishLeaderElectionMesh
(replicas []string)
internal/control_plane/leader_election/server.go:181
↓ 1 callersMethodExists
(serviceName string)
internal/worker_node/sandbox/firecracker/snapshot_manager.go:44
↓ 1 callersFunctionFillResponseWithBufferedResponse
(rw http.ResponseWriter, response *BufferedResponse)
internal/data_plane/proxy/requests/requests.go:123
↓ 1 callersMethodFindSnapshot
(serviceName string)
internal/worker_node/sandbox/firecracker/snapshot_manager.go:54
↓ 1 callersMethodGenerate
()
internal/worker_node/managers/veth_name_generator.go:37
↓ 1 callersMethodGenerateIPMACPair
()
internal/worker_node/managers/ip_manager.go:90
↓ 1 callersMethodGenerateSingleIP
()
internal/worker_node/managers/ip_manager.go:79
↓ 1 callersMethodGet
(key K)
pkg/atomic_map/atomic_map.go:46
↓ 1 callersMethodGet
(key K)
pkg/synchronization/control_plane_sync.go:92
↓ 1 callersFunctionGetCNIClient
(configFile string)
internal/worker_node/sandbox/containerd/iface.go:57
↓ 1 callersMethodGetCpApiServer
()
internal/data_plane/proxy/proxy.go:33
↓ 1 callersMethodGetCpuCores
()
internal/control_plane/workers/worker_node.go:148
↓ 1 callersMethodGetCpuUsage
()
internal/control_plane/core/interface.go:63
↓ 1 callersMethodGetHAProxyConfig
Node functions
internal/control_plane/control_plane.go:172
↓ 1 callersMethodGetHandler
(path string)
workload/http_workload.go:163
↓ 1 callersFunctionGetHardwareUsage
()
pkg/hardware/hardware.go:63
↓ 1 callersMethodGetIP
()
internal/control_plane/workers/worker_node.go:136
↓ 1 callersMethodGetIdentifier
()
internal/data_plane/function_metadata/function_metadata.go:125
↓ 1 callersMethodGetInflight
()
internal/data_plane/function_metadata/statistics.go:46
↓ 1 callersMethodGetLastHeartBeat
()
internal/control_plane/workers/worker_node.go:91
↓ 1 callersFunctionGetLoadBalancerAddress
(cpApi *api.CpApiServer)
internal/control_plane/registration_server/registration_server.go:185
↓ 1 callersFunctionGetLongLivingConnectionDialOptions
()
pkg/grpc_helpers/grpc_helpers.go:85
↓ 1 callersMethodGetMemory
()
internal/control_plane/workers/worker_node.go:144
↓ 1 callersMethodGetMemoryUsage
()
internal/control_plane/core/interface.go:64
↓ 1 callersMethodGetName
()
internal/control_plane/workers/worker_node.go:87
↓ 1 callersMethodGetNoCheck
(key K)
pkg/synchronization/control_plane_sync.go:97
↓ 1 callersMethodGetOneConfig
()
internal/worker_node/sandbox/firecracker/networking.go:126
↓ 1 callersMethodGetPort
()
internal/control_plane/workers/worker_node.go:140
↓ 1 callersMethodGetProxyServer
(async bool)
internal/data_plane/data_plane.go:159
↓ 1 callersMethodGetQueueDepth
()
internal/data_plane/function_metadata/statistics.go:58
↓ 1 callersMethodGetRequestedCpu
()
api/proto/common.pb.go:318
↓ 1 callersMethodGetRequestedMemory
()
api/proto/common.pb.go:325
↓ 1 callersMethodGetRoundRobinCounter
()
internal/data_plane/function_metadata/function_metadata.go:137
↓ 1 callersMethodGetSandboxParallelism
()
internal/data_plane/function_metadata/function_metadata.go:133
↓ 1 callersMethodGetSuccessfulInvocations
()
internal/data_plane/function_metadata/statistics.go:38
↓ 1 callersFunctionGetUniqueRequestCode
()
internal/data_plane/proxy/requests/requests.go:119
↓ 1 callersMethodIncrementInflight
()
internal/data_plane/function_metadata/statistics.go:50
↓ 1 callersMethodIncrementRequestCountPerInstance
(endpoint *UpstreamEndpoint)
internal/data_plane/function_metadata/function_metadata.go:157
↓ 1 callersMethodIncrementRoundRobinCounter
()
internal/data_plane/function_metadata/function_metadata.go:141
↓ 1 callersFunctionInitializeDataPlaneConnection
(host string, port string)
pkg/grpc_helpers/grpc_helpers.go:229
↓ 1 callersFunctionInitializeWorkerNodeConnection
(host, port string)
pkg/grpc_helpers/grpc_helpers.go:219
↓ 1 callersMethodKnativeScaling
(isScaleFromZero bool)
internal/control_plane/autoscaling/autoscaling.go:110
↓ 1 callersFunctionNewAsyncProxyingService
(cfg config.DataPlaneConfig, cache *common.Deployments, cp proto.CpiInterfaceClient, outputFile string, loadBa
internal/data_plane/proxy/async_proxy_handler.go:76
↓ 1 callersFunctionNewAtomicMapCounter
()
pkg/atomic_map/atomic_map_counter.go:37
↓ 1 callersFunctionNewBackoffDialer
(backoffConfig wait.Backoff)
internal/data_plane/proxy/net/factory.go:97
↓ 1 callersFunctionNewBufferPool
NewBufferPool creates a new BufferPool. This is only safe to use in the context of a httputil.ReverseProxy, as the buffers returned via Put are not cl
internal/data_plane/proxy/net/buffer_pool.go:39
↓ 1 callersFunctionNewColdStartTracingService
(outputFile string)
pkg/tracing/tracing.go:109
↓ 1 callersFunctionNewContainerdRuntime
(cpApi proto.CpiInterfaceClient, config config.WorkerNodeConfig, sandboxManager *managers.SandboxManager)
internal/worker_node/sandbox/containerd/runtime.go:64
↓ 1 callersFunctionNewDataplaneConnection
(IP, APIPort, ProxyPort string)
internal/control_plane/data_plane/data_plane.go:36
↓ 1 callersFunctionNewDeploymentList
()
internal/data_plane/function_metadata/deployment.go:39
↓ 1 callersFunctionNewDpApiServer
(dataPlane *data_plane.Dataplane)
api/data_plane_api_server.go:43
↓ 1 callersFunctionNewDpiInterfaceClient
(cc grpc.ClientConnInterface)
api/proto/data_plane_interface_grpc.pb.go:33
↓ 1 callersFunctionNewElectionState
(cfg config.ControlPlaneConfig, cpiApiServer *api.CpApiServer, cpApiCreationArgs *api.CpApiServerCreationArgum
cmd/master_node/state_management/election_management.go:45
↓ 1 callersFunctionNewEmptyInterfaceClient
()
internal/control_plane/workers/empty_worker/empty_interface_client.go:37
↓ 1 callersFunctionNewEmptyPeristenceLayer
()
internal/control_plane/persistence/empty_persistence.go:33
↓ 1 callersFunctionNewFakeSnapshotRuntime
()
internal/worker_node/sandbox/fake_snapshot/runtime.go:43
↓ 1 callersFunctionNewFirecrackerRuntime
(cpApi proto.CpiInterfaceClient, sandboxManager *managers.SandboxManager, kernelPath string, fileSystemPath s
internal/worker_node/sandbox/firecracker/runtime.go:69
↓ 1 callersFunctionNewFirecrackerSnapshotManager
()
internal/worker_node/sandbox/firecracker/snapshot_manager.go:40
↓ 1 callersFunctionNewKubernetesPolicy
()
internal/control_plane/placement_policy/placement_policy.go:49
↓ 1 callersFunctionNewMockDataPlaneInterface
NewMockDataPlaneInterface creates a new mock instance.
mock/mock_core/mock_core.go:36
↓ 1 callersFunctionNewMockWorkerNodeInterface
NewMockWorkerNodeInterface creates a new mock instance.
mock/mock_core/mock_core.go:216
↓ 1 callersFunctionNewMultiplexer
()
workload/http_workload.go:136
↓ 1 callersFunctionNewNetworkPoolManager
(internalPrefix, externalPrefix string, networkPoolSize int)
internal/worker_node/sandbox/firecracker/networking.go:71
↓ 1 callersFunctionNewProxyingService
(port string, cache *common.Deployments, cp proto.CpiInterfaceClient, outputFile string, loadBalancingPolicy l
internal/data_plane/proxy/sync_proxy_handler.go:61
↓ 1 callersFunctionNewServer
(serverId int32, peerIds []int, ready <-chan interface{})
internal/control_plane/leader_election/server.go:73
↓ 1 callersFunctionNewVETHNameGenerator
()
internal/worker_node/managers/veth_name_generator.go:33
↓ 1 callersFunctionNewWorkerNode
(workerNodeConfiguration core.WorkerNodeConfiguration)
internal/control_plane/workers/worker_node.go:65
↓ 1 callersFunctionNewWorkerNodeApi
(workerNode *worker_node.WorkerNode)
api/worker_node_api_server.go:40
↓ 1 callersFunctionNewWorkerNodeInterfaceClient
(cc grpc.ClientConnInterface)
api/proto/worker_node_interface_grpc.pb.go:31
↓ 1 callersMethodNumber
()
api/proto/common.pb.go:60
↓ 1 callersMethodOnMetricsReceive
(_ context.Context, metric *proto.AutoscalingMetric)
internal/control_plane/control_plane.go:352
↓ 1 callersFunctionParsePlacementPolicy
Parse placement policy
internal/control_plane/helpers.go:136
↓ 1 callersFunctionParseReplicaPorts
(cfg *config.ControlPlaneConfig)
pkg/grpc_helpers/grpc_helpers.go:111
↓ 1 callersMethodPersistBufferedRequest
(ctx context.Context, request *requests.BufferedRequest)
internal/data_plane/proxy/persistence/request_persistence.go:34
↓ 1 callersMethodPersistBufferedResponse
(ctx context.Context, response *requests.BufferedResponse)
internal/data_plane/proxy/persistence/request_persistence.go:35
↓ 1 callersMethodPresent
Not thread safe
pkg/synchronization/control_plane_sync.go:45
↓ 1 callersFunctionReadControlPlaneConfiguration
(configPath string)
pkg/config/config.go:126
↓ 1 callersFunctionReadDataPlaneConfiguration
(configPath string)
pkg/config/config.go:146
↓ 1 callersMethodReconstructState
(ctx context.Context, config config2.ControlPlaneConfig)
api/control_plane_api_server.go:274
↓ 1 callersFunctionRegisterCpiInterfaceServer
(s grpc.ServiceRegistrar, srv CpiInterfaceServer)
api/proto/control_plane_interface_grpc.pb.go:252
↓ 1 callersFunctionRegisterDpiInterfaceServer
(s grpc.ServiceRegistrar, srv DpiInterfaceServer)
api/proto/data_plane_interface_grpc.pb.go:122
↓ 1 callersFunctionRegisterWorkerNodeInterfaceServer
(s grpc.ServiceRegistrar, srv WorkerNodeInterfaceServer)
api/proto/worker_node_interface_grpc.pb.go:94
↓ 1 callersMethodRemove
(key K)
pkg/synchronization/control_plane_sync.go:102
↓ 1 callersMethodRemoveAllEndpoints
()
internal/data_plane/function_metadata/function_metadata.go:245
↓ 1 callersMethodRemoveDataplane
(dataplaneName string)
internal/control_plane/autoscaling/autoscaling.go:94
↓ 1 callersMethodReport
Report reports the state of this CM.
internal/control_plane/leader_election/consensus_module.go:105
↓ 1 callersFunctionRequestFromBufferedRequest
(bufferedRequest *BufferedRequest)
internal/data_plane/proxy/requests/requests.go:98
↓ 1 callersMethodResetTracingService
()
pkg/tracing/tracing.go:102
↓ 1 callersMethodScalingControllerLoop
()
internal/control_plane/scaling_loop.go:72
↓ 1 callersMethodScalingLoop
()
internal/control_plane/autoscaling/controller.go:103
↓ 1 callersMethodScanBufferedRequests
(ctx context.Context)
internal/data_plane/proxy/persistence/request_persistence.go:36
↓ 1 callersMethodScanBufferedResponses
(ctx context.Context)
internal/data_plane/proxy/persistence/request_persistence.go:37
↓ 1 callersFunctionSendReadinessProbe
(url string)
internal/worker_node/managers/readiness_probes.go:60
↓ 1 callersMethodSet
(key K, value V)
pkg/synchronization/control_plane_sync.go:88
↓ 1 callersMethodSetCachedScalingMetric
(metrics *proto.AutoscalingMetric)
internal/control_plane/autoscaling/autoscaling.go:102
↓ 1 callersMethodSetCpApiServer
(client proto.CpiInterfaceClient)
internal/data_plane/proxy/proxy.go:34
↓ 1 callersMethodSetCpuUsage
(uint64)
internal/control_plane/core/interface.go:59
↓ 1 callersMethodSetCurrentControlPlaneLeader
(_ leader_election.AnnounceLeadership)
cmd/master_node/state_management/election_management.go:56
↓ 1 callersMethodSetEndpoints
(newEndpoints []*UpstreamEndpoint)
internal/data_plane/function_metadata/function_metadata.go:324
← previousnext →301–400 of 1,276, ranked by callers