replicacount

Documentation

Overview

Package replicacount contains a kio.Filter implementation of the kustomize ReplicaCountTransformer.

Index

• type Filter
  • func (rc Filter) Filter(nodes []*yaml.RNode) ([]*yaml.RNode, error)
  • func (rc *Filter) WithMutationTracker(callback func(key, value, tag string, node *yaml.RNode))

Examples

• Filter

Types

type Filter

type Filter struct {
	Replica   types.Replica   `json:"replica,omitempty" yaml:"replica,omitempty"`
	FieldSpec types.FieldSpec `json:"fieldSpec,omitempty" yaml:"fieldSpec,omitempty"`
	// contains filtered or unexported fields
}

Filter updates/sets replicas fields using the fieldSpecs

Example

err := kio.Pipeline{
	Inputs: []kio.Reader{&kio.ByteReader{Reader: bytes.NewBufferString(`
apiVersion: example.com/v1
kind: Foo
metadata:
  name: instance
spec:
  template:
    replicas: 5
---
apiVersion: example.com/v1
kind: Bar
metadata:
  name: instance
spec:
  template:
    replicas: 5
`)}},
	Filters: []kio.Filter{Filter{
		Replica: types.Replica{
			Count: 42,
			Name:  "instance",
		},
		FieldSpec: types.FieldSpec{
			Path: "spec/template/replicas",
		},
	}},
	Outputs: []kio.Writer{kio.ByteWriter{Writer: os.Stdout}},
}.Execute()
if err != nil {
	log.Fatal(err)
}

Output:

apiVersion: example.com/v1
kind: Foo
metadata:
  name: instance
spec:
  template:
    replicas: 42
---
apiVersion: example.com/v1
kind: Bar
metadata:
  name: instance
spec:
  template:
    replicas: 42

func (Filter) Filter

func (rc Filter) Filter(nodes []*yaml.RNode) ([]*yaml.RNode, error)

func (*Filter) WithMutationTracker

func (rc *Filter) WithMutationTracker(callback func(key, value, tag string, node *yaml.RNode))

WithMutationTracker registers a callback which will be invoked each time a field is mutated