| /dports/databases/opentsdb/opentsdb-2.3.0/test/tsd/ |
| H A D | NettyMocks.java | 53 final TSDB tsdb = mock(TSDB.class); in getMockedHTTPTSDB() local
89 public static HttpQuery getQuery(final TSDB tsdb, final String uri) { in getQuery()
105 public static HttpQuery postQuery(final TSDB tsdb, final String uri, in postQuery()
120 public static HttpQuery postQuery(final TSDB tsdb, final String uri, in postQuery()
134 public static HttpQuery putQuery(final TSDB tsdb, final String uri, in putQuery()
149 public static HttpQuery putQuery(final TSDB tsdb, final String uri, in putQuery()
163 public static HttpQuery deleteQuery(final TSDB tsdb, final String uri, in deleteQuery()
178 public static HttpQuery deleteQuery(final TSDB tsdb, final String uri, in deleteQuery()
193 public static HttpQuery contentQuery(final TSDB tsdb, final String uri, in contentQuery()
|
| H A D | TestRpcManager.java | 55 TSDB tsdb = mock(TSDB.class); in before() local
81 TSDB tsdb = mock(TSDB.class); in loadHttpRpcPlugins() local
111 TSDB tsdb = mock(TSDB.class); in loadRpcPlugin() local
|
| H A D | DummyHttpRpcPlugin.java | 29 public void initialize(TSDB tsdb) { in initialize()
54 public void execute(TSDB tsdb, HttpRpcPluginQuery query) throws IOException { in execute()
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/tsd/ |
| H A D | RpcManager.java | 112 private TSDB tsdb; field in RpcManager
118 private RpcManager(final TSDB tsdb) { in RpcManager()
128 public static synchronized RpcManager instance(final TSDB tsdb) { in instance()
498 public Deferred<Object> execute(final TSDB tsdb, final Channel chan, in execute()
505 public void execute(final TSDB tsdb, final HttpQuery query) { in execute()
543 public Deferred<Object> execute(final TSDB tsdb, final Channel chan, in execute()
552 public Deferred<Object> execute(final TSDB tsdb, final Channel chan, in execute()
568 public void execute(final TSDB tsdb, final HttpQuery query) in execute()
585 public void execute(final TSDB tsdb, final HttpQuery query) in execute()
611 public void execute(final TSDB tsdb, final HttpQuery query) throws in execute()
[all …]
|
| H A D | DropCachesRpc.java | 58 public Deferred<Object> execute(final TSDB tsdb, final Channel chan, in execute()
65 public void execute(final TSDB tsdb, final HttpQuery query) in execute()
84 private void dropCaches(final TSDB tsdb, final Channel chan) { in dropCaches()
|
| H A D | PipelineFactory.java | 59 private final TSDB tsdb; field in PipelineFactory
72 public PipelineFactory(final TSDB tsdb) { in PipelineFactory()
85 public PipelineFactory(final TSDB tsdb, final RpcManager manager) { in PipelineFactory()
101 public PipelineFactory(final TSDB tsdb, final RpcManager manager, in PipelineFactory()
|
| H A D | TreeRpc.java | 54 public void execute(TSDB tsdb, HttpQuery query) throws IOException { in execute()
92 private void handleTree(TSDB tsdb, HttpQuery query) { in handleTree()
210 private void handleBranch(TSDB tsdb, HttpQuery query) { in handleBranch()
261 private void handleRule(TSDB tsdb, HttpQuery query) { in handleRule()
339 private void handleRules(TSDB tsdb, HttpQuery query) { in handleRules()
411 private void handleTest(TSDB tsdb, HttpQuery query) { in handleTest()
516 private void handleCollisionNotMatched(TSDB tsdb, HttpQuery query, final boolean for_collisions) { in handleCollisionNotMatched()
|
| H A D | RpcHandler.java | 67 private final TSDB tsdb; field in RpcHandler
77 public RpcHandler(final TSDB tsdb) { in RpcHandler()
89 public RpcHandler(final TSDB tsdb, final RpcManager manager) { in RpcHandler()
175 private AbstractHttpQuery createQueryInstance(final TSDB tsdb, in createQueryInstance()
251 private void handleHttpQuery(final TSDB tsdb, final Channel chan, final HttpRequest req) { in handleHttpQuery()
366 public Deferred<Object> execute(final TSDB tsdb, final Channel chan, in execute()
|
| H A D | AnnotationRpc.java | 48 public void execute(final TSDB tsdb, HttpQuery query) throws IOException { in execute()
143 void executeBulk(final TSDB tsdb, final HttpMethod method, HttpQuery query) { in executeBulk()
163 void executeBulkUpdate(final TSDB tsdb, final HttpMethod method, HttpQuery query) { in executeBulkUpdate()
250 void executeBulkDelete(final TSDB tsdb, HttpQuery query) { in executeBulkDelete()
345 private void fetchSingleAnnotation(final TSDB tsdb, final Annotation note, in fetchSingleAnnotation()
357 private void fetchMultipleAnnotations(final TSDB tsdb, final Annotation note, in fetchMultipleAnnotations()
|
| H A D | HttpRpcPlugin.java | 54 public abstract void initialize(TSDB tsdb); in initialize()
111 public abstract void execute(TSDB tsdb, HttpRpcPluginQuery query) throws IOException; in execute()
|
| H A D | UniqueIdRpc.java | 51 public void execute(TSDB tsdb, HttpQuery query) throws IOException { in execute()
89 private void handleAssign(final TSDB tsdb, final HttpQuery query) { in handleAssign()
160 private void handleUIDMeta(final TSDB tsdb, final HttpQuery query) { in handleUIDMeta()
259 private void handleTSMeta(final TSDB tsdb, final HttpQuery query) { in handleTSMeta()
493 private void handleRename(final TSDB tsdb, final HttpQuery query) { in handleRename()
627 private String getTSUIDForMetric(final String query_string, TSDB tsdb) { in getTSUIDForMetric()
|
| H A D | QueryExecutor.java | 89 private final TSDB tsdb; field in QueryExecutor
120 public QueryExecutor(final TSDB tsdb, final Query query) { in QueryExecutor()
629 final TSDB tsdb; field in QueryExecutor.SerializeExpressionIterator
647 public SerializeExpressionIterator(final TSDB tsdb, final JsonGenerator json, in SerializeExpressionIterator()
742 final TSDB tsdb; field in QueryExecutor.SerializeSubIterator
750 public SerializeSubIterator(final TSDB tsdb, final JsonGenerator json, in SerializeSubIterator()
837 final TSDB tsdb; field in QueryExecutor.MetaSerializer
847 public MetaSerializer(final TSDB tsdb, final JsonGenerator json, in MetaSerializer()
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/core/ |
| H A D | Tags.java | 335 static String getValue(final TSDB tsdb, final byte[] row, in getValue()
360 static byte[] getValueId(final TSDB tsdb, final byte[] row, in getValueId()
403 static Map<String, String> getTags(final TSDB tsdb, in getTags()
422 static Deferred<Map<String, String>> getTagsAsync(final TSDB tsdb, in getTagsAsync()
475 public static Deferred<Map<String, String>> getTagsAsync(final TSDB tsdb, in getTagsAsync()
567 public static ArrayList<byte[]> resolveAll(final TSDB tsdb, in resolveAll()
602 static ArrayList<byte[]> resolveOrCreateAll(final TSDB tsdb, in resolveOrCreateAll()
608 static ArrayList<byte[]> resolveAllInternal(final TSDB tsdb, in resolveAllInternal()
655 resolveOrCreateAllAsync(final TSDB tsdb, final String metric, in resolveOrCreateAllAsync()
661 resolveAllInternalAsync(final TSDB tsdb, in resolveAllInternalAsync()
[all …]
|
| H A D | RowKey.java | 36 static String metricName(final TSDB tsdb, final byte[] row) { in metricName()
56 public static Deferred<String> metricNameAsync(final TSDB tsdb, in metricNameAsync()
81 public static byte[] rowKeyFromTSUID(final TSDB tsdb, final byte[] tsuid, in rowKeyFromTSUID()
|
| /dports/databases/opentsdb/opentsdb-2.3.0/test/uid/ |
| H A D | TestUniqueId.java | 86 private TSDB tsdb = mock(TSDB.class); field in TestUniqueId
274 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdAssignFilterOK() local
314 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdAssignFilterBlocked() local
343 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdAssignFilterReturnException() local
372 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdAssignFilterThrowsException() local
402 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdAsyncAssignFilterOK() local
441 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdAsyncAssignFilterBlocked() local
468 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdAsyncAssignFilterReturnException() local
495 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdAsyncAssignFilterThrowsException() local
647 final TSDB tsdb = mock(TSDB.class); in getOrCreateIdWithICVFailure() local
[all …]
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/tools/ |
| H A D | Search.java | 70 final TSDB tsdb = new TSDB(config); in main() local
97 private static int runCommand(final TSDB tsdb, in runCommand()
127 private static int lookup(final TSDB tsdb, in lookup()
|
| H A D | CliUtils.java | 102 static long getMaxMetricID(final TSDB tsdb) { in getMaxMetricID()
133 static final Scanner getDataTableScanner(final TSDB tsdb, final long start_id, in getDataTableScanner()
157 static final List<Scanner> getDataTableScanners(final TSDB tsdb, in getDataTableScanners()
|
| H A D | DumpSeries.java | 78 final TSDB tsdb = new TSDB(config); in main() local
91 private static void doDump(final TSDB tsdb, in doDump()
154 final TSDB tsdb, in formatKeyValue()
162 final TSDB tsdb, in formatKeyValue()
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/meta/ |
| H A D | TSMeta.java | 186 public Deferred<Object> delete(final TSDB tsdb) { in delete()
220 public Deferred<Boolean> syncToStorage(final TSDB tsdb, in syncToStorage()
353 public Deferred<Boolean> storeNew(final TSDB tsdb) { in storeNew()
402 public static Deferred<TSMeta> parseFromColumn(final TSDB tsdb, in parseFromColumn()
434 public static Deferred<Boolean> metaExistsInStorage(final TSDB tsdb, in metaExistsInStorage()
470 public static Deferred<Boolean> counterExistsInStorage(final TSDB tsdb, in counterExistsInStorage()
509 public static Deferred<Long> incrementAndGetCounter(final TSDB tsdb, in incrementAndGetCounter()
622 public static Deferred<Boolean> storeIfNecessary(final TSDB tsdb, in storeIfNecessary()
693 private static Deferred<TSMeta> getFromStorage(final TSDB tsdb, in getFromStorage()
883 final private TSDB tsdb; field in TSMeta.LoadUIDs
[all …]
|
| H A D | Annotation.java | 155 public Deferred<Boolean> syncToStorage(final TSDB tsdb, in syncToStorage()
211 public Deferred<Object> delete(final TSDB tsdb) { in delete()
230 public static Deferred<Annotation> getAnnotation(final TSDB tsdb, in getAnnotation()
243 public static Deferred<Annotation> getAnnotation(final TSDB tsdb, in getAnnotation()
259 public static Deferred<Annotation> getAnnotation(final TSDB tsdb, in getAnnotation()
304 public static Deferred<List<Annotation>> getGlobalAnnotations(final TSDB tsdb, in getGlobalAnnotations()
395 public static Deferred<Integer> deleteRange(final TSDB tsdb, in deleteRange()
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/query/expression/ |
| H A D | DiffSeries.java | 28 final TSDB tsdb; field in DiffSeries
34 public DiffSeries(final TSDB tsdb) { in DiffSeries()
|
| H A D | DivideSeries.java | 28 final TSDB tsdb; field in DivideSeries
34 public DivideSeries(final TSDB tsdb) { in DivideSeries()
|
| H A D | MultiplySeries.java | 28 final TSDB tsdb; field in MultiplySeries
34 public MultiplySeries(final TSDB tsdb) { in MultiplySeries()
|
| H A D | SumSeries.java | 27 final TSDB tsdb; field in SumSeries
33 public SumSeries(final TSDB tsdb) { in SumSeries()
|
| /dports/databases/opentsdb/opentsdb-2.3.0/src/tree/ |
| H A D | Tree.java | 311 public Deferred<Boolean> storeTree(final TSDB tsdb, final boolean overwrite) { in storeTree()
406 public Deferred<Integer> createNewTree(final TSDB tsdb) { in createNewTree()
469 public static Deferred<Tree> fetchTree(final TSDB tsdb, final int tree_id) { in fetchTree()
534 public static Deferred<List<Tree>> fetchAllTrees(final TSDB tsdb) { in fetchAllTrees()
633 public static Deferred<Map<String, String>> fetchCollisions(final TSDB tsdb, in fetchCollisions()
717 public static Deferred<Map<String, String>> fetchNotMatched(final TSDB tsdb, in fetchNotMatched()
798 public static Deferred<Boolean> deleteTree(final TSDB tsdb, in deleteTree()
1045 private static Scanner setupAllTreeScanner(final TSDB tsdb) { in setupAllTreeScanner()
1074 public Deferred<Boolean> flushCollisions(final TSDB tsdb) { in flushCollisions()
1132 public Deferred<Boolean> flushNotMatched(final TSDB tsdb) { in flushNotMatched()
|