Documentation
¶
Index ¶
- Constants
- func FetchArtifact(reader ArtifactReader, gvr *metav1.GroupVersionResource) (*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 NewResourceReader(resourceArtifact *unstructured.Unstructured) (ArtifactReader, error)
- func NewS3Reader(s3 *apicommon.S3Artifact, creds *Credentials) (ArtifactReader, error)
- func NewURLReader(urlArtifact *v1alpha1.URLArtifact) (ArtifactReader, error)
- type ConfigMapReader
- type Credentials
- type FileReader
- type GitArtifactReader
- type InlineReader
- type ResourceReader
- type S3Reader
- type URLReader
Constants ¶
const ( DefaultRemote = "origin" DefaultBranch = "master" )
Variables ¶
This section is empty.
Functions ¶
func FetchArtifact ¶
func FetchArtifact(reader ArtifactReader, gvr *metav1.GroupVersionResource) (*unstructured.Unstructured, error)
FetchArtifact from the location, decode it using explicit types, and unstructure it
func GetSecrets ¶
GetSecretValue 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 ¶
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 NewResourceReader ¶ added in v0.9.1
func NewResourceReader(resourceArtifact *unstructured.Unstructured) (ArtifactReader, error)
NewResourceReader creates a new ArtifactReader for resource
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 minio
func GetCredentials ¶
func GetCredentials(kubeClient kubernetes.Interface, namespace string, art *v1alpha1.ArtifactLocation) (*Credentials, error)
GetCredentials for this minio
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 ResourceReader ¶ added in v0.9.1
type ResourceReader struct {
// contains filtered or unexported fields
}
ResourceReader implements the ArtifactReader interface for resource artifacts
func (*ResourceReader) Read ¶ added in v0.9.1
func (reader *ResourceReader) Read() ([]byte, error)
Source Files