merger

Documentation

Index

• func MergeAndUpdate(ctx context.Context, client mergeClient, mets *Metrics, list MergeList, ...) (*configpb.Configuration, error)
• type MergeList
  • func ParseAndCheck(data []byte) (list MergeList, err error)
• type Metrics
  • func CreateMetrics(factory metrics.Factory) *Metrics
• type Source

Functions

func MergeAndUpdate

func MergeAndUpdate(ctx context.Context, client mergeClient, mets *Metrics, list MergeList, skipValidate, confirm bool) (*configpb.Configuration, error)

MergeAndUpdate gathers configurations from each path and merges them. Puts the result at targetPath if confirm is true Will skip an input config if it is invalid and skipValidate is false Other problems are considered fatal and will return an error

Types

type MergeList

type MergeList struct {
	Target  string    `json:"Target"`
	Path    *gcs.Path `json:"-"`
	Sources []Source  `json:"Sources"`
}

MergeList is a list of config sources to merge together ParseAndCheck will construct this from a YAML document

func ParseAndCheck

func ParseAndCheck(data []byte) (list MergeList, err error)

ParseAndCheck parses and checks the configuration file for common errors

type Metrics

type Metrics struct {
	Update       metrics.Cyclic
	Fields       metrics.Int64
	LastModified metrics.Int64
}

Metrics holds metrics relevant to the config merger.

func CreateMetrics

func CreateMetrics(factory metrics.Factory) *Metrics

CreateMetrics creates metrics for the Config Merger

type Source

type Source struct {
	Name     string    `json:"Name"`
	Location string    `json:"Location"`
	Path     *gcs.Path `json:"-"`
	Contact  string    `json:"Contact,omitempty"`
}

Source represents a configuration source in cloud storage