db

Documentation

Index

• Constants
• func AppendRecordForRecordCache(ctx context.Context, roomId string, record *model.Record) error
• func Close(ctx context.Context)
• func CreateRecordCache(ctx context.Context, cache *model.RecordCache) error
• func FindRoom(ctx context.Context, roomId string) bool
• func GetCache(ctx context.Context, roomId string) (cache *model.RecordCache, err error)
• func InitDb(addr []string, maxpollsize uint64, username, password, source string) error
• func SetEnd(ctx context.Context, roomId, display string, startTime uint64) error
• func SetUrl(ctx context.Context, roomId, display string, startTime uint64, url string) error
• type DbManager
  • func (dbm *DbManager) CloseDb(ctx context.Context)
  • func (dbm *DbManager) InitDb(addr []string, maxpollsize uint64, username, password, source string) error

Constants

const (
	HEART_BEAT_INTERVAL = 10
	CONNECT_TIMEOUT     = 3
	MAX_CONNIDLE_TIME   = 60
)

Functions

func AppendRecordForRecordCache

func AppendRecordForRecordCache(ctx context.Context, roomId string, record *model.Record) error

func Close

func Close(ctx context.Context)

func CreateRecordCache

func CreateRecordCache(ctx context.Context, cache *model.RecordCache) error

func FindRoom

func FindRoom(ctx context.Context, roomId string) bool

func GetCache

func GetCache(ctx context.Context, roomId string) (cache *model.RecordCache, err error)

func InitDb

func InitDb(addr []string, maxpollsize uint64, username, password, source string) error

func SetEnd

func SetEnd(ctx context.Context, roomId, display string, startTime uint64) error

func SetUrl

func SetUrl(ctx context.Context, roomId, display string, startTime uint64, url string) error

Types

type DbManager

type DbManager struct {
	Mongo  *mongo.Client
	DbName string
}

func (*DbManager) CloseDb

func (dbm *DbManager) CloseDb(ctx context.Context)

func (*DbManager) InitDb

func (dbm *DbManager) InitDb(addr []string, maxpollsize uint64, username, password, source string) error