pipes

Documentation

Index

• Variables
• func CommandReaders(cmd *cobra.Command, args []string) []kio.Reader
• func CommandWriters(cmd *cobra.Command, overwriteFiles bool) []kio.Writer
• func Decode(values ...interface{}) kio.Writer
• func Encode(values ...interface{}) kio.Reader
• type ErrorReader
  • func (r ErrorReader) Read() ([]*yaml.RNode, error)
• type ExecReader
  • func (c *ExecReader) Read() ([]*yaml.RNode, error)
• type ExecWriter
  • func (c *ExecWriter) Write(nodes []*yaml.RNode) error
• type HelmValues
  • func (f *HelmValues) Read() ([]*yaml.RNode, error)
• type Kubectl
  • func (k *Kubectl) Apply(ctx context.Context, dryRun string) *ExecWriter
  • func (k *Kubectl) Command(ctx context.Context, args ...string) *exec.Cmd
  • func (k *Kubectl) Create(ctx context.Context, dryRun string) *ExecWriter
  • func (k *Kubectl) Delete(ctx context.Context, dryRun string, ignoreNotFound bool) *ExecWriter
  • func (k *Kubectl) Get(ctx context.Context, objs ...string) *ExecReader
  • func (k *Kubectl) Reader(ctx context.Context, args ...string) *ExecReader
  • func (k *Kubectl) Writer(ctx context.Context, args ...string) *ExecWriter
• type ReadOneFunc
  • func (r ReadOneFunc) Read() ([]*yaml.RNode, error)
• type ReaderFunc
  • func (r ReaderFunc) Read() ([]*yaml.RNode, error)
• type TemplateReader
  • func (c *TemplateReader) Read() ([]*yaml.RNode, error)

Variables

var CommandWriterFormatFlag = "output"

CommandWriterFormatFlag is a global that can be overwritten to change the name of the flag used to get the output format from the command.

Functions

func CommandReaders

func CommandReaders(cmd *cobra.Command, args []string) []kio.Reader

CommandReaders returns KYAML readers for the supplied file name arguments.

func CommandWriters

func CommandWriters(cmd *cobra.Command, overwriteFiles bool) []kio.Writer

CommandWriters returns KYAML writers for the supplied command.

func Decode

func Decode(values ...interface{}) kio.Writer

Decode returns a writer over the YAML decoding (one per resource document).

func Encode

func Encode(values ...interface{}) kio.Reader

Encode returns a reader over the YAML encoding of the specified values.

Types

type ErrorReader

type ErrorReader struct{ Err error }

ErrorReader is an adapter to allow the use of an error as a kio.Reader.

func (ErrorReader) Read

func (r ErrorReader) Read() ([]*yaml.RNode, error)

Reader returns the wrapped failure.

type ExecReader

type ExecReader struct {
	// The YAML producing command.
	*exec.Cmd
}

ExecReader is a KYAML reader that consumes YAML from another process via stdout.

func (*ExecReader) Read

func (c *ExecReader) Read() ([]*yaml.RNode, error)

Read executes the supplied command and parses the output as a YAML document stream.

type ExecWriter

type ExecWriter struct {
	// The YAML consuming command.
	*exec.Cmd
}

ExecWriter is a KYAML writer that sends YAML to another process via stdin.

func (*ExecWriter) Write

func (c *ExecWriter) Write(nodes []*yaml.RNode) error

Write executes the supplied command, piping the generated YAML to stdin.

type HelmValues

type HelmValues struct {
	// User specified values files (via -f/--values).
	ValueFiles []string
	// User specified values (via --set).
	Values []string
	// User specified string values (via --set-string).
	StringValues []string
	// User specified file values (via --set-file).
	FileValues []string

	// The file system to use for resolving file contents (defaults to the OS reader).
	FS fs.FS
}

HelmValues is a reader that emits resource nodes representing Helm values.

func (*HelmValues) Read

func (f *HelmValues) Read() ([]*yaml.RNode, error)

Read converts the configured user specified values into resource nodes.

type Kubectl

type Kubectl struct {
	// The path the kubectl binary, defaults to `kubectl`.
	Bin string
	// The path to the kubeconfig.
	KubeConfig string
	// The context name.
	Context string
	// The namespace name.
	Namespace string
	// The length of time to wait before giving up on a single request.
	RequestTimeout time.Duration
}

Kubectl is used for executing `kubectl` as part of a KYAML pipeline.

func (*Kubectl) Apply

func (k *Kubectl) Apply(ctx context.Context, dryRun string) *ExecWriter

Apply returns a sink for applying resources via kubectl.

func (*Kubectl) Command

func (k *Kubectl) Command(ctx context.Context, args ...string) *exec.Cmd

Command creates a new executable command with the configured global flags and the supplied arguments.

func (*Kubectl) Create

func (k *Kubectl) Create(ctx context.Context, dryRun string) *ExecWriter

Create returns a sink for creating resources via kubectl.

func (*Kubectl) Delete

func (k *Kubectl) Delete(ctx context.Context, dryRun string, ignoreNotFound bool) *ExecWriter

Delete returns a sink for deleting resources via kubectl.

func (*Kubectl) Get

func (k *Kubectl) Get(ctx context.Context, objs ...string) *ExecReader

Get returns a source for getting resources via kubectl.

func (*Kubectl) Reader

func (k *Kubectl) Reader(ctx context.Context, args ...string) *ExecReader

Reader returns a kio.Reader for the specified kubectl arguments.

func (*Kubectl) Writer

func (k *Kubectl) Writer(ctx context.Context, args ...string) *ExecWriter

Writer returns a kio.Writer for the specified kubectl arguments.

type ReadOneFunc

type ReadOneFunc func() (*yaml.RNode, error)

ReadOneFunc is an adapter to allow the use of single node returning functions as a kio.Reader.

func (ReadOneFunc) Read

func (r ReadOneFunc) Read() ([]*yaml.RNode, error)

Read evaluates the typed function and wraps the resulting non-nil node.

type ReaderFunc

type ReaderFunc func() ([]*yaml.RNode, error)

ReaderFunc is an adapter to allow the use of ordinary functions as a kio.Reader.

func (ReaderFunc) Read

func (r ReaderFunc) Read() ([]*yaml.RNode, error)

Read evaluates the typed function.

type TemplateReader

type TemplateReader struct {
	// The template to execute.
	Template *template.Template
	// The data for the template.
	Data interface{}
}

TemplateReader is a KYAML reader that consumes YAML from a Go template.

func (*TemplateReader) Read

func (c *TemplateReader) Read() ([]*yaml.RNode, error)

Read executes the supplied template and parses the output as a YAML document stream.