controllers

Documentation

Index

• func Config() map[string]string
• func GetMgoValue(d tk.M, fieldName string) interface{}
• func PrepareConnection() (dbox.IConnection, error)
• func SetFloatValue(strVal string) (result float64)
• func WriteWatcherErrors(errorLine tk.M, fileName string, folder string) (e error)
• type BaseController
  • func (b *BaseController) CloseDb()
  • func (b *BaseController) Delete(m orm.IModel, id interface{}, column_name ...string) error
  • func (b *BaseController) GetById(m orm.IModel, id interface{}, column_name ...string) error
  • func (b *BaseController) GetDataSource(dataSourceFolder string) ([]os.FileInfo, string)
  • func (b *BaseController) GetDataSourceDirect(dataSourceFolder string) ([]os.FileInfo, string)
  • func (b *BaseController) Insert(result []tk.M, m orm.IModel, wg *sync.WaitGroup)
  • func (b *BaseController) InsertBulk(result []tk.M, m orm.IModel, wg *sync.WaitGroup)
  • func (b *BaseController) Truncate(m orm.IModel) error
  • func (b *BaseController) Update(m orm.IModel, id interface{}, column_name ...string) error
  • func (b *BaseController) WriteLog(msg interface{})
• type ConvScadaTreeSecs
  • func (d *ConvScadaTreeSecs) Generate(base *BaseController, file string) (errorLine tk.M)
• type GenTenFromThreeSecond
  • func (d *GenTenFromThreeSecond) Generate(base *BaseController, file string) (errorLine tk.M)
• type IBaseController
• type TenMinuteInfo
  • func GenTenMinuteInfo(timestamp time.Time) (result TenMinuteInfo)

Functions

func Config

func Config() map[string]string

func GetMgoValue

func GetMgoValue(d tk.M, fieldName string) interface{}

func PrepareConnection

func PrepareConnection() (dbox.IConnection, error)

func SetFloatValue

func SetFloatValue(strVal string) (result float64)

func WriteWatcherErrors

func WriteWatcherErrors(errorLine tk.M, fileName string, folder string) (e error)

Types

type BaseController

type BaseController struct {
	Ctx *orm.DataContext
	// contains filtered or unexported fields
}

func (*BaseController) CloseDb

func (b *BaseController) CloseDb()

func (*BaseController) Delete

func (b *BaseController) Delete(m orm.IModel, id interface{}, column_name ...string) error

func (*BaseController) GetById

func (b *BaseController) GetById(m orm.IModel, id interface{}, column_name ...string) error

func (*BaseController) GetDataSource

func (b *BaseController) GetDataSource(dataSourceFolder string) ([]os.FileInfo, string)

func (*BaseController) GetDataSourceDirect

func (b *BaseController) GetDataSourceDirect(dataSourceFolder string) ([]os.FileInfo, string)

func (*BaseController) Insert

func (b *BaseController) Insert(result []tk.M, m orm.IModel, wg *sync.WaitGroup)

func (*BaseController) InsertBulk

func (b *BaseController) InsertBulk(result []tk.M, m orm.IModel, wg *sync.WaitGroup)

func (*BaseController) Truncate

func (b *BaseController) Truncate(m orm.IModel) error

func (*BaseController) Update

func (b *BaseController) Update(m orm.IModel, id interface{}, column_name ...string) error

func (*BaseController) WriteLog

func (b *BaseController) WriteLog(msg interface{})

type ConvScadaTreeSecs

type ConvScadaTreeSecs struct {
	*BaseController
}

func (*ConvScadaTreeSecs) Generate

func (d *ConvScadaTreeSecs) Generate(base *BaseController, file string) (errorLine tk.M)

type GenTenFromThreeSecond

type GenTenFromThreeSecond struct {
	*BaseController
}

func (*GenTenFromThreeSecond) Generate

func (d *GenTenFromThreeSecond) Generate(base *BaseController, file string) (errorLine tk.M)

type IBaseController

type IBaseController interface {
}

type TenMinuteInfo

type TenMinuteInfo struct {
	THour              int
	TMinute            int
	TSecond            int
	TMinuteValue       float64
	TMinuteCategory    int
	TimeStampConverted time.Time
}

func GenTenMinuteInfo

func GenTenMinuteInfo(timestamp time.Time) (result TenMinuteInfo)