queue

Documentation

Index

• type OutgoingQueues
  • func NewOutgoingQueues(db storage.Database, process *process.ProcessContext, disabled bool, ...) *OutgoingQueues
  • func (oqs *OutgoingQueues) RetryServer(srv spec.ServerName, wasBlacklisted bool)
  • func (oqs *OutgoingQueues) SendEDU(e *gomatrixserverlib.EDU, origin spec.ServerName, ...) error
  • func (oqs *OutgoingQueues) SendEvent(ev *types.HeaderedEvent, origin spec.ServerName, ...) error

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,
	process *process.ProcessContext,
	disabled bool,
	origin spec.ServerName,
	client fclient.FederationClient,
	rsAPI api.FederationRoomserverAPI,
	statistics *statistics.Statistics,
	signing []*fclient.SigningIdentity,
) *OutgoingQueues

NewOutgoingQueues makes a new OutgoingQueues

func (*OutgoingQueues) RetryServer

func (oqs *OutgoingQueues) RetryServer(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(
	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(
	ev *types.HeaderedEvent, origin spec.ServerName,
	destinations []spec.ServerName,
) error

SendEvent sends an event to the destinations