Struct CachedClient

backend/pkg/schema/client.go:46–61

CachedClient provides schema management with caching for efficient reuse. It retrieves and parses Avro, Protobuf, and JSON schemas from a Schema Registry, utilizing in-memory caches to minimize redundant fetches and compilations.

// It retrieves and parses Avro, Protobuf, and JSON schemas from a Schema Registry,
// utilizing in-memory caches to minimize redundant fetches and compilations.
type CachedClient struct {
	schemaClientFactory schema.ClientFactory
	// cacheNamespace returns a unique tenant identifier for resource cache isolation.
	// Used to generate cache keys like "{namespace}/avro-parsed-schemas/ids/{id}" for
	// multi-tenant environments where compiled schemas must be isolated per tenant.
	cacheNamespace func(context.Context) (string, error)

	standardImportsResolver func(protocompile.Resolver) protocompile.Resolver

	schemaCache        *cache.Cache[string, sr.Schema]
	subjectSchemaCache *cache.Cache[string, sr.SubjectSchema]

	avroSchemaCache  *cache.Cache[string, *avro.Schema]
	protoSchemaCache *cache.Cache[string, linker.Files]
	jsonSchemaCache  *cache.Cache[string, *jsonschema.Schema]
}

// Client defines the interface for a schema client implementation.
type Client interface {