Package com.lucidworks.apollo.store

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

java.lang.Object
com.lucidworks.apollo.store.DecryptingPipelineReader<T>
All Implemented Interfaces:
com.lucidworks.apollo.store.ItemReader<T>
public class DecryptingPipelineReader<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>> extends Object implements com.lucidworks.apollo.store.ItemReader<T>
ItemReader that decrypts secrets (e.g. passwords) stored in pipeline definitions in Zk

  • Constructor Summary

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

  • Method Summary

    Modifier and Type
    Method
    Description
    T
    read(byte[] bytes)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • DecryptingPipelineReader

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

  • Method Details

    • read

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