queue

package

v0.0.0-...-3ba1864 Latest Latest Go to latest Published: Apr 22, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/daodst/chat

Documentation ¶

Index ¶

type OutgoingQueues
- func NewOutgoingQueues(db storage.Database, process *process.ProcessContext, disabled bool, ...) *OutgoingQueues
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,
	process *process.ProcessContext,
	disabled bool,
	origin gomatrixserverlib.ServerName,
	client fedapi.FederationClient,
	rsAPI api.FederationRoomserverAPI,
	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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL