consumers

Documentation

Index

• type KeyChangeConsumer
  • func NewKeyChangeConsumer(cfg *config.KeyServer, kafkaConsumer sarama.Consumer, ...) *KeyChangeConsumer
  • func (t *KeyChangeConsumer) Start() error
• type OutputEDUConsumer
  • func NewOutputEDUConsumer(cfg *config.FederationSender, kafkaConsumer sarama.Consumer, ...) *OutputEDUConsumer
  • func (t *OutputEDUConsumer) Start() error
• type OutputRoomEventConsumer
  • func NewOutputRoomEventConsumer(cfg *config.FederationSender, kafkaConsumer sarama.Consumer, ...) *OutputRoomEventConsumer
  • func (s *OutputRoomEventConsumer) Start() error

Types

type KeyChangeConsumer

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

KeyChangeConsumer consumes events that originate in key server.

func NewKeyChangeConsumer

func NewKeyChangeConsumer(
	cfg *config.KeyServer,
	kafkaConsumer sarama.Consumer,
	queues *queue.OutgoingQueues,
	store storage.Database,
	rsAPI roomserverAPI.RoomserverInternalAPI,
) *KeyChangeConsumer

NewKeyChangeConsumer creates a new KeyChangeConsumer. Call Start() to begin consuming from key servers.

func (*KeyChangeConsumer) Start

func (t *KeyChangeConsumer) Start() error

Start consuming from key servers

type OutputEDUConsumer

type OutputEDUConsumer struct {
	ServerName        gomatrixserverlib.ServerName
	TypingTopic       string
	SendToDeviceTopic string
	// contains filtered or unexported fields
}

OutputEDUConsumer consumes events that originate in EDU server.

func NewOutputEDUConsumer

func NewOutputEDUConsumer(
	cfg *config.FederationSender,
	kafkaConsumer sarama.Consumer,
	queues *queue.OutgoingQueues,
	store storage.Database,
) *OutputEDUConsumer

NewOutputEDUConsumer creates a new OutputEDUConsumer. Call Start() to begin consuming from EDU servers.

func (*OutputEDUConsumer) Start

func (t *OutputEDUConsumer) Start() error

Start consuming from EDU servers

type OutputRoomEventConsumer

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

OutputRoomEventConsumer consumes events that originated in the room server.

func NewOutputRoomEventConsumer

func NewOutputRoomEventConsumer(
	cfg *config.FederationSender,
	kafkaConsumer sarama.Consumer,
	queues *queue.OutgoingQueues,
	store storage.Database,
	rsAPI api.RoomserverInternalAPI,
) *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