manifest

package

Go to main page

Versions in this module

v1

v1.0.3

Jan 13, 2020

Changes in this version

type InstanceGroupResolver

+ func (igr *InstanceGroupResolver) Resolve(initialRollout bool) error

v1.0.0

Dec 20, 2019

Changes in this version

+ const BoshDNSAddOnName

+ var LabelReferencedJobName = fmt.Sprintf("%s/referenced-job-name", apis.GroupName)

+ func GetClusterDomain() string

+ func SetBoshDNSDockerImage(image string)

+ func SetClusterDomain(domain string)

type AgentSettings

+ ImagePullSecrets []corev1.LocalObjectReference

+ type Alias struct

+ Domain string

+ Targets []Target

+ type BPMInfo struct

+ Configs bpm.Configs

+ InstanceGroup BPMInstanceGroup

+ Variables []Variable

+ type BPMInstanceGroup struct

+ AZs []string

+ Env AgentEnv

+ Instances int

+ Name string

+ type DomainNameService interface

+ DNSSetting func(namespace string) (corev1.DNSPolicy, *corev1.PodDNSConfig, error)

+ HeadlessServiceName func(instanceGroupName string) string

+ Reconcile func(ctx context.Context, namespace string, c client.Client, ...) error

+ func NewBoshDomainNameService(addOn *AddOn, manifestName string, instanceGroups InstanceGroups) (DomainNameService, error)

+ func NewSimpleDomainNameService(manifestName string) DomainNameService

type InstanceGroup

+ func (ig *InstanceGroup) QuarksStatefulSetName(deploymentName string) string

+ func (ig *InstanceGroup) ServicePorts() []corev1.ServicePort

+ type InstanceGroupProperties struct

+ Properties map[string]interface{}

+ Quarks InstanceGroupQuarks

+ func (p *InstanceGroupProperties) MarshalJSON() ([]byte, error)

+ func (p *InstanceGroupProperties) UnmarshalJSON(b []byte) error

+ type InstanceGroupQuarks struct

+ RequiredService *string

type InstanceGroupResolver

+ func (igr *InstanceGroupResolver) BPMInfo(initialRollout bool) (BPMInfo, error)

+ func (igr *InstanceGroupResolver) CollectQuarksLinks(linksPath string) error

+ func (igr *InstanceGroupResolver) SaveLinks(path string) error

+ type InstanceGroups []*InstanceGroup

+ func (instanceGroups InstanceGroups) InstanceGroupByName(name string) (*InstanceGroup, bool)

+ type JobLinkProperties map[string]interface

type Manifest

+ AddOnsApplied bool

+ DNS DomainNameService

+ func (m *Manifest) ApplyUpdateBlock()

+ type QuarksLink struct

+ Address string

+ Instances []JobInstance

+ Type string

+ type Target struct

+ Deployment string

+ Domain string

+ InstanceGroup string

+ Network string

+ Query string

v0

v0.4.2

Oct 7, 2019

Changes in this version

type JobInstance

+ Bootstrap bool

type VariableOptions

+ ActivateEKSWorkaroundForSAN bool

v0.4.1

Sep 19, 2019

v0.4.0

Sep 4, 2019

Changes in this version

+ const DataDir

+ const IGTypeAutoErrand

+ const IGTypeDefault

+ const IGTypeErrand

+ const IGTypeService

+ const SysDir

type AddOnPlacementRules

+ Lifecycle InstanceGroupType

type AgentSettings

+ AutomountServiceAccountToken *bool

+ DisableLogSidecar bool

+ ServiceAccountName string

type InstanceGroup

+ func (ig *InstanceGroup) ExtendedStatefulsetName(deploymentName string) string

+ func (ig *InstanceGroup) HeadlessServiceName(deploymentName string) string

+ func (ig *InstanceGroup) IndexedServiceName(deploymentName string, index int) string

+ func (ig *InstanceGroup) NameSanitized() string

+ type InstanceGroupResolver struct

+ func NewInstanceGroupResolver(basedir, namespace string, manifest Manifest, instanceGroupName string) (*InstanceGroupResolver, error)

+ func (dg *InstanceGroupResolver) BPMConfigs() (bpm.Configs, error)

+ func (dg *InstanceGroupResolver) Manifest() (Manifest, error)

+ type InstanceGroupType string

type Job

+ func (j *Job) DataDirs() []string

+ func (j *Job) SysDirs() []string

type JobLink

+ Address string

type JobProperties

+ Quarks Quarks

+ func (p *JobProperties) FromMap(properties map[string]interface{}) error

+ func (p *JobProperties) MarshalJSON() ([]byte, error)

+ func (p *JobProperties) UnmarshalJSON(b []byte) error

type Manifest

+ func (m *Manifest) ApplyAddons() error

+ func (m *Manifest) GetJobOS(instanceGroupName, jobName string) (string, error)

+ func (m *Manifest) ImplicitVariables() ([]string, error)

+ type PostStart struct

+ Condition *PostStartCondition

+ type PostStartCondition struct

+ Exec *corev1.ExecAction

+ type PreRenderScripts struct

+ BPM []string

+ IgResolver []string

+ Jobs []string

+ type Quarks struct

+ BPM *bpm.Config

+ Consumes map[string]JobLink

+ Debug bool

+ Envs []corev1.EnvVar

+ Instances []JobInstance

+ IsAddon bool

+ Ports []Port

+ PostStart PostStart

+ PreRenderScripts PreRenderScripts

+ Release string

+ Run RunConfig

type RunConfig

+ HealthCheck map[string]HealthCheck

+ SecurityContext *corev1.SecurityContext

type VariableOptions

+ ServiceRef []esv1.ServiceReference

+ SignerType string

v0.3.1

Jul 12, 2019

Changes in this version

type AgentSettings

+ Affinity *corev1.Affinity

type JobProperties

+ BOSHContainerization bc.BOSHContainerization

type Manifest

+ func (m *Manifest) Marshal() ([]byte, error)

type Resolver

+ func (r *Resolver) DesiredManifest(ctx context.Context, boshDeploymentName, namespace string) (*Manifest, error)

v0.3.0

Jun 27, 2019

Changes in this version

+ const AdditionalVolumeBaseName

+ const AdditionalVolumesRegex

+ const AdditionalVolumesVcapStoreRegex

+ const EnvBOSHManifestPath

+ const EnvBaseDir

+ const EnvCFONamespace

+ const EnvInstanceGroupName

+ const EnvJobsDir

+ const EnvVariablesDir

+ const UnrestrictedVolumeBaseName

+ const VolumeDataDirMountPath

+ const VolumeDataDirName

+ const VolumeEphemeralDirMountPath

+ const VolumeEphemeralDirName

+ const VolumeJobsDirMountPath

+ const VolumeJobsDirName

+ const VolumeJobsSrcDirMountPath

+ const VolumeJobsSrcDirName

+ const VolumeRenderingDataMountPath

+ const VolumeRenderingDataName

+ const VolumeStoreDirMountPath

+ const VolumeStoreDirName

+ const VolumeSysDirMountPath

+ const VolumeSysDirName

+ var LabelDeploymentVersion = fmt.Sprintf("%s/deployment-version", apis.GroupName)

+ type AgentSettings struct

+ Annotations map[string]string

+ Labels map[string]string

+ func (as *AgentSettings) Set(manifestName, igName, version string)

+ type BPMResourceDisk struct

+ Labels map[string]string

+ PersistentVolumeClaim *corev1.PersistentVolumeClaim

+ Volume *corev1.Volume

+ VolumeMount *corev1.VolumeMount

+ func (disk *BPMResourceDisk) MatchesFilter(filterKey, filterValue string) bool

+ type BPMResourceDisks []BPMResourceDisk

+ func (disks BPMResourceDisks) Filter(filterKey, filterValue string) BPMResourceDisks

+ func (disks BPMResourceDisks) VolumeMounts() []corev1.VolumeMount

+ func (disks BPMResourceDisks) Volumes() []corev1.Volume

type BPMResources

+ Disks BPMResourceDisks

+ type JobSpecLink struct

+ Name string

+ Properties []string

+ Type string

+ type JobSpecProvider struct

+ Name string

+ Optional bool

+ Type string

+ type ReleaseImageProvider interface

+ GetReleaseImage func(instanceGroupName, jobName string) (string, error)

type Resolver

+ func (r *Resolver) ImplicitVariables(m *Manifest, rawManifest string) []string

+ func (r *Resolver) LatestVersion(ctx context.Context, namespace string, manifestName string) string

+ func (r *Resolver) WithOpsManifest(instance *bdc.BOSHDeployment, namespace string) (*Manifest, error)

v0.2.2

May 24, 2019

Changes in this version

type BOSHContainerization

+ Run RunConfig

+ type BPMResources struct

+ Errands []ejv1.ExtendedJob

+ InstanceGroups []essv1.ExtendedStatefulSet

+ Services []corev1.Service

+ type ContainerFactory struct

+ func NewContainerFactory(manifestName string, igName string, releaseImageProvider releaseImageProvider, ...) *ContainerFactory

+ func (c *ContainerFactory) JobsToContainers(jobs []Job) ([]corev1.Container, error)

+ func (c *ContainerFactory) JobsToInitContainers(jobs []Job) ([]corev1.Container, error)

type DataGatherer

+ func (dg *DataGatherer) BPMConfigs() (bpm.Configs, error)

+ func (dg *DataGatherer) ResolvedProperties() (Manifest, error)

+ type HealthCheck struct

+ LivenessProbe *corev1.Probe

+ ReadinessProbe *corev1.Probe

type JobFactory

+ func (f *JobFactory) BPMConfigsJob() (*ejv1.ExtendedJob, error)

+ type KubeConverter struct

+ func NewKubeConverter(namespace string) *KubeConverter

+ func (kc *KubeConverter) BPMResources(manifestName string, instanceGroups []*InstanceGroup, ...) (*BPMResources, error)

+ func (kc *KubeConverter) Variables(manifestName string, variables []Variable) []esv1.ExtendedSecret

type Manifest

+ func LoadYAML(data []byte) (*Manifest, error)

+ func (m *Manifest) InstanceGroupByName(name string) (*InstanceGroup, error)

type Resolver

+ ReadDesiredManifest func(ctx context.Context, boshDeploymentName, namespace string) (*Manifest, error)

type ResolverImpl

+ func (r *ResolverImpl) ReadDesiredManifest(ctx context.Context, boshDeploymentName, namespace string) (*Manifest, error)

+ type RunConfig struct

+ HealthChecks map[string]HealthCheck

v0.2.1

May 15, 2019

Changes in this version

+ const JobSpecFilename

+ type JobFactory struct

+ Manifest Manifest

+ Namespace string

+ func NewJobFactory(manifest Manifest, namespace string) *JobFactory

+ func (f *JobFactory) DataGatheringJob() (*ejv1.ExtendedJob, error)

+ func (f *JobFactory) VariableInterpolationJob() (*ejv1.ExtendedJob, error)

type KubeConfig

+ func NewKubeConfig(namespace string, rip releaseImageProvider) *KubeConfig

+ func (kc *KubeConfig) ApplyBPMInfo(allResolvedProperties map[string]Manifest) error

+ func (kc *KubeConfig) Convert(m Manifest) error

v0.2.0

Apr 30, 2019

Changes in this version

+ const DesiredManifestKeyName

+ var DockerImageOrganization = ""

+ var DockerImageRepository = ""

+ var DockerImageTag = ""

+ func InterpolateVariables(log *zap.SugaredLogger, boshManifestBytes []byte, variablesDir string) error

+ func RenderJobTemplates(boshManifestPath string, jobsDir string, jobsOutputDir string, ...) error

type BOSHContainerization

+ Ports []Port

+ type DataGatherer struct

+ func NewDataGatherer(log *zap.SugaredLogger, namespace string, manifest *Manifest) *DataGatherer

+ func (dg *DataGatherer) CollectReleaseSpecsAndProviderLinks(baseDir string) (map[string]map[string]JobSpec, JobProviderLinks, error)

+ func (dg *DataGatherer) GenerateManifest(baseDir string, instanceGroupName string) ([]byte, error)

+ func (dg *DataGatherer) ProcessConsumersAndRenderBPM(baseDir string, jobReleaseSpecs map[string]map[string]JobSpec, ...) ([]byte, error)

type InstanceGroup

+ AZs []string

type Job

+ func (job Job) Property(propertyName string) (interface{}, bool)

+ type JobProviderLinks map[string]map[string]JobLink

+ func (jpl JobProviderLinks) Add(job Job, spec JobSpec, jobsInstances []JobInstance) error

+ func (jpl JobProviderLinks) Lookup(consumesType string, consumesName string) (JobLink, bool)

type JobSpec

+ func (js JobSpec) RetrieveNestedProperty(propertyName string) map[string]interface{}

+ func (js JobSpec) RetrievePropertyDefault(propertyName string) interface{}

type KubeConfig

+ Services []corev1.Service

type Manifest

+ func (m *Manifest) JobSpecCopierContainer(releaseName string, releaseImage string, volumeMountName string) corev1.Container

+ type NewInterpolatorFunc func() Interpolator

+ type Port struct

+ Internal int

+ Name string

+ Protocol string

type ResolverImpl

+ func (r *ResolverImpl) ImplicitVariables(m *Manifest, rawManifest string) ([]string, error)

v0.1.0

Apr 3, 2019

Changes in this version

+ const VarInterpolationContainerName

+ var DockerOrganization = ""

+ var DockerRepository = ""

+ var DockerTag = ""

+ var LabelDeploymentName = fmt.Sprintf("%s/deployment-name", apis.GroupName)

+ var LabelInstanceGroupName = fmt.Sprintf("%s/instance-group-name", apis.GroupName)

+ func GetOperatorDockerImage() string

+ type AddOn struct

+ Exclude *AddOnPlacementRules

+ Include *AddOnPlacementRules

+ Jobs []AddOnJob

+ Name string

+ type AddOnJob struct

+ Name string

+ Properties map[string]interface{}

+ Release string

+ type AddOnPlacementJob struct

+ Name string

+ Release string

+ type AddOnPlacementRules struct

+ Deployments []string

+ InstanceGroup []string

+ Jobs []*AddOnPlacementJob

+ Networks []string

+ Stemcell []*AddOnStemcell

+ Teams []string

+ type AddOnStemcell struct

+ OS string

+ type Agent struct

+ Settings string

+ Tmpfs *bool

+ type AgentEnv struct

+ AgentEnvBoshConfig *AgentEnvBoshConfig

+ PersistentDiskFS string

+ PersistentDiskMountOptions []string

+ type AgentEnvBoshConfig struct

+ Agent *Agent

+ IPv6 IPv6

+ JobDir *JobDir

+ KeepRootPassword string

+ Password string

+ RemoveDevTools *bool

+ RemoveStaticLibraries *bool

+ SwapSize *int

+ type AuthType string

+ const ClientAuth

+ const ServerAuth

+ type BOSHContainerization struct

+ BPM bpm.Config

+ Consumes map[string]JobLink

+ Instances []JobInstance

+ Release string

+ type DeploymentSecretType int

+ const DeploymentSecretTypeGeneratedVariable

+ const DeploymentSecretTypeInstanceGroupResolvedProperties

+ const DeploymentSecretTypeManifestAndVars

+ const DeploymentSecretTypeManifestWithOps

+ func (s DeploymentSecretType) String() string

+ type Feature struct

+ ConvergeVariables bool

+ RandomizeAzPlacement *bool

+ UseDNSAddresses *bool

+ UseTmpfsJobConfig *bool

+ type IPv6 struct

+ Enable bool

+ type InstanceGroup struct

+ Azs []string

+ Env *AgentEnv

+ Instances int

+ Jobs []Job

+ LifeCycle string

+ MigratedFrom *MigratedFrom

+ Name string

+ Networks []*Network

+ PersistentDisk *int

+ PersistentDiskType string

+ Properties map[string]interface{}

+ Stemcell string

+ Update *Update

+ VMExtensions []string

+ VMResources *VMResource

+ VMType string

+ type Interpolator interface

+ BuildOps func(opsBytes []byte) error

+ Interpolate func(manifestBytes []byte) ([]byte, error)

+ type InterpolatorImpl struct

+ func NewInterpolator() *InterpolatorImpl

+ func (i *InterpolatorImpl) BuildOps(opsBytes []byte) error

+ func (i *InterpolatorImpl) Interpolate(manifestBytes []byte) ([]byte, error)

+ type Job struct

+ Consumes map[string]interface{}

+ Name string

+ Properties JobProperties

+ Provides map[string]interface{}

+ Release string

+ type JobDir struct

+ Tmpfs *bool

+ TmpfsSize string

+ type JobInstance struct

+ AZ string

+ Address string

+ BPM bpm.Config

+ Fingerprint interface{}

+ ID string

+ IP string

+ Index int

+ Instance int

+ Name string

+ Network map[string]interface{}

+ type JobLink struct

+ Instances []JobInstance

+ Properties map[string]interface{}

+ type JobProperties struct

+ Properties map[string]interface{}

+ func (p *JobProperties) ToMap() map[string]interface{}

+ type JobSpec struct

+ Consumes []struct{ ... }

+ Description string

+ Name string

+ Packages []string

+ Properties map[string]struct{ ... }

+ Provides []struct{ ... }

+ Templates map[string]string

+ type KubeConfig struct

+ DataGatheringJob *ejv1.ExtendedJob

+ Errands []ejv1.ExtendedJob

+ InstanceGroups []essv1.ExtendedStatefulSet

+ Namespace string

+ VariableInterpolationJob *ejv1.ExtendedJob

+ Variables []esv1.ExtendedSecret

+ type Link struct

+ Instances []JobInstance

+ Name string

+ Properties interface{}

+ type Manifest struct

+ AddOns []*AddOn

+ DirectorUUID string

+ Features *Feature

+ InstanceGroups []*InstanceGroup

+ Name string

+ Properties []map[string]interface{}

+ Releases []*Release

+ Stemcells []*Stemcell

+ Tags map[string]string

+ Update *Update

+ Variables []Variable

+ func (m *Manifest) ApplyBPMInfo(kubeConfig *KubeConfig, allResolvedProperties map[string]Manifest) error

+ func (m *Manifest) CalculateEJobOutputSecretPrefixAndName(secretType DeploymentSecretType, containerName string) (string, string)

+ func (m *Manifest) CalculateSecretName(secretType DeploymentSecretType, name string) string

+ func (m *Manifest) ConvertToKube(namespace string) (KubeConfig, error)

+ func (m *Manifest) GetReleaseImage(instanceGroupName, jobName string) (string, error)

+ func (m *Manifest) SHA1() (string, error)

+ type MigratedFrom struct

+ Az string

+ Name string

+ type Network struct

+ Default []string

+ Name string

+ StaticIps []string

+ type Release struct

+ Name string

+ SHA1 string

+ Stemcell *ReleaseStemcell

+ URL string

+ Version string

+ type ReleaseStemcell struct

+ OS string

+ Version string

+ type Resolver interface

+ ResolveManifest func(bdc.BOSHDeploymentSpec, string) (*Manifest, error)

+ type ResolverImpl struct

+ func NewResolver(client client.Client, interpolator Interpolator) *ResolverImpl

+ func (r *ResolverImpl) ResolveManifest(spec bdc.BOSHDeploymentSpec, namespace string) (*Manifest, error)

+ type Stemcell struct

+ Alias string

+ Name string

+ OS string

+ Version string

+ type Update struct

+ Canaries int

+ CanaryWatchTime string

+ MaxInFlight string

+ Serial bool

+ UpdateWatchTime string

+ VMStrategy *string

+ type VMResource struct

+ CPU int

+ EphemeralDiskSize int

+ RAM int

+ type Variable struct

+ Name string

+ Options *VariableOptions

+ Type string

+ type VariableOptions struct

+ AlternativeNames []string

+ CA string

+ CommonName string

+ ExtendedKeyUsage []AuthType

+ IsCA bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL