ingestor

Documentation

Index

• Constants
• type CloudFoxIngestor
  • func NewCloudFoxIngestor() (*CloudFoxIngestor, error)
  • func (i *CloudFoxIngestor) InsertDBObjects(object schema.Node, relationships []schema.Relationship, ...) error
  • func (i *CloudFoxIngestor) ProcessFile(path string, info os.FileInfo) error
  • func (i *CloudFoxIngestor) ProcessFileObjects(path string, objectType schema.NodeLabel, generalType schema.NodeLabel) error
  • func (i *CloudFoxIngestor) Run(graphOutputDir string) error
• type Neo4jConfig

Constants

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 */

)

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
}