Skip to content
Snippets Groups Projects
Commit 65b9e5dc authored by Danielle Jackson's avatar Danielle Jackson
Browse files

moved indexer spi's back to indexer-core

parent dffd52bd
No related branches found
No related tags found
1 merge request!6Trusted ibm
Showing
with 25 additions and 10 deletions
package org.opengroup.osdu.indexer.provider.interfaces;
import org.opengroup.osdu.core.common.model.core.DpsHeaders;
import org.opengroup.osdu.core.common.model.indexer.JobStatus;
public interface IPublisher {
public void publishStatusChangedTagsToTopic(DpsHeaders headers, JobStatus indexerBatchStatus) throws Exception;
}
package org.opengroup.osdu.indexer.provider.interfaces;
import org.opengroup.osdu.core.common.model.core.ICache;
public interface ISchemaCache <String,V> extends ICache<String, V> {
}
......@@ -27,7 +27,7 @@ import org.opengroup.osdu.core.common.model.indexer.IndexSchema;
import org.opengroup.osdu.core.common.model.indexer.OperationType;
import org.opengroup.osdu.core.common.model.indexer.Schema;
import org.opengroup.osdu.core.common.model.indexer.StorageType;
import org.opengroup.osdu.core.common.spi.indexer.ISchemaCache;
import org.opengroup.osdu.indexer.provider.interfaces.ISchemaCache;
import org.opengroup.osdu.indexer.util.TypeMapper;
import org.opengroup.osdu.core.common.model.coreis.RequestStatus;
import org.opengroup.osdu.core.common.model.coreis.RecordMetaAttribute;
......
......@@ -36,7 +36,7 @@ import org.opengroup.osdu.core.common.model.AppException;
import org.opengroup.osdu.core.common.model.indexer.*;
import org.opengroup.osdu.core.common.model.storage.ConversionStatus;
import org.opengroup.osdu.core.common.service.coreis.JaxRsDpsLog;
import org.opengroup.osdu.core.common.spi.indexer.IPublisher;
import org.opengroup.osdu.indexer.provider.interfaces.IPublisher;
import org.opengroup.osdu.indexer.util.IndexerQueueTaskBuilder;
import org.opengroup.osdu.core.common.model.coreis.RequestStatus;
import org.opengroup.osdu.core.common.model.coreis.RecordChangedMessages;
......
......@@ -15,7 +15,7 @@
package org.opengroup.osdu.indexer.aws.cache;
import org.opengroup.osdu.core.common.model.core.cache.RedisCache;
import org.opengroup.osdu.core.common.spi.indexer.ISchemaCache;
import org.opengroup.osdu.indexer.provider.interfaces.ISchemaCache;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
......
......@@ -20,7 +20,7 @@ import com.amazonaws.services.sns.AmazonSNS;
import org.opengroup.osdu.core.common.model.core.DpsHeaders;
import org.opengroup.osdu.core.aws.sns.AmazonSNSConfig;
import org.opengroup.osdu.core.aws.sns.PublishRequestBuilder;
import org.opengroup.osdu.core.common.spi.indexer.IPublisher;
import org.opengroup.osdu.indexer.provider.interfaces.IPublisher;
import org.opengroup.osdu.core.common.model.indexer.JobStatus;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
......
package org.opengroup.osdu.indexer.azure.cache;
import org.opengroup.osdu.core.common.model.core.cache.VmCache;
import org.opengroup.osdu.core.common.spi.indexer.ISchemaCache;
import org.opengroup.osdu.indexer.provider.interfaces.ISchemaCache;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
......
......@@ -28,7 +28,7 @@ import org.opengroup.osdu.core.common.model.core.DpsHeaders;
import org.opengroup.osdu.core.common.model.indexer.JobStatus;
import org.opengroup.osdu.core.common.model.indexer.RecordStatus;
import org.opengroup.osdu.core.common.service.coreis.JaxRsDpsLog;
import org.opengroup.osdu.core.common.spi.indexer.IPublisher;
import org.opengroup.osdu.indexer.provider.interfaces.IPublisher;
import org.opengroup.osdu.core.common.model.coreis.RecordChangedMessages;
import org.springframework.stereotype.Component;
import org.springframework.web.context.annotation.RequestScope;
......
......@@ -25,7 +25,7 @@ import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.opengroup.osdu.core.common.model.indexer.IndexSchema;
import org.opengroup.osdu.core.common.model.indexer.OperationType;
import org.opengroup.osdu.core.common.spi.indexer.ISchemaCache;
import org.opengroup.osdu.indexer.provider.interfaces.ISchemaCache;
import org.opengroup.osdu.indexer.service.IndexSchemaServiceImpl;
import org.opengroup.osdu.indexer.service.IndexerMappingService;
import org.opengroup.osdu.indexer.service.StorageService;
......
package org.opengroup.osdu.indexer.cache;
import org.opengroup.osdu.core.common.model.core.cache.RedisCache;
import org.opengroup.osdu.core.common.spi.indexer.ISchemaCache;
import org.opengroup.osdu.indexer.provider.interfaces.ISchemaCache;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
......
......@@ -33,7 +33,7 @@ import org.opengroup.osdu.core.common.model.core.TenantInfo;
import org.opengroup.osdu.core.common.model.AppException;
import org.opengroup.osdu.core.common.model.indexer.JobStatus;
import org.opengroup.osdu.core.common.model.indexer.RecordStatus;
import org.opengroup.osdu.core.common.spi.indexer.IPublisher;
import org.opengroup.osdu.indexer.provider.interfaces.IPublisher;
import org.opengroup.osdu.core.gcp.PubSub.PubSubExtensions;
import org.opengroup.osdu.core.common.model.coreis.DeploymentEnvironment;
import org.springframework.beans.factory.annotation.Value;
......
......@@ -25,7 +25,7 @@ import org.mockito.Mock;
import org.opengroup.osdu.core.common.model.AppException;
import org.opengroup.osdu.core.common.model.indexer.OperationType;
import org.opengroup.osdu.core.common.service.coreis.JaxRsDpsLog;
import org.opengroup.osdu.core.common.spi.indexer.ISchemaCache;
import org.opengroup.osdu.indexer.provider.interfaces.ISchemaCache;
import org.opengroup.osdu.core.common.model.indexer.IndexSchema;
import org.opengroup.osdu.core.common.model.coreis.RequestStatus;
import org.opengroup.osdu.core.common.service.coreis.IndicesService;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment