dispatcher

Documentation

Index

• type GrpcDispatcher
  • func (d *GrpcDispatcher) CancelJob(name string, jobDetailID int) (*api.AlineMessage, error)
  • func (d *GrpcDispatcher) CancelJobWithNode(name string, jobDetailID int, node *model.Node) *api.AlineMessage
  • func (d *GrpcDispatcher) DispatchNode() (*model.Node, error)
  • func (d *GrpcDispatcher) GetJobLatestNode(name string, id int) (*model.Node, error)
  • func (d *GrpcDispatcher) GetJobNode(name string, jobDetailID int) []*model.Node
  • func (d *GrpcDispatcher) GetJobStatus(name string, id int) (*api.AlineMessage, error)
  • func (d *GrpcDispatcher) HealthcheckNode(node *model.Node)
  • func (d *GrpcDispatcher) IsValidNode(n string) bool
  • func (d *GrpcDispatcher) Ping(node *model.Node) error
  • func (d *GrpcDispatcher) Register(node *model.Node) error
  • func (d *GrpcDispatcher) SendJob(name, yamlString string, jobDetailID int, node *model.Node) *api.AlineMessage
  • func (d *GrpcDispatcher) UnRegister(node *model.Node) error
  • func (d *GrpcDispatcher) UnRegisterWithKey(key string) error
• type IDispatcher
  • func NewGrpcDispatcher() IDispatcher
• type NodeInfo
• type Poller

Types

type GrpcDispatcher

type GrpcDispatcher struct {
	JobNodeMap sync.Map // key: jobname(id), value: []*node // 记录任务和节点的对应关系，用来取消任务，value 是一个数组，用来记录任务在哪些节点上执行过
	// contains filtered or unexported fields
}

func (*GrpcDispatcher) CancelJob

func (d *GrpcDispatcher) CancelJob(name string, jobDetailID int) (*api.AlineMessage, error)

func (*GrpcDispatcher) CancelJobWithNode

func (d *GrpcDispatcher) CancelJobWithNode(name string, jobDetailID int, node *model.Node) *api.AlineMessage

CancelJobWithNode 取消任务通过指定节点

func (*GrpcDispatcher) DispatchNode

func (d *GrpcDispatcher) DispatchNode() (*model.Node, error)

DispatchNode 选择节点

func (*GrpcDispatcher) GetJobLatestNode

func (d *GrpcDispatcher) GetJobLatestNode(name string, id int) (*model.Node, error)

func (*GrpcDispatcher) GetJobNode

func (d *GrpcDispatcher) GetJobNode(name string, jobDetailID int) []*model.Node

GetJobNode 获取任务执行节点

func (*GrpcDispatcher) GetJobStatus

func (d *GrpcDispatcher) GetJobStatus(name string, id int) (*api.AlineMessage, error)

func (*GrpcDispatcher) HealthcheckNode

func (d *GrpcDispatcher) HealthcheckNode(node *model.Node)

HealthcheckNode 检查节点心跳

func (*GrpcDispatcher) IsValidNode

func (d *GrpcDispatcher) IsValidNode(n string) bool

func (*GrpcDispatcher) Ping

func (d *GrpcDispatcher) Ping(node *model.Node) error

Ping 节点心跳

func (*GrpcDispatcher) Register

func (d *GrpcDispatcher) Register(node *model.Node) error

Register 节点注册

func (*GrpcDispatcher) SendJob

func (d *GrpcDispatcher) SendJob(name, yamlString string, jobDetailID int, node *model.Node) *api.AlineMessage

SendJob 发送任务

func (*GrpcDispatcher) UnRegister

func (d *GrpcDispatcher) UnRegister(node *model.Node) error

UnRegister 节点注销

func (*GrpcDispatcher) UnRegisterWithKey

func (d *GrpcDispatcher) UnRegisterWithKey(key string) error

type IDispatcher

type IDispatcher interface {
	// DispatchNode 选择节点
	DispatchNode() (*model.Node, error)
	// Register 节点注册
	Register(node *model.Node) error
	// UnRegister 节点注销
	UnRegister(node *model.Node) error
	UnRegisterWithKey(key string) error
	// Ping 节点 ping
	Ping(node *model.Node) error
	// HealthcheckNode 检查节点心跳
	HealthcheckNode(node *model.Node)
	// SendJob 发送任务
	SendJob(name, yamlString string, jobDetailID int, node *model.Node) *api.AlineMessage
	// CancelJob 取消任务
	CancelJob(name string, jobDetailID int) (*api.AlineMessage, error)
	// CancelJobWithNode 通过指定节点取消任务
	CancelJobWithNode(name string, jobDetailID int, node *model.Node) *api.AlineMessage
	GetJobStatus(name string, jobDetailID int) (*api.AlineMessage, error)
	// IsValidNode 判断有没有这个节点
	IsValidNode(n string) bool
}

func NewGrpcDispatcher

func NewGrpcDispatcher() IDispatcher

type NodeInfo

type NodeInfo struct {
	// contains filtered or unexported fields
}

type Poller

type Poller struct {
	// contains filtered or unexported fields
}

Poller 轮询器