logstream

package

v0.4.4-RC Latest Latest Go to latest Published: Sep 27, 2022 License: MIT Imports: 5 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 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) (*Replicator, error)

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

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