in syndicate/core/resources/processors_mapping.py [0:0]
def create_handlers(self):
return {
IAM_POLICY:
self.resources_provider.iam().create_policies,
IAM_ROLE:
self.resources_provider.iam().create_roles,
LAMBDA_TYPE:
self.resources_provider.lambda_resource().create_lambda,
LAMBDA_LAYER_TYPE:
self.resources_provider.lambda_resource().create_lambda_layer,
DYNAMO_TABLE_TYPE:
self.resources_provider.dynamodb().create_tables,
CLOUD_WATCH_RULE_TYPE:
self.resources_provider.cw().create_cloud_watch_rule,
EVENT_BRIDGE_RULE_TYPE:
self.resources_provider.cw().create_cloud_watch_rule,
S3_BUCKET_TYPE:
self.resources_provider.s3().create_s3_bucket,
API_GATEWAY_TYPE:
self.resources_provider.api_gw().create_api_gateway,
API_GATEWAY_OAS_V3_TYPE:
self.resources_provider.api_gw().create_api_gateway_openapi,
WEB_SOCKET_API_GATEWAY_TYPE:
self.resources_provider.api_gw().create_web_socket_api_gateway,
COGNITO_USER_POOL_TYPE:
self.resources_provider.cognito_user_pool()
.create_cognito_user_pool,
COGNITO_FEDERATED_POOL_TYPE:
self.resources_provider.cognito_identity()
.create_cognito_identity_pool,
SNS_TOPIC_TYPE:
self.resources_provider.sns().create_sns_topic,
SNS_PLATFORM_APPLICATION_TYPE:
self.resources_provider.sns().create_sns_application,
SQS_QUEUE_TYPE:
self.resources_provider.sqs().create_sqs_queue,
CLOUD_WATCH_ALARM_TYPE:
self.resources_provider.cw_alarm().create_alarm,
EBS_TYPE:
self.resources_provider.ebs().create_ebs,
STEP_FUNCTION_TYPE:
self.resources_provider.step_functions().create_state_machine,
STATE_ACTIVITY_TYPE:
self.resources_provider.step_functions().create_activities,
KINESIS_STREAM_TYPE:
self.resources_provider.kinesis().create_kinesis_stream,
EC2_INSTANCE_TYPE:
self.resources_provider.ec2().create_ec2,
EC2_LAUNCH_TEMPLATE_TYPE:
self.resources_provider.ec2().create_launch_template,
BATCH_COMPENV_TYPE:
self.resources_provider.batch_compenv()
.create_compute_environment,
BATCH_JOBQUEUE_TYPE:
self.resources_provider.batch_jobqueue().create_job_queue,
BATCH_JOBDEF_TYPE:
self.resources_provider.batch_jobdef().register_job_definition,
DOCUMENTDB_CLUSTER_TYPE:
self.resources_provider.documentdb_cluster().create_db_cluster,
DOCUMENTDB_INSTANCE_TYPE:
self.resources_provider.documentdb_instance()
.create_db_instance,
DAX_CLUSTER_TYPE:
self.resources_provider.dax_cluster().create_cluster,
FIREHOSE_TYPE:
self.resources_provider.firehose().create_stream,
EVENT_BRIDGE_SCHEDULE_TYPE:
self.resources_provider.eventbridge_scheduler().create_schedule,
SWAGGER_UI_TYPE: self.resources_provider.swagger_ui().
create_update_swagger_ui,
APPSYNC_TYPE: self.resources_provider.appsync().create_graphql_api
}