Documentation ¶
Index ¶
- type OutgoingQueues
- func (oqs *OutgoingQueues) RetryServer(srv gomatrixserverlib.ServerName)
- func (oqs *OutgoingQueues) SendEDU(e *gomatrixserverlib.EDU, origin gomatrixserverlib.ServerName, ...) error
- func (oqs *OutgoingQueues) SendEvent(ev *gomatrixserverlib.HeaderedEvent, origin gomatrixserverlib.ServerName, ...) error
- type SigningInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OutgoingQueues ¶
type OutgoingQueues struct {
// contains filtered or unexported fields
}
OutgoingQueues is a collection of queues for sending transactions to other matrix servers
func NewOutgoingQueues ¶
func NewOutgoingQueues( db storage.Database, disabled bool, origin gomatrixserverlib.ServerName, client *gomatrixserverlib.FederationClient, rsAPI api.RoomserverInternalAPI, statistics *statistics.Statistics, signing *SigningInfo, ) *OutgoingQueues
NewOutgoingQueues makes a new OutgoingQueues
func (*OutgoingQueues) RetryServer ¶
func (oqs *OutgoingQueues) RetryServer(srv gomatrixserverlib.ServerName)
RetryServer attempts to resend events to the given server if we had given up.
func (*OutgoingQueues) SendEDU ¶
func (oqs *OutgoingQueues) SendEDU( e *gomatrixserverlib.EDU, origin gomatrixserverlib.ServerName, destinations []gomatrixserverlib.ServerName, ) error
SendEDU sends an EDU event to the destinations.
func (*OutgoingQueues) SendEvent ¶
func (oqs *OutgoingQueues) SendEvent( ev *gomatrixserverlib.HeaderedEvent, origin gomatrixserverlib.ServerName, destinations []gomatrixserverlib.ServerName, ) error
SendEvent sends an event to the destinations
type SigningInfo ¶
type SigningInfo struct { ServerName gomatrixserverlib.ServerName KeyID gomatrixserverlib.KeyID PrivateKey ed25519.PrivateKey }
TODO: Move this somewhere useful for other components as we often need to ferry these 3 variables around together
Click to show internal directories.
Click to hide internal directories.