recovery

Documentation

Index

• func MergePublications(recoveredPubs []*protocol.Publication, bufferedPubs []*protocol.Publication) ([]*protocol.Publication, bool)
• type PubSubSync
  • func NewPubSubSync() *PubSubSync
  • func (c *PubSubSync) LockBufferAndReadBuffered(channel string) []*protocol.Publication
  • func (c *PubSubSync) StartBuffering(channel string)
  • func (c *PubSubSync) StopBuffering(channel string)
  • func (c *PubSubSync) SyncPublication(channel string, pub *protocol.Publication, syncedFn func())

Functions

func MergePublications

func MergePublications(recoveredPubs []*protocol.Publication, bufferedPubs []*protocol.Publication) ([]*protocol.Publication, bool)

MergePublications allows to merge recovered pubs with buffered pubs collected during extracting recovered so result is ordered and with duplicates removed.

Types

type PubSubSync

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

PubSubSync wraps logic to synchronize recovery with PUB/SUB.

func NewPubSubSync

func NewPubSubSync() *PubSubSync

NewPubSubSync creates new PubSubSyncer.

func (*PubSubSync) LockBufferAndReadBuffered

func (c *PubSubSync) LockBufferAndReadBuffered(channel string) []*protocol.Publication

func (*PubSubSync) StartBuffering

func (c *PubSubSync) StartBuffering(channel string)

StartBuffering ...

func (*PubSubSync) StopBuffering

func (c *PubSubSync) StopBuffering(channel string)

StopBuffering ...

func (*PubSubSync) SyncPublication

func (c *PubSubSync) SyncPublication(channel string, pub *protocol.Publication, syncedFn func())

SyncPublication ...