storage

Documentation

Index

• type Storage
  • func New(pathDB string, logger log.Logger) (*Storage, error)
  • func (s *Storage) Close() error
  • func (s *Storage) Collect(record collector.Record) error
  • func (s *Storage) CountNotUseCoupon(cid int64) (uint64, error)
  • func (s *Storage) GetChat() (a []int64, err error)
  • func (s *Storage) GetCountUser() (int, error)
  • func (s *Storage) GetNotUseCoupon(cid int64) ([]collector.Record, error)
  • func (s *Storage) GetNotUseCouponCount(cid, count int64) ([]collector.Record, error)
  • func (s *Storage) GetUnsentNotification() ([]model.Notification, error)
  • func (s *Storage) LoadCollect() (map[string]collector.Record, error)
  • func (s *Storage) MarkAsRead(cid int64, rr []collector.Record) error
  • func (s *Storage) MarkSentNotification(id int64) error
  • func (s *Storage) NewChat(chat *tgbotapi.Chat) error
  • func (s *Storage) NewMessage(msg *tgbotapi.Message) error
  • func (s *Storage) UpdChatActivity(cid int64, act bool) error

Types

type Storage

type Storage struct {
	// contains filtered or unexported fields
}

func New

func New(pathDB string, logger log.Logger) (*Storage, error)

func (*Storage) Close

func (s *Storage) Close() error

func (*Storage) Collect

func (s *Storage) Collect(record collector.Record) error

func (*Storage) CountNotUseCoupon

func (s *Storage) CountNotUseCoupon(cid int64) (uint64, error)

func (*Storage) GetChat

func (s *Storage) GetChat() (a []int64, err error)

func (*Storage) GetCountUser

func (s *Storage) GetCountUser() (int, error)

func (*Storage) GetNotUseCoupon

func (s *Storage) GetNotUseCoupon(cid int64) ([]collector.Record, error)

func (*Storage) GetNotUseCouponCount

func (s *Storage) GetNotUseCouponCount(cid, count int64) ([]collector.Record, error)

func (*Storage) GetUnsentNotification

func (s *Storage) GetUnsentNotification() ([]model.Notification, error)

func (*Storage) LoadCollect

func (s *Storage) LoadCollect() (map[string]collector.Record, error)

func (*Storage) MarkAsRead

func (s *Storage) MarkAsRead(cid int64, rr []collector.Record) error

func (*Storage) MarkSentNotification

func (s *Storage) MarkSentNotification(id int64) error

func (*Storage) NewChat

func (s *Storage) NewChat(chat *tgbotapi.Chat) error

func (*Storage) NewMessage

func (s *Storage) NewMessage(msg *tgbotapi.Message) error

func (*Storage) UpdChatActivity

func (s *Storage) UpdChatActivity(cid int64, act bool) error