File tree Expand file tree Collapse file tree 5 files changed +10
-10
lines changed
common/src/main/java/com/datastax/oss/common/sink/config Expand file tree Collapse file tree 5 files changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -37,9 +37,9 @@ public class AuthenticatorConfig extends AbstractConfig {
37
37
public static final String PROVIDER_OPT = "auth.provider" ;
38
38
public static final String USERNAME_OPT = "auth.username" ;
39
39
public static final String PASSWORD_OPT = "auth.password" ;
40
- static final String KEYTAB_OPT = "auth.gssapi.keyTab" ;
41
- static final String PRINCIPAL_OPT = "auth.gssapi.principal" ;
42
- static final String SERVICE_OPT = "auth.gssapi.service" ;
40
+ public static final String KEYTAB_OPT = "auth.gssapi.keyTab" ;
41
+ public static final String PRINCIPAL_OPT = "auth.gssapi.principal" ;
42
+ public static final String SERVICE_OPT = "auth.gssapi.service" ;
43
43
44
44
private static final Logger log = LoggerFactory .getLogger (AuthenticatorConfig .class );
45
45
private static final ConfigDef CONFIG_DEF =
@@ -83,7 +83,7 @@ public class AuthenticatorConfig extends AbstractConfig {
83
83
84
84
@ Nullable private final Path keyTabPath ;
85
85
86
- AuthenticatorConfig (Map <String , String > authSettings ) {
86
+ public AuthenticatorConfig (Map <String , String > authSettings ) {
87
87
super (CONFIG_DEF , sanitizeAuthSettings (authSettings ), false );
88
88
89
89
// Verify that the provider value is valid.
Original file line number Diff line number Diff line change @@ -39,7 +39,7 @@ private ConfigUtil() {}
39
39
* @param settingNames names of settings to extract.
40
40
* @return lines of the form "setting: value".
41
41
*/
42
- static String configToString (
42
+ public static String configToString (
43
43
AbstractConfig config , String prefixToExcise , String ... settingNames ) {
44
44
return Arrays .stream (settingNames )
45
45
.map (
@@ -56,7 +56,7 @@ static String configToString(
56
56
* @param settingValue setting to convert
57
57
* @return the converted path.
58
58
*/
59
- static @ Nullable Path getFilePath (@ Nullable String settingValue ) {
59
+ public static @ Nullable Path getFilePath (@ Nullable String settingValue ) {
60
60
return settingValue == null || settingValue .isEmpty ()
61
61
? null
62
62
: Paths .get (settingValue ).toAbsolutePath ().normalize ();
@@ -69,7 +69,7 @@ static String configToString(
69
69
* @param settingName name of setting whose value is filePath; used in generating error messages
70
70
* for failures.
71
71
*/
72
- static void assertAccessibleFile (@ Nullable Path filePath , String settingName ) {
72
+ public static void assertAccessibleFile (@ Nullable Path filePath , String settingName ) {
73
73
if (filePath == null ) {
74
74
// There's no path to check.
75
75
return ;
Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ public static void validateContactPoints(List<String> contactPoints) {
45
45
}
46
46
}
47
47
48
- private static boolean isInvalidAddress (String contactPoint ) {
48
+ public static boolean isInvalidAddress (String contactPoint ) {
49
49
return !InetAddresses .isInetAddress (contactPoint ) && !InternetDomainName .isValid (contactPoint );
50
50
}
51
51
}
Original file line number Diff line number Diff line change @@ -113,7 +113,7 @@ public class SslConfig extends AbstractConfig {
113
113
private final @ Nullable Path privateKeyPath ;
114
114
private final @ Nullable SslContext sslContext ;
115
115
116
- SslConfig (Map <String , String > sslSettings ) {
116
+ public SslConfig (Map <String , String > sslSettings ) {
117
117
super (CONFIG_DEF , sslSettings , false );
118
118
119
119
keystorePath = getFilePath (getString (KEYSTORE_PATH_OPT ));
Original file line number Diff line number Diff line change @@ -66,7 +66,7 @@ public class TableConfig extends AbstractConfig {
66
66
private final boolean deletesEnabled ;
67
67
private final String query ;
68
68
69
- private TableConfig (
69
+ public TableConfig (
70
70
@ NonNull String topicName ,
71
71
@ NonNull String keyspace ,
72
72
@ NonNull String table ,
You can’t perform that action at this time.
0 commit comments