io.micronaut.discovery.aws.servicediscovery.registration

Class AwsServiceDiscoveryRegistrationClient

java.lang.Object

io.micronaut.discovery.registration.AutoRegistration

io.micronaut.discovery.client.registration.DiscoveryServiceAutoRegistration

io.micronaut.discovery.aws.servicediscovery.registration.AwsServiceDiscoveryRegistrationClient

All Implemented Interfaces:

io.micronaut.context.event.ApplicationEventListener<io.micronaut.discovery.event.AbstractServiceInstanceEvent>, java.util.EventListener

@Internal
 @Singleton
 @Requires(classes=software.amazon.awssdk.services.servicediscovery.ServiceDiscoveryClient.class) @Requires(env="ec2") @Requires(beans=AwsServiceDiscoveryRegistrationConfiguration.class) @Requires(property="aws.service-discovery.registration.enabled",value="true",defaultValue="false") @Requires(property="micronaut.application.name")
public class AwsServiceDiscoveryRegistrationClient
extends io.micronaut.discovery.client.registration.DiscoveryServiceAutoRegistration

An implementation of DiscoveryServiceAutoRegistration for Route 53.

Since:

1.0

Author:

Rvanderwerf, graemerocher, Denis Stepanov

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	AWS_ALIAS_DNS_NAME Constant for AWS alias dns name.
static java.lang.String	AWS_INSTANCE_CNAME Constant for AWS instance cname.
static java.lang.String	AWS_INSTANCE_IPV4 Constant for AWS intance IPv4.
static java.lang.String	AWS_INSTANCE_IPV6 Constant for AWS instance IPv6.
static java.lang.String	AWS_INSTANCE_PORT Constant for AWS instance port.
static java.lang.String	ENABLED Constant for whether route 53 registration is enabled.

Fields inherited from class io.micronaut.discovery.registration.AutoRegistration

registered

Constructor Summary

Constructors

Modifier

Constructor and Description

protected

AwsServiceDiscoveryRegistrationClient(io.micronaut.context.env.Environment environment, AwsServiceDiscoveryRegistrationConfiguration awsServiceDiscoveryRegistrationConfiguration, AmazonComputeInstanceMetadataResolver amazonComputeInstanceMetadataResolver, java.util.concurrent.Executor executorService, software.amazon.awssdk.services.servicediscovery.ServiceDiscoveryClient serviceDiscoveryClient, software.amazon.awssdk.services.servicediscovery.ServiceDiscoveryAsyncClient serviceDiscoveryAsyncClient) Constructor for setup.

Method Summary

Modifier and Type	Method and Description
void	deregister(io.micronaut.discovery.ServiceInstance instance) shutdown instance if it fails health check can gracefully stop.
protected void	pulsate(io.micronaut.discovery.ServiceInstance instance, io.micronaut.health.HealthStatus status) If custom health check is enabled, this sends a heartbeat to it.
void	register(io.micronaut.discovery.ServiceInstance instance) register new instance to the service registry.

Methods inherited from class io.micronaut.discovery.client.registration.DiscoveryServiceAutoRegistration

getErrorMessage, performDeregistration, performRegistration

Methods inherited from class io.micronaut.discovery.registration.AutoRegistration

onApplicationEvent, validateApplicationName, validateName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.context.event.ApplicationEventListener

supports

Field Detail

AWS_INSTANCE_PORT

public static final java.lang.String AWS_INSTANCE_PORT

Constant for AWS instance port.

See Also:

Constant Field Values

AWS_INSTANCE_IPV4

public static final java.lang.String AWS_INSTANCE_IPV4

Constant for AWS intance IPv4.

See Also:

Constant Field Values

AWS_INSTANCE_CNAME

public static final java.lang.String AWS_INSTANCE_CNAME

Constant for AWS instance cname.

See Also:

Constant Field Values

AWS_INSTANCE_IPV6

public static final java.lang.String AWS_INSTANCE_IPV6

Constant for AWS instance IPv6.

See Also:

Constant Field Values

AWS_ALIAS_DNS_NAME

public static final java.lang.String AWS_ALIAS_DNS_NAME

Constant for AWS alias dns name.

See Also:

Constant Field Values

ENABLED

public static final java.lang.String ENABLED

Constant for whether route 53 registration is enabled.

See Also:

Constant Field Values

Constructor Detail

AwsServiceDiscoveryRegistrationClient

protected AwsServiceDiscoveryRegistrationClient(io.micronaut.context.env.Environment environment,
                                                AwsServiceDiscoveryRegistrationConfiguration awsServiceDiscoveryRegistrationConfiguration,
                                                AmazonComputeInstanceMetadataResolver amazonComputeInstanceMetadataResolver,
                                                @Named(value="io")
                                                java.util.concurrent.Executor executorService,
                                                software.amazon.awssdk.services.servicediscovery.ServiceDiscoveryClient serviceDiscoveryClient,
                                                software.amazon.awssdk.services.servicediscovery.ServiceDiscoveryAsyncClient serviceDiscoveryAsyncClient)

Constructor for setup.

Parameters:

environment - current environment

awsServiceDiscoveryRegistrationConfiguration - config for auto registration

amazonComputeInstanceMetadataResolver - resolver for aws compute metdata

executorService - this is for executing the thread to monitor the register operation for completion

serviceDiscoveryClient - the serviceDiscoveryClient

serviceDiscoveryAsyncClient - the serviceDiscoveryAsyncClient

Method Detail

pulsate

protected void pulsate(io.micronaut.discovery.ServiceInstance instance,
                       io.micronaut.health.HealthStatus status)

If custom health check is enabled, this sends a heartbeat to it. In most cases aws monitoring works off polling an application's endpoint

Specified by:

pulsate in class io.micronaut.discovery.registration.AutoRegistration

Parameters:

instance - The instance of the service

status - The HealthStatus

deregister

public void deregister(io.micronaut.discovery.ServiceInstance instance)

shutdown instance if it fails health check can gracefully stop.

Specified by:

deregister in class io.micronaut.discovery.registration.AutoRegistration

register

public void register(io.micronaut.discovery.ServiceInstance instance)

register new instance to the service registry.

Specified by:

register in class io.micronaut.discovery.registration.AutoRegistration

Parameters:

instance - The ServiceInstance