consumers

Documentation

Index

• type OutputRoomEventConsumer
  • func NewOutputRoomEventConsumer(process *process.ProcessContext, cfg *config.Dendrite, ...) *OutputRoomEventConsumer
  • func (s *OutputRoomEventConsumer) Start() error

Types

type OutputRoomEventConsumer

type OutputRoomEventConsumer struct {
	// contains filtered or unexported fields
}

OutputRoomEventConsumer consumes events that originated in the room server.

func NewOutputRoomEventConsumer

func NewOutputRoomEventConsumer(
	process *process.ProcessContext,
	cfg *config.Dendrite,
	kafkaConsumer sarama.Consumer,
	appserviceDB storage.Database,
	rsAPI api.RoomserverInternalAPI,
	workerStates []types.ApplicationServiceWorkerState,
) *OutputRoomEventConsumer

NewOutputRoomEventConsumer creates a new OutputRoomEventConsumer. Call Start() to begin consuming from room servers.

func (*OutputRoomEventConsumer) Start

func (s *OutputRoomEventConsumer) Start() error

Start consuming from room servers