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

java.lang.Object
  com.continuent.tungsten.common.cluster.resource.physical.Replicator

public class Replicator
extends java.lang.Object

Defines a replicator resource. Among other things this class contains the definitive reference to names that replicators must use for monitoring properties.

Field Summary

static java.lang.String	APPLIED_LAST_EVENT_ID Last native transaction ID applied to slave database.
static java.lang.String	APPLIED_LAST_SEQNO Last LSN (log sequence number) applied to slave database.
static java.lang.String	APPLIED_LATENCY Lag in seconds between the time last event was applied and when it was originally generated.
static java.lang.String	CHANNELS Denotes the number of channels for parallel apply.
static java.lang.String	CLUSTERNAME Name of the cluster to which this replicator belongs.
static java.lang.String	CURRENT_EVENT_ID Current native transaction ID in the database.
static java.lang.String	CURRENT_TIME_MILLIS Current time on replicator expressed as milliseconds since Jan 1, 1970.
static java.lang.String	DATASERVER_HOST
static java.lang.String	DEFAULT_LAST_EVENT_ID
static long	DEFAULT_LATEST_EPOCH_NUMBER
static java.lang.String	EXTENSIONS Contains the names of enabled extensions (e.g., sharding) on this replicator.
static java.lang.String	HOST Host name of this replicator.
static java.lang.String	LATEST_EPOCH_NUMBER Current epoch number used by replicator, if it has one.
static java.lang.String	MASTER_CONNECT_URI URI to which slave replicator connects.
static java.lang.String	MASTER_LISTEN_URI URI that slaves should use when connecting to this master.
static java.lang.String	MAX_PORT Value of last port used by the replicator.
static java.lang.String	MAX_STORED_SEQNO Highest LSN stored in the replicator log.
static java.lang.String	MIN_STORED_SEQNO Lowest LSN stored in the replicator log.
static java.lang.String	OFFLINE_REQUESTS Pending offline requests in text form.
static java.lang.String	PASSWORD Replication database user's password for this replicator.
static java.lang.String	PENDING_ERROR Current error, if there is one.
static java.lang.String	PENDING_ERROR_CODE Current error code, if there is one.
static java.lang.String	PENDING_ERROR_EVENTID Current failed event ID or null if there is none.
static java.lang.String	PENDING_ERROR_SEQNO Current failed log sequence number or -1 if there is none.
static java.lang.String	PENDING_EXCEPTION_MESSAGE Current exception that caused error, if there is one.
static java.lang.String	PIPELINE_SOURCE Denotes the source of the head extractor.
static java.lang.String	RELATIVE_LATENCY Lag in seconds between the timestamp of the last committed transaction and the current time.
static java.lang.String	RESOURCE_DATASERVER_HOST Class name of Java data source.
static java.lang.String	RESOURCE_DISK_LOGDIR Directory where transaction logs are to be found
static java.lang.String	RESOURCE_JDBC_DRIVER Class name of Java data source.
static java.lang.String	RESOURCE_JDBC_URL URL to connect to underlying data source replicator serves.
static java.lang.String	RESOURCE_LOGDIR Directory where transaction logs are to be found
static java.lang.String	RESOURCE_LOGPATTERN Pattern used to identify logs
static java.lang.String	RESOURCE_PORT Port on which apps access resource
static java.lang.String	RESOURCE_PRECEDENCE Resource precedence for failover, which should be an integer > 0 or -1 to indicate do not fail over to this resource.
static java.lang.String	RESOURCE_VENDOR DBMS vendor string for this data source
static java.lang.String	RMI_PORT
static java.lang.String	ROLE Role of this replicator.
static java.lang.String	SEQNO_TYPE Log sequence number type to allow managers to figure out how to sort values.
static java.lang.String	SEQNO_TYPE_LONG Denotes a numeric log sequence number type that is convertible to a Java Long type.
static java.lang.String	SEQNO_TYPE_STRING Denotes a string log sequence number type whose values are comparable strings.
static java.lang.String	SERVICE_NAME Replication service name.
static java.lang.String	SERVICE_TYPE Replication service type, which can be local or remote.
static java.lang.String	SIMPLE_SERVICE_NAME Replication simple service name.
static java.lang.String	SITENAME Name of the site to which this replicator belongs.
static java.lang.String	SOURCEID Source ID used to mark events for this replicator.
static java.lang.String	SSL_LOG_CONNECTION Denotes the source of the head extractor.
static java.lang.String	STATE Current replicator state.
static java.lang.String	TIME_IN_STATE_SECONDS Seconds that replicator has been in its current state.
static java.lang.String	TRANSITIONING_TO Pending replicator state following current state transition.
static java.lang.String	UPTIME_SECONDS Seconds since replicator has started.
static java.lang.String	USE_SSL_CONNECTION Indicates if SSL connection is used.
static java.lang.String	USER Replication database user this replicator.
static java.lang.String	VERSION Denotes the replicator version.

Constructor Summary

Replicator()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

SERVICE_NAME

public static final java.lang.String SERVICE_NAME

Replication service name. In full clustering this should correspond with a Tungsten service.

See Also:

Constant Field Values

SIMPLE_SERVICE_NAME

public static final java.lang.String SIMPLE_SERVICE_NAME

Replication simple service name. Service names are usually mangled names and sometimes we just want the de-mangled name.

See Also:

Constant Field Values

SERVICE_TYPE

public static final java.lang.String SERVICE_TYPE

Replication service type, which can be local or remote.

See Also:

Constant Field Values

APPLIED_LAST_SEQNO

public static final java.lang.String APPLIED_LAST_SEQNO

Last LSN (log sequence number) applied to slave database. On a master this is the same as the last position read from the log.

See Also:

Constant Field Values

APPLIED_LAST_EVENT_ID

public static final java.lang.String APPLIED_LAST_EVENT_ID

Last native transaction ID applied to slave database. On a master this is the same as the last native transaction ID read from the log.

See Also:

Constant Field Values

APPLIED_LATENCY

public static final java.lang.String APPLIED_LATENCY

Lag in seconds between the time last event was applied and when it was originally generated.

See Also:

Constant Field Values

RELATIVE_LATENCY

public static final java.lang.String RELATIVE_LATENCY

Lag in seconds between the timestamp of the last committed transaction and the current time.

See Also:

Constant Field Values

LATEST_EPOCH_NUMBER

public static final java.lang.String LATEST_EPOCH_NUMBER

Current epoch number used by replicator, if it has one.

See Also:

Constant Field Values

MIN_STORED_SEQNO

public static final java.lang.String MIN_STORED_SEQNO

Lowest LSN stored in the replicator log. Value is null if there is no log.

See Also:

Constant Field Values

MAX_STORED_SEQNO

public static final java.lang.String MAX_STORED_SEQNO

Highest LSN stored in the replicator log. Value is null if there is no log. This value is used for selecting slaves for failover.

See Also:

Constant Field Values

CURRENT_EVENT_ID

public static final java.lang.String CURRENT_EVENT_ID

Current native transaction ID in the database. On a slave this value may be null.

See Also:

Constant Field Values

MASTER_CONNECT_URI

public static final java.lang.String MASTER_CONNECT_URI

URI to which slave replicator connects. Undefined for master.

See Also:

Constant Field Values

MASTER_LISTEN_URI

public static final java.lang.String MASTER_LISTEN_URI

URI that slaves should use when connecting to this master.

See Also:

Constant Field Values

USE_SSL_CONNECTION

public static final java.lang.String USE_SSL_CONNECTION

Indicates if SSL connection is used.

See Also:

Constant Field Values

SITENAME

public static final java.lang.String SITENAME

Name of the site to which this replicator belongs.

See Also:

Constant Field Values

CLUSTERNAME

public static final java.lang.String CLUSTERNAME

Name of the cluster to which this replicator belongs.

See Also:

Constant Field Values

ROLE

public static final java.lang.String ROLE

Role of this replicator. By convention roles are either 'master' or 'slave'.

See Also:

Constant Field Values

HOST

public static final java.lang.String HOST

Host name of this replicator.

See Also:

Constant Field Values

DATASERVER_HOST

public static final java.lang.String DATASERVER_HOST

See Also:

Constant Field Values

UPTIME_SECONDS

public static final java.lang.String UPTIME_SECONDS

Seconds since replicator has started.

See Also:

Constant Field Values

TIME_IN_STATE_SECONDS

public static final java.lang.String TIME_IN_STATE_SECONDS

Seconds that replicator has been in its current state.

See Also:

Constant Field Values

CURRENT_TIME_MILLIS

public static final java.lang.String CURRENT_TIME_MILLIS

Current time on replicator expressed as milliseconds since Jan 1, 1970.

See Also:

Constant Field Values

STATE

public static final java.lang.String STATE

Current replicator state.

See Also:

Constant Field Values

TRANSITIONING_TO

public static final java.lang.String TRANSITIONING_TO

Pending replicator state following current state transition.

See Also:

Constant Field Values

SOURCEID

public static final java.lang.String SOURCEID

Source ID used to mark events for this replicator.

See Also:

Constant Field Values

USER

public static final java.lang.String USER

Replication database user this replicator.

See Also:

Constant Field Values

PASSWORD

public static final java.lang.String PASSWORD

Replication database user's password for this replicator.

See Also:

Constant Field Values

MAX_PORT

public static final java.lang.String MAX_PORT

Value of last port used by the replicator.

See Also:

Constant Field Values

PENDING_EXCEPTION_MESSAGE

public static final java.lang.String PENDING_EXCEPTION_MESSAGE

Current exception that caused error, if there is one.

See Also:

Constant Field Values

PENDING_ERROR_CODE

public static final java.lang.String PENDING_ERROR_CODE

Current error code, if there is one.

See Also:

Constant Field Values

PENDING_ERROR

public static final java.lang.String PENDING_ERROR

Current error, if there is one.

See Also:

Constant Field Values

PENDING_ERROR_SEQNO

public static final java.lang.String PENDING_ERROR_SEQNO

Current failed log sequence number or -1 if there is none.

See Also:

Constant Field Values

PENDING_ERROR_EVENTID

public static final java.lang.String PENDING_ERROR_EVENTID

Current failed event ID or null if there is none.

See Also:

Constant Field Values

OFFLINE_REQUESTS

public static final java.lang.String OFFLINE_REQUESTS

Pending offline requests in text form.

See Also:

Constant Field Values

RMI_PORT

public static final java.lang.String RMI_PORT

See Also:

Constant Field Values

RESOURCE_JDBC_URL

public static final java.lang.String RESOURCE_JDBC_URL

URL to connect to underlying data source replicator serves.

See Also:

Constant Field Values

RESOURCE_JDBC_DRIVER

public static final java.lang.String RESOURCE_JDBC_DRIVER

Class name of Java data source.

See Also:

Constant Field Values

RESOURCE_DATASERVER_HOST

public static final java.lang.String RESOURCE_DATASERVER_HOST

Class name of Java data source.

See Also:

Constant Field Values

RESOURCE_PRECEDENCE

public static final java.lang.String RESOURCE_PRECEDENCE

Resource precedence for failover, which should be an integer > 0 or -1 to indicate do not fail over to this resource.

See Also:

Constant Field Values

RESOURCE_VENDOR

public static final java.lang.String RESOURCE_VENDOR

DBMS vendor string for this data source

See Also:

Constant Field Values

RESOURCE_LOGDIR

public static final java.lang.String RESOURCE_LOGDIR

Directory where transaction logs are to be found

See Also:

Constant Field Values

RESOURCE_DISK_LOGDIR

public static final java.lang.String RESOURCE_DISK_LOGDIR

Directory where transaction logs are to be found

See Also:

Constant Field Values

RESOURCE_LOGPATTERN

public static final java.lang.String RESOURCE_LOGPATTERN

Pattern used to identify logs

See Also:

Constant Field Values

RESOURCE_PORT

public static final java.lang.String RESOURCE_PORT

Port on which apps access resource

See Also:

Constant Field Values

SEQNO_TYPE

public static final java.lang.String SEQNO_TYPE

Log sequence number type to allow managers to figure out how to sort values.

See Also:

Constant Field Values

SEQNO_TYPE_LONG

public static final java.lang.String SEQNO_TYPE_LONG

Denotes a numeric log sequence number type that is convertible to a Java Long type.

See Also:

Constant Field Values

SEQNO_TYPE_STRING

public static final java.lang.String SEQNO_TYPE_STRING

Denotes a string log sequence number type whose values are comparable strings.

See Also:

Constant Field Values

EXTENSIONS

public static final java.lang.String EXTENSIONS

Contains the names of enabled extensions (e.g., sharding) on this replicator.

See Also:

Constant Field Values

PIPELINE_SOURCE

public static final java.lang.String PIPELINE_SOURCE

Denotes the source of the head extractor.

See Also:

Constant Field Values

SSL_LOG_CONNECTION

public static final java.lang.String SSL_LOG_CONNECTION

Denotes the source of the head extractor.

See Also:

Constant Field Values

CHANNELS

public static final java.lang.String CHANNELS

Denotes the number of channels for parallel apply.

See Also:

Constant Field Values

VERSION

public static final java.lang.String VERSION

Denotes the replicator version.

See Also:

Constant Field Values

DEFAULT_LATEST_EPOCH_NUMBER

public static final long DEFAULT_LATEST_EPOCH_NUMBER

See Also:

Constant Field Values

DEFAULT_LAST_EVENT_ID

public static final java.lang.String DEFAULT_LAST_EVENT_ID

See Also:

Constant Field Values

Constructor Detail

Replicator

public Replicator()