core

Documentation

Index

• type Application
  • func New(tm tm.Service, st *store.Data, ns *nats.EncodedConn) *Application
  • func (a *Application) Exit()
  • func (a *Application) Handle(d types.Data)
  • func (a *Application) Models() []string
  • func (a *Application) RegisterModel(m model.Model)
  • func (a *Application) Run() error

Types

type Application

type Application struct {

	// tm connection
	TMService tm.Service

	// data store
	Store *store.Data

	// is core application running?
	IsRun bool
	// contains filtered or unexported fields
}

Application is a main component of uplink that consists of uplink protocol and mqtt client

func New

func New(tm tm.Service, st *store.Data, ns *nats.EncodedConn) *Application

New creates new application.

func (*Application) Exit

func (a *Application) Exit()

Exit closes amqp connection then closes all channels and return from all pipeline stages

func (*Application) Handle

func (a *Application) Handle(d types.Data)

Handle handles given data into core pipeline

func (*Application) Models

func (a *Application) Models() []string

Models returns list of registered model's names

func (*Application) RegisterModel

func (a *Application) RegisterModel(m model.Model)

RegisterModel registers model m on application a

func (*Application) Run

func (a *Application) Run() error

Run runs application. this function connects mqtt client and then register its topic