Documentation ¶
Index ¶
- func Close(dbctx database.DatabaseContext[database.Record]) error
- func OpenLeaksDB() (database.DatabaseContext[database.Record], error)
- func OpenSubscriptionsDB() (database.DatabaseContext[database.Record], error)
- func StoreSubscriptionDB(dbctx database.DatabaseContext[database.Record], ...) error
- type AffectedInfo
- type AllAffectedsInfo
- type EmailInfo
- type LeakInfo
- type QueryAffectedByLeakResult
- type QueryLeakByIdResult
- type QuerySubscriptionResult
- type QuerySubscriptionWithoutAffectedResult
- type QuerySubscriptionsResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OpenLeaksDB ¶
func OpenLeaksDB() (database.DatabaseContext[database.Record], error)
func OpenSubscriptionsDB ¶
func OpenSubscriptionsDB() (database.DatabaseContext[database.Record], error)
func StoreSubscriptionDB ¶
func StoreSubscriptionDB(dbctx database.DatabaseContext[database.Record], subscription subscribe.Subscription) error
Types ¶
type AffectedInfo ¶
type AllAffectedsInfo ¶
type AllAffectedsInfo []AffectedInfo
type EmailInfo ¶
type EmailInfo struct { UsersAffected AllAffectedsInfo LeakInfo LeakInfo }
type QueryAffectedByLeakResult ¶
func QueryAffectedLeaksDB ¶
func QueryAffectedLeaksDB(dbctx database.DatabaseContext[database.Record], leakid entity.AutoGenKey, affected []subscribe.Affected) ([]QueryAffectedByLeakResult, error)
type QueryLeakByIdResult ¶
func QueryLeakByIdDB ¶
func QueryLeakByIdDB(dbctx database.DatabaseContext[database.Record], leakid entity.AutoGenKey) ([]QueryLeakByIdResult, error)
type QuerySubscriptionResult ¶
type QuerySubscriptionResult struct { subscribe.Subscriber subscribe.Affected }
type QuerySubscriptionWithoutAffectedResult ¶
type QuerySubscriptionWithoutAffectedResult struct { subscribe.Subscriber subscribe.Affected }
type QuerySubscriptionsResult ¶
type QuerySubscriptionsResult []QuerySubscriptionResult
func QuerySubscriptionsDB ¶
func QuerySubscriptionsDB(dbctx database.DatabaseContext[database.Record]) (QuerySubscriptionsResult, error)
func (QuerySubscriptionsResult) GetAffectUsers ¶
func (qsr QuerySubscriptionsResult) GetAffectUsers() []subscribe.Affected
func (QuerySubscriptionsResult) GetAffectedsInfo ¶
func (qsr QuerySubscriptionsResult) GetAffectedsInfo(usersAffectedByLeak []QueryAffectedByLeakResult) AllAffectedsInfo
Click to show internal directories.
Click to hide internal directories.