app

Documentation

Index

• type App
  • func NewApp(url url.URL, channel string) *App
  • func (a *App) AddDevice() error
  • func (a *App) Close() error
  • func (a *App) Start() error
  • func (a *App) StartPublishing()
• type Device
  • func NewDevice(id string, url url.URL) (*Device, error)
  • func (d *Device) Attach(channel string) error
  • func (d *Device) Close()
  • func (d *Device) DeAttach(channel string) error
  • func (d *Device) Publish(channel string, id string) error
  • func (d *Device) StartReceiving()
  • func (d *Device) Subscribe(channel string) error

Types

type App

type App struct {
	Url     url.URL
	Channel string
	Devices []*Device
}

func NewApp

func NewApp(url url.URL, channel string) *App

func (*App) AddDevice

func (a *App) AddDevice() error

func (*App) Close

func (a *App) Close() error

func (*App) Start

func (a *App) Start() error

func (*App) StartPublishing

func (a *App) StartPublishing()

type Device

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

func NewDevice

func NewDevice(id string, url url.URL) (*Device, error)

func (*Device) Attach

func (d *Device) Attach(channel string) error

func (*Device) Close

func (d *Device) Close()

func (*Device) DeAttach

func (d *Device) DeAttach(channel string) error

func (*Device) Publish

func (d *Device) Publish(channel string, id string) error

func (*Device) StartReceiving

func (d *Device) StartReceiving()

func (*Device) Subscribe

func (d *Device) Subscribe(channel string) error