Variable incrementalIngestionProvidersExtensionPointConst

Example

backend.add(createBackendModule({
  pluginId: 'catalog',
  moduleId: 'my-incremental-provider',
  register(env) {
    env.registerInit({
      deps: {
        extension: incrementalIngestionProvidersExtensionPoint,
      },
      async init({ extension }) {
        extension.addProvider({
          burstInterval: ...,
          burstLength: ...,
          restLength: ...,
        }, {
          next(context, cursor) {
            ...
          },
          ...
        })
      })
    })
  }
}))
Copy