Package org.odpi.openmetadata.adapters.connectors.secretsstore.yaml

Class YAMLSecretsStoreConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.frameworks.connectors.SecretsStoreConnector

org.odpi.openmetadata.adapters.connectors.secretsstore.yaml.YAMLSecretsStoreConnector

All Implemented Interfaces:

AuditLoggingComponent, SecureConnectorExtension, VirtualConnectorExtension

public class YAMLSecretsStoreConnector
extends SecretsStoreConnector

YAMLSecretsStoreConnector retrieves secrets from environment variables. Each secret is named for its environment variable.

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.SecretsStoreConnector

secretsCollectionName

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

auditLog, connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, embeddedConnectors, messageFormatter, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
YAMLSecretsStoreConnector()

Method Summary

Modifier and Type	Method	Description
long	getRefreshTimeInterval()	Retrieve the refresh time from the secrets store.
String	getSecret(String secretName)	Retrieve a secret from the secrets store.
String	getSecret(String secretsCollectionName, String secretName)	Retrieve a secret from the secrets store.
UserAccount	getUser(String userId)	Retrieve the requested user definitions stored in the secrets collection.
Map<String,UserAccount>	getUsers()	Retrieve any user definitions stored in the secrets collection.
void	initialize(String connectorInstanceId, ConnectionProperties connectionProperties)	Call made by the ConnectorProvider to initialize the Connector with the base services.
HttpRequest.BodyPublisher	ofForm(Map<String,Object> data)	Return the HTTPBodyPublisher populated with the data for the http request.
HttpRequest.BodyPublisher	ofJSON(Map<String,Object> data)	Return the HTTPBodyPublisher populated with the data for the http request.
protected void	refreshSecrets()	Request that the subclass refreshes its secrets.

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.SecretsStoreConnector

checkSecretsStillValid, getConnectorComponentDescription, resetRefreshTime, setAuditLog, start

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

combineConfigurationProperties, disconnect, disconnectConnectors, equals, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getDateConfigurationProperty, getIntConfigurationProperty, getLongConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initializeConnectedAssetProperties, initializeEmbeddedConnectors, initializeSecretsStoreConnector, isActive, logExceptionRecord, logRecord, logRecord, throwMissingConfigurationProperty, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, toString

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector

clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, setStatisticProperty, setStatisticTimestamp

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

YAMLSecretsStoreConnector

public YAMLSecretsStoreConnector()

Method Details

initialize

public void initialize(String connectorInstanceId,
 ConnectionProperties connectionProperties)

Call made by the ConnectorProvider to initialize the Connector with the base services.

Overrides:

initialize in class ConnectorBase

Parameters:

connectorInstanceId - unique id for the connector instance useful for messages etc

connectionProperties - POJO for the configuration used to create the connector.

getRefreshTimeInterval

public long getRefreshTimeInterval()

Retrieve the refresh time from the secrets store.

Specified by:

getRefreshTimeInterval in class SecretsStoreConnector

Returns:

how long the secrets can be cached - 0 means indefinitely

getSecret

public String getSecret(String secretName)
                 throws ConnectorCheckedException

Retrieve a secret from the secrets store.

Specified by:

getSecret in class SecretsStoreConnector

Parameters:

secretName - name of the secret.

Returns:

secret

Throws:

ConnectorCheckedException - problem with the store

getSecret

public String getSecret(String secretsCollectionName,
 String secretName)
                 throws ConnectorCheckedException

Retrieve a secret from the secrets store.

Specified by:

getSecret in class SecretsStoreConnector

Parameters:

secretsCollectionName - name of collection

secretName - name of the secret.

Returns:

secret

Throws:

ConnectorCheckedException - problem with the store

getUser

public UserAccount getUser(String userId)
                    throws ConnectorCheckedException

Retrieve the requested user definitions stored in the secrets collection.

Specified by:

getUser in class SecretsStoreConnector

Parameters:

userId - userId for the lookup

Returns:

associated user details or null

Throws:

ConnectorCheckedException - problem with the store

getUsers

public Map<String,UserAccount> getUsers()
                                 throws ConnectorCheckedException

Retrieve any user definitions stored in the secrets collection.

Specified by:

getUsers in class SecretsStoreConnector

Returns:

map of userIds to user details

Throws:

ConnectorCheckedException - problem with the store

ofForm

public HttpRequest.BodyPublisher ofForm(Map<String,Object> data)

Return the HTTPBodyPublisher populated with the data for the http request.

Parameters:

data - HTTP request parameters

Returns:

populated HTTPBodyPublisher

ofJSON

public HttpRequest.BodyPublisher ofJSON(Map<String,Object> data)

Return the HTTPBodyPublisher populated with the data for the http request.

Parameters:

data - HTTP request parameters

Returns:

populated HTTPBodyPublisher

refreshSecrets

protected void refreshSecrets()

Request that the subclass refreshes its secrets.

Specified by:

refreshSecrets in class SecretsStoreConnector