Documentation
¶
Index ¶
- func AdminEventStream() queueTransport.Stream
- func NewConsumer(loginLogRepo *data.BaseLoginLogRepository, ...) queueData.ConsumerFunc
- func NewMiddleware(baseCase *biz.BaseCase) (middleware.Middleware, func())
- func ReplayAdminEvent(ctx context.Context, messageID string, rawValue []byte, ...) error
- type Middleware
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AdminEventStream ¶
func AdminEventStream() queueTransport.Stream
AdminEventStream 返回 Admin 业务审计事件队列名称。
func NewConsumer ¶
func NewConsumer( loginLogRepo *data.BaseLoginLogRepository, operationLogRepo *data.BaseOperationLogRepository, dataAccessLogRepo *data.BaseDataAccessLogRepository, permissionLogRepo *data.BasePermissionLogRepository, ) queueData.ConsumerFunc
NewConsumer 创建 Admin 业务审计事件消费者并写入对应日志表。
func NewMiddleware ¶
func NewMiddleware(baseCase *biz.BaseCase) (middleware.Middleware, func())
NewMiddleware 创建审计日志中间件。
func ReplayAdminEvent ¶
func ReplayAdminEvent( ctx context.Context, messageID string, rawValue []byte, loginLogRepo *data.BaseLoginLogRepository, operationLogRepo *data.BaseOperationLogRepository, dataAccessLogRepo *data.BaseDataAccessLogRepository, permissionLogRepo *data.BasePermissionLogRepository, ) error
ReplayAdminEvent 将一条 Admin 审计事件按稳定编号幂等写入对应日志表。
Types ¶
type Middleware ¶
type Middleware struct {
// contains filtered or unexported fields
}
Middleware 记录 Admin 请求对应的登录、操作、数据访问和权限审计事实。 Core 产生的 API/策略事件走 Core Sink；本中间件只处理 Admin 自身业务事件。
func (*Middleware) Handle ¶
func (m *Middleware) Handle(next middleware.Handler) middleware.Handler
Handle 记录一次请求的登录、操作、数据访问和权限审计信息。
Source Files
Click to show internal directories.
Click to hide internal directories.