Documentation ¶
Index ¶
- Variables
- type SlaveControlBlock
- func (scb *SlaveControlBlock) Delete()
- func (scb *SlaveControlBlock) GetLastHeartbeatTime() (t time.Time)
- func (scb *SlaveControlBlock) GetStatus() types.StatsSlave
- func (scb *SlaveControlBlock) GetToken() string
- func (scb *SlaveControlBlock) GetUUID() string
- func (scb *SlaveControlBlock) ResetCtrl(ctrlConn net.Conn, ctrlEncoder *json.Encoder, ctrlDecoder *json.Decoder)
- func (scb *SlaveControlBlock) SendDataContainerCreateMsg(msg internal_data_types.ContainerCreateMessage) error
- func (scb *SlaveControlBlock) SendDataContainerRemoveMsg(msg internal_data_types.ContainerRemoveMessage) error
- func (scb *SlaveControlBlock) SendDataContainerStartMsg(msg internal_data_types.ContainerStartMessage) error
- func (scb *SlaveControlBlock) SendDataContainerStopMsg(msg internal_data_types.ContainerStopMessage) error
- func (scb *SlaveControlBlock) SetCtrlConn(c net.Conn)
- func (scb *SlaveControlBlock) SetCtrlEncoderDecoder(e *json.Encoder, d *json.Decoder)
- func (scb *SlaveControlBlock) SetDataConn(c net.Conn)
- func (scb *SlaveControlBlock) SetDataEncoderDecoder(e *json.Encoder, d *json.Decoder)
- func (scb *SlaveControlBlock) SetLastHeartbeatTime(t time.Time)
- func (scb *SlaveControlBlock) SetStatus(statusSlave types.StatsSlave)
- func (scb *SlaveControlBlock) Start()
- func (scb *SlaveControlBlock) StopWork()
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type SlaveControlBlock ¶
type SlaveControlBlock struct { RedisDAO *redis_util.RedisDAO // contains filtered or unexported fields }
func NewWithCtrl ¶
func NewWithCtrl(uuid, token string, ctrlConn net.Conn, ctrlEncoder *json.Encoder, ctrlDecoder *json.Decoder, operationResponseChan chan *operation.OperationResponse, redisDAO *redis_util.RedisDAO) *SlaveControlBlock
func NewWithReload ¶
func NewWithReload(uuid, token string, operationResponseChan chan *operation.OperationResponse, redisDAO *redis_util.RedisDAO) *SlaveControlBlock
func (*SlaveControlBlock) Delete ¶
func (scb *SlaveControlBlock) Delete()
func (*SlaveControlBlock) GetLastHeartbeatTime ¶
func (scb *SlaveControlBlock) GetLastHeartbeatTime() (t time.Time)
func (*SlaveControlBlock) GetStatus ¶
func (scb *SlaveControlBlock) GetStatus() types.StatsSlave
func (*SlaveControlBlock) GetToken ¶
func (scb *SlaveControlBlock) GetToken() string
func (*SlaveControlBlock) GetUUID ¶
func (scb *SlaveControlBlock) GetUUID() string
func (*SlaveControlBlock) SendDataContainerCreateMsg ¶
func (scb *SlaveControlBlock) SendDataContainerCreateMsg(msg internal_data_types.ContainerCreateMessage) error
func (*SlaveControlBlock) SendDataContainerRemoveMsg ¶
func (scb *SlaveControlBlock) SendDataContainerRemoveMsg(msg internal_data_types.ContainerRemoveMessage) error
func (*SlaveControlBlock) SendDataContainerStartMsg ¶
func (scb *SlaveControlBlock) SendDataContainerStartMsg(msg internal_data_types.ContainerStartMessage) error
func (*SlaveControlBlock) SendDataContainerStopMsg ¶
func (scb *SlaveControlBlock) SendDataContainerStopMsg(msg internal_data_types.ContainerStopMessage) error
func (*SlaveControlBlock) SetCtrlConn ¶
func (scb *SlaveControlBlock) SetCtrlConn(c net.Conn)
func (*SlaveControlBlock) SetCtrlEncoderDecoder ¶
func (scb *SlaveControlBlock) SetCtrlEncoderDecoder(e *json.Encoder, d *json.Decoder)
func (*SlaveControlBlock) SetDataConn ¶
func (scb *SlaveControlBlock) SetDataConn(c net.Conn)
func (*SlaveControlBlock) SetDataEncoderDecoder ¶
func (scb *SlaveControlBlock) SetDataEncoderDecoder(e *json.Encoder, d *json.Decoder)
func (*SlaveControlBlock) SetLastHeartbeatTime ¶
func (scb *SlaveControlBlock) SetLastHeartbeatTime(t time.Time)
func (*SlaveControlBlock) SetStatus ¶
func (scb *SlaveControlBlock) SetStatus(statusSlave types.StatsSlave)
func (*SlaveControlBlock) Start ¶
func (scb *SlaveControlBlock) Start()
func (*SlaveControlBlock) StopWork ¶
func (scb *SlaveControlBlock) StopWork()
Click to show internal directories.
Click to hide internal directories.