loaders

package

v1.0.0-dev Latest Latest Go to latest Published: Jun 3, 2025 License: GPL-3.0 Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

func RateIDsFromOrderedNavigableMap(data *utils.OrderedNavigableMap) ([]string, error)

func TenantIDFromOrderedNavigableMap(data *utils.OrderedNavigableMap) *utils.TenantID

type ArgsProcessFolder struct {
	LoaderID string
	APIOpts  map[string]any
}

type ArgsProcessZip struct {
	LoaderID string
	Data     []byte
	APIOpts  map[string]any
}

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

func NewCSVFile(rdr io.ReadCloser, path string, sep rune, nrFlds int) *CSVFile

func NewCSVReader(prv CSVProvider, dPath, fn string, sep rune, nrFlds int) (_ *CSVFile, err error)

func NewStringCSV(data string, sep rune, nrFlds int) *CSVFile

func (c *CSVFile) Close() error

func (c *CSVFile) Path() string

func (c *CSVFile) Read() ([]string, error)

type CSVProvider interface {
	Open(dPath, fn string) (io.ReadCloser, error)
	Type() string
}

type LoaderS struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

LoaderS is the Loader service handling independent Loaders

func NewLoaderS(cfg *config.CGRConfig, dm *engine.DataManager,
	filterS *engine.FilterS,
	connMgr *engine.ConnManager) (ldrS *LoaderS)

func (ldrS *LoaderS) Enabled() bool

Enabled returns true if at least one loader is enabled

func (ldrS *LoaderS) ListenAndServe(stopChan chan struct{}) (err error)

func (ldrS *LoaderS) Reload(dm *engine.DataManager,
	filterS *engine.FilterS, connMgr *engine.ConnManager)

Reload recreates the loaders map thread safe

func (ldrS *LoaderS) V1ImportZip(ctx *context.Context, args *ArgsProcessZip,
	rply *string) (err error)

func (ldrS *LoaderS) V1Run(ctx *context.Context, args *ArgsProcessFolder,
	rply *string) (err error)

type Locker interface {
	Lock() error
	Unlock() error
	Locked() (bool, error)
	IsLockFile(string) bool
}