stem_postgres library

Classes

PostgresBroker: PostgreSQL-backed implementation of Broker.
PostgresLockStore: PostgreSQL-backed implementation of LockStore.
PostgresOperationTiming: A completed PostgreSQL operation measurement.
PostgresOutboxBroker: Producer facade that diverts publication into a Postgres outbox.
PostgresOutboxTransaction: Active transaction passed to PostgresTransactionalOutbox.transaction.
PostgresQueryTiming: A completed SQL query measurement emitted by the PostgreSQL adapter.
PostgresRateLimiter: PostgreSQL-backed distributed token-bucket rate limiter.
PostgresResultBackend: PostgreSQL-backed implementation of ResultBackend.
PostgresRevokeStore: PostgreSQL-backed implementation of RevokeStore.
PostgresScheduleStore: PostgreSQL-backed implementation of ScheduleStore using ormed ORM.
PostgresTransactionalOutbox: Durable, PostgreSQL-backed publication outbox.
PostgresWorkflowStore: PostgreSQL-backed WorkflowStore implementation using ormed ORM.
StemPostgresAdapter: Adapter that resolves PostgreSQL-backed factories from a postgres:// URL.

postgresBrokerFactory(String uri, {String namespace = 'stem', String? applicationName, TlsConfig? tls}) → StemBrokerFactory: Creates a StemBrokerFactory backed by PostgreSQL.
postgresLockStoreFactory(String uri, {String namespace = 'stem', String schema = 'public', String? applicationName, TlsConfig? tls}) → LockStoreFactory: Creates a LockStoreFactory backed by PostgreSQL.
postgresResultBackendFactory(String uri, {String namespace = 'stem', Duration defaultTtl = const Duration(days: 1), Duration groupDefaultTtl = const Duration(days: 1), Duration heartbeatTtl = const Duration(minutes: 1)}) → StemBackendFactory: Creates a StemBackendFactory backed by PostgreSQL.
postgresRevokeStoreFactory(String uri, {String namespace = 'stem', String schema = 'public', String? applicationName, TlsConfig? tls}) → RevokeStoreFactory: Creates a RevokeStoreFactory backed by PostgreSQL.
postgresScheduleStoreFactory(String uri, {String namespace = 'stem', String schema = 'public', String? applicationName, TlsConfig? tls}) → ScheduleStoreFactory: Creates a ScheduleStoreFactory backed by PostgreSQL.
postgresWorkflowStoreFactory(String uri, {String schema = 'public', String namespace = 'stem', String? applicationName, TlsConfig? tls}) → WorkflowStoreFactory: Creates a WorkflowStoreFactory backed by PostgreSQL.

PostgresQueryTimingListener = void Function(PostgresQueryTiming query): Receives completed SQL query measurements.
PostgresTimingListener = void Function(PostgresOperationTiming timing): Receives completed PostgreSQL operation measurements.