autoscale

type Action string

type ActionExecutor interface {
	Execute(context.Context, string, routing.Route, Decision) (Execution, error)
}

type Activation struct {
	Workload orchestrator.Status `json:"workload"`
	Route    routing.Route       `json:"route"`
}

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

type ActiveStore interface {
	PolicyStore
	ActiveStates() (map[string]State, error)
}

type Compatibility struct {
	Compatible bool                  `json:"compatible"`
	Service    string                `json:"service,omitempty"`
	Image      string                `json:"image,omitempty"`
	Blockers   []string              `json:"blockers"`
	Warnings   []string              `json:"warnings"`
	Services   []string              `json:"services"`
	Workload   *models.ScalingConfig `json:"workload,omitempty"`
}

type Decision struct {
	Action    Action                 `json:"action"`
	Replicas  int                    `json:"replicas,omitempty"`
	Resources orchestrator.Resources `json:"resources,omitempty"`
	Reason    string                 `json:"reason"`
}

type EventPublisher interface {
	Publish(events.Event) (events.IngestResult, error)
}

type Execution struct {
	Decision Decision            `json:"decision"`
	Status   orchestrator.Status `json:"status"`
	Route    routing.Route       `json:"route,omitempty"`
	Pending  bool                `json:"pending"`
}

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

type Input struct {
	Now               time.Time
	Replicas          int
	CPUPercent        float64
	MemoryPercent     float64
	Diagnosis         capacity.Diagnosis
	FleetOffer        capacity.Offer
	RequiresFleet     bool
	CurrentResources  orchestrator.Resources
	SuggestedResource orchestrator.Resources
}

type Policy struct {
	Enabled            bool          `json:"enabled"`
	MinReplicas        int           `json:"min_replicas"`
	MaxReplicas        int           `json:"max_replicas"`
	ScaleUpPercent     float64       `json:"scale_up_percent"`
	ScaleDownPercent   float64       `json:"scale_down_percent"`
	ScaleUpWindows     int           `json:"scale_up_windows"`
	ScaleDownWindows   int           `json:"scale_down_windows"`
	Cooldown           time.Duration `json:"cooldown"`
	AllowFleetCapacity bool          `json:"allow_fleet_capacity"`
}

type PolicyStore interface {
	Policy(string) (Policy, error)
	State(string) (State, error)
	SetState(string, State) error
}

type ReconcileResult struct {
	State     State      `json:"state"`
	Decision  Decision   `json:"decision"`
	Execution *Execution `json:"execution,omitempty"`
}

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

type RuntimeFactory interface {
	Build(context.Context, string, State) (RuntimeSession, error)
}

type RuntimeSession struct {
	Input    Input
	Executor ActionExecutor
	Close    func() error
}

type ServiceStopper interface {
	StopService(string, string) (string, error)
}

type ServiceStopperFunc func(string, string) (string, error)

type State struct {
	HighWindows int                     `json:"high_windows"`
	LowWindows  int                     `json:"low_windows"`
	LastAction  time.Time               `json:"last_action,omitempty"`
	Active      bool                    `json:"active"`
	Provider    orchestrator.ProviderID `json:"provider,omitempty"`
	Service     string                  `json:"service,omitempty"`
	Replicas    int                     `json:"replicas,omitempty"`
	Route       routing.Route           `json:"route,omitempty"`
}

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

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