config

Documentation

Index

• Constants
• Variables
• func PrettyPrint(jsonnetSource string)
• type Config
  • func Parse(filename string, data []byte) (*Config, error)
  • func (c Config) Load(context.Context) (Config, error)
  • func (c Config) Outputs() []*output.Output
  • func (c Config) Validate() error
• type FileLoader
  • func (l FileLoader) Load(context.Context) (*Config, error)
• type Loader
  • func NewCachedLoader(logger kitlog.Logger, loader Loader, ttl time.Duration) Loader
• type LoaderFunc
  • func (l LoaderFunc) Load(ctx context.Context) (*Config, error)
• type Pipeline
  • func (p Pipeline) Validate() error

Constants

const JSONNET_DEF = `` /* 1424-byte string literal not displayed */

Variables

var ReferenceConfig []byte

Functions

func PrettyPrint

func PrettyPrint(jsonnetSource string)

Types

type Config

type Config struct {
	SyncID    string      `json:"sync_id"`
	Pipelines []*Pipeline `json:"pipelines"`
}

func Parse

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

func (Config) Load

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

Load returns currently loaded config

func (Config) Outputs

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

func (Config) Validate

func (c Config) Validate() error

type FileLoader

type FileLoader string

FileLoader loads config from a filepath

func (FileLoader) Load

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

type Loader

type Loader interface {
	Load(context.Context) (*Config, error)
}

func NewCachedLoader

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

NewCachedLoader caches a loader to avoid repeated lookups.

type LoaderFunc

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

func (LoaderFunc) Load

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

type Pipeline

type Pipeline struct {
	Sources []*source.Source `json:"sources"`
	Outputs []*output.Output `json:"outputs"`
}

func (Pipeline) Validate

func (p Pipeline) Validate() error