io.flamingock.targetsystem.couchbase

Class CouchbaseTargetSystem

java.lang.Object

io.flamingock.internal.core.external.targets.AbstractTargetSystem<HOLDER>

io.flamingock.internal.core.external.targets.TransactionalTargetSystem<CouchbaseTargetSystem>

io.flamingock.targetsystem.couchbase.CouchbaseTargetSystem

All Implemented Interfaces:

io.flamingock.api.external.ExternalSystem, io.flamingock.api.external.TargetSystem, io.flamingock.externalsystem.couchbase.api.CouchbaseExternalSystem, io.flamingock.internal.common.core.context.ContextConfigurable<CouchbaseTargetSystem>, io.flamingock.internal.common.core.context.ContextInitializable, io.flamingock.internal.common.core.context.ContextProvider

public class CouchbaseTargetSystem
extends io.flamingock.internal.core.external.targets.TransactionalTargetSystem<CouchbaseTargetSystem>
implements io.flamingock.externalsystem.couchbase.api.CouchbaseExternalSystem

Field Summary

Fields inherited from class io.flamingock.internal.core.external.targets.TransactionalTargetSystem

autoCreate, markerRepository, onGoingTasksRepositoryName

Fields inherited from class io.flamingock.internal.core.external.targets.AbstractTargetSystem

targetSystemContext

Constructor Summary

Constructors

Constructor and Description
CouchbaseTargetSystem(java.lang.String id, com.couchbase.client.java.Cluster cluster, java.lang.String bucketName)

Method Summary

Modifier and Type	Method and Description
java.util.Optional<io.flamingock.internal.common.core.audit.AuditHistoryReader>	getAuditAuditReader(io.flamingock.internal.common.core.audit.AuditReaderType type)
com.couchbase.client.java.Bucket	getBucket()
java.lang.String	getBucketName()
com.couchbase.client.java.Cluster	getCluster()
protected CouchbaseTargetSystem	getSelf()
io.flamingock.internal.core.transaction.TransactionManager<com.couchbase.client.java.transactions.TransactionAttemptContext>	getTxManager()
io.flamingock.internal.core.transaction.TransactionWrapper	getTxWrapper()
void	initialize(io.flamingock.internal.common.core.context.ContextResolver baseContext)

Methods inherited from class io.flamingock.internal.core.external.targets.TransactionalTargetSystem

applyChangeTransactional, getOnGoingTaskStatusRepository, hasMarker

Methods inherited from class io.flamingock.internal.core.external.targets.AbstractTargetSystem

addDependency, addDependency, addDependency, addDependency, applyChange, enhanceExecutionRuntime, getContext, getId, rollbackChange, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty, setProperty

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.flamingock.api.external.ExternalSystem

getId

Constructor Detail

CouchbaseTargetSystem

public CouchbaseTargetSystem(java.lang.String id,
                             com.couchbase.client.java.Cluster cluster,
                             java.lang.String bucketName)

Method Detail

getCluster

public com.couchbase.client.java.Cluster getCluster()

Specified by:

getCluster in interface io.flamingock.externalsystem.couchbase.api.CouchbaseExternalSystem

getBucket

public com.couchbase.client.java.Bucket getBucket()

Specified by:

getBucket in interface io.flamingock.externalsystem.couchbase.api.CouchbaseExternalSystem

getBucketName

public java.lang.String getBucketName()

Specified by:

getBucketName in interface io.flamingock.externalsystem.couchbase.api.CouchbaseExternalSystem

getTxManager

public io.flamingock.internal.core.transaction.TransactionManager<com.couchbase.client.java.transactions.TransactionAttemptContext> getTxManager()

initialize

public void initialize(io.flamingock.internal.common.core.context.ContextResolver baseContext)

Specified by:

initialize in interface io.flamingock.internal.common.core.context.ContextInitializable

getSelf

protected CouchbaseTargetSystem getSelf()

Specified by:

getSelf in class io.flamingock.internal.core.external.targets.AbstractTargetSystem<CouchbaseTargetSystem>

getTxWrapper

public io.flamingock.internal.core.transaction.TransactionWrapper getTxWrapper()

Specified by:

getTxWrapper in class io.flamingock.internal.core.external.targets.TransactionalTargetSystem<CouchbaseTargetSystem>

getAuditAuditReader

public java.util.Optional<io.flamingock.internal.common.core.audit.AuditHistoryReader> getAuditAuditReader(io.flamingock.internal.common.core.audit.AuditReaderType type)

Overrides:

getAuditAuditReader in class io.flamingock.internal.core.external.targets.TransactionalTargetSystem<CouchbaseTargetSystem>