MCPcopy Create free account
hub / github.com/apache/cassandra-nodejs-driver / readEvent

Method readEvent

lib/readers.js:479–499  ·  view source on GitHub ↗

* Reads an event from Cassandra and returns the detail * @returns {{eventType: String, inet: {address: Buffer, port: Number}}, *}

()

Source from the content-addressed store, hash-verified

477 * @returns {{eventType: String, inet: {address: Buffer, port: Number}}, *}
478 */
479 readEvent() {
480 const eventType = this.readString();
481 switch (eventType) {
482 case types.protocolEvents.topologyChange:
483 return {
484 added: this.readString() === 'NEW_NODE',
485 inet: this.readInet(),
486 eventType: eventType
487 };
488 case types.protocolEvents.statusChange:
489 return {
490 up: this.readString() === 'UP',
491 inet: this.readInet(),
492 eventType: eventType
493 };
494 case types.protocolEvents.schemaChange:
495 return this.parseSchemaChange();
496 }
497 //Forward compatibility
498 return { eventType: eventType };
499 }
500
501 parseSchemaChange() {
502 let result;

Callers 1

streams.jsFile · 0.80

Calls 3

readStringMethod · 0.95
readInetMethod · 0.95
parseSchemaChangeMethod · 0.95

Tested by

no test coverage detected