service

Documentation

Overview

package service implements the services and their business logic that provide the main part of the program

package service implements the services and their business logic that provide the main part of the program

package service implements the services and their business logic that provide the main part of the program

package service implements the services and their business logic that provide the main part of the program

package service implements the services and their business logic that provide the main part of the program

Index

• func GetDataFromStreamUrl(Url string) ([]byte, error)
• func GetXmlFromPollUrl(pollUrl string) (*domain.DevStat, error)
• func InitGpioPollHttp()
• func InitGpioSwitchHttp()
• func InitStreamHttp()
• func LoginToGpio(cfg *config.AppConfig) (success bool)
• type DefaultEmberPollService
  • func NewEmberPollService(cfg *config.AppConfig) DefaultEmberPollService
  • func (s DefaultEmberPollService) CloseEmberConn()
  • func (s DefaultEmberPollService) InitEmberConn()
  • func (s DefaultEmberPollService) Poll()
  • func (s DefaultEmberPollService) PollRun()
  • func (s DefaultEmberPollService) Reconnect()
• type DefaultGpioPollService
  • func NewGpioPollService(cfg *config.AppConfig) DefaultGpioPollService
  • func (s DefaultGpioPollService) Poll()
  • func (s DefaultGpioPollService) PollRun() error
• type DefaultGpioSwitchService
  • func NewGpioSwitchService(cfg *config.AppConfig) DefaultGpioSwitchService
  • func (s DefaultGpioSwitchService) Switch(xPoint string) (err api_error.ApiErr)
• type DefaultStreamScrapeService
  • func NewStreamScrapeService(cfg *config.AppConfig) DefaultStreamScrapeService
  • func (s DefaultStreamScrapeService) Scrape()
  • func (s DefaultStreamScrapeService) ScrapeRun()
• type DefaultStreamVolDetectService
  • func NewStreamVolDetectService(cfg *config.AppConfig) DefaultStreamVolDetectService
  • func (s DefaultStreamVolDetectService) Listen()
  • func (s DefaultStreamVolDetectService) ListenRun(streamUrl string)
• type EmberPollService
• type GpioPollService
• type GpioSwitchService
• type StreamScrapeService
• type StreamVolDetectService

Functions

func GetDataFromStreamUrl

func GetDataFromStreamUrl(Url string) ([]byte, error)

func GetXmlFromPollUrl

func GetXmlFromPollUrl(pollUrl string) (*domain.DevStat, error)

func InitGpioPollHttp

func InitGpioPollHttp()

func InitGpioSwitchHttp

func InitGpioSwitchHttp()

func InitStreamHttp

func InitStreamHttp()

func LoginToGpio

func LoginToGpio(cfg *config.AppConfig) (success bool)

Types

type DefaultEmberPollService

type DefaultEmberPollService struct {
	Cfg *config.AppConfig
}

func NewEmberPollService

func NewEmberPollService(cfg *config.AppConfig) DefaultEmberPollService

func (DefaultEmberPollService) CloseEmberConn

func (s DefaultEmberPollService) CloseEmberConn()

func (DefaultEmberPollService) InitEmberConn

func (s DefaultEmberPollService) InitEmberConn()

func (DefaultEmberPollService) Poll

func (s DefaultEmberPollService) Poll()

func (DefaultEmberPollService) PollRun

func (s DefaultEmberPollService) PollRun()

func (DefaultEmberPollService) Reconnect

func (s DefaultEmberPollService) Reconnect()

type DefaultGpioPollService

type DefaultGpioPollService struct {
	Cfg *config.AppConfig
}

func NewGpioPollService

func NewGpioPollService(cfg *config.AppConfig) DefaultGpioPollService

func (DefaultGpioPollService) Poll

func (s DefaultGpioPollService) Poll()

func (DefaultGpioPollService) PollRun

func (s DefaultGpioPollService) PollRun() error

type DefaultGpioSwitchService

type DefaultGpioSwitchService struct {
	Cfg *config.AppConfig
}

func NewGpioSwitchService

func NewGpioSwitchService(cfg *config.AppConfig) DefaultGpioSwitchService

func (DefaultGpioSwitchService) Switch

func (s DefaultGpioSwitchService) Switch(xPoint string) (err api_error.ApiErr)

type DefaultStreamScrapeService

type DefaultStreamScrapeService struct {
	Cfg *config.AppConfig
}

func NewStreamScrapeService

func NewStreamScrapeService(cfg *config.AppConfig) DefaultStreamScrapeService

func (DefaultStreamScrapeService) Scrape

func (s DefaultStreamScrapeService) Scrape()

func (DefaultStreamScrapeService) ScrapeRun

func (s DefaultStreamScrapeService) ScrapeRun()

type DefaultStreamVolDetectService

type DefaultStreamVolDetectService struct {
	Cfg *config.AppConfig
}

func NewStreamVolDetectService

func NewStreamVolDetectService(cfg *config.AppConfig) DefaultStreamVolDetectService

func (DefaultStreamVolDetectService) Listen

func (s DefaultStreamVolDetectService) Listen()

func (DefaultStreamVolDetectService) ListenRun

func (s DefaultStreamVolDetectService) ListenRun(streamUrl string)

type EmberPollService

type EmberPollService interface {
	Poll()
}

type GpioPollService

type GpioPollService interface {
	Poll()
}

type GpioSwitchService

type GpioSwitchService interface {
	Switch(string) api_error.ApiErr
}

type StreamScrapeService

type StreamScrapeService interface {
	Scrape()
}

type StreamVolDetectService

type StreamVolDetectService interface {
	Listen()
}