producers

Documentation

Index

• type KeyChange
  • func (p *KeyChange) DefaultPartition() int32
  • func (p *KeyChange) ProduceKeyChanges(keys []api.DeviceMessage) error

Types

type KeyChange

type KeyChange struct {
	Topic    string
	Producer sarama.SyncProducer
	DB       storage.Database
}

KeyChange produces key change events for the sync API and federation sender to consume

func (*KeyChange) DefaultPartition

func (p *KeyChange) DefaultPartition() int32

DefaultPartition returns the default partition this process is sending key changes to. NB: A keyserver MUST send key changes to only 1 partition or else query operations will become inconsistent. Partitions can be sharded (e.g by hash of user ID of key change) but then all keyservers must be queried to calculate the entire set of key changes between two sync tokens.

func (*KeyChange) ProduceKeyChanges

func (p *KeyChange) ProduceKeyChanges(keys []api.DeviceMessage) error

ProduceKeyChanges creates new change events for each key