input

Documentation

Overview

Package input contains the code processes new room events

Index

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

Types

type Inputer

type Inputer struct {
	DB                   storage.Database
	Producer             sarama.SyncProducer
	ServerName           gomatrixserverlib.ServerName
	ACLs                 *acls.ServerACLs
	OutputRoomEventTopic string
	// 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) WriteOutputEvents

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

WriteOutputEvents implements OutputRoomEventWriter