consumers

Documentation

Index

• type OutputReadUpdateConsumer
  • func NewOutputReadUpdateConsumer(process *process.ProcessContext, cfg *config.UserAPI, js nats.JetStreamContext, ...) *OutputReadUpdateConsumer
  • func (s *OutputReadUpdateConsumer) Start() error
• type OutputStreamEventConsumer
  • func NewOutputStreamEventConsumer(process *process.ProcessContext, cfg *config.UserAPI, js nats.JetStreamContext, ...) *OutputStreamEventConsumer
  • func (s *OutputStreamEventConsumer) Start() error

Types

type OutputReadUpdateConsumer

type OutputReadUpdateConsumer struct {
	ServerName gomatrixserverlib.ServerName
	// contains filtered or unexported fields
}

func NewOutputReadUpdateConsumer

func NewOutputReadUpdateConsumer(
	process *process.ProcessContext,
	cfg *config.UserAPI,
	js nats.JetStreamContext,
	store storage.Database,
	pgClient pushgateway.Client,
	userAPI uapi.UserInternalAPI,
	syncProducer *producers.SyncAPI,
) *OutputReadUpdateConsumer

func (*OutputReadUpdateConsumer) Start

func (s *OutputReadUpdateConsumer) Start() error

type OutputStreamEventConsumer

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

func NewOutputStreamEventConsumer

func NewOutputStreamEventConsumer(
	process *process.ProcessContext,
	cfg *config.UserAPI,
	js nats.JetStreamContext,
	store storage.Database,
	pgClient pushgateway.Client,
	userAPI api.UserInternalAPI,
	rsAPI rsapi.UserRoomserverAPI,
	syncProducer *producers.SyncAPI,
) *OutputStreamEventConsumer

func (*OutputStreamEventConsumer) Start

func (s *OutputStreamEventConsumer) Start() error