deployment

package

v1.9.0 Latest Latest Go to latest Published: Sep 21, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/shopware/shopware-operator

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AdminDeployment(store v1.Store) *appsv1.Deployment
func CleanupObsoleteWorkerDeployments(ctx context.Context, c client.Client, store v1.Store, perQueue bool) error
func CleanupObsoleteWorkerScaledObjects(ctx context.Context, c client.Client, store v1.Store) error
func GetAdminDeployment(ctx context.Context, store v1.Store, client client.Client) (*appsv1.Deployment, error)
func GetAdminDeploymentCondition(ctx context.Context, store v1.Store, client client.Client) v1.DeploymentCondition
func GetAdminDeploymentName(store v1.Store) string
func GetAdminQueueStats(ctx context.Context, c client.Client, clientset *kubernetes.Clientset, ...) ([]v1.QueueTransportStats, []string, error)
func GetCalculatedPHPFPMValues(memoryLimitMiB int) []corev1.EnvVar
func GetQueueWorkerDeploymentName(store v1.Store, queue string) string
func GetStoreDeploymentImage(ctx context.Context, store v1.Store, client client.Client) (string, error)
func GetStorefrontDeployment(ctx context.Context, store v1.Store, client client.Client) (*appsv1.Deployment, error)
func GetStorefrontDeploymentCondition(ctx context.Context, store v1.Store, client client.Client) v1.DeploymentCondition
func GetStorefrontDeploymentName(store v1.Store) string
func GetWorkerDeploymentCondition(ctx context.Context, store v1.Store, c client.Client, perQueue bool) v1.DeploymentCondition
func GetWorkerDeploymentName(store v1.Store) string
func StorefrontDeployment(store v1.Store) *appsv1.Deployment
func WorkerDeployment(store v1.Store, consumeQueues []string) *appsv1.Deployment
func WorkerDeployments(store v1.Store) ([]*appsv1.Deployment, error)
func WorkerQueues(store v1.Store) []string
func WorkerScaledObject(store v1.Store, queue string, metricsURL string) *kedav1alpha1.ScaledObject
func WorkerScaledObjects(store v1.Store, metricsURL string) ([]*kedav1alpha1.ScaledObject, error)
type QueueStatsError
- func (e *QueueStatsError) Error() string
- func (e *QueueStatsError) Unwrap() error

Constants ¶

View Source

const (
	DEPLOYMENT_STOREFRONT_CONTAINER_NAME       = "shopware-storefront"
	FPM_ADMIN_PORT                       int32 = 8001
)

Variables ¶

This section is empty.

Functions ¶

func AdminDeployment ¶

func AdminDeployment(store v1.Store) *appsv1.Deployment

func CleanupObsoleteWorkerDeployments ¶ added in v1.9.0

func CleanupObsoleteWorkerDeployments(
	ctx context.Context,
	c client.Client,
	store v1.Store,
	perQueue bool,
) error

func CleanupObsoleteWorkerScaledObjects ¶ added in v1.9.0

func CleanupObsoleteWorkerScaledObjects(
	ctx context.Context,
	c client.Client,
	store v1.Store,
) error

func GetAdminDeployment ¶

func GetAdminDeployment(
	ctx context.Context,
	store v1.Store,
	client client.Client,
) (*appsv1.Deployment, error)

func GetAdminDeploymentCondition ¶

func GetAdminDeploymentCondition(
	ctx context.Context,
	store v1.Store,
	client client.Client,
) v1.DeploymentCondition

func GetAdminDeploymentName ¶

func GetAdminDeploymentName(store v1.Store) string

func GetAdminQueueStats ¶ added in v1.9.0

func GetAdminQueueStats(
	ctx context.Context,
	c client.Client,
	clientset *kubernetes.Clientset,
	restConfig *rest.Config,
	store v1.Store,
) ([]v1.QueueTransportStats, []string, error)

func GetCalculatedPHPFPMValues ¶

func GetCalculatedPHPFPMValues(memoryLimitMiB int) []corev1.EnvVar

func GetQueueWorkerDeploymentName ¶ added in v1.9.0

func GetQueueWorkerDeploymentName(store v1.Store, queue string) string

func GetStoreDeploymentImage ¶

func GetStoreDeploymentImage(
	ctx context.Context,
	store v1.Store,
	client client.Client,
) (string, error)

func GetStorefrontDeployment ¶

func GetStorefrontDeployment(
	ctx context.Context,
	store v1.Store,
	client client.Client,
) (*appsv1.Deployment, error)

func GetStorefrontDeploymentCondition ¶

func GetStorefrontDeploymentCondition(
	ctx context.Context,
	store v1.Store,
	client client.Client,
) v1.DeploymentCondition

func GetStorefrontDeploymentName ¶

func GetStorefrontDeploymentName(store v1.Store) string

func GetWorkerDeploymentCondition ¶

func GetWorkerDeploymentCondition(
	ctx context.Context,
	store v1.Store,
	c client.Client,
	perQueue bool,
) v1.DeploymentCondition

func GetWorkerDeploymentName ¶

func GetWorkerDeploymentName(store v1.Store) string

func StorefrontDeployment ¶

func StorefrontDeployment(store v1.Store) *appsv1.Deployment

func WorkerDeployment ¶

func WorkerDeployment(store v1.Store, consumeQueues []string) *appsv1.Deployment

func WorkerDeployments ¶ added in v1.9.0

func WorkerDeployments(store v1.Store) ([]*appsv1.Deployment, error)

WorkerDeployments returns one deployment per known queue when perQueue is set (keda scaling), otherwise a single deployment consuming all queues.

func WorkerQueues ¶ added in v1.9.0

func WorkerQueues(store v1.Store) []string

func WorkerScaledObject ¶ added in v1.9.0

func WorkerScaledObject(store v1.Store, queue string, metricsURL string) *kedav1alpha1.ScaledObject

func WorkerScaledObjects ¶ added in v1.9.0

func WorkerScaledObjects(store v1.Store, metricsURL string) ([]*kedav1alpha1.ScaledObject, error)

Types ¶

type QueueStatsError ¶ added in v1.9.0

type QueueStatsError struct {
	Pod       string
	Container string
	Command   string
	Stdout    string
	Stderr    string
	Err       error
}

func (*QueueStatsError) Error ¶ added in v1.9.0

func (e *QueueStatsError) Error() string

func (*QueueStatsError) Unwrap ¶ added in v1.9.0

func (e *QueueStatsError) Unwrap() error

Source Files ¶

View all Source files

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