logstream

package

v0.6.0-beta.3 Latest Latest Go to latest Published: Oct 10, 2022 License: MIT Imports: 8 Imported by: 0

Details

View Source

const NodeNamePrefix = "marmot-node"

View Source

const SnapshotShardID = uint64(1)

This section is empty.

This section is empty.

type ReplicationEvent[T any] struct {
	FromNodeId uint64
	Payload    *T
}

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

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

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

func NewReplicator(
	nodeID uint64,
	natsServer string,
	shards uint64,
	compress bool,
	snapshot snapshot.NatsSnapshot,
) (*Replicator, error)

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

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

func (r *Replicator) RestoreSnapshot() error

func (r *Replicator) SaveSnapshot()