refcp

type AuditEntry struct {
	Time        time.Time
	Target      string
	Session     string
	Event       string
	Row         int
	Code        string
	Writer      protocol.WriterID
	Incarnation uint64
	Epoch       protocol.EpochID
	Seq         uint64
	Credential  string
	Alarm       bool
	Detail      string
}

type Boundary struct {
	Epoch    protocol.EpochID
	Seq      uint64
	Expected protocol.Hash
	Got      protocol.Hash
}

type EdgeChange struct {
	Epoch     protocol.EpochID
	Seq       uint64
	Time      time.Time
	Op        protocol.OpKind
	From      string
	Type      string
	To        string
	Attrs     map[string]any
	PrevAttrs map[string]any
	// Coalesced marks a folded range operation; Span is its unavailable interior.
	Coalesced bool
	Span      protocol.Span
}

type EpochView struct {
	ID         protocol.EpochID
	Owner      protocol.WriterID
	Open       bool
	Head       protocol.ChainPoint
	ClosedAt   uint64
	OpenReason string
	PrevEpoch  *protocol.EpochID
	PrevHead   *uint64
	Watermark  uint64
	Pending    []uint64
	Registered time.Time
}

type FindingState struct {
	FindingID     string
	DedupKey      string
	State         string
	Transition    string
	Severity      string
	RuleID        string
	BundleVersion string
	FirstSeen     uint64
	LastSeen      uint64
	EvalTime      uint64
	Count         uint64
	Epoch         protocol.EpochID
	Seq           uint64
}

type Notification struct {
	Target    string
	FindingID string
	DedupKey  string
	Severity  string
	EvalTime  uint64
	// Late marks a backlog notification decided from the lifecycle summary.
	Late bool
	// LateDelivered marks an evaluation time older than the late-delivery threshold on arrival.
	LateDelivered bool
	Source        string
	Epoch         protocol.EpochID
	Seq           uint64
	Time          time.Time
}

type Options struct {
	Now           func() time.Time
	LateThreshold time.Duration // default 15m
	WindowBytes   int64         // default protocol.DefaultWindowSize
	MaxFrameBytes int64         // default protocol.MaxFramePayload
	Conn          tunnel.ConnOptions
	Logger        *slog.Logger
}

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

type Stats struct {
	Committed   int
	Duplicates  int
	Rejected    int
	Divergences int
}