cluster

Documentation

Overview

* @Author: SpenserCai * @Date: 2023-08-16 15:25:34 * @version: * @LastEditors: SpenserCai * @LastEditTime: 2023-08-18 13:04:35 * @Description: file content

* @Author: SpenserCai * @Date: 2023-08-16 15:17:45 * @version: * @LastEditors: SpenserCai * @LastEditTime: 2023-08-18 13:04:46 * @Description: file content

Index

• type ClusterNode
  • func NewClusterNode(name string, actionQueue *queue.ActionQueue, ...) *ClusterNode
• type ClusterService
  • func NewClusterService(cfg *config.Config) *ClusterService
  • func (c *ClusterService) CancelTask(id string)
  • func (c *ClusterService) GetEvent() queue.EventMessage
  • func (c *ClusterService) GetNode(name string) *ClusterNode
  • func (c *ClusterService) GetNodeAuto() *ClusterNode
  • func (c *ClusterService) PreProcessEvent()
  • func (c *ClusterService) Start()

Types

type ClusterNode

type ClusterNode struct {
	Name         string
	ActionQueue  *queue.ActionQueue
	StableClient *webui.StableDiffInterface
}

func NewClusterNode

func NewClusterNode(name string, actionQueue *queue.ActionQueue, stableClient *webui.StableDiffInterface) *ClusterNode

type ClusterService

type ClusterService struct {
	Nodes                 []*ClusterNode
	NodeEventQueue        chan queue.EventMessage
	GlobalEventQueue      chan queue.EventMessage
	NodesTaskMap          map[string]*ClusterNode
	Cfg                   *config.Config
	PreProcessEventStatus bool
}

func NewClusterService

func NewClusterService(cfg *config.Config) *ClusterService

func (*ClusterService) CancelTask

func (c *ClusterService) CancelTask(id string)

func (*ClusterService) GetEvent

func (c *ClusterService) GetEvent() queue.EventMessage

func (*ClusterService) GetNode

func (c *ClusterService) GetNode(name string) *ClusterNode

func (*ClusterService) GetNodeAuto

func (c *ClusterService) GetNodeAuto() *ClusterNode

func (*ClusterService) PreProcessEvent

func (c *ClusterService) PreProcessEvent()

func (*ClusterService) Start

func (c *ClusterService) Start()