http4k-connect-amazon-core/org.http4k.connect.amazon

Package-level declarations

Types

abstract class AwsJsonAction<R : Any>(service: AwsService, clazz: KClass<R>, autoMarshalling: AutoMarshalling, contentType: ContentType = ContentType("application/x-amz-json-1.1")) : Action<Result<R, RemoteFailure>>

AwsJsonFake

class AwsJsonFake(val autoMarshalling: AutoMarshalling, val awsService: AwsService)

AwsQueryAction

abstract class AwsQueryAction<Rsp : Any>(base: Request, clazz: KClass<Rsp>, autoMarshalling: AutoMarshallingJson<MoshiNode>, actionName: String, version: String, wrapper: String?) : Action<Result4k<Rsp, RemoteFailure>>

AwsRestJsonAction

abstract class AwsRestJsonAction<R : Any>(base: Request, clazz: KClass<R>, autoMarshalling: AutoMarshalling) : Action<Result4k<R, RemoteFailure>>

AwsRestJsonFake

class AwsRestJsonFake(val autoMarshalling: AutoMarshalling, val awsService: AwsService, val region: Region, val accountId: AwsAccount)

AwsServiceCompanion

open class AwsServiceCompanion(awsServiceName: String)

Shared infra for all AWS services.

CliCachedCredentials

@JsonSerializable

data class CliCachedCredentials(val AccessKeyId: AccessKeyId, val SecretAccessKey: SecretAccessKey, val SessionToken: SessionToken, val Expiration: Expiration)

CliCachedCredentialsFile

@JsonSerializable

data class CliCachedCredentialsFile(val Credentials: CliCachedCredentials, val ProviderType: String? = null)

CredentialsChain

fun interface CredentialsChain : Function0<AwsCredentials?>

CredentialsProvider

fun interface CredentialsProvider : Function0<AwsCredentials>

JsonError

@JsonSerializable

data class JsonError(val __type: String, val Message: String)

RegionProvider

fun interface RegionProvider : Function0<Region?>

RestfulError

data class RestfulError(val status: Status, val message: String, val resourceId: ARN?, val resourceType: String?)

Properties

AWS_ACCESS_KEY_ID

val AWS_ACCESS_KEY_ID: BiDiLens<Environment, AccessKeyId>

AWS_ACCESS_KEY_ID_OPTIONAL

val AWS_ACCESS_KEY_ID_OPTIONAL: BiDiLens<Environment, AccessKeyId?>

AWS_CONFIG_FILE

val AWS_CONFIG_FILE: BiDiLens<Environment, Path>

AWS_CREDENTIAL_PROFILES_FILE

val AWS_CREDENTIAL_PROFILES_FILE: BiDiLens<Environment, Path>

AWS_CREDENTIALS

val AWS_CREDENTIALS: Lens<Environment, AwsCredentials>

AWS_PROFILE

val AWS_PROFILE: BiDiLens<Environment, ProfileName>

AWS_REGION

val AWS_REGION: BiDiLens<Environment, Region>

AWS_REGION_OPTIONAL

val AWS_REGION_OPTIONAL: BiDiLens<Environment, Region?>

AWS_ROLE_ARN

val AWS_ROLE_ARN: BiDiLens<Environment, ARN>

AWS_ROLE_SESSION_NAME

val AWS_ROLE_SESSION_NAME: BiDiLens<Environment, RoleSessionName?>

AWS_SECRET_ACCESS_KEY

val AWS_SECRET_ACCESS_KEY: BiDiLens<Environment, SecretAccessKey>

AWS_SECRET_ACCESS_KEY_OPTIONAL

val AWS_SECRET_ACCESS_KEY_OPTIONAL: BiDiLens<Environment, SecretAccessKey?>

AWS_SESSION_TOKEN

val AWS_SESSION_TOKEN: BiDiLens<Environment, SessionToken?>

AWS_WEB_IDENTITY_TOKEN

val AWS_WEB_IDENTITY_TOKEN: BiDiLens<Environment, WebIdentityToken>

For directly injecting the WebIdentityToken into the environment.

AWS_WEB_IDENTITY_TOKEN_FILE

val AWS_WEB_IDENTITY_TOKEN_FILE: BiDiLens<Environment, File>

Use when WebIdentityToken is to be stored in file on disk (eg. in K8S)

Functions

AwsReverseProxy

fun AwsReverseProxy(vararg awsServices: Pair<AwsServiceCompanion, HttpHandler>): (request: Request) -> Response

Simple ReverseProxy for AWS services. Allows for simple traffic splitting based on the Host header.

CliCache

fun CredentialsChain.Companion.CliCache(clock: Clock = systemUTC()): CredentialsChain

Environment

fun CredentialsChain.Companion.Environment(env: Environment): CredentialsChain

fun CredentialsProvider.Companion.Environment(env: Map<String, String> = System.getenv()): CredentialsProvider

fun CredentialsProvider.Companion.Environment(env: Environment = ENV): CredentialsProvider

fun RegionProvider.Companion.Environment(env: Map<String, String> = System.getenv()): RegionProvider

fun RegionProvider.Companion.Environment(env: Environment): RegionProvider

Profile

fun RegionProvider.Companion.Profile(env: Environment): RegionProvider

fun CredentialsChain.Companion.Profile(profileName: ProfileName, credentialsPath: Path, configPath: Path = credentialsPath.resolveSibling("config")): CredentialsChain

fun RegionProvider.Companion.Profile(profileName: ProfileName, credentialsPath: Path, configPath: Path = credentialsPath.resolveSibling("config")): RegionProvider

fun CredentialsChain.Companion.Profile(env: Environment = Environment.ENV, profileName: ProfileName = AWS_PROFILE(env), credentialsPath: Path = AWS_CREDENTIAL_PROFILES_FILE(env), configPath: Path = AWS_CONFIG_FILE(env)): CredentialsChain

fun CredentialsProvider.Companion.Profile(env: Environment = Environment.ENV, profileName: ProfileName = AWS_PROFILE(env), credentialsPath: Path = AWS_CREDENTIAL_PROFILES_FILE(env), configPath: Path = AWS_CONFIG_FILE(env)): CredentialsProvider