Package com.linkedin.venice.meta

Interface ValueSchemaCreatedListener

public interface ValueSchemaCreatedListener
Notified by the schema repository when a new value schema is registered for a store. Mirrors the StoreDataChangedListener pattern on ReadOnlyStoreRepository.

The callback fires while the schema repository's write lock is held, so the persist order and the listener-dispatch order match. Implementations must therefore be non-blocking — a slow listener extends the lock window and stalls concurrent schema writes. Exceptions thrown from the callback are caught and logged; they do not prevent subsequent listeners from running.

The store snapshot is wrapped in ReadOnlyStore; mutation calls on it throw. Listeners that need migration awareness can inspect Store.isMigrationDuplicateStore() on the snapshot to filter source-vs-destination during a store migration.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    handleValueSchemaCreated(Store store, SchemaEntry schemaEntry)
    Fired after this repository call durably creates a new value schema.

  • Method Details

    • handleValueSchemaCreated

      void handleValueSchemaCreated(Store store, SchemaEntry schemaEntry)
      Fired after this repository call durably creates a new value schema. Not fired for idempotent re-registration, including explicit-ID registration when the same schema already exists or a concurrent writer creates it first. This is a local creation callback, not a notification for every addValueSchema invocation or a subscription to other writers' schema changes.
      Parameters:
      store - read-only snapshot of the store the schema belongs to
      schemaEntry - the schema that was just persisted (id + schema body)