analytics

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

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

type Config struct {
	WorkerParamPrefix   string `json:"worker_param_prefix"`
	FlowEngineUrl       string `json:"flow_engine_url"`
	FlowParserUrl       string `json:"flow_parser_url"`
	ImportDeployUrl     string `json:"import_deploy_url"`
	DeviceRepositoryUrl string `json:"device_repository_url"`
	Debug               bool   `json:"debug"`

	EnableMultiplePaths bool   `json:"enable_multiple_paths"`
	DevicePathPrefix    string `json:"device_path_prefix"`
	GroupPathPrefix     string `json:"group_path_prefix"`
	ImportPathPrefix    string `json:"import_path_prefix"`

	RemoveImportPathRoot bool `json:"remove_import_path_root"`

	HealthCheckInterval string `json:"health_check_interval"`
}

type Devices interface {
	GetDeviceInfosOfGroup(token auth.Token, groupId string) (devices []devices.Device, deviceTypeIds []string, err error)
	GetDeviceInfosOfDevices(token auth.Token, deviceIds []string) (devices []devices.Device, deviceTypeIds []string, err error)
	GetDeviceTypeSelectables(token auth.Token, criteria []devices.FilterCriteria, includeModified bool, servicesMustMatchAllCriteria bool) (result []devices.DeviceTypeSelectable, err error)
}

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

type EventPipelineDescription struct {
	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"`
}

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 Imports interface {
	GetTopic(token auth.Token, importId string) (topic string, err error)
}

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"`
	PersistData bool         `json:"persistData,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"`
	ConsumeAllMessages bool           `json:"consumeAllMessages,omitempty"`
	MergeStrategy      string         `json:"mergeStrategy,omitempty"`
	Nodes              []PipelineNode `json:"nodes,omitempty"`
}

type PipelineState struct {
	Message       string `json:"message"`
	Name          string `json:"name"`
	Running       bool   `json:"running"`
	Transitioning bool   `json:"transitioning"`
}

type SmartServiceRepo interface {
	GetInstanceUser(instanceId string) (userId string, err error)
	ListExistingModules(processInstanceId string, query model.ModulQuery) (result []model.SmartServiceModule, err error)
}