pipeliner

type Config struct {
	Name                  string              `yaml:"name"`
	Schedule              string              `yaml:"schedule"`                // 调度计划，为空时死循环调度，可以传入cron表达式调度
	CircuitBreakerSamples int64               `yaml:"circuit_breaker_samples"` // 熔断器采样数, 防止stream出现异常耗尽cpu资源
	CircuitBreakerRate    float64             `yaml:"circuit_breaker_rate"`    // 熔断器采样率
	Bootstrap             bool                `yaml:"bootstrap"`               // 随进程启动而启动
	Components            []map[string]string `yaml:"components"`              // key: name, value: rawConfig
	Processors            []map[string]string `yaml:"processors"`              // key: name, value: rawConfig
	Stream                StreamConfig        `yaml:"stream"`                  // key: name, value: StreamConfig
}

type ConstantDelaySchedule struct {
}

type ErrorGroup []error

type MissingDependencyError struct {
	Field       string
	ReflectType string
	InjectName  string
}

type PipelinerFactory struct {
}

type Schedule interface {
	// Next returns the next activation time, later than the given time.
	// Next is invoked initially, and then each time the job is run.
	Next(time.Time) time.Time
}

type ScheduleParser func(spec string) (Schedule, error)

type Stream struct {
	// contains filtered or unexported fields
}

type StreamConfig struct {
	Name       string         `yaml:"name"`
	Childs     []StreamConfig `yaml:"childs,omitempty"`
	Replica    int            `yaml:"replica,omitempty"`
	BufferSize int            `yaml:"buffer_size,omitempty"`
}

type Visualizer func(w io.Writer, pipeline *pipeliner) error