analytics

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

type CellConfig struct {
	Name string `json:"name,omitempty"`
	Type string `json:"type,omitempty"`
}

type EventNode struct {
	Id      string       `json:"id"`
	Name    string       `json:"name"`
	Configs []NodeConfig `json:"configs"`
}

type EventPipelineDescription struct {
	GenericEventSource *deploymentmodel.GenericEventSource `json:"generic_event_source,omitempty"`
	ImportId           string                              `json:"import_id,omitempty"`
	DeviceGroupId      string                              `json:"device_group_id,omitempty"`
	DeviceId           string                              `json:"device_id,omitempty"`
	ServiceId          string                              `json:"service_id,omitempty"`
	FunctionId         string                              `json:"function_id,omitempty"`
	AspectId           string                              `json:"aspect_id,omitempty"`
	ValuePath          string                              `json:"value_path,omitempty"`
	OperatorValue      string                              `json:"operator_value"`
	EventId            string                              `json:"event_id"`
	DeploymentId       string                              `json:"deployment_id"`
	FlowId             string                              `json:"flow_id,omitempty"`
	UseMarshaller      bool                                `json:"use_marshaller,omitempty"`
}

type FactoryType struct{}

type Flow struct {
	Id          string    `json:"_id"`
	Name        string    `json:"name"`
	Description string    `json:"description"`
	Model       FlowModel `json:"model"`
}

type FlowModel struct {
	Cells []FlowModelCell `json:"cells"`
}

type FlowModelCell struct {
	Id             string                 `json:"id"`
	Name           string                 `json:"name"`
	DeploymentType string                 `json:"deploymentType"`
	InPorts        []string               `json:"inPorts,omitempty"`
	OutPorts       []string               `json:"outPorts,omitempty"`
	Type           string                 `json:"type"`
	Source         map[string]interface{} `json:"source"`
	Target         map[string]interface{} `json:"target"`
	Image          string                 `json:"image"`
	Config         []CellConfig           `json:"config,omitempty"`
	OperatorId     string                 `json:"operatorId"`
}

type InputTopic struct {
	Name        string    `json:"name,omitempty"`
	FilterType  string    `json:"filterType,omitempty"`
	FilterValue string    `json:"filterValue,omitempty"`
	Mappings    []Mapping `json:"mappings,omitempty"`
}

type Mapping struct {
	Dest   string `json:"dest,omitempty"`
	Source string `json:"source,omitempty"`
}

type NodeConfig struct {
	Name  string `json:"name,omitempty"`
	Value string `json:"value,omitempty"`
}

type NodeInput struct {
	FilterIds  string      `json:"filterIds,omitempty"`
	FilterType string      `json:"filterType"`
	TopicName  string      `json:"topicName,omitempty"`
	Values     []NodeValue `json:"values,omitempty"`
}

type NodeValue struct {
	Name string `json:"name,omitempty"`
	Path string `json:"path,omitempty"`
}

type Operator struct {
	Id             string            `json:"id,omitempty"`
	Name           string            `json:"name,omitempty"`
	ImageId        string            `json:"imageId,omitempty"`
	DeploymentType string            `json:"deploymentType,omitempty"`
	OperatorId     string            `json:"operatorId,omitempty"`
	Config         map[string]string `json:"config,omitempty"`
	InputTopics    []InputTopic
}

type Pipeline struct {
	Id          uuid.UUID  `json:"id,omitempty"`
	Name        string     `json:"name,omitempty"`
	Description string     `json:"description,omitempty"`
	Operators   []Operator `json:"operators,omitempty"`
}

type PipelineNode struct {
	NodeId string       `json:"nodeId,omitempty"`
	Inputs []NodeInput  `json:"inputs,omitempty"`
	Config []NodeConfig `json:"config,omitempty"`
}

type PipelineRequest struct {
	Id          string         `json:"id,omitempty"`
	FlowId      string         `json:"flowId,omitempty"`
	Name        string         `json:"name,omitempty"`
	Description string         `json:"description,omitempty"`
	WindowTime  int            `json:"windowTime,omitempty"`
	Nodes       []PipelineNode `json:"nodes,omitempty"`
}