DeleteEndpoint Go Example
// This example requires the Chilkat API to have been previously unlocked.
// See Global Unlock Sample for sample code.
rest := chilkat.NewRest()
var success bool
authAws := chilkat.NewAuthAws()
authAws.SetAccessKey("AWS_ACCESS_KEY")
authAws.SetSecretKey("AWS_SECRET_KEY")
// Don't forget to change the region to your particular region. (Also make the same change in the call to Connect below.)
authAws.SetRegion("us-west-2")
authAws.SetServiceName("dms")
// SetAuthAws causes Chilkat to automatically add the following headers: Authorization, X-Amz-Date
rest.SetAuthAws(authAws)
// URL: https://dms.us-west-2.amazonaws.com/
// Use the same region as specified above.
success = rest.Connect("dms.us-west-2.amazonaws.com",443,true,true)
if success != true {
fmt.Println("ConnectFailReason: ", rest.ConnectFailReason())
fmt.Println(rest.LastErrorText())
rest.DisposeRest()
authAws.DisposeAuthAws()
return
}
// The following code creates the JSON request body.
// The JSON created by this code is shown below.
// Use this online tool to generate code from sample JSON:
// Generate Code to Create JSON
json := chilkat.NewJsonObject()
json.UpdateString("EndpointArn","string")
// The JSON request body created by the above code:
// {
// "EndpointArn": "string"
// }
rest.AddHeader("Content-Type","application/x-amz-json-1.1")
rest.AddHeader("X-Amz-Target","AmazonDMSv20160101.DeleteEndpoint")
sbRequestBody := chilkat.NewStringBuilder()
json.EmitSb(sbRequestBody)
sbResponseBody := chilkat.NewStringBuilder()
success = rest.FullRequestSb("POST","/",sbRequestBody,sbResponseBody)
if success != true {
fmt.Println(rest.LastErrorText())
rest.DisposeRest()
authAws.DisposeAuthAws()
json.DisposeJsonObject()
sbRequestBody.DisposeStringBuilder()
sbResponseBody.DisposeStringBuilder()
return
}
respStatusCode := rest.ResponseStatusCode()
fmt.Println("response status code = ", respStatusCode)
if respStatusCode != 200 {
fmt.Println("Response Header:")
fmt.Println(rest.ResponseHeader())
fmt.Println("Response Body:")
fmt.Println(*sbResponseBody.GetAsString())
rest.DisposeRest()
authAws.DisposeAuthAws()
json.DisposeJsonObject()
sbRequestBody.DisposeStringBuilder()
sbResponseBody.DisposeStringBuilder()
return
}
jResp := chilkat.NewJsonObject()
jResp.LoadSb(sbResponseBody)
// The following code parses the JSON response.
// A sample JSON response is shown below the sample code.
// Use this online tool to generate parsing code from sample JSON:
// Generate Parsing Code from JSON
var intVal int
CertificateArn := jResp.StringOf("Endpoint.CertificateArn")
DatabaseName := jResp.StringOf("Endpoint.DatabaseName")
BucketName := jResp.StringOf("Endpoint.DmsTransferSettings.BucketName")
ServiceAccessRoleArn := jResp.StringOf("Endpoint.DmsTransferSettings.ServiceAccessRoleArn")
DocDbSettingsDatabaseName := jResp.StringOf("Endpoint.DocDbSettings.DatabaseName")
DocsToInvestigate := jResp.IntOf("Endpoint.DocDbSettings.DocsToInvestigate")
ExtractDocId := jResp.IntOf("Endpoint.DocDbSettings.ExtractDocId")
KmsKeyId := jResp.StringOf("Endpoint.DocDbSettings.KmsKeyId")
NestingLevel := jResp.StringOf("Endpoint.DocDbSettings.NestingLevel")
Password := jResp.StringOf("Endpoint.DocDbSettings.Password")
Port := jResp.IntOf("Endpoint.DocDbSettings.Port")
SecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.DocDbSettings.SecretsManagerAccessRoleArn")
SecretsManagerSecretId := jResp.StringOf("Endpoint.DocDbSettings.SecretsManagerSecretId")
ServerName := jResp.StringOf("Endpoint.DocDbSettings.ServerName")
Username := jResp.StringOf("Endpoint.DocDbSettings.Username")
DynamoDbSettingsServiceAccessRoleArn := jResp.StringOf("Endpoint.DynamoDbSettings.ServiceAccessRoleArn")
EndpointUri := jResp.StringOf("Endpoint.ElasticsearchSettings.EndpointUri")
ErrorRetryDuration := jResp.IntOf("Endpoint.ElasticsearchSettings.ErrorRetryDuration")
FullLoadErrorPercentage := jResp.IntOf("Endpoint.ElasticsearchSettings.FullLoadErrorPercentage")
ElasticsearchSettingsServiceAccessRoleArn := jResp.StringOf("Endpoint.ElasticsearchSettings.ServiceAccessRoleArn")
EndpointArn := jResp.StringOf("Endpoint.EndpointArn")
EndpointIdentifier := jResp.StringOf("Endpoint.EndpointIdentifier")
EndpointType := jResp.StringOf("Endpoint.EndpointType")
EngineDisplayName := jResp.StringOf("Endpoint.EngineDisplayName")
EngineName := jResp.StringOf("Endpoint.EngineName")
ExternalId := jResp.StringOf("Endpoint.ExternalId")
ExternalTableDefinition := jResp.StringOf("Endpoint.ExternalTableDefinition")
ExtraConnectionAttributes := jResp.StringOf("Endpoint.ExtraConnectionAttributes")
AfterConnectScript := jResp.StringOf("Endpoint.GcpMySQLSettings.AfterConnectScript")
CleanSourceMetadataOnMismatch := jResp.IntOf("Endpoint.GcpMySQLSettings.CleanSourceMetadataOnMismatch")
GcpMySQLSettingsDatabaseName := jResp.StringOf("Endpoint.GcpMySQLSettings.DatabaseName")
EventsPollInterval := jResp.IntOf("Endpoint.GcpMySQLSettings.EventsPollInterval")
MaxFileSize := jResp.IntOf("Endpoint.GcpMySQLSettings.MaxFileSize")
ParallelLoadThreads := jResp.IntOf("Endpoint.GcpMySQLSettings.ParallelLoadThreads")
GcpMySQLSettingsPassword := jResp.StringOf("Endpoint.GcpMySQLSettings.Password")
GcpMySQLSettingsPort := jResp.IntOf("Endpoint.GcpMySQLSettings.Port")
GcpMySQLSettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.GcpMySQLSettings.SecretsManagerAccessRoleArn")
GcpMySQLSettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.GcpMySQLSettings.SecretsManagerSecretId")
GcpMySQLSettingsServerName := jResp.StringOf("Endpoint.GcpMySQLSettings.ServerName")
ServerTimezone := jResp.StringOf("Endpoint.GcpMySQLSettings.ServerTimezone")
TargetDbType := jResp.StringOf("Endpoint.GcpMySQLSettings.TargetDbType")
GcpMySQLSettingsUsername := jResp.StringOf("Endpoint.GcpMySQLSettings.Username")
CurrentLsn := jResp.StringOf("Endpoint.IBMDb2Settings.CurrentLsn")
IBMDb2SettingsDatabaseName := jResp.StringOf("Endpoint.IBMDb2Settings.DatabaseName")
MaxKBytesPerRead := jResp.IntOf("Endpoint.IBMDb2Settings.MaxKBytesPerRead")
IBMDb2SettingsPassword := jResp.StringOf("Endpoint.IBMDb2Settings.Password")
IBMDb2SettingsPort := jResp.IntOf("Endpoint.IBMDb2Settings.Port")
IBMDb2SettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.IBMDb2Settings.SecretsManagerAccessRoleArn")
IBMDb2SettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.IBMDb2Settings.SecretsManagerSecretId")
IBMDb2SettingsServerName := jResp.StringOf("Endpoint.IBMDb2Settings.ServerName")
SetDataCaptureChanges := jResp.IntOf("Endpoint.IBMDb2Settings.SetDataCaptureChanges")
IBMDb2SettingsUsername := jResp.StringOf("Endpoint.IBMDb2Settings.Username")
Broker := jResp.StringOf("Endpoint.KafkaSettings.Broker")
IncludeControlDetails := jResp.IntOf("Endpoint.KafkaSettings.IncludeControlDetails")
IncludeNullAndEmpty := jResp.IntOf("Endpoint.KafkaSettings.IncludeNullAndEmpty")
IncludePartitionValue := jResp.IntOf("Endpoint.KafkaSettings.IncludePartitionValue")
IncludeTableAlterOperations := jResp.IntOf("Endpoint.KafkaSettings.IncludeTableAlterOperations")
IncludeTransactionDetails := jResp.IntOf("Endpoint.KafkaSettings.IncludeTransactionDetails")
MessageFormat := jResp.StringOf("Endpoint.KafkaSettings.MessageFormat")
MessageMaxBytes := jResp.IntOf("Endpoint.KafkaSettings.MessageMaxBytes")
NoHexPrefix := jResp.IntOf("Endpoint.KafkaSettings.NoHexPrefix")
PartitionIncludeSchemaTable := jResp.IntOf("Endpoint.KafkaSettings.PartitionIncludeSchemaTable")
SaslPassword := jResp.StringOf("Endpoint.KafkaSettings.SaslPassword")
SaslUsername := jResp.StringOf("Endpoint.KafkaSettings.SaslUsername")
SecurityProtocol := jResp.StringOf("Endpoint.KafkaSettings.SecurityProtocol")
SslCaCertificateArn := jResp.StringOf("Endpoint.KafkaSettings.SslCaCertificateArn")
SslClientCertificateArn := jResp.StringOf("Endpoint.KafkaSettings.SslClientCertificateArn")
SslClientKeyArn := jResp.StringOf("Endpoint.KafkaSettings.SslClientKeyArn")
SslClientKeyPassword := jResp.StringOf("Endpoint.KafkaSettings.SslClientKeyPassword")
Topic := jResp.StringOf("Endpoint.KafkaSettings.Topic")
KinesisSettingsIncludeControlDetails := jResp.IntOf("Endpoint.KinesisSettings.IncludeControlDetails")
KinesisSettingsIncludeNullAndEmpty := jResp.IntOf("Endpoint.KinesisSettings.IncludeNullAndEmpty")
KinesisSettingsIncludePartitionValue := jResp.IntOf("Endpoint.KinesisSettings.IncludePartitionValue")
KinesisSettingsIncludeTableAlterOperations := jResp.IntOf("Endpoint.KinesisSettings.IncludeTableAlterOperations")
KinesisSettingsIncludeTransactionDetails := jResp.IntOf("Endpoint.KinesisSettings.IncludeTransactionDetails")
KinesisSettingsMessageFormat := jResp.StringOf("Endpoint.KinesisSettings.MessageFormat")
KinesisSettingsNoHexPrefix := jResp.IntOf("Endpoint.KinesisSettings.NoHexPrefix")
KinesisSettingsPartitionIncludeSchemaTable := jResp.IntOf("Endpoint.KinesisSettings.PartitionIncludeSchemaTable")
KinesisSettingsServiceAccessRoleArn := jResp.StringOf("Endpoint.KinesisSettings.ServiceAccessRoleArn")
StreamArn := jResp.StringOf("Endpoint.KinesisSettings.StreamArn")
EndpointKmsKeyId := jResp.StringOf("Endpoint.KmsKeyId")
BcpPacketSize := jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.BcpPacketSize")
ControlTablesFileGroup := jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.ControlTablesFileGroup")
MicrosoftSQLServerSettingsDatabaseName := jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.DatabaseName")
MicrosoftSQLServerSettingsPassword := jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.Password")
MicrosoftSQLServerSettingsPort := jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.Port")
QuerySingleAlwaysOnNode := jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.QuerySingleAlwaysOnNode")
ReadBackupOnly := jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.ReadBackupOnly")
SafeguardPolicy := jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SafeguardPolicy")
MicrosoftSQLServerSettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SecretsManagerAccessRoleArn")
MicrosoftSQLServerSettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.SecretsManagerSecretId")
MicrosoftSQLServerSettingsServerName := jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.ServerName")
UseBcpFullLoad := jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.UseBcpFullLoad")
MicrosoftSQLServerSettingsUsername := jResp.StringOf("Endpoint.MicrosoftSQLServerSettings.Username")
UseThirdPartyBackupDevice := jResp.IntOf("Endpoint.MicrosoftSQLServerSettings.UseThirdPartyBackupDevice")
AuthMechanism := jResp.StringOf("Endpoint.MongoDbSettings.AuthMechanism")
AuthSource := jResp.StringOf("Endpoint.MongoDbSettings.AuthSource")
AuthType := jResp.StringOf("Endpoint.MongoDbSettings.AuthType")
MongoDbSettingsDatabaseName := jResp.StringOf("Endpoint.MongoDbSettings.DatabaseName")
MongoDbSettingsDocsToInvestigate := jResp.StringOf("Endpoint.MongoDbSettings.DocsToInvestigate")
MongoDbSettingsExtractDocId := jResp.StringOf("Endpoint.MongoDbSettings.ExtractDocId")
MongoDbSettingsKmsKeyId := jResp.StringOf("Endpoint.MongoDbSettings.KmsKeyId")
MongoDbSettingsNestingLevel := jResp.StringOf("Endpoint.MongoDbSettings.NestingLevel")
MongoDbSettingsPassword := jResp.StringOf("Endpoint.MongoDbSettings.Password")
MongoDbSettingsPort := jResp.IntOf("Endpoint.MongoDbSettings.Port")
MongoDbSettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.MongoDbSettings.SecretsManagerAccessRoleArn")
MongoDbSettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.MongoDbSettings.SecretsManagerSecretId")
MongoDbSettingsServerName := jResp.StringOf("Endpoint.MongoDbSettings.ServerName")
MongoDbSettingsUsername := jResp.StringOf("Endpoint.MongoDbSettings.Username")
MySQLSettingsAfterConnectScript := jResp.StringOf("Endpoint.MySQLSettings.AfterConnectScript")
MySQLSettingsCleanSourceMetadataOnMismatch := jResp.IntOf("Endpoint.MySQLSettings.CleanSourceMetadataOnMismatch")
MySQLSettingsDatabaseName := jResp.StringOf("Endpoint.MySQLSettings.DatabaseName")
MySQLSettingsEventsPollInterval := jResp.IntOf("Endpoint.MySQLSettings.EventsPollInterval")
MySQLSettingsMaxFileSize := jResp.IntOf("Endpoint.MySQLSettings.MaxFileSize")
MySQLSettingsParallelLoadThreads := jResp.IntOf("Endpoint.MySQLSettings.ParallelLoadThreads")
MySQLSettingsPassword := jResp.StringOf("Endpoint.MySQLSettings.Password")
MySQLSettingsPort := jResp.IntOf("Endpoint.MySQLSettings.Port")
MySQLSettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.MySQLSettings.SecretsManagerAccessRoleArn")
MySQLSettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.MySQLSettings.SecretsManagerSecretId")
MySQLSettingsServerName := jResp.StringOf("Endpoint.MySQLSettings.ServerName")
MySQLSettingsServerTimezone := jResp.StringOf("Endpoint.MySQLSettings.ServerTimezone")
MySQLSettingsTargetDbType := jResp.StringOf("Endpoint.MySQLSettings.TargetDbType")
MySQLSettingsUsername := jResp.StringOf("Endpoint.MySQLSettings.Username")
NeptuneSettingsErrorRetryDuration := jResp.IntOf("Endpoint.NeptuneSettings.ErrorRetryDuration")
IamAuthEnabled := jResp.IntOf("Endpoint.NeptuneSettings.IamAuthEnabled")
NeptuneSettingsMaxFileSize := jResp.IntOf("Endpoint.NeptuneSettings.MaxFileSize")
MaxRetryCount := jResp.IntOf("Endpoint.NeptuneSettings.MaxRetryCount")
S3BucketFolder := jResp.StringOf("Endpoint.NeptuneSettings.S3BucketFolder")
S3BucketName := jResp.StringOf("Endpoint.NeptuneSettings.S3BucketName")
NeptuneSettingsServiceAccessRoleArn := jResp.StringOf("Endpoint.NeptuneSettings.ServiceAccessRoleArn")
AccessAlternateDirectly := jResp.IntOf("Endpoint.OracleSettings.AccessAlternateDirectly")
AdditionalArchivedLogDestId := jResp.IntOf("Endpoint.OracleSettings.AdditionalArchivedLogDestId")
AddSupplementalLogging := jResp.IntOf("Endpoint.OracleSettings.AddSupplementalLogging")
AllowSelectNestedTables := jResp.IntOf("Endpoint.OracleSettings.AllowSelectNestedTables")
ArchivedLogDestId := jResp.IntOf("Endpoint.OracleSettings.ArchivedLogDestId")
ArchivedLogsOnly := jResp.IntOf("Endpoint.OracleSettings.ArchivedLogsOnly")
AsmPassword := jResp.StringOf("Endpoint.OracleSettings.AsmPassword")
AsmServer := jResp.StringOf("Endpoint.OracleSettings.AsmServer")
AsmUser := jResp.StringOf("Endpoint.OracleSettings.AsmUser")
CharLengthSemantics := jResp.StringOf("Endpoint.OracleSettings.CharLengthSemantics")
OracleSettingsDatabaseName := jResp.StringOf("Endpoint.OracleSettings.DatabaseName")
DirectPathNoLog := jResp.IntOf("Endpoint.OracleSettings.DirectPathNoLog")
DirectPathParallelLoad := jResp.IntOf("Endpoint.OracleSettings.DirectPathParallelLoad")
EnableHomogenousTablespace := jResp.IntOf("Endpoint.OracleSettings.EnableHomogenousTablespace")
FailTasksOnLobTruncation := jResp.IntOf("Endpoint.OracleSettings.FailTasksOnLobTruncation")
NumberDatatypeScale := jResp.IntOf("Endpoint.OracleSettings.NumberDatatypeScale")
OraclePathPrefix := jResp.StringOf("Endpoint.OracleSettings.OraclePathPrefix")
ParallelAsmReadThreads := jResp.IntOf("Endpoint.OracleSettings.ParallelAsmReadThreads")
OracleSettingsPassword := jResp.StringOf("Endpoint.OracleSettings.Password")
OracleSettingsPort := jResp.IntOf("Endpoint.OracleSettings.Port")
ReadAheadBlocks := jResp.IntOf("Endpoint.OracleSettings.ReadAheadBlocks")
ReadTableSpaceName := jResp.IntOf("Endpoint.OracleSettings.ReadTableSpaceName")
ReplacePathPrefix := jResp.IntOf("Endpoint.OracleSettings.ReplacePathPrefix")
RetryInterval := jResp.IntOf("Endpoint.OracleSettings.RetryInterval")
OracleSettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.OracleSettings.SecretsManagerAccessRoleArn")
SecretsManagerOracleAsmAccessRoleArn := jResp.StringOf("Endpoint.OracleSettings.SecretsManagerOracleAsmAccessRoleArn")
SecretsManagerOracleAsmSecretId := jResp.StringOf("Endpoint.OracleSettings.SecretsManagerOracleAsmSecretId")
OracleSettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.OracleSettings.SecretsManagerSecretId")
SecurityDbEncryption := jResp.StringOf("Endpoint.OracleSettings.SecurityDbEncryption")
SecurityDbEncryptionName := jResp.StringOf("Endpoint.OracleSettings.SecurityDbEncryptionName")
OracleSettingsServerName := jResp.StringOf("Endpoint.OracleSettings.ServerName")
SpatialDataOptionToGeoJsonFunctionName := jResp.StringOf("Endpoint.OracleSettings.SpatialDataOptionToGeoJsonFunctionName")
StandbyDelayTime := jResp.IntOf("Endpoint.OracleSettings.StandbyDelayTime")
UseAlternateFolderForOnline := jResp.IntOf("Endpoint.OracleSettings.UseAlternateFolderForOnline")
UseBFile := jResp.IntOf("Endpoint.OracleSettings.UseBFile")
UseDirectPathFullLoad := jResp.IntOf("Endpoint.OracleSettings.UseDirectPathFullLoad")
UseLogminerReader := jResp.IntOf("Endpoint.OracleSettings.UseLogminerReader")
UsePathPrefix := jResp.StringOf("Endpoint.OracleSettings.UsePathPrefix")
OracleSettingsUsername := jResp.StringOf("Endpoint.OracleSettings.Username")
EndpointPort := jResp.IntOf("Endpoint.Port")
PostgreSQLSettingsAfterConnectScript := jResp.StringOf("Endpoint.PostgreSQLSettings.AfterConnectScript")
CaptureDdls := jResp.IntOf("Endpoint.PostgreSQLSettings.CaptureDdls")
PostgreSQLSettingsDatabaseName := jResp.StringOf("Endpoint.PostgreSQLSettings.DatabaseName")
DdlArtifactsSchema := jResp.StringOf("Endpoint.PostgreSQLSettings.DdlArtifactsSchema")
ExecuteTimeout := jResp.IntOf("Endpoint.PostgreSQLSettings.ExecuteTimeout")
PostgreSQLSettingsFailTasksOnLobTruncation := jResp.IntOf("Endpoint.PostgreSQLSettings.FailTasksOnLobTruncation")
HeartbeatEnable := jResp.IntOf("Endpoint.PostgreSQLSettings.HeartbeatEnable")
HeartbeatFrequency := jResp.IntOf("Endpoint.PostgreSQLSettings.HeartbeatFrequency")
HeartbeatSchema := jResp.StringOf("Endpoint.PostgreSQLSettings.HeartbeatSchema")
PostgreSQLSettingsMaxFileSize := jResp.IntOf("Endpoint.PostgreSQLSettings.MaxFileSize")
PostgreSQLSettingsPassword := jResp.StringOf("Endpoint.PostgreSQLSettings.Password")
PluginName := jResp.StringOf("Endpoint.PostgreSQLSettings.PluginName")
PostgreSQLSettingsPort := jResp.IntOf("Endpoint.PostgreSQLSettings.Port")
PostgreSQLSettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.PostgreSQLSettings.SecretsManagerAccessRoleArn")
PostgreSQLSettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.PostgreSQLSettings.SecretsManagerSecretId")
PostgreSQLSettingsServerName := jResp.StringOf("Endpoint.PostgreSQLSettings.ServerName")
SlotName := jResp.StringOf("Endpoint.PostgreSQLSettings.SlotName")
PostgreSQLSettingsUsername := jResp.StringOf("Endpoint.PostgreSQLSettings.Username")
AuthPassword := jResp.StringOf("Endpoint.RedisSettings.AuthPassword")
RedisSettingsAuthType := jResp.StringOf("Endpoint.RedisSettings.AuthType")
AuthUserName := jResp.StringOf("Endpoint.RedisSettings.AuthUserName")
RedisSettingsPort := jResp.IntOf("Endpoint.RedisSettings.Port")
RedisSettingsServerName := jResp.StringOf("Endpoint.RedisSettings.ServerName")
RedisSettingsSslCaCertificateArn := jResp.StringOf("Endpoint.RedisSettings.SslCaCertificateArn")
SslSecurityProtocol := jResp.StringOf("Endpoint.RedisSettings.SslSecurityProtocol")
AcceptAnyDate := jResp.IntOf("Endpoint.RedshiftSettings.AcceptAnyDate")
RedshiftSettingsAfterConnectScript := jResp.StringOf("Endpoint.RedshiftSettings.AfterConnectScript")
BucketFolder := jResp.StringOf("Endpoint.RedshiftSettings.BucketFolder")
RedshiftSettingsBucketName := jResp.StringOf("Endpoint.RedshiftSettings.BucketName")
CaseSensitiveNames := jResp.IntOf("Endpoint.RedshiftSettings.CaseSensitiveNames")
CompUpdate := jResp.IntOf("Endpoint.RedshiftSettings.CompUpdate")
ConnectionTimeout := jResp.IntOf("Endpoint.RedshiftSettings.ConnectionTimeout")
RedshiftSettingsDatabaseName := jResp.StringOf("Endpoint.RedshiftSettings.DatabaseName")
DateFormat := jResp.StringOf("Endpoint.RedshiftSettings.DateFormat")
EmptyAsNull := jResp.IntOf("Endpoint.RedshiftSettings.EmptyAsNull")
EncryptionMode := jResp.StringOf("Endpoint.RedshiftSettings.EncryptionMode")
ExplicitIds := jResp.IntOf("Endpoint.RedshiftSettings.ExplicitIds")
FileTransferUploadStreams := jResp.IntOf("Endpoint.RedshiftSettings.FileTransferUploadStreams")
LoadTimeout := jResp.IntOf("Endpoint.RedshiftSettings.LoadTimeout")
RedshiftSettingsMaxFileSize := jResp.IntOf("Endpoint.RedshiftSettings.MaxFileSize")
RedshiftSettingsPassword := jResp.StringOf("Endpoint.RedshiftSettings.Password")
RedshiftSettingsPort := jResp.IntOf("Endpoint.RedshiftSettings.Port")
RemoveQuotes := jResp.IntOf("Endpoint.RedshiftSettings.RemoveQuotes")
ReplaceChars := jResp.StringOf("Endpoint.RedshiftSettings.ReplaceChars")
ReplaceInvalidChars := jResp.StringOf("Endpoint.RedshiftSettings.ReplaceInvalidChars")
RedshiftSettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.RedshiftSettings.SecretsManagerAccessRoleArn")
RedshiftSettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.RedshiftSettings.SecretsManagerSecretId")
RedshiftSettingsServerName := jResp.StringOf("Endpoint.RedshiftSettings.ServerName")
ServerSideEncryptionKmsKeyId := jResp.StringOf("Endpoint.RedshiftSettings.ServerSideEncryptionKmsKeyId")
RedshiftSettingsServiceAccessRoleArn := jResp.StringOf("Endpoint.RedshiftSettings.ServiceAccessRoleArn")
TimeFormat := jResp.StringOf("Endpoint.RedshiftSettings.TimeFormat")
TrimBlanks := jResp.IntOf("Endpoint.RedshiftSettings.TrimBlanks")
TruncateColumns := jResp.IntOf("Endpoint.RedshiftSettings.TruncateColumns")
RedshiftSettingsUsername := jResp.StringOf("Endpoint.RedshiftSettings.Username")
WriteBufferSize := jResp.IntOf("Endpoint.RedshiftSettings.WriteBufferSize")
AddColumnName := jResp.IntOf("Endpoint.S3Settings.AddColumnName")
S3SettingsBucketFolder := jResp.StringOf("Endpoint.S3Settings.BucketFolder")
S3SettingsBucketName := jResp.StringOf("Endpoint.S3Settings.BucketName")
CannedAclForObjects := jResp.StringOf("Endpoint.S3Settings.CannedAclForObjects")
CdcInsertsAndUpdates := jResp.IntOf("Endpoint.S3Settings.CdcInsertsAndUpdates")
CdcInsertsOnly := jResp.IntOf("Endpoint.S3Settings.CdcInsertsOnly")
CdcMaxBatchInterval := jResp.IntOf("Endpoint.S3Settings.CdcMaxBatchInterval")
CdcMinFileSize := jResp.IntOf("Endpoint.S3Settings.CdcMinFileSize")
CdcPath := jResp.StringOf("Endpoint.S3Settings.CdcPath")
CompressionType := jResp.StringOf("Endpoint.S3Settings.CompressionType")
CsvDelimiter := jResp.StringOf("Endpoint.S3Settings.CsvDelimiter")
CsvNoSupValue := jResp.StringOf("Endpoint.S3Settings.CsvNoSupValue")
CsvNullValue := jResp.StringOf("Endpoint.S3Settings.CsvNullValue")
CsvRowDelimiter := jResp.StringOf("Endpoint.S3Settings.CsvRowDelimiter")
DataFormat := jResp.StringOf("Endpoint.S3Settings.DataFormat")
DataPageSize := jResp.IntOf("Endpoint.S3Settings.DataPageSize")
DatePartitionDelimiter := jResp.StringOf("Endpoint.S3Settings.DatePartitionDelimiter")
DatePartitionEnabled := jResp.IntOf("Endpoint.S3Settings.DatePartitionEnabled")
DatePartitionSequence := jResp.StringOf("Endpoint.S3Settings.DatePartitionSequence")
DatePartitionTimezone := jResp.StringOf("Endpoint.S3Settings.DatePartitionTimezone")
DictPageSizeLimit := jResp.IntOf("Endpoint.S3Settings.DictPageSizeLimit")
EnableStatistics := jResp.IntOf("Endpoint.S3Settings.EnableStatistics")
EncodingType := jResp.StringOf("Endpoint.S3Settings.EncodingType")
S3SettingsEncryptionMode := jResp.StringOf("Endpoint.S3Settings.EncryptionMode")
S3SettingsExternalTableDefinition := jResp.StringOf("Endpoint.S3Settings.ExternalTableDefinition")
IgnoreHeaderRows := jResp.IntOf("Endpoint.S3Settings.IgnoreHeaderRows")
IncludeOpForFullLoad := jResp.IntOf("Endpoint.S3Settings.IncludeOpForFullLoad")
S3SettingsMaxFileSize := jResp.IntOf("Endpoint.S3Settings.MaxFileSize")
ParquetTimestampInMillisecond := jResp.IntOf("Endpoint.S3Settings.ParquetTimestampInMillisecond")
ParquetVersion := jResp.StringOf("Endpoint.S3Settings.ParquetVersion")
PreserveTransactions := jResp.IntOf("Endpoint.S3Settings.PreserveTransactions")
Rfc4180 := jResp.IntOf("Endpoint.S3Settings.Rfc4180")
RowGroupLength := jResp.IntOf("Endpoint.S3Settings.RowGroupLength")
S3SettingsServerSideEncryptionKmsKeyId := jResp.StringOf("Endpoint.S3Settings.ServerSideEncryptionKmsKeyId")
S3SettingsServiceAccessRoleArn := jResp.StringOf("Endpoint.S3Settings.ServiceAccessRoleArn")
TimestampColumnName := jResp.StringOf("Endpoint.S3Settings.TimestampColumnName")
UseCsvNoSupValue := jResp.IntOf("Endpoint.S3Settings.UseCsvNoSupValue")
UseTaskStartTimeForFullLoadTimestamp := jResp.IntOf("Endpoint.S3Settings.UseTaskStartTimeForFullLoadTimestamp")
EndpointServerName := jResp.StringOf("Endpoint.ServerName")
EndpointServiceAccessRoleArn := jResp.StringOf("Endpoint.ServiceAccessRoleArn")
SslMode := jResp.StringOf("Endpoint.SslMode")
Status := jResp.StringOf("Endpoint.Status")
SybaseSettingsDatabaseName := jResp.StringOf("Endpoint.SybaseSettings.DatabaseName")
SybaseSettingsPassword := jResp.StringOf("Endpoint.SybaseSettings.Password")
SybaseSettingsPort := jResp.IntOf("Endpoint.SybaseSettings.Port")
SybaseSettingsSecretsManagerAccessRoleArn := jResp.StringOf("Endpoint.SybaseSettings.SecretsManagerAccessRoleArn")
SybaseSettingsSecretsManagerSecretId := jResp.StringOf("Endpoint.SybaseSettings.SecretsManagerSecretId")
SybaseSettingsServerName := jResp.StringOf("Endpoint.SybaseSettings.ServerName")
SybaseSettingsUsername := jResp.StringOf("Endpoint.SybaseSettings.Username")
EndpointUsername := jResp.StringOf("Endpoint.Username")
i := 0
count_i := jResp.SizeOfArray("Endpoint.OracleSettings.ExtraArchivedLogDestIds")
for i < count_i {
jResp.SetI(i)
intVal = jResp.IntOf("Endpoint.OracleSettings.ExtraArchivedLogDestIds[i]")
i = i + 1
}
// A sample JSON response body parsed by the above code:
// {
// "Endpoint": {
// "CertificateArn": "string",
// "DatabaseName": "string",
// "DmsTransferSettings": {
// "BucketName": "string",
// "ServiceAccessRoleArn": "string"
// },
// "DocDbSettings": {
// "DatabaseName": "string",
// "DocsToInvestigate": number,
// "ExtractDocId": boolean,
// "KmsKeyId": "string",
// "NestingLevel": "string",
// "Password": "string",
// "Port": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "Username": "string"
// },
// "DynamoDbSettings": {
// "ServiceAccessRoleArn": "string"
// },
// "ElasticsearchSettings": {
// "EndpointUri": "string",
// "ErrorRetryDuration": number,
// "FullLoadErrorPercentage": number,
// "ServiceAccessRoleArn": "string"
// },
// "EndpointArn": "string",
// "EndpointIdentifier": "string",
// "EndpointType": "string",
// "EngineDisplayName": "string",
// "EngineName": "string",
// "ExternalId": "string",
// "ExternalTableDefinition": "string",
// "ExtraConnectionAttributes": "string",
// "GcpMySQLSettings": {
// "AfterConnectScript": "string",
// "CleanSourceMetadataOnMismatch": boolean,
// "DatabaseName": "string",
// "EventsPollInterval": number,
// "MaxFileSize": number,
// "ParallelLoadThreads": number,
// "Password": "string",
// "Port": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "ServerTimezone": "string",
// "TargetDbType": "string",
// "Username": "string"
// },
// "IBMDb2Settings": {
// "CurrentLsn": "string",
// "DatabaseName": "string",
// "MaxKBytesPerRead": number,
// "Password": "string",
// "Port": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "SetDataCaptureChanges": boolean,
// "Username": "string"
// },
// "KafkaSettings": {
// "Broker": "string",
// "IncludeControlDetails": boolean,
// "IncludeNullAndEmpty": boolean,
// "IncludePartitionValue": boolean,
// "IncludeTableAlterOperations": boolean,
// "IncludeTransactionDetails": boolean,
// "MessageFormat": "string",
// "MessageMaxBytes": number,
// "NoHexPrefix": boolean,
// "PartitionIncludeSchemaTable": boolean,
// "SaslPassword": "string",
// "SaslUsername": "string",
// "SecurityProtocol": "string",
// "SslCaCertificateArn": "string",
// "SslClientCertificateArn": "string",
// "SslClientKeyArn": "string",
// "SslClientKeyPassword": "string",
// "Topic": "string"
// },
// "KinesisSettings": {
// "IncludeControlDetails": boolean,
// "IncludeNullAndEmpty": boolean,
// "IncludePartitionValue": boolean,
// "IncludeTableAlterOperations": boolean,
// "IncludeTransactionDetails": boolean,
// "MessageFormat": "string",
// "NoHexPrefix": boolean,
// "PartitionIncludeSchemaTable": boolean,
// "ServiceAccessRoleArn": "string",
// "StreamArn": "string"
// },
// "KmsKeyId": "string",
// "MicrosoftSQLServerSettings": {
// "BcpPacketSize": number,
// "ControlTablesFileGroup": "string",
// "DatabaseName": "string",
// "Password": "string",
// "Port": number,
// "QuerySingleAlwaysOnNode": boolean,
// "ReadBackupOnly": boolean,
// "SafeguardPolicy": "string",
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "UseBcpFullLoad": boolean,
// "Username": "string",
// "UseThirdPartyBackupDevice": boolean
// },
// "MongoDbSettings": {
// "AuthMechanism": "string",
// "AuthSource": "string",
// "AuthType": "string",
// "DatabaseName": "string",
// "DocsToInvestigate": "string",
// "ExtractDocId": "string",
// "KmsKeyId": "string",
// "NestingLevel": "string",
// "Password": "string",
// "Port": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "Username": "string"
// },
// "MySQLSettings": {
// "AfterConnectScript": "string",
// "CleanSourceMetadataOnMismatch": boolean,
// "DatabaseName": "string",
// "EventsPollInterval": number,
// "MaxFileSize": number,
// "ParallelLoadThreads": number,
// "Password": "string",
// "Port": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "ServerTimezone": "string",
// "TargetDbType": "string",
// "Username": "string"
// },
// "NeptuneSettings": {
// "ErrorRetryDuration": number,
// "IamAuthEnabled": boolean,
// "MaxFileSize": number,
// "MaxRetryCount": number,
// "S3BucketFolder": "string",
// "S3BucketName": "string",
// "ServiceAccessRoleArn": "string"
// },
// "OracleSettings": {
// "AccessAlternateDirectly": boolean,
// "AdditionalArchivedLogDestId": number,
// "AddSupplementalLogging": boolean,
// "AllowSelectNestedTables": boolean,
// "ArchivedLogDestId": number,
// "ArchivedLogsOnly": boolean,
// "AsmPassword": "string",
// "AsmServer": "string",
// "AsmUser": "string",
// "CharLengthSemantics": "string",
// "DatabaseName": "string",
// "DirectPathNoLog": boolean,
// "DirectPathParallelLoad": boolean,
// "EnableHomogenousTablespace": boolean,
// "ExtraArchivedLogDestIds": [
// number
// ],
// "FailTasksOnLobTruncation": boolean,
// "NumberDatatypeScale": number,
// "OraclePathPrefix": "string",
// "ParallelAsmReadThreads": number,
// "Password": "string",
// "Port": number,
// "ReadAheadBlocks": number,
// "ReadTableSpaceName": boolean,
// "ReplacePathPrefix": boolean,
// "RetryInterval": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerOracleAsmAccessRoleArn": "string",
// "SecretsManagerOracleAsmSecretId": "string",
// "SecretsManagerSecretId": "string",
// "SecurityDbEncryption": "string",
// "SecurityDbEncryptionName": "string",
// "ServerName": "string",
// "SpatialDataOptionToGeoJsonFunctionName": "string",
// "StandbyDelayTime": number,
// "UseAlternateFolderForOnline": boolean,
// "UseBFile": boolean,
// "UseDirectPathFullLoad": boolean,
// "UseLogminerReader": boolean,
// "UsePathPrefix": "string",
// "Username": "string"
// },
// "Port": number,
// "PostgreSQLSettings": {
// "AfterConnectScript": "string",
// "CaptureDdls": boolean,
// "DatabaseName": "string",
// "DdlArtifactsSchema": "string",
// "ExecuteTimeout": number,
// "FailTasksOnLobTruncation": boolean,
// "HeartbeatEnable": boolean,
// "HeartbeatFrequency": number,
// "HeartbeatSchema": "string",
// "MaxFileSize": number,
// "Password": "string",
// "PluginName": "string",
// "Port": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "SlotName": "string",
// "Username": "string"
// },
// "RedisSettings": {
// "AuthPassword": "string",
// "AuthType": "string",
// "AuthUserName": "string",
// "Port": number,
// "ServerName": "string",
// "SslCaCertificateArn": "string",
// "SslSecurityProtocol": "string"
// },
// "RedshiftSettings": {
// "AcceptAnyDate": boolean,
// "AfterConnectScript": "string",
// "BucketFolder": "string",
// "BucketName": "string",
// "CaseSensitiveNames": boolean,
// "CompUpdate": boolean,
// "ConnectionTimeout": number,
// "DatabaseName": "string",
// "DateFormat": "string",
// "EmptyAsNull": boolean,
// "EncryptionMode": "string",
// "ExplicitIds": boolean,
// "FileTransferUploadStreams": number,
// "LoadTimeout": number,
// "MaxFileSize": number,
// "Password": "string",
// "Port": number,
// "RemoveQuotes": boolean,
// "ReplaceChars": "string",
// "ReplaceInvalidChars": "string",
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "ServerSideEncryptionKmsKeyId": "string",
// "ServiceAccessRoleArn": "string",
// "TimeFormat": "string",
// "TrimBlanks": boolean,
// "TruncateColumns": boolean,
// "Username": "string",
// "WriteBufferSize": number
// },
// "S3Settings": {
// "AddColumnName": boolean,
// "BucketFolder": "string",
// "BucketName": "string",
// "CannedAclForObjects": "string",
// "CdcInsertsAndUpdates": boolean,
// "CdcInsertsOnly": boolean,
// "CdcMaxBatchInterval": number,
// "CdcMinFileSize": number,
// "CdcPath": "string",
// "CompressionType": "string",
// "CsvDelimiter": "string",
// "CsvNoSupValue": "string",
// "CsvNullValue": "string",
// "CsvRowDelimiter": "string",
// "DataFormat": "string",
// "DataPageSize": number,
// "DatePartitionDelimiter": "string",
// "DatePartitionEnabled": boolean,
// "DatePartitionSequence": "string",
// "DatePartitionTimezone": "string",
// "DictPageSizeLimit": number,
// "EnableStatistics": boolean,
// "EncodingType": "string",
// "EncryptionMode": "string",
// "ExternalTableDefinition": "string",
// "IgnoreHeaderRows": number,
// "IncludeOpForFullLoad": boolean,
// "MaxFileSize": number,
// "ParquetTimestampInMillisecond": boolean,
// "ParquetVersion": "string",
// "PreserveTransactions": boolean,
// "Rfc4180": boolean,
// "RowGroupLength": number,
// "ServerSideEncryptionKmsKeyId": "string",
// "ServiceAccessRoleArn": "string",
// "TimestampColumnName": "string",
// "UseCsvNoSupValue": boolean,
// "UseTaskStartTimeForFullLoadTimestamp": boolean
// },
// "ServerName": "string",
// "ServiceAccessRoleArn": "string",
// "SslMode": "string",
// "Status": "string",
// "SybaseSettings": {
// "DatabaseName": "string",
// "Password": "string",
// "Port": number,
// "SecretsManagerAccessRoleArn": "string",
// "SecretsManagerSecretId": "string",
// "ServerName": "string",
// "Username": "string"
// },
// "Username": "string"
// }
// }
rest.DisposeRest()
authAws.DisposeAuthAws()
json.DisposeJsonObject()
sbRequestBody.DisposeStringBuilder()
sbResponseBody.DisposeStringBuilder()
jResp.DisposeJsonObject()
