MCPcopy Create free account

hub / github.com/ManbangGroup/cantor / functions

Functions334 in github.com/ManbangGroup/cantor

MethodSnowFlake
(long category, long instanceId, long desc)
service/src/main/java/io/cantor/service/clients/SnowFlake.java:15
MethodThreadPattern
(boolean io)
http/src/main/java/io/cantor/http/ThreadPattern.java:14
MethodTimeWatcher
(Config config, List<Storage> storages, String localId, Map<String, Integer> instancesB
service/src/main/java/io/cantor/service/clients/TimeWatcher.java:41
MethodTrafficDispatcher
()
http/src/main/java/io/cantor/http/TrafficDispatcher.java:19
MethodTypeRef
()
http/src/main/java/io/cantor/http/TypeRef.java:12
MethodWatchedThread
(@NonNull ThreadGroup threadGroup, @NonNull Runnable target, @NonNull WatchedThreadFactory factory)
http/src/main/java/io/cantor/http/WatchedThread.java:23
MethodWatchedThreadFactory
(@NonNull String name, @NonNull ThreadPattern pattern, long maxDuration)
http/src/main/java/io/cantor/http/WatchedThreadFactory.java:34
MethodWildcardNode
(String placeholder)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:151
Methodalloc
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:327
Methodattr
(AttributeKey<T> key)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:357
Methodavailable
()
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:152
MethodbadRequest
()
http/src/main/java/io/cantor/http/HandlerResponse.java:105
Methodbind
(SocketAddress localAddress)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:228
Methodbuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:34
Methodbuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:367
MethodcalculateNewCapacity
(int minNewCapacity, int maxCapacity)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:463
Methodcatcher
(Consumer<Throwable> catcher)
http/src/main/java/io/cantor/http/HandlerResponse.java:76
Methodcategory
(long category)
sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:21
MethodcategoryCodeLeft
()
service/src/main/java/io/cantor/service/schema/Schema.java:86
MethodcategoryMusk
()
service/src/main/java/io/cantor/service/schema/Schema.java:81
MethodchannelRead
(ChannelHandlerContext ctx, Object msg)
http/src/main/java/io/cantor/http/HttpServerHandler.java:21
MethodchannelRead
(ChannelHandlerContext ctx, FullHttpRequest request)
http/src/main/java/io/cantor/http/Server.java:55
MethodcheckAndRegister
(int maxInstances)
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:236
MethodcheckAndRegister
(int maxInstances)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:179
MethodcheckConn
()
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:294
Methodclose
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:248
Methodclose
()
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:130
Methodclose
()
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:95
MethodcompareTo
(TypeRef<T> o)
http/src/main/java/io/cantor/http/TypeRef.java:22
MethodcompareTo
(@NonNull PathNode o)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:139
MethodcompareTo
(@NonNull PathNode o)
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:160
Methodcompleter
(Runnable completer)
http/src/main/java/io/cantor/http/HandlerResponse.java:80
MethodcompositeBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:427
MethodcompositeDirectBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:447
MethodcompositeHeapBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:437
Methodcompute4test
(final Runnable command)
http/src/main/java/io/cantor/http/AffinityScheduler.java:49
Methodconnect
(SocketAddress remoteAddress)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:233
Methodderegister
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:253
Methodderegister
()
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:211
Methodderegister
()
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:159
Methoddescriptor
()
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:231
Methoddescriptor
()
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:174
Methoddescriptor
()
sdk/src/main/java/io/cantor/sdk/Sequence.java:24
MethoddescriptorLeft
()
service/src/main/java/io/cantor/service/schema/Schema.java:51
MethoddescriptorMusk
()
service/src/main/java/io/cantor/service/schema/Schema.java:46
Methoddestroy
()
service/src/main/java/io/cantor/service/InitialService.java:101
MethoddirectBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:412
Methoddisconnect
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:243
Methodencode
(ChannelHandlerContext ctx, Object msg, List<Object> out)
http/src/main/java/io/cantor/http/BoundHttpResponseEncoder.java:12
MethodexceptionCaught
(ChannelHandlerContext ctx, Throwable cause)
http/src/main/java/io/cantor/http/HttpServerHandler.java:51
Methodexecutor
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:153
MethodfireChannelActive
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:186
MethodfireChannelInactive
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:192
MethodfireChannelReadComplete
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:216
MethodfireChannelRegistered
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:173
MethodfireChannelUnregistered
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:179
MethodfireChannelWritabilityChanged
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:222
MethodfireExceptionCaught
(Throwable cause)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:198
MethodfireUserEventTriggered
(Object event)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:204
Methodforbidden
()
http/src/main/java/io/cantor/http/HandlerResponse.java:132
Methodget
(String path, AppRequestResponseHandler<AffinityScheduler, Handler
http/src/main/java/io/cantor/http/Applications.java:43
MethodgetAll
(String name)
http/src/main/java/io/cantor/http/HttpHeaders.java:31
MethodgetType
()
http/src/main/java/io/cantor/http/TypeRef.java:20
MethodgetType
()
http/src/main/java/io/cantor/http/JacksonTypeRefs.java:10
Methodhandle
(AffinityScheduler scheduler, HandlerRequest handlerRequest, HandlerResponse handlerResponse)
http/src/main/java/io/cantor/http/Applications.java:71
Methodhandle
(S scheduler, I inBound, O outBound)
http/src/main/java/io/cantor/http/AppRequestResponseHandler.java:5
Methodhandle
(AffinityScheduler scheduler, HandlerRequest req, HandlerResponse resp)
service/src/main/java/io/cantor/service/rest/IdParser.java:25
Methodhandle
(AffinityScheduler scheduler, HandlerRequest req, HandlerResponse resp)
service/src/main/java/io/cantor/service/rest/IdGenerator.java:80
Methodhandler
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:163
MethodhandlerAdded
(ChannelHandlerContext ctx)
http/src/main/java/io/cantor/http/BoundHttpResponseEncoder.java:18
MethodhasAttr
(AttributeKey<T> attributeKey)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:142
Methodheaders
()
sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:55
MethodheapBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:397
MethodincrementAndGet
@return the value before increment
service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:107
MethodincrementAndGet
(long category, long ts, long range)
service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:72
MethodinitChannel
(Channel ch)
http/src/main/java/io/cantor/http/HttpServer.java:66
MethodinstanceCodeLeft
()
service/src/main/java/io/cantor/service/schema/Schema.java:61
MethodinstanceMusk
()
service/src/main/java/io/cantor/service/schema/Schema.java:56
Methodintercept
(Chain chain)
sdk/src/test/java/io/cantor/sdk/MockHttpInterceptor.java:22
MethodinternalServerError
()
http/src/main/java/io/cantor/http/HandlerResponse.java:123
Methodio4test
(final Runnable cmd)
http/src/main/java/io/cantor/http/AffinityScheduler.java:40
MethodioBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:49
MethodioBuffer
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:382
MethodisDirectBufferPooled
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:457
MethodisRemoved
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:168
MethodisTimeout
()
http/src/main/java/io/cantor/http/WatchedThread.java:41
Methodmain
(String[] args)
service/src/main/java/io/cantor/service/InitialService.java:34
Methodmatcher
()
http/src/main/java/io/cantor/http/RequestMappingRegistry.java:155
MethodmaxCategory
()
service/src/main/java/io/cantor/service/schema/Schema.java:101
MethodmaxInstanceCount
()
service/src/main/java/io/cantor/service/schema/Schema.java:106
MethodmaxSequence
()
service/src/main/java/io/cantor/service/schema/Schema.java:96
MethodmaxTimestamp
()
service/src/main/java/io/cantor/service/schema/Schema.java:91
Methodmethod
(@NonNull String path, @NonNull RequestMappingRegistry.HttpMeth
http/src/main/java/io/cantor/http/Applications.java:30
Methodnames
()
http/src/main/java/io/cantor/http/HttpHeaders.java:35
MethodnewChild
(Executor executor, Object... args)
http/src/main/java/io/cantor/http/ComputeEventLoopGroup.java:17
MethodnewFailedFuture
(Throwable cause)
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:347
MethodnewProgressivePromise
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:337
MethodnewPromise
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:332
MethodnewSucceededFuture
()
http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:342
MethodnewTaskQueue
(int maxPendingTasks)
http/src/main/java/io/cantor/http/ComputeEventLoop.java:59
← previousnext →201–300 of 334, ranked by callers