mypydantic.models.events

   1# Model Generated: Thu Mar  2 21:56:19 2023
   2
   3from __future__ import annotations
   4
   5from datetime import datetime
   6from typing import Dict, List, Literal, Optional, Sequence, Union
   7
   8from pydantic import Field
   9
  10from mypydantic.models.base_model import BaseModel
  11
  12
  13class ActivateEventSourceRequestModel(BaseModel):
  14    name: str = Field(alias="Name")
  15
  16
  17class ApiDestinationModel(BaseModel):
  18    api_destination_arn: Optional[str] = Field(default=None, alias="ApiDestinationArn")
  19    name: Optional[str] = Field(default=None, alias="Name")
  20    api_destination_state: Optional[Literal["ACTIVE", "INACTIVE"]] = Field(
  21        default=None, alias="ApiDestinationState"
  22    )
  23    connection_arn: Optional[str] = Field(default=None, alias="ConnectionArn")
  24    invocation_endpoint: Optional[str] = Field(default=None, alias="InvocationEndpoint")
  25    http_method: Optional[
  26        Literal["DELETE", "GET", "HEAD", "OPTIONS", "PATCH", "POST", "PUT"]
  27    ] = Field(default=None, alias="HttpMethod")
  28    invocation_rate_limit_per_second: Optional[int] = Field(
  29        default=None, alias="InvocationRateLimitPerSecond"
  30    )
  31    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
  32    last_modified_time: Optional[datetime] = Field(
  33        default=None, alias="LastModifiedTime"
  34    )
  35
  36
  37class ArchiveModel(BaseModel):
  38    archive_name: Optional[str] = Field(default=None, alias="ArchiveName")
  39    event_source_arn: Optional[str] = Field(default=None, alias="EventSourceArn")
  40    state: Optional[
  41        Literal[
  42            "CREATE_FAILED",
  43            "CREATING",
  44            "DISABLED",
  45            "ENABLED",
  46            "UPDATE_FAILED",
  47            "UPDATING",
  48        ]
  49    ] = Field(default=None, alias="State")
  50    state_reason: Optional[str] = Field(default=None, alias="StateReason")
  51    retention_days: Optional[int] = Field(default=None, alias="RetentionDays")
  52    size_bytes: Optional[int] = Field(default=None, alias="SizeBytes")
  53    event_count: Optional[int] = Field(default=None, alias="EventCount")
  54    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
  55
  56
  57class AwsVpcConfigurationModel(BaseModel):
  58    subnets: List[str] = Field(alias="Subnets")
  59    security_groups: Optional[List[str]] = Field(default=None, alias="SecurityGroups")
  60    assign_public_ip: Optional[Literal["DISABLED", "ENABLED"]] = Field(
  61        default=None, alias="AssignPublicIp"
  62    )
  63
  64
  65class BatchArrayPropertiesModel(BaseModel):
  66    size: Optional[int] = Field(default=None, alias="Size")
  67
  68
  69class BatchRetryStrategyModel(BaseModel):
  70    attempts: Optional[int] = Field(default=None, alias="Attempts")
  71
  72
  73class CancelReplayRequestModel(BaseModel):
  74    replay_name: str = Field(alias="ReplayName")
  75
  76
  77class ResponseMetadataModel(BaseModel):
  78    request_id: str = Field(alias="RequestId")
  79    host_id: str = Field(alias="HostId")
  80    http_status_code: int = Field(alias="HTTPStatusCode")
  81    http_headers: Dict[str, str] = Field(alias="HTTPHeaders")
  82    retry_attempts: int = Field(alias="RetryAttempts")
  83
  84
  85class CapacityProviderStrategyItemModel(BaseModel):
  86    capacity_provider: str = Field(alias="capacityProvider")
  87    weight: Optional[int] = Field(default=None, alias="weight")
  88    base: Optional[int] = Field(default=None, alias="base")
  89
  90
  91class ConditionModel(BaseModel):
  92    type: str = Field(alias="Type")
  93    key: str = Field(alias="Key")
  94    value: str = Field(alias="Value")
  95
  96
  97class ConnectionApiKeyAuthResponseParametersModel(BaseModel):
  98    api_key_name: Optional[str] = Field(default=None, alias="ApiKeyName")
  99
 100
 101class ConnectionBasicAuthResponseParametersModel(BaseModel):
 102    username: Optional[str] = Field(default=None, alias="Username")
 103
 104
 105class ConnectionBodyParameterModel(BaseModel):
 106    key: Optional[str] = Field(default=None, alias="Key")
 107    value: Optional[str] = Field(default=None, alias="Value")
 108    is_value_secret: Optional[bool] = Field(default=None, alias="IsValueSecret")
 109
 110
 111class ConnectionHeaderParameterModel(BaseModel):
 112    key: Optional[str] = Field(default=None, alias="Key")
 113    value: Optional[str] = Field(default=None, alias="Value")
 114    is_value_secret: Optional[bool] = Field(default=None, alias="IsValueSecret")
 115
 116
 117class ConnectionQueryStringParameterModel(BaseModel):
 118    key: Optional[str] = Field(default=None, alias="Key")
 119    value: Optional[str] = Field(default=None, alias="Value")
 120    is_value_secret: Optional[bool] = Field(default=None, alias="IsValueSecret")
 121
 122
 123class ConnectionOAuthClientResponseParametersModel(BaseModel):
 124    client_id: Optional[str] = Field(default=None, alias="ClientID")
 125
 126
 127class ConnectionModel(BaseModel):
 128    connection_arn: Optional[str] = Field(default=None, alias="ConnectionArn")
 129    name: Optional[str] = Field(default=None, alias="Name")
 130    connection_state: Optional[
 131        Literal[
 132            "AUTHORIZED",
 133            "AUTHORIZING",
 134            "CREATING",
 135            "DEAUTHORIZED",
 136            "DEAUTHORIZING",
 137            "DELETING",
 138            "UPDATING",
 139        ]
 140    ] = Field(default=None, alias="ConnectionState")
 141    state_reason: Optional[str] = Field(default=None, alias="StateReason")
 142    authorization_type: Optional[
 143        Literal["API_KEY", "BASIC", "OAUTH_CLIENT_CREDENTIALS"]
 144    ] = Field(default=None, alias="AuthorizationType")
 145    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
 146    last_modified_time: Optional[datetime] = Field(
 147        default=None, alias="LastModifiedTime"
 148    )
 149    last_authorized_time: Optional[datetime] = Field(
 150        default=None, alias="LastAuthorizedTime"
 151    )
 152
 153
 154class CreateApiDestinationRequestModel(BaseModel):
 155    name: str = Field(alias="Name")
 156    connection_arn: str = Field(alias="ConnectionArn")
 157    invocation_endpoint: str = Field(alias="InvocationEndpoint")
 158    http_method: Literal[
 159        "DELETE", "GET", "HEAD", "OPTIONS", "PATCH", "POST", "PUT"
 160    ] = Field(alias="HttpMethod")
 161    description: Optional[str] = Field(default=None, alias="Description")
 162    invocation_rate_limit_per_second: Optional[int] = Field(
 163        default=None, alias="InvocationRateLimitPerSecond"
 164    )
 165
 166
 167class CreateArchiveRequestModel(BaseModel):
 168    archive_name: str = Field(alias="ArchiveName")
 169    event_source_arn: str = Field(alias="EventSourceArn")
 170    description: Optional[str] = Field(default=None, alias="Description")
 171    event_pattern: Optional[str] = Field(default=None, alias="EventPattern")
 172    retention_days: Optional[int] = Field(default=None, alias="RetentionDays")
 173
 174
 175class CreateConnectionApiKeyAuthRequestParametersModel(BaseModel):
 176    api_key_name: str = Field(alias="ApiKeyName")
 177    api_key_value: str = Field(alias="ApiKeyValue")
 178
 179
 180class CreateConnectionBasicAuthRequestParametersModel(BaseModel):
 181    username: str = Field(alias="Username")
 182    password: str = Field(alias="Password")
 183
 184
 185class CreateConnectionOAuthClientRequestParametersModel(BaseModel):
 186    client_id: str = Field(alias="ClientID")
 187    client_secret: str = Field(alias="ClientSecret")
 188
 189
 190class EndpointEventBusModel(BaseModel):
 191    event_bus_arn: str = Field(alias="EventBusArn")
 192
 193
 194class ReplicationConfigModel(BaseModel):
 195    state: Optional[Literal["DISABLED", "ENABLED"]] = Field(default=None, alias="State")
 196
 197
 198class TagModel(BaseModel):
 199    key: str = Field(alias="Key")
 200    value: str = Field(alias="Value")
 201
 202
 203class CreatePartnerEventSourceRequestModel(BaseModel):
 204    name: str = Field(alias="Name")
 205    account: str = Field(alias="Account")
 206
 207
 208class DeactivateEventSourceRequestModel(BaseModel):
 209    name: str = Field(alias="Name")
 210
 211
 212class DeadLetterConfigModel(BaseModel):
 213    arn: Optional[str] = Field(default=None, alias="Arn")
 214
 215
 216class DeauthorizeConnectionRequestModel(BaseModel):
 217    name: str = Field(alias="Name")
 218
 219
 220class DeleteApiDestinationRequestModel(BaseModel):
 221    name: str = Field(alias="Name")
 222
 223
 224class DeleteArchiveRequestModel(BaseModel):
 225    archive_name: str = Field(alias="ArchiveName")
 226
 227
 228class DeleteConnectionRequestModel(BaseModel):
 229    name: str = Field(alias="Name")
 230
 231
 232class DeleteEndpointRequestModel(BaseModel):
 233    name: str = Field(alias="Name")
 234
 235
 236class DeleteEventBusRequestModel(BaseModel):
 237    name: str = Field(alias="Name")
 238
 239
 240class DeletePartnerEventSourceRequestModel(BaseModel):
 241    name: str = Field(alias="Name")
 242    account: str = Field(alias="Account")
 243
 244
 245class DeleteRuleRequestModel(BaseModel):
 246    name: str = Field(alias="Name")
 247    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 248    force: Optional[bool] = Field(default=None, alias="Force")
 249
 250
 251class DescribeApiDestinationRequestModel(BaseModel):
 252    name: str = Field(alias="Name")
 253
 254
 255class DescribeArchiveRequestModel(BaseModel):
 256    archive_name: str = Field(alias="ArchiveName")
 257
 258
 259class DescribeConnectionRequestModel(BaseModel):
 260    name: str = Field(alias="Name")
 261
 262
 263class DescribeEndpointRequestModel(BaseModel):
 264    name: str = Field(alias="Name")
 265    home_region: Optional[str] = Field(default=None, alias="HomeRegion")
 266
 267
 268class DescribeEventBusRequestModel(BaseModel):
 269    name: Optional[str] = Field(default=None, alias="Name")
 270
 271
 272class DescribeEventSourceRequestModel(BaseModel):
 273    name: str = Field(alias="Name")
 274
 275
 276class DescribePartnerEventSourceRequestModel(BaseModel):
 277    name: str = Field(alias="Name")
 278
 279
 280class DescribeReplayRequestModel(BaseModel):
 281    replay_name: str = Field(alias="ReplayName")
 282
 283
 284class ReplayDestinationModel(BaseModel):
 285    arn: str = Field(alias="Arn")
 286    filter_arns: Optional[List[str]] = Field(default=None, alias="FilterArns")
 287
 288
 289class DescribeRuleRequestModel(BaseModel):
 290    name: str = Field(alias="Name")
 291    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 292
 293
 294class DisableRuleRequestModel(BaseModel):
 295    name: str = Field(alias="Name")
 296    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 297
 298
 299class PlacementConstraintModel(BaseModel):
 300    type: Optional[Literal["distinctInstance", "memberOf"]] = Field(
 301        default=None, alias="type"
 302    )
 303    expression: Optional[str] = Field(default=None, alias="expression")
 304
 305
 306class PlacementStrategyModel(BaseModel):
 307    type: Optional[Literal["binpack", "random", "spread"]] = Field(
 308        default=None, alias="type"
 309    )
 310    field: Optional[str] = Field(default=None, alias="field")
 311
 312
 313class EnableRuleRequestModel(BaseModel):
 314    name: str = Field(alias="Name")
 315    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 316
 317
 318class EventBusModel(BaseModel):
 319    name: Optional[str] = Field(default=None, alias="Name")
 320    arn: Optional[str] = Field(default=None, alias="Arn")
 321    policy: Optional[str] = Field(default=None, alias="Policy")
 322
 323
 324class EventSourceModel(BaseModel):
 325    arn: Optional[str] = Field(default=None, alias="Arn")
 326    created_by: Optional[str] = Field(default=None, alias="CreatedBy")
 327    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
 328    expiration_time: Optional[datetime] = Field(default=None, alias="ExpirationTime")
 329    name: Optional[str] = Field(default=None, alias="Name")
 330    state: Optional[Literal["ACTIVE", "DELETED", "PENDING"]] = Field(
 331        default=None, alias="State"
 332    )
 333
 334
 335class PrimaryModel(BaseModel):
 336    health_check: str = Field(alias="HealthCheck")
 337
 338
 339class SecondaryModel(BaseModel):
 340    route: str = Field(alias="Route")
 341
 342
 343class HttpParametersModel(BaseModel):
 344    path_parameter_values: Optional[List[str]] = Field(
 345        default=None, alias="PathParameterValues"
 346    )
 347    header_parameters: Optional[Dict[str, str]] = Field(
 348        default=None, alias="HeaderParameters"
 349    )
 350    query_string_parameters: Optional[Dict[str, str]] = Field(
 351        default=None, alias="QueryStringParameters"
 352    )
 353
 354
 355class InputTransformerModel(BaseModel):
 356    input_template: str = Field(alias="InputTemplate")
 357    input_paths_map: Optional[Dict[str, str]] = Field(
 358        default=None, alias="InputPathsMap"
 359    )
 360
 361
 362class KinesisParametersModel(BaseModel):
 363    partition_key_path: str = Field(alias="PartitionKeyPath")
 364
 365
 366class ListApiDestinationsRequestModel(BaseModel):
 367    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
 368    connection_arn: Optional[str] = Field(default=None, alias="ConnectionArn")
 369    next_token: Optional[str] = Field(default=None, alias="NextToken")
 370    limit: Optional[int] = Field(default=None, alias="Limit")
 371
 372
 373class ListArchivesRequestModel(BaseModel):
 374    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
 375    event_source_arn: Optional[str] = Field(default=None, alias="EventSourceArn")
 376    state: Optional[
 377        Literal[
 378            "CREATE_FAILED",
 379            "CREATING",
 380            "DISABLED",
 381            "ENABLED",
 382            "UPDATE_FAILED",
 383            "UPDATING",
 384        ]
 385    ] = Field(default=None, alias="State")
 386    next_token: Optional[str] = Field(default=None, alias="NextToken")
 387    limit: Optional[int] = Field(default=None, alias="Limit")
 388
 389
 390class ListConnectionsRequestModel(BaseModel):
 391    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
 392    connection_state: Optional[
 393        Literal[
 394            "AUTHORIZED",
 395            "AUTHORIZING",
 396            "CREATING",
 397            "DEAUTHORIZED",
 398            "DEAUTHORIZING",
 399            "DELETING",
 400            "UPDATING",
 401        ]
 402    ] = Field(default=None, alias="ConnectionState")
 403    next_token: Optional[str] = Field(default=None, alias="NextToken")
 404    limit: Optional[int] = Field(default=None, alias="Limit")
 405
 406
 407class ListEndpointsRequestModel(BaseModel):
 408    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
 409    home_region: Optional[str] = Field(default=None, alias="HomeRegion")
 410    next_token: Optional[str] = Field(default=None, alias="NextToken")
 411    max_results: Optional[int] = Field(default=None, alias="MaxResults")
 412
 413
 414class ListEventBusesRequestModel(BaseModel):
 415    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
 416    next_token: Optional[str] = Field(default=None, alias="NextToken")
 417    limit: Optional[int] = Field(default=None, alias="Limit")
 418
 419
 420class ListEventSourcesRequestModel(BaseModel):
 421    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
 422    next_token: Optional[str] = Field(default=None, alias="NextToken")
 423    limit: Optional[int] = Field(default=None, alias="Limit")
 424
 425
 426class ListPartnerEventSourceAccountsRequestModel(BaseModel):
 427    event_source_name: str = Field(alias="EventSourceName")
 428    next_token: Optional[str] = Field(default=None, alias="NextToken")
 429    limit: Optional[int] = Field(default=None, alias="Limit")
 430
 431
 432class PartnerEventSourceAccountModel(BaseModel):
 433    account: Optional[str] = Field(default=None, alias="Account")
 434    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
 435    expiration_time: Optional[datetime] = Field(default=None, alias="ExpirationTime")
 436    state: Optional[Literal["ACTIVE", "DELETED", "PENDING"]] = Field(
 437        default=None, alias="State"
 438    )
 439
 440
 441class ListPartnerEventSourcesRequestModel(BaseModel):
 442    name_prefix: str = Field(alias="NamePrefix")
 443    next_token: Optional[str] = Field(default=None, alias="NextToken")
 444    limit: Optional[int] = Field(default=None, alias="Limit")
 445
 446
 447class PartnerEventSourceModel(BaseModel):
 448    arn: Optional[str] = Field(default=None, alias="Arn")
 449    name: Optional[str] = Field(default=None, alias="Name")
 450
 451
 452class ListReplaysRequestModel(BaseModel):
 453    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
 454    state: Optional[
 455        Literal["CANCELLED", "CANCELLING", "COMPLETED", "FAILED", "RUNNING", "STARTING"]
 456    ] = Field(default=None, alias="State")
 457    event_source_arn: Optional[str] = Field(default=None, alias="EventSourceArn")
 458    next_token: Optional[str] = Field(default=None, alias="NextToken")
 459    limit: Optional[int] = Field(default=None, alias="Limit")
 460
 461
 462class ReplayModel(BaseModel):
 463    replay_name: Optional[str] = Field(default=None, alias="ReplayName")
 464    event_source_arn: Optional[str] = Field(default=None, alias="EventSourceArn")
 465    state: Optional[
 466        Literal["CANCELLED", "CANCELLING", "COMPLETED", "FAILED", "RUNNING", "STARTING"]
 467    ] = Field(default=None, alias="State")
 468    state_reason: Optional[str] = Field(default=None, alias="StateReason")
 469    event_start_time: Optional[datetime] = Field(default=None, alias="EventStartTime")
 470    event_end_time: Optional[datetime] = Field(default=None, alias="EventEndTime")
 471    event_last_replayed_time: Optional[datetime] = Field(
 472        default=None, alias="EventLastReplayedTime"
 473    )
 474    replay_start_time: Optional[datetime] = Field(default=None, alias="ReplayStartTime")
 475    replay_end_time: Optional[datetime] = Field(default=None, alias="ReplayEndTime")
 476
 477
 478class PaginatorConfigModel(BaseModel):
 479    max_items: Optional[int] = Field(default=None, alias="MaxItems")
 480    page_size: Optional[int] = Field(default=None, alias="PageSize")
 481    starting_token: Optional[str] = Field(default=None, alias="StartingToken")
 482
 483
 484class ListRuleNamesByTargetRequestModel(BaseModel):
 485    target_arn: str = Field(alias="TargetArn")
 486    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 487    next_token: Optional[str] = Field(default=None, alias="NextToken")
 488    limit: Optional[int] = Field(default=None, alias="Limit")
 489
 490
 491class ListRulesRequestModel(BaseModel):
 492    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
 493    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 494    next_token: Optional[str] = Field(default=None, alias="NextToken")
 495    limit: Optional[int] = Field(default=None, alias="Limit")
 496
 497
 498class RuleModel(BaseModel):
 499    name: Optional[str] = Field(default=None, alias="Name")
 500    arn: Optional[str] = Field(default=None, alias="Arn")
 501    event_pattern: Optional[str] = Field(default=None, alias="EventPattern")
 502    state: Optional[Literal["DISABLED", "ENABLED"]] = Field(default=None, alias="State")
 503    description: Optional[str] = Field(default=None, alias="Description")
 504    schedule_expression: Optional[str] = Field(default=None, alias="ScheduleExpression")
 505    role_arn: Optional[str] = Field(default=None, alias="RoleArn")
 506    managed_by: Optional[str] = Field(default=None, alias="ManagedBy")
 507    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 508
 509
 510class ListTagsForResourceRequestModel(BaseModel):
 511    resource_arn: str = Field(alias="ResourceARN")
 512
 513
 514class ListTargetsByRuleRequestModel(BaseModel):
 515    rule: str = Field(alias="Rule")
 516    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 517    next_token: Optional[str] = Field(default=None, alias="NextToken")
 518    limit: Optional[int] = Field(default=None, alias="Limit")
 519
 520
 521class PutEventsRequestEntryModel(BaseModel):
 522    time: Optional[Union[datetime, str]] = Field(default=None, alias="Time")
 523    source: Optional[str] = Field(default=None, alias="Source")
 524    resources: Optional[Sequence[str]] = Field(default=None, alias="Resources")
 525    detail_type: Optional[str] = Field(default=None, alias="DetailType")
 526    detail: Optional[str] = Field(default=None, alias="Detail")
 527    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 528    trace_header: Optional[str] = Field(default=None, alias="TraceHeader")
 529
 530
 531class PutEventsResultEntryModel(BaseModel):
 532    event_id: Optional[str] = Field(default=None, alias="EventId")
 533    error_code: Optional[str] = Field(default=None, alias="ErrorCode")
 534    error_message: Optional[str] = Field(default=None, alias="ErrorMessage")
 535
 536
 537class PutPartnerEventsRequestEntryModel(BaseModel):
 538    time: Optional[Union[datetime, str]] = Field(default=None, alias="Time")
 539    source: Optional[str] = Field(default=None, alias="Source")
 540    resources: Optional[Sequence[str]] = Field(default=None, alias="Resources")
 541    detail_type: Optional[str] = Field(default=None, alias="DetailType")
 542    detail: Optional[str] = Field(default=None, alias="Detail")
 543
 544
 545class PutPartnerEventsResultEntryModel(BaseModel):
 546    event_id: Optional[str] = Field(default=None, alias="EventId")
 547    error_code: Optional[str] = Field(default=None, alias="ErrorCode")
 548    error_message: Optional[str] = Field(default=None, alias="ErrorMessage")
 549
 550
 551class PutTargetsResultEntryModel(BaseModel):
 552    target_id: Optional[str] = Field(default=None, alias="TargetId")
 553    error_code: Optional[str] = Field(default=None, alias="ErrorCode")
 554    error_message: Optional[str] = Field(default=None, alias="ErrorMessage")
 555
 556
 557class RedshiftDataParametersModel(BaseModel):
 558    database: str = Field(alias="Database")
 559    sql: str = Field(alias="Sql")
 560    secret_manager_arn: Optional[str] = Field(default=None, alias="SecretManagerArn")
 561    db_user: Optional[str] = Field(default=None, alias="DbUser")
 562    statement_name: Optional[str] = Field(default=None, alias="StatementName")
 563    with_event: Optional[bool] = Field(default=None, alias="WithEvent")
 564
 565
 566class RemovePermissionRequestModel(BaseModel):
 567    statement_id: Optional[str] = Field(default=None, alias="StatementId")
 568    remove_all_permissions: Optional[bool] = Field(
 569        default=None, alias="RemoveAllPermissions"
 570    )
 571    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 572
 573
 574class RemoveTargetsRequestModel(BaseModel):
 575    rule: str = Field(alias="Rule")
 576    ids: Sequence[str] = Field(alias="Ids")
 577    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 578    force: Optional[bool] = Field(default=None, alias="Force")
 579
 580
 581class RemoveTargetsResultEntryModel(BaseModel):
 582    target_id: Optional[str] = Field(default=None, alias="TargetId")
 583    error_code: Optional[str] = Field(default=None, alias="ErrorCode")
 584    error_message: Optional[str] = Field(default=None, alias="ErrorMessage")
 585
 586
 587class RetryPolicyModel(BaseModel):
 588    maximum_retry_attempts: Optional[int] = Field(
 589        default=None, alias="MaximumRetryAttempts"
 590    )
 591    maximum_event_age_in_seconds: Optional[int] = Field(
 592        default=None, alias="MaximumEventAgeInSeconds"
 593    )
 594
 595
 596class RunCommandTargetModel(BaseModel):
 597    key: str = Field(alias="Key")
 598    values: List[str] = Field(alias="Values")
 599
 600
 601class SageMakerPipelineParameterModel(BaseModel):
 602    name: str = Field(alias="Name")
 603    value: str = Field(alias="Value")
 604
 605
 606class SqsParametersModel(BaseModel):
 607    message_group_id: Optional[str] = Field(default=None, alias="MessageGroupId")
 608
 609
 610class TestEventPatternRequestModel(BaseModel):
 611    event_pattern: str = Field(alias="EventPattern")
 612    event: str = Field(alias="Event")
 613
 614
 615class UntagResourceRequestModel(BaseModel):
 616    resource_arn: str = Field(alias="ResourceARN")
 617    tag_keys: Sequence[str] = Field(alias="TagKeys")
 618
 619
 620class UpdateApiDestinationRequestModel(BaseModel):
 621    name: str = Field(alias="Name")
 622    description: Optional[str] = Field(default=None, alias="Description")
 623    connection_arn: Optional[str] = Field(default=None, alias="ConnectionArn")
 624    invocation_endpoint: Optional[str] = Field(default=None, alias="InvocationEndpoint")
 625    http_method: Optional[
 626        Literal["DELETE", "GET", "HEAD", "OPTIONS", "PATCH", "POST", "PUT"]
 627    ] = Field(default=None, alias="HttpMethod")
 628    invocation_rate_limit_per_second: Optional[int] = Field(
 629        default=None, alias="InvocationRateLimitPerSecond"
 630    )
 631
 632
 633class UpdateArchiveRequestModel(BaseModel):
 634    archive_name: str = Field(alias="ArchiveName")
 635    description: Optional[str] = Field(default=None, alias="Description")
 636    event_pattern: Optional[str] = Field(default=None, alias="EventPattern")
 637    retention_days: Optional[int] = Field(default=None, alias="RetentionDays")
 638
 639
 640class UpdateConnectionApiKeyAuthRequestParametersModel(BaseModel):
 641    api_key_name: Optional[str] = Field(default=None, alias="ApiKeyName")
 642    api_key_value: Optional[str] = Field(default=None, alias="ApiKeyValue")
 643
 644
 645class UpdateConnectionBasicAuthRequestParametersModel(BaseModel):
 646    username: Optional[str] = Field(default=None, alias="Username")
 647    password: Optional[str] = Field(default=None, alias="Password")
 648
 649
 650class UpdateConnectionOAuthClientRequestParametersModel(BaseModel):
 651    client_id: Optional[str] = Field(default=None, alias="ClientID")
 652    client_secret: Optional[str] = Field(default=None, alias="ClientSecret")
 653
 654
 655class NetworkConfigurationModel(BaseModel):
 656    awsvpc_configuration: Optional[AwsVpcConfigurationModel] = Field(
 657        default=None, alias="awsvpcConfiguration"
 658    )
 659
 660
 661class BatchParametersModel(BaseModel):
 662    job_definition: str = Field(alias="JobDefinition")
 663    job_name: str = Field(alias="JobName")
 664    array_properties: Optional[BatchArrayPropertiesModel] = Field(
 665        default=None, alias="ArrayProperties"
 666    )
 667    retry_strategy: Optional[BatchRetryStrategyModel] = Field(
 668        default=None, alias="RetryStrategy"
 669    )
 670
 671
 672class CancelReplayResponseModel(BaseModel):
 673    replay_arn: str = Field(alias="ReplayArn")
 674    state: Literal[
 675        "CANCELLED", "CANCELLING", "COMPLETED", "FAILED", "RUNNING", "STARTING"
 676    ] = Field(alias="State")
 677    state_reason: str = Field(alias="StateReason")
 678    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 679
 680
 681class CreateApiDestinationResponseModel(BaseModel):
 682    api_destination_arn: str = Field(alias="ApiDestinationArn")
 683    api_destination_state: Literal["ACTIVE", "INACTIVE"] = Field(
 684        alias="ApiDestinationState"
 685    )
 686    creation_time: datetime = Field(alias="CreationTime")
 687    last_modified_time: datetime = Field(alias="LastModifiedTime")
 688    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 689
 690
 691class CreateArchiveResponseModel(BaseModel):
 692    archive_arn: str = Field(alias="ArchiveArn")
 693    state: Literal[
 694        "CREATE_FAILED", "CREATING", "DISABLED", "ENABLED", "UPDATE_FAILED", "UPDATING"
 695    ] = Field(alias="State")
 696    state_reason: str = Field(alias="StateReason")
 697    creation_time: datetime = Field(alias="CreationTime")
 698    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 699
 700
 701class CreateConnectionResponseModel(BaseModel):
 702    connection_arn: str = Field(alias="ConnectionArn")
 703    connection_state: Literal[
 704        "AUTHORIZED",
 705        "AUTHORIZING",
 706        "CREATING",
 707        "DEAUTHORIZED",
 708        "DEAUTHORIZING",
 709        "DELETING",
 710        "UPDATING",
 711    ] = Field(alias="ConnectionState")
 712    creation_time: datetime = Field(alias="CreationTime")
 713    last_modified_time: datetime = Field(alias="LastModifiedTime")
 714    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 715
 716
 717class CreateEventBusResponseModel(BaseModel):
 718    event_bus_arn: str = Field(alias="EventBusArn")
 719    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 720
 721
 722class CreatePartnerEventSourceResponseModel(BaseModel):
 723    event_source_arn: str = Field(alias="EventSourceArn")
 724    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 725
 726
 727class DeauthorizeConnectionResponseModel(BaseModel):
 728    connection_arn: str = Field(alias="ConnectionArn")
 729    connection_state: Literal[
 730        "AUTHORIZED",
 731        "AUTHORIZING",
 732        "CREATING",
 733        "DEAUTHORIZED",
 734        "DEAUTHORIZING",
 735        "DELETING",
 736        "UPDATING",
 737    ] = Field(alias="ConnectionState")
 738    creation_time: datetime = Field(alias="CreationTime")
 739    last_modified_time: datetime = Field(alias="LastModifiedTime")
 740    last_authorized_time: datetime = Field(alias="LastAuthorizedTime")
 741    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 742
 743
 744class DeleteConnectionResponseModel(BaseModel):
 745    connection_arn: str = Field(alias="ConnectionArn")
 746    connection_state: Literal[
 747        "AUTHORIZED",
 748        "AUTHORIZING",
 749        "CREATING",
 750        "DEAUTHORIZED",
 751        "DEAUTHORIZING",
 752        "DELETING",
 753        "UPDATING",
 754    ] = Field(alias="ConnectionState")
 755    creation_time: datetime = Field(alias="CreationTime")
 756    last_modified_time: datetime = Field(alias="LastModifiedTime")
 757    last_authorized_time: datetime = Field(alias="LastAuthorizedTime")
 758    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 759
 760
 761class DescribeApiDestinationResponseModel(BaseModel):
 762    api_destination_arn: str = Field(alias="ApiDestinationArn")
 763    name: str = Field(alias="Name")
 764    description: str = Field(alias="Description")
 765    api_destination_state: Literal["ACTIVE", "INACTIVE"] = Field(
 766        alias="ApiDestinationState"
 767    )
 768    connection_arn: str = Field(alias="ConnectionArn")
 769    invocation_endpoint: str = Field(alias="InvocationEndpoint")
 770    http_method: Literal[
 771        "DELETE", "GET", "HEAD", "OPTIONS", "PATCH", "POST", "PUT"
 772    ] = Field(alias="HttpMethod")
 773    invocation_rate_limit_per_second: int = Field(alias="InvocationRateLimitPerSecond")
 774    creation_time: datetime = Field(alias="CreationTime")
 775    last_modified_time: datetime = Field(alias="LastModifiedTime")
 776    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 777
 778
 779class DescribeArchiveResponseModel(BaseModel):
 780    archive_arn: str = Field(alias="ArchiveArn")
 781    archive_name: str = Field(alias="ArchiveName")
 782    event_source_arn: str = Field(alias="EventSourceArn")
 783    description: str = Field(alias="Description")
 784    event_pattern: str = Field(alias="EventPattern")
 785    state: Literal[
 786        "CREATE_FAILED", "CREATING", "DISABLED", "ENABLED", "UPDATE_FAILED", "UPDATING"
 787    ] = Field(alias="State")
 788    state_reason: str = Field(alias="StateReason")
 789    retention_days: int = Field(alias="RetentionDays")
 790    size_bytes: int = Field(alias="SizeBytes")
 791    event_count: int = Field(alias="EventCount")
 792    creation_time: datetime = Field(alias="CreationTime")
 793    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 794
 795
 796class DescribeEventBusResponseModel(BaseModel):
 797    name: str = Field(alias="Name")
 798    arn: str = Field(alias="Arn")
 799    policy: str = Field(alias="Policy")
 800    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 801
 802
 803class DescribeEventSourceResponseModel(BaseModel):
 804    arn: str = Field(alias="Arn")
 805    created_by: str = Field(alias="CreatedBy")
 806    creation_time: datetime = Field(alias="CreationTime")
 807    expiration_time: datetime = Field(alias="ExpirationTime")
 808    name: str = Field(alias="Name")
 809    state: Literal["ACTIVE", "DELETED", "PENDING"] = Field(alias="State")
 810    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 811
 812
 813class DescribePartnerEventSourceResponseModel(BaseModel):
 814    arn: str = Field(alias="Arn")
 815    name: str = Field(alias="Name")
 816    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 817
 818
 819class DescribeRuleResponseModel(BaseModel):
 820    name: str = Field(alias="Name")
 821    arn: str = Field(alias="Arn")
 822    event_pattern: str = Field(alias="EventPattern")
 823    schedule_expression: str = Field(alias="ScheduleExpression")
 824    state: Literal["DISABLED", "ENABLED"] = Field(alias="State")
 825    description: str = Field(alias="Description")
 826    role_arn: str = Field(alias="RoleArn")
 827    managed_by: str = Field(alias="ManagedBy")
 828    event_bus_name: str = Field(alias="EventBusName")
 829    created_by: str = Field(alias="CreatedBy")
 830    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 831
 832
 833class EmptyResponseMetadataModel(BaseModel):
 834    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 835
 836
 837class ListApiDestinationsResponseModel(BaseModel):
 838    api_destinations: List[ApiDestinationModel] = Field(alias="ApiDestinations")
 839    next_token: str = Field(alias="NextToken")
 840    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 841
 842
 843class ListArchivesResponseModel(BaseModel):
 844    archives: List[ArchiveModel] = Field(alias="Archives")
 845    next_token: str = Field(alias="NextToken")
 846    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 847
 848
 849class ListRuleNamesByTargetResponseModel(BaseModel):
 850    rule_names: List[str] = Field(alias="RuleNames")
 851    next_token: str = Field(alias="NextToken")
 852    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 853
 854
 855class PutRuleResponseModel(BaseModel):
 856    rule_arn: str = Field(alias="RuleArn")
 857    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 858
 859
 860class StartReplayResponseModel(BaseModel):
 861    replay_arn: str = Field(alias="ReplayArn")
 862    state: Literal[
 863        "CANCELLED", "CANCELLING", "COMPLETED", "FAILED", "RUNNING", "STARTING"
 864    ] = Field(alias="State")
 865    state_reason: str = Field(alias="StateReason")
 866    replay_start_time: datetime = Field(alias="ReplayStartTime")
 867    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 868
 869
 870class TestEventPatternResponseModel(BaseModel):
 871    result: bool = Field(alias="Result")
 872    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 873
 874
 875class UpdateApiDestinationResponseModel(BaseModel):
 876    api_destination_arn: str = Field(alias="ApiDestinationArn")
 877    api_destination_state: Literal["ACTIVE", "INACTIVE"] = Field(
 878        alias="ApiDestinationState"
 879    )
 880    creation_time: datetime = Field(alias="CreationTime")
 881    last_modified_time: datetime = Field(alias="LastModifiedTime")
 882    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 883
 884
 885class UpdateArchiveResponseModel(BaseModel):
 886    archive_arn: str = Field(alias="ArchiveArn")
 887    state: Literal[
 888        "CREATE_FAILED", "CREATING", "DISABLED", "ENABLED", "UPDATE_FAILED", "UPDATING"
 889    ] = Field(alias="State")
 890    state_reason: str = Field(alias="StateReason")
 891    creation_time: datetime = Field(alias="CreationTime")
 892    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 893
 894
 895class UpdateConnectionResponseModel(BaseModel):
 896    connection_arn: str = Field(alias="ConnectionArn")
 897    connection_state: Literal[
 898        "AUTHORIZED",
 899        "AUTHORIZING",
 900        "CREATING",
 901        "DEAUTHORIZED",
 902        "DEAUTHORIZING",
 903        "DELETING",
 904        "UPDATING",
 905    ] = Field(alias="ConnectionState")
 906    creation_time: datetime = Field(alias="CreationTime")
 907    last_modified_time: datetime = Field(alias="LastModifiedTime")
 908    last_authorized_time: datetime = Field(alias="LastAuthorizedTime")
 909    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 910
 911
 912class PutPermissionRequestModel(BaseModel):
 913    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 914    action: Optional[str] = Field(default=None, alias="Action")
 915    principal: Optional[str] = Field(default=None, alias="Principal")
 916    statement_id: Optional[str] = Field(default=None, alias="StatementId")
 917    condition: Optional[ConditionModel] = Field(default=None, alias="Condition")
 918    policy: Optional[str] = Field(default=None, alias="Policy")
 919
 920
 921class ConnectionHttpParametersModel(BaseModel):
 922    header_parameters: Optional[Sequence[ConnectionHeaderParameterModel]] = Field(
 923        default=None, alias="HeaderParameters"
 924    )
 925    query_string_parameters: Optional[
 926        Sequence[ConnectionQueryStringParameterModel]
 927    ] = Field(default=None, alias="QueryStringParameters")
 928    body_parameters: Optional[Sequence[ConnectionBodyParameterModel]] = Field(
 929        default=None, alias="BodyParameters"
 930    )
 931
 932
 933class ListConnectionsResponseModel(BaseModel):
 934    connections: List[ConnectionModel] = Field(alias="Connections")
 935    next_token: str = Field(alias="NextToken")
 936    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 937
 938
 939class CreateEventBusRequestModel(BaseModel):
 940    name: str = Field(alias="Name")
 941    event_source_name: Optional[str] = Field(default=None, alias="EventSourceName")
 942    tags: Optional[Sequence[TagModel]] = Field(default=None, alias="Tags")
 943
 944
 945class ListTagsForResourceResponseModel(BaseModel):
 946    tags: List[TagModel] = Field(alias="Tags")
 947    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 948
 949
 950class PutRuleRequestModel(BaseModel):
 951    name: str = Field(alias="Name")
 952    schedule_expression: Optional[str] = Field(default=None, alias="ScheduleExpression")
 953    event_pattern: Optional[str] = Field(default=None, alias="EventPattern")
 954    state: Optional[Literal["DISABLED", "ENABLED"]] = Field(default=None, alias="State")
 955    description: Optional[str] = Field(default=None, alias="Description")
 956    role_arn: Optional[str] = Field(default=None, alias="RoleArn")
 957    tags: Optional[Sequence[TagModel]] = Field(default=None, alias="Tags")
 958    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
 959
 960
 961class TagResourceRequestModel(BaseModel):
 962    resource_arn: str = Field(alias="ResourceARN")
 963    tags: Sequence[TagModel] = Field(alias="Tags")
 964
 965
 966class DescribeReplayResponseModel(BaseModel):
 967    replay_name: str = Field(alias="ReplayName")
 968    replay_arn: str = Field(alias="ReplayArn")
 969    description: str = Field(alias="Description")
 970    state: Literal[
 971        "CANCELLED", "CANCELLING", "COMPLETED", "FAILED", "RUNNING", "STARTING"
 972    ] = Field(alias="State")
 973    state_reason: str = Field(alias="StateReason")
 974    event_source_arn: str = Field(alias="EventSourceArn")
 975    destination: ReplayDestinationModel = Field(alias="Destination")
 976    event_start_time: datetime = Field(alias="EventStartTime")
 977    event_end_time: datetime = Field(alias="EventEndTime")
 978    event_last_replayed_time: datetime = Field(alias="EventLastReplayedTime")
 979    replay_start_time: datetime = Field(alias="ReplayStartTime")
 980    replay_end_time: datetime = Field(alias="ReplayEndTime")
 981    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 982
 983
 984class StartReplayRequestModel(BaseModel):
 985    replay_name: str = Field(alias="ReplayName")
 986    event_source_arn: str = Field(alias="EventSourceArn")
 987    event_start_time: Union[datetime, str] = Field(alias="EventStartTime")
 988    event_end_time: Union[datetime, str] = Field(alias="EventEndTime")
 989    destination: ReplayDestinationModel = Field(alias="Destination")
 990    description: Optional[str] = Field(default=None, alias="Description")
 991
 992
 993class ListEventBusesResponseModel(BaseModel):
 994    event_buses: List[EventBusModel] = Field(alias="EventBuses")
 995    next_token: str = Field(alias="NextToken")
 996    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
 997
 998
 999class ListEventSourcesResponseModel(BaseModel):
1000    event_sources: List[EventSourceModel] = Field(alias="EventSources")
1001    next_token: str = Field(alias="NextToken")
1002    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1003
1004
1005class FailoverConfigModel(BaseModel):
1006    primary: PrimaryModel = Field(alias="Primary")
1007    secondary: SecondaryModel = Field(alias="Secondary")
1008
1009
1010class ListPartnerEventSourceAccountsResponseModel(BaseModel):
1011    partner_event_source_accounts: List[PartnerEventSourceAccountModel] = Field(
1012        alias="PartnerEventSourceAccounts"
1013    )
1014    next_token: str = Field(alias="NextToken")
1015    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1016
1017
1018class ListPartnerEventSourcesResponseModel(BaseModel):
1019    partner_event_sources: List[PartnerEventSourceModel] = Field(
1020        alias="PartnerEventSources"
1021    )
1022    next_token: str = Field(alias="NextToken")
1023    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1024
1025
1026class ListReplaysResponseModel(BaseModel):
1027    replays: List[ReplayModel] = Field(alias="Replays")
1028    next_token: str = Field(alias="NextToken")
1029    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1030
1031
1032class ListRuleNamesByTargetRequestListRuleNamesByTargetPaginateModel(BaseModel):
1033    target_arn: str = Field(alias="TargetArn")
1034    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
1035    pagination_config: Optional[PaginatorConfigModel] = Field(
1036        default=None, alias="PaginationConfig"
1037    )
1038
1039
1040class ListRulesRequestListRulesPaginateModel(BaseModel):
1041    name_prefix: Optional[str] = Field(default=None, alias="NamePrefix")
1042    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
1043    pagination_config: Optional[PaginatorConfigModel] = Field(
1044        default=None, alias="PaginationConfig"
1045    )
1046
1047
1048class ListTargetsByRuleRequestListTargetsByRulePaginateModel(BaseModel):
1049    rule: str = Field(alias="Rule")
1050    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
1051    pagination_config: Optional[PaginatorConfigModel] = Field(
1052        default=None, alias="PaginationConfig"
1053    )
1054
1055
1056class ListRulesResponseModel(BaseModel):
1057    rules: List[RuleModel] = Field(alias="Rules")
1058    next_token: str = Field(alias="NextToken")
1059    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1060
1061
1062class PutEventsRequestModel(BaseModel):
1063    entries: Sequence[PutEventsRequestEntryModel] = Field(alias="Entries")
1064    endpoint_id: Optional[str] = Field(default=None, alias="EndpointId")
1065
1066
1067class PutEventsResponseModel(BaseModel):
1068    failed_entry_count: int = Field(alias="FailedEntryCount")
1069    entries: List[PutEventsResultEntryModel] = Field(alias="Entries")
1070    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1071
1072
1073class PutPartnerEventsRequestModel(BaseModel):
1074    entries: Sequence[PutPartnerEventsRequestEntryModel] = Field(alias="Entries")
1075
1076
1077class PutPartnerEventsResponseModel(BaseModel):
1078    failed_entry_count: int = Field(alias="FailedEntryCount")
1079    entries: List[PutPartnerEventsResultEntryModel] = Field(alias="Entries")
1080    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1081
1082
1083class PutTargetsResponseModel(BaseModel):
1084    failed_entry_count: int = Field(alias="FailedEntryCount")
1085    failed_entries: List[PutTargetsResultEntryModel] = Field(alias="FailedEntries")
1086    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1087
1088
1089class RemoveTargetsResponseModel(BaseModel):
1090    failed_entry_count: int = Field(alias="FailedEntryCount")
1091    failed_entries: List[RemoveTargetsResultEntryModel] = Field(alias="FailedEntries")
1092    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1093
1094
1095class RunCommandParametersModel(BaseModel):
1096    run_command_targets: List[RunCommandTargetModel] = Field(alias="RunCommandTargets")
1097
1098
1099class SageMakerPipelineParametersModel(BaseModel):
1100    pipeline_parameter_list: Optional[List[SageMakerPipelineParameterModel]] = Field(
1101        default=None, alias="PipelineParameterList"
1102    )
1103
1104
1105class EcsParametersModel(BaseModel):
1106    task_definition_arn: str = Field(alias="TaskDefinitionArn")
1107    task_count: Optional[int] = Field(default=None, alias="TaskCount")
1108    launch_type: Optional[Literal["EC2", "EXTERNAL", "FARGATE"]] = Field(
1109        default=None, alias="LaunchType"
1110    )
1111    network_configuration: Optional[NetworkConfigurationModel] = Field(
1112        default=None, alias="NetworkConfiguration"
1113    )
1114    platform_version: Optional[str] = Field(default=None, alias="PlatformVersion")
1115    group: Optional[str] = Field(default=None, alias="Group")
1116    capacity_provider_strategy: Optional[
1117        List[CapacityProviderStrategyItemModel]
1118    ] = Field(default=None, alias="CapacityProviderStrategy")
1119    enable_ecs_managed_tags: Optional[bool] = Field(
1120        default=None, alias="EnableECSManagedTags"
1121    )
1122    enable_execute_command: Optional[bool] = Field(
1123        default=None, alias="EnableExecuteCommand"
1124    )
1125    placement_constraints: Optional[List[PlacementConstraintModel]] = Field(
1126        default=None, alias="PlacementConstraints"
1127    )
1128    placement_strategy: Optional[List[PlacementStrategyModel]] = Field(
1129        default=None, alias="PlacementStrategy"
1130    )
1131    propagate_tags: Optional[Literal["TASK_DEFINITION"]] = Field(
1132        default=None, alias="PropagateTags"
1133    )
1134    reference_id: Optional[str] = Field(default=None, alias="ReferenceId")
1135    tags: Optional[List[TagModel]] = Field(default=None, alias="Tags")
1136
1137
1138class ConnectionOAuthResponseParametersModel(BaseModel):
1139    client_parameters: Optional[ConnectionOAuthClientResponseParametersModel] = Field(
1140        default=None, alias="ClientParameters"
1141    )
1142    authorization_endpoint: Optional[str] = Field(
1143        default=None, alias="AuthorizationEndpoint"
1144    )
1145    http_method: Optional[Literal["GET", "POST", "PUT"]] = Field(
1146        default=None, alias="HttpMethod"
1147    )
1148    oauth_http_parameters: Optional[ConnectionHttpParametersModel] = Field(
1149        default=None, alias="OAuthHttpParameters"
1150    )
1151
1152
1153class CreateConnectionOAuthRequestParametersModel(BaseModel):
1154    client_parameters: CreateConnectionOAuthClientRequestParametersModel = Field(
1155        alias="ClientParameters"
1156    )
1157    authorization_endpoint: str = Field(alias="AuthorizationEndpoint")
1158    http_method: Literal["GET", "POST", "PUT"] = Field(alias="HttpMethod")
1159    oauth_http_parameters: Optional[ConnectionHttpParametersModel] = Field(
1160        default=None, alias="OAuthHttpParameters"
1161    )
1162
1163
1164class UpdateConnectionOAuthRequestParametersModel(BaseModel):
1165    client_parameters: Optional[
1166        UpdateConnectionOAuthClientRequestParametersModel
1167    ] = Field(default=None, alias="ClientParameters")
1168    authorization_endpoint: Optional[str] = Field(
1169        default=None, alias="AuthorizationEndpoint"
1170    )
1171    http_method: Optional[Literal["GET", "POST", "PUT"]] = Field(
1172        default=None, alias="HttpMethod"
1173    )
1174    oauth_http_parameters: Optional[ConnectionHttpParametersModel] = Field(
1175        default=None, alias="OAuthHttpParameters"
1176    )
1177
1178
1179class RoutingConfigModel(BaseModel):
1180    failover_config: FailoverConfigModel = Field(alias="FailoverConfig")
1181
1182
1183class TargetModel(BaseModel):
1184    id: str = Field(alias="Id")
1185    arn: str = Field(alias="Arn")
1186    role_arn: Optional[str] = Field(default=None, alias="RoleArn")
1187    input: Optional[str] = Field(default=None, alias="Input")
1188    input_path: Optional[str] = Field(default=None, alias="InputPath")
1189    input_transformer: Optional[InputTransformerModel] = Field(
1190        default=None, alias="InputTransformer"
1191    )
1192    kinesis_parameters: Optional[KinesisParametersModel] = Field(
1193        default=None, alias="KinesisParameters"
1194    )
1195    run_command_parameters: Optional[RunCommandParametersModel] = Field(
1196        default=None, alias="RunCommandParameters"
1197    )
1198    ecs_parameters: Optional[EcsParametersModel] = Field(
1199        default=None, alias="EcsParameters"
1200    )
1201    batch_parameters: Optional[BatchParametersModel] = Field(
1202        default=None, alias="BatchParameters"
1203    )
1204    sqs_parameters: Optional[SqsParametersModel] = Field(
1205        default=None, alias="SqsParameters"
1206    )
1207    http_parameters: Optional[HttpParametersModel] = Field(
1208        default=None, alias="HttpParameters"
1209    )
1210    redshift_data_parameters: Optional[RedshiftDataParametersModel] = Field(
1211        default=None, alias="RedshiftDataParameters"
1212    )
1213    sage_maker_pipeline_parameters: Optional[SageMakerPipelineParametersModel] = Field(
1214        default=None, alias="SageMakerPipelineParameters"
1215    )
1216    dead_letter_config: Optional[DeadLetterConfigModel] = Field(
1217        default=None, alias="DeadLetterConfig"
1218    )
1219    retry_policy: Optional[RetryPolicyModel] = Field(default=None, alias="RetryPolicy")
1220
1221
1222class ConnectionAuthResponseParametersModel(BaseModel):
1223    basic_auth_parameters: Optional[ConnectionBasicAuthResponseParametersModel] = Field(
1224        default=None, alias="BasicAuthParameters"
1225    )
1226    oauth_parameters: Optional[ConnectionOAuthResponseParametersModel] = Field(
1227        default=None, alias="OAuthParameters"
1228    )
1229    api_key_auth_parameters: Optional[
1230        ConnectionApiKeyAuthResponseParametersModel
1231    ] = Field(default=None, alias="ApiKeyAuthParameters")
1232    invocation_http_parameters: Optional[ConnectionHttpParametersModel] = Field(
1233        default=None, alias="InvocationHttpParameters"
1234    )
1235
1236
1237class CreateConnectionAuthRequestParametersModel(BaseModel):
1238    basic_auth_parameters: Optional[
1239        CreateConnectionBasicAuthRequestParametersModel
1240    ] = Field(default=None, alias="BasicAuthParameters")
1241    oauth_parameters: Optional[CreateConnectionOAuthRequestParametersModel] = Field(
1242        default=None, alias="OAuthParameters"
1243    )
1244    api_key_auth_parameters: Optional[
1245        CreateConnectionApiKeyAuthRequestParametersModel
1246    ] = Field(default=None, alias="ApiKeyAuthParameters")
1247    invocation_http_parameters: Optional[ConnectionHttpParametersModel] = Field(
1248        default=None, alias="InvocationHttpParameters"
1249    )
1250
1251
1252class UpdateConnectionAuthRequestParametersModel(BaseModel):
1253    basic_auth_parameters: Optional[
1254        UpdateConnectionBasicAuthRequestParametersModel
1255    ] = Field(default=None, alias="BasicAuthParameters")
1256    oauth_parameters: Optional[UpdateConnectionOAuthRequestParametersModel] = Field(
1257        default=None, alias="OAuthParameters"
1258    )
1259    api_key_auth_parameters: Optional[
1260        UpdateConnectionApiKeyAuthRequestParametersModel
1261    ] = Field(default=None, alias="ApiKeyAuthParameters")
1262    invocation_http_parameters: Optional[ConnectionHttpParametersModel] = Field(
1263        default=None, alias="InvocationHttpParameters"
1264    )
1265
1266
1267class CreateEndpointRequestModel(BaseModel):
1268    name: str = Field(alias="Name")
1269    routing_config: RoutingConfigModel = Field(alias="RoutingConfig")
1270    event_buses: Sequence[EndpointEventBusModel] = Field(alias="EventBuses")
1271    description: Optional[str] = Field(default=None, alias="Description")
1272    replication_config: Optional[ReplicationConfigModel] = Field(
1273        default=None, alias="ReplicationConfig"
1274    )
1275    role_arn: Optional[str] = Field(default=None, alias="RoleArn")
1276
1277
1278class CreateEndpointResponseModel(BaseModel):
1279    name: str = Field(alias="Name")
1280    arn: str = Field(alias="Arn")
1281    routing_config: RoutingConfigModel = Field(alias="RoutingConfig")
1282    replication_config: ReplicationConfigModel = Field(alias="ReplicationConfig")
1283    event_buses: List[EndpointEventBusModel] = Field(alias="EventBuses")
1284    role_arn: str = Field(alias="RoleArn")
1285    state: Literal[
1286        "ACTIVE",
1287        "CREATE_FAILED",
1288        "CREATING",
1289        "DELETE_FAILED",
1290        "DELETING",
1291        "UPDATE_FAILED",
1292        "UPDATING",
1293    ] = Field(alias="State")
1294    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1295
1296
1297class DescribeEndpointResponseModel(BaseModel):
1298    name: str = Field(alias="Name")
1299    description: str = Field(alias="Description")
1300    arn: str = Field(alias="Arn")
1301    routing_config: RoutingConfigModel = Field(alias="RoutingConfig")
1302    replication_config: ReplicationConfigModel = Field(alias="ReplicationConfig")
1303    event_buses: List[EndpointEventBusModel] = Field(alias="EventBuses")
1304    role_arn: str = Field(alias="RoleArn")
1305    endpoint_id: str = Field(alias="EndpointId")
1306    endpoint_url: str = Field(alias="EndpointUrl")
1307    state: Literal[
1308        "ACTIVE",
1309        "CREATE_FAILED",
1310        "CREATING",
1311        "DELETE_FAILED",
1312        "DELETING",
1313        "UPDATE_FAILED",
1314        "UPDATING",
1315    ] = Field(alias="State")
1316    state_reason: str = Field(alias="StateReason")
1317    creation_time: datetime = Field(alias="CreationTime")
1318    last_modified_time: datetime = Field(alias="LastModifiedTime")
1319    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1320
1321
1322class EndpointModel(BaseModel):
1323    name: Optional[str] = Field(default=None, alias="Name")
1324    description: Optional[str] = Field(default=None, alias="Description")
1325    arn: Optional[str] = Field(default=None, alias="Arn")
1326    routing_config: Optional[RoutingConfigModel] = Field(
1327        default=None, alias="RoutingConfig"
1328    )
1329    replication_config: Optional[ReplicationConfigModel] = Field(
1330        default=None, alias="ReplicationConfig"
1331    )
1332    event_buses: Optional[List[EndpointEventBusModel]] = Field(
1333        default=None, alias="EventBuses"
1334    )
1335    role_arn: Optional[str] = Field(default=None, alias="RoleArn")
1336    endpoint_id: Optional[str] = Field(default=None, alias="EndpointId")
1337    endpoint_url: Optional[str] = Field(default=None, alias="EndpointUrl")
1338    state: Optional[
1339        Literal[
1340            "ACTIVE",
1341            "CREATE_FAILED",
1342            "CREATING",
1343            "DELETE_FAILED",
1344            "DELETING",
1345            "UPDATE_FAILED",
1346            "UPDATING",
1347        ]
1348    ] = Field(default=None, alias="State")
1349    state_reason: Optional[str] = Field(default=None, alias="StateReason")
1350    creation_time: Optional[datetime] = Field(default=None, alias="CreationTime")
1351    last_modified_time: Optional[datetime] = Field(
1352        default=None, alias="LastModifiedTime"
1353    )
1354
1355
1356class UpdateEndpointRequestModel(BaseModel):
1357    name: str = Field(alias="Name")
1358    description: Optional[str] = Field(default=None, alias="Description")
1359    routing_config: Optional[RoutingConfigModel] = Field(
1360        default=None, alias="RoutingConfig"
1361    )
1362    replication_config: Optional[ReplicationConfigModel] = Field(
1363        default=None, alias="ReplicationConfig"
1364    )
1365    event_buses: Optional[Sequence[EndpointEventBusModel]] = Field(
1366        default=None, alias="EventBuses"
1367    )
1368    role_arn: Optional[str] = Field(default=None, alias="RoleArn")
1369
1370
1371class UpdateEndpointResponseModel(BaseModel):
1372    name: str = Field(alias="Name")
1373    arn: str = Field(alias="Arn")
1374    routing_config: RoutingConfigModel = Field(alias="RoutingConfig")
1375    replication_config: ReplicationConfigModel = Field(alias="ReplicationConfig")
1376    event_buses: List[EndpointEventBusModel] = Field(alias="EventBuses")
1377    role_arn: str = Field(alias="RoleArn")
1378    endpoint_id: str = Field(alias="EndpointId")
1379    endpoint_url: str = Field(alias="EndpointUrl")
1380    state: Literal[
1381        "ACTIVE",
1382        "CREATE_FAILED",
1383        "CREATING",
1384        "DELETE_FAILED",
1385        "DELETING",
1386        "UPDATE_FAILED",
1387        "UPDATING",
1388    ] = Field(alias="State")
1389    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1390
1391
1392class ListTargetsByRuleResponseModel(BaseModel):
1393    targets: List[TargetModel] = Field(alias="Targets")
1394    next_token: str = Field(alias="NextToken")
1395    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1396
1397
1398class PutTargetsRequestModel(BaseModel):
1399    rule: str = Field(alias="Rule")
1400    targets: Sequence[TargetModel] = Field(alias="Targets")
1401    event_bus_name: Optional[str] = Field(default=None, alias="EventBusName")
1402
1403
1404class DescribeConnectionResponseModel(BaseModel):
1405    connection_arn: str = Field(alias="ConnectionArn")
1406    name: str = Field(alias="Name")
1407    description: str = Field(alias="Description")
1408    connection_state: Literal[
1409        "AUTHORIZED",
1410        "AUTHORIZING",
1411        "CREATING",
1412        "DEAUTHORIZED",
1413        "DEAUTHORIZING",
1414        "DELETING",
1415        "UPDATING",
1416    ] = Field(alias="ConnectionState")
1417    state_reason: str = Field(alias="StateReason")
1418    authorization_type: Literal["API_KEY", "BASIC", "OAUTH_CLIENT_CREDENTIALS"] = Field(
1419        alias="AuthorizationType"
1420    )
1421    secret_arn: str = Field(alias="SecretArn")
1422    auth_parameters: ConnectionAuthResponseParametersModel = Field(
1423        alias="AuthParameters"
1424    )
1425    creation_time: datetime = Field(alias="CreationTime")
1426    last_modified_time: datetime = Field(alias="LastModifiedTime")
1427    last_authorized_time: datetime = Field(alias="LastAuthorizedTime")
1428    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")
1429
1430
1431class CreateConnectionRequestModel(BaseModel):
1432    name: str = Field(alias="Name")
1433    authorization_type: Literal["API_KEY", "BASIC", "OAUTH_CLIENT_CREDENTIALS"] = Field(
1434        alias="AuthorizationType"
1435    )
1436    auth_parameters: CreateConnectionAuthRequestParametersModel = Field(
1437        alias="AuthParameters"
1438    )
1439    description: Optional[str] = Field(default=None, alias="Description")
1440
1441
1442class UpdateConnectionRequestModel(BaseModel):
1443    name: str = Field(alias="Name")
1444    description: Optional[str] = Field(default=None, alias="Description")
1445    authorization_type: Optional[
1446        Literal["API_KEY", "BASIC", "OAUTH_CLIENT_CREDENTIALS"]
1447    ] = Field(default=None, alias="AuthorizationType")
1448    auth_parameters: Optional[UpdateConnectionAuthRequestParametersModel] = Field(
1449        default=None, alias="AuthParameters"
1450    )
1451
1452
1453class ListEndpointsResponseModel(BaseModel):
1454    endpoints: List[EndpointModel] = Field(alias="Endpoints")
1455    next_token: str = Field(alias="NextToken")
1456    response_metadata: ResponseMetadataModel = Field(alias="ResponseMetadata")