cluster

type Control struct {
	Op        string
	SubID     string
	GatewayID string
	TenantID  string
	Query     livequery.LiveQuery
	Cursor    *livequery.Cursor // OpReanchor
	Limit     int               // OpReanchor
}

type ControlBus interface {
	SendControl(ctx context.Context, shardID string, c Control) error
	Control(ctx context.Context, shardID string) (<-chan Control, func(), error)
}

type DeltaBus interface {
	SendDelta(ctx context.Context, gatewayID string, d GatewayDelta) error
	Deltas(ctx context.Context, gatewayID string) (<-chan GatewayDelta, func(), error)
}

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

type GatewayDelta struct {
	SubID string
	Delta livequery.LiveDelta
}

type GatewayDeps struct {
	Members Membership
	Control ControlBus
	Delta   DeltaBus
}

type Membership interface {
	// Heartbeat refreshes this shard's TTL liveness key; call it on a ticker
	// at an interval well under the TTL.
	Heartbeat(ctx context.Context, shardID string) error
	// LiveShards returns the currently-live shard ids (unexpired heartbeats),
	// sorted, so Owner is stable across callers.
	LiveShards(ctx context.Context) ([]string, error)
	// Leave removes this shard's heartbeat immediately (graceful shutdown).
	Leave(ctx context.Context, shardID string) error
}

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

type ShardDeps struct {
	Engine   *livequery.Engine
	Registry livequery.SubscriptionRegistry
	Members  Membership
	Control  ControlBus
	Delta    DeltaBus
}

type ShardOptions struct {
	HeartbeatInterval time.Duration
	OwnershipInterval time.Duration
}