Functions — github.com/ManbangGroup/cantor

hub / github.com/ManbangGroup/cantor / functions

Functions334 in github.com/ManbangGroup/cantor

⨍ Functions 334◇ Types & classes 72

↓ 42 callersMethoderror

()

http/src/main/java/io/cantor/http/RequestMappingRegistry.java:216

↓ 41 callersMethodget

(String name)

http/src/main/java/io/cantor/http/HttpHeaders.java:39

↓ 24 callersMethodtoString

(int radix)

service/src/main/java/io/cantor/service/clients/Parser.java:131

↓ 16 callersMethodcode

()

http/src/main/java/io/cantor/http/HttpStatus.java:13

↓ 15 callersMethodset

(String name, Object value)

http/src/main/java/io/cantor/http/HttpHeaders.java:23

↓ 14 callersMethodadd

(PathNode node)

http/src/main/java/io/cantor/http/RequestMappingRegistry.java:128

↓ 13 callersMethodcomplete

()

http/src/main/java/io/cantor/http/HandlerResponse.java:85

↓ 13 callersMethodput

(String path, AppRequestResponseHandler<AffinityScheduler, Handler

http/src/main/java/io/cantor/http/Applications.java:37

↓ 12 callersMethodbuild

()

sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:36

↓ 12 callersMethoddirectBuffer

()

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:79

↓ 12 callersMethodrelease

()

service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:246

↓ 9 callersMethodchannel

()

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:148

↓ 9 callersMethodclose

()

service/src/main/java/io/cantor/service/clients/storage/Storage.java:13

↓ 7 callersMethodbadRequest

(HandlerRequest request)

http/src/main/java/io/cantor/http/HttpResponses.java:15

↓ 7 callersMethodcheckBusyAndBlock

()

service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:232

↓ 7 callersMethodwriteAndFlush

(Object msg, ChannelPromise promise)

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:312

↓ 6 callersMethodcheckAndInit

()

http/src/main/java/io/cantor/http/HandlerResponse.java:37

↓ 6 callersMethodheapBuffer

()

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:64

↓ 6 callersMethodtype

()

service/src/main/java/io/cantor/service/clients/storage/Storage.java:23

↓ 5 callersMethoddescriptor

()

service/src/main/java/io/cantor/service/clients/storage/Storage.java:25

↓ 5 callersMethodheaders

()

http/src/main/java/io/cantor/http/HandlerRequest.java:76

↓ 5 callersMethodnext

(String segment)

http/src/main/java/io/cantor/http/RequestMappingRegistry.java:132

↓ 5 callersMethodregistry

(@NonNull HttpMethodKey method, @NonNull String path, AppRequestResponseHandler<S, I, O> handler)

http/src/main/java/io/cantor/http/RequestMappingRegistry.java:20

↓ 5 callersMethodsequence

()

sdk/src/main/java/io/cantor/sdk/Sequence.java:40

↓ 5 callersMethodsequenceMusk

()

service/src/main/java/io/cantor/service/schema/VersionedSchema.java:13

↓ 4 callersMethodcompositeHeapBuffer

()

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:104

↓ 4 callersMethoderror

(HandlerRequest request, HttpResponseStatus status)

http/src/main/java/io/cantor/http/HttpResponses.java:39

↓ 4 callersMethodgetAndIncrement

()

sdk/src/main/java/io/cantor/sdk/Range.java:19

↓ 4 callersMethodheaders

()

http/src/main/java/io/cantor/http/HandlerResponse.java:60

↓ 4 callersMethodinternalServerError

(HandlerRequest request)

http/src/main/java/io/cantor/http/HttpResponses.java:27

↓ 4 callersMethodstatus

()

http/src/main/java/io/cantor/http/HandlerResponse.java:55

↓ 4 callersMethodtimestamp

()

sdk/src/main/java/io/cantor/sdk/Sequence.java:36

↓ 4 callersMethoduri

()

http/src/main/java/io/cantor/http/HandlerRequest.java:64

↓ 3 callersMethodavailable

()

service/src/main/java/io/cantor/service/clients/storage/Storage.java:15

↓ 3 callersMethodcategory

()

sdk/src/main/java/io/cantor/sdk/Sequence.java:28

↓ 3 callersMethodcategoryCodeLeft

()

service/src/main/java/io/cantor/service/schema/VersionedSchema.java:17

↓ 3 callersMethodconnect

()

service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:311

↓ 3 callersMethodderegister

()

service/src/main/java/io/cantor/service/clients/storage/Storage.java:21

↓ 3 callersMethoddescriptorLeft

()

service/src/main/java/io/cantor/service/schema/VersionedSchema.java:7

↓ 3 callersMethodepochSeconds

(long millis)

service/src/main/java/io/cantor/service/clients/SnowFlake.java:62

↓ 3 callersMethodgetTable

(String namespace, String tableName)

service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:287

↓ 3 callersMethodheader

(String name, String value)

http/src/main/java/io/cantor/http/HandlerResponse.java:45

↓ 3 callersMethodinstance

()

sdk/src/main/java/io/cantor/sdk/Sequence.java:32

↓ 3 callersMethodinstanceCodeLeft

()

service/src/main/java/io/cantor/service/schema/VersionedSchema.java:21

↓ 3 callersMethodmethod

()

http/src/main/java/io/cantor/http/HandlerRequest.java:72

↓ 3 callersMethodname

()

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:158

↓ 3 callersMethodqueries

()

sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:59

↓ 3 callersMethodscheduleAtFixedRate

(final Runnable command, long initialDelay,

http/src/main/java/io/cantor/http/AffinityScheduler.java:61

↓ 3 callersMethodsplit

(String path)

http/src/main/java/io/cantor/http/RequestMappingRegistry.java:99

↓ 3 callersMethodstream

()

http/src/main/java/io/cantor/http/HandlerRequest.java:80

↓ 3 callersMethodtimestampLeft

()

service/src/main/java/io/cantor/service/schema/VersionedSchema.java:11

↓ 2 callersMethodaccept

Performs this operation on the given arguments. @param t the first input argument @param u the second input argument @param v the third input argumen

http/src/main/java/io/cantor/http/TriConsumer.java:17

↓ 2 callersMethodbody

()

http/src/main/java/io/cantor/http/HandlerRequest.java:96

↓ 2 callersMethodbuilder

()

http/src/main/java/io/cantor/http/Applications.java:17

↓ 2 callersMethodbuilder

()

sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:17

↓ 2 callersMethodcategoryMusk

()

service/src/main/java/io/cantor/service/schema/VersionedSchema.java:15

↓ 2 callersMethodcomplete

(Callback<V> callback, V result)

http/src/main/java/io/cantor/http/Callbacks.java:9

↓ 2 callersMethodcompositeBuffer

()

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:94

↓ 2 callersMethodcompositeDirectBuffer

()

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:114

↓ 2 callersMethodcontains

(String name)

http/src/main/java/io/cantor/http/HttpHeaders.java:27

↓ 2 callersMethodcontextLoader

()

http/src/main/java/io/cantor/http/Threads.java:26

↓ 2 callersMethodconvertToString

(Map<String, Object> data)

service/src/main/java/io/cantor/service/Utils.java:15

↓ 2 callersMethodcreateTableConnections

(int tableCount)

service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:320

↓ 2 callersMethodfail

(Callback<V> callback, Throwable t)

http/src/main/java/io/cantor/http/Callbacks.java:17

↓ 2 callersMethodhandle

(AffinityScheduler scheduler, HandlerRequest handlerRequest, HandlerResponse handlerResponse)

http/src/main/java/io/cantor/http/Application.java:7

↓ 2 callersMethodhandleLoopException

(Throwable t)

http/src/main/java/io/cantor/http/ComputeEventLoop.java:46

↓ 2 callersMethodinstanceMusk

()

service/src/main/java/io/cantor/service/schema/VersionedSchema.java:19

↓ 2 callersMethodio

(final Runnable command)

http/src/main/java/io/cantor/http/AffinityScheduler.java:35

↓ 2 callersMethodisWildcard

(String segment)

http/src/main/java/io/cantor/http/RequestMappingRegistry.java:95

↓ 2 callersMethodjson

()

http/src/main/java/io/cantor/http/Codecs.java:17

↓ 2 callersMethodlocalTimestamp

()

service/src/main/java/io/cantor/service/clients/TimeWatcher.java:115

↓ 2 callersMethodnext

()

service/src/main/java/io/cantor/service/rest/IdGenerator.java:249

↓ 2 callersMethodok

()

http/src/main/java/io/cantor/http/HandlerResponse.java:97

↓ 2 callersMethodparseFromNormal

(String id)

service/src/main/java/io/cantor/service/clients/Parser.java:42

↓ 2 callersMethodpath

()

http/src/main/java/io/cantor/http/RequestMappingRegistry.java:120

↓ 2 callersMethodpeek

()

sdk/src/main/java/io/cantor/sdk/Range.java:14

↓ 2 callersMethodpipeline

()

http/src/main/java/io/cantor/http/HttpServer.java:64

↓ 2 callersMethodproduce

(long category)

sdk/src/main/java/io/cantor/sdk/SequenceProducer.java:94

↓ 2 callersMethodserialize

(long category, long desc, long ts, long seq, long instanceId)

service/src/main/java/io/cantor/service/clients/Parser.java:28

↓ 2 callersMethodsignalFeeding

()

sdk/src/main/java/io/cantor/sdk/SequenceProducer.java:171

↓ 2 callersMethodstart

()

service/src/main/java/io/cantor/service/clients/TimeWatcher.java:64

↓ 2 callersMethodtimeout

(Long timeout)

sdk/src/main/java/io/cantor/sdk/RequestBuilder.java:31

↓ 2 callersMethodvalidSequence

(long seq)

service/src/main/java/io/cantor/service/clients/Parser.java:73

↓ 2 callersMethodverify

(Class<T> clazz)

http/src/main/java/io/cantor/http/Threads.java:18

↓ 2 callersMethodversion

()

http/src/main/java/io/cantor/http/HandlerRequest.java:68

↓ 2 callersMethodwith

(AppRequestResponseHandler serverHandler)

http/src/main/java/io/cantor/http/RequestMappingRegistry.java:195

↓ 1 callersMethodaddToMap

(WatchedThread thread)

http/src/main/java/io/cantor/http/WatchedThreadFactory.java:41

↓ 1 callersMethodassign

()

http/src/main/java/io/cantor/http/TrafficDispatcher.java:46

↓ 1 callersMethodavailable

()

service/src/main/java/io/cantor/service/clients/storage/RedisStorage.java:105

↓ 1 callersMethodbind

(@NonNull String host, int port, Callback<Channel> callback)

http/src/main/java/io/cantor/http/HttpServer.java:40

↓ 1 callersMethodbuild

()

http/src/main/java/io/cantor/http/Applications.java:61

↓ 1 callersMethodcalculateNewCapacity

(int minNewCapacity, int maxCapacity)

http/src/main/java/io/cantor/http/PooledDirectByteBufAllocator.java:129

↓ 1 callersMethodcall

(RequestBuilder.SequenceRequest sequenceRequest)

sdk/src/main/java/io/cantor/sdk/ServiceCaller.java:42

↓ 1 callersMethodcheckAndRegister

To check and register in the instance box of storage. If register successfully, it returns an {@link Integer} value as 1. If it's failed, it returns t

service/src/main/java/io/cantor/service/clients/storage/Storage.java:33

↓ 1 callersMethodcheckConn

()

service/src/main/java/io/cantor/service/clients/storage/HBaseStorage.java:293

↓ 1 callersMethodcheckMissingParams

(Map<String, String> queries, int mode)

service/src/main/java/io/cantor/service/rest/IdParser.java:74

↓ 1 callersMethodcodec

(ChannelPipeline pipeline)

http/src/main/java/io/cantor/http/HttpServer.java:125

↓ 1 callersMethodcompute

(final Runnable command)

http/src/main/java/io/cantor/http/AffinityScheduler.java:44

↓ 1 callersMethodcurrent

()

http/src/main/java/io/cantor/http/Threads.java:9

↓ 1 callersMethodcurrentAvailableTimestamp

Return the availableTimestamp updated according to the time lattice in the storage if the {@link TimeWatcher} works well. Or it returns the local time

service/src/main/java/io/cantor/service/clients/TimeWatcher.java:104

next →1–100 of 334, ranked by callers