heat

Documentation

Index

• Constants
• func APICertificate(instance *openstackv1beta1.Heat) *unstructured.Unstructured
• func APIDeployment(instance *openstackv1beta1.Heat, env []corev1.EnvVar, volumes []corev1.Volume) *appsv1.Deployment
• func APIIngress(instance *openstackv1beta1.Heat) *netv1.Ingress
• func APIInternalURL(instance *openstackv1beta1.Heat) string
• func APIPublicURL(instance *openstackv1beta1.Heat) string
• func APIService(instance *openstackv1beta1.Heat) *corev1.Service
• func AddReadyCheck(cw *template.ConditionWaiter, instance *openstackv1beta1.Heat)
• func BrokerUser(instance *openstackv1beta1.Heat) *openstackv1beta1.RabbitMQUser
• func CFNCertificate(instance *openstackv1beta1.Heat) *unstructured.Unstructured
• func CFNDeployment(instance *openstackv1beta1.Heat, env []corev1.EnvVar, volumes []corev1.Volume) *appsv1.Deployment
• func CFNIngress(instance *openstackv1beta1.Heat) *netv1.Ingress
• func CFNInternalURL(instance *openstackv1beta1.Heat) string
• func CFNPublicURL(instance *openstackv1beta1.Heat) string
• func CFNService(instance *openstackv1beta1.Heat) *corev1.Service
• func ConfigMap(instance *openstackv1beta1.Heat) *corev1.ConfigMap
• func DBSyncJob(instance *openstackv1beta1.Heat, env []corev1.EnvVar, volumes []corev1.Volume) *batchv1.Job
• func Database(instance *openstackv1beta1.Heat) *openstackv1beta1.MariaDBDatabase
• func EngineService(instance *openstackv1beta1.Heat) *corev1.Service
• func EngineStatefulSet(instance *openstackv1beta1.Heat, env []corev1.EnvVar, volumes []corev1.Volume) *appsv1.StatefulSet
• func Ensure(ctx context.Context, c client.Client, instance *openstackv1beta1.Heat, ...) error
• func KeystoneServices(instance *openstackv1beta1.Heat) []*openstackv1beta1.KeystoneService
• func KeystoneStackUser(instance *openstackv1beta1.Heat) *openstackv1beta1.KeystoneUser
• func KeystoneUser(instance *openstackv1beta1.Heat) *openstackv1beta1.KeystoneUser
• func PKIResources(instance *openstackv1beta1.Heat) []*unstructured.Unstructured
• type Reporter
  • func NewReporter(instance *openstackv1beta1.Heat, k8sClient client.Client, ...) *Reporter
  • func (r *Reporter) Pending(ctx context.Context, message string, args ...any) error
  • func (r *Reporter) Running(ctx context.Context) error

Constants

const (
	APIComponentLabel = "api"
)

const (
	AppLabel = "heat"
)

const (
	CFNComponentLabel = "cfn"
)

const (
	EngineComponentLabel = "engine"
)

Functions

func APICertificate

func APICertificate(instance *openstackv1beta1.Heat) *unstructured.Unstructured

func APIDeployment

func APIDeployment(instance *openstackv1beta1.Heat, env []corev1.EnvVar, volumes []corev1.Volume) *appsv1.Deployment

func APIIngress

func APIIngress(instance *openstackv1beta1.Heat) *netv1.Ingress

func APIInternalURL

func APIInternalURL(instance *openstackv1beta1.Heat) string

func APIPublicURL

func APIPublicURL(instance *openstackv1beta1.Heat) string

func APIService

func APIService(instance *openstackv1beta1.Heat) *corev1.Service

func AddReadyCheck

func AddReadyCheck(cw *template.ConditionWaiter, instance *openstackv1beta1.Heat)

func BrokerUser

func BrokerUser(instance *openstackv1beta1.Heat) *openstackv1beta1.RabbitMQUser

func CFNCertificate

func CFNCertificate(instance *openstackv1beta1.Heat) *unstructured.Unstructured

func CFNDeployment

func CFNDeployment(instance *openstackv1beta1.Heat, env []corev1.EnvVar, volumes []corev1.Volume) *appsv1.Deployment

func CFNIngress

func CFNIngress(instance *openstackv1beta1.Heat) *netv1.Ingress

func CFNInternalURL

func CFNInternalURL(instance *openstackv1beta1.Heat) string

func CFNPublicURL

func CFNPublicURL(instance *openstackv1beta1.Heat) string

func CFNService

func CFNService(instance *openstackv1beta1.Heat) *corev1.Service

func ConfigMap

func ConfigMap(instance *openstackv1beta1.Heat) *corev1.ConfigMap

func DBSyncJob

func DBSyncJob(instance *openstackv1beta1.Heat, env []corev1.EnvVar, volumes []corev1.Volume) *batchv1.Job

func Database

func Database(instance *openstackv1beta1.Heat) *openstackv1beta1.MariaDBDatabase

func EngineService

func EngineService(instance *openstackv1beta1.Heat) *corev1.Service

func EngineStatefulSet

func EngineStatefulSet(instance *openstackv1beta1.Heat, env []corev1.EnvVar, volumes []corev1.Volume) *appsv1.StatefulSet

func Ensure

func Ensure(ctx context.Context, c client.Client, instance *openstackv1beta1.Heat, log logr.Logger) error

func KeystoneServices

func KeystoneServices(instance *openstackv1beta1.Heat) []*openstackv1beta1.KeystoneService

func KeystoneStackUser

func KeystoneStackUser(instance *openstackv1beta1.Heat) *openstackv1beta1.KeystoneUser

func KeystoneUser

func KeystoneUser(instance *openstackv1beta1.Heat) *openstackv1beta1.KeystoneUser

func PKIResources

func PKIResources(instance *openstackv1beta1.Heat) []*unstructured.Unstructured

Types

type Reporter

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

func NewReporter

func NewReporter(instance *openstackv1beta1.Heat, k8sClient client.Client, recorder record.EventRecorder) *Reporter

func (*Reporter) Pending

func (r *Reporter) Pending(ctx context.Context, message string, args ...any) error

func (*Reporter) Running

func (r *Reporter) Running(ctx context.Context) error