queue

Documentation

Index

• type OutgoingQueues
  • func NewOutgoingQueues(origin gomatrixserverlib.ServerName, fedClient *client.FedClientWrap, ...) *OutgoingQueues
  • func (oqs *OutgoingQueues) Release(ctx context.Context, roomID, domain string)
  • func (oqs *OutgoingQueues) RetrySend(ctx context.Context, roomID, domain string)
  • func (oqs *OutgoingQueues) SendEDU(ctx context.Context, partition int32, e *gomatrixserverlib.EDU, domain string, ...) error
  • func (oqs *OutgoingQueues) SendEvent(ctx context.Context, partition int32, ev *gomatrixserverlib.Event, ...) error
• type PartitionProcessor

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(
	origin gomatrixserverlib.ServerName,
	fedClient *client.FedClientWrap,
	rpcCli roomserverapi.RoomserverRPCAPI,
	cfg *config.Fed,
	feddomains *common.FedDomains,
	rsRepo *repos.RoomServerCurStateRepo,
	recRepo *fedrepos.SendRecRepo,
	partitionProcessor PartitionProcessor,
) *OutgoingQueues

NewOutgoingQueues makes a new OutgoingQueues

func (*OutgoingQueues) Release

func (oqs *OutgoingQueues) Release(ctx context.Context, roomID, domain string)

func (*OutgoingQueues) RetrySend

func (oqs *OutgoingQueues) RetrySend(ctx context.Context, roomID, domain string)

func (*OutgoingQueues) SendEDU

func (oqs *OutgoingQueues) SendEDU(
	ctx context.Context,
	partition int32,
	e *gomatrixserverlib.EDU,
	domain string,
	roomID string,
) error

SendEDU sends an EDU event to the destinations

func (*OutgoingQueues) SendEvent

func (oqs *OutgoingQueues) SendEvent(
	ctx context.Context,
	partition int32,
	ev *gomatrixserverlib.Event,
	domain string,
	roomID string,
) error

SendEvent sends an event to the destinations

type PartitionProcessor

type PartitionProcessor interface {
	AssignRoomPartition(ctx context.Context, roomID, domain string, retryTime time.Duration, retryInterval time.Duration) (*fedrepos.RecordItem, bool)
	TryAssignRoomPartition(ctx context.Context, roomID, domain string) (*fedrepos.RecordItem, bool)
	UnassignRoomPartition(ctx context.Context, roomID, domain string)
	OnRoomDomainRelease(ctx context.Context, origin, roomID, domain string)
	HasAssgined(ctx context.Context, roomID, domain string) (*fedrepos.RecordItem, bool)
}