dao

Documentation

Index

• type Dao
  • func NewDao() (dao *Dao, err error)
• type Kafka
  • func NewKafka() (k *Kafka)
• type MongoDB
  • func NewMongoDB() (mdb *MongoDB, err error)
  • func (m *MongoDB) StoreOfflineMsg(msg *commmodel.OfflineMsg) (err error)

Types

type Dao

type Dao struct {
	MongoDB *MongoDB
	Kafka   *Kafka
}

func NewDao

func NewDao() (dao *Dao, err error)

type Kafka

type Kafka struct {
	Consumer *kafka.Consumer
}

func NewKafka

func NewKafka() (k *Kafka)

type MongoDB

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

func NewMongoDB

func NewMongoDB() (mdb *MongoDB, err error)

func (*MongoDB) StoreOfflineMsg

func (m *MongoDB) StoreOfflineMsg(msg *commmodel.OfflineMsg) (err error)