com.netflix.conductor.noopindex

Class NoopIndexDAO

java.lang.Object

com.netflix.conductor.noopindex.NoopIndexDAO

All Implemented Interfaces:

com.netflix.conductor.dao.IndexDAO

@Singleton
public class NoopIndexDAO
extends java.lang.Object
implements com.netflix.conductor.dao.IndexDAO

Dummy implementation of IndexDAO which does nothing. Nothing is ever indexed, and no results are ever returned.

Constructor Summary

Constructors

Constructor and Description
NoopIndexDAO()

Method Summary

Modifier and Type	Method and Description
void	addEventExecution(com.netflix.conductor.common.metadata.events.EventExecution eventExecution)
void	addMessage(java.lang.String queue, com.netflix.conductor.core.events.queue.Message msg)
void	addTaskExecutionLogs(java.util.List<com.netflix.conductor.common.metadata.tasks.TaskExecLog> logs)
java.util.concurrent.CompletableFuture<java.lang.Void>	asyncAddEventExecution(com.netflix.conductor.common.metadata.events.EventExecution eventExecution)
java.util.concurrent.CompletableFuture<java.lang.Void>	asyncAddMessage(java.lang.String queue, com.netflix.conductor.core.events.queue.Message message)
java.util.concurrent.CompletableFuture<java.lang.Void>	asyncAddTaskExecutionLogs(java.util.List<com.netflix.conductor.common.metadata.tasks.TaskExecLog> logs)
java.util.concurrent.CompletableFuture<java.lang.Void>	asyncIndexTask(com.netflix.conductor.common.metadata.tasks.Task task)
java.util.concurrent.CompletableFuture<java.lang.Void>	asyncIndexWorkflow(com.netflix.conductor.common.run.Workflow workflow)
java.util.concurrent.CompletableFuture<java.lang.Void>	asyncRemoveWorkflow(java.lang.String workflowId)
java.util.concurrent.CompletableFuture<java.lang.Void>	asyncUpdateWorkflow(java.lang.String workflowInstanceId, java.lang.String[] keys, java.lang.Object[] values)
java.lang.String	get(java.lang.String workflowInstanceId, java.lang.String key)
java.util.List<com.netflix.conductor.common.metadata.events.EventExecution>	getEventExecutions(java.lang.String event)
java.util.List<com.netflix.conductor.core.events.queue.Message>	getMessages(java.lang.String queue)
java.util.List<com.netflix.conductor.common.metadata.tasks.TaskExecLog>	getTaskExecutionLogs(java.lang.String taskId)
void	indexTask(com.netflix.conductor.common.metadata.tasks.Task task)
void	indexWorkflow(com.netflix.conductor.common.run.Workflow workflow)
void	removeWorkflow(java.lang.String workflowId)
java.util.List<java.lang.String>	searchArchivableWorkflows(java.lang.String indexName, long archiveTtlDays)
java.util.List<java.lang.String>	searchRecentRunningWorkflows(int lastModifiedHoursAgoFrom, int lastModifiedHoursAgoTo)
com.netflix.conductor.common.run.SearchResult<java.lang.String>	searchTasks(java.lang.String query, java.lang.String freeText, int start, int count, java.util.List<java.lang.String> sort)
com.netflix.conductor.common.run.SearchResult<java.lang.String>	searchWorkflows(java.lang.String query, java.lang.String freeText, int start, int count, java.util.List<java.lang.String> sort)
void	setup()
void	updateWorkflow(java.lang.String workflowInstanceId, java.lang.String[] keys, java.lang.Object[] values)

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopIndexDAO

public NoopIndexDAO()

Method Detail

setup

public void setup()

Specified by:

setup in interface com.netflix.conductor.dao.IndexDAO

indexWorkflow

public void indexWorkflow(com.netflix.conductor.common.run.Workflow workflow)

Specified by:

indexWorkflow in interface com.netflix.conductor.dao.IndexDAO

asyncIndexWorkflow

public java.util.concurrent.CompletableFuture<java.lang.Void> asyncIndexWorkflow(com.netflix.conductor.common.run.Workflow workflow)

Specified by:

asyncIndexWorkflow in interface com.netflix.conductor.dao.IndexDAO

indexTask

public void indexTask(com.netflix.conductor.common.metadata.tasks.Task task)

Specified by:

indexTask in interface com.netflix.conductor.dao.IndexDAO

asyncIndexTask

public java.util.concurrent.CompletableFuture<java.lang.Void> asyncIndexTask(com.netflix.conductor.common.metadata.tasks.Task task)

Specified by:

asyncIndexTask in interface com.netflix.conductor.dao.IndexDAO

searchWorkflows

public com.netflix.conductor.common.run.SearchResult<java.lang.String> searchWorkflows(java.lang.String query,
                                                                                       java.lang.String freeText,
                                                                                       int start,
                                                                                       int count,
                                                                                       java.util.List<java.lang.String> sort)

Specified by:

searchWorkflows in interface com.netflix.conductor.dao.IndexDAO

searchTasks

public com.netflix.conductor.common.run.SearchResult<java.lang.String> searchTasks(java.lang.String query,
                                                                                   java.lang.String freeText,
                                                                                   int start,
                                                                                   int count,
                                                                                   java.util.List<java.lang.String> sort)

Specified by:

searchTasks in interface com.netflix.conductor.dao.IndexDAO

removeWorkflow

public void removeWorkflow(java.lang.String workflowId)

Specified by:

removeWorkflow in interface com.netflix.conductor.dao.IndexDAO

asyncRemoveWorkflow

public java.util.concurrent.CompletableFuture<java.lang.Void> asyncRemoveWorkflow(java.lang.String workflowId)

Specified by:

asyncRemoveWorkflow in interface com.netflix.conductor.dao.IndexDAO

updateWorkflow

public void updateWorkflow(java.lang.String workflowInstanceId,
                           java.lang.String[] keys,
                           java.lang.Object[] values)

Specified by:

updateWorkflow in interface com.netflix.conductor.dao.IndexDAO

asyncUpdateWorkflow

public java.util.concurrent.CompletableFuture<java.lang.Void> asyncUpdateWorkflow(java.lang.String workflowInstanceId,
                                                                                  java.lang.String[] keys,
                                                                                  java.lang.Object[] values)

Specified by:

asyncUpdateWorkflow in interface com.netflix.conductor.dao.IndexDAO

get

public java.lang.String get(java.lang.String workflowInstanceId,
                            java.lang.String key)

Specified by:

get in interface com.netflix.conductor.dao.IndexDAO

addTaskExecutionLogs

public void addTaskExecutionLogs(java.util.List<com.netflix.conductor.common.metadata.tasks.TaskExecLog> logs)

Specified by:

addTaskExecutionLogs in interface com.netflix.conductor.dao.IndexDAO

asyncAddTaskExecutionLogs

public java.util.concurrent.CompletableFuture<java.lang.Void> asyncAddTaskExecutionLogs(java.util.List<com.netflix.conductor.common.metadata.tasks.TaskExecLog> logs)

Specified by:

asyncAddTaskExecutionLogs in interface com.netflix.conductor.dao.IndexDAO

getTaskExecutionLogs

public java.util.List<com.netflix.conductor.common.metadata.tasks.TaskExecLog> getTaskExecutionLogs(java.lang.String taskId)

Specified by:

getTaskExecutionLogs in interface com.netflix.conductor.dao.IndexDAO

addEventExecution

public void addEventExecution(com.netflix.conductor.common.metadata.events.EventExecution eventExecution)

Specified by:

addEventExecution in interface com.netflix.conductor.dao.IndexDAO

getEventExecutions

public java.util.List<com.netflix.conductor.common.metadata.events.EventExecution> getEventExecutions(java.lang.String event)

Specified by:

getEventExecutions in interface com.netflix.conductor.dao.IndexDAO

asyncAddEventExecution

public java.util.concurrent.CompletableFuture<java.lang.Void> asyncAddEventExecution(com.netflix.conductor.common.metadata.events.EventExecution eventExecution)

Specified by:

asyncAddEventExecution in interface com.netflix.conductor.dao.IndexDAO

addMessage

public void addMessage(java.lang.String queue,
                       com.netflix.conductor.core.events.queue.Message msg)

Specified by:

addMessage in interface com.netflix.conductor.dao.IndexDAO

asyncAddMessage

public java.util.concurrent.CompletableFuture<java.lang.Void> asyncAddMessage(java.lang.String queue,
                                                                              com.netflix.conductor.core.events.queue.Message message)

Specified by:

asyncAddMessage in interface com.netflix.conductor.dao.IndexDAO

getMessages

public java.util.List<com.netflix.conductor.core.events.queue.Message> getMessages(java.lang.String queue)

Specified by:

getMessages in interface com.netflix.conductor.dao.IndexDAO

searchArchivableWorkflows

public java.util.List<java.lang.String> searchArchivableWorkflows(java.lang.String indexName,
                                                                  long archiveTtlDays)

Specified by:

searchArchivableWorkflows in interface com.netflix.conductor.dao.IndexDAO

searchRecentRunningWorkflows

public java.util.List<java.lang.String> searchRecentRunningWorkflows(int lastModifiedHoursAgoFrom,
                                                                     int lastModifiedHoursAgoTo)

Specified by:

searchRecentRunningWorkflows in interface com.netflix.conductor.dao.IndexDAO