dbus

Documentation

Index

• type Client
  • func NewClient(appName string) *Client
  • func (c *Client) Close()
  • func (c *Client) InitializeDefaultConnection() error
  • func (c *Client) ListDistributors() (distributors []string, err error)
  • func (c *Client) PickDistributor(dist string) *Distributor
  • func (c *Client) StartHandling(connector Connector) error
• type Connector
  • func NewConnector(handler ConnectorHandler) Connector
  • func (c Connector) Message(token string, message []byte, msgID string) *dbus.Error
  • func (c Connector) NewEndpoint(token, endpoint string) *dbus.Error
  • func (c Connector) Unregistered(token string) *dbus.Error
• type ConnectorHandler
• type Distributor
  • func NewDistributor(object dbus.BusObject) *Distributor
  • func (d *Distributor) Register(name, token, description string) (definitions.RegisterStatus, string)
  • func (d *Distributor) Unregister(token string) (err error)

Types

type Client

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

func NewClient

func NewClient(appName string) *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) InitializeDefaultConnection

func (c *Client) InitializeDefaultConnection() error

func (*Client) ListDistributors

func (c *Client) ListDistributors() (distributors []string, err error)

func (*Client) PickDistributor

func (c *Client) PickDistributor(dist string) *Distributor

func (*Client) StartHandling

func (c *Client) StartHandling(connector Connector) error

StartHandling exports the connector interface and requests the app's name on the bus

type Connector

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

func NewConnector

func NewConnector(handler ConnectorHandler) Connector

func (Connector) Message

func (c Connector) Message(token string, message []byte, msgID string) *dbus.Error

func (Connector) NewEndpoint

func (c Connector) NewEndpoint(token, endpoint string) *dbus.Error

func (Connector) Unregistered

func (c Connector) Unregistered(token string) *dbus.Error

type ConnectorHandler

type ConnectorHandler interface {
	Message(token string, message []byte, msgID string)
	NewEndpoint(token, endpoint string)
	Unregistered(token string)
}

type Distributor

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

func NewDistributor

func NewDistributor(object dbus.BusObject) *Distributor

func (*Distributor) Register

func (d *Distributor) Register(name, token, description string) (definitions.RegisterStatus, string)

func (*Distributor) Unregister

func (d *Distributor) Unregister(token string) (err error)