iothub

Documentation

Index

• Constants
• func InitializeIothub(c core.Config) error
• func RunWithConfigFile(fileName string) error
• type ApiService
  • func (this *ApiService) Name() string
  • func (this *ApiService) Start() error
  • func (this *ApiService) Stop()
• type ApiServiceFactory
  • func (this *ApiServiceFactory) New(protocol string, c core.Config, ch chan core.ServiceCommand) (core.Service, error)
• type Broker
• type BrokerStatus
• type Iothub
• type NotifyService
  • func (this *NotifyService) Name() string
  • func (this *NotifyService) Start() error
  • func (this *NotifyService) Stop()
• type NotifyServiceFactory
  • func (m *NotifyServiceFactory) New(protocol string, c core.Config, ch chan core.ServiceCommand) (core.Service, error)
• type Tenant

Constants

const (
	BrokerStatusInvalid = "invalid"
	BrokerStatusStarted = "started"
	BrokerStatusStoped  = "stoped"
)

const APIHEAD = "iothub/api/v1/"

Functions

func InitializeIothub

func InitializeIothub(c core.Config) error

InitializeIothub create iothub global instance at startup time

func RunWithConfigFile

func RunWithConfigFile(fileName string) error

RunWithConfigFile create and start iothub with config file

Types

type ApiService

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

func (*ApiService) Name

func (this *ApiService) Name() string

Name

func (*ApiService) Start

func (this *ApiService) Start() error

Start

func (*ApiService) Stop

func (this *ApiService) Stop()

Stop

type ApiServiceFactory

type ApiServiceFactory struct{}

ApiServiceFactory

func (*ApiServiceFactory) New

func (this *ApiServiceFactory) New(protocol string, c core.Config, ch chan core.ServiceCommand) (core.Service, error)

New create apiService service factory

type Broker

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

type BrokerStatus

type BrokerStatus string

type Iothub

type Iothub struct {
	sync.Once
	// contains filtered or unexported fields
}

type NotifyService

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

func (*NotifyService) Name

func (this *NotifyService) Name() string

Name

func (*NotifyService) Start

func (this *NotifyService) Start() error

Start

func (*NotifyService) Stop

func (this *NotifyService) Stop()

Stop

type NotifyServiceFactory

type NotifyServiceFactory struct{}

NotifyServiceFactory

func (*NotifyServiceFactory) New

func (m *NotifyServiceFactory) New(protocol string, c core.Config, ch chan core.ServiceCommand) (core.Service, error)

New create apiService service factory

type Tenant

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