io.stargate.db.datastore.common

Class AbstractCassandraPersistence.AbstractConnection

java.lang.Object

io.stargate.db.datastore.common.AbstractCassandraPersistence.AbstractConnection

All Implemented Interfaces:

Persistence.Connection, SchemaAgreementChecker

Enclosing class:

AbstractCassandraPersistence<Config,K,T,C,U,I,V>

protected abstract static class AbstractCassandraPersistence.AbstractConnection
extends Object
implements Persistence.Connection

Field Summary

Fields inherited from interface io.stargate.db.SchemaAgreementChecker

SCHEMA_AGREEMENT_WAIT_RETRIES

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractConnection(ClientInfo clientInfo)

Method Summary

Modifier and Type	Method and Description
Optional<ClientInfo>	clientInfo()
Optional<AuthenticatedUser>	loggedUser()
void	login(AuthenticatedUser user)
protected abstract void	loginInternally(AuthenticatedUser user)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.stargate.db.Persistence.Connection

batch, execute, getPrepared, isInSchemaAgreement, makePagingState, makeRowDecorator, persistence, prepare, setCustomProperties, usedKeyspace

Methods inherited from interface io.stargate.db.SchemaAgreementChecker

waitForSchemaAgreement

Constructor Detail

AbstractConnection

protected AbstractConnection(@Nullable
                             ClientInfo clientInfo)

Method Detail

clientInfo

public Optional<ClientInfo> clientInfo()

Specified by:

clientInfo in interface Persistence.Connection

loginInternally

protected abstract void loginInternally(AuthenticatedUser user)

login

public void login(AuthenticatedUser user)

Specified by:

login in interface Persistence.Connection

loggedUser

public Optional<AuthenticatedUser> loggedUser()

Specified by:

loggedUser in interface Persistence.Connection

toString

public String toString()

Overrides:

toString in class Object