@Component(value="audit-cassandra-dao") public class AuditCassandraDao extends CassandraDao
client, manager, session
Constructor and Description |
---|
AuditCassandraDao() |
@PostConstruct public void init()
public <T extends AuditingGenericEvent> CassandraOperationStatus saveRecord(T entity)
public fj.data.Either<List<DistributionStatusEvent>,ActionStatus> getListOfDistributionStatuses(String did)
did
- public fj.data.Either<List<DistributionDeployEvent>,ActionStatus> getDistributionDeployByStatus(String did, String action, String status)
public fj.data.Either<List<ResourceAdminEvent>,ActionStatus> getDistributionRequest(String did, String action)
public fj.data.Either<List<DistributionNotificationEvent>,ActionStatus> getDistributionNotify(String did, String action)
public fj.data.Either<List<ResourceAdminEvent>,ActionStatus> getByServiceInstanceId(String serviceInstanceId)
public fj.data.Either<List<? extends AuditingGenericEvent>,ActionStatus> getServiceDistributionStatusesList(String serviceInstanceId)
serviceInstanceId
- public fj.data.Either<List<ResourceAdminEvent>,ActionStatus> getAuditByServiceIdAndPrevVersion(String serviceInstanceId, String prevVersion)
public fj.data.Either<List<ResourceAdminEvent>,ActionStatus> getAuditByServiceIdAndCurrVersion(String serviceInstanceId, String currVersion)
public fj.data.Either<Boolean,CassandraOperationStatus> isTableEmpty(String tableName)
isTableEmpty
in class CassandraDao
tableName
- the name of the table we want to checkpublic CassandraOperationStatus deleteAllAudit()
Copyright © 2017. All rights reserved.