forked from apache/cassandra-gocql-driver
-
Notifications
You must be signed in to change notification settings - Fork 70
Description
To implement #616, we need an event bus in the driver that lets us listen to events originating either from the driver itself or from the cluster
API
Subscribe/Unsubscribe:
// Subscribe
sub := sess.SubscribeToEvents("my-subs", maxQueueSize, nil)
// Unsubscribe
defer sub.Stop()
Filtering:
sub := sess.SubscribeToEvents("schema-event", maxQueueSize, func(ev events.Event) bool {
return ev.Type() == events.ClusterEventTypeSchemaChangeKeyspace
})
Sub-issues
Metadata
Metadata
Assignees
Labels
No labels