Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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"`
}
Click to show internal directories.
Click to hide internal directories.