public createMySQLEndpoint()

in lib/dms-replication.ts [111:128]

• 17 lines of code
• 3 McCabe index (conditional complexity)

  public createMySQLEndpoint(
    endpointIdentifier: string,
    endpointType: 'source' | 'target',
    secretId: string,
    secretAccessRoleArn?: string
  ): CfnEndpoint {
    const target_extra_conn_attr = 'parallelLoadThreads=1 maxFileSize=512';
    const roleArn = secretAccessRoleArn == null ? this.role.roleArn : secretAccessRoleArn
    const endpoint = new CfnEndpoint(this, 'dms-' + endpointType + '-' + endpointIdentifier, {
      endpointIdentifier: endpointIdentifier,
      endpointType: endpointType,
      engineName: 'mysql',
      mySqlSettings: { secretsManagerAccessRoleArn: secretAccessRoleArn, secretsManagerSecretId: secretId },
      extraConnectionAttributes: endpointType == 'source' ? 'parallelLoadThreads=1' : target_extra_conn_attr,
    });

    return endpoint;
  }