Documentation
¶
Index ¶
- type OutgoingQueues
- func (oqs *OutgoingQueues) RetryServer(ctx context.Context, srv spec.ServerName, wasBlacklisted bool)
- func (oqs *OutgoingQueues) SendEDU(ctx context.Context, e *gomatrixserverlib.EDU, origin spec.ServerName, ...) error
- func (oqs *OutgoingQueues) SendEvent(ctx context.Context, ev *types.HeaderedEvent, origin spec.ServerName, ...) error
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( ctx context.Context, db storage.Database, disabled bool, origin spec.ServerName, client fclient.FederationClient, statistics *statistics.Statistics, signing []*fclient.SigningIdentity, ) *OutgoingQueues
NewOutgoingQueues makes a new OutgoingQueues
func (*OutgoingQueues) RetryServer ¶
func (oqs *OutgoingQueues) RetryServer(ctx context.Context, srv spec.ServerName, wasBlacklisted bool)
RetryServer attempts to resend events to the given server if we had given up.
func (*OutgoingQueues) SendEDU ¶
func (oqs *OutgoingQueues) SendEDU( ctx context.Context, e *gomatrixserverlib.EDU, origin spec.ServerName, destinations []spec.ServerName, ) error
SendEDU sends an EDU event to the destinations.
func (*OutgoingQueues) SendEvent ¶
func (oqs *OutgoingQueues) SendEvent( ctx context.Context, ev *types.HeaderedEvent, origin spec.ServerName, destinations []spec.ServerName, ) error
SendEvent sends an event to the destinations
Source Files
Click to show internal directories.
Click to hide internal directories.