...
Package replicacount
Package replicacount contains a kio.Filter implementation of the kustomize
ReplicaCountTransformer.
Filter updates/sets replicas fields using the fieldSpecs
type Filter struct {
Replica types.Replica `json:"replica,omitempty" yaml:"replica,omitempty"`
FieldSpec types.FieldSpec `json:"fieldSpec,omitempty" yaml:"fieldSpec,omitempty"`
}
▾ Example
Code:
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 (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