presence

Documentation

Index

• func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)
• type Database
  • func (d *Database) OnUpsertPresences(ctx context.Context, userID, status, statusMsg, extStatusMsg string) error
  • func (d *Database) RecoverCache()
  • func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)
  • func (d *Database) UpsertPresences(ctx context.Context, userID, status, statusMsg, extStatusMsg string) error
  • func (d *Database) WriteDBEvent(ctx context.Context, update *dbtypes.DBEvent) error
  • func (d *Database) WriteDBEventWithTbl(ctx context.Context, update *dbtypes.DBEvent, tbl string) error

Functions

func NewDatabase

func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)

Types

type Database

type Database struct {
	AsyncSave bool
	// contains filtered or unexported fields
}

func (*Database) OnUpsertPresences

func (d *Database) OnUpsertPresences(
	ctx context.Context, userID, status, statusMsg, extStatusMsg string,
) error

func (*Database) RecoverCache

func (d *Database) RecoverCache()

func (*Database) SetGauge

func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)

func (*Database) UpsertPresences

func (d *Database) UpsertPresences(
	ctx context.Context, userID, status, statusMsg, extStatusMsg string,
) error

func (*Database) WriteDBEvent

func (d *Database) WriteDBEvent(ctx context.Context, update *dbtypes.DBEvent) error

WriteOutputEvents implements OutputRoomEventWriter

func (*Database) WriteDBEventWithTbl

func (d *Database) WriteDBEventWithTbl(ctx context.Context, update *dbtypes.DBEvent, tbl string) error