v1alpha1

type EventSourceRef struct {
	// Name of the event source
	Name string `json:"name" protobuf:"bytes,1,name=name"`
	// Namespace of the event source
	// Default value is the namespace where referencing gateway is deployed
	// +optional
	Namespace string `json:"namespace,omitempty" protobuf:"bytes,2,opt,name=namespace"`
}

type Gateway struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	Status            GatewayStatus `json:"status" protobuf:"bytes,2,opt,name=status"`
	Spec              GatewaySpec   `json:"spec" protobuf:"bytes,3,opt,name=spec"`
}

type GatewayList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"`
	// +listType=items
	Items []Gateway `json:"items" protobuf:"bytes,2,opt,name=items"`
}

type GatewayResource struct {
	// Metadata of the deployment for the gateway
	Deployment *metav1.ObjectMeta `json:"deployment" protobuf:"bytes,1,name=deployment"`
	// Metadata of the service for the gateway
	// +optional
	Service *metav1.ObjectMeta `json:"service,omitempty" protobuf:"bytes,2,opt,name=service"`
}

type GatewaySpec struct {
	// Template is the pod specification for the gateway
	// +optional
	Template Template `json:"template,omitempty" protobuf:"bytes,1,opt,name=template"`
	// EventSourceRef refers to event-source that stores event source configurations for the gateway
	EventSourceRef *EventSourceRef `json:"eventSourceRef,omitempty" protobuf:"bytes,2,opt,name=eventSourceRef"`
	// Type is the type of gateway. Used as metadata.
	Type apicommon.EventSourceType `json:"type" protobuf:"bytes,3,opt,name=type"`
	// Service is the specifications of the service to expose the gateway
	// +optional
	Service *Service `json:"service,omitempty" protobuf:"bytes,4,opt,name=service"`
	// Subscribers holds the contexts of the subscribers/sinks to send events to.
	// +listType=subscribers
	// +optional
	Subscribers *Subscribers `json:"subscribers,omitempty" protobuf:"bytes,5,opt,name=subscribers"`
	// Port on which the gateway event source processor is running on.
	ProcessorPort string `json:"processorPort" protobuf:"bytes,6,opt,name=processorPort"`
	// Replica is the gateway deployment replicas
	Replica int `json:"replica,omitempty" protobuf:"bytes,9,opt,name=replica"`
}

type GatewayStatus struct {
	// Phase is the high-level summary of the gateway
	Phase NodePhase `json:"phase" protobuf:"bytes,1,opt,name=phase"`
	// StartedAt is the time at which this gateway was initiated
	StartedAt metav1.Time `json:"startedAt,omitempty" protobuf:"bytes,2,opt,name=startedAt"`
	// Message is a human readable string indicating details about a gateway in its phase
	Message string `json:"message,omitempty" protobuf:"bytes,4,opt,name=message"`
	// Nodes is a mapping between a node ID and the node's status
	// it records the states for the configurations of gateway.
	Nodes map[string]NodeStatus `json:"nodes,omitempty" protobuf:"bytes,5,rep,name=nodes"`
	// Resources refers to the metadata about the gateway resources
	Resources *GatewayResource `json:"resources" protobuf:"bytes,6,opt,name=resources"`
}

type NATSSubscriber struct {
	// ServerURL refers to the NATS server URL.
	ServerURL string `json:"serverURL" protobuf:"bytes,1,name=serverURL"`
	// Subject refers to the NATS subject name.
	Subject string `json:"subject" protobuf:"bytes,2,name=subject"`
	// Name of the subscription. Must be unique.
	Name string `json:"name" protobuf:"bytes,3,name=name"`
}

type NodePhase string

type NodeStatus struct {
	// ID is a unique identifier of a node within a sensor
	// It is a hash of the node name
	ID string `json:"id" protobuf:"bytes,1,opt,name=id"`
	// Name is a unique name in the node tree used to generate the node ID
	Name string `json:"name" protobuf:"bytes,3,opt,name=name"`
	// DisplayName is the human readable representation of the node
	DisplayName string `json:"displayName" protobuf:"bytes,5,opt,name=displayName"`
	// Phase of the node
	Phase NodePhase `json:"phase" protobuf:"bytes,6,opt,name=phase"`
	// StartedAt is the time at which this node started
	// +k8s:openapi-gen=false
	StartedAt metav1.MicroTime `json:"startedAt,omitempty" protobuf:"bytes,7,opt,name=startedAt"`
	// Message store data or something to save for configuration
	Message string `json:"message,omitempty" protobuf:"bytes,8,opt,name=message"`
	// UpdateTime is the time when node(gateway configuration) was updated
	UpdateTime metav1.MicroTime `json:"updateTime,omitempty" protobuf:"bytes,9,opt,name=updateTime"`
}

type Service struct {
	// The list of ports that are exposed by this service.
	// +patchMergeKey=port
	// +patchStrategy=merge
	// +listType=map
	// +listMapKey=port
	// +listMapKey=protocol
	Ports []corev1.ServicePort `json:"ports,omitempty" patchStrategy:"merge" patchMergeKey:"port" protobuf:"bytes,1,rep,name=ports"`
	// Spec holds the gateway service spec.
	// DEPRECATED: Use Ports to declare the ports to be exposed.
	Spec *corev1.ServiceSpec `json:"spec,omitempty" protobuf:"bytes,2,opt,name=spec"`
}

type Subscribers struct {
	// HTTP subscribers are HTTP endpoints to send events to.
	// +listType=string
	// +optional
	HTTP []string `json:"http,omitempty" protobuf:"bytes,1,opt,name=http"`
	// NATS refers to the subscribers over NATS protocol.
	// +listType=NATSSubscriber
	// +optional
	NATS []NATSSubscriber `json:"nats,omitempty" protobuf:"bytes,2,opt,name=nats"`
}

type Template struct {
	// ServiceAccountName is the name of the ServiceAccount to use to run gateway pod.
	// More info: https://kubernetes.io/docs/tasks/configure-pod-container/configure-service-account/
	// +optional
	ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,1,opt,name=serviceAccountName"`
	// Container is the main container image to run in the gateway pod
	// +optional
	Container *corev1.Container `json:"container,omitempty" protobuf:"bytes,2,opt,name=container"`
	// Volumes is a list of volumes that can be mounted by containers in a workflow.
	// +patchStrategy=merge
	// +patchMergeKey=name
	// +optional
	Volumes []corev1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,3,opt,name=volumes"`
	// SecurityContext holds pod-level security attributes and common container settings.
	// Optional: Defaults to empty.  See type description for default values of each field.
	// +optional
	SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,4,opt,name=securityContext"`
	// Spec holds the gateway deployment spec.
	// DEPRECATED: Use Container instead.
	Spec *corev1.PodSpec `json:"spec,omitempty" protobuf:"bytes,5,opt,name=spec"`
}