consumers

package
v0.0.0-...-9835270 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Register 

func Register(name int64, f func() ConsumerInterface)

Types

type AccountDBEVConsumer 

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

func (*AccountDBEVConsumer) IsDump 

func (s *AccountDBEVConsumer) IsDump(errMsg string) bool

func (*AccountDBEVConsumer) OnDeleteRoomTag 

func (s *AccountDBEVConsumer) OnDeleteRoomTag(
	ctx context.Context, msg *dbtypes.RoomTagDelete,
) error

func (*AccountDBEVConsumer) OnDeleteUserInfo 

func (s *AccountDBEVConsumer) OnDeleteUserInfo(
	ctx context.Context, msg *dbtypes.UserInfoDelete,
) error

func (*AccountDBEVConsumer) OnInitProfile 

func (s *AccountDBEVConsumer) OnInitProfile(
	ctx context.Context, msg *dbtypes.ProfileInsert,
) error

func (*AccountDBEVConsumer) OnInitUserInfo 

func (s *AccountDBEVConsumer) OnInitUserInfo(
	ctx context.Context, msg *dbtypes.UserInfoInsert,
) error

func (*AccountDBEVConsumer) OnInsertAccount 

func (s *AccountDBEVConsumer) OnInsertAccount(
	ctx context.Context, msg *dbtypes.AccountInsert,
) error

func (*AccountDBEVConsumer) OnInsertAccountData 

func (s *AccountDBEVConsumer) OnInsertAccountData(
	ctx context.Context, msg *dbtypes.AccountDataInsert,
) error

func (*AccountDBEVConsumer) OnInsertFilter 

func (s *AccountDBEVConsumer) OnInsertFilter(
	ctx context.Context, msg *dbtypes.FilterInsert,
) error

func (*AccountDBEVConsumer) OnInsertRoomTag 

func (s *AccountDBEVConsumer) OnInsertRoomTag(
	ctx context.Context, msg *dbtypes.RoomTagInsert,
) error

func (*AccountDBEVConsumer) OnMessage 

func (s *AccountDBEVConsumer) OnMessage(ctx context.Context, dbEv *dbtypes.DBEvent) error

func (*AccountDBEVConsumer) OnUpsertAvatar 

func (s *AccountDBEVConsumer) OnUpsertAvatar(
	ctx context.Context, msg *dbtypes.ProfileInsert,
) error

func (*AccountDBEVConsumer) OnUpsertDisplayName 

func (s *AccountDBEVConsumer) OnUpsertDisplayName(
	ctx context.Context, msg *dbtypes.ProfileInsert,
) error

func (*AccountDBEVConsumer) OnUpsertProfile 

func (s *AccountDBEVConsumer) OnUpsertProfile(
	ctx context.Context, msg *dbtypes.ProfileInsert,
) error

func (*AccountDBEVConsumer) OnUpsertUserInfo 

func (s *AccountDBEVConsumer) OnUpsertUserInfo(
	ctx context.Context, msg *dbtypes.UserInfoInsert,
) error

func (*AccountDBEVConsumer) Prepare 

func (s *AccountDBEVConsumer) Prepare(cfg *config.Dendrite)

func (*AccountDBEVConsumer) Report 

func (s *AccountDBEVConsumer) Report(mon monitor.LabeledGauge)

func (*AccountDBEVConsumer) Start 

func (s *AccountDBEVConsumer) Start()

type ConsumerInterface 

type ConsumerInterface interface {
	OnMessage(context.Context, *dbtypes.DBEvent) error
	Prepare(*config.Dendrite)
	Report(monitor.LabeledGauge)
	Start()
}

func NewAccountDBEVConsumer 

func NewAccountDBEVConsumer() ConsumerInterface

func NewDeviceDBEVConsumer 

func NewDeviceDBEVConsumer() ConsumerInterface

func NewE2EDBEVConsumer 

func NewE2EDBEVConsumer() ConsumerInterface

func NewPresenceDBEVConsumer 

func NewPresenceDBEVConsumer() ConsumerInterface

func NewPublicRoomDBEVConsumer 

func NewPublicRoomDBEVConsumer() ConsumerInterface

func NewPushDBEVConsumer 

func NewPushDBEVConsumer() ConsumerInterface

func NewRoomDBEVConsumer 

func NewRoomDBEVConsumer() ConsumerInterface

func NewSyncDBEVConsumer 

func NewSyncDBEVConsumer() ConsumerInterface

type DBEventDataConsumer 

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

DBEventDataConsumer consumes db events for roomserver.

func NewDBEventDataConsumer 

func NewDBEventDataConsumer(
	cfg *config.Dendrite,
) *DBEventDataConsumer

NewDBUpdateDataConsumer creates a new DBUpdateData consumer. Call Start() to begin consuming from room servers.

func (*DBEventDataConsumer) CommitMessage 

func (s *DBEventDataConsumer) CommitMessage(rawMsg []interface{})

func (*DBEventDataConsumer) OnMessage 

func (s *DBEventDataConsumer) OnMessage(ctx context.Context, topic string, partition int32, data []byte, rawMsg interface{})

func (*DBEventDataConsumer) Start 

func (s *DBEventDataConsumer) Start() error

Start consuming from room servers

type DBMonItem 

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

type DeviceDBEVConsumer 

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

func (*DeviceDBEVConsumer) IsDump 

func (s *DeviceDBEVConsumer) IsDump(errMsg string) bool

func (*DeviceDBEVConsumer) OnMessage 

func (s *DeviceDBEVConsumer) OnMessage(ctx context.Context, dbEv *dbtypes.DBEvent) error

func (*DeviceDBEVConsumer) Prepare 

func (s *DeviceDBEVConsumer) Prepare(cfg *config.Dendrite)

func (*DeviceDBEVConsumer) Report 

func (s *DeviceDBEVConsumer) Report(mon monitor.LabeledGauge)

func (*DeviceDBEVConsumer) Start 

func (s *DeviceDBEVConsumer) Start()

type E2EDBEVConsumer 

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

func (*E2EDBEVConsumer) OnMessage 

func (s *E2EDBEVConsumer) OnMessage(ctx context.Context, dbEv *dbtypes.DBEvent) error

func (*E2EDBEVConsumer) Prepare 

func (s *E2EDBEVConsumer) Prepare(cfg *config.Dendrite)

func (*E2EDBEVConsumer) Report 

func (s *E2EDBEVConsumer) Report(mon monitor.LabeledGauge)

func (*E2EDBEVConsumer) Start 

func (s *E2EDBEVConsumer) Start()

type PresenceDBEVConsumer 

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

func (*PresenceDBEVConsumer) IsDump 

func (s *PresenceDBEVConsumer) IsDump(errMsg string) bool

func (*PresenceDBEVConsumer) OnInsertPresences 

func (s *PresenceDBEVConsumer) OnInsertPresences(
	ctx context.Context, msg *dbtypes.PresencesInsert,
) error

func (*PresenceDBEVConsumer) OnMessage 

func (s *PresenceDBEVConsumer) OnMessage(ctx context.Context, dbEv *dbtypes.DBEvent) error

func (*PresenceDBEVConsumer) Prepare 

func (s *PresenceDBEVConsumer) Prepare(cfg *config.Dendrite)

func (*PresenceDBEVConsumer) Report 

func (s *PresenceDBEVConsumer) Report(mon monitor.LabeledGauge)

func (*PresenceDBEVConsumer) Start 

func (s *PresenceDBEVConsumer) Start()

type PublicRoomDBEVConsumer 

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

func (*PublicRoomDBEVConsumer) IsDump 

func (s *PublicRoomDBEVConsumer) IsDump(errMsg string) bool

func (*PublicRoomDBEVConsumer) OnMessage 

func (s *PublicRoomDBEVConsumer) OnMessage(ctx context.Context, dbEv *dbtypes.DBEvent) error

func (*PublicRoomDBEVConsumer) Prepare 

func (s *PublicRoomDBEVConsumer) Prepare(cfg *config.Dendrite)

func (*PublicRoomDBEVConsumer) Report 

func (s *PublicRoomDBEVConsumer) Report(mon monitor.LabeledGauge)

func (*PublicRoomDBEVConsumer) Start 

func (s *PublicRoomDBEVConsumer) Start()

type PushDBEVConsumer 

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

func (*PushDBEVConsumer) IsDump 

func (s *PushDBEVConsumer) IsDump(errMsg string) bool

func (*PushDBEVConsumer) OnMessage 

func (s *PushDBEVConsumer) OnMessage(ctx context.Context, dbEv *dbtypes.DBEvent) error

func (*PushDBEVConsumer) Prepare 

func (s *PushDBEVConsumer) Prepare(cfg *config.Dendrite)

func (*PushDBEVConsumer) Report 

func (s *PushDBEVConsumer) Report(mon monitor.LabeledGauge)

func (*PushDBEVConsumer) Start 

func (s *PushDBEVConsumer) Start()

type RoomDBEVConsumer 

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

func (*RoomDBEVConsumer) IsDump 

func (s *RoomDBEVConsumer) IsDump(errMsg string) bool

func (*RoomDBEVConsumer) OnMessage 

func (s *RoomDBEVConsumer) OnMessage(ctx context.Context, dbev *dbtypes.DBEvent) error

func (*RoomDBEVConsumer) Prepare 

func (s *RoomDBEVConsumer) Prepare(cfg *config.Dendrite)

func (*RoomDBEVConsumer) Report 

func (s *RoomDBEVConsumer) Report(mon monitor.LabeledGauge)

func (*RoomDBEVConsumer) Start 

func (s *RoomDBEVConsumer) Start()

type SyncDBEVConsumer 

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

func (*SyncDBEVConsumer) IsDump 

func (s *SyncDBEVConsumer) IsDump(errMsg string) bool

func (*SyncDBEVConsumer) OnMessage 

func (s *SyncDBEVConsumer) OnMessage(ctx context.Context, dbEv *dbtypes.DBEvent) error

func (*SyncDBEVConsumer) Prepare 

func (s *SyncDBEVConsumer) Prepare(cfg *config.Dendrite)

func (*SyncDBEVConsumer) Report 

func (s *SyncDBEVConsumer) Report(mon monitor.LabeledGauge)

func (*SyncDBEVConsumer) Start 

func (s *SyncDBEVConsumer) Start()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.