in aws-globalaccelerator-endpointgroup/src/main/kotlin/software/amazon/globalaccelerator/endpointgroup/CreateHandler.kt [19:31]
override fun handleRequest(proxy: AmazonWebServicesClientProxy,
request: ResourceHandlerRequest<ResourceModel>,
callbackContext: CallbackContext?,
logger: Logger): ProgressEvent<ResourceModel, CallbackContext?> {
logger.debug("Create new EndpointGroup request: $request")
val agaClient = AcceleratorClientBuilder.client
val inferredCallbackContext = callbackContext ?: CallbackContext(stabilizationRetriesRemaining = HandlerCommons.NUMBER_OF_STATE_POLL_RETRIES)
val model = request.desiredResourceState
return when (model.endpointGroupArn) {
null -> createEndpointGroupStep(model, request, proxy, agaClient, logger)
else -> HandlerCommons.waitForSynchronizedStep(inferredCallbackContext, model, proxy, agaClient, logger)
}
}