schema

type APIFetcher struct {
	URL    string
	APIKey string
}

type Cache struct {
	TTL int `json:"ttl"`
}

type Changefeed struct {
	AppendFieldsToSubject []string `json:"appendFieldsToSubject"`
	PartitionKeys         []string `json:"partitionKeys"`
}

type Fetcher interface {
	FetchTable(ctx context.Context, table string) (io.ReadCloser, error)
}

type Model struct {
	Cache        *Cache      `json:"cache"`
	Changefeed   *Changefeed `json:"changefeed"`
	ModelVersion string      `json:"modelVersion"`
	Public       bool        `json:"public"`
}

type ModelRegistry interface {
	Get(ctx context.Context, table string) (*Model, error)
}

type ModelRegistryOption struct {
	ExpireAfter time.Duration
}

type Result struct {
	Success bool   `json:"success"`
	Model   *Model `json:"data"`
}

type WithOption func(opt *ModelRegistryOption)