upstream

Documentation

Index

• Constants
• Variables
• func CopyUpstreamImages(u *types.Upstream, options WriteUpstreamImageOptions) ([]kustomizeimage.Image, error)
• func FetchUpstream(upstreamURI string, fetchOptions *FetchOptions) (*types.Upstream, error)
• func FindObjectsWithImages(u *types.Upstream, options FindObjectsWithImagesOptions) ([]*k8sdoc.Doc, error)
• func FindPrivateImages(u *types.Upstream, options FindPrivateImagesOptions) ([]kustomizeimage.Image, []*k8sdoc.Doc, error)
• func GetApplicationMetadata(upstream *url.URL) ([]byte, error)
• func MustMarshalLicense(license *kotsv1beta1.License) []byte
• func TagAndPushUpstreamImages(u *types.Upstream, options PushUpstreamImageOptions) ([]kustomizeimage.Image, error)
• func WriteUpstream(u *types.Upstream, options types.WriteOptions) error
• type App
• type ChannelRelease
• type FetchOptions
• type FindObjectsWithImagesOptions
• type FindPrivateImagesOptions
• type PushUpstreamImageOptions
• type Release
• type ReplicatedUpstream
• type Update
  • func GetUpdatesUpstream(upstreamURI string, fetchOptions *FetchOptions) ([]Update, error)
• type UpstreamSettings
• type WriteUpstreamImageOptions

Constants

const DefaultMetadata = `` /* 232-byte string literal not displayed */

Variables

var KnownRepos = map[string]string{
	"stable":  "https://kubernetes-charts.storage.googleapis.com",
	"local":   "http://127.0.0.1:8879",
	"elastic": "https://helm.elastic.co",
	"gomods":  "https://athens.blob.core.windows.net/charts",
	"harbor":  "https://helm.goharbor.io",
}

Functions

func CopyUpstreamImages

func CopyUpstreamImages(u *types.Upstream, options WriteUpstreamImageOptions) ([]kustomizeimage.Image, error)

func FetchUpstream

func FetchUpstream(upstreamURI string, fetchOptions *FetchOptions) (*types.Upstream, error)

func FindObjectsWithImages

func FindObjectsWithImages(u *types.Upstream, options FindObjectsWithImagesOptions) ([]*k8sdoc.Doc, error)

func FindPrivateImages

func FindPrivateImages(u *types.Upstream, options FindPrivateImagesOptions) ([]kustomizeimage.Image, []*k8sdoc.Doc, error)

func GetApplicationMetadata

func GetApplicationMetadata(upstream *url.URL) ([]byte, error)

GetApplicationMetadata will return any available application yaml from the upstream. If there is no application.yaml, it will return a placeholder one

func MustMarshalLicense

func MustMarshalLicense(license *kotsv1beta1.License) []byte

func TagAndPushUpstreamImages

func TagAndPushUpstreamImages(u *types.Upstream, options PushUpstreamImageOptions) ([]kustomizeimage.Image, error)

func WriteUpstream

func WriteUpstream(u *types.Upstream, options types.WriteOptions) error

Types

type App

type App struct {
	Name string
}

type ChannelRelease

type ChannelRelease struct {
	ChannelSequence int    `json:"channelSequence"`
	ReleaseSequence int    `json:"releaseSequence"`
	VersionLabel    string `json:"versionLabel"`
	CreatedAt       string `json:"createdAt"`
}

type FetchOptions

type FetchOptions struct {
	RootDir             string
	UseAppDir           bool
	HelmRepoName        string
	HelmRepoURI         string
	HelmOptions         []string
	LocalPath           string
	License             *kotsv1beta1.License
	ConfigValues        *kotsv1beta1.ConfigValues
	Airgap              *kotsv1beta1.Airgap
	EncryptionKey       string
	CurrentCursor       string
	CurrentVersionLabel string
}

type FindObjectsWithImagesOptions

type FindObjectsWithImagesOptions struct {
	RootDir      string
	CreateAppDir bool
	Log          *logger.Logger
}

type FindPrivateImagesOptions

type FindPrivateImagesOptions struct {
	RootDir            string
	CreateAppDir       bool
	AppSlug            string
	ReplicatedRegistry registry.RegistryOptions
	Log                *logger.Logger
}

type PushUpstreamImageOptions

type PushUpstreamImageOptions struct {
	RootDir             string
	ImagesDir           string
	CreateAppDir        bool
	Log                 *logger.Logger
	ReplicatedRegistry  registry.RegistryOptions
	ReportWriter        io.Writer
	DestinationRegistry registry.RegistryOptions
}

type Release

type Release struct {
	UpdateCursor string
	VersionLabel string
	ReleaseNotes string
	Manifests    map[string][]byte
}

type ReplicatedUpstream

type ReplicatedUpstream struct {
	Channel      *string
	AppSlug      string
	VersionLabel *string
	Sequence     *int
}

type Update

type Update struct {
	Cursor       string `json:"cursor"`
	VersionLabel string `json:"versionLabel"`
}

func GetUpdatesUpstream

func GetUpdatesUpstream(upstreamURI string, fetchOptions *FetchOptions) ([]Update, error)

type UpstreamSettings

type UpstreamSettings struct {
	SharedPassword       string
	SharedPasswordBcrypt string
	S3AccessKey          string
	S3SecretKey          string
	JWT                  string
	PostgresPassword     string
	APIEncryptionKey     string

	AutoCreateClusterToken string
}

type WriteUpstreamImageOptions

type WriteUpstreamImageOptions struct {
	RootDir        string
	CreateAppDir   bool
	AppSlug        string
	SourceRegistry registry.RegistryOptions
	DestRegistry   registry.RegistryOptions
	Log            *logger.Logger
	ReportWriter   io.Writer
}