db

Documentation

Index

• Constants
• type Database
  • func OpenDatabase(l *zap.Logger, client *redis.Client) *Database
  • func (db *Database) AddMails(target string, mails ...*pb.Mail) error
  • func (db *Database) AddMultiplyMails(targets []string, mails ...*pb.Mail) error
  • func (db *Database) DelMails(profileId string, ids ...int64) error
  • func (db *Database) GetSelfMails(id string) map[int64]*pb.Mail
  • func (db *Database) MergePublicAndPrivateMail(uid, channel, language string, registerTime int64) error
  • func (db *Database) PushMailToPublic(channel string, mail *pb.Mail) error
  • func (db *Database) UpdateAllStatus(profileId string, status pb.MailStatus) ([]*pb.Mail, error)
  • func (db *Database) UpdateOneStatus(profileId string, id int64, status pb.MailStatus) (*pb.Mail, error)

Constants

const (
	MailTheme           = "mail"
	MailPublicIndex     = "index"
	MailPublicKeyPrefix = "public"
)

Types

type Database

type Database struct {
	*redis.Client
	// contains filtered or unexported fields
}

func OpenDatabase

func OpenDatabase(l *zap.Logger, client *redis.Client) *Database

func (*Database) AddMails

func (db *Database) AddMails(target string, mails ...*pb.Mail) error

func (*Database) AddMultiplyMails

func (db *Database) AddMultiplyMails(targets []string, mails ...*pb.Mail) error

func (*Database) DelMails

func (db *Database) DelMails(profileId string, ids ...int64) error

func (*Database) GetSelfMails

func (db *Database) GetSelfMails(id string) map[int64]*pb.Mail

func (*Database) MergePublicAndPrivateMail

func (db *Database) MergePublicAndPrivateMail(uid, channel, language string, registerTime int64) error

func (*Database) PushMailToPublic

func (db *Database) PushMailToPublic(channel string, mail *pb.Mail) error

func (*Database) UpdateAllStatus

func (db *Database) UpdateAllStatus(profileId string, status pb.MailStatus) ([]*pb.Mail, error)

func (*Database) UpdateOneStatus

func (db *Database) UpdateOneStatus(profileId string, id int64, status pb.MailStatus) (*pb.Mail, error)