proto

Jul 6, 2020

Changes in this version

+ type Executor interface

+ Add func(_type string, config []byte) error

+ Control func(cmd ControlCommand, executorInstanceIDs ...string) error

+ Find func(executorInstanceID string) (*ExecutorView, error)

+ List func() ([]ExecutorView, error)

+ Recreate func(_type string, config []byte) error

+ Remove func(executorInstanceIDs ...string) error

+ Visualize func(format VisualizeFormat, executorInstanceID string) ([]byte, error)

+ type ExecutorView struct

+ Bootstrap bool

+ Components []ComponentView

+ Error string

+ ExitTime string

+ LastEndTime string

+ LastStartTime string

+ Name string

+ NextRunTime string

+ Processors []ProcessorView

+ RawConfig []byte

+ RunTimes string

+ Schedule string

+ StartTime string

+ State string

+ StreamError string

+ StreamErrorCount int

type FileType

+ const FileTypeExecutorConfig

type GenerateConfigRequest

+ Config []byte

+ Type string

type Metadata

+ AddExecutorConfigPath func(_type, path string) error

+ AddPluginPath func(path string) error

+ PutExecutorRawConfig func(_type, name string, raw []byte) (path string, err error)

+ PutPlugin func(name string, bin []byte) (path string, err error)

+ RemoveExecutorConfigPath func(_type, path string) error

+ RemovePluginPath func(path string) error

+ Snapshot func(do func(Snapshot))

type MetadataView

+ ExecutorConfigPaths map[string][]string

type Plugin

+ AddPath func(path string) error

+ type Snapshot struct

+ ExecutorConfigPaths map[string][]string

+ PluginPaths []string

Jun 29, 2020

Changes in this version

+ var DefaultBootstrap = false

+ var DefaultCircuitBreakerRate float64 = 0.9

+ var DefaultCircuitBreakerSamples int64 = 10

+ var DefaultConfigOptions = ConfigOptions

+ var DefaultSchedule = ""

+ type ConfigOption func(*ConfigOptions)

+ func WithBootstrap(b bool) ConfigOption

+ func WithCircuitBreakerRate(f float64) ConfigOption

+ func WithCircuitBreakerSamples(s int64) ConfigOption

+ func WithComponents(cs []string) ConfigOption

+ func WithProcessor(ps []string) ConfigOption

+ func WithSchedule(schedule string) ConfigOption

+ type ConfigOptions struct

+ Bootstrap bool

+ CircuitBreakerRate float64

+ CircuitBreakerSamples int64

+ Components []string

+ Processors []string

+ Schedule string

+ func NewConfigOptions(opts ...ConfigOption) ConfigOptions

+ type GenerateConfigRequest struct

+ Bootstrap bool

+ CircuitBreakerRate float64

+ CircuitBreakerSamples int64

+ Components []string

+ Name string

+ Processors []string

+ Schedule string

type MetadataView

+ Branch string

+ Built string

+ Commit string

+ Version string

type PipelineView

+ StreamError string

+ StreamErrorCount int

Jun 28, 2020

Changes in this version

type Pipeline

+ Remove func(names ...string) error

+ Visualize func(name string, format VisualizeFormat) ([]byte, error)

type PipelineView

+ Error string

type Plugin

+ Remove func(names ...string) error

type PluginView

+ IsRemoved bool

+ Name string

type VisualizeFormat

+ const VisualizeFormatPng

+ const VisualizeFormatTerm

Jun 23, 2020

Changes in this version

+ type Component interface

+ Find func(name string) (*ComponentView, error)

+ List func() ([]ComponentView, error)

+ type ComponentView struct

+ Description string

+ InjectName string

+ Name string

+ RawConfig string

+ ReflectType string

+ ReflectValue string

+ SampleConfig string

+ type ControlCommand string

+ const ControlCommandRestart

+ const ControlCommandStart

+ const ControlCommandStop

+ type FileType string

+ const FileTypePipelineConfig

+ const FileTypePlugin

+ type Metadata interface

+ AddPath func(ft FileType, path string) error

+ ExistsPath func(ft FileType, path string) bool

+ GetPath func(ft FileType, filename string) string

+ ListPaths func(ft FileType) []string

+ Overwrite func(ft FileType, path string, data []byte) error

+ RemovePath func(ft FileType, path string) error

+ type MetadataView struct

+ HTTPAddr string

+ PipelineConfigPaths []string

+ PluginPaths []string

+ type Pipeline interface

+ Add func(conf pipe.Config) error

+ Control func(cmd ControlCommand, names []string) error

+ Find func(name string) (*PipelineView, error)

+ GenerateConfig func(name, schdule string, components, processors []string) (*pipe.Config, error)

+ List func() ([]PipelineView, error)

+ Recreate func(conf pipe.Config) error

+ type PipelineView struct

+ Bootstrap bool

+ Components []ComponentView

+ ExitTime string

+ LastEndTime string

+ LastStartTime string

+ Name string

+ NextRunTime string

+ Processors []ProcessorView

+ RawConfig []byte

+ RunTimes string

+ Schedule string

+ StartTime string

+ State string

+ type Plugin interface

+ Add func(path string) error

+ List func() ([]PluginView, error)

+ Open func(path string) error

+ type PluginOpenRequest struct

+ Path string

+ type PluginView struct

+ Module string

+ OpenTime string

+ Path string

+ type Processor interface

+ Find func(name string) (*ProcessorView, error)

+ List func() ([]ProcessorView, error)

+ type ProcessorView struct

+ Description string

+ Name string

+ RawConfig string

+ SampleConfig string

+ type Result struct

+ Code int

+ Data interface{}

+ Msg string

+ type Server interface

+ Metadata func() (MetadataView, error)

+ type VisualizeFormat string

+ const VisualizeFormatASCIITable

+ const VisualizeFormatDot

+ const VisualizeFormatRaw

+ const VisualizeFormatSVG