encryptoapi

Documentation

Index

• func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)
• type Database
  • func (d *Database) DeleteDeviceKeys(ctx context.Context, deviceID, userID string) error
  • func (d *Database) DeleteDeviceOneTimeKey(ctx context.Context, deviceID, userID string) error
  • func (d *Database) DeleteMacKeys(ctx context.Context, deviceID, userID, identifier string) error
  • func (d *Database) DeleteMacOneTimeKey(ctx context.Context, deviceID, userID, identifier string) (err error)
  • func (d *Database) DeleteOneTimeKey(ctx context.Context, deviceID, userID, keyID, algorithm string) (err error)
  • func (d *Database) InsertAl(ctx context.Context, uid, device, als, identifier string) (err error)
  • func (d *Database) InsertDeviceKey(ctx context.Context, deviceID, userID, keyInfo, al, sig, identifier string) (err error)
  • func (d *Database) InsertOneTimeKey(ctx context.Context, ...) (err error)
  • func (d *Database) OnDeleteAl(ctx context.Context, userID, deviceID string) error
  • func (d *Database) OnDeleteDeviceKey(ctx context.Context, deviceID, userID string) error
  • func (d *Database) OnDeleteDeviceOneTimeKey(ctx context.Context, deviceID, userID string) error
  • func (d *Database) OnDeleteMacAl(ctx context.Context, userID, deviceID, identifier string) error
  • func (d *Database) OnDeleteMacDeviceKey(ctx context.Context, deviceID, userID, identifier string) error
  • func (d *Database) OnDeleteMacOneTimeKey(ctx context.Context, deviceID, userID, identifier string) (err error)
  • func (d *Database) OnDeleteOneTimeKey(ctx context.Context, deviceID, userID, keyID, algorithm string) (err error)
  • func (d *Database) OnInsertAl(ctx context.Context, uid, device, als, identifier string) (err error)
  • func (d *Database) OnInsertDeviceKey(ctx context.Context, deviceID, userID, keyInfo, al, sig, identifier string) (err error)
  • func (d *Database) OnInsertOneTimeKey(ctx context.Context, ...) (err error)
  • func (d *Database) RecoverCache()
  • func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)
  • 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)

NewDatabase creates a new presence database

Types

type Database

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

Database represents a presence database.

func (*Database) DeleteDeviceKeys

func (d *Database) DeleteDeviceKeys(
	ctx context.Context, deviceID, userID string,
) error

func (*Database) DeleteDeviceOneTimeKey

func (d *Database) DeleteDeviceOneTimeKey(
	ctx context.Context, deviceID, userID string,
) error

func (*Database) DeleteMacKeys

func (d *Database) DeleteMacKeys(
	ctx context.Context, deviceID, userID, identifier string,
) error

func (*Database) DeleteMacOneTimeKey

func (d *Database) DeleteMacOneTimeKey(
	ctx context.Context,
	deviceID, userID, identifier string,
) (err error)

func (*Database) DeleteOneTimeKey

func (d *Database) DeleteOneTimeKey(
	ctx context.Context,
	deviceID, userID, keyID, algorithm string,
) (err error)

func (*Database) InsertAl

func (d *Database) InsertAl(
	ctx context.Context, uid, device, als, identifier string,
) (err error)

InsertAl persist algorithms

func (*Database) InsertDeviceKey

func (d *Database) InsertDeviceKey(
	ctx context.Context,
	deviceID, userID, keyInfo, al, sig, identifier string,
) (err error)

func (*Database) InsertOneTimeKey

func (d *Database) InsertOneTimeKey(
	ctx context.Context,
	deviceID, userID, keyID, keyInfo, al, sig, identifier string,
) (err error)

func (*Database) OnDeleteAl

func (d *Database) OnDeleteAl(
	ctx context.Context,
	userID, deviceID string,
) error

func (*Database) OnDeleteDeviceKey

func (d *Database) OnDeleteDeviceKey(
	ctx context.Context,
	deviceID, userID string,
) error

func (*Database) OnDeleteDeviceOneTimeKey

func (d *Database) OnDeleteDeviceOneTimeKey(
	ctx context.Context,
	deviceID, userID string,
) error

func (*Database) OnDeleteMacAl

func (d *Database) OnDeleteMacAl(
	ctx context.Context,
	userID, deviceID, identifier string,
) error

func (*Database) OnDeleteMacDeviceKey

func (d *Database) OnDeleteMacDeviceKey(
	ctx context.Context,
	deviceID, userID, identifier string,
) error

func (*Database) OnDeleteMacOneTimeKey

func (d *Database) OnDeleteMacOneTimeKey(
	ctx context.Context,
	deviceID, userID, identifier string,
) (err error)

func (*Database) OnDeleteOneTimeKey

func (d *Database) OnDeleteOneTimeKey(
	ctx context.Context,
	deviceID, userID, keyID, algorithm string,
) (err error)

func (*Database) OnInsertAl

func (d *Database) OnInsertAl(
	ctx context.Context, uid, device, als, identifier string,
) (err error)

func (*Database) OnInsertDeviceKey

func (d *Database) OnInsertDeviceKey(
	ctx context.Context,
	deviceID, userID, keyInfo, al, sig, identifier string,
) (err error)

func (*Database) OnInsertOneTimeKey

func (d *Database) OnInsertOneTimeKey(
	ctx context.Context,
	deviceID, userID, keyID, keyInfo, al, sig, identifier string,
) (err error)

func (*Database) RecoverCache

func (d *Database) RecoverCache()

func (*Database) SetGauge

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

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