tasks

package
v0.0.0-...-149ce59 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2018 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	DatabaseFlags = []cli.Flag{
		cli.StringFlag{
			Name:   "database, d",
			Usage:  "Database URL",
			EnvVar: "CAP_DATABASE_TYPE",
			Value:  "elasticsearch",
		},
		cli.StringFlag{
			Name:   "elastic-url",
			Usage:  "Elasticsearch URL",
			EnvVar: "CAP_ELASTIC_URL",
			Value:  "http://localhost:9200",
		},
		cli.StringFlag{
			Name:   "elastic-index",
			Usage:  "Elasticsearch index",
			EnvVar: "CAP_ELASTIC_INDEX",
			Value:  "alerts",
		},
	}
)
View Source
var (
	ServerFlags = []cli.Flag{
		cli.StringFlag{
			Name:   "broker, b",
			Usage:  "Message broker URL",
			EnvVar: "CAP_BROKER_URL",
			Value:  "redis://127.0.0.1:6379",
		},
		cli.StringFlag{
			Name:   "queue, q",
			Usage:  "Queue name",
			EnvVar: "CAP_QUEUE",
			Value:  "alerts",
		},
		cli.StringFlag{
			Name:   "result-backend, r",
			Usage:  "Result backend URL",
			EnvVar: "CAP_RESULTS_BACKEND",
			Value:  "redis://127.0.0.1:6379",
		},
		cli.IntFlag{
			Name:   "results-expiry, e",
			Usage:  "Time when results expire (in seconds)",
			EnvVar: "CAP_RESULTS_EXPIRY",
			Value:  120,
		},
	}
)
View Source
var (
	SystemFlags = []cli.Flag{
		cli.StringFlag{
			Name:   "system, s",
			Usage:  "System",
			EnvVar: "CAP_SYSTEM",
		},

		cli.StringFlag{
			Name:   "canada-naad-fetch",
			Usage:  "Base URL for fetching alerts",
			EnvVar: "CAP_CANADA_NAAD_FETCH",
		},
	}
)

Functions

func AddAlert

func AddAlert(server *machinery.Server, alert *cap.Alert) (*backends.AsyncResult, error)

func CreateDatabase

func CreateDatabase(c *cli.Context) (db.Database, error)

func CreateServer

func CreateServer(c *cli.Context) (*machinery.Server, error)

func CreateSystem

func CreateSystem(c *cli.Context) (system.System, error)

func EnsureReference

func EnsureReference(server *machinery.Server, reference *cap.Reference) (*backends.AsyncResult, error)

func ProcessAlert

func ProcessAlert(alert *cap.Alert) error

Types

This section is empty.

Jump to

Keyboard shortcuts

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