yaml

package
v0.10.7 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 6, 2021 License: Apache-2.0 Imports: 20 Imported by: 615

Documentation

Overview

Package yaml contains libraries for manipulating individual Kubernetes Resource Configuration as yaml, keeping yaml structure and comments.

Parsing Resources

Typically Resources will be initialized as collections through the kio package libraries. However it is possible to directly initialize Resources using Parse. 

resource, err := yaml.Parse("apiVersion: apps/v1\nkind: Deployment")

Processing Resources

Individual Resources are manipulated using the Pipe and PipeE to apply Filter functions to transform the Resource data. 

err := resource.PipeE(yaml.SetAnnotation("key", "value"))

If multiple Filter functions are provided to Pipe or PipeE, each function is applied to the result of the last function -- e.g. yaml.Lookup(...), yaml.SetField(...)

Field values may also be retrieved using Pipe. 

annotationValue, err := resource.Pipe(yaml.GetAnnotation("key"))

See http://www.linfo.org/filters.html for a definition of filters.

Common Filters

There are a number of standard filter functions provided by the yaml package.

Working with annotations: 

[AnnotationSetter{}, AnnotationGetter{}, AnnotationClearer{}]

Working with fields by path: 

[PathMatcher{}, PathGetter{}]

Working with individual fields on Maps and Objects: 

[FieldMatcher{}, FieldSetter{}, FieldGetter{}]

Working with individual elements in Sequences: 

[ElementAppender{}, ElementSetter{}, ElementMatcher{}]

Writing Filters

Users may implement their own filter functions. When doing so, can be necessary to work with the RNode directly rather than through Pipe. RNode provides a number of functions for doing so. See: 

[GetMeta(), Fields(), Elements(), String()]
Example 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
  name: app
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
`)
if err != nil {
	log.Fatal(err)
}

containers, err := Parse(`
- name: nginx # first container
  image: nginx
- name: nginx2 # second container
  image: nginx2
`)
if err != nil {
	log.Fatal(err)
}

node, err := obj.Pipe(
	LookupCreate(SequenceNode, "spec", "template", "spec", "containers"),
	Append(containers.YNode().Content...))
if err != nil {
	log.Fatal(err)
}

fmt.Println(node.String())
fmt.Println(obj.String())

Output:

 <nil>
apiVersion: apps/v1
kind: Deployment
metadata:
  name: app
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
spec:
  template:
    spec:
      containers:
      - name: nginx # first container
        image: nginx
      - name: nginx2 # second container
        image: nginx2
 <nil>

Index

Examples

Constants

View Source 
const (
	// NodeTagNull is the tag set for a yaml.Document that contains no data;
	// e.g. it isn't a Map, Slice, Document, etc
	NodeTagNull   = "!!null"
	NodeTagFloat  = "!!float"
	NodeTagString = "!!str"
	NodeTagBool   = "!!bool"
	NodeTagInt    = "!!int"
	NodeTagMap    = "!!map"
	NodeTagSeq    = "!!seq"
	NodeTagEmpty  = ""
)
View Source 
const (
	AnnotationsField = "annotations"
	APIVersionField  = "apiVersion"
	KindField        = "kind"
	MetadataField    = "metadata"
	DataField        = "data"
	BinaryDataField  = "binaryData"
	NameField        = "name"
	NamespaceField   = "namespace"
	LabelsField      = "labels"
)

Field names

View Source 
const (
	Trim = "Trim"
	Flow = "Flow"
)

Variables

View Source 
var AliasNode yaml.Kind = yaml.AliasNode
View Source 
var AssociativeSequenceKeys = []string{"name"}

AssociativeSequenceKeys is a map of paths to sequences that have associative keys. The order sets the precedence of the merge keys -- if multiple keys are present in Resources in a list, then the FIRST key which ALL elements in the list have is used as the associative key for merging that list. Only infer name as a merge key.

View Source 
var DocumentNode yaml.Kind = yaml.DocumentNode
View Source 
var DoubleQuotedStyle yaml.Style = yaml.DoubleQuotedStyle
View Source 
var ErrMissingMetadata = fmt.Errorf("missing Resource metadata")
View Source 
var FieldOrder = func() map[string]int {

	fo := map[string]int{}
	for i, f := range fieldSortOrder {
		fo[f] = i + 1
	}
	return fo
}()

FieldOrder indexes fields and maps them to relative precedence

View Source 
var Filters = map[string]func() Filter{
	"AnnotationClearer": func() Filter { return &AnnotationClearer{} },
	"AnnotationGetter":  func() Filter { return &AnnotationGetter{} },
	"AnnotationSetter":  func() Filter { return &AnnotationSetter{} },
	"LabelSetter":       func() Filter { return &LabelSetter{} },
	"ElementAppender":   func() Filter { return &ElementAppender{} },
	"ElementMatcher":    func() Filter { return &ElementMatcher{} },
	"FieldClearer":      func() Filter { return &FieldClearer{} },
	"FilterMatcher":     func() Filter { return &FilterMatcher{} },
	"FieldMatcher":      func() Filter { return &FieldMatcher{} },
	"FieldSetter":       func() Filter { return &FieldSetter{} },
	"PathGetter":        func() Filter { return &PathGetter{} },
	"PathMatcher":       func() Filter { return &PathMatcher{} },
	"Parser":            func() Filter { return &Parser{} },
	"PrefixSetter":      func() Filter { return &PrefixSetter{} },
	"ValueReplacer":     func() Filter { return &ValueReplacer{} },
	"SuffixSetter":      func() Filter { return &SuffixSetter{} },
	"TeePiper":          func() Filter { return &TeePiper{} },
}

Filters is the list of serializable Pipeline Filters

View Source 
var FlowStyle yaml.Style = yaml.FlowStyle
View Source 
var FoldedStyle yaml.Style = yaml.FoldedStyle
View Source 
var LiteralStyle yaml.Style = yaml.LiteralStyle
View Source 
var MappingNode yaml.Kind = yaml.MappingNode
View Source 
var Marshal = yaml.Marshal
View Source 
var NewDecoder = yaml.NewDecoder
View Source 
var NewEncoder = func(w io.Writer) *yaml.Encoder {
	e := yaml.NewEncoder(w)
	e.SetIndent(2)
	return e
}
View Source 
var ScalarNode yaml.Kind = yaml.ScalarNode
View Source 
var SequenceNode yaml.Kind = yaml.SequenceNode
View Source 
var SingleQuotedStyle yaml.Style = yaml.SingleQuotedStyle
View Source 
var TaggedStyle yaml.Style = yaml.TaggedStyle
View Source 
var Unmarshal = yaml.Unmarshal
View Source 
var WhitelistedListSortApis = newSet(
	"apps/v1", "apps/v1beta1", "apps/v1beta2", "batch/v1", "batch/v1beta1",
	"extensions/v1beta1", "v1", "admissionregistration.k8s.io/v1")

WhitelistedListSortApis contains the set of apis that are whitelisted for sorting list field elements

View Source 
var WhitelistedListSortFields = map[string]string{
	".spec.template.spec.containers": "name",
	".webhooks.rules.operations":     "",
}

WhitelistedListSortFields contains json paths to list fields that should be sorted, and the field they should be sorted by

View Source 
var WhitelistedListSortKinds = newSet(
	"CronJob", "DaemonSet", "Deployment", "Job", "ReplicaSet", "StatefulSet",
	"ValidatingWebhookConfiguration")

WhitelistedListSortKinds contains the set of kinds that are whitelisted for sorting list field elements

Functions

func ClearEmptyAnnotations added in v0.4.2 

func ClearEmptyAnnotations(rn *RNode) error

ClearEmptyAnnotations clears the keys, annotations and metadata if they are empty/null

func CopyYNode added in v0.6.1 

func CopyYNode(n *yaml.Node) *yaml.Node

CopyYNode returns a distinct copy of its argument. Use https://github.com/jinzhu/copier instead?

func DoSerializationHacks added in v0.1.4 

func DoSerializationHacks(node *yaml.Node)

DoSerializationHacks addresses a bug in yaml V3 upstream, it parses the yaml node, and rearranges the head comments of the children of sequence node. Refer to https://github.com/go-yaml/yaml/issues/587 for more details

func DoSerializationHacksOnNodes added in v0.1.4 

func DoSerializationHacksOnNodes(nodes []*RNode)

func ErrorIfAnyInvalidAndNonNull 

func ErrorIfAnyInvalidAndNonNull(kind yaml.Kind, rn ...*RNode) error

func ErrorIfInvalid 

func ErrorIfInvalid(rn *RNode, kind yaml.Kind) error

func FormatNonStringStyle added in v0.0.6 

func FormatNonStringStyle(node *Node, schema spec.Schema)

FormatNonStringStyle makes sure that values which parse as non-string values in yaml 1.1 are correctly formatted given the Schema type.

func GetValue added in v0.0.6 

func GetValue(node *RNode) string

GetValue returns underlying yaml.Node Value field

func IncrementFieldIndex 

func IncrementFieldIndex(i int) int

IncrementFieldIndex increments i to point to the next field name element in a slice of Contents.

func IsCreate 

func IsCreate(kind yaml.Kind) bool

IsCreate returns true if kind is specified

func IsEmptyMap added in v0.5.0 

func IsEmptyMap(node *RNode) bool

IsEmptyMap returns true if the RNode is an empty node or an empty map. TODO: make this a method on RNode.

func IsFoundOrError 

func IsFoundOrError(rn *RNode, err error) bool

IsFoundOrError returns true if rn is found or err is non-nil

func IsListIndex 

func IsListIndex(p string) bool

IsListIndex returns true if p is an index into a Val. e.g. [fieldName=fieldValue] e.g. [=primitiveValue]

func IsMissingOrError 

func IsMissingOrError(rn *RNode, err error) bool

IsMissingOrError returns true if rn is NOT found or err is non-nil

func IsMissingOrNull 

func IsMissingOrNull(node *RNode) bool

IsMissingOrNull is true if the RNode is nil or explicitly tagged null. TODO: make this a method on RNode.

func IsValueNonString added in v0.1.11 

func IsValueNonString(value string) bool

func IsYNodeEmptyDoc added in v0.5.0 

func IsYNodeEmptyDoc(n *yaml.Node) bool

IsYNodeEmptyDoc is true if the node is a Document with no content. E.g.: "---\n---"

func IsYNodeEmptyMap added in v0.5.0 

func IsYNodeEmptyMap(n *yaml.Node) bool

IsYNodeEmptyMap is true if the Node is a non-nil empty map.

func IsYNodeEmptySeq added in v0.5.0 

func IsYNodeEmptySeq(n *yaml.Node) bool

IsYNodeEmptyMap is true if the Node is a non-nil empty sequence.

func IsYNodeString added in v0.5.0 

func IsYNodeString(n *yaml.Node) bool

func IsYNodeTaggedNull added in v0.6.0 

func IsYNodeTaggedNull(n *yaml.Node) bool

IsYNodeTaggedNull returns true if the node is explicitly tagged Null.

func IsYNodeZero added in v0.10.4 

func IsYNodeZero(n *yaml.Node) bool

IsYNodeZero is true if all the public fields in the Node are empty. Which means it's not initialized and should be omitted when marshal. The Node itself has a method IsZero but it is not released in yaml.v3. https://pkg.go.dev/gopkg.in/yaml.v3#Node.IsZero

func IsYaml1_1NonString added in v0.0.6 

func IsYaml1_1NonString(node *Node) bool

IsYaml1_1NonString returns true if the value parses as a non-string value in yaml 1.1 when unquoted.

Note: yaml 1.2 uses different keywords than yaml 1.1. Example: yaml 1.2 interprets `field: on` and `field: "on"` as equivalent (both strings). However Yaml 1.1 interprets `field: on` as on being a bool and `field: "on"` as on being a string. If an input is read with `field: "on"`, and the style is changed from DoubleQuote to 0, it will change the type of the field from a string to a bool. For this reason, fields which are keywords in yaml 1.1 should never have their style changed, as it would break backwards compatibility with yaml 1.1 -- which is what is used by the Kubernetes apiserver.

func SetK8sName added in v0.10.1 

func SetK8sName(value string) k8sMetaSetter

func SetK8sNamespace added in v0.10.1 

func SetK8sNamespace(value string) k8sMetaSetter

func SortedMapKeys added in v0.10.6 

func SortedMapKeys(m map[string]string) []string

SortedMapKeys returns a sorted slice of keys to the given map. Writing this function never gets old.

func SplitIndexNameValue 

func SplitIndexNameValue(p string) (string, string, error)

SplitIndexNameValue splits a lookup part Val index into the field name and field value to match. e.g. splits [name=nginx] into (name, nginx) e.g. splits [=-jar] into ("", -jar)

func String 

func String(node *yaml.Node, opts ...string) (string, error)

String returns a string value for a Node, applying the supplied formatting options

func UndoSerializationHacks added in v0.1.4 

func UndoSerializationHacks(node *yaml.Node)

UndoSerializationHacks reverts the changes made by DoSerializationHacks Refer to https://github.com/go-yaml/yaml/issues/587 for more details

func UndoSerializationHacksOnNodes added in v0.1.4 

func UndoSerializationHacksOnNodes(nodes []*RNode)

func UpdateFile added in v0.0.12 

func UpdateFile(filter Filter, path string) error

UpdateFile reads the file at path, applies the filter to it, and write the result back. path must contain a exactly 1 resource (YAML).

func WriteFile added in v0.0.12 

func WriteFile(node *RNode, path string) error

WriteFile writes a single Resource to a yaml file

Types

type AnnotationClearer 

type AnnotationClearer struct {
	Kind string `yaml:"kind,omitempty"`
	Key  string `yaml:"key,omitempty"`
}

AnnotationClearer removes an annotation at metadata.annotations. Returns nil if the annotation or field does not exist.

func ClearAnnotation 

func ClearAnnotation(key string) AnnotationClearer

func (AnnotationClearer) Filter 

func (c AnnotationClearer) Filter(rn *RNode) (*RNode, error)

type AnnotationGetter 

type AnnotationGetter struct {
	Kind  string `yaml:"kind,omitempty"`
	Key   string `yaml:"key,omitempty"`
	Value string `yaml:"value,omitempty"`
}

AnnotationGetter gets an annotation at metadata.annotations. Returns nil if metadata.annotations does not exist.

func GetAnnotation 

func GetAnnotation(key string) AnnotationGetter

func (AnnotationGetter) Filter 

func (g AnnotationGetter) Filter(rn *RNode) (*RNode, error)

AnnotationGetter returns the annotation value. Returns "", nil if the annotation does not exist.

type AnnotationSetter 

type AnnotationSetter struct {
	Kind  string `yaml:"kind,omitempty"`
	Key   string `yaml:"key,omitempty"`
	Value string `yaml:"value,omitempty"`
}

AnnotationSetter sets an annotation at metadata.annotations. Creates metadata.annotations if does not exist.

func SetAnnotation 

func SetAnnotation(key, value string) AnnotationSetter

func (AnnotationSetter) Filter 

func (s AnnotationSetter) Filter(rn *RNode) (*RNode, error)

type Comments added in v0.6.1 

type Comments struct {
	LineComment string `yaml:"lineComment,omitempty"`
	HeadComment string `yaml:"headComment,omitempty"`
	FootComment string `yaml:"footComment,omitempty"`
}

Comments struct is comment yaml comment types

type Decoder 

type Decoder = yaml.Decoder

type ElementAppender 

type ElementAppender struct {
	Kind string `yaml:"kind,omitempty"`

	// Elem is the value to append.
	Elements []*yaml.Node `yaml:"elements,omitempty"`
}

ElementAppender adds all element to a SequenceNode's Content. Returns Elements[0] if len(Elements) == 1, otherwise returns nil.

func Append 

func Append(elements ...*yaml.Node) ElementAppender

Append creates an ElementAppender

Example (AppendMap) 
obj, err := Parse(`
- name: foo
- name: bar
`)
if err != nil {
	log.Fatal(err)
}
elem, err := Parse("name: baz")
if err != nil {
	log.Fatal(err)
}
node, err := obj.Pipe(Append(elem.YNode()))
if err != nil {
	log.Fatal(err)
}

// Expect the node to contain the appended element because only
// 1 element was appended
fmt.Println(node.String())
fmt.Println(obj.String())

Output:

name: baz
 <nil>
- name: foo
- name: bar
- name: baz
 <nil>
Example (AppendScalars) 
obj, err := Parse(`
- a
- b
`)
if err != nil {
	log.Fatal(err)
}
_, err = obj.Pipe(Append(&Node{Value: "c", Kind: ScalarNode}))
if err != nil {
	log.Fatal(err)
}
node, err := obj.Pipe(Append(
	&Node{Value: "c", Kind: ScalarNode},
	&Node{Value: "d", Kind: ScalarNode},
))
if err != nil {
	log.Fatal(err)
}
fmt.Println(node.String())
fmt.Println(obj.String())

Output:

 <nil>
- a
- b
- c
- c
- d
 <nil>

func (ElementAppender) Filter 

func (a ElementAppender) Filter(rn *RNode) (*RNode, error)

type ElementIndexer added in v0.9.3 

type ElementIndexer struct {
	Index int
}

ElementIndexer picks the element with a specified index. Index starts from 0 to len(list) - 1. a hyphen ("-") means the last index.

func GetElementByIndex added in v0.9.3 

func GetElementByIndex(index int) ElementIndexer

GetElementByIndex will return a Filter which can be applied to a sequence node to get the element specified by the index

func (ElementIndexer) Filter added in v0.9.3 

func (i ElementIndexer) Filter(rn *RNode) (*RNode, error)

Filter implements Filter

type ElementMatcher 

type ElementMatcher struct {
	Kind string `yaml:"kind,omitempty"`

	// Keys are the list of fields upon which to match this element.
	Keys []string

	// Values are the list of values upon which to match this element.
	Values []string

	// Create will create the Element if it is not found
	Create *RNode `yaml:"create,omitempty"`

	// MatchAnyValue indicates that matcher should only consider the key and ignore
	// the actual value in the list. Values must be empty when MatchAnyValue is
	// set to true.
	MatchAnyValue bool `yaml:"noValue,omitempty"`
}

ElementMatcher returns the first element from a Sequence matching the specified key-value pairs. If there's no match, and no configuration error, the matcher returns nil, nil.

func GetElementByKey added in v0.9.0 

func GetElementByKey(key string) ElementMatcher

func MatchElement 

func MatchElement(field, value string) ElementMatcher

func MatchElementList added in v0.9.4 

func MatchElementList(keys []string, values []string) ElementMatcher

func (ElementMatcher) Filter 

func (e ElementMatcher) Filter(rn *RNode) (*RNode, error)
Example 
obj, err := Parse(`
- a
- b
`)
if err != nil {
	log.Fatal(err)
}
elem, err := obj.Pipe(ElementMatcher{
	Values: []string{"c"}, Create: NewScalarRNode("c"),
})
if err != nil {
	log.Fatal(err)
}

fmt.Println(elem.String())
fmt.Println(obj.String())

Output:

c
 <nil>
- a
- b
- c
 <nil>
Example (ObjectFound) 
obj, err := Parse(`
- name: foo
- name: bar
- name: baz
`)
if err != nil {
	log.Fatal(err)
}
append, err := Parse(`
name: baz
image: nginx
`)
if err != nil {
	log.Fatal(err)
}
elem, err := obj.Pipe(ElementMatcher{
	Keys: []string{"name"}, Values: []string{"baz"}, Create: append})
if err != nil {
	log.Fatal(err)
}
fmt.Println(elem.String())
fmt.Println(obj.String())

Output:

name: baz
 <nil>
- name: foo
- name: bar
- name: baz
 <nil>
Example (ObjectNotFound) 
obj, err := Parse(`
- name: foo
- name: bar
`)
if err != nil {
	log.Fatal(err)
}
append, err := Parse(`
name: baz
image: nginx
`)
if err != nil {
	log.Fatal(err)
}
elem, err := obj.Pipe(ElementMatcher{
	Keys: []string{"name"}, Values: []string{"baz"}, Create: append})
if err != nil {
	log.Fatal(err)
}
fmt.Println(elem.String())
fmt.Println(obj.String())

Output:

name: baz
image: nginx
 <nil>
- name: foo
- name: bar
- name: baz
  image: nginx
 <nil>
Example (PrimitiveFound) 
obj, err := Parse(`
- a
- b
- c
`)
if err != nil {
	log.Fatal(err)
}
elem, err := obj.Pipe(ElementMatcher{
	Keys:   []string{""},
	Values: []string{"c"},
	Create: NewScalarRNode("c"),
})
if err != nil {
	log.Fatal(err)
}
fmt.Println(elem.String())
fmt.Println(obj.String())

Output:

c
 <nil>
- a
- b
- c
 <nil>

type ElementSetter 

type ElementSetter struct {
	Kind string `yaml:"kind,omitempty"`

	// Element is the new value to set -- remove the existing element if nil
	Element *Node

	// Key is a list of fields on the elements. It is used to find matching elements to
	// update / delete
	Keys []string

	// Value is a list of field values on the elements corresponding to the keys. It is
	// used to find matching elements to update / delete.
	Values []string
}

ElementSetter sets the value for an Element in an associative list. ElementSetter will append, replace or delete an element in an associative list. To append, user a key-value pair that doesn't exist in the sequence. this behavior is intended to handle the case that not matching element found. It's not designed for this purpose. To append an element, please use ElementAppender. To replace, set the key-value pair and a non-nil Element. To delete, set the key-value pair and leave the Element as nil. Every key must have a corresponding value.

func (ElementSetter) Filter 

func (e ElementSetter) Filter(rn *RNode) (*RNode, error)

type Encoder 

type Encoder = yaml.Encoder

type FieldClearer 

type FieldClearer struct {
	Kind string `yaml:"kind,omitempty"`

	// Name is the name of the field or key in the map.
	Name string `yaml:"name,omitempty"`

	IfEmpty bool `yaml:"ifEmpty,omitempty"`
}

FieldClearer removes the field or map key. Returns a RNode with the removed field or map entry.

func Clear 

func Clear(name string) FieldClearer

Clear returns a FieldClearer

Example 
obj, err := Parse(`
kind: Deployment
metadata:
  name: app
  annotations:
    a.b.c: d.e.f
    g: h
spec:
  template: {}
`)
if err != nil {
	log.Fatal(err)
}
node, err := obj.Pipe(Clear("metadata"))
if err != nil {
	log.Fatal(err)
}
fmt.Println(node.String())
fmt.Println(obj.String())

Output:

name: app
annotations:
  a.b.c: d.e.f
  g: h
 <nil>
kind: Deployment
spec:
  template: {}
 <nil>

func (FieldClearer) Filter 

func (c FieldClearer) Filter(rn *RNode) (*RNode, error)

type FieldMatcher 

type FieldMatcher struct {
	Kind string `yaml:"kind,omitempty"`

	// Name of the field to return
	Name string `yaml:"name,omitempty"`

	// YNode of the field to return.
	// Optional.  Will only need to match field name if unset.
	Value *RNode `yaml:"value,omitempty"`

	StringValue string `yaml:"stringValue,omitempty"`

	StringRegexValue string `yaml:"stringRegexValue,omitempty"`

	// Create will cause the field to be created with this value
	// if it is set.
	Create *RNode `yaml:"create,omitempty"`
}

FieldMatcher returns the value of a named field or map entry.

func Get 

func Get(name string) FieldMatcher
Example 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
  name: app
  annotations:
    a.b.c: d.e.f
    g: h
spec:
  template: {}
`)
if err != nil {
	log.Fatal(err)
}
node, err := obj.Pipe(Get("metadata"))
if err != nil {
	log.Fatal(err)
}
fmt.Println(node.String())
fmt.Println(obj.String())

Output:

name: app
annotations:
  a.b.c: d.e.f
  g: h
 <nil>
apiVersion: apps/v1
kind: Deployment
metadata:
  name: app
  annotations:
    a.b.c: d.e.f
    g: h
spec:
  template: {}
 <nil>
Example (NotFound) 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
spec:
  template: {}
`)
if err != nil {
	log.Fatal(err)
}
node, err := obj.Pipe(FieldMatcher{Name: "metadata"})
if err != nil {
	log.Fatal(err)
}
fmt.Println(node.String())
fmt.Println(obj.String())

Output:

 <nil>
apiVersion: apps/v1
kind: Deployment
spec:
  template: {}
 <nil>

func Match 

func Match(value string) FieldMatcher

func MatchField 

func MatchField(name, value string) FieldMatcher

func (FieldMatcher) Filter 

func (f FieldMatcher) Filter(rn *RNode) (*RNode, error)
Example 
obj, err := Parse(`
kind: Deployment
spec:
  template: {}
`)
if err != nil {
	log.Fatal(err)
}
value, err := Parse(`
name: app
annotations:
  a.b.c: d.e.f
  g: h
`)
if err != nil {
	log.Fatal(err)
}
elem, err := obj.Pipe(FieldMatcher{
	Name: "metadata", Value: value, Create: value})
if err != nil {
	log.Fatal(err)
}
fmt.Println(elem.String())
fmt.Println(obj.String())

Output:

name: app
annotations:
  a.b.c: d.e.f
  g: h
 <nil>
kind: Deployment
spec:
  template: {}
metadata:
  name: app
  annotations:
    a.b.c: d.e.f
    g: h
 <nil>

type FieldSetter 

type FieldSetter struct {
	Kind string `yaml:"kind,omitempty"`

	// Name is the name of the field or key to lookup in a MappingNode.
	// If Name is unspecified, and the input is a ScalarNode, FieldSetter will set the
	// value on the ScalarNode.
	Name string `yaml:"name,omitempty"`

	// Comments for the field
	Comments Comments `yaml:"comments,omitempty"`

	// Value is the value to set.
	// Optional if Kind is set.
	Value *RNode `yaml:"value,omitempty"`

	StringValue string `yaml:"stringValue,omitempty"`

	// OverrideStyle can be set to override the style of the existing node
	// when setting it.  Otherwise, if an existing node is found, the style is
	// retained.
	OverrideStyle bool `yaml:"overrideStyle,omitempty"`
}

FieldSetter sets a field or map entry to a value.

func Set 

func Set(value *RNode) FieldSetter

func SetField 

func SetField(name string, value *RNode) FieldSetter
Example 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
  name: app
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
`)
if err != nil {
	log.Fatal(err)
}

containers, err := Parse(`
- name: nginx # first container
  image: nginx
- name: nginx2 # second container
  image: nginx2
`)
if err != nil {
	log.Fatal(err)
}

_, err = obj.Pipe(
	LookupCreate(MappingNode, "spec", "template", "spec"),
	SetField("containers", containers))
if err != nil {
	log.Fatal(err)
}

fmt.Println(obj.String())

Output:

apiVersion: apps/v1
kind: Deployment
metadata:
  name: app
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
spec:
  template:
    spec:
      containers:
      - name: nginx # first container
        image: nginx
      - name: nginx2 # second container
        image: nginx2
 <nil>
Example (StringValue) 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
 name: app
`)
if err != nil {
	log.Fatal(err)
}
_, err = obj.Pipe(SetField("foo", NewScalarRNode("bar")))
if err != nil {
	log.Fatal(err)
}

fmt.Println(obj.String())

Output:

apiVersion: apps/v1
kind: Deployment
metadata:
  name: app
foo: bar
 <nil>
Example (StringValueOverwrite) 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
   name: app
foo: baz
`)
if err != nil {
	// handle error
}
// set metadata.annotations.foo = bar
_, err = obj.Pipe(SetField("foo", NewScalarRNode("bar")))
if err != nil {
	// handle error
}

fmt.Println(obj.String())

Output:

apiVersion: apps/v1
kind: Deployment
metadata:
  name: app
foo: bar
 <nil>

func (FieldSetter) Filter 

func (s FieldSetter) Filter(rn *RNode) (*RNode, error)

type Filter 

type Filter interface {
	Filter(object *RNode) (*RNode, error)
}

Filter defines a function to manipulate an individual RNode such as by changing its values, or returning a field.

When possible, Filters should be serializable to yaml so that they can be described declaratively as data.

Analogous to http://www.linfo.org/filters.html

func Tee 

func Tee(filters ...Filter) Filter

Tee calls the provided Filters, and returns its argument rather than the result of the filters. May be used to fork sub-filters from a call. e.g. locate field, set value; locate another field, set another value

Example 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
  name: nginx-deployment
  labels:
    app: nginx
spec:
  replicas: 3
  selector:
    matchLabels:
      app: nginx
  template:
    metadata:
      labels:
        app: nginx
    spec:
      containers:
      - name: nginx
        image: nginx:1.7.9
        ports:
        - containerPort: 80
`)
if err != nil {
	// handle error
}
// set metadata.annotations.foo = bar
_, err = obj.Pipe(
	Lookup("spec", "template", "spec", "containers", "[name=nginx]"),
	Tee(SetField("filter", NewListRNode("foo"))),
	SetField("args", NewListRNode("baz", "bar")))
if err != nil {
	// handle error
}

fmt.Println(obj.String())

Output:

apiVersion: apps/v1
kind: Deployment
metadata:
  name: nginx-deployment
  labels:
    app: nginx
spec:
  replicas: 3
  selector:
    matchLabels:
      app: nginx
  template:
    metadata:
      labels:
        app: nginx
    spec:
      containers:
      - name: nginx
        image: nginx:1.7.9
        ports:
        - containerPort: 80
        filter:
        - foo
        args:
        - baz
        - bar
 <nil>

type FilterFunc 

type FilterFunc func(object *RNode) (*RNode, error)

func (FilterFunc) Filter 

func (f FilterFunc) Filter(object *RNode) (*RNode, error)

type FilterMatcher 

type FilterMatcher struct {
	Kind string `yaml:"kind"`

	// Filters are the set of Filters run by TeePiper.
	Filters YFilters `yaml:"pipeline,omitempty"`
}

func (FilterMatcher) Filter 

func (t FilterMatcher) Filter(rn *RNode) (*RNode, error)

type IsZeroer 

type IsZeroer = yaml.IsZeroer

type Kind 

type Kind = yaml.Kind

type LabelSetter added in v0.1.1 

type LabelSetter struct {
	Kind  string `yaml:"kind,omitempty"`
	Key   string `yaml:"key,omitempty"`
	Value string `yaml:"value,omitempty"`
}

LabelSetter sets a label at metadata.labels. Creates metadata.labels if does not exist.

func SetLabel added in v0.1.1 

func SetLabel(key, value string) LabelSetter

func (LabelSetter) Filter added in v0.1.1 

func (s LabelSetter) Filter(rn *RNode) (*RNode, error)

type MapNode 

type MapNode struct {
	Key   *RNode
	Value *RNode
}

MapNode wraps a field key and value.

func (*MapNode) IsNilOrEmpty added in v0.6.0 

func (mn *MapNode) IsNilOrEmpty() bool

IsNilOrEmpty returns true if the MapNode is nil, has no value, or has a value that appears empty.

type MapNodeSlice 

type MapNodeSlice []*MapNode

func (MapNodeSlice) Keys 

func (m MapNodeSlice) Keys() []*RNode

func (MapNodeSlice) Values 

func (m MapNodeSlice) Values() []*RNode

type Marshaler 

type Marshaler = yaml.Marshaler

type MergeOptions added in v0.9.0 

type MergeOptions struct {
	// ListIncreaseDirection indicates should merge function prepend the items from
	// source list to destination or append.
	ListIncreaseDirection MergeOptionsListIncreaseDirection
}

MergeOptions is a struct which contains the options for merge

type MergeOptionsListIncreaseDirection added in v0.9.0 

type MergeOptionsListIncreaseDirection int

MergeOptionsListIncreaseDirection is the type of list growth in merge 

const (
	MergeOptionsListAppend MergeOptionsListIncreaseDirection = iota
	MergeOptionsListPrepend
)

type NameMeta added in v0.6.1 

type NameMeta struct {
	// Name is the metadata.name field of a Resource
	Name string `json:"name,omitempty" yaml:"name,omitempty"`
	// Namespace is the metadata.namespace field of a Resource
	Namespace string `json:"namespace,omitempty" yaml:"namespace,omitempty"`
}

NameMeta contains name information.

type Node 

type Node = yaml.Node

type ObjectMeta 

type ObjectMeta struct {
	NameMeta `json:",inline" yaml:",inline"`
	// Labels is the metadata.labels field of a Resource
	Labels map[string]string `yaml:"labels,omitempty"`
	// Annotations is the metadata.annotations field of a Resource.
	Annotations map[string]string `yaml:"annotations,omitempty"`
}

ObjectMeta contains metadata about a Resource

type Parser 

type Parser struct {
	Kind  string `yaml:"kind,omitempty"`
	Value string `yaml:"value,omitempty"`
}

Parser parses values into configuration.

func (Parser) Filter 

func (p Parser) Filter(_ *RNode) (*RNode, error)

type PathGetter 

type PathGetter struct {
	Kind string `yaml:"kind,omitempty"`

	// Path is a slice of parts leading to the RNode to lookup.
	// Each path part may be one of:
	// * FieldMatcher -- e.g. "spec"
	// * Map Key -- e.g. "app.k8s.io/version"
	// * List Entry -- e.g. "[name=nginx]" or "[=-jar]" or "0" or "-"
	//
	// Map Keys and Fields are equivalent.
	// See FieldMatcher for more on Fields and Map Keys.
	//
	// List Entries can be specified as map entry to match [fieldName=fieldValue]
	// or a positional index like 0 to get the element. - (unquoted hyphen) is
	// special and means the last element.
	//
	// See Elem for more on List Entries.
	//
	// Examples:
	// * spec.template.spec.container with matching name: [name=nginx]
	// * spec.template.spec.container.argument matching a value: [=-jar]
	Path []string `yaml:"path,omitempty"`

	// Create will cause missing path parts to be created as they are walked.
	//
	// * The leaf Node (final path) will be created with a Kind matching Create
	// * Intermediary Nodes will be created as either a MappingNodes or
	//   SequenceNodes as appropriate for each's Path location.
	// * If a list item is specified by a index (an offset or "-"), this item will
	//   not be created even Create is set.
	Create yaml.Kind `yaml:"create,omitempty"`

	// Style is the style to apply to created value Nodes.
	// Created key Nodes keep an unspecified Style.
	Style yaml.Style `yaml:"style,omitempty"`
}

PathGetter returns the RNode under Path.

func Lookup 

func Lookup(path ...string) PathGetter

Lookup returns a PathGetter to lookup a field by its path.

Example (Element) 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
spec:
  templates:
    spec:
      containers:
      - name: nginx
        image: nginx:latest
`)
if err != nil {
	log.Fatal(err)
}
value, err := obj.Pipe(Lookup(
	"spec", "templates", "spec", "containers", "[name=nginx]"))
if err != nil {
	log.Fatal(err)
}

fmt.Println(value.String())

Output:

name: nginx
image: nginx:latest
 <nil>
Example (NotFound) 
obj, err := Parse(`
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
`)
if err != nil {
	log.Fatal(err)
}
rs, err := obj.Pipe(Lookup("spec", "templates", "spec"))
if err != nil {
	log.Fatal(err)
}

fmt.Println(rs)
fmt.Println("---")
fmt.Println(obj.String())

Output:

 <nil>
---
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
 <nil>
Example (Scalar) 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
spec:
  templates:
    spec:
      containers:
      - name: nginx
        image: nginx:latest
`)
if err != nil {
	log.Fatal(err)
}
value, err := obj.Pipe(Lookup(
	"spec", "templates", "spec", "containers", "[name=nginx]", "image"))
if err != nil {
	log.Fatal(err)
}

fmt.Println(value.String())

Output:

nginx:latest
 <nil>
Example (Sequence) 
obj, err := Parse(`apiVersion: apps/v1
kind: Deployment
metadata:
  labels:
     app: java
  annotations:
    a.b.c: d.e.f
  name: app
spec:
  templates:
    spec:
      containers:
      - name: nginx
        image: nginx:latest
`)
if err != nil {
	log.Fatal(err)
}
value, err := obj.Pipe(Lookup(
	"spec", "templates", "spec", "containers"))
if err != nil {
	log.Fatal(err)
}

fmt.Println(value.String())

Output:

- name: nginx
  image: nginx:latest
 <nil>

func LookupCreate 

func LookupCreate(kind yaml.Kind, path ...string) PathGetter

Lookup returns a PathGetter to lookup a field by its path and create it if it doesn't already exist.

Example (Element) 
obj, err := Parse(`
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
`)
if err != nil {
	log.Fatal(err)
}
rs, err := obj.Pipe(LookupCreate(
	MappingNode, "spec", "templates", "spec", "containers", "[name=nginx]"))
if err != nil {
	log.Fatal(err)
}

fmt.Println(rs.String())
fmt.Println("---")
fmt.Println(obj.String())

Output:

name: nginx
 <nil>
---
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
spec:
  templates:
    spec:
      containers:
      - name: nginx
 <nil>
Example (Object) 
obj, err := Parse(`
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
`)
if err != nil {
	log.Fatal(err)
}
rs, err := obj.Pipe(LookupCreate(
	MappingNode, "spec", "templates", "spec"))
if err != nil {
	log.Fatal(err)
}

fmt.Println(rs.String())
fmt.Println("---")
fmt.Println(obj.String())

Output:

{}
 <nil>
---
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
spec:
  templates:
    spec: {}
 <nil>
Example (Sequence) 
obj, err := Parse(`
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
`)
if err != nil {
	log.Fatal(err)
}
rs, err := obj.Pipe(LookupCreate(
	SequenceNode, "spec", "templates", "spec", "containers"))
if err != nil {
	log.Fatal(err)
}

fmt.Println(rs.String())
fmt.Println("---")
fmt.Println(obj.String())

Output:

[]
 <nil>
---
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
spec:
  templates:
    spec:
      containers: []
 <nil>

func (PathGetter) Filter 

func (l PathGetter) Filter(rn *RNode) (*RNode, error)
Example 
obj, err := Parse(`
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
`)
if err != nil {
	log.Fatal(err)
}
rs, err := obj.Pipe(PathGetter{
	Path:   []string{"spec", "templates", "spec", "containers", "[name=nginx]", "image"},
	Create: ScalarNode,
})
if err != nil {
	log.Fatal(err)
}
rs.Document().Style = SingleQuotedStyle

fmt.Println(rs.String())
fmt.Println("---")
fmt.Println(obj.String())

Output:

''
 <nil>
---
kind: Deployment
metadata:
  labels:
    app: java
  annotations:
    a.b.c: d.e.f
  name: app
spec:
  templates:
    spec:
      containers:
      - name: nginx
        image: ''
 <nil>

type PathMatcher 

type PathMatcher struct {
	Kind string `yaml:"kind,omitempty"`

	// Path is a slice of parts leading to the RNode to lookup.
	// Each path part may be one of:
	// * FieldMatcher -- e.g. "spec"
	// * Map Key -- e.g. "app.k8s.io/version"
	// * List Entry -- e.g. "[name=nginx]" or "[=-jar]"
	//
	// Map Keys and Fields are equivalent.
	// See FieldMatcher for more on Fields and Map Keys.
	//
	// List Entries are specified as map entry to match [fieldName=fieldValue].
	// See Elem for more on List Entries.
	//
	// Examples:
	// * spec.template.spec.container with matching name: [name=nginx] -- match 'name': 'nginx'
	// * spec.template.spec.container.argument matching a value: [=-jar] -- match '-jar'
	Path []string `yaml:"path,omitempty"`

	// Matches is set by PathMatch to publish the matched element values for each node.
	// After running  PathMatcher.Filter, each node from the SequenceNode result may be
	// looked up in Matches to find the field values that were matched.
	Matches map[*Node][]string

	// StripComments may be set to remove the comments on the matching Nodes.
	// This is useful for if the nodes are to be printed in FlowStyle.
	StripComments bool
	// contains filtered or unexported fields
}

PathMatcher returns all RNodes matching the path wrapped in a SequenceNode. Lists may have multiple elements matching the path, and each matching element is added to the return result. If Path points to a SequenceNode, the SequenceNode is wrapped in another SequenceNode If Path does not contain any lists, the result is still wrapped in a SequenceNode of len == 1

func (*PathMatcher) Filter 

func (p *PathMatcher) Filter(rn *RNode) (*RNode, error)

type PrefixSetter 

type PrefixSetter struct {
	Kind string `yaml:"kind"`

	Value string `yaml:"value"`
}

func (PrefixSetter) Filter 

func (s PrefixSetter) Filter(object *RNode) (*RNode, error)

type RNode 

type RNode struct {
	Match []string
	// contains filtered or unexported fields
}

RNode provides functions for manipulating Kubernetes Resources Objects unmarshalled into *yaml.Nodes

func ConvertJSONToYamlNode added in v0.1.12 

func ConvertJSONToYamlNode(jsonStr string) (*RNode, error)

ConvertJSONToYamlNode parses input json string and returns equivalent yaml node

func FromMap added in v0.10.0 

func FromMap(m map[string]interface{}) (*RNode, error)

func MakeNullNode added in v0.5.0 

func MakeNullNode() *RNode

MakeNullNode returns an RNode that represents an empty document.

func MustParse 

func MustParse(value string) *RNode

MustParse parses a yaml string into an *RNode and panics if there is an error

func NewListRNode 

func NewListRNode(values ...string) *RNode

NewListRNode returns a new List *RNode containing the provided scalar values.

func NewMapRNode added in v0.4.1 

func NewMapRNode(values *map[string]string) *RNode

NewMapRNode returns a new Map *RNode containing the provided values

func NewRNode 

func NewRNode(value *yaml.Node) *RNode

NewRNode returns a new RNode pointer containing the provided Node.

func NewScalarRNode 

func NewScalarRNode(value string) *RNode

NewScalarRNode returns a new Scalar *RNode containing the provided scalar value.

func NewStringRNode added in v0.10.1 

func NewStringRNode(value string) *RNode

NewStringRNode returns a new Scalar *RNode containing the provided string. If the string is non-utf8, it will be base64 encoded, and the tag will indicate binary data.

func Parse 

func Parse(value string) (*RNode, error)

Parse parses a yaml string into an *RNode. To parse multiple resources, consider a kio.ByteReader

func ReadFile added in v0.0.12 

func ReadFile(path string) (*RNode, error)

ReadFile parses a single Resource from a yaml file. To parse multiple resources, consider a kio.ByteReader

func (*RNode) AppendToFieldPath 

func (rn *RNode) AppendToFieldPath(parts ...string)

AppendToFieldPath appends a field name to the FieldPath.

func (*RNode) Content 

func (rn *RNode) Content() []*yaml.Node

Content returns Node Content field.

func (*RNode) Copy added in v0.6.1 

func (rn *RNode) Copy() *RNode

Copy returns a distinct copy.

func (*RNode) Document 

func (rn *RNode) Document() *yaml.Node

Document returns the Node for the value.

func (*RNode) Element 

func (rn *RNode) Element(key, value string) *RNode

Element returns the element in the list which contains the field matching the value. Returns nil for non-SequenceNodes or if no Element matches.

func (*RNode) ElementList added in v0.9.4 

func (rn *RNode) ElementList(keys []string, values []string) *RNode

ElementList returns the element in the list in which all fields keys[i] matches all corresponding values[i]. Returns nil for non-SequenceNodes or if no Element matches.

func (*RNode) ElementValues 

func (rn *RNode) ElementValues(key string) ([]string, error)

ElementValues returns a list of all observed values for a given field name in a list of elements. Returns error for non-SequenceNodes.

Example 
resource, err := Parse(`
- name: foo
  args: ['run.sh']
- name: bar
  args: ['run.sh']
- name: baz
  args: ['run.sh']
`)
if err != nil {
	log.Fatal(err)
}

fmt.Println(resource.ElementValues("name"))

Output:

[foo bar baz] <nil>

func (*RNode) ElementValuesList added in v0.9.4 

func (rn *RNode) ElementValuesList(keys []string) ([][]string, error)

ElementValuesList returns a list of lists, where each list is a set of values corresponding to each key in keys. Returns error for non-SequenceNodes.

func (*RNode) Elements 

func (rn *RNode) Elements() ([]*RNode, error)

Elements returns the list of elements in the RNode. Returns an error for non-SequenceNodes.

Example 
resource, err := Parse(`
- name: foo
  args: ['run.sh']
- name: bar
  args: ['run.sh']
- name: baz
  args: ['run.sh']
`)
if err != nil {
	log.Fatal(err)
}
elements, err := resource.Elements()
if err != nil {
	log.Fatal(err)
}
for i, e := range elements {
	fmt.Printf("Element: %d\n", i)
	fmt.Println(e.MustString())
}

Output:

Element: 0
name: foo
args: ['run.sh']

Element: 1
name: bar
args: ['run.sh']

Element: 2
name: baz
args: ['run.sh']

func (*RNode) Field 

func (rn *RNode) Field(field string) *MapNode

Field returns a fieldName, fieldValue pair for MappingNodes. Returns nil for non-MappingNodes.

func (*RNode) FieldPath 

func (rn *RNode) FieldPath() []string

FieldPath returns the field path from the Resource root node, to rn. Does not include list indexes.

func (*RNode) FieldRNodes added in v0.6.1 

func (rn *RNode) FieldRNodes() ([]*RNode, error)

FieldRNodes returns the list of field key RNodes for a MappingNode. Returns an error for non-MappingNodes.

func (*RNode) Fields 

func (rn *RNode) Fields() ([]string, error)

Fields returns the list of field names for a MappingNode. Returns an error for non-MappingNodes.

func (*RNode) GetAnnotations added in v0.10.2 

func (rn *RNode) GetAnnotations() (map[string]string, error)

GetAnnotations gets the metadata annotations field.

func (*RNode) GetAssociativeKey 

func (rn *RNode) GetAssociativeKey() string

GetAssociativeKey returns the AssociativeSequenceKey used to merge the elements in the SequenceNode, or "" if the list is not associative.

func (*RNode) GetDataMap added in v0.10.4 

func (rn *RNode) GetDataMap() map[string]string

func (*RNode) GetLabels added in v0.10.2 

func (rn *RNode) GetLabels() (map[string]string, error)

GetLabels gets the metadata labels field.

func (*RNode) GetMeta 

func (rn *RNode) GetMeta() (ResourceMeta, error)

GetMeta returns the ResourceMeta for an RNode

func (*RNode) GetNamespace added in v0.10.2 

func (rn *RNode) GetNamespace() (string, error)

GetNamespace gets the metadata namespace field.

func (*RNode) GetValidatedMetadata added in v0.10.0 

func (rn *RNode) GetValidatedMetadata() (ResourceMeta, error)

GetValidatedMetadata returns metadata after subjecting it to some tests.

func (*RNode) HasNilEntryInList added in v0.10.0 

func (rn *RNode) HasNilEntryInList() (bool, string)

HasNilEntryInList returns true if the RNode contains a list which has a nil item, along with the path to the missing item. TODO(broken): This was copied from api/k8sdeps/kunstruct/factory.go//checkListItemNil and doesn't do what it claims to do (see TODO in unit test and pr 1513).

func (*RNode) IsAssociative 

func (rn *RNode) IsAssociative() bool

IsAssociative returns true if the RNode contains an AssociativeSequenceKey as a field.

func (*RNode) IsNil added in v0.6.0 

func (rn *RNode) IsNil() bool

IsNil is true if the node is nil, or its underlying YNode is nil.

func (*RNode) IsNilOrEmpty added in v0.6.0 

func (rn *RNode) IsNilOrEmpty() bool

IsNilOrEmpty is true if the node is nil, has no YNode, or has YNode that appears empty.

func (*RNode) IsTaggedNull added in v0.6.0 

func (rn *RNode) IsTaggedNull() bool

IsTaggedNull is true if a non-nil node is explicitly tagged Null.

func (*RNode) LoadMapIntoConfigMapData added in v0.10.6 

func (rn *RNode) LoadMapIntoConfigMapData(m map[string]string) error

func (*RNode) LoadMapIntoSecretData added in v0.10.6 

func (rn *RNode) LoadMapIntoSecretData(m map[string]string) error

func (*RNode) Map added in v0.10.6 

func (rn *RNode) Map() map[string]interface{}

func (*RNode) MarshalJSON added in v0.1.5 

func (rn *RNode) MarshalJSON() ([]byte, error)

MarshalJSON creates a byte slice from the RNode.

func (*RNode) MatchesAnnotationSelector added in v0.10.2 

func (rn *RNode) MatchesAnnotationSelector(selector string) (bool, error)

MatchesAnnotationSelector implements ifc.Kunstructured.

func (*RNode) MatchesLabelSelector added in v0.10.2 

func (rn *RNode) MatchesLabelSelector(selector string) (bool, error)

MatchesLabelSelector implements ifc.Kunstructured.

func (*RNode) MustString 

func (rn *RNode) MustString() string

MustString returns string representation of the RNode or panics if there is an error

func (*RNode) Pipe 

func (rn *RNode) Pipe(functions ...Filter) (*RNode, error)

Pipe sequentially invokes each Filter, and passes the result to the next Filter.

Analogous to http://www.linfo.org/pipes.html

* rn is provided as input to the first Filter. * if any Filter returns an error, immediately return the error * if any Filter returns a nil RNode, immediately return nil, nil * if all Filters succeed with non-empty results, return the final result

func (*RNode) PipeE 

func (rn *RNode) PipeE(functions ...Filter) error

PipeE runs Pipe, dropping the *RNode return value. Useful for directly returning the Pipe error value from functions.

func (*RNode) SetAnnotations added in v0.10.2 

func (rn *RNode) SetAnnotations(m map[string]string) error

SetAnnotations tries to set the metadata annotations field.

func (*RNode) SetDataMap added in v0.10.4 

func (rn *RNode) SetDataMap(m map[string]string)

func (*RNode) SetLabels added in v0.10.2 

func (rn *RNode) SetLabels(m map[string]string) error

SetLabels sets the metadata labels field.

func (*RNode) SetMapField added in v0.10.2 

func (rn *RNode) SetMapField(value *RNode, path ...string) error

func (*RNode) SetNamespace added in v0.10.2 

func (rn *RNode) SetNamespace(ns string) error

SetNamespace tries to set the metadata namespace field.

func (*RNode) SetYNode 

func (rn *RNode) SetYNode(node *yaml.Node)

SetYNode sets the yaml.Node value on an RNode.

func (*RNode) String 

func (rn *RNode) String() (string, error)

String returns string representation of the RNode

func (*RNode) UnmarshalJSON added in v0.1.5 

func (rn *RNode) UnmarshalJSON(b []byte) error

UnmarshalJSON overwrites this RNode with data from []byte.

func (*RNode) VisitElements 

func (rn *RNode) VisitElements(fn func(node *RNode) error) error

VisitElements calls fn for each element in a SequenceNode. Returns an error for non-SequenceNodes

func (*RNode) VisitFields 

func (rn *RNode) VisitFields(fn func(node *MapNode) error) error

VisitFields calls fn for each field in the RNode. Returns an error for non-MappingNodes.

func (*RNode) YNode 

func (rn *RNode) YNode() *yaml.Node

YNode returns the yaml.Node value. If the yaml.Node value is a DocumentNode, YNode will return the DocumentNode Content entry instead of the DocumentNode.

type ResourceIdentifier 

type ResourceIdentifier struct {
	TypeMeta `json:",inline" yaml:",inline"`
	NameMeta `json:",inline" yaml:",inline"`
}

ResourceIdentifier contains the information needed to uniquely identify a resource in a cluster.

func (*ResourceIdentifier) GetAPIVersion 

func (r *ResourceIdentifier) GetAPIVersion() string

func (*ResourceIdentifier) GetKind 

func (r *ResourceIdentifier) GetKind() string

func (*ResourceIdentifier) GetName 

func (r *ResourceIdentifier) GetName() string

func (*ResourceIdentifier) GetNamespace 

func (r *ResourceIdentifier) GetNamespace() string

type ResourceMeta 

type ResourceMeta struct {
	TypeMeta `json:",inline" yaml:",inline"`
	// ObjectMeta is the metadata field of a Resource
	ObjectMeta `yaml:"metadata,omitempty"`
}

ResourceMeta contains the metadata for a both Resource Type and Resource.

func (*ResourceMeta) GetIdentifier 

func (m *ResourceMeta) GetIdentifier() ResourceIdentifier

GetIdentifier returns a ResourceIdentifier that includes the information needed to uniquely identify a resource in a cluster.

type Style 

type Style = yaml.Style

func GetStyle 

func GetStyle(styles ...string) Style

TODO(pwittrock): test this

type SuffixSetter 

type SuffixSetter struct {
	Kind string `yaml:"kind"`

	Value string `yaml:"value"`
}

func (SuffixSetter) Filter 

func (s SuffixSetter) Filter(object *RNode) (*RNode, error)

type TeePiper 

type TeePiper struct {
	Kind string `yaml:"kind,omitempty"`

	// Filters are the set of Filters run by TeePiper.
	Filters []Filter `yaml:"filters,omitempty"`
}

TeePiper Calls a slice of Filters and returns its input. May be used to fork sub-filters from a call. e.g. locate field, set value; locate another field, set another value

func (TeePiper) Filter 

func (t TeePiper) Filter(rn *RNode) (*RNode, error)

type TypeError 

type TypeError = yaml.TypeError

type TypeMeta added in v0.0.6 

type TypeMeta struct {
	// APIVersion is the apiVersion field of a Resource
	APIVersion string `json:"apiVersion,omitempty" yaml:"apiVersion,omitempty"`
	// Kind is the kind field of a Resource
	Kind string `json:"kind,omitempty" yaml:"kind,omitempty"`
}

TypeMeta partially copies apimachinery/pkg/apis/meta/v1.TypeMeta No need for a direct dependence; the fields are stable.

type Unmarshaler 

type Unmarshaler = yaml.Unmarshaler

type ValueReplacer 

type ValueReplacer struct {
	Kind string `yaml:"kind"`

	StringMatch string `yaml:"stringMatch"`
	RegexMatch  string `yaml:"regexMatch"`
	Replace     string `yaml:"replace"`
	Count       int    `yaml:"count"`
}

func (ValueReplacer) Filter 

func (s ValueReplacer) Filter(object *RNode) (*RNode, error)

type YFilter 

type YFilter struct {
	Filter
}

YFilter wraps the Filter interface so the filter can be represented as data and can be unmarshalled into a struct from a yaml config file. This allows Pipelines to be expressed as data rather than code.

func (YFilter) MarshalYAML 

func (y YFilter) MarshalYAML() (interface{}, error)

func (*YFilter) UnmarshalYAML 

func (y *YFilter) UnmarshalYAML(unmarshal func(interface{}) error) error

type YFilters 

type YFilters []YFilter

func (YFilters) Filters 

func (y YFilters) Filters() []Filter

Source Files

View all Source files

Directories

Path Synopsis
internal
k8sgen
Package k8sgen contains code generated by copying bits of k8s.io code.
 Package k8sgen contains code generated by copying bits of k8s.io code.
k8sgen/pkg/labels
k8sgen/pkg/selection
k8sgen/pkg/util/errors
k8sgen/pkg/util/sets
k8sgen/pkg/util/validation
k8sgen/pkg/util/validation/field
Package merge contains libraries for merging fields from one RNode to another RNode
 Package merge contains libraries for merging fields from one RNode to another RNode
Package merge contains libraries for merging fields from one RNode to another RNode
 Package merge contains libraries for merging fields from one RNode to another RNode
Package schema contains libraries for working with the yaml and openapi packages.
 Package schema contains libraries for working with the yaml and openapi packages.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.