Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.