Package org.apache.nifi.processors.standard.ssh

Class StandardSshClientProvider

java.lang.Object

org.apache.nifi.processors.standard.ssh.StandardSshClientProvider

All Implemented Interfaces:

SshClientProvider

public class StandardSshClientProvider
extends Object
implements SshClientProvider

Standard Apache MINA SSHD Client Provider supporting configuration and authentication

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	StandardSshClientProvider.AcceptAllServerKeyVerifier

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.sshd.client.keyverifier.ServerKeyVerifier	ACCEPT_ALL_SERVER_KEY_VERIFIER
private static final List<org.apache.sshd.common.NamedFactory<org.apache.sshd.common.compression.Compression>>	COMPRESSION_FACTORIES
private static final Duration	HEARTBEAT_INTERVAL
private static final int	HEARTBEAT_NO_REPLY_MAX

Constructor Summary

Constructors

Constructor	Description
StandardSshClientProvider()

Method Summary

Modifier and Type	Method	Description
private org.apache.sshd.client.SshClient	buildSshClient(org.apache.nifi.context.PropertyContext context)
private org.apache.sshd.client.session.ClientSession	getAuthenticatedClientSession(org.apache.nifi.context.PropertyContext context, Map<String,String> attributes, org.apache.sshd.client.SshClient sshClient)
org.apache.sshd.client.session.ClientSession	getClientSession(org.apache.nifi.context.PropertyContext context, Map<String,String> attributes)	Get SSH Client Session connected and authenticated based on provided configuration
private void	setAlgorithmConfiguration(org.apache.nifi.context.PropertyContext context, org.apache.sshd.client.SshClient sshClient)
private void	setAuthentication(org.apache.nifi.context.PropertyContext context, Map<String,String> attributes, org.apache.sshd.client.SshClient sshClient)
private void	setHostKeyChecking(org.apache.nifi.context.PropertyContext context, org.apache.sshd.client.ClientBuilder clientBuilder)
private void	setProxy(org.apache.nifi.context.PropertyContext context, Map<String,String> attributes, org.apache.sshd.client.SshClient sshClient)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

HEARTBEAT_INTERVAL

private static final Duration HEARTBEAT_INTERVAL

HEARTBEAT_NO_REPLY_MAX

private static final int HEARTBEAT_NO_REPLY_MAX

See Also:

• Constant Field Values

ACCEPT_ALL_SERVER_KEY_VERIFIER

private static final org.apache.sshd.client.keyverifier.ServerKeyVerifier ACCEPT_ALL_SERVER_KEY_VERIFIER

COMPRESSION_FACTORIES

private static final List<org.apache.sshd.common.NamedFactory<org.apache.sshd.common.compression.Compression>> COMPRESSION_FACTORIES

Constructor Details

StandardSshClientProvider

public StandardSshClientProvider()

Method Details

getClientSession

public org.apache.sshd.client.session.ClientSession getClientSession(org.apache.nifi.context.PropertyContext context,
 Map<String,String> attributes)

Get SSH Client Session connected and authenticated based on provided configuration

Specified by:

getClientSession in interface SshClientProvider

Parameters:

context - Property Context containing configuration properties

attributes - FlowFile attributes for property expression evaluation

Returns:

Connected and authenticated SSH Client Session

getAuthenticatedClientSession

private org.apache.sshd.client.session.ClientSession getAuthenticatedClientSession(org.apache.nifi.context.PropertyContext context,
 Map<String,String> attributes,
 org.apache.sshd.client.SshClient sshClient)

buildSshClient

private org.apache.sshd.client.SshClient buildSshClient(org.apache.nifi.context.PropertyContext context)

setHostKeyChecking

private void setHostKeyChecking(org.apache.nifi.context.PropertyContext context,
 org.apache.sshd.client.ClientBuilder clientBuilder)

setAlgorithmConfiguration

private void setAlgorithmConfiguration(org.apache.nifi.context.PropertyContext context,
 org.apache.sshd.client.SshClient sshClient)

setProxy

private void setProxy(org.apache.nifi.context.PropertyContext context,
 Map<String,String> attributes,
 org.apache.sshd.client.SshClient sshClient)

setAuthentication

private void setAuthentication(org.apache.nifi.context.PropertyContext context,
 Map<String,String> attributes,
 org.apache.sshd.client.SshClient sshClient)