kio

Documentation

Index

• func NewPipeline(reader io.Reader, writer io.Writer, keepReaderAnnotations bool) kio.Pipeline
• type Filter
  • func (f Filter) Filter(in []*yaml.RNode) ([]*yaml.RNode, error)

Functions

func NewPipeline

func NewPipeline(reader io.Reader, writer io.Writer, keepReaderAnnotations bool) kio.Pipeline

NewPipeline creates a new kio.Pipeline with the given reader, writer, and keepReaderAnnotations flag. It returns the created pipeline.

Parameters: - reader: an io.Reader used to read the input data - writer: an io.Writer used to write the output data - keepReaderAnnotations: a boolean flag indicating whether to keep the annotations from the input data

Return: A kio.Pipeline object that reads data from the given reader, runs it through a filter, and writes it to the given writer.

Pipeline reads Resource Configuration from a set of Inputs, applies some transformation filters, and writes the results to a set of Outputs.

Types

type Filter

type Filter struct {
	// contains filtered or unexported fields
}

Filter implements kio.Filter

func (Filter) Filter

func (f Filter) Filter(in []*yaml.RNode) ([]*yaml.RNode, error)

Filter checks each input and ensures that all containers have cpu and memory reservations set, otherwise it returns an error.