postgresScheduleStoreFactory function

ScheduleStoreFactory postgresScheduleStoreFactory(
  1. String uri, {
  2. String namespace = 'stem',
  3. String schema = 'public',
  4. String? applicationName,
  5. TlsConfig? tls,
})

Creates a ScheduleStoreFactory backed by PostgreSQL.

Implementation

ScheduleStoreFactory postgresScheduleStoreFactory(
  String uri, {
  String namespace = 'stem',
  String schema = 'public',
  String? applicationName,
  TlsConfig? tls,
}) {
  return ScheduleStoreFactory(
    create: () async => PostgresScheduleStore.connect(
      uri,
      namespace: namespace,
      schema: schema,
      applicationName: applicationName,
      tls: tls,
    ),
    dispose: (store) async {
      if (store is PostgresScheduleStore) {
        await store.close();
      }
    },
  );
}