conversion

type Converter ¶ added in v0.23.0

type Converter interface {
	ConvertObject(ctx context.Context, src, dst runtime.Object) error
}

type Decoder ¶

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

Decoder knows how to decode the contents of a CRD version conversion request into a concrete object. TODO(droot): consider reusing decoder from admission pkg for this.

func NewDecoder(scheme *runtime.Scheme) *Decoder

func (d *Decoder) Decode(content []byte) (runtime.Object, *schema.GroupVersionKind, error)

func (d *Decoder) DecodeInto(content []byte, into runtime.Object) error

type PartialImplementationError ¶

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

PartialImplementationError represents an error due to partial conversion implementation such as hub without spokes, multiple hubs or spokes without hub.

func (e PartialImplementationError) Error() string

type Registry ¶ added in v0.23.0

type Registry interface {
	RegisterConverter(gk schema.GroupKind, converter Converter) error
	GetConverter(gk schema.GroupKind) (Converter, bool)
}

func NewRegistry() Registry

type SpokeConverter ¶ added in v0.23.0

type SpokeConverter[hubObject runtime.Object] interface {
	GetSpoke() runtime.Object
	ConvertHubToSpoke(ctx context.Context, hub hubObject, spoke runtime.Object) error
	ConvertSpokeToHub(ctx context.Context, spoke runtime.Object, hub hubObject) error
}

func NewSpokeConverter[hubObject, spokeObject client.Object](
	spoke spokeObject,
	convertHubToSpokeFunc func(ctx context.Context, src hubObject, dst spokeObject) error,
	convertSpokeToHubFunc func(ctx context.Context, src spokeObject, dst hubObject) error,
) SpokeConverter[hubObject]