logstream

Documentation

Index

• Constants
• Variables
• type ReplicationEvent
  • func (e *ReplicationEvent[T]) Marshal() ([]byte, error)
  • func (e *ReplicationEvent[T]) Unmarshal(data []byte) error
• type Replicator
  • func NewReplicator(snapshot snapshot.NatsSnapshot) (*Replicator, error)
  • func (r *Replicator) ForceSaveSnapshot()
  • func (r *Replicator) LastSaveSnapshotTime() time.Time
  • func (r *Replicator) Listen(shardID uint64, callback func(payload []byte) error) error
  • func (r *Replicator) Publish(hash uint64, payload []byte) error
  • func (r *Replicator) ReloadCertificates() error
  • func (r *Replicator) RestoreSnapshot() error
  • func (r *Replicator) SaveSnapshot()

Constants

const SnapshotShardID = uint64(1)

Variables

var ErrNotInitialized = errors.New("not initialized")

var SnapshotLeaseTTL = 10 * time.Second

Types

type ReplicationEvent

type ReplicationEvent[T core.ReplicableEvent[T]] struct {
	FromNodeId uint64
	Payload    T
}

func (*ReplicationEvent[T]) Marshal

func (e *ReplicationEvent[T]) Marshal() ([]byte, error)

func (*ReplicationEvent[T]) Unmarshal

func (e *ReplicationEvent[T]) Unmarshal(data []byte) error

type Replicator

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

func NewReplicator

func NewReplicator(
	snapshot snapshot.NatsSnapshot,
) (*Replicator, error)

func (*Replicator) ForceSaveSnapshot

func (r *Replicator) ForceSaveSnapshot()

func (*Replicator) LastSaveSnapshotTime

func (r *Replicator) LastSaveSnapshotTime() time.Time

func (*Replicator) Listen

func (r *Replicator) Listen(shardID uint64, callback func(payload []byte) error) error

func (*Replicator) Publish

func (r *Replicator) Publish(hash uint64, payload []byte) error

func (*Replicator) ReloadCertificates

func (r *Replicator) ReloadCertificates() error

func (*Replicator) RestoreSnapshot

func (r *Replicator) RestoreSnapshot() error

func (*Replicator) SaveSnapshot

func (r *Replicator) SaveSnapshot()