agent

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

type CatalogRuntimeStatusProvider struct {
	CatalogDir string
}

type ExistingRuntimeProvider struct {
	CatalogDir string
	BaseURL    string
}

type LocalRuntimeProvider struct {
	CatalogDir       string
	DataDir          string
	RuntimeRoot      string
	ModelCacheDir    string
	ModelQuotaBytes  int64
	RuntimePublicKey ed25519.PublicKey
	RuntimeEnv       []string
	HTTPClient       *http.Client
	StartupTimeout   time.Duration
	ShutdownTimeout  time.Duration
	HealthInterval   time.Duration
	// contains filtered or unexported fields
}

type Options struct {
	DataDir           string
	CatalogDir        string
	CoordinatorURL    string
	ModelID           string
	AccessToken       string
	NodeID            string
	AgentVersion      string
	HeartbeatInterval time.Duration
	HTTPClient        *http.Client
	Validator         *protocol.Validator
	Telemetry         telemetry.Provider
	Runtime           RuntimeStatusProvider
	Backoff           session.Backoff
	Now               func() time.Time
	Output            io.Writer
	PrivateKey        ed25519.PrivateKey
	ScheduleFrom      string
	ScheduleUntil     string
	ScheduleLocation  *time.Location
	MaxTempC          int
	HardTempC         int
	ThermalHysteresis int
	PauseIdleTimeout  time.Duration
	ThermalPoll       time.Duration
}

type RuntimeStatus struct {
	ModelID     string
	RuntimeHash string
	ModelHash   string
	BaseURL     string
}

type RuntimeStatusProvider interface {
	Prepare(ctx context.Context, modelID string) (RuntimeStatus, error)
}