manager_pipe

Documentation

Index

• type Manager
  • func New(n *node.Node) (m *Manager)
  • func (m *Manager) Run(ctx context.Context)
  • func (m *Manager) Stopped() chan struct{}

Types

type Manager

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

Manager is pipeline instance manager. If there is a pipeline bound to the current node, run an instance will also stop inbound instance on the current node

func New

func New(n *node.Node) (m *Manager)

New returns a new Manager

func (*Manager) Run

func (m *Manager) Run(ctx context.Context)

Run start woking

func (*Manager) Stopped

func (m *Manager) Stopped() chan struct{}