changefeed

type Authorizer func(r *http.Request) (src, subscriber string, ok bool)

type Event struct {
	Kind   replicate.Kind  `json:"kind"`
	Src    string          `json:"src,omitempty"`
	Ver    uint64          `json:"ver,omitempty"`
	Key    string          `json:"key,omitempty"`
	Ad     json.RawMessage `json:"ad,omitempty"`
	Cursor []byte          `json:"cursor,omitempty"`
	TS     int64           `json:"ts,omitempty"`

	FromMillis int64 `json:"fromMillis,omitempty"`
	ToMillis   int64 `json:"toMillis,omitempty"`
}

type MemRegistry struct {
	LeaseTTL time.Duration
	// contains filtered or unexported fields
}

type PullConfig struct {
	BaseURL    string   // source root, e.g. "https://source:9200"
	Table      string   // source table/archive
	Subscriber string   // stable durable-subscription id (identifies this sink to the source)
	Src        string   // label recorded with events (defaults to Subscriber); passed as ?src=
	Constraint string   // optional server-side filter
	Project    []string // optional attribute projection

	Token      string        // bearer token
	AckEvery   time.Duration // ack + commit cadence; default 5s
	Backoff    time.Duration // reconnect backoff cap; default 30s
	HTTPClient *http.Client
}

type Registry interface {
	// Ack records that subscriber has durably persisted every record up to ackMillis on table.
	Ack(table, subscriber string, ackMillis int64, now time.Time)
	// Renew marks a subscriber live (an active subscribe stream) without moving its ack.
	Renew(table, subscriber string, now time.Time)
	// Floor returns the min ack over live subscribers of table and their count. With no live
	// subscribers, held is false (no retention hold from the feed).
	Floor(table string, now time.Time) (ackMillis int64, held bool)
	// Evict drops subscribers whose lease expired as of now; returns how many were dropped.
	Evict(now time.Time) int
	// Subscribers lists live subscribers of a table (for observability).
	Subscribers(table string, now time.Time) []SubStatus
}

type ServerOptions struct {
	Auth      Authorizer
	Registry  Registry      // records acks + leases, computes the GC floor; MemRegistry if nil
	Heartbeat time.Duration // SSE keep-alive comment cadence; default 15s
	AgeAttr   string        // the record attribute (unix seconds) stamped as Event.TS for GC; "" => no TS
}

type SubStatus struct {
	Subscriber string
	AckMillis  int64
	LastSeen   time.Time
}