Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ballerina/Dependencies.toml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

[ballerina]
dependencies-toml-version = "2"
distribution-version = "2201.12.3"
distribution-version = "2201.12.0"

[[package]]
org = "ballerina"
Expand Down
24 changes: 12 additions & 12 deletions ballerina/mssql_listener.bal
Original file line number Diff line number Diff line change
Expand Up @@ -37,13 +37,13 @@
# + return - An error if the service cannot be attached, or `()` if successful
public isolated function attach(Service s, string[]|string? name = ()) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");

Check warning on line 41 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L41

Added line #L41 was not covered by tests
}
}
check externAttach(self, s);
lock {
self.hasAttachedService = true;
self.hasAttachedService = true;

Check warning on line 46 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L46

Added line #L46 was not covered by tests
}
}

Expand All @@ -52,13 +52,13 @@
# + return - An error if the listener cannot be started, or `()` if successful
public isolated function 'start() returns Error? {
lock {
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");

Check warning on line 56 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L56

Added line #L56 was not covered by tests
}
}
check externStart(self, self.config);
lock {
self.isStarted = true;
self.isStarted = true;

Check warning on line 61 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L61

Added line #L61 was not covered by tests
}
}

Expand All @@ -68,16 +68,16 @@
# + return - An error if the service cannot be detached, or `()` if successful
public isolated function detach(Service s) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");

Check warning on line 72 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L72

Added line #L72 was not covered by tests
}
if !self.hasAttachedService {
return;
}
}
boolean result = check externDetach(self, s);
lock {
self.hasAttachedService = result;
self.hasAttachedService = result;

Check warning on line 80 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L80

Added line #L80 was not covered by tests
}
}

Expand Down
24 changes: 12 additions & 12 deletions ballerina/mysql_listener.bal
Original file line number Diff line number Diff line change
Expand Up @@ -36,13 +36,13 @@
# + return - An error if the service cannot be attached, or `()` if successful
public isolated function attach(Service s, string[]|string? name = ()) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");

Check warning on line 40 in ballerina/mysql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mysql_listener.bal#L40

Added line #L40 was not covered by tests
}
}
check externAttach(self, s);
lock {
self.hasAttachedService = true;
self.hasAttachedService = true;
}
}

Expand All @@ -51,13 +51,13 @@
# + return - An error if the listener cannot be started, or `()` if successful
public isolated function 'start() returns Error? {
lock {
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
}
check externStart(self, self.config);
lock {
self.isStarted = true;
self.isStarted = true;

Check warning on line 60 in ballerina/mysql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mysql_listener.bal#L60

Added line #L60 was not covered by tests
}
}

Expand All @@ -67,16 +67,16 @@
# + return - An error if the service cannot be detached, or `()` if successful
public isolated function detach(Service s) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");

Check warning on line 71 in ballerina/mysql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mysql_listener.bal#L71

Added line #L71 was not covered by tests
}
if !self.hasAttachedService {
return;
}
}
boolean result = check externDetach(self, s);
lock {
self.hasAttachedService = result;
self.hasAttachedService = result;

Check warning on line 79 in ballerina/mysql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mysql_listener.bal#L79

Added line #L79 was not covered by tests
}
}

Expand Down
24 changes: 12 additions & 12 deletions ballerina/oracledb_listener.bal
Original file line number Diff line number Diff line change
Expand Up @@ -37,13 +37,13 @@
# + return - An error if the service cannot be attached, or `()` if successful
public isolated function attach(Service s, string[]|string? name = ()) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");

Check warning on line 41 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L41

Added line #L41 was not covered by tests
}
}
check externAttach(self, s);
lock {
self.hasAttachedService = true;
self.hasAttachedService = true;

Check warning on line 46 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L46

Added line #L46 was not covered by tests
}
}

Expand All @@ -52,13 +52,13 @@
# + return - An error if the listener cannot be started, or `()` if successful
public isolated function 'start() returns Error? {
lock {
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");

Check warning on line 56 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L56

Added line #L56 was not covered by tests
}
}
check externStart(self, self.config);
lock {
self.isStarted = true;
self.isStarted = true;

Check warning on line 61 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L61

Added line #L61 was not covered by tests
}
}

Expand All @@ -68,16 +68,16 @@
# + return - An error if the service cannot be detached, or `()` if successful
public isolated function detach(Service s) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");

Check warning on line 72 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L72

Added line #L72 was not covered by tests
}
if !self.hasAttachedService {
return;
}
}
boolean result = check externDetach(self, s);
lock {
self.hasAttachedService = result;
self.hasAttachedService = result;

Check warning on line 80 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L80

Added line #L80 was not covered by tests
}
}

Expand Down
24 changes: 12 additions & 12 deletions ballerina/postgresql_listener.bal
Original file line number Diff line number Diff line change
Expand Up @@ -37,13 +37,13 @@
# + return - An error if the service cannot be attached, or `()` if successful
public isolated function attach(Service s, string[]|string? name = ()) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");

Check warning on line 41 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L41

Added line #L41 was not covered by tests
}
}
check externAttach(self, s);
lock {
self.hasAttachedService = true;
self.hasAttachedService = true;

Check warning on line 46 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L46

Added line #L46 was not covered by tests
}
}

Expand All @@ -52,13 +52,13 @@
# + return - An error if the listener cannot be started, or `()` if successful
public isolated function 'start() returns Error? {
lock {
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");

Check warning on line 56 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L56

Added line #L56 was not covered by tests
}
}
check externStart(self, self.config);
lock {
self.isStarted = true;
self.isStarted = true;

Check warning on line 61 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L61

Added line #L61 was not covered by tests
}
}

Expand All @@ -68,16 +68,16 @@
# + return - An error if the service cannot be detached, or `()` if successful
public isolated function detach(Service s) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");

Check warning on line 72 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L72

Added line #L72 was not covered by tests
}
if !self.hasAttachedService {
return;
}
}
boolean result = check externDetach(self, s);
lock {
self.hasAttachedService = result;
self.hasAttachedService = result;

Check warning on line 80 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L80

Added line #L80 was not covered by tests
}
}

Expand Down
2 changes: 1 addition & 1 deletion ballerina/utils.bal
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ const string ORACLE_URL = "database.url";
const string ORACLE_PDB_NAME = "database.dbname";
const string ORACLE_CONNECTION_ADAPTER = "database.connection.adapter";

isolated function getDebeziumProperties(MySqlListenerConfiguration|MsSqlListenerConfiguration|PostgresListenerConfiguration|OracleListenerConfiguration config) returns map<string> & readonly{
isolated function getDebeziumProperties(MySqlListenerConfiguration|MsSqlListenerConfiguration|PostgresListenerConfiguration|OracleListenerConfiguration config) returns map<string> & readonly {
map<string> configMap = {};

// Common configurations
Expand Down

This file was deleted.

Loading
Loading