slave_control_block

package

v0.0.0-...-2e1a402 Latest Latest Go to latest Published: Dec 22, 2021 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/PenguinCats/Unison-Elastic-Compute

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type SlaveControlBlock
- func NewWithCtrl(uuid, token string, ctrlConn net.Conn, ctrlEncoder *json.Encoder, ...) *SlaveControlBlock
- func NewWithReload(uuid, token string, operationResponseChan chan *operation.OperationResponse, ...) *SlaveControlBlock

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrJsonEncode = errors.New("json encode error")

	ErrSendDataMsg = errors.New("send data message fail")

	ErrSendCtrlMsg = errors.New("send control message fail")
)

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) ResetCtrl ¶

func (scb *SlaveControlBlock) ResetCtrl(ctrlConn net.Conn, ctrlEncoder *json.Encoder, ctrlDecoder *json.Decoder)

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL