pipeline

Apr 19, 2024

Changes in this version

+ func ListExisting[T client.Object](r Request, obj T) ([]T, error)

+ func ListNew[T client.Object](r Request, obj T) ([]T, error)

type Request

+ ListExisting func(obj client.Object) ([]client.Object, error)

+ ListNew func(obj client.Object) ([]client.Object, error)

type RequestBase

+ func (r *RequestBase) ListExisting(obj client.Object) ([]client.Object, error)

+ func (r *RequestBase) ListNew(obj client.Object) ([]client.Object, error)

Apr 15, 2024

Changes in this version

type ExecutableRequest

+ func NewProjectEnvironmentRequest(c client.Client, reader client.Reader, config *configv1alpha1.OperatorConfig, ...) ExecutableRequest[ProjectEnvironmentRequest]

+ type ProjectEnvironmentRequest interface

+ ProjectEnvironment func() *v1alpha2.ProjectEnvironment

Apr 4, 2024

Changes in this version

+ const LabelOwnedByProject

+ var CoreNamespace = corev1.SchemeGroupVersion.WithKind("Namespace")

+ type ExecutableRequest interface

+ GetBase func() *RequestBase

+ GetRequest func() T

+ func NewProjectRequest(c client.Client, reader client.Reader, config *configv1alpha1.OperatorConfig, ...) ExecutableRequest[ProjectRequest]

+ type ProjectRequest interface

+ Project func() *v1alpha2.Project

Apr 2, 2024

Changes in this version

+ type CapsulePipeline struct

+ func NewCapsulePipeline(cc client.Client, cr client.Reader, config *configv1alpha1.OperatorConfig, ...) *CapsulePipeline

+ func (p *CapsulePipeline) AddStep(step CapsuleStep)

+ func (p *CapsulePipeline) RunCapsule(ctx context.Context, capsule *v1alpha2.Capsule, opts ...CapsuleRequestOption) (*Result, error)

+ type CapsuleStep interface

+ Apply func(ctx context.Context, req CapsuleRequest) error

+ type Change struct

+ type ObjectKey struct

+ func (ok ObjectKey) MarshalLog() interface{}

+ func (ok ObjectKey) String() string

+ type Request interface

+ Delete func(obj client.Object) error

+ GetExisting func(obj client.Object) error

+ GetNew func(obj client.Object) error

+ Reader func() client.Reader

+ Scheme func() *runtime.Scheme

+ Set func(obj client.Object) error

+ type RequestBase struct

+ Strategies RequestStrategies

+ func NewRequestBase(c client.Client, reader client.Reader, config *configv1alpha1.OperatorConfig, ...) RequestBase

+ func (r *RequestBase) Commit(ctx context.Context) (map[ObjectKey]*Change, error)

+ func (r *RequestBase) Delete(obj client.Object) error

+ func (r *RequestBase) GetExisting(obj client.Object) error

+ func (r *RequestBase) GetNew(obj client.Object) error

+ func (r *RequestBase) PrepareRequest() *Result

+ func (r *RequestBase) Reader() client.Reader

+ func (r *RequestBase) Scheme() *runtime.Scheme

+ func (r *RequestBase) Set(obj client.Object) error

+ type RequestDeps struct

+ type RequestState struct

+ type RequestStrategies interface

+ GetKey func(obj client.Object) (ObjectKey, error)

+ LoadExistingObjects func(ctx context.Context) error

+ OwnedLabel func() string

+ Prepare func()

+ UpdateStatusWithChanges func(ctx context.Context, changes map[ObjectKey]*Change) error

+ UpdateStatusWithError func(ctx context.Context, err error) error

type Result

+ func ExecuteRequest[T Request](ctx context.Context, req T, base *RequestBase, ...) (*Result, error)

Mar 13, 2024

Changes in this version

type CapsuleRequest

+ GetExisting func(obj client.Object) error

+ MarkUsedObject func(res v1alpha2.UsedResource) error

type CapsuleRequestOption

+ func WithAdditionalResources(resources []*pipeline.Object) CapsuleRequestOption

Mar 5, 2024

Changes in this version

+ const LabelOwnedByCapsule

+ var AppsDeploymentGVK = appsv1.SchemeGroupVersion.WithKind("Deployment")

+ var AutoscalingvHorizontalPodAutoscalerGVK = autoscalingv2.SchemeGroupVersion.WithKind("HorizontalPodAutoscaler")

+ var BatchCronJobGVK = batchv1.SchemeGroupVersion.WithKind("CronJob")

+ var CMCertificateGVK = cmv1.SchemeGroupVersion.WithKind(cmv1.CertificateKind)

+ var CoreServiceAccount = corev1.SchemeGroupVersion.WithKind("ServiceAccount")

+ var CoreServiceGVK = corev1.SchemeGroupVersion.WithKind("Service")

+ var MonitoringServiceMonitorGVK = monitorv1.SchemeGroupVersion.WithKind(monitorv1.ServiceMonitorsKind)

+ var NetIngressGVK = netv1.SchemeGroupVersion.WithKind("Ingress")

+ var VPAVerticalPodAutoscalerGVK = vpav1.SchemeGroupVersion.WithKind("VerticalPodAutoscaler")

+ func IsOwnedBy(owner metav1.Object, obj metav1.Object) bool

+ func LookupGVK(gk schema.GroupKind) (schema.GroupVersionKind, error)

+ func ObjectsEquals(o1, o2 client.Object) bool

+ type CapsuleRequest interface

+ Capsule func() *v1alpha2.Capsule

+ Delete func(obj client.Object) error

+ GetCurrent func(obj client.Object) error

+ GetNew func(obj client.Object) error

+ MarkUsedResource func(res v1alpha2.UsedResource)

+ Reader func() client.Reader

+ Scheme func() *runtime.Scheme

+ Set func(obj client.Object) error

+ func NewCapsuleRequest(p *Pipeline, capsule *v1alpha2.Capsule, opts ...CapsuleRequestOption) CapsuleRequest

+ type CapsuleRequestOption interface

+ func WithDryRun() CapsuleRequestOption

+ func WithForce() CapsuleRequestOption

+ type Object struct

+ Current client.Object

+ Materialized client.Object

+ New client.Object

+ type ObjectsEqual func(o1, o2 client.Object) bool

+ type OutputObject struct

+ Object client.Object

+ ObjectKey objectKey

+ State ResourceState

+ type Pipeline struct

+ func New(cc client.Client, cr client.Reader, config *configv1alpha1.OperatorConfig, ...) *Pipeline

+ func (p *Pipeline) AddStep(step Step)

+ func (p *Pipeline) RunCapsule(ctx context.Context, capsule *v1alpha2.Capsule, opts ...CapsuleRequestOption) (*Result, error)

+ func (p *Pipeline) RunSteps(ctx context.Context, capReq CapsuleRequest, commit bool) (*Result, error)

+ type ResourceState string

+ const ResourceStateAlreadyExists

+ const ResourceStateChangePending

+ const ResourceStateCreated

+ const ResourceStateDeleted

+ const ResourceStateFailed

+ const ResourceStateUnchanged

+ const ResourceStateUpdated

+ type Result struct

+ InputObjects []client.Object

+ Objects []*Object

+ OutputObjects []OutputObject

+ type Step interface

+ Apply func(ctx context.Context, req CapsuleRequest) error