Interface ConnectorOrBuilder (0.32.0)

Version latest

• 0.32.0 (latest)
• 0.31.0
• 0.30.0
• 0.29.0
• 0.28.0
• 0.26.0
• 0.24.0
• 0.23.0
• 0.20.0
• 0.19.0
• 0.18.0
• 0.16.1
• 0.15.0
• 0.14.0
• 0.13.0
• 0.12.0
• 0.11.0
• 0.10.0
• 0.9.0
• 0.8.0
• 0.7.0
• 0.5.0
• 0.4.0
• 0.3.0
• 0.2.0
• 0.1.0

public interface ConnectorOrBuilder extends MessageOrBuilder

Implements

MessageOrBuilder

Methods

containsConfigs(String key)

public abstract boolean containsConfigs(String key)

Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];

Parameter
Name	Description
key	String

Returns
Type	Description
boolean

getConfigs() (deprecated)

public abstract Map<String,String> getConfigs()

Use #getConfigsMap() instead.

Returns
Type	Description
Map<String,String>

getConfigsCount()

public abstract int getConfigsCount()

Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
int

getConfigsMap()

public abstract Map<String,String> getConfigsMap()

Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
Map<String,String>

getConfigsOrDefault(String key, String defaultValue)

public abstract String getConfigsOrDefault(String key, String defaultValue)

Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];

Parameters
Name	Description
key	String
defaultValue	String

Returns
Type	Description
String

getConfigsOrThrow(String key)

public abstract String getConfigsOrThrow(String key)

Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

map<string, string> configs = 2 [(.google.api.field_behavior) = OPTIONAL];

Parameter
Name	Description
key	String

Returns
Type	Description
String

getName()

public abstract String getName()

Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}

string name = 1 [(.google.api.field_behavior) = IDENTIFIER];

Returns
Type	Description
String	The name.

getNameBytes()

public abstract ByteString getNameBytes()

Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}

string name = 1 [(.google.api.field_behavior) = IDENTIFIER];

Returns
Type	Description
ByteString	The bytes for name.

getRestartPolicyCase()

public abstract Connector.RestartPolicyCase getRestartPolicyCase()

Returns
Type	Description
Connector.RestartPolicyCase

getState()

public abstract Connector.State getState()

Output only. The current state of the connector.

.google.cloud.managedkafka.v1.Connector.State state = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];

Returns
Type	Description
Connector.State	The state.

getStateValue()

public abstract int getStateValue()

Output only. The current state of the connector.

.google.cloud.managedkafka.v1.Connector.State state = 3 [(.google.api.field_behavior) = OUTPUT_ONLY];

Returns
Type	Description
int	The enum numeric value on the wire for state.

getTaskRestartPolicy()

public abstract TaskRetryPolicy getTaskRestartPolicy()

Optional. Restarts the individual tasks of a Connector.

.google.cloud.managedkafka.v1.TaskRetryPolicy task_restart_policy = 4 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
TaskRetryPolicy	The taskRestartPolicy.

getTaskRestartPolicyOrBuilder()

public abstract TaskRetryPolicyOrBuilder getTaskRestartPolicyOrBuilder()

Optional. Restarts the individual tasks of a Connector.

.google.cloud.managedkafka.v1.TaskRetryPolicy task_restart_policy = 4 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
TaskRetryPolicyOrBuilder

hasTaskRestartPolicy()

public abstract boolean hasTaskRestartPolicy()

Optional. Restarts the individual tasks of a Connector.

.google.cloud.managedkafka.v1.TaskRetryPolicy task_restart_policy = 4 [(.google.api.field_behavior) = OPTIONAL];

Returns
Type	Description
boolean	Whether the taskRestartPolicy field is set.