Documentation
¶
Index ¶
- func AddConnectRequest(req types.RequestConnect)
- func AddContainer(container_id string, client_id string, container *types.Container)
- func AddService(service_id string, client_id string, service *types.Service)
- func DeleteContainer(container_id string)
- func DeleteService(service_id string)
- func Disconnect(client_id string)
- func FetchLowestDemandClient() (types.Client, error)
- func FlushContainer(client_id string)
- func FlushService(client_id string)
- func GetClient(client_id string) *types.Client
- func GetClientStatus(client_id string) (types.ClientStatus, error)
- func GetConnectRequest() types.RequestConnect
- func GetContainer(container_id string) (*types.Container, string, error)
- func GetService(service_id string) (*types.Service, string, error)
- func RegisterOnNodeConnect(f KisaraOnNodeConnect)
- func RegisterOnNodeDisconnect(f KisaraOnNodeDisconnect)
- func RegisterOnNodeHeartBeat(f KisaraOnNodeHeartBeat)
- func RegisterOnNodeLaunchContainer(f KisaraOnNodeLaunchContainer)
- func RegisterOnNodeStopContainer(f KisaraOnNodeStopContainer)
- func RegisterOnServiceStart(f KisaraOnServiceStart)
- func RegisterOnServiceStop(f KisaraOnServiceStop)
- func Server(show_log ...bool)
- func UnsetOnNodeConnect()
- func UnsetOnNodeDisconnect()
- func UnsetOnNodeHeartBeat()
- func UnsetOnNodeLaunchContainer()
- func UnsetOnNodeStopContainer()
- func UnsetOnServiceStart()
- func UnsetOnServiceStop()
- func UpdateClientContainer(client_id string) error
- func UpdateClientStatus(client_id string, status types.ClientStatus) error
- func UpdateHeartBeat(client_id string) error
- type ClientItem
- type ContainerItem
- type KisaraOnNodeConnect
- type KisaraOnNodeDisconnect
- type KisaraOnNodeHeartBeat
- type KisaraOnNodeLaunchContainer
- type KisaraOnNodeStopContainer
- type KisaraOnServiceStart
- type KisaraOnServiceStop
- type ServiceItem
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddConnectRequest ¶
func AddConnectRequest(req types.RequestConnect)
func AddContainer ¶
func DeleteContainer ¶
func DeleteContainer(container_id string)
func DeleteService ¶
func DeleteService(service_id string)
func Disconnect ¶
func Disconnect(client_id string)
func FetchLowestDemandClient ¶
func FlushContainer ¶
func FlushContainer(client_id string)
func FlushService ¶
func FlushService(client_id string)
func GetClientStatus ¶
func GetClientStatus(client_id string) (types.ClientStatus, error)
func GetConnectRequest ¶
func GetConnectRequest() types.RequestConnect
func RegisterOnNodeConnect ¶
func RegisterOnNodeConnect(f KisaraOnNodeConnect)
func RegisterOnNodeDisconnect ¶
func RegisterOnNodeDisconnect(f KisaraOnNodeDisconnect)
func RegisterOnNodeHeartBeat ¶
func RegisterOnNodeHeartBeat(f KisaraOnNodeHeartBeat)
func RegisterOnNodeLaunchContainer ¶
func RegisterOnNodeLaunchContainer(f KisaraOnNodeLaunchContainer)
func RegisterOnNodeStopContainer ¶
func RegisterOnNodeStopContainer(f KisaraOnNodeStopContainer)
func RegisterOnServiceStart ¶
func RegisterOnServiceStart(f KisaraOnServiceStart)
func RegisterOnServiceStop ¶
func RegisterOnServiceStop(f KisaraOnServiceStop)
func Server ¶
func Server(show_log ...bool)
Server is the main function of the synergy server, it's non-blocking, call it directly without goroutine
func UnsetOnNodeConnect ¶
func UnsetOnNodeConnect()
func UnsetOnNodeDisconnect ¶
func UnsetOnNodeDisconnect()
func UnsetOnNodeHeartBeat ¶
func UnsetOnNodeHeartBeat()
func UnsetOnNodeLaunchContainer ¶
func UnsetOnNodeLaunchContainer()
func UnsetOnNodeStopContainer ¶
func UnsetOnNodeStopContainer()
func UnsetOnServiceStart ¶
func UnsetOnServiceStart()
func UnsetOnServiceStop ¶
func UnsetOnServiceStop()
func UpdateClientContainer ¶
func UpdateClientStatus ¶
func UpdateClientStatus(client_id string, status types.ClientStatus) error
func UpdateHeartBeat ¶
Types ¶
type ClientItem ¶
type ClientItem struct {
ClientID string
Client *types.Client
ClientStatus *types.ClientStatus
LastHeartBeat time.Time
}
func GetNodes ¶
func GetNodes() []ClientItem
func (*ClientItem) GetDemand ¶
func (c *ClientItem) GetDemand() (float64, error)
TODO: currently, this function is too simple.
type ContainerItem ¶
type KisaraOnNodeConnect ¶
type KisaraOnNodeDisconnect ¶
type KisaraOnNodeHeartBeat ¶
type KisaraOnNodeHeartBeat func(client_id string, client *types.Client, status *types.ClientStatus)
type KisaraOnServiceStart ¶
type KisaraOnServiceStop ¶
Source Files
Click to show internal directories.
Click to hide internal directories.