server

Documentation

Index

• func ExportToDBus(proc *Process, bus string) error
• type DBusServer
  • func (s *DBusServer) Close() error
  • func (s *DBusServer) RequestCommand(sender dbus.Sender, otype byte) (input, output dbus.UnixFD, derr *dbus.Error)
  • func (s *DBusServer) RequestOutput(sender dbus.Sender, otype byte) (output dbus.UnixFD, derr *dbus.Error)
  • func (s *DBusServer) SendCommand(sender dbus.Sender, otype byte, command string) (output dbus.UnixFD, derr *dbus.Error)
• type ListenerList
  • func NewListenerList() *ListenerList
  • func (l *ListenerList) Append() *ListenerNode
  • func (l *ListenerList) Remove(node *ListenerNode) bool
  • func (l *ListenerList) Traverse() chan *ListenerNode
• type ListenerNode
  • func (n *ListenerNode) Read() chan []byte
  • func (n *ListenerNode) Remove() bool
  • func (n *ListenerNode) Write(data []byte)
• type Process
  • func StartProcess(name string, desc string, bus string, arg ...string) (p *Process, err error)
  • func (p *Process) Cleanup() error
  • func (p *Process) ConnectError(sink *os.File)
  • func (p *Process) ConnectInput(source *os.File) error
  • func (p *Process) ConnectOutput(sink *os.File)
  • func (p *Process) RequestCommand(otype common.OutputType) (*os.File, *os.File, error)
  • func (p *Process) RequestOutput(otype common.OutputType) (*os.File, error)
  • func (p *Process) SendCommand(otype common.OutputType, command string) (*os.File, error)
  • func (p *Process) Start() (err error)
  • func (p *Process) Wait() error
• type Provider
  • func New() *Provider
  • func (p *Provider) Start(pipe io.Writer)
  • func (p *Provider) Stop()
  • func (p *Provider) Write() (dataChan chan []byte, ok bool)

Functions

func ExportToDBus

func ExportToDBus(proc *Process, bus string) error

Types

type DBusServer

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

func (*DBusServer) Close

func (s *DBusServer) Close() error

func (*DBusServer) RequestCommand

func (s *DBusServer) RequestCommand(sender dbus.Sender, otype byte) (input, output dbus.UnixFD, derr *dbus.Error)

func (*DBusServer) RequestOutput

func (s *DBusServer) RequestOutput(sender dbus.Sender, otype byte) (output dbus.UnixFD, derr *dbus.Error)

func (*DBusServer) SendCommand

func (s *DBusServer) SendCommand(sender dbus.Sender, otype byte, command string) (output dbus.UnixFD, derr *dbus.Error)

type ListenerList

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

func NewListenerList

func NewListenerList() *ListenerList

func (*ListenerList) Append

func (l *ListenerList) Append() *ListenerNode

func (*ListenerList) Remove

func (l *ListenerList) Remove(node *ListenerNode) bool

func (*ListenerList) Traverse

func (l *ListenerList) Traverse() chan *ListenerNode

type ListenerNode

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

func (*ListenerNode) Read

func (n *ListenerNode) Read() chan []byte

func (*ListenerNode) Remove

func (n *ListenerNode) Remove() bool

func (*ListenerNode) Write

func (n *ListenerNode) Write(data []byte)

type Process

type Process struct {
	Description string
	// contains filtered or unexported fields
}

func StartProcess

func StartProcess(name string, desc string, bus string, arg ...string) (p *Process, err error)

func (*Process) Cleanup

func (p *Process) Cleanup() error

func (*Process) ConnectError

func (p *Process) ConnectError(sink *os.File)

func (*Process) ConnectInput

func (p *Process) ConnectInput(source *os.File) error

func (*Process) ConnectOutput

func (p *Process) ConnectOutput(sink *os.File)

func (*Process) RequestCommand

func (p *Process) RequestCommand(otype common.OutputType) (*os.File, *os.File, error)

func (*Process) RequestOutput

func (p *Process) RequestOutput(otype common.OutputType) (*os.File, error)

func (*Process) SendCommand

func (p *Process) SendCommand(otype common.OutputType, command string) (*os.File, error)

func (*Process) Start

func (p *Process) Start() (err error)

func (*Process) Wait

func (p *Process) Wait() error

type Provider

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

func New

func New() *Provider

func (*Provider) Start

func (p *Provider) Start(pipe io.Writer)

func (*Provider) Stop

func (p *Provider) Stop()

func (*Provider) Write

func (p *Provider) Write() (dataChan chan []byte, ok bool)