consumers

package

v0.0.0-...-9835270 Latest Latest Go to latest Published: Sep 22, 2021 License: AGPL-3.0, Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/finogeeks/ligase

Documentation ¶

Index ¶

func Register(name int64, f func() ConsumerInterface)
type AccountDBEvCacheConsumer
type ConsumerInterface
type DBEventCacheConsumer
- func NewDBEventCacheConsumer(cfg *config.Dendrite) *DBEventCacheConsumer
type DeviceDBEvCacheConsumer
type E2EDBEvCacheConsumer
type PoolProviderInterface
type PresenceDBEvCacheConsumer
type PushDBEvCacheConsumer
type RoomDBEvCacheConsumer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Register ¶

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

Types ¶

type AccountDBEvCacheConsumer ¶

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

func (*AccountDBEvCacheConsumer) OnDeleteRoomTag ¶

func (s *AccountDBEvCacheConsumer) OnDeleteRoomTag(
	msg *dbtypes.RoomTagDelete,
) error

func (*AccountDBEvCacheConsumer) OnDeleteUserInfo ¶

func (s *AccountDBEvCacheConsumer) OnDeleteUserInfo(
	msg *dbtypes.UserInfoDelete,
) error

func (*AccountDBEvCacheConsumer) OnInitProfile ¶

func (s *AccountDBEvCacheConsumer) OnInitProfile(
	msg *dbtypes.ProfileInsert,
) error

func (*AccountDBEvCacheConsumer) OnInitUserInfo ¶

func (s *AccountDBEvCacheConsumer) OnInitUserInfo(
	msg *dbtypes.UserInfoInsert,
) error

func (*AccountDBEvCacheConsumer) OnInsertAccountData ¶

func (s *AccountDBEvCacheConsumer) OnInsertAccountData(
	msg *dbtypes.AccountDataInsert,
) error

func (*AccountDBEvCacheConsumer) OnInsertFilter ¶

func (s *AccountDBEvCacheConsumer) OnInsertFilter(
	msg *dbtypes.FilterInsert,
) error

func (*AccountDBEvCacheConsumer) OnInsertRoomTag ¶

func (s *AccountDBEvCacheConsumer) OnInsertRoomTag(
	msg *dbtypes.RoomTagInsert,
) error

func (*AccountDBEvCacheConsumer) OnMessage ¶

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

func (*AccountDBEvCacheConsumer) OnUpsertProfile ¶

func (s *AccountDBEvCacheConsumer) OnUpsertProfile(
	msg *dbtypes.ProfileInsert,
) error

func (*AccountDBEvCacheConsumer) OnUpsertUserInfo ¶

func (s *AccountDBEvCacheConsumer) OnUpsertUserInfo(
	msg *dbtypes.UserInfoInsert,
) error

func (*AccountDBEvCacheConsumer) Prepare ¶

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

func (*AccountDBEvCacheConsumer) SetPool ¶

func (s *AccountDBEvCacheConsumer) SetPool(pool PoolProviderInterface)

func (*AccountDBEvCacheConsumer) Start ¶

func (s *AccountDBEvCacheConsumer) Start()

type ConsumerInterface ¶

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

func NewAccountDBEvCacheConsumer ¶

func NewAccountDBEvCacheConsumer() ConsumerInterface

func NewDeviceDBEvCacheConsumer ¶

func NewDeviceDBEvCacheConsumer() ConsumerInterface

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

func NewE2EDBEvCacheConsumer ¶

func NewE2EDBEvCacheConsumer() ConsumerInterface

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

func NewPresenceDBEvCacheConsumer ¶

func NewPresenceDBEvCacheConsumer() ConsumerInterface

func NewPushDBEvCacheConsumer ¶

func NewPushDBEvCacheConsumer() ConsumerInterface

func NewRoomDBEvCacheConsumer ¶

func NewRoomDBEvCacheConsumer() ConsumerInterface

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

type DBEventCacheConsumer ¶

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

DBEventDataConsumer consumes db events for cache writer.

func NewDBEventCacheConsumer ¶

func NewDBEventCacheConsumer(
	cfg *config.Dendrite,
) *DBEventCacheConsumer

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

func (*DBEventCacheConsumer) OnMessage ¶

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

func (*DBEventCacheConsumer) Pool ¶

func (s *DBEventCacheConsumer) Pool() *redis.Pool

func (*DBEventCacheConsumer) Start ¶

func (s *DBEventCacheConsumer) Start() error

Start consuming from room servers

type DeviceDBEvCacheConsumer ¶

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

func (*DeviceDBEvCacheConsumer) OnMessage ¶

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

func (*DeviceDBEvCacheConsumer) Prepare ¶

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

func (*DeviceDBEvCacheConsumer) SetPool ¶

func (s *DeviceDBEvCacheConsumer) SetPool(pool PoolProviderInterface)

func (*DeviceDBEvCacheConsumer) Start ¶

func (s *DeviceDBEvCacheConsumer) Start()

type E2EDBEvCacheConsumer ¶

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

func (*E2EDBEvCacheConsumer) OnMessage ¶

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

func (*E2EDBEvCacheConsumer) Prepare ¶

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

func (*E2EDBEvCacheConsumer) SetPool ¶

func (s *E2EDBEvCacheConsumer) SetPool(pool PoolProviderInterface)

func (*E2EDBEvCacheConsumer) Start ¶

func (s *E2EDBEvCacheConsumer) Start()

type PoolProviderInterface ¶

type PoolProviderInterface interface {
	Pool() *redis.Pool
}

type PresenceDBEvCacheConsumer ¶

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

func (*PresenceDBEvCacheConsumer) OnInsertPresences ¶

func (s *PresenceDBEvCacheConsumer) OnInsertPresences(
	msg *dbtypes.PresencesInsert,
) error

func (*PresenceDBEvCacheConsumer) OnMessage ¶

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

func (*PresenceDBEvCacheConsumer) Prepare ¶

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

func (*PresenceDBEvCacheConsumer) SetPool ¶

func (s *PresenceDBEvCacheConsumer) SetPool(pool PoolProviderInterface)

func (*PresenceDBEvCacheConsumer) Start ¶

func (s *PresenceDBEvCacheConsumer) Start()

type PushDBEvCacheConsumer ¶

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

DBEventDataConsumer consumes db events for roomserver.

func (*PushDBEvCacheConsumer) OnMessage ¶

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

func (*PushDBEvCacheConsumer) Prepare ¶

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

func (*PushDBEvCacheConsumer) SetPool ¶

func (s *PushDBEvCacheConsumer) SetPool(pool PoolProviderInterface)

func (*PushDBEvCacheConsumer) Start ¶

func (s *PushDBEvCacheConsumer) Start()

type RoomDBEvCacheConsumer ¶

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

DBEventDataConsumer consumes db events for roomserver.

func (*RoomDBEvCacheConsumer) OnMessage ¶

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

func (*RoomDBEvCacheConsumer) Prepare ¶

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

todo set db

func (*RoomDBEvCacheConsumer) SetPool ¶

func (s *RoomDBEvCacheConsumer) SetPool(pool PoolProviderInterface)

func (*RoomDBEvCacheConsumer) Start ¶

func (s *RoomDBEvCacheConsumer) Start()

Start consuming from room servers

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL