Error returns a string detailing how many errors were contained within a configErrors type.

Queue up one or more database write operations within the provided function to be executed when it is safe to do so.

Add appends an error to the list of errors in this configErrors. It is a wrapper to the builtin append and hides pointers from the client code. This m

TODO(gene): unify simpleByteSender and QueueOut QueueOut attempts to send a SCM to a session; if the send buffer is full, time out is 1 second

Load the membership states required to notify users correctly.

simpleByteSender attempts to send a JSON to a connection, time out is 1 second

RoomInfo returns room information for the given room ID, or nil if there is no room.

PrevEventIDs returns the prev_event IDs of all backwards extremities, de-duplicated in a lexicographically sorted order.

MakeFedAPI makes an http.Handler that checks matrix federation authentication.

AddMigrations appends migrations to the list of migrations. Migrations are executed in the order they are added to the list. De-duplicates migrations

Up executes all migrations in order they were added.

checkURL verifies that the parameter is a valid URL

Split a key in KeyJSON into algorithm and key ID

4xx Errors

LatestPosition returns the latest stream position for this stream.

checkNotEmpty verifies the given value is not empty in the configuration. If it is, adds an error to the list.

filterConvertWildcardToSQL converts wildcards as defined in https://matrix.org/docs/spec/client_server/r0.3.0.html#post-matrix-client-r0-user-userid-f

SetDefaults sets default config values if they are not explicitly set.

ForServer returns server statistics for the given server name. If it does not exist, it will create empty statistics and return those.

High returns the high number of the range This represents the position the client is going towards and hence is inclusive.

RoomVersion implements types.RoomRecentEventsUpdater

TODO: TestMSC2836TerminatesLoops (short and long) TODO: TestMSC2836UnknownEventsSkipped TODO: TestMSC2836SkipEventIfNotInRoom

Advance will update the latest position of the stream based on an update and will wake callers waiting on StreamNotifyAfter.

Query the membership event for an user for a room.

ApplyUpdates applies any changes from the supplied StreamingToken. If the supplied streaming token contains any positions that are not 0, they are con

DatabaseConnection assists in setting up a database connection. It accepts the database properties and a new writer for the given component. If we're

Low returns the low number of the range. This represents the position the client already has and hence is exclusive.

Update changes values of user's subscription.

Failure marks a failure and starts backing off if needed. The next call to BackoffIfRequired will do the right thing after this. It will return the ti

JSONResponse maps error codes to suitable HTTP error codes, defaulting to 500.

QueryCurrentState retrieves the requested state events. If state events are not found, they will be missing from the response.

EventsFromIDs looks up the Events for a list of event IDs. Does not error if event was not found. Returns an error if the retrieval went wrong.

StoreKeyChange stores key change metadata and returns the device change ID which represents the position in the /sync stream for this device change. `

GetStateEvent returns the state event of a given type for a given room with a given state key If no event could be found, returns nil If there was an

IncrementalSync will update the response to include all updates between the from and to sync positions. It will always return immediately, making no c

LessThan returns true if this state entry is less than the other state entry. The ordering is arbitrary and is used to implement binary search and to

ListenAndServe registers a variable in JS-land with the given namespace. This variable is a function which JS-land can call to 'send' HTTP requests. T

Query a list of events by event ID.

SetupAndServeHTTP sets up the HTTP server to serve endpoints registered on ApiMux under /api/ and adds a prometheus handler under /metrics.

Username returns the user localpart/user_id in this request, if it exists.

_wakeupUsers will wake up the sync strems for all of the devices for all of the specified user IDs, and also the specified peekingDevices

checkPositive verifies the given value is positive (zero included) in the configuration. If it is not, adds an error to the list.

CompleteSync will update the response to include all updates as needed for a complete sync. It will always return immediately.