upstream

Documentation

Index

• Variables
• func FetchUpstream(upstreamURI string, fetchOptions *types.FetchOptions) (*types.Upstream, error)
• func GenerateAdminConsoleFiles(renderDir string, options types.WriteOptions) ([]types.UpstreamFile, error)
• func GetUpdatesUpstream(upstreamURI string, fetchOptions *types.FetchOptions) (*types.UpdateCheckResult, error)
• func LoadIdentity(upstreamDir string) (*kotsv1beta1.Identity, error)
• func LoadIdentityConfig(upstreamDir string) (*kotsv1beta1.IdentityConfig, error)
• func MustMarshalLicense(license *kotsv1beta1.License) []byte
• func SaveIdentityConfig(identityConfig *kotsv1beta1.IdentityConfig, upstreamDir string) error
• func SaveInstallation(installation *kotsv1beta1.Installation, upstreamDir string) error
• func WriteUpstream(u *types.Upstream, options types.WriteOptions) error
• type App
• type ChannelRelease
• type IncompatibleAppError
  • func (e IncompatibleAppError) Error() string
• type ProcessAirgapImagesOptions
• type ProcessAirgapImagesResult
  • func ProcessAirgapImages(options ProcessAirgapImagesOptions) (*ProcessAirgapImagesResult, error)
• type ProgressImage
• type ProgressReport
• type Release
• type UpgradeOptions
• type UpgradeRelease
• type UpgradeResponse
  • func Upgrade(appSlug string, options UpgradeOptions) (*UpgradeResponse, error)
• type UpstreamSettings

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 FetchUpstream

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

func GenerateAdminConsoleFiles

func GenerateAdminConsoleFiles(renderDir string, options types.WriteOptions) ([]types.UpstreamFile, error)

func GetUpdatesUpstream

func GetUpdatesUpstream(upstreamURI string, fetchOptions *types.FetchOptions) (*types.UpdateCheckResult, error)

func LoadIdentity

func LoadIdentity(upstreamDir string) (*kotsv1beta1.Identity, error)

func LoadIdentityConfig

func LoadIdentityConfig(upstreamDir string) (*kotsv1beta1.IdentityConfig, error)

func MustMarshalLicense

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

func SaveIdentityConfig

func SaveIdentityConfig(identityConfig *kotsv1beta1.IdentityConfig, upstreamDir string) error

func SaveInstallation

func SaveInstallation(installation *kotsv1beta1.Installation, upstreamDir string) 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"`
	IsRequired      bool   `json:"isRequired"`
	CreatedAt       string `json:"createdAt"`
	ReleaseNotes    string `json:"releaseNotes"`
}

type IncompatibleAppError

type IncompatibleAppError struct {
	KotsApplication *kotsv1beta1.Application
	License         *kotsv1beta1.License
	Message         string
}

func (IncompatibleAppError) Error

func (e IncompatibleAppError) Error() string

type ProcessAirgapImagesOptions

type ProcessAirgapImagesOptions struct {
	RootDir             string
	AirgapRoot          string
	AirgapBundle        string
	CreateAppDir        bool
	PushImages          bool
	UseKnownImages      bool
	KnownImages         []kustomizetypes.Image
	Log                 *logger.CLILogger
	ReplicatedRegistry  registrytypes.RegistryOptions
	ReportWriter        io.Writer
	DestinationRegistry registrytypes.RegistryOptions
}

type ProcessAirgapImagesResult

type ProcessAirgapImagesResult struct {
	KustomizeImages []kustomizetypes.Image
	KnownImages     []kotsv1beta1.InstallationImage
}

func ProcessAirgapImages

func ProcessAirgapImages(options ProcessAirgapImagesOptions) (*ProcessAirgapImagesResult, error)

type ProgressImage

type ProgressImage struct {
	// image name and tag, "nginx:latest"
	DisplayName string `json:"displayName"`
	// image upload status: queued, uploading, uploaded, failed
	Status string `json:"status"`
	// error string set when status is failed
	Error string `json:"error"`
	// amount currently uploaded (currently number of layers)
	Current int64 `json:"current"`
	// total amount that needs to be uploaded (currently number of layers)
	Total int64 `json:"total"`
	// time when image started uploading
	StartTime time.Time `json:"startTime"`
	// time when image finished uploading
	EndTime time.Time `json:"endTime"`
}

type ProgressReport

type ProgressReport struct {
	// set to "progressReport"
	Type string `json:"type"`
	// the same progress text that used to be sent in unstructured message
	CompatibilityMessage string `json:"compatibilityMessage"`
	// all images found in archive
	Images []ProgressImage `json:"images"`
}

type Release

type Release struct {
	UpdateCursor replicatedapp.ReplicatedCursor
	VersionLabel string
	IsRequired   bool
	ReleaseNotes string
	ReleasedAt   *time.Time
	Manifests    map[string][]byte
}

type UpgradeOptions

type UpgradeOptions struct {
	AirgapBundle        string
	RegistryEndpoint    string
	RegistryNamespace   string
	RegistryUsername    string
	RegistryPassword    string
	IsKurl              bool
	DisableImagePush    bool
	UpdateCheckEndpoint string
	Namespace           string
	Debug               bool
	Deploy              bool
	DeployVersionLabel  string
	Wait                bool
	Silent              bool
}

type UpgradeRelease

type UpgradeRelease struct {
	Sequence int64  `json:"sequence"`
	Version  string `json:"version"`
}

type UpgradeResponse

type UpgradeResponse struct {
	Success           bool             `json:"success"`
	AvailableUpdates  int64            `json:"availableUpdates"`
	CurrentRelease    *UpgradeRelease  `json:"currentRelease,omitempty"`
	AvailableReleases []UpgradeRelease `json:"availableReleases,omitempty"`
	DeployingRelease  *UpgradeRelease  `json:"deployingRelease,omitempty"`
	Error             string           `json:"error,omitempty"`
}

func Upgrade

func Upgrade(appSlug string, options UpgradeOptions) (*UpgradeResponse, error)

type UpstreamSettings

type UpstreamSettings struct {
	Namespace              string
	SharedPassword         string
	SharedPasswordBcrypt   string
	S3AccessKey            string
	S3SecretKey            string
	JWT                    string
	RqlitePassword         string
	APIEncryptionKey       string
	HTTPProxyEnvValue      string
	HTTPSProxyEnvValue     string
	NoProxyEnvValue        string
	AutoCreateClusterToken string
	IsOpenShift            bool
	IncludeMinio           bool
	IsMinimalRBAC          bool
	AdditionalNamespaces   []string
}