Class OpenSearchPipesReporter

    • Field Detail

      • DEFAULT_PARSE_TIME_KEY

        public static String DEFAULT_PARSE_TIME_KEY
      • DEFAULT_PARSE_STATUS_KEY

        public static String DEFAULT_PARSE_STATUS_KEY
      • DEFAULT_EXIT_VALUE_KEY

        public static String DEFAULT_EXIT_VALUE_KEY
    • Constructor Detail

      • OpenSearchPipesReporter

        public OpenSearchPipesReporter()
    • Method Detail

      • error

        public void error​(Throwable t)
        Description copied from class: PipesReporter
        This is called if the process has crashed. Implementers should not rely on close() to be called after this.
        Specified by:
        error in class PipesReporter
      • error

        public void error​(String msg)
        Description copied from class: PipesReporter
        This is called if the process has crashed. Implementers should not rely on close() to be called after this.
        Specified by:
        error in class PipesReporter
      • setConnectionTimeout

        @Field
        public void setConnectionTimeout​(int connectionTimeout)
      • setSocketTimeout

        @Field
        public void setSocketTimeout​(int socketTimeout)
      • setOpenSearchUrl

        @Field
        public void setOpenSearchUrl​(String openSearchUrl)
      • setUserName

        @Field
        public void setUserName​(String userName)
      • setPassword

        @Field
        public void setPassword​(String password)
      • setAuthScheme

        @Field
        public void setAuthScheme​(String authScheme)
      • setProxyHost

        @Field
        public void setProxyHost​(String proxyHost)
      • setProxyPort

        @Field
        public void setProxyPort​(int proxyPort)
      • setIncludeStatuses

        @Field
        public void setIncludeStatuses​(List<String> statusList)
      • setExcludeStatuses

        @Field
        public void setExcludeStatuses​(List<String> statusList)
      • setIncludeRouting

        @Field
        public void setIncludeRouting​(boolean includeRouting)
      • setKeyPrefix

        @Field
        public void setKeyPrefix​(String keyPrefix)
        This prefixes the keys before sending them to OpenSearch. For example, "pdfinfo_", would have this reporter sending "pdfinfo_status" and "pdfinfo_parse_time" to OpenSearch.
        Parameters:
        keyPrefix -