systemd

Documentation

Index

• Constants
• type EventStream
  • func NewEventStream() *EventStream
  • func (es *EventStream) Close()
  • func (es *EventStream) Stream(unitchan <-chan map[string]*dbus.UnitStatus, eventchan chan *event.Event)
• type SystemdManager
  • func NewSystemdManager(uDir string) (*SystemdManager, error)
  • func (m *SystemdManager) GetUnitState(name string) (*unit.UnitState, error)
  • func (m *SystemdManager) Load(name string, u unit.Unit) error
  • func (m *SystemdManager) MarshalJSON() ([]byte, error)
  • func (m *SystemdManager) Publish(bus *event.EventBus, stopchan chan bool)
  • func (m *SystemdManager) Start(name string)
  • func (m *SystemdManager) Stop(name string)
  • func (m *SystemdManager) Units() (units []string, err error)
  • func (m *SystemdManager) Unload(name string)

Constants

const (
	DefaultUnitsDirectory = "/run/fleet/units/"
)

Types

type EventStream

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

func NewEventStream

func NewEventStream() *EventStream

func (*EventStream) Close

func (es *EventStream) Close()

func (*EventStream) Stream

func (es *EventStream) Stream(unitchan <-chan map[string]*dbus.UnitStatus, eventchan chan *event.Event)

type SystemdManager

type SystemdManager struct {
	UnitsDir string
	// contains filtered or unexported fields
}

func NewSystemdManager

func NewSystemdManager(uDir string) (*SystemdManager, error)

func (*SystemdManager) GetUnitState

func (m *SystemdManager) GetUnitState(name string) (*unit.UnitState, error)

GetUnitState generates a UnitState object representing the current state of a Unit

func (*SystemdManager) Load

func (m *SystemdManager) Load(name string, u unit.Unit) error

Load writes the given Unit to disk, subscribing to relevant dbus events, and, if necessary, instructing the systemd daemon to reload.

func (*SystemdManager) MarshalJSON

func (m *SystemdManager) MarshalJSON() ([]byte, error)

func (*SystemdManager) Publish

func (m *SystemdManager) Publish(bus *event.EventBus, stopchan chan bool)

Publish is a long-running function that streams dbus events through a translation layer and on to the EventBus

func (*SystemdManager) Start

func (m *SystemdManager) Start(name string)

Start starts the unit identified by the given name

func (*SystemdManager) Stop

func (m *SystemdManager) Stop(name string)

Stop stops the unit identified by the given name

func (*SystemdManager) Units

func (m *SystemdManager) Units() (units []string, err error)

Units enumerates all files recognized as valid systemd units in this manager's units directory.

func (*SystemdManager) Unload

func (m *SystemdManager) Unload(name string)

Unload removes the indicated unit from the filesystem, unsubscribing from relevant dbus events.