CHATGPT AI
infrastructure
.config.Config
import com.github.j5ik2o.reactive.aws.sqs.SqsAsyncClient
import software.amazon.awssdk.services.sqs.SqsAsyncClient as JavaSqsAsyncClient

object SqsAsyncClientV1Impl {

def of(config: Config): SqsAsyncClient = {
val underlying = JavaSqsAsyncClient
.builder()
.credentialsProvider(config.credentialsProviderV1)
.region(config.region)
.overrideConfiguration(config.clientConfigurationV1)
.build()

new SqsAsyncClientV1Impl(underlying, config)
}

def of(underlying: JavaSqsAsyncClient, config: Config): SqsAsyncClient = {
new SqsAsyncClientV1Impl(underlying, config)
}

def resource(config: Config): Resource[SqsAsyncClient] = {
Resource[JavaSqsAsyncClient] { _ =>
val underlying = JavaSqsAsyncClient
.builder()
.credentialsProvider(config
.config.Config import com.github.j5ik2o.reactive.aws.sqs.SqsAsyncClient import software.amazon.awssdk.services.sqs.SqsAsyncClient as JavaSqsAsyncClient object SqsAsyncClientV1Impl { def of(config: Config): SqsAsyncClient = { val underlying = JavaSqsAsyncClient .builder() .credentialsProvider(config.credentialsProviderV1) .region(config.region) .overrideConfiguration(config.clientConfigurationV1) .build() new SqsAsyncClientV1Impl(underlying, config) } def of(underlying: JavaSqsAsyncClient, config: Config): SqsAsyncClient = { new SqsAsyncClientV1Impl(underlying, config) } def resource(config: Config): Resource[SqsAsyncClient] = { Resource[JavaSqsAsyncClient] { _ => val underlying = JavaSqsAsyncClient .builder() .credentialsProvider(config
0 Comments & Tags 0 condivisioni 1 Views

Password Copied!

Please Wait....