NewPullInstance opens a new event source and starts a capture session, filling the event batches with a pull model.

NewPushInstance opens a new event source and starts a capture session, filling the event batches with a push model.

Register registers the event sourcing capability in the framework for the given Plugin.

WithInstanceBatchSize sets a custom size for the pre-allocated event batch used by NextBatch().

WithInstanceClose sets a custom closing callback in the opened event source.

WithInstanceContext sets a custom context in the opened event source.

WithInstanceEventSize sets a custom maximum size for each event returned by NextBatch().

WithInstanceProgress sets a custom callback for the framework to request a the progress state of the opened event stream.

WithInstanceTimeout sets a custom timeout in the opened event source.

BaseInstance is a base implementation of the Instance interface.

PushEvent represents an event produced from an event source with the push model.

Instance is an interface representing a source capture session instance returned by a call to Open of a plugin with event sourcing capability.

Plugin is an interface representing a plugin with event sourcing capability.

PullFunc produces a new event and returns a non-nil error in case of failure.