v1alpha1

type CloudEventStatus struct {
	// AcceptedEventTypes are the CloudEvent types that a target can process.
	// +optional
	AcceptedEventTypes []string `json:"acceptedEventTypes,omitempty"`
}

type Correlation struct {
	Attribute string `json:"attribute"`
	Length    int    `json:"length"`
}

type DataWeaveTransformation struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   DataWeaveTransformationSpec `json:"spec"`
	Status TargetStatus                `json:"status,omitempty"`
}

type DataWeaveTransformationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []DataWeaveTransformation `json:"items"`
}

type DataWeaveTransformationSpec struct {
	// DataWeave spell that will be used by default for transformation.
	DwSpell ValueFromField `json:"dw_spell"`

	// Content type for incoming transformation.
	IncomingContentType string `json:"incoming_content_type"`

	// Content type for transformation Output.
	OutputContentType string `json:"output_content_type"`

	// Support sending to an event sink instead of replying.
	duckv1.SourceSpec `json:",inline"`
}

type EventOptions struct {
	// PayloadPolicy indicates if replies from the target should include
	// a payload if available. Possible values are:
	//
	// - always: will return a with the reply payload if avaliable.
	// - errors: will only reply with payload in case of an error.
	// - never: will not reply with payload.
	//
	// +optional
	PayloadPolicy *cloudevents.PayloadPolicy `json:"payloadPolicy,omitempty"`
}

type EventReceiver interface {
	// AcceptedEventTypes returns the event types accepted by the target.
	AcceptedEventTypes() []string
}

type EventSender interface {
	// GetSink returns the component's event sink.
	GetSink() *duckv1.Destination
}

type EventSource interface {
	// GetEventTypes returns the event types generated by the component.
	GetEventTypes() []string
	// AsEventSource returns a unique reference to the component suitable
	// for use as a CloudEvent 'source' attribute.
	AsEventSource() string
}

type JQTransformation struct {
	metav1.TypeMeta `json:",inline"`
	// +optional
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   JQTransformationSpec `json:"spec"`
	Status TargetStatus         `json:"status,omitempty"`
}

type JQTransformationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []JQTransformation `json:"items"`
}

type JQTransformationSpec struct {
	// The query that gets passed to the JQ library
	Query string `json:"query"`

	// EventOptions for targets
	EventOptions *EventOptions `json:"eventOptions,omitempty"`

	// Support sending to an event sink instead of replying.
	duckv1.SourceSpec `json:",inline"`
}

type JQTransformationStatus struct {
	duckv1.SourceStatus  `json:",inline"`
	duckv1.AddressStatus `json:",inline"`
}

type Path struct {
	Key   string `json:"key,omitempty"`
	Value string `json:"value,omitempty"`
}

type Reconcilable interface {
	metav1.Object
	runtime.Object
	// OwnerRefable is used to construct a generic reconciler for each
	// component type, and convert custom objects to owner references.
	kmeta.OwnerRefable
	// KRShaped is used by generated reconcilers to perform pre and
	// post-reconcile status updates.
	duckv1.KRShaped

	// GetStatusManager returns a manager for the component's status.
	GetStatusManager() *StatusManager
}

type Response struct {
	Timeout apis.Duration `json:"timeout"`
}

type StatusManager struct {
	apis.ConditionSet
	*TargetStatus
}

type Synchronizer struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   SynchronizerSpec `json:"spec"`
	Status TargetStatus     `json:"status,omitempty"`
}

type SynchronizerList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`
	Items           []Synchronizer `json:"items"`
}

type SynchronizerSpec struct {
	CorrelationKey Correlation `json:"correlationKey"`
	Response       Response    `json:"response"`

	// Support sending to an event sink instead of replying.
	duckv1.SourceSpec `json:",inline"`
}

type TargetStatus struct {
	duckv1.SourceStatus  `json:",inline"`
	duckv1.AddressStatus `json:",inline"`

	// Accepted CloudEvent attributes
	CloudEventStatus `json:",inline"`
}

type Transform struct {
	Operation string `json:"operation"`
	Paths     []Path `json:"paths"`
}

type Transformation struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   TransformationSpec `json:"spec,omitempty"`
	Status TargetStatus       `json:"status,omitempty"`
}

type TransformationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []Transformation `json:"items"`
}

type TransformationSpec struct {
	// Context contains Transformations that must be applied on CE Context
	Context []Transform `json:"context,omitempty"`
	// Data contains Transformations that must be applied on CE Data
	Data []Transform `json:"data,omitempty"`

	// Support sending to an event sink instead of replying.
	duckv1.SourceSpec `json:",inline"`
}

type ValueFromField struct {

	// Field value.
	// +optional
	Value string `json:"value,omitempty"`
	// Field value from a Kubernetes Secret.
	// +optional
	ValueFromSecret *corev1.SecretKeySelector `json:"valueFromSecret,omitempty"`
	// Field value from a Kubernetes ConfigMap.
	// +optional
	ValueFromConfigMap *corev1.ConfigMapKeySelector `json:"valueFromConfigMap,omitempty"`
}

type XMLToJSONTransformation struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   XMLToJSONTransformationSpec `json:"spec,omitempty"`
	Status TargetStatus                `json:"status,omitempty"`
}

type XMLToJSONTransformationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []XMLToJSONTransformation `json:"items"`
}

type XMLToJSONTransformationSpec struct {
	// EventOptions for targets
	EventOptions *EventOptions `json:"eventOptions,omitempty"`

	// Support sending to an event sink instead of replying.
	duckv1.SourceSpec `json:",inline"`
}

type XSLTTransformation struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   XSLTTransformationSpec `json:"spec"`
	Status TargetStatus           `json:"status,omitempty"`
}

type XSLTTransformationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata"`

	Items []XSLTTransformation `json:"items"`
}

type XSLTTransformationSpec struct {
	// XSLT document that will be used by default for transformation.
	// Can be omited if the XSLT is informed at each event.
	// +optional
	XSLT *ValueFromField `json:"xslt,omitempty"`

	// Whether the default XSLT can be overriden at each event
	// +optional
	AllowPerEventXSLT *bool `json:"allowPerEventXSLT,omitempty"`

	// Support sending to an event sink instead of replying.
	duckv1.SourceSpec `json:",inline"`
}