dispatcher

package

v1.0.3 Latest Latest Go to latest Published: Jul 28, 2023 License: GPL-3.0 Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hamster-shared/aline-engine

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type GrpcDispatcher ¶ added in v1.0.3

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

func (*GrpcDispatcher) CancelJob ¶ added in v1.0.3

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

func (*GrpcDispatcher) CancelJobWithNode ¶ added in v1.0.3

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

CancelJobWithNode 取消任务通过指定节点

func (*GrpcDispatcher) DispatchNode ¶ added in v1.0.3

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

DispatchNode 选择节点

func (*GrpcDispatcher) GetJobLatestNode ¶ added in v1.0.3

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

func (*GrpcDispatcher) GetJobNode ¶ added in v1.0.3

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

GetJobNode 获取任务执行节点

func (*GrpcDispatcher) GetJobStatus ¶ added in v1.0.3

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

func (*GrpcDispatcher) HealthcheckNode ¶ added in v1.0.3

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

HealthcheckNode 检查节点心跳

func (*GrpcDispatcher) IsValidNode ¶ added in v1.0.3

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

func (*GrpcDispatcher) Ping ¶ added in v1.0.3

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

Ping 节点心跳

func (*GrpcDispatcher) Register ¶ added in v1.0.3

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

Register 节点注册

func (*GrpcDispatcher) SendJob ¶ added in v1.0.3

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

SendJob 发送任务

func (*GrpcDispatcher) UnRegister ¶ added in v1.0.3

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

UnRegister 节点注销

func (*GrpcDispatcher) UnRegisterWithKey ¶ added in v1.0.3

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 ¶ added in v1.0.3

func NewGrpcDispatcher() IDispatcher

type NodeInfo ¶ added in v1.0.3

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

type Poller ¶ added in v1.0.3

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

Poller 轮询器

Source Files ¶

View all Source files

dispatcher.go

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