dispatcher

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

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

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.