Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/ManbangGroup/cantor
/ functions
Functions
334 in github.com/ManbangGroup/cantor
⨍
Functions
334
◇
Types & classes
72
Method
SnowFlake
(long category, long instanceId, long desc)
service/src/main/java/io/cantor/service/clients/SnowFlake.java:15
Method
ThreadPattern
(boolean io)
http/src/main/java/io/cantor/http/ThreadPattern.java:14
Method
TimeWatcher
(Config config, List<Storage> storages, String localId, Map<String, Integer> instancesB
service/src/main/java/io/cantor/service/clients/TimeWatcher.java:41
Method
TrafficDispatcher
()
http/src/main/java/io/cantor/http/TrafficDispatcher.java:19
Method
TypeRef
()
http/src/main/java/io/cantor/http/TypeRef.java:12
Method
WatchedThread
(@NonNull ThreadGroup threadGroup, @NonNull Runnable target, @NonNull WatchedThreadFactory factory)
http/src/main/java/io/cantor/http/WatchedThread.java:23
Method
WatchedThreadFactory
(@NonNull String name, @NonNull ThreadPattern pattern, long maxDuration)
http/src/main/java/io/cantor/http/WatchedThreadFactory.java:34
Method
WildcardNode
(String placeholder)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:151
Method
alloc
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:327
Method
attr
(AttributeKey<T> key)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:357
Method
available
()
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:152
Method
badRequest
()
http/src/main/java/io/cantor/http/HandlerResponse.java:105
Method
bind
(SocketAddress localAddress)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:228
Method
buffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:34
Method
buffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:367
Method
calculateNewCapacity
(int minNewCapacity, int maxCapacity)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:463
Method
catcher
(Consumer<Throwable> catcher)
http/src/main/java/io/cantor/http/HandlerResponse.java:76
Method
category
(long category)
sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:21
Method
categoryCodeLeft
()
service/src/main/java/io/cantor/service/schema/Schema.java:86
Method
categoryMusk
()
service/src/main/java/io/cantor/service/schema/Schema.java:81
Method
channelRead
(ChannelHandlerContext ctx, Object msg)
http/src/main/java/io/cantor/http/HttpServerHandler.java:21
Method
channelRead
(ChannelHandlerContext ctx, FullHttpRequest request)
http/src/main/java/io/cantor/http/Server.java:55
Method
checkAndRegister
(int maxInstances)
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:236
Method
checkAndRegister
(int maxInstances)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:179
Method
checkConn
()
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:294
Method
close
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:248
Method
close
()
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:130
Method
close
()
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:95
Method
compareTo
(TypeRef<T> o)
http/src/main/java/io/cantor/http/TypeRef.java:22
Method
compareTo
(@NonNull PathNode o)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:139
Method
compareTo
(@NonNull PathNode o)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:160
Method
completer
(Runnable completer)
http/src/main/java/io/cantor/http/HandlerResponse.java:80
Method
compositeBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:427
Method
compositeDirectBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:447
Method
compositeHeapBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:437
Method
compute4test
(final Runnable command)
http/src/main/java/io/cantor/http/AffinityScheduler.java:49
Method
connect
(SocketAddress remoteAddress)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:233
Method
deregister
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:253
Method
deregister
()
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:211
Method
deregister
()
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:159
Method
descriptor
()
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:231
Method
descriptor
()
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:174
Method
descriptor
()
sdk/src/main/java/io/cantor/sdk/Sequence.java:24
Method
descriptorLeft
()
service/src/main/java/io/cantor/service/schema/Schema.java:51
Method
descriptorMusk
()
service/src/main/java/io/cantor/service/schema/Schema.java:46
Method
destroy
()
service/src/main/java/io/cantor/service/InitialService.java:101
Method
directBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:412
Method
disconnect
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:243
Method
encode
(ChannelHandlerContext ctx, Object msg, List<Object> out)
http/src/main/java/io/cantor/http/BoundHttpResponseEncoder.java:12
Method
exceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
http/src/main/java/io/cantor/http/HttpServerHandler.java:51
Method
executor
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:153
Method
fireChannelActive
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:186
Method
fireChannelInactive
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:192
Method
fireChannelReadComplete
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:216
Method
fireChannelRegistered
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:173
Method
fireChannelUnregistered
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:179
Method
fireChannelWritabilityChanged
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:222
Method
fireExceptionCaught
(Throwable cause)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:198
Method
fireUserEventTriggered
(Object event)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:204
Method
forbidden
()
http/src/main/java/io/cantor/http/HandlerResponse.java:132
Method
get
(String path, AppRequestResponseHandler<AffinityScheduler, Handler
http/src/main/java/io/cantor/http/Applications.java:43
Method
getAll
(String name)
http/src/main/java/io/cantor/http/HttpHeaders.java:31
Method
getType
()
http/src/main/java/io/cantor/http/TypeRef.java:20
Method
getType
()
http/src/main/java/io/cantor/http/JacksonTypeRefs.java:10
Method
handle
(AffinityScheduler scheduler, HandlerRequest handlerRequest, HandlerResponse handlerResponse)
http/src/main/java/io/cantor/http/Applications.java:71
Method
handle
(S scheduler, I inBound, O outBound)
http/src/main/java/io/cantor/http/AppRequestResponseHandler.java:5
Method
handle
(AffinityScheduler scheduler, HandlerRequest req, HandlerResponse resp)
service/src/main/java/io/cantor/service/rest/IdParser.java:25
Method
handle
(AffinityScheduler scheduler, HandlerRequest req, HandlerResponse resp)
service/src/main/java/io/cantor/service/rest/IdGenerator.java:80
Method
handler
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:163
Method
handlerAdded
(ChannelHandlerContext ctx)
http/src/main/java/io/cantor/http/BoundHttpResponseEncoder.java:18
Method
hasAttr
(AttributeKey<T> attributeKey)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:142
Method
headers
()
sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:55
Method
heapBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:397
Method
incrementAndGet
@return the value before increment
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:107
Method
incrementAndGet
(long category, long ts, long range)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:72
Method
initChannel
(Channel ch)
http/src/main/java/io/cantor/http/HttpServer.java:66
Method
instanceCodeLeft
()
service/src/main/java/io/cantor/service/schema/Schema.java:61
Method
instanceMusk
()
service/src/main/java/io/cantor/service/schema/Schema.java:56
Method
intercept
(Chain chain)
sdk/src/test/java/io/cantor/sdk/MockHttpInterceptor.java:22
Method
internalServerError
()
http/src/main/java/io/cantor/http/HandlerResponse.java:123
Method
io4test
(final Runnable cmd)
http/src/main/java/io/cantor/http/AffinityScheduler.java:40
Method
ioBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:49
Method
ioBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:382
Method
isDirectBufferPooled
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:457
Method
isRemoved
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:168
Method
isTimeout
()
http/src/main/java/io/cantor/http/WatchedThread.java:41
Method
main
(String[] args)
service/src/main/java/io/cantor/service/InitialService.java:34
Method
matcher
()
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:155
Method
maxCategory
()
service/src/main/java/io/cantor/service/schema/Schema.java:101
Method
maxInstanceCount
()
service/src/main/java/io/cantor/service/schema/Schema.java:106
Method
maxSequence
()
service/src/main/java/io/cantor/service/schema/Schema.java:96
Method
maxTimestamp
()
service/src/main/java/io/cantor/service/schema/Schema.java:91
Method
method
(@NonNull String path, @NonNull RequestMappingRegistry.HttpMeth
http/src/main/java/io/cantor/http/Applications.java:30
Method
names
()
http/src/main/java/io/cantor/http/HttpHeaders.java:35
Method
newChild
(Executor executor, Object... args)
http/src/main/java/io/cantor/http/ComputeEventLoopGroup.java:17
Method
newFailedFuture
(Throwable cause)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:347
Method
newProgressivePromise
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:337
Method
newPromise
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:332
Method
newSucceededFuture
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:342
Method
newTaskQueue
(int maxPendingTasks)
http/src/main/java/io/cantor/http/ComputeEventLoop.java:59
← previous
next →
201–300 of 334, ranked by callers