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 a new value schema is durably persisted.

  • Method Details

    • handleValueSchemaCreated

      void handleValueSchemaCreated(Store store, SchemaEntry schemaEntry)
      Fired after a new value schema is durably persisted. Not fired for duplicate schemas (i.e. when the same schema was already registered).
      Parameters:
      store - read-only snapshot of the store the schema belongs to
      schemaEntry - the schema that was just persisted (id + schema body)