ingestor

package
v1.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 16, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	// Neo4j
	MergeNodeQueryTemplate = `` /* 175-byte string literal not displayed */

	MergeRelationQueryTemplate = `` /* 364-byte string literal not displayed */

	// Using sprintf to insert the label name since the driver doesn't support parameters for labels here
	// %[1]s is a nice way to say "insert the first parameter here"
	CreateConstraintQueryTemplate = "CREATE CONSTRAINT IF NOT EXISTS FOR (n: %s) REQUIRE n.Id IS UNIQUE"
	CreateIndexQueryTemplate      = "CREATE INDEX %[1]s_Id IF NOT EXISTS FOR (n: %[1]s) ON (n.Id)"

	PostProcessMergeQueryTemplate = `` /* 200-byte string literal not displayed */

)

Variables

This section is empty.

Functions

This section is empty.

Types

type CloudFoxIngestor

type CloudFoxIngestor struct {
	Neo4jConfig
	//ResultsFile string
	Driver neo4j.DriverWithContext
	TmpDir string
}

func NewCloudFoxIngestor

func NewCloudFoxIngestor() (*CloudFoxIngestor, error)

func (*CloudFoxIngestor) InsertDBObjects

func (i *CloudFoxIngestor) InsertDBObjects(object schema.Node, relationships []schema.Relationship, labels []schema.NodeLabel) error

func (*CloudFoxIngestor) ProcessFile

func (i *CloudFoxIngestor) ProcessFile(path string, info os.FileInfo) error

func (*CloudFoxIngestor) ProcessFileObjects

func (i *CloudFoxIngestor) ProcessFileObjects(path string, objectType schema.NodeLabel, generalType schema.NodeLabel) error

func (*CloudFoxIngestor) Run

func (i *CloudFoxIngestor) Run(graphOutputDir string) error

type Neo4jConfig

type Neo4jConfig struct {
	Uri      string
	Username string
	Password string
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL