Documentation
¶
Overview ¶
Package usersub implements the admin-side user subscription management of the subscription module. Only the module facade may reach it.
Index ¶
- type CreateUserSubscribeLogic
- type DeleteUserSubscribeLogic
- type Deps
- type GetUserSubscribeByIdLogic
- type GetUserSubscribeDevicesLogic
- type GetUserSubscribeLogic
- type GetUserSubscribeLogsLogic
- type GetUserSubscribeResetTrafficLogsLogic
- type GetUserSubscribeTrafficLogsLogic
- type ResetUserSubscribeTokenLogic
- type ResetUserSubscribeTrafficLogic
- type Service
- func (s *Service) CreateUserSubscribe(ctx context.Context, req *dto.CreateUserSubscribeRequest) error
- func (s *Service) DeleteUserSubscribe(ctx context.Context, req *dto.DeleteUserSubscribeRequest) error
- func (s *Service) GetUserSubscribe(ctx context.Context, req *dto.GetUserSubscribeListRequest) (*dto.GetUserSubscribeListResponse, error)
- func (s *Service) GetUserSubscribeById(ctx context.Context, req *dto.GetUserSubscribeByIdRequest) (*dto.UserSubscribeDetail, error)
- func (s *Service) GetUserSubscribeDevices(ctx context.Context, req *dto.GetUserSubscribeDevicesRequest) (*dto.GetUserSubscribeDevicesResponse, error)
- func (s *Service) GetUserSubscribeLogs(ctx context.Context, req *dto.GetUserSubscribeLogsRequest) (*dto.GetUserSubscribeLogsResponse, error)
- func (s *Service) GetUserSubscribeResetTrafficLogs(ctx context.Context, req *dto.GetUserSubscribeResetTrafficLogsRequest) (*dto.GetUserSubscribeResetTrafficLogsResponse, error)
- func (s *Service) GetUserSubscribeTrafficLogs(ctx context.Context, req *dto.GetUserSubscribeTrafficLogsRequest) (*dto.GetUserSubscribeTrafficLogsResponse, error)
- func (s *Service) ResetUserSubscribeToken(ctx context.Context, req *dto.ResetUserSubscribeTokenRequest) error
- func (s *Service) ResetUserSubscribeTraffic(ctx context.Context, req *dto.ResetUserSubscribeTrafficRequest) error
- func (s *Service) ToggleUserSubscribeStatus(ctx context.Context, req *dto.ToggleUserSubscribeStatusRequest) error
- func (s *Service) UpdateUserSubscribe(ctx context.Context, req *dto.UpdateUserSubscribeRequest) error
- type ToggleUserSubscribeStatusLogic
- type UpdateUserSubscribeLogic
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CreateUserSubscribeLogic ¶
func (*CreateUserSubscribeLogic) CreateUserSubscribe ¶
func (l *CreateUserSubscribeLogic) CreateUserSubscribe(req *dto.CreateUserSubscribeRequest) error
type DeleteUserSubscribeLogic ¶
func (*DeleteUserSubscribeLogic) DeleteUserSubscribe ¶
func (l *DeleteUserSubscribeLogic) DeleteUserSubscribe(req *dto.DeleteUserSubscribeRequest) error
type Deps ¶
type Deps struct {
Plans repository.SubscribeRepo
UserSubs repository.UserSubscriptionRepo
// Users/Devices/Traffic/Logs are read ports onto the identity, network
// and platform domains for the admin detail views.
Users repository.UserRepo
Devices repository.UserDeviceRepo
Cache repository.UserCacheRepo
Traffic repository.TrafficRepo
Logs repository.LogRepo
Store repository.Store
// SingleModel forbids holding more than one blocking subscription;
// runtime-mutable, read per request.
SingleModel func() bool
}
type GetUserSubscribeByIdLogic ¶
func (*GetUserSubscribeByIdLogic) GetUserSubscribeById ¶
func (l *GetUserSubscribeByIdLogic) GetUserSubscribeById(req *dto.GetUserSubscribeByIdRequest) (resp *dto.UserSubscribeDetail, err error)
type GetUserSubscribeDevicesLogic ¶
type GetUserSubscribeDevicesLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*GetUserSubscribeDevicesLogic) GetUserSubscribeDevices ¶
func (l *GetUserSubscribeDevicesLogic) GetUserSubscribeDevices(req *dto.GetUserSubscribeDevicesRequest) (resp *dto.GetUserSubscribeDevicesResponse, err error)
type GetUserSubscribeLogic ¶
func (*GetUserSubscribeLogic) GetUserSubscribe ¶
func (l *GetUserSubscribeLogic) GetUserSubscribe(req *dto.GetUserSubscribeListRequest) (resp *dto.GetUserSubscribeListResponse, err error)
type GetUserSubscribeLogsLogic ¶
func (*GetUserSubscribeLogsLogic) GetUserSubscribeLogs ¶
func (l *GetUserSubscribeLogsLogic) GetUserSubscribeLogs(req *dto.GetUserSubscribeLogsRequest) (resp *dto.GetUserSubscribeLogsResponse, err error)
type GetUserSubscribeResetTrafficLogsLogic ¶
type GetUserSubscribeResetTrafficLogsLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*GetUserSubscribeResetTrafficLogsLogic) GetUserSubscribeResetTrafficLogs ¶
func (l *GetUserSubscribeResetTrafficLogsLogic) GetUserSubscribeResetTrafficLogs(req *dto.GetUserSubscribeResetTrafficLogsRequest) (resp *dto.GetUserSubscribeResetTrafficLogsResponse, err error)
type GetUserSubscribeTrafficLogsLogic ¶
type GetUserSubscribeTrafficLogsLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*GetUserSubscribeTrafficLogsLogic) GetUserSubscribeTrafficLogs ¶
func (l *GetUserSubscribeTrafficLogsLogic) GetUserSubscribeTrafficLogs(req *dto.GetUserSubscribeTrafficLogsRequest) (resp *dto.GetUserSubscribeTrafficLogsResponse, err error)
type ResetUserSubscribeTokenLogic ¶
type ResetUserSubscribeTokenLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*ResetUserSubscribeTokenLogic) ResetUserSubscribeToken ¶
func (l *ResetUserSubscribeTokenLogic) ResetUserSubscribeToken(req *dto.ResetUserSubscribeTokenRequest) error
type ResetUserSubscribeTrafficLogic ¶
type ResetUserSubscribeTrafficLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*ResetUserSubscribeTrafficLogic) ResetUserSubscribeTraffic ¶
func (l *ResetUserSubscribeTrafficLogic) ResetUserSubscribeTraffic(req *dto.ResetUserSubscribeTrafficRequest) error
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func (*Service) CreateUserSubscribe ¶
func (*Service) DeleteUserSubscribe ¶
func (*Service) GetUserSubscribe ¶
func (s *Service) GetUserSubscribe(ctx context.Context, req *dto.GetUserSubscribeListRequest) (*dto.GetUserSubscribeListResponse, error)
func (*Service) GetUserSubscribeById ¶
func (s *Service) GetUserSubscribeById(ctx context.Context, req *dto.GetUserSubscribeByIdRequest) (*dto.UserSubscribeDetail, error)
func (*Service) GetUserSubscribeDevices ¶
func (s *Service) GetUserSubscribeDevices(ctx context.Context, req *dto.GetUserSubscribeDevicesRequest) (*dto.GetUserSubscribeDevicesResponse, error)
func (*Service) GetUserSubscribeLogs ¶
func (s *Service) GetUserSubscribeLogs(ctx context.Context, req *dto.GetUserSubscribeLogsRequest) (*dto.GetUserSubscribeLogsResponse, error)
func (*Service) GetUserSubscribeResetTrafficLogs ¶
func (s *Service) GetUserSubscribeResetTrafficLogs(ctx context.Context, req *dto.GetUserSubscribeResetTrafficLogsRequest) (*dto.GetUserSubscribeResetTrafficLogsResponse, error)
func (*Service) GetUserSubscribeTrafficLogs ¶
func (s *Service) GetUserSubscribeTrafficLogs(ctx context.Context, req *dto.GetUserSubscribeTrafficLogsRequest) (*dto.GetUserSubscribeTrafficLogsResponse, error)
func (*Service) ResetUserSubscribeToken ¶
func (*Service) ResetUserSubscribeTraffic ¶
func (*Service) ToggleUserSubscribeStatus ¶
func (*Service) UpdateUserSubscribe ¶
type ToggleUserSubscribeStatusLogic ¶
type ToggleUserSubscribeStatusLogic struct {
logger.Logger
// contains filtered or unexported fields
}
func (*ToggleUserSubscribeStatusLogic) ToggleUserSubscribeStatus ¶
func (l *ToggleUserSubscribeStatusLogic) ToggleUserSubscribeStatus(req *dto.ToggleUserSubscribeStatusRequest) error
type UpdateUserSubscribeLogic ¶
func (*UpdateUserSubscribeLogic) UpdateUserSubscribe ¶
func (l *UpdateUserSubscribeLogic) UpdateUserSubscribe(req *dto.UpdateUserSubscribeRequest) error
Source Files
¶
- createusersubscribe.go
- deleteusersubscribe.go
- getusersubscribe.go
- getusersubscribebyid.go
- getusersubscribedevices.go
- getusersubscribelogs.go
- getusersubscriberesettrafficlogs.go
- getusersubscribetrafficlogs.go
- resetusersubscribetoken.go
- resetusersubscribetraffic.go
- service.go
- toggleusersubscribestatus.go
- updateusersubscribe.go
Click to show internal directories.
Click to hide internal directories.