slave_controller

Documentation

Index

• Variables
• type CreateSlaveControllerBody
• type SlaveController
  • func NewSlaveController(cscb CreateSlaveControllerBody) (*SlaveController, error)
  • func (sc *SlaveController) GetSlaveCtrlBlk(slaveID string) (*slave_control_block.SlaveControlBlock, bool)
  • func (sc *SlaveController) Reload() error
  • func (sc *SlaveController) SlaveDelete(uuid string) error
  • func (sc *SlaveController) Start()

Variables

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")
)

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()