consumers

Documentation

Index

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

Types

type OutputCrossSigningKeyUpdateConsumer

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

func NewOutputCrossSigningKeyUpdateConsumer

func NewOutputCrossSigningKeyUpdateConsumer(
	process *process.ProcessContext,
	cfg *config.Dendrite,
	js nats.JetStreamContext,
	keyDB storage.Database,
	keyAPI api.KeyInternalAPI,
) *OutputCrossSigningKeyUpdateConsumer

func (*OutputCrossSigningKeyUpdateConsumer) Start

func (s *OutputCrossSigningKeyUpdateConsumer) Start() error