config

Documentation

Index

• func CreateAppInputSecret(spec *cfapp.CloudflowApplicationSpec, config *Config) (*corev1.Secret, error)
• func CreateEmptyStreamletSecret(appID string, name string, ownerReference metav1.OwnerReference) *corev1.Secret
• func CreateInputSecret(appID string, data map[string]string) *corev1.Secret
• func ReferencedPersistentVolumeClaimsExist(config *Config, namespace string, ...) error
• func UpdateSecretWithOwnerReference(cloudflowCROwnerReference metav1.OwnerReference, secret *corev1.Secret) *corev1.Secret
• type Config
  • func GetAppConfiguration(args []string, namespace string, ...) (*Config, error)
  • func MountExistingPVCs(applicationSpec cfapp.CloudflowApplicationSpec, config *Config) (*Config, error)
  • func (conf *Config) String() string

Functions

func CreateAppInputSecret

func CreateAppInputSecret(spec *cfapp.CloudflowApplicationSpec, config *Config) (*corev1.Secret, error)

CreateAppInputSecret creates input secret

func CreateEmptyStreamletSecret

func CreateEmptyStreamletSecret(appID string, name string, ownerReference metav1.OwnerReference) *corev1.Secret

CreateEmptyStreamletSecret creates empty streamlet secret

func CreateInputSecret

func CreateInputSecret(appID string, data map[string]string) *corev1.Secret

func ReferencedPersistentVolumeClaimsExist

func ReferencedPersistentVolumeClaimsExist(config *Config, namespace string, applicationSpec cfapp.CloudflowApplicationSpec, k8sClient *kubernetes.Clientset) error

ReferencedPersistentVolumeClaimsExist checks if all the PVCs exist.

func UpdateSecretWithOwnerReference

func UpdateSecretWithOwnerReference(cloudflowCROwnerReference metav1.OwnerReference, secret *corev1.Secret) *corev1.Secret

UpdateSecretWithOwnerReference updates the secret with the ownerreference passed in

Types

type Config

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

Config keeps the configuration that has been built up so far.

func GetAppConfiguration

func GetAppConfiguration(
	args []string,
	namespace string,
	applicationSpec cfapp.CloudflowApplicationSpec,
	configFiles []string) (*Config, error)

func MountExistingPVCs

func MountExistingPVCs(applicationSpec cfapp.CloudflowApplicationSpec, config *Config) (*Config, error)

func (*Config) String

func (conf *Config) String() string