Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrListenerCreat = errors.New("create slave internal_control_types listener fail") ErrSlaveControllerCreat = errors.New("create slave controller fail") ErrInvalidConnectionRequest = errors.New("invalid internal_connect_types request") ErrEstablishCtrlConnInvalidRequest = errors.New("invalid establish ctrl internal_connect_types request") ErrEstablishCtrlConnStepFail = errors.New("establish ctrl internal_connect_types step fail") ErrEstablishDataConnInvalidRequest = errors.New("invalid establish internal_data_types internal_connect_types request") ErrEstablishDataConnStepFail = errors.New("establish internal_data_types internal_connect_types step fail") ErrReconnectCtrlConnInvalidRequest = errors.New("invalid reconnect ctrl internal_connect_types request") ErrReconnectCtrlConnStepFail = errors.New("reconnect ctrl internal_connect_types step fail") )
Functions ¶
This section is empty.
Types ¶
type CreateSlaveControllerBody ¶
type CreateSlaveControllerBody struct {
SlaveControlListenerPort string
RedisDAO *redis_util.RedisDAO
Db *leveldb.DB
OperationResponseChan chan *operation.OperationResponse
}
type SlaveController ¶
type SlaveController struct {
// contains filtered or unexported fields
}
func NewSlaveController ¶
func NewSlaveController(cscb CreateSlaveControllerBody) (*SlaveController, error)
func (*SlaveController) GetSlaveCtrlBlk ¶
func (sc *SlaveController) GetSlaveCtrlBlk(slaveID string) (*slave_control_block.SlaveControlBlock, bool)
func (*SlaveController) Reload ¶
func (sc *SlaveController) Reload() error
func (*SlaveController) SlaveDelete ¶
func (sc *SlaveController) SlaveDelete(uuid string) error
func (*SlaveController) Start ¶
func (sc *SlaveController) Start()
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.