tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
9ded2ff6d9
memgraph/tests/manual
History
Matija Santl a026c4c764 Add test stream clause 
Summary:
Added test stream functionality. When a stream is configured, it will try to
consume messages from a kafka topic and return them back to the user.
For now, the messages aren't transformed, so it just returns the payload string.

Depends on D1466

Next steps are persisting stream metadata and transforming messages in order to
store them in the graph.

Reviewers: teon.banek, mtomic

Reviewed By: teon.banek

Subscribers: pullbot, buda

Differential Revision: https://phabricator.memgraph.io/D1474
2018-07-09 11:00:18 +02:00
..
snapshot_generation Add support for the id function 2018-07-04 22:14:13 +02:00
antlr_parser.cpp youcompleteme config has been added to the repo 2017-02-20 14:17:41 +01:00
antlr_sigsegv.cpp Clean utils folder (namespaces, function names) 2018-04-22 09:44:32 +02:00
antlr_tree_pretty_print.cpp Implement expression code generator 2017-03-08 14:10:16 +01:00
binomial.cpp Clean utils folder (namespaces, function names) 2018-04-22 09:44:32 +02:00
bolt_client.cpp Implement SSL support for servers and clients 2018-06-20 17:56:47 +02:00
card_fraud_generate_snapshot.cpp Clean utils folder (namespaces, function names) 2018-04-22 09:44:32 +02:00
card_fraud_local.cpp Extract io/network into mg-io library 2018-05-30 14:58:41 +02:00
CMakeLists.txt Implement SSL support for servers and clients 2018-06-20 17:56:47 +02:00
distributed_common.hpp Invalidate distributed plan caches 2018-03-13 14:59:51 +01:00
distributed_repl.cpp Two phase commit on cursor destruction 2018-04-03 16:20:00 +02:00
endinan.cpp examples folder has been removed; src/test folder has been removed; the existing tests were moved to tests folder; StacktraceException has been introduced; query_plan_templated has been moved to query folder; hazard pointers have been deleted because they are not used any more 2017-02-18 18:03:48 +01:00
generate_snapshot.cpp Refactor snapshot generators to reduce code duplication 2018-03-22 17:27:45 +01:00
graph_500_generate_snapshot.cpp Distributed BFS 2018-05-15 17:38:51 +02:00
kvstore_console.cpp Initial implementation of telemetry 2018-06-20 14:49:07 +02:00
query_hash.cpp Clean utils folder (namespaces, function names) 2018-04-22 09:44:32 +02:00
query_planner.cpp Add test stream clause 2018-07-09 11:00:18 +02:00
raft_rpc.cpp Replace boost with capnp in RPC 2018-06-04 10:45:12 +02:00
repl.cpp Fix and rename REPL 2018-03-08 10:58:43 +01:00
single_query.cpp Invalidate distributed plan caches 2018-03-13 14:59:51 +01:00
sl_position_and_count.cpp GraphDbAccessor - label+property index cardinalities for exact value and value ranges 2017-07-06 10:22:19 +02:00
ssl_client.cpp Implement SSL support for servers and clients 2018-06-20 17:56:47 +02:00
ssl_server.cpp Implement SSL support for servers and clients 2018-06-20 17:56:47 +02:00
stripped_timing.cpp Add AST cache 2017-06-14 18:59:31 +02:00
test_antlr_sigsegv Added antlr sigsegv test. 2017-08-03 13:06:18 +02:00
xorshift.cpp Clean utils folder (namespaces, function names) 2018-04-22 09:44:32 +02:00