consumers

Documentation

Index

• type DeviceListUpdateConsumer
  • func NewDeviceListUpdateConsumer(process *process.ProcessContext, cfg *config.KeyServer, ...) *DeviceListUpdateConsumer
  • func (t *DeviceListUpdateConsumer) 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