notifystorage

package

v0.0.0-...-c6a46fa Latest Latest Go to latest Published: Oct 29, 2026 License: MIT Imports: 28 Imported by: 0

Details

This section is empty.

This section is empty.

func NewNotificationChannelsStorage(db *gorm.DB, logger *logging.Logger) notifysvc.NotificationChannelsStorage

func NewNotificationRulesStorage(db *gorm.DB, logger *logging.Logger) notifysvc.NotificationRulesStorage

func NewTableGenerators() table.GeneratorList

func NewWebhooksStorage(db *gorm.DB, logger *logging.Logger) notifysvc.WebhooksStorage

type Storages struct {
	// contains filtered or unexported fields
}

func NewStorages(db *gorm.DB, logger *logging.Logger, processors []txoutbox.MessageProcessor) *Storages

func (s Storages) ExecuteInTransaction(ctx context.Context, cb func(ctx context.Context, tx notifysvc.Storage) error) error

func (s Storages) IdempotencyKeys() idempotency.Storage

func (s Storages) NotificationChannels() notifysvc.NotificationChannelsStorage

func (s Storages) NotificationRules() notifysvc.NotificationRulesStorage

func (s Storages) Webhooks() notifysvc.WebhooksStorage

func (s *Storages) WithAdvisoryLock(ctx context.Context, scope string, lockID int64) error