Types & classes — github.com/ChenInfo/Gengine

hub / github.com/ChenInfo/Gengine / types & classes

Types & classes151 in github.com/ChenInfo/Gengine

⨍ Functions 946◇ Types & classes 151

Base component which pulls a message off the queue before performing the work, useful when progress reporting is needed as some messaging endpoints wi

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/content/AbstractAsyncComponent.java:22

ClassAbstractComponent

Base implementation of a component with content worker and messageProducer fields. @param <W>

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/content/AbstractComponent.java:10

ClassAbstractComponentBootstrapFromProperties

Base bootstrap which creates a component, configures it with a worker, and creates an endpoint for sending and receiving messages @param <W>

gengine-node-simple/src/main/java/org/gengine/content/node/AbstractComponentBootstrapFromProperties.java:26

ClassAbstractContentHashWorker

Abstract hash node worker which uses a content reference handler to convert the content reference into a usable input stream for the actual implementa

gengine-hash/gengine-hash-commons/src/main/java/org/gengine/content/hash/AbstractContentHashWorker.java:19

ClassAbstractContentReply

Base implementation of a content reply

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/content/AbstractContentReply.java:12

ClassAbstractContentRequest

Represents a request for some operation on content sources.

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/content/AbstractContentRequest.java:12

ClassAbstractContentTransformerWorker

Abstract transform node worker which uses a content reference handler to convert the content reference into a usable File object for the actual implem

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/AbstractContentTransformerWorker.java:13

ClassAbstractContentTransformerWorkerTest

Base content transformer worker class

gengine-transform/gengine-transform-commons/src/test/java/org/gengine/content/transform/AbstractContentTransformerWorkerTest.java:18

ClassAbstractContentWorker

Base implementation of a content worker with a <code>sourceContentReferenceHandler</code> field.

gengine-commons/src/main/java/org/gengine/content/AbstractContentWorker.java:17

ClassAbstractFileContentTransformerWorker

Extension of AbstractContentTransformerWorker for dealing with file content references

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/AbstractFileContentTransformerWorker.java:32

ClassAbstractHeartImpl

Abstract heart implementation for sending {@link Heartbeat} messages.

gengine-health-commons/src/main/java/org/gengine/health/heartbeat/AbstractHeartImpl.java:15

ClassAbstractReply

Base implementation of a reply.

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/messaging/AbstractReply.java:7

ClassAbstractRequest

Represents a generic messaging request

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/messaging/AbstractRequest.java:9

ClassAbstractRuntimeExecContentTransformerWorker

Base class that uses a command line {@link RuntimeExec} to perform the transform

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/AbstractRuntimeExecContentTransformerWorker.java:17

ClassAbstractTransformationSourceOptions

Base implementation of TransformationSourceOptions which holds applicable mimetypes and handles merge of options.

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/options/AbstractTransformationSourceOptions.java:17

ClassAbstractUrlContentReferenceHandler

A base ContentReferenceHandler implementation with convenience methods for dealing with URLs.

gengine-commons/src/main/java/org/gengine/content/handler/AbstractUrlContentReferenceHandler.java:10

EnumAction

Action to take place for a given pair of values.

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/options/TransformationOptionPair.java:31

ClassAmqpDirectEndpoint

A {@link MessageProducer} and message listener which interacts with AMQP queues directly using Apache Qpid.

gengine-messaging/gengine-messaging-amqp-direct/src/main/java/org/gengine/messaging/amqp/AmqpDirectEndpoint.java:33

ClassAmqpListener

gengine-messaging/gengine-messaging-amqp-direct/src/main/java/org/gengine/messaging/amqp/AmqpDirectEndpoint.java:64

ClassAmqpNodeBootstrapUtils

A utility class for helping to bootstrap AMQP nodes from command line arguments

gengine-messaging/gengine-messaging-amqp-direct/src/main/java/org/gengine/messaging/amqp/AmqpNodeBootstrapUtils.java:18

ClassAudioTransformationOptions

Options relating to audio transformations

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/options/AudioTransformationOptions.java:11

ClassBaseContentHashComponent

A base implementation of a hash node which receives messages, uses a {@link ContentHashWorker} to perform the hash computation, then uses a {@link Mes

gengine-hash/gengine-hash-component/src/main/java/org/gengine/content/hash/BaseContentHashComponent.java:18

ClassBaseContentTransformerComponent

A base implementation of a transform node which receives messages, uses a {@link ContentTransformerWorker} to perform the transformation, then uses a

gengine-transform/gengine-transform-component/src/main/java/org/gengine/content/transform/BaseContentTransformerComponent.java:18

ClassBeanUtils

Utility class for common operations on Java beans

gengine-commons/src/main/java/org/gengine/util/BeanUtils.java:15

ClassBenchmarkConsumer

Consumer of {@link BenchmarkMessage}s which maintains a count of messages received.

gengine-messaging/gengine-messaging-benchmark/src/main/java/org/gengine/messaging/benchmark/BenchmarkConsumer.java:11

ClassBenchmarkMessage

A simple message with a decent sized payload for benchmarking.

gengine-messaging/gengine-messaging-benchmark/src/main/java/org/gengine/messaging/benchmark/BenchmarkMessage.java:13

ClassBenchmarkRunner

Runner which creates an {@link AmqpDirectEndpoint} or Camel-based endpoint (depending on the <code>brokerUrl</code> given) with a {@link BenchmarkCons

gengine-messaging/gengine-messaging-benchmark/src/main/java/org/gengine/messaging/benchmark/BenchmarkRunner.java:40

ClassBootstrap

Boostrap which creates and runs a {@link BenchmarkRunner}

gengine-messaging/gengine-messaging-benchmark/src/main/java/org/gengine/messaging/benchmark/Bootstrap.java:10

ClassBootstrapArguments

gengine-messaging/gengine-messaging-benchmark/src/main/java/org/gengine/messaging/benchmark/BootstrapArguments.java:3

ClassCamelMessageProducer

An Apache Camel implementation of a message producer

gengine-messaging/gengine-messaging-camel/src/main/java/org/gengine/messaging/camel/CamelMessageProducer.java:17

ClassCamelRequestReplyMessageProducer

An Apache Camel implementation of a request-reply message producer. A pending requests map is maintained and the {@link ReplyCallable} periodicall

gengine-messaging/gengine-messaging-camel/src/main/java/org/gengine/messaging/camel/CamelRequestReplyMessageProducer.java:36

ClassCleaningTempFileProvider

A helper class that provides temporary files, providing a common point to clean them up. The contents of CHENINFO_TEMP_FILE_DIR [%java.io.tmpdir%

gengine-content-handlers/gengine-content-handler-tempfile/src/main/java/org/gengine/content/file/CleaningTempFileProvider.java:32

InterfaceComponent

Defines a component which is a consumer of request for content action messages, delegates that work to a worker, and sends a reply with the results.

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/content/Component.java:10

InterfaceComponentUnavailableAction

Defines actions to be taken when a service's dependent component is unavailable.

gengine-health-commons/src/main/java/org/gengine/health/ComponentUnavailableAction.java:7

ClassComponentUnavailableActionStopCamelContext

ComponentUnavailableAction which stops a given Camel context.

gengine-messaging/gengine-messaging-camel/src/main/java/org/gengine/health/camel/ComponentUnavailableActionStopCamelContext.java:12

ClassComponentUnavailableActionTerminate

ComponentUnavailableAction which terminates the JVM with the specified exit code, not to be used lightly.

gengine-health-commons/src/main/java/org/gengine/health/ComponentUnavailableActionTerminate.java:10

ClassComponentUnavailableException

Thrown when a dependent component such as a database or other service is unavailable.

gengine-health-commons/src/main/java/org/gengine/health/ComponentUnavailableException.java:7

ClassComponentUnavailableExceptionHandler

Determines the {@link ComponentUnavailableAction} to execute when a {@link ComponentUnavailableException} is thrown

gengine-health-commons/src/main/java/org/gengine/health/ComponentUnavailableExceptionHandler.java:13

ClassCompositeComponentUnavailableAction

ComponentUnavailableAction which iterates over a list of specified actions.

gengine-health-commons/src/main/java/org/gengine/health/CompositeComponentUnavailableAction.java:19

ClassContentHashException

Thrown when an implementation can not perform the requested hashing due to configuration or environment.

gengine-hash/gengine-hash-commons/src/main/java/org/gengine/content/hash/ContentHashException.java:8

InterfaceContentHashWorker

Defines the methods responsible for doing the work of hash computation of content references

gengine-hash/gengine-hash-commons/src/main/java/org/gengine/content/hash/ContentHashWorker.java:14

ClassContentIOException

Wraps a general <code>Exceptions</code> that occurred while reading or writing content. @see Throwable#getCause()

gengine-commons/src/main/java/org/gengine/content/ContentIOException.java:14

ClassContentReference

A reference to content by its URI and media type (mimetype). @see {@link ContentReferenceHandler}

gengine-commons/src/main/java/org/gengine/content/ContentReference.java:11

InterfaceContentReferenceHandler

Defines a handler for reading and writing {@link ContentReference} objects.

gengine-commons/src/main/java/org/gengine/content/handler/ContentReferenceHandler.java:13

InterfaceContentReply

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/content/ContentReply.java:7

InterfaceContentTransformerWorker

Defines the methods responsible for doing the work of transformation of a content reference

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/ContentTransformerWorker.java:14

InterfaceContentTransformerWorkerProgressReporter

Defines methods for reporting progress on a content transformation. Implementations might send replies via messaging system or just log progress.

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/ContentTransformerWorkerProgressReporter.java:14

ClassContentTransformerWorkerProgressReporterImpl

Implementation of the progress reporter which sends reply messages with progress on the transformation.

gengine-transform/gengine-transform-component/src/main/java/org/gengine/content/transform/BaseContentTransformerComponent.java:74

ClassContentWorkResult

The result of some operation on content which includes a content reference and details about the operation. The content reference could indicate t

gengine-commons/src/main/java/org/gengine/content/ContentWorkResult.java:13

InterfaceContentWorker

Defines a low-level worker that performs some action on content, i.e. performing a transformation, extracting metadata, computing a hash, etc.

gengine-commons/src/main/java/org/gengine/content/ContentWorker.java:8

ClassCropSourceOptions

DTO used to store options for ImageMagick cropping.

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/options/CropSourceOptions.java:16

ClassCropSourceOptionsSerializer

Serializer for crop source options

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/options/CropSourceOptions.java:222

ClassDelegatingContentHandlerImpl

ContentReferenceHandler implementation that maintains a list of delegates that are chosen based on the content references passed to method invocations

gengine-commons/src/main/java/org/gengine/content/handler/DelegatingContentHandlerImpl.java:15

ClassDelegatingContentHandlerImplTest

gengine-commons/src/test/java/org/gengine/content/handler/DelegatingContentHandlerImplTest.java:22

EnumEnumValue

gengine-messaging/gengine-messaging-camel/src/test/java/org/gengine/messaging/camel/dataformat/SimplePojo.java:7

ClassEqualsHelper

Utility class providing helper methods for various types of <code>equals</code> functionality

gengine-commons/src/main/java/org/gengine/util/EqualsHelper.java:16

ClassExceptionProcessor

Camel Processor and standard bean which provide methods to pass the exception to the specified handler.

gengine-messaging/gengine-messaging-camel/src/main/java/org/gengine/health/camel/ExceptionProcessor.java:12

ClassExecParameterTokenizer

This class is used to tokenize strings used as parameters for {@link RuntimeExec} objects. Examples of such strings are as follows (ImageMagick-like p

gengine-commons/src/main/java/org/gengine/util/exec/ExecParameterTokenizer.java:34

ClassExecParameterTokenizerTest

Unit test class for {@link ExecParameterTokenizer}. @since 3.4.2

gengine-commons/src/test/java/org/gengine/util/exec/ExecParameterTokenizerTest.java:15

ClassExecutionResult

Object to carry the results of an execution to the caller.

gengine-commons/src/main/java/org/gengine/util/exec/RuntimeExec.java:772

ClassFfmpegContentTransformerWorker

An FFmpeg command line implementation of a content hash node worker

gengine-transform/gengine-transform-worker-ffmpeg/src/main/java/org/gengine/content/transform/ffmpeg/FfmpegContentTransformerWorker.java:36

ClassFfmpegContentTransformerWorkerIT

@see {@link FfmpegContentTransformerWorker}

gengine-transform/gengine-transform-worker-ffmpeg/src/test/java/org/gengine/content/transform/ffmpeg/FfmpegContentTransformerWorkerIT.java:37

ClassFfmpegInputStreamReaderThread

Reads the input stream to a string buffer via InputStreamReaderThread but also parses for progress

gengine-transform/gengine-transform-worker-ffmpeg/src/main/java/org/gengine/content/transform/ffmpeg/FfmpegInputStreamReaderThreadFactory.java:60

ClassFfmpegInputStreamReaderThreadFactory

InputStreamReaderThreadFactory extension which, in addition to adding the input stream to a string, parses the buffered portions of the stream for tra

gengine-transform/gengine-transform-worker-ffmpeg/src/main/java/org/gengine/content/transform/ffmpeg/FfmpegInputStreamReaderThreadFactory.java:24

InterfaceFileContentReferenceHandler

Adds file handling to the ContentReferenceHandler interface.

gengine-commons/src/main/java/org/gengine/content/handler/FileContentReferenceHandler.java:12

ClassFileContentReferenceHandlerImpl

Java {@link File} content reference handler implementation. Content reference creation is delegated to {@link FileProvider}.

gengine-commons/src/main/java/org/gengine/content/handler/FileContentReferenceHandlerImpl.java:29

ClassFileContentReferenceHandlerImplTest

Tests of the file content reference handler @see {@link FileContentReferenceHandler}

gengine-commons/src/test/java/org/gengine/content/handler/FileContentReferenceHandlerImplTest.java:20

ClassFileContentReferencePair

Wrapper for a content reference and a {@link File}, useful for passing around an already instantiated File object with a related content reference.

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/AbstractFileContentTransformerWorker.java:308

EnumFileMediaType

Convenience enum for to more easily use media types with {@link FileMediaTypeServiceImpl}.

gengine-commons/src/main/java/org/gengine/content/mediatype/FileMediaType.java:12

InterfaceFileMediaTypeService

Defines a service for getting extensions for media types and vice versa.

gengine-commons/src/main/java/org/gengine/content/mediatype/FileMediaTypeService.java:9

ClassFileMediaTypeServiceImpl

Implementation of FileMediaTypeService which delegates to Apache Tika to do the actual work.

gengine-commons/src/main/java/org/gengine/content/mediatype/FileMediaTypeServiceImpl.java:18

InterfaceFileProvider

Defines methods to create files. Implementations might include leverage Java's temporary file components, explicit user-defined directories, etc.

gengine-commons/src/main/java/org/gengine/content/file/FileProvider.java:10

ClassFileProviderImpl

FileProvider implementation which is configured with a directoryPath in which files should be created

gengine-commons/src/main/java/org/gengine/content/file/FileProviderImpl.java:14

ClassGengineRuntimeException

I18n'ed runtime exception thrown by ChenInfo code.

gengine-commons/src/main/java/org/gengine/error/GengineRuntimeException.java:15

ClassHashComponentBootstrapFromProperties

Bootraps a hash component @param <W>

gengine-node-simple/src/main/java/org/gengine/content/node/HashComponentBootstrapFromProperties.java:15

ClassHashReply

Represents a reply from a content hasher on the status of a hash request.

gengine-hash/gengine-hash-messaging/src/main/java/org/gengine/content/hash/HashReply.java:10

ClassHashRequest

Represents a request for content hash

gengine-hash/gengine-hash-messaging/src/main/java/org/gengine/content/hash/HashRequest.java:13

InterfaceHeart

Defines the object responsible for producing {@link Heartbeat}s which let services monitor health of other services in the system.

gengine-health-commons/src/main/java/org/gengine/health/heartbeat/Heart.java:8

ClassHeartbeat

An object describing service resource behavior at a particular point in time.

gengine-health-commons/src/main/java/org/gengine/health/heartbeat/Heartbeat.java:10

InterfaceHeartbeatDao

Defines the persistence of a heartbeat. Implementations might be a log, database, or in-memory queue.

gengine-health-commons/src/main/java/org/gengine/health/heartbeat/HeartbeatDao.java:8

InterfaceHeartbeatMonitor

Defines an object responsible for listening for the heartbeat. Implementations may utilize a {@link HeartbeatDao} to persist the data.

gengine-health-commons/src/main/java/org/gengine/health/heartbeat/HeartbeatMonitor.java:8

ClassHeartbeatMonitorImpl

HeartbeatMonitor implementation which uses Camel to route {@link Heartbeat} messages.

gengine-messaging/gengine-messaging-camel/src/main/java/org/gengine/health/camel/HeartbeatMonitorImpl.java:15

ClassHeartbeatTask

gengine-health-commons/src/main/java/org/gengine/health/heartbeat/AbstractHeartImpl.java:106

ClassI18NUtil

Utility class providing methods to access the Locale of the current thread and to get Localised strings.

gengine-commons/src/main/java/org/gengine/util/I18NUtil.java:23

ClassImageMagickContentTransformerWorker

Executes a statement to implement

gengine-transform/gengine-transform-worker-imagemagick/src/main/java/org/gengine/content/transform/imagemagick/ImageMagickContentTransformerWorker.java:29

ClassImageMagickContentTransformerWorkerIT

@see {@link ImageMagickContentTransformerWorker}

gengine-transform/gengine-transform-worker-imagemagick/src/test/java/org/gengine/content/transform/imagemagick/ImageMagickContentTransformerWorkerIT.java:36

ClassImageResizeOptions

Image resize options

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/options/ImageResizeOptions.java:12

ClassImageTransformationOptions

Image transformation options

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/options/ImageTransformationOptions.java:12

ClassInputStreamReaderThread

Gobbles an <code>InputStream</code> and writes it into a <code>StringBuffer</code> The reading of the input stream is buffered.

gengine-commons/src/main/java/org/gengine/util/exec/RuntimeExec.java:936

ClassInputStreamReaderThreadFactory

Class for instantiating InputStreamReaderThreads

gengine-commons/src/main/java/org/gengine/util/exec/RuntimeExec.java:922

ClassJacksonDataFormatTest

gengine-messaging/gengine-messaging-camel/src/test/java/org/gengine/messaging/camel/dataformat/JacksonDataFormatTest.java:24

ClassJavaSeContentHashWorker

A Java SE implementation of a content hash node worker

gengine-hash/gengine-hash-worker-javase/src/main/java/org/gengine/content/hash/javase/JavaSeContentHashWorker.java:17

ClassJavaSeContentHashWorkerTest

Test of the Java SE content hash worker @see {@link JavaSeContentHashWorker}

gengine-hash/gengine-hash-worker-javase/src/test/java/org/gengine/content/hash/javase/JavaSeContentHashWorkerTest.java:21

ClassJsonObjectMarshallerImplTest

gengine-transform/gengine-transform-component/src/test/java/org/gengine/messaging/marshalling/JsonObjectMarshallerImplTest.java:20

ClassLocalQueueProcessor

Takes from the local concurrent queue and hands them off to be processed

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/content/AbstractAsyncComponent.java:68

ClassLoggingDeadLetterQueue

Endpoint which simply logs dead letter messages

gengine-messaging/gengine-messaging-commons/src/main/java/org/gengine/messaging/LoggingDeadLetterQueue.java:10

ClassLoggingProgressReporterImpl

Progress reporter which logs via a given logger.

gengine-transform/gengine-transform-commons/src/main/java/org/gengine/content/transform/LoggingProgressReporterImpl.java:12

EnumMapValueComparison

Enumeration for results returned by {@link EqualsHelper#getMapComparison(Map, Map) map comparisons}. @since 3.3

gengine-commons/src/main/java/org/gengine/util/EqualsHelper.java:158

ClassMediaTypeServiceTest

Tests the media type service @see {@link FileMediaTypeService}

gengine-commons/src/test/java/org/gengine/content/mediatype/MediaTypeServiceTest.java:14

InterfaceMergable

Defines that a class can be merged with the overriding values from another object of the same type. @param <T>

gengine-commons/src/main/java/org/gengine/util/Mergable.java:9

next →1–100 of 151, ranked by callers