node

Documentation

Index

• type Node
  • func New(options *Options) (node *Node)
  • func (n *Node) Close()
  • func (n *Node) CompleteClose()
  • func (n *Node) Run(ctx context.Context) (err error)
• type NodeMode
• type Option
• type Options
• type Register
  • func NewRegister(log *logrus.Entry, n *node.Node) *Register
  • func (r *Register) Close()
  • func (r *Register) Closed() chan struct{}
  • func (r *Register) CompleteClose()
  • func (r *Register) Run(ctx context.Context) error

Types

type Node

type Node struct {
	Mode    *NodeMode
	Options *Options
	Name    string
	// Register *register.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

func New(options *Options) (node *Node)

New return a new node

func (*Node) Close

func (n *Node) Close()

func (*Node) CompleteClose

func (n *Node) CompleteClose()

func (*Node) Run

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

Run start working

type NodeMode

type NodeMode byte

const (
	MODE_CLUSTER NodeMode = 1
	MODE_SINGLE  NodeMode = 2
)

type Option

type Option func(options *Options)

Option function config Options

type Options

type Options struct {
	Node *node.Node
	Log  *logrus.Entry
}

Options Node's options

type Register

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

func NewRegister

func NewRegister(log *logrus.Entry, n *node.Node) *Register

func (*Register) Close

func (r *Register) Close()

func (*Register) Closed

func (r *Register) Closed() chan struct{}

func (*Register) CompleteClose

func (r *Register) CompleteClose()

func (*Register) Run

func (r *Register) Run(ctx context.Context) error