input

Documentation

Overview

Package input contains the code processes new room events

Index

• Constants
• type Inputer
  • func (r *Inputer) InputRoomEvents(ctx context.Context, request *api.InputRoomEventsRequest, ...)
  • func (r *Inputer) Start() error
  • func (r *Inputer) WriteOutputEvents(roomID string, updates []api.OutputEvent) error

Constants

const MaximumMissingProcessingTime = time.Minute * 2

TODO: Does this value make sense?

Types

type Inputer

type Inputer struct {
	DB                   storage.Database
	JetStream            nats.JetStreamContext
	Durable              nats.SubOpt
	ServerName           gomatrixserverlib.ServerName
	FSAPI                fedapi.FederationInternalAPI
	KeyRing              gomatrixserverlib.JSONVerifier
	ACLs                 *acls.ServerACLs
	InputRoomEventTopic  string
	OutputRoomEventTopic string

	Queryer *query.Queryer
	// contains filtered or unexported fields
}

func (*Inputer) InputRoomEvents

func (r *Inputer) InputRoomEvents(
	ctx context.Context,
	request *api.InputRoomEventsRequest,
	response *api.InputRoomEventsResponse,
)

InputRoomEvents implements api.RoomserverInternalAPI

func (*Inputer) Start

func (r *Inputer) Start() error

onMessage is called when a new event arrives in the roomserver input stream.

func (*Inputer) WriteOutputEvents

func (r *Inputer) WriteOutputEvents(roomID string, updates []api.OutputEvent) error

WriteOutputEvents implements OutputRoomEventWriter