systemd

Documentation

Index

• type EventStream
  • func NewEventStream() *EventStream
  • func (self *EventStream) Close()
  • func (self *EventStream) Stream(unitchan <-chan map[string]*dbus.UnitStatus, eventchan chan *event.Event)
• type ListenSocket
  • func NewListenSocketFromListenConfig(cfg string) (*ListenSocket, error)
  • func (ls *ListenSocket) String(ip string) string
• type SystemdManager
  • func NewSystemdManager(machine *machine.Machine, unitPrefix string) *SystemdManager
  • func (m *SystemdManager) Publish(bus *event.EventBus, stopchan chan bool)
  • func (m *SystemdManager) StartJob(job *job.Job)
  • func (m *SystemdManager) StopJob(jobName string)
• type SystemdService
  • func NewSystemdService(manager *SystemdManager, name string) *SystemdService
  • func (ss *SystemdService) Name() string
  • func (ss *SystemdService) Payload() (string, error)
  • func (ss *SystemdService) State() (string, string, string, []string, error)
• type SystemdSocket
  • func NewSystemdSocket(manager *SystemdManager, name string) *SystemdSocket
  • func (ss *SystemdSocket) Name() string
  • func (ss *SystemdSocket) Payload() (string, error)
  • func (ss *SystemdSocket) State() (string, string, string, []string, error)
• type SystemdTarget
  • func NewSystemdTarget(name string) *SystemdTarget
  • func (st *SystemdTarget) Name() string
  • func (st *SystemdTarget) Payload() (string, error)
  • func (st *SystemdTarget) State() (string, string, string, []string, error)
• type SystemdUnit

Types

type EventStream

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

func NewEventStream

func NewEventStream() *EventStream

func (*EventStream) Close

func (self *EventStream) Close()

func (*EventStream) Stream

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

type ListenSocket

type ListenSocket struct {
	Type string
	Port int
}

func NewListenSocketFromListenConfig

func NewListenSocketFromListenConfig(cfg string) (*ListenSocket, error)

func (*ListenSocket) String

func (ls *ListenSocket) String(ip string) string

type SystemdManager

type SystemdManager struct {
	Systemd    *dbus.Conn
	Target     *SystemdTarget
	Machine    *machine.Machine
	UnitPrefix string
	// contains filtered or unexported fields
}

func NewSystemdManager

func NewSystemdManager(machine *machine.Machine, unitPrefix string) *SystemdManager

func (*SystemdManager) Publish

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

func (*SystemdManager) StartJob

func (m *SystemdManager) StartJob(job *job.Job)

func (*SystemdManager) StopJob

func (m *SystemdManager) StopJob(jobName string)

type SystemdService

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

func NewSystemdService

func NewSystemdService(manager *SystemdManager, name string) *SystemdService

func (*SystemdService) Name

func (ss *SystemdService) Name() string

func (*SystemdService) Payload

func (ss *SystemdService) Payload() (string, error)

func (*SystemdService) State

func (ss *SystemdService) State() (string, string, string, []string, error)

type SystemdSocket

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

func NewSystemdSocket

func NewSystemdSocket(manager *SystemdManager, name string) *SystemdSocket

func (*SystemdSocket) Name

func (ss *SystemdSocket) Name() string

func (*SystemdSocket) Payload

func (ss *SystemdSocket) Payload() (string, error)

func (*SystemdSocket) State

func (ss *SystemdSocket) State() (string, string, string, []string, error)

type SystemdTarget

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

func NewSystemdTarget

func NewSystemdTarget(name string) *SystemdTarget

func (*SystemdTarget) Name

func (st *SystemdTarget) Name() string

func (*SystemdTarget) Payload

func (st *SystemdTarget) Payload() (string, error)

func (*SystemdTarget) State

func (st *SystemdTarget) State() (string, string, string, []string, error)

type SystemdUnit

type SystemdUnit interface {
	Name() string
	Payload() (string, error)

	// The first three strings correspond to the LoadState,
	// ActiveState and SubState of a unit.
	State() (string, string, string, []string, error)
}