MCPcopy Create free account

hub / github.com/ManbangGroup/cantor / functions

Functions334 in github.com/ManbangGroup/cantor

⨍ Functions 334◇ Types & classes 72
↓ 1 callersMethoddelegator
()
http/src/main/java/io/cantor/http/HandlerResponse.java:156
↓ 1 callersMethoddelete
(String path, AppRequestResponseHandler<AffinityScheduler, Hand
http/src/main/java/io/cantor/http/Applications.java:55
↓ 1 callersMethoddeleteField
(String key, String field)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:280
↓ 1 callersMethoddescriptorMusk
()
service/src/main/java/io/cantor/service/schema/VersionedSchema.java:5
↓ 1 callersMethoddeserializer
(long id)
service/src/main/java/io/cantor/service/clients/SnowFlake.java:67
↓ 1 callersMethodfeed
()
sdk/src/main/java/io/cantor/sdk/SequenceProducer.java:49
↓ 1 callersMethodfind
(HandlerRequest handlerRequest)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:50
↓ 1 callersMethodfireChannelRead
(Object msg)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:210
↓ 1 callersMethodflush
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:306
↓ 1 callersMethodforbidden
(HandlerRequest request)
http/src/main/java/io/cantor/http/HttpResponses.java:35
↓ 1 callersMethodforceDirectAllocator
(ChannelHandlerContext ctx)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:30
↓ 1 callersMethodforceToNextMillis
()
service/src/main/java/io/cantor/service/clients/SnowFlake.java:54
↓ 1 callersMethodgetField
(String key, String field)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:250
↓ 1 callersMethodgetFromCache
(long category, long ts, long range, Storage storage, long instanceId)
service/src/main/java/io/cantor/service/rest/IdGenerator.java:184
↓ 1 callersMethodgetFromLocal
(long category, long range, long locatorId)
service/src/main/java/io/cantor/service/clients/LocalIdGenerator.java:16
↓ 1 callersMethodgetInstance
(String name, Config config, String localId)
service/src/main/java/io/cantor/service/clients/storage/StorageFactory.java:26
↓ 1 callersMethodgetMaxTime
()
service/src/main/java/io/cantor/service/clients/TimeWatcher.java:159
↓ 1 callersMethodgetSequence
(long category, long ts, long range, long instanceId)
service/src/main/java/io/cantor/service/rest/IdGenerator.java:153
↓ 1 callersMethodhbase
(Config config, String localId)
service/src/main/java/io/cantor/service/clients/storage/StorageFactory.java:40
↓ 1 callersMethodheartbeat
()
service/src/main/java/io/cantor/service/clients/TimeWatcher.java:154
↓ 1 callersMethodheartbeat
(int instanceNumber, int ttl)
service/src/main/java/io/cantor/service/clients/storage/Storage.java:35
↓ 1 callersMethodheartbeat
(int instanceNumber, int ttl)
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:268
↓ 1 callersMethodheartbeat
(int instanceNumber, int ttl)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:206
↓ 1 callersMethodhostname
()
service/src/main/java/io/cantor/service/Utils.java:42
↓ 1 callersMethodincrementAndGet
(long category, long ts, long range)
service/src/main/java/io/cantor/service/clients/storage/Storage.java:11
↓ 1 callersMethodinstanceId
()
service/src/main/java/io/cantor/service/clients/TimeWatcher.java:110
↓ 1 callersMethodisDirectBufferPooled
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:124
↓ 1 callersMethodisValid
(long category, long ts, long seq)
service/src/main/java/io/cantor/service/clients/Parser.java:61
↓ 1 callersMethoditerator
()
http/src/main/java/io/cantor/http/HttpHeaders.java:43
↓ 1 callersMethodmatch
(String segment)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:107
↓ 1 callersMethodmatched
()
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:204
↓ 1 callersMethodmatcher
()
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:124
↓ 1 callersMethodmaxCategory
()
service/src/main/java/io/cantor/service/schema/VersionedSchema.java:27
↓ 1 callersMethodmaxInstanceCount
()
service/src/main/java/io/cantor/service/schema/VersionedSchema.java:29
↓ 1 callersMethodmaxSequence
()
service/src/main/java/io/cantor/service/schema/VersionedSchema.java:25
↓ 1 callersMethodmaxTimestamp
()
service/src/main/java/io/cantor/service/schema/VersionedSchema.java:23
↓ 1 callersMethodmergeURISlash
()
http/src/main/java/io/cantor/http/HandlerRequest.java:116
↓ 1 callersMethodmethodUnmatched
()
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:212
↓ 1 callersMethodnewRequestBuilder
()
sdk/src/main/java/io/cantor/sdk/ServiceCaller.java:104
↓ 1 callersMethodnext
(long category, long range, long locatorId)
service/src/main/java/io/cantor/service/clients/LocalIdGenerator.java:22
↓ 1 callersMethodnext
(long batch)
service/src/main/java/io/cantor/service/clients/SnowFlake.java:21
↓ 1 callersMethodonComplete
Invoked with the result of computation when it is completed.
http/src/main/java/io/cantor/http/Callback.java:11
↓ 1 callersMethodonFailure
Invoked when a computation fails or is canceled.
http/src/main/java/io/cantor/http/Callback.java:16
↓ 1 callersMethodparseFromParts
(long id)
service/src/main/java/io/cantor/service/clients/Parser.java:52
↓ 1 callersMethodparserFromRadix
(String radixId)
service/src/main/java/io/cantor/service/clients/Parser.java:47
↓ 1 callersMethodpath
()
sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:63
↓ 1 callersMethodpathVariables
(String key, String value)
http/src/main/java/io/cantor/http/HandlerRequest.java:84
↓ 1 callersMethodpoll
()
sdk/src/main/java/io/cantor/sdk/SequenceProducer.java:140
↓ 1 callersMethodpost
(String path, AppRequestResponseHandler<AffinityScheduler, Handle
http/src/main/java/io/cantor/http/Applications.java:49
↓ 1 callersMethodrange
(long range)
sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:26
↓ 1 callersMethodredis
(Config config, String localId)
service/src/main/java/io/cantor/service/clients/storage/StorageFactory.java:54
↓ 1 callersMethodrun
()
http/src/main/java/io/cantor/http/ComputeEventLoop.java:24
↓ 1 callersMethodschedule
(final Runnable command, long delay, TimeUnit unit)
http/src/main/java/io/cantor/http/AffinityScheduler.java:53
↓ 1 callersMethodsequenceRange
()
sdk/src/main/java/io/cantor/sdk/ServiceCaller.java:115
↓ 1 callersMethodserialize
()
service/src/main/java/io/cantor/service/clients/Parser.java:119
↓ 1 callersMethodserverBootstrap
(EventLoopGroup acceptors, EventLoopGroup workers)
http/src/main/java/io/cantor/http/Bootstraps.java:16
↓ 1 callersMethodsetField
(String key, String field, String value)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:267
↓ 1 callersMethodsleepDream
()
http/src/main/java/io/cantor/http/ComputeEventLoop.java:20
↓ 1 callersMethodstartup
(int port)
http/src/main/java/io/cantor/http/Server.java:30
↓ 1 callersMethodstop
()
service/src/main/java/io/cantor/service/clients/TimeWatcher.java:80
↓ 1 callersMethodstopWatch
()
http/src/main/java/io/cantor/http/WatchedThread.java:35
↓ 1 callersMethodsupportedStorage
()
service/src/main/java/io/cantor/service/clients/storage/StorageFactory.java:22
↓ 1 callersMethodsyncTime
(long localTime)
service/src/main/java/io/cantor/service/clients/storage/Storage.java:17
↓ 1 callersMethodtimeMeta
()
service/src/main/java/io/cantor/service/clients/storage/Storage.java:19
↓ 1 callersMethodtimestampMusk
()
service/src/main/java/io/cantor/service/schema/VersionedSchema.java:9
↓ 1 callersMethodtoBigInteger
()
service/src/main/java/io/cantor/service/clients/Parser.java:127
↓ 1 callersMethodtouch
(Long timeout)
sdk/src/main/java/io/cantor/sdk/SequenceProducer.java:118
↓ 1 callersMethodtypeRef
(TypeRef<T> typeRef)
http/src/main/java/io/cantor/http/JacksonTypeRefs.java:8
↓ 1 callersMethodvalidCategory
(long category)
service/src/main/java/io/cantor/service/clients/Parser.java:69
↓ 1 callersMethodvalidTimestamp
(long timestamp)
service/src/main/java/io/cantor/service/clients/Parser.java:65
↓ 1 callersMethodversionedSchema
(long version)
service/src/main/java/io/cantor/service/schema/Schema.java:11
↓ 1 callersMethodwatch
()
service/src/main/java/io/cantor/service/clients/TimeWatcher.java:119
↓ 1 callersMethodwrite
(byte[] bytes)
http/src/main/java/io/cantor/http/HandlerResponse.java:65
MethodAffinityScheduler
(ClassLoader contextLoader, EventLoop acceptor, Ev
http/src/main/java/io/cantor/http/AffinityScheduler.java:24
MethodCacheSequence
(long seq, long seqLimit, long step)
service/src/main/java/io/cantor/service/rest/IdGenerator.java:243
MethodComputeEventLoop
(EventLoopGroup parent, Executor executor, int maxPendingTasks)
http/src/main/java/io/cantor/http/ComputeEventLoop.java:16
MethodComputeEventLoopGroup
(int nThreads, ThreadFactory threadFactory, int maxPendingTasks)
http/src/main/java/io/cantor/http/ComputeEventLoopGroup.java:13
MethodDeserializer
(long id)
service/src/main/java/io/cantor/service/clients/Parser.java:88
MethodDeserializer
(long id)
sdk/src/main/java/io/cantor/sdk/Deserializer.java:52
MethodHBaseStorage
(Config config, String localId)
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:68
MethodHandlerRequest
(FullHttpRequest request, Channel channel)
http/src/main/java/io/cantor/http/HandlerRequest.java:39
MethodHandlerResponse
(HandlerRequest request, AffinityScheduler scheduler, TriConsumer<Full
http/src/main/java/io/cantor/http/HandlerResponse.java:29
MethodHttpHeaders
(io.netty.handler.codec.http.HttpHeaders headers)
http/src/main/java/io/cantor/http/HttpHeaders.java:19
MethodHttpServer
(@NonNull EventLoopGroup acceptors, @NonNull EventLoopGroup workers,
http/src/main/java/io/cantor/http/HttpServer.java:31
MethodHttpStatus
(FullHttpResponse delegator)
http/src/main/java/io/cantor/http/HttpStatus.java:9
MethodIdGenerator
(List<Storage> storages, TimeWatcher timeWatcher)
service/src/main/java/io/cantor/service/rest/IdGenerator.java:66
MethodInitialService
()
service/src/main/java/io/cantor/service/InitialService.java:39
MethodNetServerListener
(Channel ch, Callback<Channel> callback, ChannelGroup chgp
http/src/main/java/io/cantor/http/HttpServer.java:86
MethodPathNode
(String path)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:116
MethodPooledChannelHandlerContext
(ChannelHandlerContext ctx)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:138
MethodQueueHolder
(long category)
sdk/src/main/java/io/cantor/sdk/SequenceProducer.java:114
MethodRange
(long id, long range)
sdk/src/main/java/io/cantor/sdk/Range.java:9
MethodRedisStorage
(Config config, String localId)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:48
MethodSequence
(long id)
sdk/src/main/java/io/cantor/sdk/Sequence.java:15
MethodSequenceException
(String message)
sdk/src/main/java/io/cantor/sdk/SequenceException.java:4
MethodSequenceProducer
(String host, int port, long range)
sdk/src/main/java/io/cantor/sdk/SequenceProducer.java:39
MethodSequenceRequest
(long category, long range, Long timeout)
sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:47
MethodServer
(@NonNull Application application)
http/src/main/java/io/cantor/http/Server.java:24
MethodServiceCaller
(String host, int port)
sdk/src/main/java/io/cantor/sdk/ServiceCaller.java:32
MethodSimpleApplicationBuilder
()
http/src/main/java/io/cantor/http/Applications.java:23
← previousnext →101–200 of 334, ranked by callers