v1alpha1

type Position int

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

	Spec   TinyModuleSpec   `json:"spec,omitempty"`
	Status TinyModuleStatus `json:"status,omitempty"`
}

type TinyModuleList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []TinyModule `json:"items"`
}

type TinyModuleSpec struct {

	// Foo is an example field of TinyModule. Edit tinymodule_types.go to remove/update
	Image string `json:"image,omitempty"`
}

type TinyModuleStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Addr string `json:"addr"`
}

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

	Spec   TinyNodeSpec   `json:"spec,omitempty"`
	Status TinyNodeStatus `json:"status,omitempty"`
}

type TinyNodeEdge struct {
	// Edge id
	// +kubebuilder:validation:Required
	ID string `json:"id"`
	// Current node's port name
	// Source port
	// +kubebuilder:validation:Required
	Port string `json:"port"`
	// Other node's full port name
	// +kubebuilder:validation:Required
	To string `json:"to"`
}

type TinyNodeList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []TinyNode `json:"items"`
}

type TinyNodePortConfig struct {
	// +kubebuilder:validation:Optional
	// Settings depend on a sender
	From string `json:"from,omitempty"`
	// +kubebuilder:validation:Required
	Port string `json:"port"`

	// +kubebuilder:validation:Optional
	//Schema JSON schema of the port
	Schema []byte `json:"schema"`

	// +kubebuilder:validation:Optional
	//Configuration JSON data of the port's configuration
	Configuration []byte `json:"configuration"`
}

type TinyNodePortStatus struct {
	Name          string   `json:"name"`
	Label         string   `json:"label"`
	Position      Position `json:"position"`
	Settings      bool     `json:"settings"`
	Status        bool     `json:"status"`
	Source        bool     `json:"source"`
	Schema        []byte   `json:"schema"`
	Configuration []byte   `json:"configuration"`
}

type TinyNodeSpec struct {

	// Module name - container image repo + tag
	// +kubebuilder:validation:Required
	Module string `json:"module"`

	// Component name within a module
	// +kubebuilder:validation:Required
	Component string `json:"component"`

	// Port configurations
	// +kubebuilder:validation:Optional
	Ports []TinyNodePortConfig `json:"ports"`

	// Edges to send message next
	// +kubebuilder:validation:Optional
	Edges []TinyNodeEdge `json:"edges"`

	//Run if emitter component should run
	// +kubebuilder:validation:Optional
	Run bool `json:"run"`
}

type TinyNodeStatus struct {
	// +kubebuilder:validation:Optional
	Ports []TinyNodePortStatus `json:"ports"`

	// +kubebuilder:validation:Optional
	Error string `json:"error,omitempty"`

	// +kubebuilder:validation:Optional
	Status string `json:"status,omitempty"`

	// +kubebuilder:validation:Optional
	Emitter bool `json:"emitter,omitempty"`

	// +kubebuilder:validation:Optional
	Running bool `json:"running,omitempty"`
}

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

	Spec   TinyTrackerSpec   `json:"spec,omitempty"`
	Status TinyTrackerStatus `json:"status,omitempty"`
}

type TinyTrackerList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []TinyTracker `json:"items"`
}

type TinyTrackerPortDataWebhook struct {
	FlowID string `json:"flowID"`

	// URL of the POST request
	URL string `json:"url,omitempty"`

	//Interval send requests not often than interval
	Interval metav1.Duration `json:"interval"`

	//Do not send data bigger than below
	MaxDataSize int `json:"maxDataSize"`
}

type TinyTrackerSpec struct {
	// +kubebuilder:validation:Optional
	PortDataWebhook *TinyTrackerPortDataWebhook `json:"portDataWebhook"`

	// +kubebuilder:validation:Optional
	NodeStatisticsWebhook *TinyTrackerStatisticsWebhook `json:"nodeStatisticsWebhook"`
}

type TinyTrackerStatisticsWebhook struct {
	FlowID string `json:"flowID"`

	// URL of the POST request
	URL string `json:"url,omitempty"`

	//Interval send requests not often than interval
	Interval metav1.Duration `json:"interval"`
}

type TinyTrackerStatus struct {
}