queue

Documentation

Index

• type OutgoingQueues
  • func NewOutgoingQueues(db storage.Database, process *process.ProcessContext, disabled bool, ...) *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

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 gomatrixserverlib.ServerName,
	client fedapi.FederationClient,
	rsAPI api.FederationRoomserverAPI,
	statistics *statistics.Statistics,
	signing map[gomatrixserverlib.ServerName]*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