fetch

Documentation

Overview

Package fetch provides information retrieval, mostly by wrapping vendir.

Index

• type Factory
  • func NewFactory(coreClient kubernetes.Interface, skipTLSConfig SkipTLSConfig) Factory
  • func (f Factory) NewInline(opts v1alpha1.AppFetchInline, nsName string) *Inline
  • func (f Factory) NewVendir(nsName string) *Vendir
• type Inline
  • func NewInline(opts v1alpha1.AppFetchInline, nsName string, coreClient kubernetes.Interface) *Inline
  • func (t *Inline) Retrieve(dstPath string) error
• type SkipTLSConfig
• type Vendir
  • func NewVendir(nsName string, coreClient kubernetes.Interface, skipTLSConfig SkipTLSConfig) *Vendir
  • func (v *Vendir) AddDir(fetch v1alpha1.AppFetch, dirPath string) error
  • func (v *Vendir) Config() vendirconf.Config
  • func (v *Vendir) ConfigReader() (io.Reader, error)

Types

type Factory

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

func NewFactory

func NewFactory(coreClient kubernetes.Interface, skipTLSConfig SkipTLSConfig) Factory

func (Factory) NewInline

func (f Factory) NewInline(opts v1alpha1.AppFetchInline, nsName string) *Inline

func (Factory) NewVendir

func (f Factory) NewVendir(nsName string) *Vendir

TODO: pass v1alpha1.Vendir opts here once api is exapnded

type Inline

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

Inline struct helps you fetch files or strings from a storage location such as a configmap or secret. For an example if you had a controller in your cluster that generated certs and stored them in a configmap or secret, you could use this inline fetcher to retrieve those certs to pass them on to a templating step.

func NewInline

func NewInline(opts v1alpha1.AppFetchInline, nsName string, coreClient kubernetes.Interface) *Inline

func (*Inline) Retrieve

func (t *Inline) Retrieve(dstPath string) error

type SkipTLSConfig

type SkipTLSConfig interface {
	ShouldSkipTLSForAuthority(authority string) bool
}

type Vendir

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

func NewVendir

func NewVendir(nsName string, coreClient kubernetes.Interface, skipTLSConfig SkipTLSConfig) *Vendir

func (*Vendir) AddDir

func (v *Vendir) AddDir(fetch v1alpha1.AppFetch, dirPath string) error

AddDir adds a directory to vendir's config for each fetcher that the app spec declares. vendir fetches resources into your filesystem, so the destination directory is a core part of vendir config.

func (*Vendir) Config

func (v *Vendir) Config() vendirconf.Config

Config is just for accessing (a copy of) the internal config for testing; you probably don't want to call this IRL

func (*Vendir) ConfigReader

func (v *Vendir) ConfigReader() (io.Reader, error)

ConfigReader generates config yaml bytes and wraps them in a bytes.Reader. These bytes could be written to a file and then passed to vendir but can also be mapped to stdin of the vendir process.