MCPcopy Create free account

hub / github.com/coding-parrot/Low-Level-Design / functions

Functions178 in github.com/coding-parrot/Low-Level-Design

⨍ Functions 178◇ Types & classes 42
↓ 141 callersMethodget
(KEY key)
distributed-cache/src/main/java/Cache.java:62
↓ 48 callersMethodgetEventQueue
()
distributed-cache/src/main/java/Cache.java:167
↓ 34 callersMethodpublish
(final String topic, final Event event)
distributed-event-bus/src/main/java/EventBus.java:47
↓ 32 callersMethodgetCurrentTime
()
distributed-event-bus/src/test/java/TestTimer.java:10
↓ 31 callersMethodnewRequest
(String s)
service-orchestrator/src/test/java/RouterTester.java:133
↓ 27 callersMethodpoll
(final String topic, final String subscriber)
distributed-event-bus/src/main/java/EventBus.java:111
↓ 21 callersMethodgetAssignedNode
(Request request)
service-orchestrator/src/main/java/algorithms/ConsistentHashing.java:48
↓ 18 callersMethodconstructEvent
(EventType priority, String description)
distributed-event-bus/src/test/java/EventBusTest.java:40
↓ 17 callersMethodgetDescription
()
distributed-event-bus/src/main/java/models/Event.java:40
↓ 17 callersMethodtoString
()
distributed-cache/src/main/java/events/Event.java:30
↓ 16 callersMethodaddRequest
(final Request request)
rate-limiter/src/main/java/TimerWheel.java:54
↓ 15 callersMethodgetHandler
(Request request)
service-orchestrator/src/main/java/LoadBalancer.java:30
↓ 12 callersMethodgetCurrentTime
()
distributed-cache/src/main/java/models/Timer.java:4
↓ 12 callersMethodgetKey
()
distributed-cache/src/main/java/models/Record.java:16
↓ 11 callersMethodbuild
()
distributed-cache/src/main/java/CacheBuilder.java:69
↓ 11 callersMethodgetEventType
()
distributed-event-bus/src/main/java/models/Event.java:32
↓ 11 callersMethodnewNode
(String s)
service-orchestrator/src/test/java/RouterTester.java:137
↓ 10 callersMethoddataSource
(final DataSource<KEY, VALUE> dataSource)
distributed-cache/src/main/java/CacheBuilder.java:54
↓ 10 callersMethodgetAssignedNode
(Request request)
service-orchestrator/src/main/java/algorithms/WeightedRoundRobin.java:35
↓ 10 callersMethodgetElement
()
distributed-cache/src/main/java/events/Event.java:22
↓ 10 callersMethodset
(KEY key, VALUE value)
distributed-cache/src/main/java/Cache.java:66
↓ 9 callersMethodsubscribeForPull
(final String topic, final String subscriber, final Predicate<Event> precondition)
distributed-event-bus/src/main/java/EventBus.java:186
↓ 9 callersMethodsubscribeToEventsAfter
(final String topic, final String subscriber, final long timeStamp)
distributed-event-bus/src/main/java/EventBus.java:130
↓ 8 callersMethodaddNode
(Node node)
service-orchestrator/src/main/java/algorithms/ConsistentHashing.java:31
↓ 8 callersMethodgetId
()
distributed-event-bus/src/main/java/models/Event.java:24
↓ 8 callersMethodgetThreadFor
(KEY key, Runnable task)
distributed-event-bus/src/main/java/lib/KeyedExecutor.java:20
↓ 8 callersMethodgetType
()
distributed-cache/src/main/java/events/Eviction.java:13
↓ 8 callersMethodgetValue
()
distributed-cache/src/main/java/models/Record.java:20
↓ 7 callersMethodgetAccessDetails
()
distributed-cache/src/main/java/models/Record.java:28
↓ 7 callersMethodgetInsertionTime
()
distributed-cache/src/main/java/models/Record.java:24
↓ 7 callersMethodsubscribeForPush
(final String topic, final String subscriber,
distributed-event-bus/src/main/java/EventBus.java:157
↓ 6 callersMethodaddNode
(String serviceId, Node node)
service-orchestrator/src/main/java/LoadBalancer.java:21
↓ 6 callersMethodsetTime
(long time)
distributed-cache/src/test/java/models/SettableTimer.java:11
↓ 5 callersMethodequals
(Object o)
distributed-cache/src/main/java/models/AccessDetails.java:29
↓ 5 callersMethodgetAccessCount
()
distributed-cache/src/main/java/models/AccessDetails.java:19
↓ 5 callersMethodgetId
()
service-orchestrator/src/main/java/models/Node.java:20
↓ 5 callersMethodsetCurrentIndex
(final int offset)
distributed-event-bus/src/main/java/models/Subscription.java:49
↓ 4 callersMethodaddNode
(Node node)
service-orchestrator/src/main/java/algorithms/WeightedRoundRobin.java:21
↓ 4 callersMethodaddToCache
(final KEY key, final CompletionStage<VALUE> valueFuture)
distributed-cache/src/main/java/Cache.java:116
↓ 4 callersMethodfetchAlgorithm
(final FetchAlgorithm fetchAlgorithm)
distributed-cache/src/main/java/CacheBuilder.java:49
↓ 4 callersMethodhashCode
()
distributed-cache/src/main/java/models/AccessDetails.java:38
↓ 4 callersMethodisEqualTo
(CompletionStage<String> future, String value)
distributed-cache/src/test/java/TestCache.java:357
↓ 4 callersMethodmaximumSize
(final int maximumSize)
distributed-cache/src/main/java/CacheBuilder.java:29
↓ 4 callersMethodunsubscribe
(final String topic, final String subscriber)
distributed-event-bus/src/main/java/EventBus.java:194
↓ 3 callersMethodacceptWrite
()
distributed-cache/src/test/java/TestCache.java:70
↓ 3 callersMethodexpiryTime
(final Duration expiryTime)
distributed-cache/src/main/java/CacheBuilder.java:34
↓ 3 callersMethodgetCreationTime
()
distributed-event-bus/src/main/java/models/Event.java:36
↓ 3 callersMethodgetRouter
()
service-orchestrator/src/main/java/models/Service.java:16
↓ 3 callersMethodgetThreadFor
(KEY key, CompletionStage<U> task)
distributed-cache/src/main/java/Cache.java:58
↓ 3 callersMethodhasExpired
(final Record<KEY, VALUE> record)
distributed-cache/src/main/java/Cache.java:159
↓ 3 callersMethodloadFromDB
(final DataSource<KEY, VALUE> dataSource, KEY key)
distributed-cache/src/main/java/Cache.java:171
↓ 3 callersMethodregister
(Service service)
service-orchestrator/src/main/java/LoadBalancer.java:17
↓ 3 callersMethodtimer
(final Timer timer)
distributed-cache/src/main/java/CacheBuilder.java:59
↓ 2 callersMethodaddSubscriber
(final Map<String, Map<String, Subscription>> pullSubscriptions, final String s
distributed-event-bus/src/main/java/EventBus.java:174
↓ 2 callersMethodevict
(final String requestId)
rate-limiter/src/main/java/TimerWheel.java:65
↓ 2 callersMethodevictionAlgorithm
(final EvictionAlgorithm evictionAlgorithm)
distributed-cache/src/main/java/CacheBuilder.java:44
↓ 2 callersMethodgetCurrentSlot
()
rate-limiter/src/main/java/TimerWheel.java:73
↓ 2 callersMethodgetCurrentTime
()
distributed-event-bus/src/main/java/util/Timer.java:7
↓ 2 callersMethodgetCurrentTime
(final TimeUnit timeUnit)
rate-limiter/src/main/java/utils/Timer.java:6
↓ 2 callersMethodgetCurrentTimeInMillis
()
rate-limiter/src/main/java/utils/Timer.java:10
↓ 2 callersMethodgetLastAccessTime
()
distributed-cache/src/main/java/models/AccessDetails.java:15
↓ 2 callersMethodgetPrecondition
()
distributed-event-bus/src/main/java/models/Subscription.java:37
↓ 2 callersMethodgetRequestId
()
rate-limiter/src/main/java/models/Request.java:14
↓ 2 callersMethodgetTopic
()
distributed-event-bus/src/main/java/models/Subscription.java:29
↓ 2 callersMethodgetWeight
()
service-orchestrator/src/main/java/models/Node.java:24
↓ 2 callersMethodremoveNode
(Node node)
service-orchestrator/src/main/java/algorithms/ConsistentHashing.java:42
↓ 2 callersMethodsetCurrentTime
(final long currentTime)
distributed-event-bus/src/test/java/TestTimer.java:15
↓ 2 callersMethodtick
(TimeUnit timeUnit, TestTimer timer, TimerWheel timerWheel)
rate-limiter/src/test/java/RateLimitTest.java:70
↓ 1 callersMethodaddNode
(Node node)
service-orchestrator/src/main/java/algorithms/Router.java:7
↓ 1 callersMethoddoWithRetry
(final Event event, final Function<Event, CompletionStage<Void>>
distributed-event-bus/src/main/java/EventBus.java:89
↓ 1 callersMethodexecuteEventHandler
(final Event event, Subscription subscription)
distributed-event-bus/src/main/java/EventBus.java:77
↓ 1 callersMethodflushRequests
()
rate-limiter/src/main/java/TimerWheel.java:42
↓ 1 callersMethodgetAssignedNode
(Request request)
service-orchestrator/src/main/java/algorithms/Router.java:11
↓ 1 callersMethodgetCurrentIndex
()
distributed-event-bus/src/main/java/models/Subscription.java:45
↓ 1 callersMethodgetCurrentTimeInMillis
()
rate-limiter/src/test/java/TestTimer.java:6
↓ 1 callersMethodgetEvent
()
distributed-event-bus/src/main/java/models/FailureEvent.java:13
↓ 1 callersMethodgetEventHandler
()
distributed-event-bus/src/main/java/models/Subscription.java:41
↓ 1 callersMethodgetFromCache
(KEY key)
distributed-cache/src/main/java/Cache.java:70
↓ 1 callersMethodgetNumberOfRetries
()
distributed-event-bus/src/main/java/models/Subscription.java:54
↓ 1 callersMethodgetPublisher
()
distributed-event-bus/src/main/java/models/Event.java:28
↓ 1 callersMethodgetServiceId
()
service-orchestrator/src/main/java/models/Request.java:19
↓ 1 callersMethodgetStartTime
()
rate-limiter/src/main/java/models/Request.java:18
↓ 1 callersMethodgetSubscriber
()
distributed-event-bus/src/main/java/models/Subscription.java:33
↓ 1 callersMethodgetThrowable
()
distributed-event-bus/src/main/java/models/FailureEvent.java:17
↓ 1 callersMethodhashCode
()
service-orchestrator/src/main/java/models/Node.java:40
↓ 1 callersMethodload
(KEY key)
distributed-cache/src/main/java/DataSource.java:5
↓ 1 callersMethodloadKeysOnStart
(final Set<KEY> keys)
distributed-cache/src/main/java/CacheBuilder.java:39
↓ 1 callersMethodmanageEntries
()
distributed-cache/src/main/java/Cache.java:130
↓ 1 callersMethodmoveIndexAfterEvent
(final String topic, final String subscriber, final String eventId)
distributed-event-bus/src/main/java/EventBus.java:148
↓ 1 callersMethodmoveIndexAtTimestamp
(final String topic, final String subscriber, final long timeStamp)
distributed-event-bus/src/main/java/EventBus.java:134
↓ 1 callersMethodnotifyPushSubscribers
(String topic, Event event)
distributed-event-bus/src/main/java/EventBus.java:64
↓ 1 callersMethodpersist
(KEY key, VALUE value, long timestamp)
distributed-cache/src/main/java/DataSource.java:7
↓ 1 callersMethodpersistRecord
(final Record<KEY, VALUE> record)
distributed-cache/src/main/java/Cache.java:154
↓ 1 callersMethodpollBus
(final String topic, final String subscriber)
distributed-event-bus/src/main/java/EventBus.java:115
↓ 1 callersMethodpoolSize
(final int poolSize)
distributed-cache/src/main/java/CacheBuilder.java:64
↓ 1 callersMethodpublishToBus
(final String topic, final Event event)
distributed-event-bus/src/main/java/EventBus.java:51
↓ 1 callersMethodremoveNode
(String serviceId, String nodeId)
service-orchestrator/src/main/java/LoadBalancer.java:26
↓ 1 callersMethodremoveNode
(Node node)
service-orchestrator/src/main/java/algorithms/WeightedRoundRobin.java:27
↓ 1 callersMethodremoveNode
(Node node)
service-orchestrator/src/main/java/algorithms/Router.java:9
↓ 1 callersMethodsetAccessDetails
(final AccessDetails accessDetails)
distributed-cache/src/main/java/models/Record.java:32
next →1–100 of 178, ranked by callers