Package com.lucidworks.apollo.store

Class EncryptingPipelineWriter<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>

java.lang.Object
com.lucidworks.apollo.store.EncryptingPipelineWriter<T>
All Implemented Interfaces:
com.lucidworks.apollo.store.ItemWriter<T>
public class EncryptingPipelineWriter<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>> extends Object implements com.lucidworks.apollo.store.ItemWriter<T>
ItemWriter that encrypts secrets (e.g. passwords) in pipeline definitions before saving to Zk

  • Constructor Summary

    Constructors
    Constructor
    Description
    EncryptingPipelineWriter(com.fasterxml.jackson.databind.ObjectMapper mapper, com.lucidworks.apollo.security.crypto.StringEncryptor encryptor, Class<T> clazz, com.lucidworks.apollo.pipeline.schema.SchemaProcessorFactory schemaProcessorFactory)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    byte[]
    write(T item)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • EncryptingPipelineWriter

      public EncryptingPipelineWriter(com.fasterxml.jackson.databind.ObjectMapper mapper, com.lucidworks.apollo.security.crypto.StringEncryptor encryptor, Class<T> clazz, com.lucidworks.apollo.pipeline.schema.SchemaProcessorFactory schemaProcessorFactory)

  • Method Details

    • write

      public byte[] write(T item) throws IOException
      Specified by:
      write in interface com.lucidworks.apollo.store.ItemWriter<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>>
      Throws:
      IOException