ekuiper-new/xstream/nodes/without_edgex.go

// +build !edgex

package nodes

import "github.com/emqx/kuiper/xstream/api"

func getSource(t string) (api.Source, error) {
	return doGetSource(t)
}