utils

Documentation

Index

• func DeleteIfExists(ctx context.Context, cli client.Client, obj client.Object) error
• func Max(a, b int32) int32
• func Min(a, b int32) int32
• func MustExtractList(obj runtime.Object) []runtime.Object
• func MustGetKind(obj runtime.Object) schema.GroupVersionKind
• func RemoteClient(ctx context.Context, log logr.Logger, reader client.Reader, ...) (client.Client, error)
• func UpdateStatus(ctx context.Context, client client.Client, obj client.Object) error
• func VariantEnabled(releaseManager *picchu.ReleaseManager, variant string) bool
• type Config

Functions

func DeleteIfExists

func DeleteIfExists(ctx context.Context, cli client.Client, obj client.Object) error

func Max

func Max(a, b int32) int32

func Min

func Min(a, b int32) int32

func MustExtractList

func MustExtractList(obj runtime.Object) []runtime.Object

MustExtractList panics if the object isn't a list

func MustGetKind

func MustGetKind(obj runtime.Object) schema.GroupVersionKind

func RemoteClient

func RemoteClient(ctx context.Context, log logr.Logger, reader client.Reader, cluster *picchuv1alpha1.Cluster) (client.Client, error)

RemoteClient creates a k8s client from a cluster object.

func UpdateStatus

func UpdateStatus(ctx context.Context, client client.Client, obj client.Object) error

UpdateStatus first tries new method of status update, and falls back to old.

func VariantEnabled

func VariantEnabled(releaseManager *picchu.ReleaseManager, variant string) bool

Types

type Config

type Config struct {
	HumaneReleasesEnabled     bool
	ManageRoute53             bool
	RequeueAfter              time.Duration
	PrometheusQueryAddress    string
	PrometheusQueryTTL        time.Duration
	ServiceLevelsNamespace    string
	ServiceLevelsFleet        string
	ConcurrentRevisions       int
	ConcurrentReleaseManagers int
	DevRoutesServiceHost      string
	DevRoutesServicePort      int
}