Versions in this module Expand all Collapse all v0 v0.14.0 Dec 18, 2024 Changes in this version + const MaximumMissingProcessingTime + type Inputer struct + ACLs *acls.ServerACLs + Cfg *config.RoomServer + DB storage.RoomDatabase + Durable nats.SubOpt + EnableMetrics bool + FSAPI fedapi.RoomserverFederationAPI + InputRoomEventTopic string + JetStream nats.JetStreamContext + KeyRing gomatrixserverlib.JSONVerifier + NATSClient *nats.Conn + OutputProducer *producers.RoomEventProducer + ProcessContext *process.ProcessContext + Queryer *query.Queryer + RSAPI api.RoomserverInternalAPI + ServerName spec.ServerName + SigningIdentity func(ctx context.Context, roomID spec.RoomID, senderID spec.UserID) (fclient.SigningIdentity, error) + UserAPI userapi.RoomserverUserAPI + func (r *Inputer) InputRoomEvents(ctx context.Context, request *api.InputRoomEventsRequest, ...) + func (r *Inputer) Start() error