Documentation ¶
Index ¶
- type BlacklistRepository
- type CampaignRepository
- type ContentRepository
- type HistoryRepository
- type IBlacklistRepository
- type ICampaignRepository
- type IContentRepository
- type IHistoryRepository
- type IScheduleRepository
- type IServiceRepository
- type ISubscriptionRepository
- type ITransactionRepository
- type IVIPRepository
- type IVerifyRepository
- type ScheduleRepository
- type ServiceRepository
- type SubscriptionRepository
- func (r *SubscriptionRepository) AveragePerUser(start, end, renewal, subkey string) (*[]entity.AveragePerUser, error)
- func (r *SubscriptionRepository) Count(serviceId int, msisdn string) (int, error)
- func (r *SubscriptionRepository) CountActive(serviceId int, msisdn string) (int, error)
- func (r *SubscriptionRepository) CountPin(pin int) (int, error)
- func (r *SubscriptionRepository) Get(serviceId int, msisdn string) (*entity.Subscription, error)
- func (r *SubscriptionRepository) Reminder() (*[]entity.Subscription, error)
- func (r *SubscriptionRepository) Renewal() (*[]entity.Subscription, error)
- func (r *SubscriptionRepository) Retry() (*[]entity.Subscription, error)
- func (r *SubscriptionRepository) Save(s *entity.Subscription) error
- func (r *SubscriptionRepository) UpdateConfirm(s *entity.Subscription) error
- func (r *SubscriptionRepository) UpdateDisable(s *entity.Subscription) error
- func (r *SubscriptionRepository) UpdateEnable(s *entity.Subscription) error
- func (r *SubscriptionRepository) UpdateFailed(s *entity.Subscription) error
- func (r *SubscriptionRepository) UpdateLatest(s *entity.Subscription) error
- func (r *SubscriptionRepository) UpdateSuccess(s *entity.Subscription) error
- type TransactionRepository
- func (r *TransactionRepository) Delete(t *entity.Transaction) error
- func (r *TransactionRepository) Save(t *entity.Transaction) error
- func (r *TransactionRepository) SelectByAdnet() (*[]entity.Transaction, error)
- func (r *TransactionRepository) SelectByStatus() (*[]entity.Transaction, error)
- func (r *TransactionRepository) SelectByStatusDetail() (*[]entity.Transaction, error)
- type VIPRepository
- type VerifyRepository
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlacklistRepository ¶
type BlacklistRepository struct {
// contains filtered or unexported fields
}
func NewBlacklistRepository ¶
func NewBlacklistRepository(db *sql.DB) *BlacklistRepository
type CampaignRepository ¶
type CampaignRepository struct {
// contains filtered or unexported fields
}
func NewCampaignRepository ¶
func NewCampaignRepository(db *sql.DB) *CampaignRepository
type ContentRepository ¶
type ContentRepository struct {
// contains filtered or unexported fields
}
func NewContentRepository ¶
func NewContentRepository(db *sql.DB) *ContentRepository
type HistoryRepository ¶
type HistoryRepository struct {
// contains filtered or unexported fields
}
func NewHistoryRepository ¶
func NewHistoryRepository(db *sql.DB) *HistoryRepository
type IBlacklistRepository ¶
type ICampaignRepository ¶
type IContentRepository ¶
type IHistoryRepository ¶
type IScheduleRepository ¶
type IServiceRepository ¶
type ISubscriptionRepository ¶
type ISubscriptionRepository interface { Save(*entity.Subscription) error UpdateSuccess(*entity.Subscription) error UpdateFailed(*entity.Subscription) error UpdateLatest(*entity.Subscription) error UpdateEnable(*entity.Subscription) error UpdateDisable(*entity.Subscription) error UpdateConfirm(*entity.Subscription) error Count(int, string) (int, error) CountActive(int, string) (int, error) CountPin(int) (int, error) Get(int, string) (*entity.Subscription, error) Renewal() (*[]entity.Subscription, error) Retry() (*[]entity.Subscription, error) Reminder() (*[]entity.Subscription, error) AveragePerUser(string, string, string, string) (*[]entity.AveragePerUser, error) }
type ITransactionRepository ¶
type ITransactionRepository interface { Save(*entity.Transaction) error Delete(*entity.Transaction) error SelectByStatus() (*[]entity.Transaction, error) SelectByStatusDetail() (*[]entity.Transaction, error) SelectByAdnet() (*[]entity.Transaction, error) }
type IVIPRepository ¶
type IVerifyRepository ¶
type ScheduleRepository ¶
type ScheduleRepository struct {
// contains filtered or unexported fields
}
func NewScheduleRepository ¶
func NewScheduleRepository(db *sql.DB) *ScheduleRepository
func (*ScheduleRepository) CountLocked ¶
func (r *ScheduleRepository) CountLocked(name, hour string) (int, error)
func (*ScheduleRepository) CountUnlocked ¶
func (r *ScheduleRepository) CountUnlocked(name, hour string) (int, error)
type ServiceRepository ¶
type ServiceRepository struct {
// contains filtered or unexported fields
}
func NewServiceRepository ¶
func NewServiceRepository(db *sql.DB) *ServiceRepository
func (*ServiceRepository) CountByCategory ¶
func (r *ServiceRepository) CountByCategory(category string) (int, error)
func (*ServiceRepository) CountByCode ¶
func (r *ServiceRepository) CountByCode(code string) (int, error)
type SubscriptionRepository ¶
type SubscriptionRepository struct {
// contains filtered or unexported fields
}
func NewSubscriptionRepository ¶
func NewSubscriptionRepository(db *sql.DB) *SubscriptionRepository
func (*SubscriptionRepository) AveragePerUser ¶
func (r *SubscriptionRepository) AveragePerUser(start, end, renewal, subkey string) (*[]entity.AveragePerUser, error)
func (*SubscriptionRepository) Count ¶
func (r *SubscriptionRepository) Count(serviceId int, msisdn string) (int, error)
func (*SubscriptionRepository) CountActive ¶
func (r *SubscriptionRepository) CountActive(serviceId int, msisdn string) (int, error)
func (*SubscriptionRepository) CountPin ¶
func (r *SubscriptionRepository) CountPin(pin int) (int, error)
func (*SubscriptionRepository) Get ¶
func (r *SubscriptionRepository) Get(serviceId int, msisdn string) (*entity.Subscription, error)
func (*SubscriptionRepository) Reminder ¶
func (r *SubscriptionRepository) Reminder() (*[]entity.Subscription, error)
func (*SubscriptionRepository) Renewal ¶
func (r *SubscriptionRepository) Renewal() (*[]entity.Subscription, error)
func (*SubscriptionRepository) Retry ¶
func (r *SubscriptionRepository) Retry() (*[]entity.Subscription, error)
func (*SubscriptionRepository) Save ¶
func (r *SubscriptionRepository) Save(s *entity.Subscription) error
func (*SubscriptionRepository) UpdateConfirm ¶
func (r *SubscriptionRepository) UpdateConfirm(s *entity.Subscription) error
func (*SubscriptionRepository) UpdateDisable ¶
func (r *SubscriptionRepository) UpdateDisable(s *entity.Subscription) error
func (*SubscriptionRepository) UpdateEnable ¶
func (r *SubscriptionRepository) UpdateEnable(s *entity.Subscription) error
func (*SubscriptionRepository) UpdateFailed ¶
func (r *SubscriptionRepository) UpdateFailed(s *entity.Subscription) error
func (*SubscriptionRepository) UpdateLatest ¶
func (r *SubscriptionRepository) UpdateLatest(s *entity.Subscription) error
func (*SubscriptionRepository) UpdateSuccess ¶
func (r *SubscriptionRepository) UpdateSuccess(s *entity.Subscription) error
type TransactionRepository ¶
type TransactionRepository struct {
// contains filtered or unexported fields
}
func NewTransactionRepository ¶
func NewTransactionRepository(db *sql.DB) *TransactionRepository
func (*TransactionRepository) Delete ¶
func (r *TransactionRepository) Delete(t *entity.Transaction) error
func (*TransactionRepository) Save ¶
func (r *TransactionRepository) Save(t *entity.Transaction) error
func (*TransactionRepository) SelectByAdnet ¶
func (r *TransactionRepository) SelectByAdnet() (*[]entity.Transaction, error)
func (*TransactionRepository) SelectByStatus ¶
func (r *TransactionRepository) SelectByStatus() (*[]entity.Transaction, error)
func (*TransactionRepository) SelectByStatusDetail ¶
func (r *TransactionRepository) SelectByStatusDetail() (*[]entity.Transaction, error)
type VIPRepository ¶
type VIPRepository struct {
// contains filtered or unexported fields
}
func NewVIPRepository ¶
func NewVIPRepository(db *sql.DB) *VIPRepository
type VerifyRepository ¶
type VerifyRepository struct {
// contains filtered or unexported fields
}
func NewVerifyRepository ¶
func NewVerifyRepository(db *sql.DB) *VerifyRepository
func (*VerifyRepository) GetByToken ¶
func (r *VerifyRepository) GetByToken(token string) (*entity.Verify, error)
Click to show internal directories.
Click to hide internal directories.