trigger

Documentation

Index

• func HttpServer(parentCtx context.Context, serverCfg *config.HttpServerCfg, ...) *httpServer
• func Scheduler(parentCtx context.Context, name string, cfg *config.SchedulerTrigger) *scheduler
• type Message
• type Trigger

Functions

func HttpServer

func HttpServer(parentCtx context.Context, serverCfg *config.HttpServerCfg, ignoreTrigger []string) *httpServer

func Scheduler

func Scheduler(parentCtx context.Context, name string, cfg *config.SchedulerTrigger) *scheduler

Types

type Message

type Message struct {
	Name  string
	Value builder.Jsonable
}

type Trigger

type Trigger interface {
	Run(chan<- Message)
	Stop()
}