Package cz.o2.proxima.direct.transaction.manager

Class TransactionLogObserver

java.lang.Object

cz.o2.proxima.direct.transaction.manager.TransactionLogObserver

All Implemented Interfaces:

CommitLogObserver, LogObserver<Offset,CommitLogObserver.OnNextContext>

@Internal
@ThreadSafe
@DeclaredThreadSafe
public class TransactionLogObserver
extends java.lang.Object
implements CommitLogObserver

A CommitLogObserver performing the overall transaction logic via keeping state of transactions and responding to requests.

Nested Class Summary

Nested classes/interfaces inherited from interface cz.o2.proxima.direct.core.commitlog.CommitLogObserver

CommitLogObserver.OffsetCommitter, CommitLogObserver.OnIdleContext, CommitLogObserver.OnNextContext, CommitLogObserver.OnRepartitionContext

Constructor Summary

Constructors

Constructor	Description
TransactionLogObserver(DirectDataOperator direct, Metrics metrics)

Method Summary

Modifier and Type	Method	Description
protected void	assertSingleton()
ServerTransactionManager	getRawManager()
boolean	onError(java.lang.Throwable error)	Called to notify there was an error in the commit reader.
void	onIdle(CommitLogObserver.OnIdleContext context)	Called when the observer is idle.
boolean	onNext(StreamElement element, CommitLogObserver.OnNextContext context)	Process next record in the commit log.
void	run(java.lang.String name)

Methods inherited from class java.lang.Object

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

Methods inherited from interface cz.o2.proxima.direct.core.commitlog.CommitLogObserver

onRepartition

Methods inherited from interface cz.o2.proxima.direct.core.LogObserver

onCancelled, onCompleted, onException, onFatalError

Constructor Detail

TransactionLogObserver

public TransactionLogObserver(DirectDataOperator direct,
                              Metrics metrics)

Method Detail

assertSingleton

protected void assertSingleton()

onNext

public boolean onNext(StreamElement element,
                      CommitLogObserver.OnNextContext context)

Description copied from interface: LogObserver

Process next record in the commit log.

Specified by:

onNext in interface LogObserver<Offset,CommitLogObserver.OnNextContext>

Parameters:

element - the element written to the commit log

context - a context that the application must use to confirm processing of the element. If the application fails to do so, the result is undefined.

Returns:

true if the processing should continue, false otherwise

onIdle

public void onIdle(CommitLogObserver.OnIdleContext context)

Description copied from interface: CommitLogObserver

Called when the observer is idle. Note that the definition of idle is commit-log dependent and it even might NOT be called at all, if the commit log guarantees that as long as there are *any* data flowing in, then LogObserver.onNext(cz.o2.proxima.core.storage.StreamElement, ContextT) will be called eventually.

Typical example of commit log with no need to call CommitLogObserver.onIdle(cz.o2.proxima.direct.core.commitlog.CommitLogObserver.OnIdleContext) is google PubSub, having virtually single shared partition which loads balances incoming data.

Specified by:

onIdle in interface CommitLogObserver

Parameters:

context - the context for on idle processing

onError

public boolean onError(java.lang.Throwable error)

Description copied from interface: LogObserver

Called to notify there was an error in the commit reader.

Specified by:

onError in interface LogObserver<Offset,CommitLogObserver.OnNextContext>

Parameters:

error - error caught during processing

Returns:

true to restart processing from last committed position, false to stop processing

run

public void run(java.lang.String name)

getRawManager

public ServerTransactionManager getRawManager()