routes

Documentation

Index

• type InputRoute
  • func ConfigureTimeouts(route *InputRoute) *InputRoute
  • func (route *InputRoute) IsSchedulerRun() bool
  • func (route *InputRoute) StartScheduler()
  • func (route *InputRoute) StopScheduler()
• type Plugins

Types

type InputRoute

type InputRoute struct {
	Name             string   `json:"name"`
	Input            string   `json:"input"`
	InputFiles       []string `json:"input-files"`
	Actions          []string `json:"actions"`
	Plugins          Plugins  `json:"plugins"`
	Template         string   `json:"template"`
	SerializeActions bool     `json:"serialize-actions"`
	Scheduling       chan struct{}
}

func ConfigureTimeouts

func ConfigureTimeouts(route *InputRoute) *InputRoute

func (*InputRoute) IsSchedulerRun

func (route *InputRoute) IsSchedulerRun() bool

func (*InputRoute) StartScheduler

func (route *InputRoute) StartScheduler()

func (*InputRoute) StopScheduler

func (route *InputRoute) StopScheduler()

type Plugins

type Plugins struct {
	AggregateMessageNumber      int    `json:"aggregate-message-number"`
	AggregateMessageTimeout     string `json:"aggregate-message-timeout"`
	AggregateTimeoutSeconds     int
	UniqueMessageProps          []string `json:"unique-message-props"`
	UniqueMessageTimeout        string   `json:"unique-message-timeout"`
	UniqueMessageTimeoutSeconds int
}