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
  • func CreateTriggers(ctx context.Context, cfg *config.Config, logger logger.Logger) []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.Interfacable
}

type Trigger

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

func CreateTriggers

func CreateTriggers(ctx context.Context, cfg *config.Config, logger logger.Logger) []Trigger