Documentation ¶
Index ¶
- func MetricsPrintOut() string
- type App
- func (a *App) BotBroadcastMsg(msg string)
- func (a *App) CancelAndExit()
- func (a *App) ErrorPoller(ctx context.Context)
- func (a *App) GetParams() string
- func (a *App) HandleMessages(ctx context.Context)
- func (a *App) Heartbeat(ctx context.Context)
- func (a *App) ListenTelegram(ctx context.Context)
- func (a *App) MessengerListen(ctx context.Context) error
- func (a *App) NextFrame() error
- func (a *App) NextFrameFromCam(index int) error
- func (a *App) Run(ctx context.Context) error
- func (a *App) SendHist(camIndex int, hist *HistVals) error
- func (a *App) Supervisor(ctx context.Context)
- func (a *App) Uploader(ctx context.Context) error
- type CamMetrics
- type Config
- type HistVals
- type Label
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MetricsPrintOut ¶
func MetricsPrintOut() string
Types ¶
type App ¶
type App struct { Cams []*camera.Cam Detector *detect.Detector SysErr *systemerr.LogReader PubSub messaging.MessengerInterface FrameInterval time.Duration StartupTime time.Time HeartbeatURL string CancelFn context.CancelFunc RoundRobin int AlertUploadChan chan *jobs.UploadJob InfoUploadChan chan *jobs.UploadJob SnapshotChan chan jobs.Cmd FrameChan chan jobs.Cmd MsgChan chan messaging.Msg }
func (*App) BotBroadcastMsg ¶
func (*App) CancelAndExit ¶
func (a *App) CancelAndExit()
func (*App) ErrorPoller ¶
func (*App) HandleMessages ¶
HandleMessages pulls incoming messages from the messenger (pubsub) and handles them.
func (*App) ListenTelegram ¶
func (*App) MessengerListen ¶
MessengerListen invokes the messenger pubsub interface to listen for incoming messages
func (*App) NextFrameFromCam ¶
func (*App) Supervisor ¶
type CamMetrics ¶
type CamMetrics struct {
// contains filtered or unexported fields
}
func NewCamMetrics ¶
func NewCamMetrics(name string) *CamMetrics
type HistVals ¶
func NewHistVals ¶
Click to show internal directories.
Click to hide internal directories.