config

Mar 6, 2024

Changes in this version

+ const JSONNET_DEF

+ var ReferenceConfig []byte

+ func PrettyPrint(jsonnetSource string)

+ type Config struct

+ Pipelines []*Pipeline

+ SyncID string

+ func Parse(filename string, data []byte) (*Config, error)

+ func (c Config) Filter(typeNames []string) *Config

+ func (c Config) Load(context.Context) (Config, error)

+ func (c Config) Outputs() []*output.Output

+ func (c Config) Validate() error

+ type FileLoader string

+ func (l FileLoader) Load(context.Context) (*Config, error)

+ type Loader interface

+ Load func(context.Context) (*Config, error)

+ func NewCachedLoader(logger kitlog.Logger, loader Loader, ttl time.Duration) Loader

+ type LoaderFunc func(context.Context) (*Config, error)

+ func (l LoaderFunc) Load(ctx context.Context) (*Config, error)

+ type Pipeline struct

+ Outputs []*output.Output

+ Sources []*source.Source

+ func (p Pipeline) Validate() error