store

Documentation

Index

• Constants
• func FetchArtifact(reader ArtifactReader, gvk *metav1.GroupVersionKind) (*unstructured.Unstructured, error)
• func GetSecrets(client kubernetes.Interface, namespace string, name, key string) (string, error)
• func NewMinioClient(s3 *apicommon.S3Artifact, creds Credentials) (*minio.Client, error)
• type ArtifactReader
  • func GetArtifactReader(loc *ss_v1alpha1.ArtifactLocation, creds *Credentials, ...) (ArtifactReader, error)
  • func NewFileReader(fileArtifact *v1alpha1.FileArtifact) (ArtifactReader, error)
  • func NewInlineReader(inlineArtifact *string) (ArtifactReader, error)
  • func NewS3Reader(s3 *apicommon.S3Artifact, creds *Credentials) (ArtifactReader, error)
  • func NewURLReader(urlArtifact *v1alpha1.URLArtifact) (ArtifactReader, error)
• type ConfigMapReader
  • func NewConfigMapReader(kubeClientset kubernetes.Interface, ...) (*ConfigMapReader, error)
  • func (c *ConfigMapReader) Read() (body []byte, err error)
• type Credentials
  • func GetCredentials(kubeClient kubernetes.Interface, namespace string, ...) (*Credentials, error)
• type FileReader
  • func (reader *FileReader) Read() ([]byte, error)
• type GitArtifactReader
  • func NewGitReader(kubeClientset kubernetes.Interface, gitArtifact *v1alpha1.GitArtifact) (*GitArtifactReader, error)
  • func (g *GitArtifactReader) Read() ([]byte, error)
• type InlineReader
  • func (reader *InlineReader) Read() ([]byte, error)
• type S3Reader
  • func (reader *S3Reader) Read() ([]byte, error)
• type URLReader
  • func (reader *URLReader) Read() ([]byte, error)

Constants

const (
	DefaultRemote = "origin"
	DefaultBranch = "master"
)

Functions

func FetchArtifact

func FetchArtifact(reader ArtifactReader, gvk *metav1.GroupVersionKind) (*unstructured.Unstructured, error)

FetchArtifact from the location, decode it using explicit types, and unstructure it

func GetSecrets

func GetSecrets(client kubernetes.Interface, namespace string, name, key string) (string, error)

GetSecrets retrieves the secret value from the secret in namespace with name and key

func NewMinioClient

func NewMinioClient(s3 *apicommon.S3Artifact, creds Credentials) (*minio.Client, error)

NewMinioClient instantiates a new minio client object to access s3 compatible APIs

Types

type ArtifactReader

type ArtifactReader interface {
	Read() ([]byte, error)
}

ArtifactReader enables reading artifacts from an external store

func GetArtifactReader

func GetArtifactReader(loc *ss_v1alpha1.ArtifactLocation, creds *Credentials, clientset kubernetes.Interface) (ArtifactReader, error)

GetArtifactReader returns the ArtifactReader for this location

func NewFileReader

func NewFileReader(fileArtifact *v1alpha1.FileArtifact) (ArtifactReader, error)

NewFileReader creates a new ArtifactReader for inline

func NewInlineReader

func NewInlineReader(inlineArtifact *string) (ArtifactReader, error)

NewInlineReader creates a new ArtifactReader for inline

func NewS3Reader

func NewS3Reader(s3 *apicommon.S3Artifact, creds *Credentials) (ArtifactReader, error)

NewS3Reader creates a new ArtifactReader for an S3 compatible store

func NewURLReader

func NewURLReader(urlArtifact *v1alpha1.URLArtifact) (ArtifactReader, error)

NewURLReader creates a new ArtifactReader for workflows at URL endpoints.

type ConfigMapReader

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

ConfigMapReader implements the ArtifactReader interface for k8 configmap

func NewConfigMapReader

func NewConfigMapReader(kubeClientset kubernetes.Interface, configmapArtifact *v1alpha1.ConfigmapArtifact) (*ConfigMapReader, error)

NewConfigMapReader returns a new configmap reader

func (*ConfigMapReader) Read

func (c *ConfigMapReader) Read() (body []byte, err error)

type Credentials

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

Credentials contains the information necessary to access the artifact

func GetCredentials

func GetCredentials(kubeClient kubernetes.Interface, namespace string, art *v1alpha1.ArtifactLocation) (*Credentials, error)

GetCredentials for this artifact

type FileReader

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

FileReader implements the ArtifactReader interface for file artifacts

func (*FileReader) Read

func (reader *FileReader) Read() ([]byte, error)

type GitArtifactReader

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

func NewGitReader

func NewGitReader(kubeClientset kubernetes.Interface, gitArtifact *v1alpha1.GitArtifact) (*GitArtifactReader, error)

NewGitReader returns a new git reader

func (*GitArtifactReader) Read

func (g *GitArtifactReader) Read() ([]byte, error)

type InlineReader

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

InlineReader implements the ArtifactReader interface for inlined artifacts

func (*InlineReader) Read

func (reader *InlineReader) Read() ([]byte, error)

type S3Reader

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

S3Reader implements the ArtifactReader interface and allows reading artifacts from S3 compatible API store

func (*S3Reader) Read

func (reader *S3Reader) Read() ([]byte, error)

type URLReader

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

URLReader implements the ArtifactReader interface for urls

func (*URLReader) Read

func (reader *URLReader) Read() ([]byte, error)