validator

Jun 18, 2025

Changes in this version

type Validator

+ func NewMonoVertexValidator(old, new *dfv1.MonoVertex) Validator

Aug 19, 2024

Changes in this version

+ func AllowedResponse() *admissionv1.AdmissionResponse

+ func DeniedResponse(reason string, args ...interface{}) *admissionv1.AdmissionResponse

+ type MockInterStepBufferServices struct

+ Fake *fake.FakeNumaflowV1alpha1

+ func (c *MockInterStepBufferServices) Create(ctx context.Context, interStepBufferService *v1alpha1.InterStepBufferService, ...) (result *v1alpha1.InterStepBufferService, err error)

+ func (c *MockInterStepBufferServices) Delete(ctx context.Context, name string, opts v1.DeleteOptions) error

+ func (c *MockInterStepBufferServices) DeleteCollection(ctx context.Context, opts v1.DeleteOptions, listOpts v1.ListOptions) error

+ func (c *MockInterStepBufferServices) Get(ctx context.Context, name string, options v1.GetOptions) (result *v1alpha1.InterStepBufferService, err error)

+ func (c *MockInterStepBufferServices) List(ctx context.Context, opts v1.ListOptions) (result *v1alpha1.InterStepBufferServiceList, err error)

+ func (c *MockInterStepBufferServices) Patch(ctx context.Context, name string, pt types.PatchType, data []byte, ...) (result *v1alpha1.InterStepBufferService, err error)

+ func (c *MockInterStepBufferServices) Update(ctx context.Context, interStepBufferService *v1alpha1.InterStepBufferService, ...) (result *v1alpha1.InterStepBufferService, err error)

+ func (c *MockInterStepBufferServices) UpdateStatus(ctx context.Context, interStepBufferService *v1alpha1.InterStepBufferService, ...) (*v1alpha1.InterStepBufferService, error)

+ func (c *MockInterStepBufferServices) Watch(ctx context.Context, opts v1.ListOptions) (watch.Interface, error)

+ type Validator interface

+ ValidateCreate func(context.Context) *admissionv1.AdmissionResponse

+ ValidateUpdate func(context.Context) *admissionv1.AdmissionResponse

+ func GetValidator(ctx context.Context, NumaClient v1alpha1.NumaflowV1alpha1Interface, ...) (Validator, error)

+ func NewISBServiceValidator(old, new *dfv1.InterStepBufferService) Validator

+ func NewPipelineValidator(isbClient v1alpha1.InterStepBufferServiceInterface, old, new *dfv1.Pipeline) Validator