service

type DeviceManagerService interface {
	GetDevice(deviceID, userID, token string) (models.Device, error)
	GetDeviceType(deviceTypeID, userID, token string) (models.DeviceType, error)
}

type Driver interface {
	CreateOperators(pipelineId string, input []pipe.Operator, pipelineConfig lib.PipelineConfig) error
	/*
		DeleteOperator deletes an operator in the given pipeline
		Deprecated: Use DeleteOperators instead.
	*/
	DeleteOperator(pipelineId string, input pipe.Operator) error
	DeleteOperators(pipelineId string, inputs []pipe.Operator) error
	GetPipelineStatus(pipelineId string) (lib.PipelineStatus, error)
	GetPipelinesStatus() ([]lib.PipelineStatus, error)
}

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

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

type Kafka2MqttApiService interface {
	StartOperatorInstance(operatorName, operatorID string, pipelineID, userI, token string) (kafka2mqtt_api.Instance, error)
	RemoveInstance(id, pipelineID, userID, token string) error
}

type ParsingApiService interface {
	GetPipeline(id string, userId string, authorization string) (p parser.Pipeline, err error)
}

type PermissionApiService interface {
	UserHasDevicesReadAccess(ids []string, authorization string) (bool, error)
}

type PipelineApiService interface {
	RegisterPipeline(pipeline *pipe.Pipeline, userId string, authorization string) (id uuid.UUID, err error)
	UpdatePipeline(pipeline *pipe.Pipeline, userId string, authorization string) (err error)
	GetPipeline(id string, userId string, authorization string) (pipe pipe.Pipeline, err error)
	GetPipelines(userId string, authorization string) (pipelines []pipe.Pipeline, err error)
	DeletePipeline(id string, userId string, authorization string) (err error)
}