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,omitempty"`
	Input            string        `json:"input,omitempty"`
	InputFiles       []string      `json:"input-files,omitempty"`
	Actions          []string      `json:"actions,omitempty"`
	Plugins          Plugins       `json:"plugins,omitempty"`
	Template         string        `json:"template,omitempty"`
	SerializeActions bool          `json:"serialize-actions,omitempty"`
	Scheduling       chan struct{} `json:"-"`
}

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,omitempty"`
	AggregateMessageTimeout     string   `json:"aggregate-message-timeout,omitempty"`
	AggregateTimeoutSeconds     int      `json:"aggregate-timeout-seconds,omitempty"`
	UniqueMessageProps          []string `json:"unique-message-props,omitempty"`
	UniqueMessageTimeout        string   `json:"unique-message-timeout,omitempty"`
	UniqueMessageTimeoutSeconds int      `json:"unique-message-timeout-seconds,omitempty"`
}