provisioning

Documentation

Index

• Constants
• Variables
• func Parse(data []byte) (map[string]PipelineConfig, error)
• type ConnectorConfig
• type PipelineConfig
• type PipelinesConfig
• type ProcessorConfig

Constants

const ParserVersion = "1.0"

Variables

var ErrUnsupportedVersion = cerrors.New("unsupported parser version")

Functions

func Parse

func Parse(data []byte) (map[string]PipelineConfig, error)

Types

type ConnectorConfig

type ConnectorConfig struct {
	Type       string                     `yaml:"type"`
	Plugin     string                     `yaml:"plugin"`
	Name       string                     `yaml:"name"`
	Settings   map[string]string          `yaml:"settings"`
	Processors map[string]ProcessorConfig `yaml:"processors,omitempty"`
}

type PipelineConfig

type PipelineConfig struct {
	Status      string                     `yaml:"status"`
	Name        string                     `yaml:"name"`
	Description string                     `yaml:"description"`
	Connectors  map[string]ConnectorConfig `yaml:"connectors,omitempty"`
	Processors  map[string]ProcessorConfig `yaml:"processors,omitempty"`
}

type PipelinesConfig

type PipelinesConfig struct {
	Version   string                    `yaml:"version"`
	Pipelines map[string]PipelineConfig `yaml:"pipelines"`
}

type ProcessorConfig

type ProcessorConfig struct {
	Type     string            `yaml:"type"`
	Settings map[string]string `yaml:"settings"`
}