Package | Description |
---|---|
org.apache.camel.cloud |
Camel cloud
|
org.apache.camel.impl.cloud |
Base classes and implementation for Camel Cloud
|
Modifier and Type | Method and Description |
---|---|
ServiceDefinition |
ServiceChooser.choose(List<ServiceDefinition> services)
Chooses one of the service to use
|
Modifier and Type | Method and Description |
---|---|
List<ServiceDefinition> |
ServiceFilter.apply(List<ServiceDefinition> services)
Chooses one of the service to use
|
List<ServiceDefinition> |
ServiceDiscovery.getServices(String name)
Gets the list of services.
|
Modifier and Type | Method and Description |
---|---|
T |
ServiceLoadBalancerFunction.apply(ServiceDefinition serviceDefinition) |
void |
ServiceRegistry.deregister(ServiceDefinition definition)
Remove the service definition.
|
default boolean |
ServiceDefinition.matches(ServiceDefinition other)
Check if a service definition matches.
|
void |
ServiceRegistry.register(ServiceDefinition definition)
Register the service definition.
|
Modifier and Type | Method and Description |
---|---|
List<ServiceDefinition> |
ServiceFilter.apply(List<ServiceDefinition> services)
Chooses one of the service to use
|
ServiceDefinition |
ServiceChooser.choose(List<ServiceDefinition> services)
Chooses one of the service to use
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultServiceDefinition |
Modifier and Type | Method and Description |
---|---|
ServiceDefinition |
DefaultServiceDefinition.Builder.build() |
ServiceDefinition |
RoundRobinServiceChooser.choose(List<ServiceDefinition> definitions) |
ServiceDefinition |
RandomServiceChooser.choose(List<ServiceDefinition> definitions) |
Modifier and Type | Method and Description |
---|---|
List<ServiceDefinition> |
CombinedServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
BlacklistServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
PassThroughServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
HealthyServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
DefaultServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
StaticServiceDiscovery.getServices(String name) |
List<ServiceDefinition> |
CombinedServiceDiscovery.getServices(String name) |
List<ServiceDefinition> |
DefaultServiceDiscovery.getServices(String name) |
List<ServiceDefinition> |
CachingServiceDiscovery.getServices(String name) |
static Stream<? extends ServiceDefinition> |
DefaultServiceDefinition.parse(String serverString) |
Modifier and Type | Method and Description |
---|---|
void |
StaticServiceDiscovery.addServer(ServiceDefinition server)
Add a server to the known list of servers.
|
void |
BlacklistServiceFilter.addServer(ServiceDefinition server)
Add a server to the known list of servers.
|
static StaticServiceDiscovery |
StaticServiceDiscovery.forServices(ServiceDefinition... definitions) |
static BlacklistServiceFilter |
BlacklistServiceFilter.forServices(ServiceDefinition... definitions) |
DefaultServiceDefinition.Builder |
DefaultServiceDefinition.Builder.from(ServiceDefinition source) |
Modifier and Type | Method and Description |
---|---|
List<ServiceDefinition> |
CombinedServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
BlacklistServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
PassThroughServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
HealthyServiceFilter.apply(List<ServiceDefinition> services) |
List<ServiceDefinition> |
DefaultServiceFilter.apply(List<ServiceDefinition> services) |
ServiceDefinition |
RoundRobinServiceChooser.choose(List<ServiceDefinition> definitions) |
ServiceDefinition |
RandomServiceChooser.choose(List<ServiceDefinition> definitions) |
static StaticServiceDiscovery |
StaticServiceDiscovery.forServices(Collection<ServiceDefinition> definitions) |
static BlacklistServiceFilter |
BlacklistServiceFilter.forServices(Collection<ServiceDefinition> definitions) |
void |
StaticServiceDiscovery.removeServer(Predicate<ServiceDefinition> condition)
Remove an existing server from the list of known servers.
|
void |
BlacklistServiceFilter.removeServer(Predicate<ServiceDefinition> condition)
Remove an existing server from the list of known servers.
|
Constructor and Description |
---|
BlacklistServiceFilter(List<ServiceDefinition> blacklist) |
StaticServiceDiscovery(List<ServiceDefinition> servers) |
Apache Camel