Skip to content

Create an event bus #617

@dkropachev

Description

@dkropachev

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
No labels

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions