RoutingModel (Proxy runtime 0.23.0 API)

All Superinterfaces:: AutoCloseable

All Known Implementing Classes:: DirectRouting, DynamicRouting

public sealed interface RoutingModel extends AutoCloseable permits DirectRouting, DynamicRouting

Sealed hierarchy representing how a virtual cluster reaches its upstream Kafka cluster(s).

DirectRouting — a single, statically-configured upstream cluster
DynamicRouting — one or more upstream clusters reached via a named router plugin

Implementations own the UpstreamClusterModel instances they hold and must release them via close() when the owning virtual cluster is stopped.

Method Summary

Modifier and Type

Method

Description

void

close()

UpstreamClusterModel

upstreamClusterFor(String routeName)

Returns the UpstreamClusterModel for the given route name

Method Details
- upstreamClusterFor
  
  UpstreamClusterModel upstreamClusterFor(String routeName)
  
  Returns the UpstreamClusterModel for the given route name
  
  Throws:
  
  NoUpstreamClusterForRouteException - if no upstream exists for this routeName
- close
  
  void close()
  
  Specified by:
  
  close in interface AutoCloseable