RegisterRowSource registers a row source type this is called from the package init function of the table implementation.

PluginSourceWrapperIdentifier is the source name for the plugin source wrapper.

Factory is a global newFactory instance.

ResolvedFromTime is a struct that holds the 'resolved' from time and the source that provided it From time is determined from either: - the default (T-7d - the from time provided in the request - the end time od the collection state.

RowSourceImpl is a base implementation of the [plugin.RowSource] interface It implements the [observable.Observable] interface, as well as providing a default implementation of Close(), and contains the logic to raise a Row event It should be embedded in all [plugin.RowSource] implementations S is the type of the source config struct T is the type of the connection struct.

BaseSource registers the rowSource implementation with the base struct (_before_ calling Init) we do not want to expose this function in the RowSource interface.

RowSource is the interface that represents a data source A number of data sourceFuncs are provided by the SDK, and plugins may provide their own Built in data sourceFuncs: - AWS S3 Bucket - API Source (this must be implemented by the plugin) - File Source - Webhook source Sources may be configured with data transfo.

RowSourceOption is a function that can be used to configure a RowSource NOTE: individual options are specific to specific row source types RowSourceOption accepts the base Observable interface, and each option must implement a safe type assertion to the specific row source type.