message

Dec 19, 2023

Changes in this version

+ type CompressedService struct

+ Identifier []byte

+ Metadata []byte

+ Tags []string

+ func (cs CompressedService) ForMe(pickup *id.ID, contents, hash []byte) (tags []string, found bool, metadata []byte)

+ func (cs CompressedService) Hash(pickup *id.ID, contents []byte) ([]byte, error)

+ func (cs CompressedService) String() string

+ type CompressedServiceList map[id.ID][]CompressedService

+ func (csl CompressedServiceList) DeepCopy() CompressedServiceList

type Handler

+ DeleteCompressedService func(clientID *id.ID, toDelete CompressedService, processor Processor)

+ GetServices func() (ServiceList, CompressedServiceList)

+ UpsertCompressedService func(clientID *id.ID, newService CompressedService, response Processor)

type ServiceList

+ func (sl ServiceList) DeepCopy() ServiceList

type ServicesManager

+ func (sm *ServicesManager) DeleteCompressedService(clientID *id.ID, toDelete CompressedService, processor Processor)

+ func (sm *ServicesManager) GetServices() (ServiceList, CompressedServiceList)

+ func (sm *ServicesManager) UpsertCompressedService(clientID *id.ID, newService CompressedService, response Processor)

Jan 19, 2023

Changes in this version

+ type FallthroughManager struct

+ func (f *FallthroughManager) AddFallthrough(c *id.ID, p Processor)

+ func (f *FallthroughManager) RemoveFallthrough(c *id.ID)

type Handler

+ AddFallthrough func(c *id.ID, p Processor)

+ RemoveFallthrough func(c *id.ID)

Nov 10, 2022

Changes in this version

+ func RandomFingerprint(rng csprng.Source) format.Fingerprint

+ type Bundle struct

+ Finish func()

+ Identity receptionID.EphemeralIdentity

+ Messages []format.Message

+ Round id.Round

+ RoundInfo rounds.Round

+ type FingerprintsManager struct

+ func (f *FingerprintsManager) AddFingerprint(clientID *id.ID, fingerprint format.Fingerprint, mp Processor) error

+ func (f *FingerprintsManager) DeleteClientFingerprints(clientID *id.ID)

+ func (f *FingerprintsManager) DeleteFingerprint(clientID *id.ID, fingerprint format.Fingerprint)

+ type Handler interface

+ AddFingerprint func(clientID *id.ID, fingerprint format.Fingerprint, mp Processor) error

+ AddService func(clientID *id.ID, newService Service, response Processor)

+ CheckInProgressMessages func()

+ DeleteClientFingerprints func(clientID *id.ID)

+ DeleteClientService func(clientID *id.ID)

+ DeleteFingerprint func(clientID *id.ID, fingerprint format.Fingerprint)

+ DeleteService func(clientID *id.ID, toDelete Service, response Processor)

+ GetMessageReceptionChannel func() chan<- Bundle

+ StartProcesses func() stoppable.Stoppable

+ TrackServices func(triggerTracker ServicesTracker)

+ func NewHandler(param Params, kv *versioned.KV, events event.Reporter, standardID *id.ID) Handler

+ type MeteredCmixMessageBuffer struct

+ func LoadMeteredCmixMessageBuffer(kv *versioned.KV, key string) (*MeteredCmixMessageBuffer, error)

+ func NewMeteredCmixMessageBuffer(kv *versioned.KV, key string) (*MeteredCmixMessageBuffer, error)

+ func NewOrLoadMeteredCmixMessageBuffer(kv *versioned.KV, key string) (*MeteredCmixMessageBuffer, error)

+ func (mcmb *MeteredCmixMessageBuffer) Add(m format.Message, ri *pb.RoundInfo, identity receptionID.EphemeralIdentity) (uint, time.Time)

+ func (mcmb *MeteredCmixMessageBuffer) AddProcessing(m format.Message, ri *pb.RoundInfo, identity receptionID.EphemeralIdentity) (uint, time.Time)

+ func (mcmb *MeteredCmixMessageBuffer) Failed(m format.Message, ri *pb.RoundInfo, identity receptionID.EphemeralIdentity)

+ func (mcmb *MeteredCmixMessageBuffer) Next() (format.Message, *pb.RoundInfo, receptionID.EphemeralIdentity, bool)

+ func (mcmb *MeteredCmixMessageBuffer) Remove(m format.Message, ri *pb.RoundInfo, identity receptionID.EphemeralIdentity)

+ type Params struct

+ InProcessMessageWait time.Duration

+ MaxChecksInProcessMessage uint

+ MessageReceptionBuffLen uint

+ MessageReceptionWorkerPoolSize uint

+ RealtimeOnly bool

+ func GetDefaultParams() Params

+ func GetParameters(params string) (Params, error)

+ func (p *Params) UnmarshalJSON(data []byte) error

+ func (p Params) MarshalJSON() ([]byte, error)

+ type Processor interface

+ Process func(message format.Message, receptionID receptionID.EphemeralIdentity, ...)

+ type Service struct

+ Identifier []byte

+ Metadata []byte

+ Tag string

+ func GetDefaultService(recipient *id.ID) Service

+ func GetRandomService(rng csprng.Source) Service

+ func (si Service) ForMe(contents, hash []byte) bool

+ func (si Service) ForMeFromMessageHash(messageHash, hash []byte) bool

+ func (si Service) Hash(contents []byte) []byte

+ func (si Service) HashFromMessageHash(messageHash []byte) []byte

+ func (si Service) String() string

+ type ServiceList map[id.ID][]Service

+ func (sl ServiceList) MarshalJSON() ([]byte, error)

+ func (sl ServiceList) UnmarshalJSON(b []byte) error

+ type ServicesManager struct

+ func NewServices() *ServicesManager

+ func (sm *ServicesManager) AddService(clientID *id.ID, newService Service, response Processor)

+ func (sm *ServicesManager) DeleteClientService(clientID *id.ID)

+ func (sm *ServicesManager) DeleteService(clientID *id.ID, toDelete Service, processor Processor)

+ func (sm *ServicesManager) TrackServices(tracker ServicesTracker)

+ type ServicesTracker func(ServiceList)