Documentation
¶
Index ¶
- Variables
- func NewSecretFieldStorage(databases map[string]*gorm.Client) (*kit.SecretFieldRuntime, error)
- type MessageDeliveryWriter
- func (w *MessageDeliveryWriter) CreateIgnore(ctx context.Context, list []*models.BaseMessageDelivery, batchSize int) (int64, error)
- func (w *MessageDeliveryWriter) RevokeMessage(ctx context.Context, messageID int64, revokedAt time.Time) error
- func (w *MessageDeliveryWriter) SetAllReadAt(ctx context.Context, userID, beforeDeliveryID int64, readAt time.Time) error
- func (w *MessageDeliveryWriter) SetArchivedAt(ctx context.Context, userID, id int64, archivedAt *time.Time) error
- func (w *MessageDeliveryWriter) SetReadAt(ctx context.Context, userID int64, ids []int64, readAt *time.Time) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet( data.ProviderSet, ragdata.ProviderSet, wire.Bind(new(ragdata.QueryProvider), new(*ragdata.Data)), NewMessageDeliveryWriter, NewSecretFieldStorage, wire.Bind(new(data.QueryProvider), new(*data.Data)), )
ProviderSet 汇总 Admin 数据访问依赖注入提供者和查询接口绑定。
Functions ¶
func NewSecretFieldStorage ¶ added in v0.0.67
NewSecretFieldStorage 在默认数据库上绑定密钥字段加解密回调并返回运行时。
Types ¶
type MessageDeliveryWriter ¶ added in v0.0.30
type MessageDeliveryWriter struct {
// contains filtered or unexported fields
}
MessageDeliveryWriter 封装统一投递明细的幂等写入和站内信状态更新。
func NewMessageDeliveryWriter ¶ added in v0.0.30
func NewMessageDeliveryWriter(queryProvider data.QueryProvider) *MessageDeliveryWriter
NewMessageDeliveryWriter 创建消息投递写入器。
func (*MessageDeliveryWriter) CreateIgnore ¶ added in v0.0.30
func (w *MessageDeliveryWriter) CreateIgnore(ctx context.Context, list []*models.BaseMessageDelivery, batchSize int) (int64, error)
CreateIgnore 幂等批量创建投递记录并返回实际新增数量。
func (*MessageDeliveryWriter) RevokeMessage ¶ added in v0.0.30
func (w *MessageDeliveryWriter) RevokeMessage(ctx context.Context, messageID int64, revokedAt time.Time) error
RevokeMessage 批量撤回指定消息的全部用户投递记录。
func (*MessageDeliveryWriter) SetAllReadAt ¶ added in v0.0.30
func (w *MessageDeliveryWriter) SetAllReadAt(ctx context.Context, userID, beforeDeliveryID int64, readAt time.Time) error
SetAllReadAt 按水位线批量设置当前用户消息已读时间。
func (*MessageDeliveryWriter) SetArchivedAt ¶ added in v0.0.30
func (w *MessageDeliveryWriter) SetArchivedAt(ctx context.Context, userID, id int64, archivedAt *time.Time) error
SetArchivedAt 设置或清空当前用户单条投递记录的归档时间。
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.