forward

type AdoptArgs struct{}

type Call struct {
	Kind  Kind
	User  string
	Group string
	Args  any
}

type Clock interface {
	RedisTimeMS(ctx context.Context) (int64, error)
}

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

type FreshStateArgs struct {
	VehicleID string `json:"vehicle_id"`
	MaxAgeMS  int64  `json:"max_age_ms"`
}

type Keys struct{ Prefix string }

type Kind string

type LeaseForgetter interface{ Forget(group string) }

type LeaseOwner struct {
	Found     bool
	Pod       string
	Epoch     int64
	ExpiresAt time.Time
}

type LeaseView interface {
	// Owner is the current owner of the group, from the lease row.
	Owner(ctx context.Context, group string) (LeaseOwner, error)
	// Held reports whether this pod holds the group, and at which epoch.
	Held(group string) (epoch int64, ok bool)
	// PastDeadline reports whether this pod's local lease deadline has passed (the pod must stop acting).
	PastDeadline() bool
}

type LocalLeases interface {
	GroupTokens() []leases.GroupToken
	PastLocalDeadline() bool
}

type Metrics struct {
	Total      *prometheus.CounterVec   // rivolt_rivian_forward_total{kind,outcome}
	Seconds    *prometheus.HistogramVec // rivolt_rivian_forward_seconds{kind}
	QueueDepth prometheus.Gauge         // rivolt_forward_queue_depth (this pod's owner list, owner loop)
	OwnerReady prometheus.Gauge         // rivolt_forward_owner_ready (1 while this pod's owner loop is running and marked ready)
}

type NetworkPref struct {
	NetworkID  string `json:"network_id"`
	Preference int    `json:"preference"`
}

type OTANotesArgs struct {
	VehicleID string `json:"vehicle_id"`
	ReleaseID string `json:"release_id,omitempty"`
}

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

type OwnerConfig struct {
	Pod     string
	Keys    Keys
	Signer  *Signer
	Redis   redis.Cmdable
	Leases  LeaseView
	Runner  Runner
	Metrics *Metrics // nil: no metrics
	Logger  *slog.Logger

	Workers  int           // concurrent kinds on this pod (default 8)
	PerUser  int           // concurrent kinds for one user (default 2)
	BlockFor time.Duration // BLPOP timeout (default 2 s, so shutdown is prompt)
}

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

type PlanLegsArgs struct {
	VehicleID               string        `json:"vehicle_id"`
	StartingSoC             float64       `json:"starting_soc"`
	StartingRangeMeters     float64       `json:"starting_range_meters"`
	OriginBearing           float64       `json:"origin_bearing"`
	Waypoints               []Waypoint    `json:"waypoints"`
	TargetArrivalSocPercent *float64      `json:"target_arrival_soc_percent,omitempty"`
	NetworkPreferences      []NetworkPref `json:"network_preferences,omitempty"`
	DriveMode               string        `json:"drive_mode,omitempty"`
	HasAdapter              *bool         `json:"has_adapter,omitempty"`
	RoutePreferences        *RoutePrefs   `json:"route_preferences,omitempty"`
	DepartureTimeMS         int64         `json:"departure_time_ms,omitempty"`
}

type Reply struct {
	V      int             `json:"v"`
	ID     string          `json:"id"`
	User   string          `json:"user"`
	OK     bool            `json:"ok"`
	Status int             `json:"status"`
	Class  string          `json:"class,omitempty"`
	Body   json.RawMessage `json:"body,omitempty"`
	Sig    string          `json:"sig"`
}

type Request struct {
	V         int             `json:"v"`
	ID        string          `json:"id"`
	User      string          `json:"user"`
	Group     string          `json:"group"`
	Epoch     int64           `json:"epoch"`
	Kind      Kind            `json:"kind"`
	Args      json.RawMessage `json:"args"`
	ExpiresMS int64           `json:"expires_ms"`
	Sig       string          `json:"sig"`
}

type RequesterConfig struct {
	Pod     string // this pod (the lease holder name)
	Keys    Keys
	Signer  *Signer
	Redis   redis.Cmdable
	Leases  LeaseView
	Metrics *Metrics
	Logger  *slog.Logger
	// Timeouts overrides a kind's wait (tests). Zero or missing: the kind's own.
	Timeouts map[Kind]time.Duration
	// Jitter is the pause before the one retry after a `busy` reply (default 200-500 ms).
	Jitter func() time.Duration
	// Acquire takes a group whose lease is absent or expired, by the database clock, and reports whether this pod now holds it (single-owner
	// M4-2, the acquire half). Nil, or AcquireOnRequest false: the M3 behaviour, the fail-soft cases run the call here.
	Acquire func(ctx context.Context, group string) (bool, error)
	// AcquireOnRequest (RIVOLT_ACQUIRE_ON_REQUEST) replaces the fail-soft "run it here" with acquire-or-503: the only trigger for an
	// acquire is a lease row absent or expired; a live lease (owner not ready, Redis down, busy, moved to someone) is a 503, never an acquire.
	AcquireOnRequest bool
	// Token returns this pod's fence token for the group, after an acquire (the lease store's view). The call that runs as the new owner carries
	// it in its context, so the owner guard and the permit see the new epoch. Nil: the context is unchanged.
	Token func(group string) (fence.Token, bool)
}

type Result struct {
	Status int
	Class  string
	Body   json.RawMessage
}

type RoutePrefs struct {
	AvoidTolls    bool `json:"avoid_tolls"`
	AvoidFerries  bool `json:"avoid_ferries"`
	AvoidHighways bool `json:"avoid_highways"`
}

type Runner interface {
	Run(ctx context.Context, kind Kind, user, group string, args any) (Result, error)
}

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

type Spec struct {
	// Timeout bounds the owner's work and the requester's wait. It stays at least 2 s under the handler deadline of every route that
	// forwards the kind (the API's 30 s group deadline; see TestForwardKindTimeoutsFitTheirRoutes), or the requester would be cut
	// off before it could answer or retry.
	Timeout time.Duration
	// Retry says whether a timeout or a `moved` reply may be retried once (reads and version-CAS: yes; adopt: never).
	Retry bool
	// Validate strictly decodes the args (unknown fields rejected) and checks types, lengths and ranges. It returns the decoded
	// value on success.
	Validate func(args json.RawMessage) (any, error)
}

type Validatable interface {
	// contains filtered or unexported methods
}

type Waypoint struct {
	Latitude     float64 `json:"lat"`
	Longitude    float64 `json:"lon"`
	WaypointType string  `json:"type,omitempty"`
	EntityID     string  `json:"entity_id,omitempty"`
}