contrabase.api
Class ContrabaseConnector

java.lang.Object
  extended by contrabase.api.ContrabaseConnector

public class ContrabaseConnector
extends java.lang.Object

API가 Contrabase에 접속하기 위해서 필요한 클래스

Author:
Jong10

Field Summary
private  long clientId
           
private  contrabase.network.ClientSide connection
           
private  java.lang.String password
           
private  java.lang.String userId
           
 
Constructor Summary
ContrabaseConnector(java.lang.String ip, int port, java.lang.String userId, java.lang.String password)
          서버와의 새 연결을 만든다.
 
Method Summary
 void close()
          연결을 끊어준다.
private  contrabase.network.Message createActionMessage(java.lang.String action, java.lang.String tableName)
          테이블 조작하는 메시지를 생성한다.
 Table createTable(java.lang.String tableName)
          새 테이블을 만든다.
 void deleteTable(java.lang.String tableName)
          테이블을 지운다.
 void finalize()
           
 java.util.Map<java.lang.String,java.lang.Long> getDataByAction(java.lang.String action)
           
 Table getOrCreateTable(java.lang.String tableName)
          테이블을 가져오거나, 없으면 생성한다.
 java.util.List<java.lang.String> getRepositoryList()
           
 Table getTable(java.lang.String tableName)
          기존의 테이블을 가져온다.
 java.util.List<java.lang.String> getTableList()
          Monitoring Tool에서 사용하기 위한 Table List를 가져온다.
 void loadBalanceAllTables()
           
private  void open(java.lang.String ip, int port)
          마스터와 새 연결을 생성한다.
 
Methods inherited from class java.lang.Object
clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

connection

private contrabase.network.ClientSide connection

userId

private java.lang.String userId

password

private java.lang.String password

clientId

private long clientId
Constructor Detail

ContrabaseConnector

public ContrabaseConnector(java.lang.String ip,
                           int port,
                           java.lang.String userId,
                           java.lang.String password)
                    throws contrabase.network.ContrabaseNetworkException
서버와의 새 연결을 만든다.

Parameters:
ip - 서버의 아이피
port - 서버의 포트
Throws:
contrabase.network.ContrabaseNetworkException
Method Detail

open

private void open(java.lang.String ip,
                  int port)
           throws contrabase.network.ContrabaseNetworkException
마스터와 새 연결을 생성한다.

Parameters:
ip - 마스터의 IP 주소
port - 마스터의 포트
Throws:
contrabase.network.ContrabaseNetworkException

close

public void close()
           throws contrabase.network.ContrabaseNetworkException
연결을 끊어준다.

Throws:
contrabase.network.ContrabaseNetworkException

finalize

public void finalize()
Overrides:
finalize in class java.lang.Object

getTableList

public java.util.List<java.lang.String> getTableList()
                                              throws contrabase.network.ContrabaseNetworkException
Monitoring Tool에서 사용하기 위한 Table List를 가져온다.

Returns:
Throws:
contrabase.network.ContrabaseNetworkException

getRepositoryList

public java.util.List<java.lang.String> getRepositoryList()
                                                   throws contrabase.network.ContrabaseNetworkException
Throws:
contrabase.network.ContrabaseNetworkException

getDataByAction

public java.util.Map<java.lang.String,java.lang.Long> getDataByAction(java.lang.String action)
                                                               throws contrabase.network.ContrabaseNetworkException
Throws:
contrabase.network.ContrabaseNetworkException

getOrCreateTable

public Table getOrCreateTable(java.lang.String tableName)
                       throws contrabase.network.ContrabaseNetworkException
테이블을 가져오거나, 없으면 생성한다.

Parameters:
tableName -
Returns:
Throws:
contrabase.network.ContrabaseNetworkException

createTable

public Table createTable(java.lang.String tableName)
                  throws contrabase.network.ContrabaseNetworkException
새 테이블을 만든다.

Parameters:
tableName -
Returns:
Throws:
contrabase.network.ContrabaseNetworkException

getTable

public Table getTable(java.lang.String tableName)
               throws contrabase.network.ContrabaseNetworkException
기존의 테이블을 가져온다. 마스터에 해당 테이블이 있는지 확인한다.

Parameters:
tableName -
Returns:
Throws:
contrabase.network.ContrabaseNetworkException

deleteTable

public void deleteTable(java.lang.String tableName)
                 throws contrabase.network.ContrabaseNetworkException
테이블을 지운다.

Parameters:
tableName -
Throws:
contrabase.network.ContrabaseNetworkException

createActionMessage

private contrabase.network.Message createActionMessage(java.lang.String action,
                                                       java.lang.String tableName)
테이블 조작하는 메시지를 생성한다.

Parameters:
tableName -
Returns:
생성된 메시지의 인스턴스를 넘겨준다.

loadBalanceAllTables

public void loadBalanceAllTables()
                          throws contrabase.network.ContrabaseNetworkException
Throws:
contrabase.network.ContrabaseNetworkException