node

type Node ¶

type Node struct {
	Mode     *NodeMode
	Options  *Options
	Name     string
	Register *register.Register

	Scheduler     *scheduler.Scheduler
	StatusManager *manager_status.Manager
	// contains filtered or unexported fields
}

Node represents a node instance Running pipeline, reporting status, etc. if it becomes the master node, it will run tasks such as scheduling pipeline, monitoring, event management, etc

func New(opts ...Option) (node *Node)

func (n *Node) Run(ctx context.Context) (err error)

type NodeMode ¶

type NodeMode byte

const (
	MODE_CLUSTER NodeMode = 1
	MODE_SINGLE  NodeMode = 2
)

func (n NodeMode) String() string

type Option ¶

type Option func(options *Options)

Option function config Options

func OptionNode(node *node.Node) Option

type Options ¶

type Options struct {
	Node *node.Node
}

Options Node's options