Documentation
¶
Index ¶
- func JoinedHostsFromEvents(ctx context.Context, evs []gomatrixserverlib.PDU, ...) ([]types.JoinedHost, error)
- func NewKeyChangeConsumer(ctx context.Context, cfg *config.KeyServer, qm queueutil.QueueManager, ...) error
- func NewOutputPresenceConsumer(ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, ...) error
- func NewOutputReceiptConsumer(ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, ...) error
- func NewOutputRoomEventConsumer(ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, ...) error
- func NewOutputSendToDeviceConsumer(ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, ...) error
- func NewOutputTypingConsumer(ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, ...) error
- type KeyChangeConsumer
- type OutputPresenceConsumer
- type OutputReceiptConsumer
- type OutputRoomEventConsumer
- type OutputSendToDeviceConsumer
- type OutputTypingConsumer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func JoinedHostsFromEvents ¶
func JoinedHostsFromEvents(ctx context.Context, evs []gomatrixserverlib.PDU, rsAPI api.FederationRoomserverAPI) ([]types.JoinedHost, error)
JoinedHostsFromEvents turns a list of state events into a list of joined hosts. This errors if one of the events was invalid. It should be impossible for an invalid event to get this far in the pipeline.
func NewKeyChangeConsumer ¶
func NewKeyChangeConsumer( ctx context.Context, cfg *config.KeyServer, qm queueutil.QueueManager, queues *queue.OutgoingQueues, store storage.Database, rsAPI roomserverAPI.FederationRoomserverAPI, ) error
NewKeyChangeConsumer creates a new KeyChangeConsumer. Call Start() to begin consuming from key servers.
func NewOutputPresenceConsumer ¶
func NewOutputPresenceConsumer( ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, queues *queue.OutgoingQueues, store storage.Database, rsAPI roomserverAPI.FederationRoomserverAPI, ) error
NewOutputPresenceConsumer creates a new OutputPresenceConsumer. Call Start() to begin consuming events.
func NewOutputReceiptConsumer ¶
func NewOutputReceiptConsumer( ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, queues *queue.OutgoingQueues, store storage.Database, ) error
NewOutputReceiptConsumer creates a new OutputReceiptConsumer. Call Start() to begin consuming typing events.
func NewOutputRoomEventConsumer ¶
func NewOutputRoomEventConsumer( ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, am actorutil.ActorManager, queues *queue.OutgoingQueues, store storage.Database, rsAPI api.FederationRoomserverAPI, presenceClient presencev1connect.PresenceServiceClient, ) error
NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func NewOutputSendToDeviceConsumer ¶
func NewOutputSendToDeviceConsumer( ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, queues *queue.OutgoingQueues, store storage.Database, ) error
NewOutputSendToDeviceConsumer creates a new OutputSendToDeviceConsumer. Call Start() to begin consuming send-to-device events.
func NewOutputTypingConsumer ¶
func NewOutputTypingConsumer( ctx context.Context, cfg *config.FederationAPI, qm queueutil.QueueManager, queues *queue.OutgoingQueues, store storage.Database, ) error
NewOutputTypingConsumer creates a new OutputTypingConsumer. Call Start() to begin consuming typing events.
Types ¶
type KeyChangeConsumer ¶
type KeyChangeConsumer struct {
// contains filtered or unexported fields
}
KeyChangeConsumer consumes events that originate in key server.
type OutputPresenceConsumer ¶
type OutputPresenceConsumer struct {
// contains filtered or unexported fields
}
OutputPresenceConsumer consumes events that originate in the clientapi.
type OutputReceiptConsumer ¶
type OutputReceiptConsumer struct {
// contains filtered or unexported fields
}
OutputReceiptConsumer consumes events that originate in the clientapi.
type OutputRoomEventConsumer ¶
type OutputRoomEventConsumer struct {
// contains filtered or unexported fields
}
OutputRoomEventConsumer consumes events that originated in the room server.
func (*OutputRoomEventConsumer) HandleRoomEvent ¶ added in v0.6.21
func (s *OutputRoomEventConsumer) HandleRoomEvent(ctx context.Context, metadata map[string]string, message []byte) error
HandleRoomEvent is called when the federation server receives a new event from the room server output log. It is unsafe to call this with messages for the same room in multiple gorountines because updates it will likely fail with a types.EventIDMismatchError when it realises that it cannot update the room state using the deltas.
type OutputSendToDeviceConsumer ¶
type OutputSendToDeviceConsumer struct {
// contains filtered or unexported fields
}
OutputSendToDeviceConsumer consumes events that originate in the clientapi.
type OutputTypingConsumer ¶
type OutputTypingConsumer struct {
// contains filtered or unexported fields
}
OutputTypingConsumer consumes events that originate in the clientapi.
Source Files