logstream

package

v0.6.0-alpha.1 Latest Latest Go to latest Published: Oct 5, 2022 License: MIT Imports: 7 Imported by: 0

Details

View Source

const DefaultUrl = nats.DefaultURL

View Source

const NodeNamePrefix = "marmot-node"

View Source

var EntryReplicas = 1

View Source

var MaxLogEntries = int64(1024)

View Source

var SnapshotShardID = uint64(1)

View Source

var StreamNamePrefix = "marmot-changes"

View Source

var SubjectPrefix = "marmot-change-log"

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()