consumers

package

v0.11.0 Latest Latest Go to latest Published: Oct 16, 2025 License: Apache-2.0 Imports: 30 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/antinvestor/matrix

Links

Open Source Insights

Documentation ¶

Index ¶

func NewDeviceListUpdateConsumer(ctx context.Context, cfg *config.UserAPI, qm queueutil.QueueManager, ...) error
func NewOutputReceiptEventConsumer(ctx context.Context, cfg *config.UserAPI, qm queueutil.QueueManager, ...) error
func NewOutputRoomEventConsumer(ctx context.Context, cfg *config.UserAPI, qm queueutil.QueueManager, ...) error
func NewSigningKeyUpdateConsumer(ctx context.Context, cfg *config.UserAPI, qm queueutil.QueueManager, ...) error
type DeviceListUpdateConsumer
- func (t *DeviceListUpdateConsumer) Handle(ctx context.Context, metadata map[string]string, message []byte) error
type OutputReceiptEventConsumer
- func (s *OutputReceiptEventConsumer) Handle(ctx context.Context, metadata map[string]string, message []byte) error
type OutputRoomEventConsumer
- func (s *OutputRoomEventConsumer) Handle(ctx context.Context, metadata map[string]string, _ []byte) error
- func (s *OutputRoomEventConsumer) HandleRoomEvent(ctx context.Context, metadata map[string]string, message []byte) error
type SigningKeyUpdateConsumer
- func (t *SigningKeyUpdateConsumer) Handle(ctx context.Context, metadata map[string]string, message []byte) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewDeviceListUpdateConsumer ¶

func NewDeviceListUpdateConsumer(
	ctx context.Context,
	cfg *config.UserAPI,
	qm queueutil.QueueManager,
	updater *internal.DeviceListUpdater,
) error

NewDeviceListUpdateConsumer creates a new DeviceListConsumer. Call Start() to begin consuming from key servers.

func NewOutputReceiptEventConsumer ¶

func NewOutputReceiptEventConsumer(
	ctx context.Context,
	cfg *config.UserAPI,
	qm queueutil.QueueManager,
	store storage.UserDatabase,
	syncProducer *producers.SyncAPI,
	pgClient pushgateway.Client,
) error

NewOutputReceiptEventConsumer creates a new OutputReceiptEventConsumer. Call Start() to begin consuming from the EDU server.

func NewOutputRoomEventConsumer ¶

func NewOutputRoomEventConsumer(
	ctx context.Context,
	cfg *config.UserAPI,
	qm queueutil.QueueManager,
	am actorutil.ActorManager,
	store storage.UserDatabase,
	pgClient pushgateway.Client,
	rsAPI rsapi.UserRoomserverAPI,
	syncProducer *producers.SyncAPI,
) error

func NewSigningKeyUpdateConsumer ¶

func NewSigningKeyUpdateConsumer(
	ctx context.Context,
	cfg *config.UserAPI,
	qm queueutil.QueueManager,
	userAPI api.UploadDeviceKeysAPI,
) error

NewSigningKeyUpdateConsumer creates a new SigningKeyUpdateConsumer. Call Start() to begin consuming from key servers.

Types ¶

type DeviceListUpdateConsumer ¶

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

DeviceListUpdateConsumer consumes device list updates that came in over federation.

func (*DeviceListUpdateConsumer) Handle ¶ added in v0.6.21

func (t *DeviceListUpdateConsumer) Handle(ctx context.Context, metadata map[string]string, message []byte) error

Handle is called in response to a message received on the key change events topic from the key server.

type OutputReceiptEventConsumer ¶

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

OutputReceiptEventConsumer consumes events that originated in the clientAPI.

func (*OutputReceiptEventConsumer) Handle ¶ added in v0.6.21

func (s *OutputReceiptEventConsumer) Handle(ctx context.Context, metadata map[string]string, message []byte) error

type OutputRoomEventConsumer ¶

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

func (*OutputRoomEventConsumer) Handle ¶ added in v0.6.21

func (s *OutputRoomEventConsumer) Handle(ctx context.Context, metadata map[string]string, _ []byte) error

func (*OutputRoomEventConsumer) HandleRoomEvent ¶ added in v0.6.21

func (s *OutputRoomEventConsumer) HandleRoomEvent(ctx context.Context, metadata map[string]string, message []byte) error

type SigningKeyUpdateConsumer ¶

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

SigningKeyUpdateConsumer consumes signing key updates that came in over federation.

func (*SigningKeyUpdateConsumer) Handle ¶ added in v0.6.21

func (t *SigningKeyUpdateConsumer) Handle(ctx context.Context, metadata map[string]string, message []byte) error

Handle is called in response to a message received on the signing key update events topic from the key server.

Source Files ¶

View all Source files

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