Documentation
¶
Overview ¶
Package auditlog implements the audit/message log subdomain of the platform module: filtered views over the system log, message log listing and the log retention settings. Only the module facade may reach it.
Index ¶
- type Deps
- type FilterBalanceLogLogic
- type FilterCommissionLogLogic
- type FilterEmailLogLogic
- type FilterGiftLogLogic
- type FilterLoginLogLogic
- type FilterMobileLogLogic
- type FilterRegisterLogLogic
- type FilterResetSubscribeLogLogic
- type FilterServerTrafficLogLogic
- type FilterSubscribeLogLogic
- type FilterTrafficLogDetailsLogic
- type FilterUserSubscribeTrafficLogLogic
- type GetLogSettingLogic
- type GetMessageLogListLogic
- type PlatformTransactor
- type Service
- func (s *Service) FilterBalanceLog(ctx context.Context, req *dto.FilterBalanceLogRequest) (*dto.FilterBalanceLogResponse, error)
- func (s *Service) FilterCommissionLog(ctx context.Context, req *dto.FilterCommissionLogRequest) (*dto.FilterCommissionLogResponse, error)
- func (s *Service) FilterEmailLog(ctx context.Context, req *dto.FilterLogParams) (*dto.FilterEmailLogResponse, error)
- func (s *Service) FilterGiftLog(ctx context.Context, req *dto.FilterGiftLogRequest) (*dto.FilterGiftLogResponse, error)
- func (s *Service) FilterLoginLog(ctx context.Context, req *dto.FilterLoginLogRequest) (*dto.FilterLoginLogResponse, error)
- func (s *Service) FilterMobileLog(ctx context.Context, req *dto.FilterLogParams) (*dto.FilterMobileLogResponse, error)
- func (s *Service) FilterRegisterLog(ctx context.Context, req *dto.FilterRegisterLogRequest) (*dto.FilterRegisterLogResponse, error)
- func (s *Service) FilterResetSubscribeLog(ctx context.Context, req *dto.FilterResetSubscribeLogRequest) (*dto.FilterResetSubscribeLogResponse, error)
- func (s *Service) FilterServerTrafficLog(ctx context.Context, req *dto.FilterServerTrafficLogRequest) (*dto.FilterServerTrafficLogResponse, error)
- func (s *Service) FilterSubscribeLog(ctx context.Context, req *dto.FilterSubscribeLogRequest) (*dto.FilterSubscribeLogResponse, error)
- func (s *Service) FilterTrafficLogDetails(ctx context.Context, req *dto.FilterTrafficLogDetailsRequest) (*dto.FilterTrafficLogDetailsResponse, error)
- func (s *Service) FilterUserSubscribeTrafficLog(ctx context.Context, req *dto.FilterSubscribeTrafficRequest) (*dto.FilterSubscribeTrafficResponse, error)
- func (s *Service) GetLogSetting(ctx context.Context) (*dto.LogSetting, error)
- func (s *Service) GetMessageLogList(ctx context.Context, req *dto.GetMessageLogListRequest) (*dto.GetMessageLogListResponse, error)
- func (s *Service) UpdateLogSetting(ctx context.Context, req *dto.LogSetting) error
- type TrafficReader
- type UpdateLogSettingLogic
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Deps ¶
type Deps struct {
Logs repository.LogRepo
System repository.SystemRepo
Traffic TrafficReader
Store PlatformTransactor
// OnLogSettingChanged propagates a committed retention change to the
// running configuration.
OnLogSettingChanged func(autoClear bool, clearDays int64)
// LogRetention reads the current (mutable) retention configuration.
LogRetention func() (autoClear bool, clearDays int64)
}
type FilterBalanceLogLogic ¶
func (*FilterBalanceLogLogic) FilterBalanceLog ¶
func (l *FilterBalanceLogLogic) FilterBalanceLog(req *dto.FilterBalanceLogRequest) (resp *dto.FilterBalanceLogResponse, err error)
type FilterCommissionLogLogic ¶
func (*FilterCommissionLogLogic) FilterCommissionLog ¶
func (l *FilterCommissionLogLogic) FilterCommissionLog(req *dto.FilterCommissionLogRequest) (resp *dto.FilterCommissionLogResponse, err error)
type FilterEmailLogLogic ¶
func (*FilterEmailLogLogic) FilterEmailLog ¶
func (l *FilterEmailLogLogic) FilterEmailLog(req *dto.FilterLogParams) (resp *dto.FilterEmailLogResponse, err error)
type FilterGiftLogLogic ¶
func (*FilterGiftLogLogic) FilterGiftLog ¶
func (l *FilterGiftLogLogic) FilterGiftLog(req *dto.FilterGiftLogRequest) (resp *dto.FilterGiftLogResponse, err error)
type FilterLoginLogLogic ¶
func (*FilterLoginLogLogic) FilterLoginLog ¶
func (l *FilterLoginLogLogic) FilterLoginLog(req *dto.FilterLoginLogRequest) (resp *dto.FilterLoginLogResponse, err error)
type FilterMobileLogLogic ¶
func (*FilterMobileLogLogic) FilterMobileLog ¶
func (l *FilterMobileLogLogic) FilterMobileLog(req *dto.FilterLogParams) (resp *dto.FilterMobileLogResponse, err error)
type FilterRegisterLogLogic ¶
func (*FilterRegisterLogLogic) FilterRegisterLog ¶
func (l *FilterRegisterLogLogic) FilterRegisterLog(req *dto.FilterRegisterLogRequest) (resp *dto.FilterRegisterLogResponse, err error)
type FilterResetSubscribeLogLogic ¶
type FilterResetSubscribeLogLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*FilterResetSubscribeLogLogic) FilterResetSubscribeLog ¶
func (l *FilterResetSubscribeLogLogic) FilterResetSubscribeLog(req *dto.FilterResetSubscribeLogRequest) (resp *dto.FilterResetSubscribeLogResponse, err error)
type FilterServerTrafficLogLogic ¶
func (*FilterServerTrafficLogLogic) FilterServerTrafficLog ¶
func (l *FilterServerTrafficLogLogic) FilterServerTrafficLog(req *dto.FilterServerTrafficLogRequest) (resp *dto.FilterServerTrafficLogResponse, err error)
type FilterSubscribeLogLogic ¶
func (*FilterSubscribeLogLogic) FilterSubscribeLog ¶
func (l *FilterSubscribeLogLogic) FilterSubscribeLog(req *dto.FilterSubscribeLogRequest) (resp *dto.FilterSubscribeLogResponse, err error)
type FilterTrafficLogDetailsLogic ¶
type FilterTrafficLogDetailsLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*FilterTrafficLogDetailsLogic) FilterTrafficLogDetails ¶
func (l *FilterTrafficLogDetailsLogic) FilterTrafficLogDetails(req *dto.FilterTrafficLogDetailsRequest) (resp *dto.FilterTrafficLogDetailsResponse, err error)
type FilterUserSubscribeTrafficLogLogic ¶
type FilterUserSubscribeTrafficLogLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*FilterUserSubscribeTrafficLogLogic) FilterUserSubscribeTrafficLog ¶
func (l *FilterUserSubscribeTrafficLogLogic) FilterUserSubscribeTrafficLog(req *dto.FilterSubscribeTrafficRequest) (resp *dto.FilterSubscribeTrafficResponse, err error)
type GetLogSettingLogic ¶
func (*GetLogSettingLogic) GetLogSetting ¶
func (l *GetLogSettingLogic) GetLogSetting() (resp *dto.LogSetting, err error)
type GetMessageLogListLogic ¶
func (*GetMessageLogListLogic) GetMessageLogList ¶
func (l *GetMessageLogListLogic) GetMessageLogList(req *dto.GetMessageLogListRequest) (resp *dto.GetMessageLogListResponse, err error)
type PlatformTransactor ¶
type PlatformTransactor interface {
InPlatformTx(ctx context.Context, fn func(repository.PlatformStore) error) error
}
PlatformTransactor mirrors the store's platform-scoped transaction.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func (*Service) FilterBalanceLog ¶
func (s *Service) FilterBalanceLog(ctx context.Context, req *dto.FilterBalanceLogRequest) (*dto.FilterBalanceLogResponse, error)
func (*Service) FilterCommissionLog ¶
func (s *Service) FilterCommissionLog(ctx context.Context, req *dto.FilterCommissionLogRequest) (*dto.FilterCommissionLogResponse, error)
func (*Service) FilterEmailLog ¶
func (s *Service) FilterEmailLog(ctx context.Context, req *dto.FilterLogParams) (*dto.FilterEmailLogResponse, error)
func (*Service) FilterGiftLog ¶
func (s *Service) FilterGiftLog(ctx context.Context, req *dto.FilterGiftLogRequest) (*dto.FilterGiftLogResponse, error)
func (*Service) FilterLoginLog ¶
func (s *Service) FilterLoginLog(ctx context.Context, req *dto.FilterLoginLogRequest) (*dto.FilterLoginLogResponse, error)
func (*Service) FilterMobileLog ¶
func (s *Service) FilterMobileLog(ctx context.Context, req *dto.FilterLogParams) (*dto.FilterMobileLogResponse, error)
func (*Service) FilterRegisterLog ¶
func (s *Service) FilterRegisterLog(ctx context.Context, req *dto.FilterRegisterLogRequest) (*dto.FilterRegisterLogResponse, error)
func (*Service) FilterResetSubscribeLog ¶
func (s *Service) FilterResetSubscribeLog(ctx context.Context, req *dto.FilterResetSubscribeLogRequest) (*dto.FilterResetSubscribeLogResponse, error)
func (*Service) FilterServerTrafficLog ¶
func (s *Service) FilterServerTrafficLog(ctx context.Context, req *dto.FilterServerTrafficLogRequest) (*dto.FilterServerTrafficLogResponse, error)
func (*Service) FilterSubscribeLog ¶
func (s *Service) FilterSubscribeLog(ctx context.Context, req *dto.FilterSubscribeLogRequest) (*dto.FilterSubscribeLogResponse, error)
func (*Service) FilterTrafficLogDetails ¶
func (s *Service) FilterTrafficLogDetails(ctx context.Context, req *dto.FilterTrafficLogDetailsRequest) (*dto.FilterTrafficLogDetailsResponse, error)
func (*Service) FilterUserSubscribeTrafficLog ¶
func (s *Service) FilterUserSubscribeTrafficLog(ctx context.Context, req *dto.FilterSubscribeTrafficRequest) (*dto.FilterSubscribeTrafficResponse, error)
func (*Service) GetLogSetting ¶
func (*Service) GetMessageLogList ¶
func (s *Service) GetMessageLogList(ctx context.Context, req *dto.GetMessageLogListRequest) (*dto.GetMessageLogListResponse, error)
func (*Service) UpdateLogSetting ¶
type TrafficReader ¶
type TrafficReader = repository.TrafficRepo
TrafficReader is the subdomain's port onto the network domain's traffic statistics; the legacy traffic repository satisfies it structurally.
type UpdateLogSettingLogic ¶
func (*UpdateLogSettingLogic) UpdateLogSetting ¶
func (l *UpdateLogSettingLogic) UpdateLogSetting(req *dto.LogSetting) error
Source Files
¶
- filterbalancelog.go
- filtercommissionlog.go
- filteremaillog.go
- filtergiftlog.go
- filterloginlog.go
- filtermobilelog.go
- filterregisterlog.go
- filterresetsubscribelog.go
- filterservertrafficlog.go
- filtersubscribelog.go
- filtertrafficlogdetails.go
- filterusersubscribetrafficlog.go
- getlogsetting.go
- getmessageloglist.go
- service.go
- updatelogsetting.go
Click to show internal directories.
Click to hide internal directories.