Package org.graylog2.cluster.certificates

Class CertificateExchangeImpl

java.lang.Object

org.graylog2.cluster.certificates.CertificateExchangeImpl

All Implemented Interfaces:

CertificateExchange

public class CertificateExchangeImpl
extends Object
implements CertificateExchange

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FIELD_ENCRYPTED_VALUE
static final String	FIELD_ENTRY_TYPE
static final String	FIELD_NODE_ID

Constructor Summary

Constructors

Constructor	Description
CertificateExchangeImpl(MongoConnection mongoConnection, EncryptedValueService encryptionService)

Method Summary

Modifier and Type	Method	Description
CertificateChain	parseCertificateChain(String certificate)
void	pollCertificate(String nodeId, Consumer<CertificateChain> chainConsumer)	If the consumer fails to consume existing certificate, the certificate won't be removed and the attempt will be repeated during the next poll call.
void	requestCertificate(CertificateSigningRequest request)
void	signPendingCertificateRequests(Function<CertificateSigningRequest,CertificateChain> signingFunction)	Take every pending CSR and transform it to a valid certificate chain by using the signing function

Methods inherited from class java.lang.Object

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

Field Details

FIELD_NODE_ID

public static final String FIELD_NODE_ID

See Also:

• Constant Field Values

FIELD_ENTRY_TYPE

public static final String FIELD_ENTRY_TYPE

See Also:

• Constant Field Values

FIELD_ENCRYPTED_VALUE

public static final String FIELD_ENCRYPTED_VALUE

See Also:

• Constant Field Values

Constructor Details

CertificateExchangeImpl

@Inject
public CertificateExchangeImpl(MongoConnection mongoConnection,
 EncryptedValueService encryptionService)

Method Details

requestCertificate

public void requestCertificate(CertificateSigningRequest request)
                        throws IOException

Specified by:

requestCertificate in interface CertificateExchange

Throws:

IOException

signPendingCertificateRequests

public void signPendingCertificateRequests(Function<CertificateSigningRequest,CertificateChain> signingFunction)
                                    throws IOException

Description copied from interface: CertificateExchange

Take every pending CSR and transform it to a valid certificate chain by using the signing function

Specified by:

signPendingCertificateRequests in interface CertificateExchange

Throws:

IOException

pollCertificate

public void pollCertificate(String nodeId,
 Consumer<CertificateChain> chainConsumer)

Description copied from interface: CertificateExchange

If the consumer fails to consume existing certificate, the certificate won't be removed and the attempt will be repeated during the next poll call.

Specified by:

pollCertificate in interface CertificateExchange

parseCertificateChain

public CertificateChain parseCertificateChain(String certificate)