coord

type ChangeMsg struct {
	LSN     int64           `json:"l"`
	Ino     uint64          `json:"i"`
	Op      uint8           `json:"o"`
	Payload json.RawMessage `json:"p"`
}

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

type ChangelogScanner interface {
	ScanChangelog(ctx context.Context, after int64, fn func(meta.ChangeEntry) error) error
}

type EmbeddedConfig struct {
	NodeName string // server + cluster identity
	StoreDir string // JetStream file storage directory

	// Cluster wiring. Leave ClusterName empty for a standalone single node
	// (in-process, no network listener — ideal for tests and single-mount dev).
	// Set ClusterName + ListenHost/ListenPort + Routes to form a multi-node
	// JetStream cluster across mlfs daemons.
	ClusterName string
	ListenHost  string
	ListenPort  int      // client port; 0 picks a free port
	ClusterPort int      // route port
	Routes      []string // nats-route URLs of peer nodes

	ReadyTimeout time.Duration // default 10s
}

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

type LeaderMetrics interface {
	LeaderTransition(leader bool)
}

type LeaseMetrics interface {
	LeaseAcquired()
	LeaseLost()
}

type LockReaper interface {
	ListLockSIDs(ctx context.Context) ([]uint64, error)
	ClearLocksForSID(ctx context.Context, sid uint64) error
}

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

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

type OwnershipStore interface {
	AcquireOrResume(ctx context.Context, scopeKey, node string, ttlMs int64) (meta.Lease, bool, error)
	Refresh(ctx context.Context, scopeKey, node string, generation, ttlMs int64) (bool, error)
	ReleaseOwnership(ctx context.Context, scopeKey, node string, generation int64) (bool, error)
}

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