App

package
v0.0.0-...-72abcba Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 20, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type App

type App struct {
	Config  config.Config
	Logger  zap.SugaredLogger
	Storage storage.DBStorage
	Broker  broker.Broker
}

func New

func New() *App

func (*App) HandleByState

func (app *App) HandleByState(notice models.SchedulerNotice) error

func (*App) PublishState

func (app *App) PublishState(event PublishState)

func (*App) SchedulerHandler

func (app *App) SchedulerHandler(msg broker.Message) (bool, error)

handle msgs, if a msg cant handle return true and error

type PublishState

type PublishState struct {
	Notice models.SchedulerNotice
	State  models.SchedulerState
	Error  error
	Queue  string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL