ncd

README

uyuni-ncd

Uyuni Cluster: Node Controller Daemon. It runs on each Node and ensures the communication between Cluster Director and Uyuni Server.

Documentation

Index

• Constants
• type Ncd
  • func NewNcd() *Ncd
  • func (n *Ncd) AddMapper(mapper eventmappers.Mapper) *Ncd
  • func (n *Ncd) GetDBListener() *ncdtransport.PgEventListener
  • func (n *Ncd) GetMapper(topic string) (*eventmappers.Mapper, error)
  • func (n *Ncd) GetTransport() *ncdtransport.NcdPubSub
  • func (n *Ncd) IsLeader() bool
  • func (n *Ncd) IsRunning() bool
  • func (n *Ncd) Run()
  • func (n *Ncd) RunProcess()
  • func (n *Ncd) SetLeader(leader bool) *Ncd
  • func (n *Ncd) Stop()
• type NcdConf

Constants

const (
	CHANNEL_NODES    = "nodes"
	CHANNEL_DIRECTOR = "director"
)

Types

type Ncd

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

func NewNcd

func NewNcd() *Ncd

func (*Ncd) AddMapper

func (n *Ncd) AddMapper(mapper eventmappers.Mapper) *Ncd

AddMapper adds a mapper to the ncd

func (*Ncd) GetDBListener

func (n *Ncd) GetDBListener() *ncdtransport.PgEventListener

GetDBListener return PgEventListener instance

func (*Ncd) GetMapper

func (n *Ncd) GetMapper(topic string) (*eventmappers.Mapper, error)

GetMapper by a topic

func (*Ncd) GetTransport

func (n *Ncd) GetTransport() *ncdtransport.NcdPubSub

GetTransport returns NcdPubSub instance

func (*Ncd) IsLeader

func (n *Ncd) IsLeader() bool

IsLeader returns true, if the current node is a leader node

func (*Ncd) IsRunning

func (n *Ncd) IsRunning() bool

IsRunning returns true, if the Ncd is already running

func (*Ncd) Run

func (n *Ncd) Run()

Run ncd in foreground

func (*Ncd) RunProcess

func (n *Ncd) RunProcess()

Run ncd in background

func (*Ncd) SetLeader

func (n *Ncd) SetLeader(leader bool) *Ncd

SetLeader sets the current node into a leader mode

func (*Ncd) Stop

func (n *Ncd) Stop()

Stop ncd

type NcdConf

type NcdConf struct {
	Running bool
	Leader  bool
}