modelinventory

type AcceptedInventory ¶

type AcceptedInventory interface {
	AcceptInventory(models []Model)
}

AcceptedInventory is optionally implemented by Provider values that maintain a local allowlist aligned with inventory accepted into the aggregate registry. Core calls AcceptInventory after publishing a registry snapshot: accepted backends receive their published models, and omitted backends receive a nil or empty slice (both must clear). An empty/nil slice must clear the allowlist.

type Discovery ¶

type Discovery struct {
	Status     DiscoveryStatus
	Source     Source
	ModelCount int
	ErrorCode  string
}

Discovery is protocol-neutral per-inventory discovery metadata.

func DiscoveryFromLoadError(err error) Discovery

func DiscoveryFromSnapshot(snap Snapshot) Discovery

type DiscoveryStatus ¶

type DiscoveryStatus string

DiscoveryStatus is protocol-neutral inventory discovery outcome for one backend instance.

const (
	DiscoveryStatusOK          DiscoveryStatus = "ok"
	DiscoveryStatusEmpty       DiscoveryStatus = "empty"
	DiscoveryStatusUnavailable DiscoveryStatus = "unavailable"
	DiscoveryStatusCached      DiscoveryStatus = "cached"
)

type ErrorProvider ¶

type ErrorProvider struct {
	Err error
}

func (p ErrorProvider) LoadModels(ctx context.Context) (Snapshot, error)

func (p ErrorProvider) StaticInventory() bool

type Model ¶

type Model struct {
	CanonicalID string
	NativeID    string
	DisplayName string
}

type OperationalError ¶

type OperationalError struct {
	Code string
	Err  error
}

OperationalError marks a fail-soft inventory load failure. Aggregators omit the backend without aborting unrelated successful inventories.

func (e *OperationalError) Error() string

func (e *OperationalError) Operational() bool

func (e *OperationalError) Unwrap() error

type Provider ¶

type Provider interface {
	LoadModels(ctx context.Context) (Snapshot, error)
}

Provider loads model inventory for one configured backend instance.

type Snapshot ¶

type Snapshot struct {
	Source   Source
	LoadedAt time.Time
	Models   []Model
	Warnings []string
}

type Source ¶

type Source string

const (
	SourceUnknown       Source = ""
	SourceRemote        Source = "remote"
	SourceStaticFile    Source = "static_file"
	SourceStaticInline  Source = "static_inline"
	SourceStaticBuiltin Source = "static_builtin"
)

type StaticInventory ¶

type StaticInventory interface {
	StaticInventory() bool
}

StaticInventory marks providers whose inventory is local and does not require periodic remote refresh.

type StaticProvider ¶

type StaticProvider struct {
	Source   Source
	LoadedAt time.Time
	Models   []Model
	Warnings []string
}

StaticProvider returns a fixed inventory snapshot. Models and Warnings slices are treated as immutable after construction; LoadModels returns them without cloning. Callers must not mutate the returned Snapshot slices.

func (p StaticProvider) LoadModels(ctx context.Context) (Snapshot, error)

func (p StaticProvider) StaticInventory() bool