conduitio-labs / conduit-connector-cassandra Goto Github PK

Feature description

related to #1 (comment)

correction: we can support multiple nodes' hosts with multiple ports, no need to have the same port for all hosts.
we can provide the whole URL in the configs as: 127.0.0.1:9042,127.0.0.1:8080 instead of providing hosts and ports separately, and this list can be used directly in this method:

Feature description

write the Readme file

Feature description

• research document
• #2
• #3
• #4

Feature description

create an interface for cassandra session, mock, and add tests for handling inserts, updates, and deletes

Feature description

• build the skeleton for the connector
• add license and file headers
• fill in specs
• create config struct and generate params using paramgen
• connect to Cassandra on the Open method

Feature description

add insert handler, that parses create and snapshot records into CQL looking like:
INSERT INTO {table} (id, column1, column2, column3) VALUES (5, 'foo', 123, true);
and update handler :
UPDATE {table} SET column1='bar', column2=567, column3=true WHERE id=6 AND id2=3;
and delete:
DELETE FROM {table} WHERE id=6