federation

Documentation

Index

• func NewDatabase(driver, createAddr, address, underlying, topic string, useAsync bool) (interface{}, error)
• type Database
  • func (d *Database) InsertBackfillRecord(ctx context.Context, rec model.BackfillRecord) error
  • func (d *Database) InsertJoinedRooms(ctx context.Context, roomID, eventID string) error
  • func (d *Database) InsertMissingEvents(ctx context.Context, roomID, eventID string, amount int) error
  • func (d *Database) InsertSendRecord(ctx context.Context, roomID, domain string, domainOffset int64) error
  • func (d *Database) SelectAllBackfillRecord(ctx context.Context) ([]model.BackfillRecord, error)
  • func (d *Database) SelectAllSendRecord(ctx context.Context) ([]string, []string, []string, []int32, []int32, []int64, int, error)
  • func (d *Database) SelectBackfillRecord(ctx context.Context, roomID string) (model.BackfillRecord, error)
  • func (d *Database) SelectJoinedRooms(ctx context.Context, roomID string) (eventID, recvOffsets string, err error)
  • func (d *Database) SelectMissingEvents(ctx context.Context) (roomIDs, eventIDs []string, amounts []int, err error)
  • func (d *Database) SelectPendingSendRecord(ctx context.Context) ([]string, []string, []string, []int32, []int32, []int64, int, error)
  • func (d *Database) SelectSendRecord(ctx context.Context, roomID, domain string) (eventID string, sendTimes, pendingSize int32, domainOffset int64, err error)
  • func (d *Database) SetGauge(qryDBGauge mon.LabeledGauge)
  • func (d *Database) UpdateBackfillRecordDomainsInfo(ctx context.Context, roomID string, depth int64, finished bool, ...) error
  • func (d *Database) UpdateJoinedRoomsRecvOffset(ctx context.Context, roomID string, recvOffsets string) error
  • func (d *Database) UpdateMissingEvents(ctx context.Context, roomID, eventID string, finished bool) error
  • func (d *Database) UpdateSendRecordPendingSize(ctx context.Context, roomID, domain string, size int32, domainOffset int64) error
  • func (d *Database) UpdateSendRecordPendingSizeAndEventID(ctx context.Context, roomID, domain string, size int32, eventID string, ...) error

Functions

func NewDatabase

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

NewDatabase opens a new database

Types

type Database

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

Database stores information needed by the federation sender

func (*Database) InsertBackfillRecord

func (d *Database) InsertBackfillRecord(ctx context.Context, rec model.BackfillRecord) error

func (*Database) InsertJoinedRooms

func (d *Database) InsertJoinedRooms(ctx context.Context, roomID, eventID string) error

func (*Database) InsertMissingEvents

func (d *Database) InsertMissingEvents(
	ctx context.Context,
	roomID, eventID string, amount int,
) error

func (*Database) InsertSendRecord

func (d *Database) InsertSendRecord(ctx context.Context, roomID, domain string, domainOffset int64) error

func (*Database) SelectAllBackfillRecord

func (d *Database) SelectAllBackfillRecord(ctx context.Context) ([]model.BackfillRecord, error)

func (*Database) SelectAllSendRecord

func (d *Database) SelectAllSendRecord(ctx context.Context) ([]string, []string, []string, []int32, []int32, []int64, int, error)

func (*Database) SelectBackfillRecord

func (d *Database) SelectBackfillRecord(ctx context.Context, roomID string) (model.BackfillRecord, error)

func (*Database) SelectJoinedRooms

func (d *Database) SelectJoinedRooms(ctx context.Context, roomID string) (eventID, recvOffsets string, err error)

func (*Database) SelectMissingEvents

func (d *Database) SelectMissingEvents(ctx context.Context) (roomIDs, eventIDs []string, amounts []int, err error)

func (*Database) SelectPendingSendRecord

func (d *Database) SelectPendingSendRecord(ctx context.Context) ([]string, []string, []string, []int32, []int32, []int64, int, error)

func (*Database) SelectSendRecord

func (d *Database) SelectSendRecord(ctx context.Context, roomID, domain string) (eventID string, sendTimes, pendingSize int32, domainOffset int64, err error)

func (*Database) SetGauge

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

func (*Database) UpdateBackfillRecordDomainsInfo

func (d *Database) UpdateBackfillRecordDomainsInfo(ctx context.Context, roomID string, depth int64, finished bool, finishedDomains string, states string) error

func (*Database) UpdateJoinedRoomsRecvOffset

func (d *Database) UpdateJoinedRoomsRecvOffset(ctx context.Context, roomID string, recvOffsets string) error

func (*Database) UpdateMissingEvents

func (d *Database) UpdateMissingEvents(ctx context.Context, roomID, eventID string, finished bool) error

func (*Database) UpdateSendRecordPendingSize

func (d *Database) UpdateSendRecordPendingSize(ctx context.Context, roomID, domain string, size int32, domainOffset int64) error

func (*Database) UpdateSendRecordPendingSizeAndEventID

func (d *Database) UpdateSendRecordPendingSizeAndEventID(ctx context.Context, roomID, domain string, size int32, eventID string, domainOffset int64) error