Documentation
¶
Index ¶
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.
Types ¶
type KeyChangeConsumer ¶
type KeyChangeConsumer struct {
// contains filtered or unexported fields
}
KeyChangeConsumer consumes events that originate in key server.
func NewKeyChangeConsumer ¶
func NewKeyChangeConsumer( process *process.ProcessContext, cfg *config.KeyServer, js nats.JetStreamContext, queues *queue.OutgoingQueues, store storage.Database, rsAPI roomserverAPI.FederationRoomserverAPI, ) *KeyChangeConsumer
NewKeyChangeConsumer creates a new KeyChangeConsumer. Call Start() to begin consuming from key servers.
func (*KeyChangeConsumer) Start ¶
func (t *KeyChangeConsumer) Start() error
Start consuming from key servers
type OutputPresenceConsumer ¶
type OutputPresenceConsumer struct {
// contains filtered or unexported fields
}
OutputReceiptConsumer consumes events that originate in the clientapi.
func NewOutputPresenceConsumer ¶
func NewOutputPresenceConsumer( process *process.ProcessContext, cfg *config.FederationAPI, js nats.JetStreamContext, queues *queue.OutgoingQueues, store storage.Database, rsAPI roomserverAPI.FederationRoomserverAPI, ) *OutputPresenceConsumer
NewOutputPresenceConsumer creates a new OutputPresenceConsumer. Call Start() to begin consuming events.
func (*OutputPresenceConsumer) Start ¶
func (t *OutputPresenceConsumer) Start() error
Start consuming from the clientapi
type OutputReceiptConsumer ¶
type OutputReceiptConsumer struct {
// contains filtered or unexported fields
}
OutputReceiptConsumer consumes events that originate in the clientapi.
func NewOutputReceiptConsumer ¶
func NewOutputReceiptConsumer( process *process.ProcessContext, cfg *config.FederationAPI, js nats.JetStreamContext, queues *queue.OutgoingQueues, store storage.Database, ) *OutputReceiptConsumer
NewOutputReceiptConsumer creates a new OutputReceiptConsumer. Call Start() to begin consuming typing events.
func (*OutputReceiptConsumer) Start ¶
func (t *OutputReceiptConsumer) Start() error
Start consuming from the clientapi
type OutputRoomEventConsumer ¶
type OutputRoomEventConsumer struct {
// contains filtered or unexported fields
}
OutputRoomEventConsumer consumes events that originated in the room server.
func NewOutputRoomEventConsumer ¶
func NewOutputRoomEventConsumer( process *process.ProcessContext, cfg *config.FederationAPI, js nats.JetStreamContext, natsClient *nats.Conn, queues *queue.OutgoingQueues, store storage.Database, rsAPI api.FederationRoomserverAPI, ) *OutputRoomEventConsumer
NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.
func (*OutputRoomEventConsumer) Start ¶
func (s *OutputRoomEventConsumer) Start() error
Start consuming from room servers
type OutputSendToDeviceConsumer ¶
type OutputSendToDeviceConsumer struct {
// contains filtered or unexported fields
}
OutputSendToDeviceConsumer consumes events that originate in the clientapi.
func NewOutputSendToDeviceConsumer ¶
func NewOutputSendToDeviceConsumer( process *process.ProcessContext, cfg *config.FederationAPI, js nats.JetStreamContext, queues *queue.OutgoingQueues, store storage.Database, ) *OutputSendToDeviceConsumer
NewOutputSendToDeviceConsumer creates a new OutputSendToDeviceConsumer. Call Start() to begin consuming send-to-device events.
func (*OutputSendToDeviceConsumer) Start ¶
func (t *OutputSendToDeviceConsumer) Start() error
Start consuming from the client api
type OutputTypingConsumer ¶
type OutputTypingConsumer struct {
// contains filtered or unexported fields
}
OutputTypingConsumer consumes events that originate in the clientapi.
func NewOutputTypingConsumer ¶
func NewOutputTypingConsumer( process *process.ProcessContext, cfg *config.FederationAPI, js nats.JetStreamContext, queues *queue.OutgoingQueues, store storage.Database, ) *OutputTypingConsumer
NewOutputTypingConsumer creates a new OutputTypingConsumer. Call Start() to begin consuming typing events.
func (*OutputTypingConsumer) Start ¶
func (t *OutputTypingConsumer) Start() error
Start consuming from the clientapi
Source Files