|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| com.continuent.* |
|---|
| com.continuent.tungsten.common.cluster.resource.DatabaseVendors | ||
|---|---|---|
public static final java.lang.String |
MYSQL |
"mysql" |
public static final java.lang.String |
ORACLE |
"oracle" |
public static final java.lang.String |
POSTGRES |
"postgres" |
| com.continuent.tungsten.common.cluster.resource.DataServer | ||
|---|---|---|
public static final java.lang.String |
HOST |
"host" |
| com.continuent.tungsten.common.cluster.resource.DataSource | ||
|---|---|---|
public static final java.lang.String |
ACTIVE_CONNECTION_COUNT |
"activeConnectionCount" |
public static final java.lang.String |
ALERT_MESSAGE |
"alertMessage" |
public static final java.lang.String |
ALERT_STATUS |
"alertStatus" |
public static final java.lang.String |
ALERT_TIME |
"alertTime" |
public static final java.lang.String |
APPLIED_LATENCY |
"appliedLatency" |
public static final java.lang.String |
CLUSTERNAME |
"dataServiceName" |
public static final java.lang.String |
CONNECTIONS_CREATED_COUNT |
"connectionsCreatedCount" |
public static final double |
DEFAULT_APPLIED_LATENCY |
0.0 |
public static final java.lang.String |
DRIVER |
"driver" |
public static final java.lang.String |
HIGHWATER |
"highWater" |
public static final java.lang.String |
HOST |
"host" |
public static final java.lang.String |
ISAVAILABLE |
"isAvailable" |
public static final java.lang.String |
ISCOMPOSITE |
"isComposite" |
public static final java.lang.String |
ISWITNESS |
"isWitness" |
public static final java.lang.String |
JDBC_URL_START |
"jdbc:" |
public static final java.lang.String |
LASTERROR |
"lastError" |
public static final java.lang.String |
LASTSHUNREASON |
"lastShunReason" |
public static final java.lang.String |
MASTER_CONNECT_URI |
"masterConnectUri" |
public static final java.lang.String |
NAME |
"name" |
public static final java.lang.String |
PRECEDENCE |
"precedence" |
public static final java.lang.String |
ROLE |
"role" |
public static final java.lang.String |
STATE |
"state" |
public static final java.lang.String |
TYPE |
"type" |
public static final java.lang.String |
URL |
"url" |
public static final java.lang.String |
VENDOR |
"vendor" |
public static final java.lang.String |
VIPADDRESS |
"vipAddress" |
public static final java.lang.String |
VIPINTERFACE |
"vipInterface" |
public static final java.lang.String |
VIPISBOUND |
"vipIsBound" |
| com.continuent.tungsten.common.cluster.resource.Monitor | ||
|---|---|---|
public static final java.lang.String |
MEMBERNAME |
"memberName" |
| com.continuent.tungsten.common.cluster.resource.OpenReplicatorParams | ||
|---|---|---|
public static final java.lang.String |
BASE_SEQNO |
"baseSeqno" |
public static final java.lang.String |
DO_CHECKSUM |
"do_checksum" |
public static final java.lang.String |
FORCE |
"force" |
public static final java.lang.String |
HEARTBEAT_NAME |
"heartbeatName" |
public static final java.lang.String |
INIT_EVENT_ID |
"extractFromId" |
public static final java.lang.String |
OFFLINE_AT_EVENT_ID |
"atEventId" |
public static final java.lang.String |
OFFLINE_AT_HEARTBEAT |
"atHeartbeat" |
public static final java.lang.String |
OFFLINE_AT_SEQNO |
"atSeqno" |
public static final java.lang.String |
OFFLINE_AT_TIMESTAMP |
"atTimestamp" |
public static final java.lang.String |
OFFLINE_TRANSACTIONAL |
"atTransaction" |
public static final java.lang.String |
ONLINE_TO_EVENT_ID |
"toEventId" |
public static final java.lang.String |
ONLINE_TO_HEARTBEAT |
"toHeartbeat" |
public static final java.lang.String |
ONLINE_TO_SEQNO |
"toSeqno" |
public static final java.lang.String |
ONLINE_TO_TIMESTAMP |
"toTimestamp" |
public static final java.lang.String |
SKIP_APPLY_EVENTS |
"skipApplyEvents" |
public static final java.lang.String |
SKIP_APPLY_SEQNOS |
"skipApplySeqnos" |
public static final java.lang.String |
TIMEOUT |
"timeout" |
| com.continuent.tungsten.common.cluster.resource.Replicator | ||
|---|---|---|
public static final java.lang.String |
APPLIED_LAST_EVENT_ID |
"appliedLastEventId" |
public static final java.lang.String |
APPLIED_LAST_SEQNO |
"appliedLastSeqno" |
public static final java.lang.String |
APPLIED_LATENCY |
"appliedLatency" |
public static final java.lang.String |
CLUSTERNAME |
"clusterName" |
public static final java.lang.String |
CURRENT_EVENT_ID |
"currentEventId" |
public static final java.lang.String |
CURRENT_TIME_MILLIS |
"currentTimeMillis" |
public static final java.lang.String |
DATASERVERHOST |
"dataServerHost" |
public static final java.lang.String |
DEFAULT_LAST_EVENT_ID |
"0:0" |
public static final long |
DEFAULT_LATEST_EPOCH_NUMBER |
-1L |
public static final java.lang.String |
LATEST_EPOCH_NUMBER |
"latestEpochNumber" |
public static final java.lang.String |
MASTER_CONNECT_URI |
"masterConnectUri" |
public static final java.lang.String |
MASTER_LISTEN_URI |
"masterListenUri" |
public static final java.lang.String |
MASTER_URI |
"masterUri" |
public static final java.lang.String |
MAX_STORED_SEQNO |
"maximumStoredSeqNo" |
public static final java.lang.String |
MIN_STORED_SEQNO |
"minimumStoredSeqNo" |
public static final java.lang.String |
OFFLINE_REQUESTS |
"offlineRequests" |
public static final java.lang.String |
PENDING_ERROR |
"pendingError" |
public static final java.lang.String |
PENDING_ERROR_CODE |
"pendingErrorCode" |
public static final java.lang.String |
PENDING_ERROR_EVENTID |
"pendingErrorEventId" |
public static final java.lang.String |
PENDING_ERROR_SEQNO |
"pendingErrorSeqno" |
public static final java.lang.String |
PENDING_EXCEPTION_MESSAGE |
"pendingExceptionMessage" |
public static final java.lang.String |
RESOURCE_IS_STANDBY_DATASOURCE |
"isStandbyDataSource" |
public static final java.lang.String |
RESOURCE_JDBC_DRIVER |
"resourceJdbcDriver" |
public static final java.lang.String |
RESOURCE_JDBC_URL |
"resourceJdbcUrl" |
public static final java.lang.String |
RESOURCE_PRECEDENCE |
"resourcePrecedence" |
public static final java.lang.String |
RESOURCE_VENDOR |
"resourceVendor" |
public static final java.lang.String |
RESOURCE_VIP_ADDRESS |
"vipAddress" |
public static final java.lang.String |
RESOURCE_VIP_INTERFACE |
"vipInterface" |
public static final java.lang.String |
ROLE |
"role" |
public static final java.lang.String |
SEQNO_TYPE |
"seqnoType" |
public static final java.lang.String |
SEQNO_TYPE_LONG |
"java.lang.Long" |
public static final java.lang.String |
SEQNO_TYPE_STRING |
"java.lang.String" |
public static final java.lang.String |
SOURCEID |
"sourceId" |
public static final java.lang.String |
STATE |
"state" |
public static final java.lang.String |
TIME_IN_STATE_SECONDS |
"timeInStateSeconds" |
public static final java.lang.String |
UPTIME_SECONDS |
"uptimeSeconds" |
public static final java.lang.String |
USE_SSL_CONNECTION |
"useSSLConnection" |
| com.continuent.tungsten.common.cluster.resource.ReplicatorCapabilities | ||
|---|---|---|
public static final java.lang.String |
MODEL |
"model" |
public static final java.lang.String |
MODEL_PEER |
"peer" |
public static final java.lang.String |
MODEL_PULL |
"pull" |
public static final java.lang.String |
MODEL_PUSH |
"push" |
public static final java.lang.String |
PROVISION_DONOR |
"donor" |
public static final java.lang.String |
PROVISION_JOINER |
"joiner" |
public static final java.lang.String |
ROLE_MASTER |
"master" |
public static final java.lang.String |
ROLE_RELAY |
"relay" |
public static final java.lang.String |
ROLE_SLAVE |
"slave" |
public static final java.lang.String |
ROLES |
"roles" |
public static final java.lang.String |
UNKNOWN |
"unknown" |
| com.continuent.tungsten.common.cluster.resource.RouterURL | ||
|---|---|---|
public static final java.lang.String |
DBNAME_TOKEN |
"${DBNAME}" |
public static final java.lang.String |
KEY_AFFINITY |
"affinity" |
public static final java.lang.String |
KEY_MAX_APPLIED_LATENCY |
"maxAppliedLatency" |
public static final java.lang.String |
KEY_PASSWORD |
"password" |
public static final java.lang.String |
KEY_QOS |
"qos" |
public static final java.lang.String |
KEY_SESSION_ID |
"sessionId" |
public static final java.lang.String |
KEY_USER |
"user" |
public static final java.lang.String |
SESSIONID_CONNECTION |
"CONNECTION" |
public static final java.lang.String |
SESSIONID_DATABASE |
"DATABASE" |
public static final java.lang.String |
SESSIONID_PROVIDED_IN_DBNAME |
"PROVIDED_IN_DBNAME" |
public static final java.lang.String |
SESSIONID_USER |
"USER" |
public static final java.lang.String |
URL_FULL_HEADER |
"jdbc:t-router://" |
| com.continuent.tungsten.common.cluster.resource.notification.ClusterResourceNotification | ||
|---|---|---|
public static final java.lang.String |
CLUSTER_NAME |
"clusterName" |
public static final java.lang.String |
MEMBER_NAME |
"memberName" |
public static final java.lang.String |
NOTIFICATION_SOURCE |
"notificationSource" |
public static final java.lang.String |
RESOURCE_NAME |
"resourceName" |
public static final java.lang.String |
RESOURCE_PROPS |
"resourceProps" |
public static final java.lang.String |
RESOURCE_STATE |
"resourceState" |
public static final java.lang.String |
RESOURCE_TYPE |
"resourceType" |
| com.continuent.tungsten.common.cluster.resource.notification.DataServerStatus | ||
|---|---|---|
public static final java.lang.String |
PROPERTY_KEY_DRIVER |
"driver" |
public static final java.lang.String |
PROPERTY_KEY_HOST |
"host" |
public static final java.lang.String |
PROPERTY_KEY_PRECEDENCE |
"precedence" |
public static final java.lang.String |
PROPERTY_KEY_ROLE |
"role" |
public static final java.lang.String |
PROPERTY_KEY_SERVICE |
"dataServiceName" |
public static final java.lang.String |
PROPERTY_KEY_URL |
"url" |
public static final java.lang.String |
PROPERTY_KEY_VENDOR |
"vendor" |
| com.continuent.tungsten.common.cluster.resource.notification.DataSourceStatus | ||
|---|---|---|
public static final java.lang.String |
PROPERTY_KEY_DRIVER |
"driver" |
public static final java.lang.String |
PROPERTY_KEY_HOST |
"host" |
public static final java.lang.String |
PROPERTY_KEY_PRECEDENCE |
"precedence" |
public static final java.lang.String |
PROPERTY_KEY_ROLE |
"role" |
public static final java.lang.String |
PROPERTY_KEY_SERVICE |
"dataServiceName" |
public static final java.lang.String |
PROPERTY_KEY_URL |
"url" |
public static final java.lang.String |
PROPERTY_KEY_VENDOR |
"vendor" |
| com.continuent.tungsten.common.cluster.resource.notification.HostStatus | ||
|---|---|---|
public static final java.lang.String |
PROPERTY_KEY_CLUSTER |
"dataServiceName" |
public static final java.lang.String |
PROPERTY_KEY_CPUCOUNT |
"cpuCount" |
public static final java.lang.String |
PROPERTY_KEY_HOST |
"host" |
public static final java.lang.String |
PROPERTY_KEY_UPTIME |
"uptime" |
public static final java.lang.String |
PROPERTY_LOAD_AVG_1 |
"loadAverage1" |
public static final java.lang.String |
PROPERTY_LOAD_AVG_15 |
"loadAverage5" |
public static final java.lang.String |
PROPERTY_LOAD_AVG_5 |
"loadAverage5" |
| com.continuent.tungsten.common.cluster.resource.notification.NotificationPropertyKey | ||
|---|---|---|
public static final java.lang.String |
KEY_NOTIFICATION_CLUSTER_MEMBER |
"notificationClusterMemberName" |
public static final java.lang.String |
KEY_NOTIFICATION_CLUSTER_NAME |
"notificationClusterName" |
public static final java.lang.String |
KEY_NOTIFICATION_SOURCE |
"notificationSource" |
public static final java.lang.String |
KEY_NOTIFICATION_TYPE |
"notificationType" |
public static final java.lang.String |
KEY_RESOURCE_NAME |
"resourceName" |
public static final java.lang.String |
KEY_RESOURCE_PROPERTIES |
"resourceProperties" |
public static final java.lang.String |
KEY_RESOURCE_STATE |
"resourceState" |
public static final java.lang.String |
KEY_RESOURCE_TYPE |
"resourceType" |
| com.continuent.tungsten.common.cluster.resource.notification.ResourceStatus.States | ||
|---|---|---|
public static final java.lang.String |
NOTRUNNING |
"STOPPED" |
public static final java.lang.String |
OFFLINE |
"OFFLINE" |
public static final java.lang.String |
ONLINE |
"ONLINE" |
public static final java.lang.String |
UNKNOWN |
"UNKNOWN" |
| com.continuent.tungsten.common.cluster.resource.notification.ResourceStatus.Types | ||
|---|---|---|
public static final java.lang.String |
DATASERVER |
"DATASERVER" |
public static final java.lang.String |
DATASOURCE |
"DATASOURCE" |
public static final java.lang.String |
HOST |
"HOST" |
public static final java.lang.String |
REPLICATOR |
"REPLICATOR" |
public static final java.lang.String |
UNKNOWN |
"UNKNOWN" |
| com.continuent.tungsten.common.cluster.resource.physical.DataSource | ||
|---|---|---|
public static final java.lang.String |
APPLIED_LATENCY |
"appliedLatency" |
public static final java.lang.String |
CLUSTER |
"cluster" |
public static final java.lang.String |
DATASERVICE |
"dataService" |
public static final double |
DEFAULT_APPLIED_LATENCY |
0.0 |
public static final java.lang.String |
DISKLOGDIR |
"diskLogDir" |
public static final java.lang.String |
DRIVER |
"driver" |
public static final java.lang.String |
HIGHWATER |
"highWater" |
public static final java.lang.String |
HOST |
"host" |
public static final java.lang.String |
ISAVAILABLE |
"isAvailable" |
public static final java.lang.String |
LASTERROR |
"lastError" |
public static final java.lang.String |
LASTSHUNREASON |
"lastShunReason" |
public static final java.lang.String |
LOGDIR |
"logDir" |
public static final java.lang.String |
LOGPATTERN |
"logPattern" |
public static final java.lang.String |
NAME |
"name" |
public static final java.lang.String |
PASSWORD |
"password" |
public static final java.lang.String |
PORT |
"port" |
public static final java.lang.String |
PRECEDENCE |
"precedence" |
public static final java.lang.String |
REPLICATOR_HOST |
"replicatorHost" |
public static final java.lang.String |
ROLE |
"role" |
public static final java.lang.String |
STATE |
"state" |
public static final java.lang.String |
URL |
"url" |
public static final java.lang.String |
USER |
"user" |
public static final java.lang.String |
VENDOR |
"vendor" |
| com.continuent.tungsten.common.cluster.resource.physical.Replicator | ||
|---|---|---|
public static final java.lang.String |
APPLIED_LAST_EVENT_ID |
"appliedLastEventId" |
public static final java.lang.String |
APPLIED_LAST_SEQNO |
"appliedLastSeqno" |
public static final java.lang.String |
APPLIED_LATENCY |
"appliedLatency" |
public static final java.lang.String |
CHANNELS |
"channels" |
public static final java.lang.String |
CLUSTERNAME |
"clusterName" |
public static final java.lang.String |
CURRENT_EVENT_ID |
"currentEventId" |
public static final java.lang.String |
CURRENT_TIME_MILLIS |
"currentTimeMillis" |
public static final java.lang.String |
DATASERVER_HOST |
"dataServerHost" |
public static final java.lang.String |
DEFAULT_LAST_EVENT_ID |
"0:0" |
public static final long |
DEFAULT_LATEST_EPOCH_NUMBER |
-1L |
public static final java.lang.String |
EXTENSIONS |
"extensions" |
public static final java.lang.String |
HOST |
"host" |
public static final java.lang.String |
LATEST_EPOCH_NUMBER |
"latestEpochNumber" |
public static final java.lang.String |
MASTER_CONNECT_URI |
"masterConnectUri" |
public static final java.lang.String |
MASTER_LISTEN_URI |
"masterListenUri" |
public static final java.lang.String |
MAX_PORT |
"maxPort" |
public static final java.lang.String |
MAX_STORED_SEQNO |
"maximumStoredSeqNo" |
public static final java.lang.String |
MIN_STORED_SEQNO |
"minimumStoredSeqNo" |
public static final java.lang.String |
OFFLINE_REQUESTS |
"offlineRequests" |
public static final java.lang.String |
PASSWORD |
"password" |
public static final java.lang.String |
PENDING_ERROR |
"pendingError" |
public static final java.lang.String |
PENDING_ERROR_CODE |
"pendingErrorCode" |
public static final java.lang.String |
PENDING_ERROR_EVENTID |
"pendingErrorEventId" |
public static final java.lang.String |
PENDING_ERROR_SEQNO |
"pendingErrorSeqno" |
public static final java.lang.String |
PENDING_EXCEPTION_MESSAGE |
"pendingExceptionMessage" |
public static final java.lang.String |
PIPELINE_SOURCE |
"pipelineSource" |
public static final java.lang.String |
RELATIVE_LATENCY |
"relativeLatency" |
public static final java.lang.String |
RESOURCE_DATASERVER_HOST |
"resourceDataServerHost" |
public static final java.lang.String |
RESOURCE_DISK_LOGDIR |
"resourceDiskLogDir" |
public static final java.lang.String |
RESOURCE_JDBC_DRIVER |
"resourceJdbcDriver" |
public static final java.lang.String |
RESOURCE_JDBC_URL |
"resourceJdbcUrl" |
public static final java.lang.String |
RESOURCE_LOGDIR |
"resourceLogDir" |
public static final java.lang.String |
RESOURCE_LOGPATTERN |
"resourceLogPattern" |
public static final java.lang.String |
RESOURCE_PORT |
"resourcePort" |
public static final java.lang.String |
RESOURCE_PRECEDENCE |
"resourcePrecedence" |
public static final java.lang.String |
RESOURCE_VENDOR |
"resourceVendor" |
public static final java.lang.String |
RMI_PORT |
"rmiPort" |
public static final java.lang.String |
ROLE |
"role" |
public static final java.lang.String |
SEQNO_TYPE |
"seqnoType" |
public static final java.lang.String |
SEQNO_TYPE_LONG |
"java.lang.Long" |
public static final java.lang.String |
SEQNO_TYPE_STRING |
"java.lang.String" |
public static final java.lang.String |
SERVICE_NAME |
"serviceName" |
public static final java.lang.String |
SERVICE_TYPE |
"serviceType" |
public static final java.lang.String |
SIMPLE_SERVICE_NAME |
"simpleServiceName" |
public static final java.lang.String |
SITENAME |
"siteName" |
public static final java.lang.String |
SOURCEID |
"sourceId" |
public static final java.lang.String |
SSL_LOG_CONNECTION |
"sslLogConnection" |
public static final java.lang.String |
STATE |
"state" |
public static final java.lang.String |
TIME_IN_STATE_SECONDS |
"timeInStateSeconds" |
public static final java.lang.String |
TRANSITIONING_TO |
"transitioningTo" |
public static final java.lang.String |
UPTIME_SECONDS |
"uptimeSeconds" |
public static final java.lang.String |
USE_SSL_CONNECTION |
"useSSLConnection" |
public static final java.lang.String |
USER |
"user" |
public static final java.lang.String |
VERSION |
"version" |
| com.continuent.tungsten.common.cluster.resource.physical.ReplicatorCapabilities | ||
|---|---|---|
public static final java.lang.String |
MODEL |
"model" |
public static final java.lang.String |
MODEL_PEER |
"peer" |
public static final java.lang.String |
MODEL_PULL |
"pull" |
public static final java.lang.String |
MODEL_PUSH |
"push" |
public static final java.lang.String |
PROVISION_DONOR |
"donor" |
public static final java.lang.String |
PROVISION_JOINER |
"joiner" |
public static final java.lang.String |
ROLE_MASTER |
"master" |
public static final java.lang.String |
ROLE_SLAVE |
"slave" |
public static final java.lang.String |
ROLE_STANDBY |
"standby" |
public static final java.lang.String |
ROLES |
"roles" |
public static final java.lang.String |
UNKNOWN |
"unknown" |
| com.continuent.tungsten.common.config.TungstenProperties | ||
|---|---|---|
public static final java.lang.String |
ENDOFLINE_TAG |
"#EOL" |
public static final java.lang.String |
ENDOFPROPERTIES_TAG |
"#EOF" |
| com.continuent.tungsten.common.config.TungstenPropertiesIO | ||
|---|---|---|
public final java.lang.String |
JAVA_PROPERTIES |
"JAVA_PROPERTIES" |
public final java.lang.String |
JSON |
"JSON" |
| com.continuent.tungsten.common.config.cluster.ConfigurationConstants | ||
|---|---|---|
public static final java.lang.String |
CLUSTER_CLUSTERNAME |
"clusterName" |
public static final java.lang.String |
CLUSTER_CONF_DIR |
"conf" |
public static final java.lang.String |
CLUSTER_DEFAULT_NAME |
"default" |
public static final java.lang.String |
CLUSTER_DIR |
"cluster" |
public static final java.lang.String |
CLUSTER_HOME |
"cluster.home" |
public static final java.lang.String |
CLUSTER_MANAGER_LIST |
"managerList" |
public static final java.lang.String |
CLUSTER_MEMBERNAME |
"memberName" |
public static final java.lang.String |
CLUSTER_PORT |
"port" |
public static final java.lang.String |
CLUSTER_SITENAME |
"siteName" |
public static final java.lang.String |
CLUSTER_STATE_MAP_PROPS |
"statemap.properties" |
public static final int |
DELAY_BEFORE_OFFLINE_IF_NO_MANAGER_DEFAULT |
30 |
public static final int |
DELAY_BEFORE_OFFLINE_IF_NO_MANAGER_MAX |
60 |
public static final int |
DELAY_BEFORE_OFFLINE_IN_MAINTENANCE_MODE_IF_NO_MANAGER_DEFAULT |
300 |
public static final int |
GATEWAY_CONNECT_TIMEOUT_MS_DEFAULT |
5000 |
public static final int |
GATEWAY_CONNECT_TIMEOUT_MS_MAX |
30000 |
public static final int |
KEEP_ALIVE_TIMEOUT_DEFAULT |
30000 |
public static final int |
KEEP_ALIVE_TIMEOUT_MAX |
300000 |
public static final java.lang.String |
PM_NOTIFY_PORT |
"policymgr.notify_port" |
public static final java.lang.String |
PM_NOTIFY_PORT_DEFAULT |
"10100" |
public static final java.lang.String |
PM_PROPERTIES |
"policymgr.properties" |
public static final java.lang.String |
PM_RMI_DEFAULT_HOST |
"localhost" |
public static final java.lang.String |
PM_RMI_PORT |
"policymgr.rmi_port" |
public static final java.lang.String |
PM_RMI_PORT_DEFAULT |
"10011" |
public static final java.lang.String |
PM_SERVICE_NAME |
"cluster-policy-mgr" |
public static final long |
READ_COMMAND_RETRY_TIMEOUT_MS_DEFAULT |
10000L |
public static final java.lang.String |
TR_GW_PORT_DEFAULT |
"11999" |
public static final java.lang.String |
TR_PROPERTIES |
"router.properties" |
public static final java.lang.String |
TR_RMI_DEFAULT_HOST |
"localhost" |
public static final java.lang.String |
TR_RMI_PORT |
"router.rmi_port" |
public static final java.lang.String |
TR_RMI_PORT_DEFAULT |
"10999" |
public static final java.lang.String |
TR_SERVICE_NAME |
"router" |
public static final java.lang.String |
TR_SERVICES_PROPS |
"dataservices.properties" |
| com.continuent.tungsten.common.directory.Directory | ||
|---|---|---|
public static final java.lang.String |
AMPERSAND |
"&" |
public static final java.lang.String |
ANY_ELEMENT |
"*" |
public static final java.lang.String |
CD |
"cd" |
public static final java.lang.String |
CHKEXEC |
"chkexec" |
public static final java.lang.String |
CONNECT |
"connect" |
public static final java.lang.String |
CP |
"cp" |
public static final java.lang.String |
CREATE |
"create" |
public static final java.lang.String |
CURRENT_ELEMENT |
"." |
public static final java.lang.String |
DEFAULT_CLUSTER_NAME |
"default" |
public static final java.lang.String |
DIRECTORY |
"directory" |
public static final java.lang.String |
DISCONNECT |
"disconnect" |
public static final java.lang.String |
DISCONNECT_ALL |
"disconnectAll" |
public static final java.lang.String |
EXECUTE |
"execute" |
public static final java.lang.String |
EXTENSION |
"extension" |
public static final char |
FLAG_ABSOLUTE |
65 |
public static final char |
FLAG_LONG |
108 |
public static final char |
FLAG_PARENTS |
112 |
public static final char |
FLAG_RECURSIVE |
82 |
public static final java.lang.String |
KEY_COMMAND |
"command" |
public static final java.lang.String |
LIST |
"ls" |
public static final java.lang.String |
LOCATE_SERVICE |
"locateServices" |
public static final java.lang.String |
MERGE |
"merge" |
public static final java.lang.String |
PARENT_ELEMENT |
".." |
public static final java.lang.String |
PATH_SEPARATOR |
"/" |
public static final java.lang.String |
PROTOCOL |
"resource:" |
public static final java.lang.String |
PWD |
"pwd" |
public static final java.lang.String |
RM |
"rm" |
public static final java.lang.String |
ROOT_ELEMENT |
"/" |
public static final java.lang.String |
SERVICE |
"service" |
public static final java.lang.String |
WHICH |
"which" |
| com.continuent.tungsten.common.exec.ProcessExecutor | ||
|---|---|---|
protected static final int |
THREAD_WAIT_MILLIS |
30000 |
| com.continuent.tungsten.common.jmx.JmxManager | ||
|---|---|---|
public static final java.lang.String |
CREATE_MBEAN_HELPER |
"createHelper" |
| com.continuent.tungsten.common.mysql.MySQLConstants | ||
|---|---|---|
public static final int |
AUTO_INCREMENT_FLAG |
512 |
public static final int |
BINARY_FLAG |
128 |
public static final int |
BLOB_FLAG |
16 |
public static final short |
CHARSET_BINARY |
63 |
public static final short |
CHARSET_UTF8 |
33 |
public static final int |
CLIENT_COMPRESS |
32 |
public static final int |
CLIENT_CONNECT_WITH_DB |
8 |
public static final int |
CLIENT_FOUND_ROWS |
2 |
public static final int |
CLIENT_IGNORE_SIGPIPE |
4096 |
public static final int |
CLIENT_IGNORE_SPACE |
256 |
public static final int |
CLIENT_INTERACTIVE |
1024 |
public static final int |
CLIENT_LOCAL_FILES |
128 |
public static final int |
CLIENT_LONG_FLAG |
4 |
public static final int |
CLIENT_LONG_PASSWORD |
1 |
public static final int |
CLIENT_MULTI_RESULTS |
131072 |
public static final int |
CLIENT_MULTI_STATEMENTS |
65536 |
public static final int |
CLIENT_NO_SCHEMA |
16 |
public static final int |
CLIENT_ODBC |
64 |
public static final int |
CLIENT_PROTOCOL_41 |
512 |
public static final int |
CLIENT_RESERVED |
16384 |
public static final int |
CLIENT_SECURE_CONNECTION |
32768 |
public static final int |
CLIENT_SSL |
2048 |
public static final int |
CLIENT_TRANSACTIONS |
8192 |
public static final int |
COM_BINLOG_DUMP |
18 |
public static final int |
COM_CHANGE_USER |
17 |
public static final int |
COM_CONNECT |
11 |
public static final int |
COM_CONNECT_OUT |
20 |
public static final int |
COM_CREATE_DB |
5 |
public static final int |
COM_DEBUG |
13 |
public static final int |
COM_DELAYED_INSERT |
16 |
public static final int |
COM_DROP_DB |
6 |
public static final int |
COM_FIELD_LIST |
4 |
public static final int |
COM_INIT_DB |
2 |
public static final int |
COM_PING |
14 |
public static final int |
COM_PROCESS_INFO |
10 |
public static final int |
COM_PROCESS_KILL |
12 |
public static final int |
COM_QUERY |
3 |
public static final int |
COM_QUIT |
1 |
public static final int |
COM_REFRESH |
7 |
public static final int |
COM_REGISTER_SLAVE |
21 |
public static final int |
COM_SET_OPTION |
27 |
public static final int |
COM_SHUTDOWN |
8 |
public static final int |
COM_SLEEP |
0 |
public static final int |
COM_STATISTICS |
9 |
public static final int |
COM_STMT_CLOSE |
25 |
public static final int |
COM_STMT_EXECUTE |
23 |
public static final int |
COM_STMT_FETCH |
28 |
public static final int |
COM_STMT_PREPARE |
22 |
public static final int |
COM_STMT_RESET |
26 |
public static final int |
COM_STMT_SEND_LONG_DATA |
24 |
public static final int |
COM_TABLE_DUMP |
19 |
public static final int |
COM_TIME |
15 |
public static final byte |
CURSOR_TYPE_FOR_UPDATE |
2 |
public static final byte |
CURSOR_TYPE_NO_CURSOR |
0 |
public static final byte |
CURSOR_TYPE_READ_ONLY |
1 |
public static final byte |
CURSOR_TYPE_SCROLLABLE |
4 |
public static final int |
ENUM_FLAG |
256 |
public static final int |
ER_BAD_DB_ERROR |
1049 |
public static final int |
ER_CON_COUNT_ERROR |
1040 |
public static final int |
ER_DBACCESS_DENIED_ERROR |
1044 |
public static final int |
ER_LOST_CONNECTION |
2013 |
public static final int |
ER_NO |
1002 |
public static final int |
ER_NO_DB_ERROR |
1046 |
public static final int |
ER_NO_ERROR |
-1 |
public static final int |
ER_NOT_SUPPORTED_YET |
1235 |
public static final int |
ER_OUTOFMEMORY |
1037 |
public static final int |
ER_SERVER_GONE_AWAY |
2006 |
public static final int |
ER_TOO_MANY_USER_CONNECTIONS |
1203 |
public static final int |
ER_UNKNOWN_ERROR |
1055 |
public static final int |
ER_UNKNOWN_STMT_HANDLER |
1243 |
public static final int |
ER_WRONG_ARGUMENTS |
1210 |
public static final int |
MULTIPLE_KEY_FLAG |
8 |
public static final int |
MYSQL_LONG_DATA_HEADER |
6 |
public static final byte |
MYSQL_TYPE_BIT |
16 |
public static final byte |
MYSQL_TYPE_BLOB |
-4 |
public static final byte |
MYSQL_TYPE_DATE |
10 |
public static final byte |
MYSQL_TYPE_DATETIME |
12 |
public static final byte |
MYSQL_TYPE_DECIMAL |
0 |
public static final byte |
MYSQL_TYPE_DOUBLE |
5 |
public static final byte |
MYSQL_TYPE_ENUM |
-9 |
public static final byte |
MYSQL_TYPE_FLOAT |
4 |
public static final byte |
MYSQL_TYPE_GEOMETRY |
-1 |
public static final byte |
MYSQL_TYPE_INT24 |
9 |
public static final byte |
MYSQL_TYPE_LONG |
3 |
public static final byte |
MYSQL_TYPE_LONG_BLOB |
-5 |
public static final byte |
MYSQL_TYPE_LONGLONG |
8 |
public static final byte |
MYSQL_TYPE_MEDIUM_BLOB |
-6 |
public static final byte |
MYSQL_TYPE_NEWDATE |
14 |
public static final byte |
MYSQL_TYPE_NEWDECIMAL |
-10 |
public static final byte |
MYSQL_TYPE_NULL |
6 |
public static final byte |
MYSQL_TYPE_SET |
-8 |
public static final byte |
MYSQL_TYPE_SHORT |
2 |
public static final byte |
MYSQL_TYPE_STRING |
-2 |
public static final byte |
MYSQL_TYPE_TIME |
11 |
public static final byte |
MYSQL_TYPE_TIMESTAMP |
7 |
public static final byte |
MYSQL_TYPE_TINY |
1 |
public static final byte |
MYSQL_TYPE_TINY_BLOB |
-7 |
public static final byte |
MYSQL_TYPE_VAR_STRING |
-3 |
public static final byte |
MYSQL_TYPE_VARCHAR |
15 |
public static final byte |
MYSQL_TYPE_YEAR |
13 |
public static final int |
NO_DEFAULT_VALUE_FLAG |
4096 |
public static final int |
NOT_NULL_FLAG |
1 |
public static final int |
NUM_FLAG |
32768 |
public static final int |
PRI_KEY_FLAG |
2 |
public static final short |
SERVER_MORE_RESULTS_EXISTS |
8 |
public static final short |
SERVER_QUERY_NO_GOOD_INDEX_USED |
16 |
public static final short |
SERVER_QUERY_NO_INDEX_USED |
32 |
public static final short |
SERVER_STATUS_AUTOCOMMIT |
2 |
public static final short |
SERVER_STATUS_CURSOR_EXISTS |
64 |
public static final short |
SERVER_STATUS_IN_TRANS |
1 |
public static final short |
SERVER_STATUS_LAST_ROW_SENT |
128 |
public static final int |
SET_FLAG |
2048 |
public static final java.lang.String |
SQL_STATE_COMMUNICATION_ERROR |
"08S01" |
public static final int |
TIMESTAMP_FLAG |
1024 |
public static final int |
UNIQUE_KEY_FLAG |
4 |
public static final int |
UNSIGNED_FLAG |
32 |
public static final int |
ZEROFILL_FLAG |
64 |
| com.continuent.tungsten.common.mysql.MySQLIOs | ||
|---|---|---|
public static final java.lang.String |
MYSQL_ERRNO |
"MySQLErrNo" |
public static final java.lang.String |
MYSQL_SQL_STATE |
"MySQLState" |
public static final java.lang.String |
RESULT_KEY |
"Result" |
public static final java.lang.String |
SOCKET_PHASE_CONNECT |
"connecting to" |
public static final java.lang.String |
SOCKET_PHASE_READ |
"reading from" |
public static final java.lang.String |
SOCKET_PHASE_WRITE |
"writing to" |
public static final java.lang.String |
STATUS_EXCEPTION |
"Exception" |
public static final java.lang.String |
STATUS_KEY |
"Status" |
public static final java.lang.String |
STATUS_MESSAGE_KEY |
"StatusMsg" |
public static final java.lang.String |
TIME_TO_CONNECT_MS |
"TimeToConnectMs" |
public static final java.lang.String |
TIME_TO_EXEC_QUERY_MS |
"TimeToExecQueryMs" |
public static final java.lang.String |
TIME_TO_INIT_MS |
"TimeToInitMs" |
| com.continuent.tungsten.common.mysql.MySQLPacket | ||
|---|---|---|
public static final int |
EOF_SERVER_STATUS_OFFSET |
7 |
public static final int |
EOF_WARNING_COUNT_OFFSET |
5 |
public static final int |
ERROR_MESSAGE_OFFSET |
8 |
public static final int |
ERROR_NUMBER_OFFSET |
5 |
public static final int |
ERROR_SQL_STATE_OFFSET |
7 |
public static final int |
HEADER_LENGTH |
4 |
public static final int |
MAX_LENGTH |
16777215 |
public static final int |
PACKET_TYPE_OFFSET |
4 |
| com.continuent.tungsten.common.security.AuthenticationInfo | ||
|---|---|---|
public static final java.lang.String |
AUTHENTICATION_INFO_PROPERTY |
"authenticationInfo" |
public static final java.lang.String |
KEYSTORE_LOCATION |
"-keystoreLocation" |
public static final java.lang.String |
KEYSTORE_PASSWORD |
"-keystorePassword" |
public static final java.lang.String |
PASSWORD |
"-password" |
public static final java.lang.String |
SECURITY_CONFIG_FILE_LOCATION |
"-securityProperties" |
public static final java.lang.String |
TRUSTSTORE_LOCATION |
"-truststoreLocation" |
public static final java.lang.String |
TRUSTSTORE_PASSWORD |
"-truststorePassword" |
public static final java.lang.String |
TUNGSTEN_AUTHENTICATION_REALM |
"tungstenAutenthicationRealm" |
public static final java.lang.String |
USERNAME |
"-username" |
| com.continuent.tungsten.common.security.SecurityConf | ||
|---|---|---|
public static final java.lang.String |
SECURITY_ACCESS_FILE_LOCATION |
"security.rmi.jmxremote.access_file.location" |
public static final java.lang.String |
SECURITY_APPLICATION_CONNECTOR |
"connector" |
public static final java.lang.String |
SECURITY_APPLICATION_RMI_JMX |
"rmi_jmx" |
public static final java.lang.String |
SECURITY_DIR |
"security.dir" |
public static final java.lang.String |
SECURITY_JMX_USE_AUTHENTICATION |
"security.rmi.authentication" |
public static final java.lang.String |
SECURITY_JMX_USE_ENCRYPTION |
"security.rmi.encryption" |
public static final java.lang.String |
SECURITY_JMX_USE_TUNGSTEN_AUTHENTICATION_REALM |
"security.rmi.tungsten.authenticationRealm" |
public static final java.lang.String |
SECURITY_JMX_USE_TUNGSTEN_AUTHENTICATION_REALM_ENCRYPTED_PASSWORD |
"security.rmi.tungsten.authenticationRealm.encrypted.password" |
public static final java.lang.String |
SECURITY_JMX_USERNAME |
"security.rmi.authentication.username" |
public static final java.lang.String |
SECURITY_KEYSTORE_LOCATION |
"security.keystore.location" |
public static final java.lang.String |
SECURITY_KEYSTORE_PASSWORD |
"security.keystore.password" |
public static final java.lang.String |
SECURITY_PASSWORD_FILE_LOCATION |
"security.password_file.location" |
public static final java.lang.String |
SECURITY_PROPERTIES_FILE_NAME |
"security.properties" |
public static final java.lang.String |
SECURITY_PROPERTIES_PARENT_FILE_LOCATION |
"security.properties.parent.file.location" |
public static final java.lang.String |
SECURITY_TRUSTSTORE_LOCATION |
"security.truststore.location" |
public static final java.lang.String |
SECURITY_TRUSTSTORE_PASSWORD |
"security.truststore.password" |
public static final java.lang.String |
SECURITY_USE_AUTHENTICATION_DEFAULT |
"false" |
public static final java.lang.String |
SECURITY_USE_ENCRYPTION_DEFAULT |
"false" |
public static final java.lang.String |
SECURITY_USE_TUNGSTEN_AUTHENTICATION_REALM_DEFAULT |
"true" |
public static final java.lang.String |
SECURITY_USE_TUNGSTEN_AUTHENTICATION_REALM_ENCRYPTED_PASSWORD_DEFAULT |
"false" |
| com.continuent.tungsten.common.utils.Command | ||
|---|---|---|
public static final int |
FLAG_ABSOLUTE |
5 |
public static final int |
FLAG_BACKGROUND |
2 |
public static final int |
FLAG_COUNT |
7 |
public static final int |
FLAG_LONG |
1 |
public static final int |
FLAG_PARENTS |
6 |
public static final int |
FLAG_RECURSIVE |
0 |
public static final int |
FLAG_REDIRECT_IN |
4 |
public static final int |
FLAG_REDIRECT_OUT |
3 |
| com.continuent.tungsten.common.utils.CommandLineParser | ||
|---|---|---|
public static final char |
ABSOLUTE_FLAG |
65 |
public static final char |
BACKGROUND_FLAG |
38 |
public static final char |
PARENTS_FLAG |
112 |
| com.continuent.tungsten.common.utils.ResultFormatter | ||
|---|---|---|
public static final java.lang.String |
DEFAULT_INDENT |
" " |
public static final int |
DEFAULT_WIDTH |
75 |
public static final java.lang.String |
NEWLINE |
"\n" |
public static final java.lang.String |
ROW_BEGIN_END |
"|" |
public static final java.lang.String |
ROW_SEPARATOR |
"-" |
| com.continuent.tungsten.common.utils.TraceVectorManager | ||
|---|---|---|
public static final java.lang.String |
TRACE_ARG_ENABLE_FLAG |
"enableFlag" |
public static final java.lang.String |
TRACE_ARG_VECTOR_PATH |
"vectorPath" |
public static final java.lang.String |
TRACE_METHOD_AUTO_DISABLE |
"traceAUtoDisable" |
public static final java.lang.String |
TRACE_METHOD_GLOBAL_ENABLE |
"traceEnable" |
public static final java.lang.String |
TRACE_METHOD_LIST |
"traceList" |
public static final java.lang.String |
TRACE_METHOD_RESET |
"traceReset" |
public static final java.lang.String |
TRACE_METHOD_TRACE |
"trace" |
| com.continuent.tungsten.manager.router.gateway.RouterGatewayConstants | ||
|---|---|---|
public static final java.lang.String |
ARGS |
"args" |
public static final char |
COMMAND_CONFIGURE |
99 |
public static final char |
COMMAND_DATASOURCE_MAP |
109 |
public static final char |
COMMAND_DIAG |
100 |
public static final char |
COMMAND_GATEWAY_IS_RUNNING |
105 |
public static final char |
COMMAND_MAINTENANCE_MODE |
97 |
public static final char |
COMMAND_OFFLINE |
102 |
public static final char |
COMMAND_ONLINE |
110 |
public static final char |
COMMAND_PING |
112 |
public static final char |
COMMAND_QUIT |
113 |
public static final char |
COMMAND_REMOVE_DS |
114 |
public static final char |
COMMAND_RESET_CLUSTER_VIEW |
101 |
public static final char |
COMMAND_RUN_GATEWAY |
85 |
public static final char |
COMMAND_STATISTICS |
116 |
public static final char |
COMMAND_STATUS |
115 |
public static final char |
COMMAND_STOP_GATEWAY |
83 |
public static final char |
COMMAND_TRACE |
84 |
public static final char |
COMMAND_TRACE_GLOBAL_ENABLE |
69 |
public static final char |
COMMAND_TRACE_LIST |
76 |
public static final char |
COMMAND_TRACE_RESET |
82 |
public static final char |
COMMAND_UPDATE_DS |
117 |
public static final int |
DEFAULT_GATEWAY_PORT |
11999 |
public static final java.lang.String |
ERROR |
"error" |
public static final java.lang.String |
FAILSAFE |
"failSafe" |
public static final java.lang.String |
MAINTENANCE_MODE |
"maintenanceMode" |
public static final java.lang.String |
MANAGER_LIST |
"managers" |
public static final java.lang.String |
METHOD_NAME |
"methodName" |
public static final java.lang.String |
NOTIFICATION_ARGS_PREFIX |
"notificationArgs." |
public static final java.lang.String |
NOTIFICATION_PREFIX |
"notification." |
public static final java.lang.String |
RESULT |
"result" |
public static final java.lang.String |
ROUTER_ID |
"router.id" |
public static final java.lang.String |
ROUTER_NAME |
"memberName" |
public static final java.lang.String |
SERVICE_NAME |
"serviceName" |
public static final java.lang.String |
TIMEOUT_MSECS |
"timeoutMsecs" |
| com.continuent.tungsten.replicator.Version | ||
|---|---|---|
public static final java.lang.String |
MAJOR_COLUMN |
"major" |
public static final java.lang.String |
MINOR_COLUMN |
"minor" |
public static final java.lang.String |
MODULE_COLUMN |
"module" |
public static final java.lang.String |
SELECT |
"SELECT * FROM " |
public static final java.lang.String |
SUFFIX_COLUMN |
"suffix" |
public static final java.lang.String |
TABLE_NAME |
"version" |
| com.continuent.tungsten.replicator.channel.ShardChannelTable | ||
|---|---|---|
public static final java.lang.String |
CHANNEL_COL |
"channel" |
public static final java.lang.String |
SHARD_ID_COL |
"shard_id" |
public static final java.lang.String |
TABLE_NAME |
"trep_shard_channel" |
| com.continuent.tungsten.replicator.conf.MonitorThreadInfo | ||
|---|---|---|
public static final java.lang.String |
APPLIER |
"Applier" |
public static final java.lang.String |
EXTRACTOR |
"Extract" |
public static final java.lang.String |
THLCLI |
"THLCli" |
public static final java.lang.String |
THLSRV |
"THLSrv" |
| com.continuent.tungsten.replicator.conf.ReplicatorConf | ||
|---|---|---|
public static final java.lang.String |
APPLIER |
"applier" |
public static final java.lang.String |
APPLIER_CONSISTENCY_COL_NAMES |
"replicator.applier.consistency_column_names" |
public static final java.lang.String |
APPLIER_CONSISTENCY_COL_NAMES_DEFAULT |
"true" |
public static final java.lang.String |
APPLIER_CONSISTENCY_COL_TYPES |
"replicator.applier.consistency_column_types" |
public static final java.lang.String |
APPLIER_CONSISTENCY_COL_TYPES_DEFAULT |
"true" |
public static final java.lang.String |
APPLIER_CONSISTENCY_POLICY |
"replicator.applier.consistency_policy" |
public static final java.lang.String |
APPLIER_CONSISTENCY_POLICY_DEFAULT |
"stop" |
public static final java.lang.String |
APPLIER_FAIL_ON_0_ROW_UPDATE |
"replicator.applier.failOnZeroRowUpdate" |
public static final java.lang.String |
APPLIER_FAIL_ON_0_ROW_UPDATE_DEFAULT |
"warn" |
public static final java.lang.String |
APPLIER_FAILURE_POLICY |
"replicator.applier.failure_policy" |
public static final java.lang.String |
APPLIER_FAILURE_POLICY_DEFAULT |
"stop" |
public static final java.lang.String |
APPLIER_ROOT |
"replicator.applier" |
public static final java.lang.String |
AUTO_BACKUP |
"replicator.auto_backup" |
public static final java.lang.String |
AUTO_BACKUP_DEFAULT |
"false" |
public static final java.lang.String |
AUTO_ENABLE |
"replicator.auto_enable" |
public static final java.lang.String |
AUTO_ENABLE_DEFAULT |
"false" |
public static final java.lang.String |
AUTO_MASTER_REPOSITIONING |
"replicator.repositionOnSourceIdChange" |
public static final java.lang.String |
AUTO_MASTER_REPOSITIONING_DEFAULT |
"true" |
public static final java.lang.String |
AUTO_PROVISION |
"replicator.auto_provision" |
public static final java.lang.String |
AUTO_PROVISION_DEFAULT |
"false" |
public static final java.lang.String |
CLUSTER_NAME |
"cluster.name" |
public static final java.lang.String |
CLUSTER_NAME_DEFAULT |
"default" |
public static final java.lang.String |
DETACHED |
"replicator.detached" |
public static final java.lang.String |
DETACHED_DEFAULT |
"false" |
public static final java.lang.String |
EXTENSION_ROOT |
"replicator.extension" |
public static final java.lang.String |
EXTENSIONS |
"replicator.extensions" |
public static final java.lang.String |
EXTRACTOR |
"extractor" |
public static final java.lang.String |
EXTRACTOR_FAILURE_POLICY |
"replicator.extractor.failure_policy" |
public static final java.lang.String |
EXTRACTOR_FAILURE_POLICY_DEFAULT |
"stop" |
public static final java.lang.String |
EXTRACTOR_ROOT |
"replicator.extractor" |
public static final java.lang.String |
FILTER |
"filter" |
public static final java.lang.String |
FILTER_ROOT |
"replicator.filter" |
public static final java.lang.String |
FILTERS |
"filters" |
public static final java.lang.String |
FORCE_OFFLINE |
"forceOffline" |
public static final java.lang.String |
GLOBAL_DB_PASSWORD |
"replicator.global.db.password" |
public static final java.lang.String |
GLOBAL_DB_USER |
"replicator.global.db.user" |
public static final java.lang.String |
LOG_SLAVE_UPDATES |
"replicator.log.slave.updates" |
public static final java.lang.String |
LOG_SLAVE_UPDATES_DEFAULT |
"false" |
public static final java.lang.String |
MASTER_CONNECT_URI |
"replicator.master.connect.uri" |
public static final java.lang.String |
MASTER_LISTEN_PORT_START |
"replicator.masterListenPortStart" |
public static final java.lang.String |
MASTER_LISTEN_URI |
"replicator.master.listen.uri" |
public static final java.lang.String |
MASTER_THL_CHECK |
"replicator.master.thl_check" |
public static final java.lang.String |
MASTER_THL_CHECK_DEFAULT |
"true" |
public static final java.lang.String |
METADATA_SCHEMA |
"replicator.schema" |
public static final java.lang.String |
METADATA_SCHEMA_DEFAULT |
"tungsten_default" |
public static final java.lang.String |
METADATA_TABLE_TYPE |
"replicator.table.engine" |
public static final java.lang.String |
METADATA_TABLE_TYPE_DEFAULT |
"" |
public static final java.lang.String |
MONITOR_DETAIL_ENABLED |
"replicator.monitor.detail_enabled" |
public static final java.lang.String |
NATIVE_SLAVE_TAKEOVER |
"replicator.nativeSlaveTakeover" |
public static final java.lang.String |
NATIVE_SLAVE_TAKEOVER_DEFAULT |
"false" |
public static final java.lang.String |
OOS_POLICY |
"replicator.oos_policy" |
public static final java.lang.String |
OPEN_REPLICATOR |
"replicator.plugin" |
public static final java.lang.String |
PIPELINE_ROOT |
"replicator.pipeline" |
public static final java.lang.String |
PIPELINES |
"replicator.pipelines" |
public static final java.lang.String |
PRIVILEGED_SLAVE_UPDATE |
"replicator.privileged.slave.update" |
public static final java.lang.String |
PRIVILEGED_SLAVE_UPDATE_DEFAULT |
"true" |
public static final java.lang.String |
REPLICATOR_HOST |
"replicator.host" |
public static final java.lang.String |
RESOURCE_DATASERVER_HOST |
"replicator.resourceDataServerHost" |
public static final java.lang.String |
RESOURCE_DISKLOGDIR |
"replicator.resourceDiskLogDir" |
public static final java.lang.String |
RESOURCE_JDBC_DRIVER |
"replicator.resourceJdbcDriver" |
public static final java.lang.String |
RESOURCE_JDBC_URL |
"replicator.resourceJdbcUrl" |
public static final java.lang.String |
RESOURCE_JDBC_URL_DEFAULT |
"jdbc:mysql://localhost/${DBNAME}" |
public static final java.lang.String |
RESOURCE_LOGDIR |
"replicator.resourceLogDir" |
public static final java.lang.String |
RESOURCE_LOGPATTERN |
"replicator.resourceLogPattern" |
public static final java.lang.String |
RESOURCE_PORT |
"replicator.resourcePort" |
public static final java.lang.String |
RESOURCE_PRECEDENCE |
"replicator.resourcePrecedence" |
public static final java.lang.String |
RESOURCE_PRECEDENCE_DEFAULT |
"99" |
public static final java.lang.String |
RESOURCE_VENDOR |
"replicator.resourceVendor" |
public static final java.lang.String |
RMI_DEFAULT_HOST |
"localhost" |
public static final java.lang.String |
RMI_DEFAULT_PORT |
"10000" |
public static final java.lang.String |
RMI_DEFAULT_SERVICE_NAME |
"replicator" |
public static final java.lang.String |
RMI_HOST |
"replicator.rmi_host" |
public static final java.lang.String |
RMI_PORT |
"replicator.rmi_port" |
public static final java.lang.String |
ROLE |
"replicator.role" |
public static final java.lang.String |
ROLE_MASTER |
"master" |
public static final java.lang.String |
ROLE_SLAVE |
"slave" |
public static final java.lang.String |
SCRIPT_CONF_FILE |
"replicator.script.conf_file" |
public static final java.lang.String |
SCRIPT_PROCESSOR |
"replicator.script.processor" |
public static final java.lang.String |
SCRIPT_ROOT_DIR |
"replicator.script.root_dir" |
public static final java.lang.String |
SERVICE |
"service" |
public static final java.lang.String |
SERVICE_COMMENTS_ENABLED |
"replicator.service.comments" |
public static final java.lang.String |
SERVICE_COMMENTS_ENABLED_DEFAULT |
"false" |
public static final java.lang.String |
SERVICE_NAME |
"service.name" |
public static final java.lang.String |
SERVICE_RMI_PORT_START |
"replicator.serviceRMIPortStart" |
public static final java.lang.String |
SERVICE_ROOT |
"replicator.service" |
public static final java.lang.String |
SERVICE_TYPE |
"replicator.service.type" |
public static final java.lang.String |
SERVICE_TYPE_DEFAULT |
"local" |
public static final java.lang.String |
SHARD_DEFAULT_DB_USAGE |
"replicator.shard.default.db" |
public static final java.lang.String |
SHARD_DEFAULT_DB_USAGE_DEFAULT |
"stringent" |
public static final java.lang.String |
SITE_NAME |
"site.name" |
public static final java.lang.String |
SITE_NAME_DEFAULT |
"default" |
public static final java.lang.String |
SOURCE_ID |
"replicator.source_id" |
public static final java.lang.String |
SOURCE_ID_DEFAULT |
"tungsten" |
public static final java.lang.String |
STAGE |
"stage" |
public static final java.lang.String |
STAGE_ROOT |
"replicator.stage" |
public static final java.lang.String |
STORE |
"store" |
public static final java.lang.String |
STORE_ROOT |
"replicator.store" |
public static final java.lang.String |
THL_APPLIER_BLOCK_COMMIT_SIZE |
"replicator.thl.applier_block_commit_size" |
public static final java.lang.String |
THL_APPLIER_BLOCK_COMMIT_SIZE_DEFAULT |
"0" |
public static final java.lang.String |
THL_DB_PASSWORD |
"replicator.store.thl.password" |
public static final java.lang.String |
THL_DB_URL |
"replicator.store.thl.url" |
public static final java.lang.String |
THL_DB_USER |
"replicator.store.thl.user" |
public static final java.lang.String |
THL_PROTOCOL |
"replicator.thl.protocol" |
public static final java.lang.String |
THL_PROTOCOL_BUFFER_SIZE |
"replicator.thl.protocol.buffer_size" |
public static final java.lang.String |
THL_PROTOCOL_BUFFER_SIZE_DEFAULT |
"0" |
public static final java.lang.String |
THL_PROTOCOL_DEFAULT |
"com.continuent.tungsten.replicator.thl.Connector" |
public static final java.lang.String |
THL_REMOTE_URI_DEFAULT |
"thl://localhost/" |
public static final java.lang.String |
THL_SERVER_ACCEPT_TIMEOUT |
"replicator.thl.server.accept.timeout" |
public static final java.lang.String |
THL_SERVER_ACCEPT_TIMEOUT_DEFAULT |
"5000" |
public static final java.lang.String |
THL_STORAGE |
"replicator.thl.storage" |
public static final java.lang.String |
THL_URI |
"replicator.thl.uri" |
public static final java.lang.String |
THL_URI_DEFAULT |
"thl://0.0.0.0/" |
| com.continuent.tungsten.replicator.conf.ReplicatorMonitor | ||
|---|---|---|
public static final int |
COUNT_COUNT |
3 |
public static final int |
COUNT_EVENTS_PER_COMMIT |
2 |
public static final int |
COUNT_EVENTS_PER_MESSAGE |
1 |
public static final int |
COUNT_RECORDS_PER_EVENT |
0 |
public static final int |
CPU_APPLIERAEVENT |
12 |
public static final int |
CPU_APPLIERBISQL |
9 |
public static final int |
CPU_APPLIERBUSQL |
7 |
public static final int |
CPU_APPLIEREXSQL |
10 |
public static final int |
CPU_APPLIERGEVENT |
11 |
public static final int |
CPU_APPLIERMEVENT |
13 |
public static final int |
CPU_APPLIERPRSQL |
8 |
public static final int |
CPU_APPLIERSTRANS |
14 |
public static final int |
CPU_CHECKSUM |
6 |
public static final int |
CPU_COUNT |
15 |
public static final int |
CPU_DB_DESERIAL |
3 |
public static final int |
CPU_DB_SERIAL |
2 |
public static final int |
CPU_EXTRACT |
4 |
public static final int |
CPU_INSERTTHL |
5 |
public static final int |
CPU_MSG_DESERIAL |
1 |
public static final int |
CPU_MSG_SERIAL |
0 |
public static final int |
REAL_APPLY |
10 |
public static final int |
REAL_COMMIT |
9 |
public static final int |
REAL_COUNT |
12 |
public static final int |
REAL_DELWAIT |
8 |
public static final int |
REAL_EXTBODY |
5 |
public static final int |
REAL_EXTHEAD |
4 |
public static final int |
REAL_EXTRACT |
11 |
public static final int |
REAL_INSWAIT |
6 |
public static final int |
REAL_THLCLIWAIT |
1 |
public static final int |
REAL_THLSRVWAIT |
0 |
public static final int |
REAL_UPDWAIT |
7 |
public static final int |
REAL_WAIT4EXT |
2 |
public static final int |
REAL_WAIT4THLCLI |
3 |
| com.continuent.tungsten.replicator.conf.ReplicatorRuntimeConf | ||
|---|---|---|
public static final java.lang.String |
CLEAR_DYNAMIC_PROPERTIES |
"replicator.clear.dynamic.proeprties" |
public static final java.lang.String |
CONF_DIR |
"replicator.conf.dir" |
public static final java.lang.String |
HOME_DIR |
"replicator.home.dir" |
public static final java.lang.String |
LOG_DIR |
"replicator.log.dir" |
| com.continuent.tungsten.replicator.consistency.ConsistencyTable | ||
|---|---|---|
public static final int |
dbColumnIdx |
0 |
public static final java.lang.String |
dbColumnName |
"db" |
public static final int |
idColumnIdx |
2 |
public static final java.lang.String |
idColumnName |
"id" |
public static final int |
limitColumnIdx |
4 |
public static final java.lang.String |
limitColumnName |
"row_limit" |
public static final int |
masterCntColumnIdx |
8 |
public static final java.lang.String |
masterCntColumnName |
"master_cnt" |
public static final int |
masterCrcColumnIdx |
7 |
public static final java.lang.String |
masterCrcColumnName |
"master_crc" |
public static final int |
methodColumnIdx |
10 |
public static final java.lang.String |
methodColumnName |
"method" |
public static final int |
offsetColumnIdx |
3 |
public static final java.lang.String |
offsetColumnName |
"row_offset" |
public static final int |
ROW_UNSET |
-1 |
public static final java.lang.String |
TABLE_NAME |
"consistency" |
public static final int |
tblColumnIdx |
1 |
public static final java.lang.String |
tblColumnName |
"tbl" |
public static final int |
thisCntColumnIdx |
6 |
public static final java.lang.String |
thisCntColumnName |
"this_cnt" |
public static final int |
thisCrcColumnIdx |
5 |
public static final java.lang.String |
thisCrcColumnName |
"this_crc" |
public static final int |
tsColumnIdx |
9 |
public static final java.lang.String |
tsColumnName |
"ts" |
| com.continuent.tungsten.replicator.database.AdditionalTypes | ||
|---|---|---|
public static final int |
MEDIUMINT |
1515 |
public static final int |
TIMESTAMPLOCAL |
1500 |
public static final int |
UBIGINT |
1514 |
public static final int |
UINT |
1513 |
public static final int |
UMEDIUMINT |
1512 |
public static final int |
USMALLINT |
1511 |
public static final int |
UTINYINT |
1510 |
public static final int |
XML |
1501 |
| com.continuent.tungsten.replicator.database.Database | ||
|---|---|---|
public static final java.lang.String |
MYSQL |
"mysql" |
public static final java.lang.String |
ORACLE |
"oracle" |
public static final java.lang.String |
POSTGRESQL |
"postgresql" |
public static final java.lang.String |
UNKNOWN |
"unknown" |
| com.continuent.tungsten.replicator.database.Key | ||
|---|---|---|
public static final int |
IllegalType |
0 |
public static final int |
NonUnique |
1 |
public static final int |
Primary |
2 |
public static final int |
Unique |
3 |
| com.continuent.tungsten.replicator.database.Table | ||
|---|---|---|
public static final int |
DELETE |
3 |
public static final int |
INSERT |
0 |
public static final int |
NPREPPED |
4 |
public static final int |
UPDATE1 |
1 |
public static final int |
UPDATE2 |
2 |
| com.continuent.tungsten.replicator.dbms.RowIdData | ||
|---|---|---|
public static final int |
INSERT_ID |
2 |
public static final int |
LAST_INSERT_ID |
1 |
| com.continuent.tungsten.replicator.dbms.StatementData | ||
|---|---|---|
public static final java.lang.String |
CREATE_OR_DROP_DB |
"createOrDropDB" |
| com.continuent.tungsten.replicator.ddlscan.DDLScanCtrl | ||
|---|---|---|
public static final java.lang.String |
DBNAME_VAR |
"${DBNAME}" |
| com.continuent.tungsten.replicator.event.ReplControlEvent | ||
|---|---|---|
public static final int |
STOP |
1 |
public static final int |
SYNC |
2 |
| com.continuent.tungsten.replicator.event.ReplOptionParams | ||
|---|---|---|
public static final java.lang.String |
ROLLBACK |
"rollback" |
public static final java.lang.String |
UNSAFE_FOR_BLOCK_COMMIT |
"unsafe_for_block_commit" |
| com.continuent.tungsten.replicator.extractor.mysql.MysqlBinlog | ||
|---|---|---|
public static final int |
ANONYMOUS_GTID_LOG_EVENT |
34 |
public static final int |
APPEND_BLOCK_EVENT |
9 |
public static final int |
APPEND_BLOCK_HEADER_LEN |
4 |
public static final int |
BEGIN_LOAD_QUERY_EVENT |
17 |
public static final int |
BIN_LOG_HEADER_SIZE |
4 |
public static final int |
BINLOG_V1 |
1 |
public static final int |
BINLOG_V3 |
2 |
public static final int |
BINLOG_V4 |
3 |
public static final int |
CREATE_FILE_EVENT |
8 |
public static final int |
CREATE_FILE_HEADER_LEN |
4 |
public static final int |
DELETE_FILE_EVENT |
11 |
public static final int |
DELETE_FILE_HEADER_LEN |
4 |
public static final int |
DELETE_ROWS_EVENT |
25 |
public static final int |
DIG_PER_INT32 |
9 |
public static final int |
E_DEC_OVERFLOW |
100 |
public static final int |
E_DEC_TRUNCATED |
101 |
public static final int |
ENUM_END_EVENT |
27 |
public static final int |
ENUM_END_EVENT_FROM_56 |
36 |
public static final int |
EVENT_LEN_OFFSET |
9 |
public static final int |
EVENT_TYPE_OFFSET |
4 |
public static final int |
EXEC_LOAD_EVENT |
10 |
public static final int |
EXEC_LOAD_HEADER_LEN |
4 |
public static final int |
EXECUTE_LOAD_QUERY_EVENT |
18 |
public static final int |
EXECUTE_LOAD_QUERY_EXTRA_HEADER_LEN |
13 |
public static final int |
EXECUTE_LOAD_QUERY_HEADER_LEN |
26 |
public static final int |
FLAGS_OFFSET |
17 |
public static final int |
FN_REFLEN |
512 |
public static final int |
FORMAT_DESCRIPTION_EVENT |
15 |
public static final int |
FORMAT_DESCRIPTION_HEADER_LEN |
83 |
public static final int |
FORMAT_DESCRIPTION_HEADER_LEN_5_6 |
91 |
public static final int |
GTID_LOG_EVENT |
33 |
public static final int |
HEARTBEAT_LOG_EVENT |
27 |
public static final int |
I_TYPE_OFFSET |
0 |
public static final int |
I_VAL_OFFSET |
1 |
public static final int |
IGNORABLE_LOG_EVENT |
28 |
public static final int |
INCIDENT_EVENT |
26 |
public static final int |
INCIDENT_HEADER_LEN |
2 |
public static final int |
INT_MAX |
2147483647 |
public static final int |
INT_MIN |
-2147483648 |
public static final int |
INTVAR_EVENT |
5 |
public static final int |
LOAD_EVENT |
6 |
public static final int |
LOAD_HEADER_LEN |
18 |
public static final byte |
LOG_EVENT_BINLOG_IN_USE_F |
1 |
public static final int |
LOG_EVENT_HEADER_LEN |
19 |
public static final int |
LOG_EVENT_MINIMAL_HEADER_LEN |
19 |
public static final int |
LOG_EVENT_THREAD_SPECIFIC_F |
4 |
public static final int |
LOG_EVENT_TYPES |
26 |
public static final int |
LOG_NEW_5_6_EVENT_TYPES |
9 |
public static final int |
LOG_POS_OFFSET |
13 |
public static final long |
LONG_MAX |
2147483647L |
public static final int |
MEDIUMINT_MAX |
8388607 |
public static final int |
MEDIUMINT_MIN |
-8388608 |
public static final int |
MYSQL_TYPE_BIT |
16 |
public static final int |
MYSQL_TYPE_BLOB |
252 |
public static final int |
MYSQL_TYPE_DATE |
10 |
public static final int |
MYSQL_TYPE_DATETIME |
12 |
public static final int |
MYSQL_TYPE_DATETIME2 |
18 |
public static final int |
MYSQL_TYPE_DECIMAL |
0 |
public static final int |
MYSQL_TYPE_DOUBLE |
5 |
public static final int |
MYSQL_TYPE_ENUM |
247 |
public static final int |
MYSQL_TYPE_FLOAT |
4 |
public static final int |
MYSQL_TYPE_GEOMETRY |
255 |
public static final int |
MYSQL_TYPE_INT24 |
9 |
public static final int |
MYSQL_TYPE_LONG |
3 |
public static final int |
MYSQL_TYPE_LONG_BLOB |
251 |
public static final int |
MYSQL_TYPE_LONGLONG |
8 |
public static final int |
MYSQL_TYPE_MEDIUM_BLOB |
250 |
public static final int |
MYSQL_TYPE_NEWDATE |
14 |
public static final int |
MYSQL_TYPE_NEWDECIMAL |
246 |
public static final int |
MYSQL_TYPE_NULL |
6 |
public static final int |
MYSQL_TYPE_SET |
248 |
public static final int |
MYSQL_TYPE_SHORT |
2 |
public static final int |
MYSQL_TYPE_STRING |
254 |
public static final int |
MYSQL_TYPE_TIME |
11 |
public static final int |
MYSQL_TYPE_TIME2 |
19 |
public static final int |
MYSQL_TYPE_TIMESTAMP |
7 |
public static final int |
MYSQL_TYPE_TIMESTAMP2 |
17 |
public static final int |
MYSQL_TYPE_TINY |
1 |
public static final int |
MYSQL_TYPE_TINY_BLOB |
249 |
public static final int |
MYSQL_TYPE_VAR_STRING |
253 |
public static final int |
MYSQL_TYPE_VARCHAR |
15 |
public static final int |
MYSQL_TYPE_YEAR |
13 |
public static final int |
NEW_DELETE_ROWS_EVENT |
32 |
public static final int |
NEW_LOAD_EVENT |
12 |
public static final int |
NEW_UPDATE_ROWS_EVENT |
31 |
public static final int |
NEW_WRITE_ROWS_EVENT |
30 |
public static final long |
NULL_LENGTH |
2147483647L |
public static final int |
OLD_HEADER_LEN |
13 |
public static final int |
OPTION_AUTO_IS_NULL |
16384 |
public static final int |
OPTION_NO_FOREIGN_KEY_CHECKS |
67108864 |
public static final int |
OPTION_NOT_AUTOCOMMIT |
524288 |
public static final int |
OPTION_RELAXED_UNIQUE_CHECKS |
134217728 |
public static final int |
PRE_GA_DELETE_ROWS_EVENT |
22 |
public static final int |
PRE_GA_UPDATE_ROWS_EVENT |
21 |
public static final int |
PRE_GA_WRITE_ROWS_EVENT |
20 |
public static final int |
PREVIOUS_GTIDS_LOG_EVENT |
35 |
public static final int |
PROBE_HEADER_LEN |
13 |
public static final int |
Q_AUTO_INCREMENT |
3 |
public static final int |
Q_CATALOG_CODE |
2 |
public static final int |
Q_CATALOG_NZ_CODE |
6 |
public static final int |
Q_CHARSET_CODE |
4 |
public static final int |
Q_CHARSET_DATABASE_CODE |
8 |
public static final int |
Q_DATA_OFFSET |
13 |
public static final int |
Q_DB_LEN_OFFSET |
8 |
public static final int |
Q_ERR_CODE_OFFSET |
9 |
public static final int |
Q_EXEC_TIME_OFFSET |
4 |
public static final int |
Q_FLAGS2_CODE |
0 |
public static final int |
Q_LC_TIME_NAMES_CODE |
7 |
public static final int |
Q_SQL_MODE_CODE |
1 |
public static final int |
Q_STATUS_VARS_LEN_OFFSET |
11 |
public static final int |
Q_THREAD_ID_OFFSET |
0 |
public static final int |
Q_TIME_ZONE_CODE |
5 |
public static final int |
QUERY_EVENT |
2 |
public static final int |
QUERY_HEADER_LEN |
13 |
public static final int |
QUERY_HEADER_MINIMAL_LEN |
11 |
public static final int |
R_IDENT_OFFSET |
8 |
public static final int |
R_POS_OFFSET |
0 |
public static final int |
RAND_EVENT |
13 |
public static final int |
RAND_SEED1_OFFSET |
0 |
public static final int |
RAND_SEED2_OFFSET |
8 |
public static final int |
ROTATE_EVENT |
4 |
public static final int |
ROTATE_HEADER_LEN |
8 |
public static final int |
ROWS_HEADER_LEN |
8 |
public static final int |
ROWS_QUERY_LOG_EVENT |
29 |
public static final int |
RW_FLAGS_OFFSET |
6 |
public static final int |
RW_MAPID_OFFSET |
0 |
public static final int |
SERVER_ID_OFFSET |
5 |
public static final int |
SIZE_OF_INT32 |
4 |
public static final int |
SL_MASTER_HOST_OFFSET |
10 |
public static final int |
SL_MASTER_PORT_OFFSET |
8 |
public static final int |
SL_MASTER_POS_OFFSET |
0 |
public static final int |
SLAVE_EVENT |
7 |
public static final int |
SMALLINT_MAX |
32767 |
public static final int |
SMALLINT_MIN |
-32768 |
public static final int |
ST_BINLOG_VER_OFFSET |
0 |
public static final int |
ST_COMMON_HEADER_LEN_OFFSET |
56 |
public static final int |
ST_CREATED_OFFSET |
52 |
public static final int |
ST_SERVER_VER_LEN |
50 |
public static final int |
ST_SERVER_VER_OFFSET |
2 |
public static final int |
START_EVENT_V3 |
1 |
public static final int |
START_V3_HEADER_LEN |
56 |
public static final int |
STOP_EVENT |
3 |
public static final int |
TABLE_MAP_EVENT |
19 |
public static final int |
TABLE_MAP_HEADER_LEN |
8 |
public static final int |
TINYINT_MAX |
127 |
public static final int |
TINYINT_MIN |
-128 |
public static final int |
TM_FLAGS_OFFSET |
6 |
public static final int |
TM_MAPID_OFFSET |
0 |
public static final int |
UNKNOWN_EVENT |
0 |
public static final int |
UPDATE_ROWS_EVENT |
24 |
public static final int |
USER_VAR_EVENT |
14 |
public static final int |
UV_CHARSET_NUMBER_SIZE |
4 |
public static final int |
UV_NAME_LEN_SIZE |
4 |
public static final int |
UV_VAL_IS_NULL |
1 |
public static final int |
UV_VAL_LEN_SIZE |
4 |
public static final int |
UV_VAL_TYPE_SIZE |
1 |
public static final int |
VERSION_NONE |
0 |
public static final int |
WRITE_ROWS_EVENT |
23 |
public static final int |
XID_EVENT |
16 |
| com.continuent.tungsten.replicator.heartbeat.HeartbeatTable | ||
|---|---|---|
public static final java.lang.String |
TABLE_NAME |
"heartbeat" |
| com.continuent.tungsten.replicator.management.OpenReplicatorManager | ||
|---|---|---|
public static final int |
FLUSH |
2 |
public static final int |
MAJOR |
1 |
public static final int |
MINOR |
0 |
public static final int |
REPL |
1 |
public static final java.lang.String |
SUFFIX |
"beta5" |
| com.continuent.tungsten.replicator.management.OpenReplicatorManagerMBean | ||
|---|---|---|
public static final int |
signalConfigured |
3 |
public static final int |
signalConsistencyFail |
6 |
public static final int |
signalError |
7 |
public static final int |
signalOfflineReached |
1 |
public static final int |
signalRestored |
5 |
public static final int |
signalShutdown |
2 |
public static final int |
signalSynced |
4 |
| com.continuent.tungsten.replicator.management.OpenReplicatorPlugin | ||
|---|---|---|
public static final java.lang.String |
STATUS_APPLIED_LATENCY |
"applied-latency" |
public static final java.lang.String |
STATUS_ERRMSG |
"errmsg" |
public static final java.lang.String |
STATUS_LAST_APPLIED |
"last-applied" |
public static final java.lang.String |
STATUS_LAST_RECEIVED |
"last-received" |
public static final java.lang.String |
STATUS_LAST_SENT |
"last-sent" |
public static final java.lang.String |
STATUS_ROLE |
"role" |
| com.continuent.tungsten.replicator.management.ReplicationServiceManager | ||
|---|---|---|
public static final java.lang.String |
CONFIG_FILE_PREFIX |
"static-" |
public static final java.lang.String |
CONFIG_FILE_SUFFIX |
".properties" |
public static final java.lang.String |
CONFIG_SERVICES |
"services.properties" |
| com.continuent.tungsten.replicator.management.script.ScriptPlugin | ||
|---|---|---|
public static final java.lang.String |
ARG_URI |
"uri" |
| com.continuent.tungsten.replicator.pipeline.Schedule | ||
|---|---|---|
public static final int |
CONTINUE_NEXT |
3 |
public static final int |
CONTINUE_NEXT_COMMIT |
4 |
public static final int |
PROCEED |
1 |
public static final int |
QUIT |
2 |
| com.continuent.tungsten.replicator.shard.ShardTable | ||
|---|---|---|
public static final java.lang.String |
SHARD_CRIT_COL |
"critical" |
public static final java.lang.String |
SHARD_ID_COL |
"shard_id" |
public static final java.lang.String |
SHARD_MASTER_COL |
"master" |
public static final java.lang.String |
TABLE_NAME |
"trep_shard" |
| com.continuent.tungsten.replicator.thl.CommitSeqnoTable | ||
|---|---|---|
public static final java.lang.String |
TABLE_NAME |
"trep_commit_seqno" |
| com.continuent.tungsten.replicator.thl.ProtocolParams | ||
|---|---|---|
public static final java.lang.String |
INIT_EVENT_ID |
"extractFromId" |
public static final java.lang.String |
RMI_HOST |
"rmiHost" |
public static final java.lang.String |
RMI_PORT |
"rmiPort" |
| com.continuent.tungsten.replicator.thl.THL | ||
|---|---|---|
public static final int |
MAJOR |
1 |
public static final int |
MINOR |
3 |
public static final java.lang.String |
PLAINTEXT_URI_SCHEME |
"thl" |
public static final java.lang.String |
SSL_URI_SCHEME |
"thls" |
public static final java.lang.String |
SUFFIX |
"" |
| com.continuent.tungsten.replicator.thl.THLCommands | ||
|---|---|---|
public static final java.lang.String |
HELP |
"help" |
public static final java.lang.String |
INFO |
"info" |
public static final java.lang.String |
LIST |
"list" |
public static final java.lang.String |
PURGE |
"purge" |
public static final java.lang.String |
SKIP |
"skip" |
| com.continuent.tungsten.replicator.thl.THLEvent | ||
|---|---|---|
public static final short |
HEARTBEAT_EVENT |
3 |
public static final short |
REPL_DBMS_EVENT |
0 |
public static final short |
START_MASTER_EVENT |
1 |
public static final short |
STOP_MASTER_EVENT |
2 |
| com.continuent.tungsten.replicator.thl.log.LogFile | ||
|---|---|---|
public static final int |
HEADER_LENGTH |
16 |
public static final int |
NO_WAIT |
0 |
| com.continuent.tungsten.replicator.thl.log.LogRecord | ||
|---|---|---|
public static final byte |
CRC_TYPE_32 |
1 |
public static final byte |
CRC_TYPE_NONE |
0 |
public static final byte |
EVENT_REPL |
1 |
public static final byte |
EVENT_ROTATE |
2 |
public static final int |
NON_DATA_BYTES |
13 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.Header | ||
|---|---|---|
public static final int |
EPOCHNUMBER_FIELD_NUMBER |
7 |
public static final int |
EVENTID_FIELD_NUMBER |
8 |
public static final int |
EXTRACTEDTSTAMP_FIELD_NUMBER |
5 |
public static final int |
FILTEREDEVENT_FIELD_NUMBER |
10 |
public static final int |
FRAGNO_FIELD_NUMBER |
2 |
public static final int |
FRAGNOEND_FIELD_NUMBER |
12 |
public static final int |
LASTFRAG_FIELD_NUMBER |
3 |
public static final int |
SEQNO_FIELD_NUMBER |
1 |
public static final int |
SEQNOEND_FIELD_NUMBER |
11 |
public static final int |
SHARDID_FIELD_NUMBER |
9 |
public static final int |
SOURCEID_FIELD_NUMBER |
6 |
public static final int |
SOURCETSTAMP_FIELD_NUMBER |
4 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufEventOption | ||
|---|---|---|
public static final int |
NAME_FIELD_NUMBER |
1 |
public static final int |
VALUE_FIELD_NUMBER |
2 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufLoadDataFileDelete | ||
|---|---|---|
public static final int |
INT32_FIELD_NUMBER |
1 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufLoadDataFileFragment | ||
|---|---|---|
public static final int |
DATA_FIELD_NUMBER |
2 |
public static final int |
DATABASE_FIELD_NUMBER |
3 |
public static final int |
FILEID_FIELD_NUMBER |
1 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufLoadDataFileQuery | ||
|---|---|---|
public static final int |
FILEID_FIELD_NUMBER |
2 |
public static final int |
FILENAMEENDPOS_FIELD_NUMBER |
4 |
public static final int |
FILENAMESTARTPOS_FIELD_NUMBER |
3 |
public static final int |
STATEMENT_FIELD_NUMBER |
1 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufOneChange | ||
|---|---|---|
public static final int |
DATA_FIELD_NUMBER |
2 |
public static final int |
FILEDELETE_FIELD_NUMBER |
7 |
public static final int |
FILEFRAGMENT_FIELD_NUMBER |
5 |
public static final int |
FILEQUERY_FIELD_NUMBER |
6 |
public static final int |
ROWID_FIELD_NUMBER |
4 |
public static final int |
STATEMENT_FIELD_NUMBER |
3 |
public static final int |
TYPE_FIELD_NUMBER |
1 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufOneRowChange | ||
|---|---|---|
public static final int |
ACTION_FIELD_NUMBER |
3 |
public static final int |
COLUMNSPEC_FIELD_NUMBER |
5 |
public static final int |
COLUMNVALUES_FIELD_NUMBER |
7 |
public static final int |
KEYSPEC_FIELD_NUMBER |
4 |
public static final int |
KEYVALUES_FIELD_NUMBER |
6 |
public static final int |
SCHEMANAME_FIELD_NUMBER |
1 |
public static final int |
TABLEID_FIELD_NUMBER |
8 |
public static final int |
TABLENAME_FIELD_NUMBER |
2 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufOneRowChange.ProtobufColumnSpec | ||
|---|---|---|
public static final int |
INDEX_FIELD_NUMBER |
1 |
public static final int |
LENGTH_FIELD_NUMBER |
5 |
public static final int |
NAME_FIELD_NUMBER |
2 |
public static final int |
NOTNULL_FIELD_NUMBER |
6 |
public static final int |
SIGNED_FIELD_NUMBER |
4 |
public static final int |
TYPE_FIELD_NUMBER |
3 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufOneRowChange.ProtobufRowValue | ||
|---|---|---|
public static final int |
COLUMNVALUE_FIELD_NUMBER |
1 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufOneRowChange.ProtobufRowValue.ProtobufColumnVal | ||
|---|---|---|
public static final int |
BYTESVALUE_FIELD_NUMBER |
7 |
public static final int |
DOUBLEVALUE_FIELD_NUMBER |
5 |
public static final int |
FLOATVALUE_FIELD_NUMBER |
4 |
public static final int |
INTVALUE_FIELD_NUMBER |
2 |
public static final int |
LONGVALUE_FIELD_NUMBER |
3 |
public static final int |
STRINGVALUE_FIELD_NUMBER |
6 |
public static final int |
TYPE_FIELD_NUMBER |
1 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufReplDBMSEvent | ||
|---|---|---|
public static final int |
CHANGE_FIELD_NUMBER |
1 |
public static final int |
METADATA_FIELD_NUMBER |
2 |
public static final int |
OPTIONS_FIELD_NUMBER |
3 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufRowChangeData | ||
|---|---|---|
public static final int |
OPTIONS_FIELD_NUMBER |
2 |
public static final int |
ROWCHANGE_FIELD_NUMBER |
1 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufRowIdData | ||
|---|---|---|
public static final int |
ID_FIELD_NUMBER |
1 |
public static final int |
TYPE_FIELD_NUMBER |
2 |
| com.continuent.tungsten.replicator.thl.protobuf.TungstenProtos.ProtobufStatementData | ||
|---|---|---|
public static final int |
DEFAULTSCHEMA_FIELD_NUMBER |
1 |
public static final int |
ERRORCODE_FIELD_NUMBER |
5 |
public static final int |
OPTIONS_FIELD_NUMBER |
4 |
public static final int |
QUERY_FIELD_NUMBER |
3 |
public static final int |
QUERYBYTES_FIELD_NUMBER |
6 |
public static final int |
TIMESTAMP_FIELD_NUMBER |
2 |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||