consumers

Documentation

Index

• type DeviceListUpdateConsumer
  • func NewDeviceListUpdateConsumer(process *process.ProcessContext, cfg *config.KeyServer, ...) *DeviceListUpdateConsumer
  • func (t *DeviceListUpdateConsumer) Start() error
• type SigningKeyUpdateConsumer
  • func NewSigningKeyUpdateConsumer(process *process.ProcessContext, cfg *config.KeyServer, ...) *SigningKeyUpdateConsumer
  • func (t *SigningKeyUpdateConsumer) Start() error

Types

type DeviceListUpdateConsumer

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

DeviceListUpdateConsumer consumes device list updates that came in over federation.

func NewDeviceListUpdateConsumer

func NewDeviceListUpdateConsumer(
	process *process.ProcessContext,
	cfg *config.KeyServer,
	js nats.JetStreamContext,
	updater *internal.DeviceListUpdater,
) *DeviceListUpdateConsumer

NewDeviceListUpdateConsumer creates a new DeviceListConsumer. Call Start() to begin consuming from key servers.

func (*DeviceListUpdateConsumer) Start

func (t *DeviceListUpdateConsumer) Start() error

Start consuming from key servers

type SigningKeyUpdateConsumer

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

SigningKeyUpdateConsumer consumes signing key updates that came in over federation.

func NewSigningKeyUpdateConsumer

func NewSigningKeyUpdateConsumer(
	process *process.ProcessContext,
	cfg *config.KeyServer,
	js nats.JetStreamContext,
	keyAPI *internal.KeyInternalAPI,
) *SigningKeyUpdateConsumer

NewSigningKeyUpdateConsumer creates a new SigningKeyUpdateConsumer. Call Start() to begin consuming from key servers.

func (*SigningKeyUpdateConsumer) Start

func (t *SigningKeyUpdateConsumer) Start() error

Start consuming from key servers