com.continuent.tungsten.common.cluster.resource.physical
Class DataSource

java.lang.Object
  com.continuent.tungsten.common.cluster.resource.Resource
      com.continuent.tungsten.common.cluster.resource.physical.DataSource

All Implemented Interfaces:

java.io.Serializable

public class DataSource
extends Resource
implements java.io.Serializable

See Also:

Serialized Form

Field Summary

static java.lang.String	APPLIED_LATENCY
static java.lang.String	CLUSTER
static java.lang.String	DATASERVICE
static double	DEFAULT_APPLIED_LATENCY
static java.lang.String	DISKLOGDIR
static java.lang.String	DRIVER
static java.lang.String	HIGHWATER
static java.lang.String	HOST
static java.lang.String	ISAVAILABLE
static java.lang.String	LASTERROR
static java.lang.String	LASTSHUNREASON
static java.lang.String	LOGDIR
static java.lang.String	LOGPATTERN
static java.lang.String	NAME
static java.lang.String	PASSWORD
static java.lang.String	PORT
static java.lang.String	PRECEDENCE
static java.lang.String	REPLICATOR_HOST
static java.lang.String	ROLE
static java.lang.String	STATE
static java.lang.String	URL
static java.lang.String	USER
static java.lang.String	VENDOR

Fields inherited from class com.continuent.tungsten.common.cluster.resource.Resource

childType, compositeMember, description, isContainer, isExecutable, name, type

Constructor Summary

DataSource()

DataSource(java.util.Map<java.lang.String,java.lang.String> dsProperties)
Creates a new DataSource object

DataSource(java.lang.String key, java.lang.String clusterName, java.lang.String host)

DataSource(TungstenProperties props)

Method Summary

static DataSource	copy(DataSource ds)
static TungstenProperties	createFromReplicatorStatus(TungstenProperties replicatorProps)
void	decrementActiveConnections()
java.lang.String	describe(boolean detailed) Describe this instance, in detail if necessary.
void	disable() Prevent the driver from pDaterocessing new connection requests.
long	getActiveConnections() Returns the number of currently active connections.
double	getAppliedLatency() Format a datasource for display
long	getCallableStatementsCreated() Returns the number of JDBC CallableStatement instances created.
java.lang.String	getCluster() Returns the cluster value.
long	getConnectionsCreated() Returns the number of connections created on this datasource.
DataShardFacetRole	getDataSourceRole()
java.lang.String	getDiskLogDir() Returns the diskLogDir value.
java.lang.String	getDriver()
java.util.concurrent.atomic.AtomicInteger	getEnabled()
HighWaterResource	getHighWater()
java.lang.String	getHost() Returns the host value.
boolean	getIsAvailable()
java.lang.String	getLastError()
java.lang.String	getLastShunReason()
java.util.Date	getLastUpdate() Gives the last time this data source received an update
java.lang.String	getLogDir() Returns the logDir value.
java.lang.String	getLogPattern() Returns the logPattern value.
java.lang.String	getPassword() Returns the password value.
int	getPort() Returns the port value.
int	getPrecedence()
long	getPreparedStatementsCreated() Returns the number of JDBC PreparedStatement instances created.
java.lang.String	getReplicatorHost() Returns the replicatorHost value.
java.lang.String	getRole()
Sequence	getSequence() Returns the sequence value.
ResourceState	getState()
long	getStatementsCreated() Returns the number of JDBC Statement instances created.
java.lang.String	getUrl()
java.lang.String	getUser() Returns the user value.
java.lang.String	getVendor()
void	incrementActiveConnections()
void	incrementCallableStatementsCreated()
void	incrementConnectionsCreated()
void	incrementPreparedStatementsCreated()
void	incrementStatementsCreated()
boolean	isAvailable()
boolean	isMaster()
boolean	isSlave()
void	set(java.util.Map<java.lang.String,java.lang.String> dsProperties)
void	setAppliedLatency(double appliedLatency) Sets the last seen latency of this data source
void	setCluster(java.lang.String cluster) Sets the cluster value.
void	setDataSourceRole(DataShardFacetRole role)
void	setDiskLogDir(java.lang.String diskLogDir) Sets the diskLogDir value.
void	setDriver(java.lang.String driver)
void	setEnabled(java.util.concurrent.atomic.AtomicInteger enabled)
void	setFailed(java.lang.String error)
void	setHighWater(HighWaterResource highWater)
void	setHighWater(long epoch, java.lang.String eventId)
void	setHost(java.lang.String host) Sets the host value.
void	setIsAvailable(boolean isAvailable)
void	setLastError(java.lang.String lastError)
void	setLastShunReason(java.lang.String lastShunReason)
void	setLogDir(java.lang.String logDir) Sets the logDir value.
void	setLogPattern(java.lang.String logPattern) Sets the logPattern value.
void	setPassword(java.lang.String password) Sets the password value.
void	setPort(int port) Sets the port value.
void	setPrecedence(int precedence)
void	setReplicatorHost(java.lang.String replicatorHost) Sets the replicatorHost value.
void	setRole(java.lang.String role)
void	setSequence(Sequence sequence) Sets the sequence value.
void	setShunned(java.lang.String reason)
void	setState(ResourceState state)
void	setState(java.lang.String state)
void	setUrl(java.lang.String url)
void	setUser(java.lang.String user) Sets the user value.
void	setVendor(java.lang.String vendor)
java.util.Map<java.lang.String,java.lang.String>	toMap() TODO: toMap definition.
TungstenProperties	toProperties()
java.lang.String	toString() Format a datasource for display
void	update(DataSource ds) Update a given datasource with values from a different datasource
static TungstenProperties	updateFromReplicatorStatus(TungstenProperties replicatorProps, TungstenProperties dsProps)

Methods inherited from class com.continuent.tungsten.common.cluster.resource.Resource

copyTo, getChildType, getCompositeMember, getKey, getName, getType, isContainer, isExecutable, setChildType, setCompositeMember, setContainer, setExecutable, setName, setType, toJSON

Methods inherited from class java.lang.Object

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

Field Detail

APPLIED_LATENCY

public static final java.lang.String APPLIED_LATENCY

See Also:

Constant Field Values

CLUSTER

public static final java.lang.String CLUSTER

See Also:

Constant Field Values

DATASERVICE

public static final java.lang.String DATASERVICE

See Also:

Constant Field Values

DISKLOGDIR

public static final java.lang.String DISKLOGDIR

See Also:

Constant Field Values

DRIVER

public static final java.lang.String DRIVER

See Also:

Constant Field Values

HIGHWATER

public static final java.lang.String HIGHWATER

See Also:

Constant Field Values

HOST

public static final java.lang.String HOST

See Also:

Constant Field Values

ISAVAILABLE

public static final java.lang.String ISAVAILABLE

See Also:

Constant Field Values

LASTERROR

public static final java.lang.String LASTERROR

See Also:

Constant Field Values

LASTSHUNREASON

public static final java.lang.String LASTSHUNREASON

See Also:

Constant Field Values

LOGDIR

public static final java.lang.String LOGDIR

See Also:

Constant Field Values

LOGPATTERN

public static final java.lang.String LOGPATTERN

See Also:

Constant Field Values

NAME

public static final java.lang.String NAME

See Also:

Constant Field Values

PASSWORD

public static final java.lang.String PASSWORD

See Also:

Constant Field Values

PORT

public static final java.lang.String PORT

See Also:

Constant Field Values

PRECEDENCE

public static final java.lang.String PRECEDENCE

See Also:

Constant Field Values

REPLICATOR_HOST

public static final java.lang.String REPLICATOR_HOST

See Also:

Constant Field Values

ROLE

public static final java.lang.String ROLE

See Also:

Constant Field Values

STATE

public static final java.lang.String STATE

See Also:

Constant Field Values

URL

public static final java.lang.String URL

See Also:

Constant Field Values

USER

public static final java.lang.String USER

See Also:

Constant Field Values

VENDOR

public static final java.lang.String VENDOR

See Also:

Constant Field Values

DEFAULT_APPLIED_LATENCY

public static final double DEFAULT_APPLIED_LATENCY

See Also:

Constant Field Values

Constructor Detail

DataSource

public DataSource(TungstenProperties props)

DataSource

public DataSource()

DataSource

public DataSource(java.lang.String key,
                  java.lang.String clusterName,
                  java.lang.String host)

DataSource

public DataSource(java.util.Map<java.lang.String,java.lang.String> dsProperties)

Creates a new DataSource object

Parameters:

dsProperties -

Method Detail

updateFromReplicatorStatus

public static TungstenProperties updateFromReplicatorStatus(TungstenProperties replicatorProps,
                                                            TungstenProperties dsProps)

createFromReplicatorStatus

public static TungstenProperties createFromReplicatorStatus(TungstenProperties replicatorProps)

getDriver

public java.lang.String getDriver()

setDriver

public void setDriver(java.lang.String driver)

getUrl

public java.lang.String getUrl()

setUrl

public void setUrl(java.lang.String url)

getRole

public java.lang.String getRole()

getDataSourceRole

public DataShardFacetRole getDataSourceRole()

setRole

public void setRole(java.lang.String role)

setDataSourceRole

public void setDataSourceRole(DataShardFacetRole role)

getPrecedence

public int getPrecedence()

setPrecedence

public void setPrecedence(int precedence)

getVendor

public java.lang.String getVendor()

setVendor

public void setVendor(java.lang.String vendor)

isAvailable

public boolean isAvailable()

Returns:

the isAvailable

getIsAvailable

public boolean getIsAvailable()

Returns:

the isAvailable

setIsAvailable

public void setIsAvailable(boolean isAvailable)

Parameters:

isAvailable - the isDateAvailable to set

disable

public void disable()
             throws java.lang.InterruptedException

Prevent the driver from pDaterocessing new connection requests. If the driver is disabled, it will either cause new connection requests to wait or will throw a SQLException.

Throws:

java.lang.InterruptedException

update

public void update(DataSource ds)

Update a given datasource with values from a different datasource

Parameters:

ds -

toProperties

public TungstenProperties toProperties()

Overrides:

toProperties in class Resource

toMap

public java.util.Map<java.lang.String,java.lang.String> toMap()

TODO: toMap definition.

Returns:

properties representing this datasource

set

public void set(java.util.Map<java.lang.String,java.lang.String> dsProperties)

getSequence

public Sequence getSequence()

Returns the sequence value.

Returns:

Returns the sequence.

getActiveConnections

public long getActiveConnections()

Returns the number of currently active connections.

incrementActiveConnections

public void incrementActiveConnections()

decrementActiveConnections

public void decrementActiveConnections()

getConnectionsCreated

public long getConnectionsCreated()

Returns the number of connections created on this datasource.

incrementConnectionsCreated

public void incrementConnectionsCreated()

getStatementsCreated

public long getStatementsCreated()

Returns the number of JDBC Statement instances created.

incrementStatementsCreated

public void incrementStatementsCreated()

getPreparedStatementsCreated

public long getPreparedStatementsCreated()

Returns the number of JDBC PreparedStatement instances created.

incrementPreparedStatementsCreated

public void incrementPreparedStatementsCreated()

getCallableStatementsCreated

public long getCallableStatementsCreated()

Returns the number of JDBC CallableStatement instances created.

incrementCallableStatementsCreated

public void incrementCallableStatementsCreated()

getCluster

public java.lang.String getCluster()

Returns the cluster value.

Returns:

Returns the cluster.

setCluster

public void setCluster(java.lang.String cluster)

Sets the cluster value.

Parameters:

cluster - The cluster to set.

getAppliedLatency

public double getAppliedLatency()

Format a datasource for display

setAppliedLatency

public void setAppliedLatency(double appliedLatency)

Sets the last seen latency of this data source

Parameters:

appliedLatency - update appliedLatency observed

toString

public java.lang.String toString()

Format a datasource for display

Overrides:

toString in class Resource

getLastUpdate

public java.util.Date getLastUpdate()

Gives the last time this data source received an update

Returns:

the last update time

setSequence

public void setSequence(Sequence sequence)

Sets the sequence value.

Parameters:

sequence - The sequence to set.

getHost

public java.lang.String getHost()

Returns the host value.

Returns:

Returns the host.

setHost

public void setHost(java.lang.String host)

Sets the host value.

Parameters:

host - The host to set.

getHighWater

public HighWaterResource getHighWater()

setHighWater

public void setHighWater(HighWaterResource highWater)

setHighWater

public void setHighWater(long epoch,
                         java.lang.String eventId)

getEnabled

public java.util.concurrent.atomic.AtomicInteger getEnabled()

setEnabled

public void setEnabled(java.util.concurrent.atomic.AtomicInteger enabled)

isMaster

public boolean isMaster()

isSlave

public boolean isSlave()

getState

public ResourceState getState()

setState

public void setState(ResourceState state)

setState

public void setState(java.lang.String state)

setFailed

public void setFailed(java.lang.String error)

setShunned

public void setShunned(java.lang.String reason)

getLastError

public java.lang.String getLastError()

setLastError

public void setLastError(java.lang.String lastError)

getLastShunReason

public java.lang.String getLastShunReason()

setLastShunReason

public void setLastShunReason(java.lang.String lastShunReason)

copy

public static DataSource copy(DataSource ds)

getUser

public java.lang.String getUser()

Returns the user value.

Returns:

Returns the user.

setUser

public void setUser(java.lang.String user)

Sets the user value.

Parameters:

user - The user to set.

getPassword

public java.lang.String getPassword()

Returns the password value.

Returns:

Returns the password.

setPassword

public void setPassword(java.lang.String password)

Sets the password value.

Parameters:

password - The password to set.

describe

public java.lang.String describe(boolean detailed)

Description copied from class: Resource

Describe this instance, in detail if necessary.

Overrides:

describe in class Resource

Returns:

string description of this resource

getLogPattern

public java.lang.String getLogPattern()

Returns the logPattern value.

Returns:

Returns the logPattern.

setLogPattern

public void setLogPattern(java.lang.String logPattern)

Sets the logPattern value.

Parameters:

logPattern - The logPattern to set.

getLogDir

public java.lang.String getLogDir()

Returns the logDir value.

Returns:

Returns the logDir.

setLogDir

public void setLogDir(java.lang.String logDir)

Sets the logDir value.

Parameters:

logDir - The logDir to set.

getPort

public int getPort()

Returns the port value.

Returns:

Returns the port.

setPort

public void setPort(int port)

Sets the port value.

Parameters:

port - The port to set.

getDiskLogDir

public java.lang.String getDiskLogDir()

Returns the diskLogDir value.

Returns:

Returns the diskLogDir.

setDiskLogDir

public void setDiskLogDir(java.lang.String diskLogDir)

Sets the diskLogDir value.

Parameters:

diskLogDir - The diskLogDir to set.

getReplicatorHost

public java.lang.String getReplicatorHost()

Returns the replicatorHost value.

Returns:

Returns the replicatorHost.

setReplicatorHost

public void setReplicatorHost(java.lang.String replicatorHost)

Sets the replicatorHost value.

Parameters:

replicatorHost - The replicatorHost to set.