writer

Documentation

Overview

Package writer implements a writer logic for the Neo4j Destination.

Index

• Variables
• type Params
• type Writer
  • func New(params Params) *Writer
  • func (w *Writer) Write(ctx context.Context, record sdk.Record) error

Variables

var (
	// ErrEmptyRawData occurs when trying to structurize empty [sdk.RawData].
	ErrEmptyRawData = errors.New("empty raw data")
	// ErrUnsupportedEntityType occurs when the entityType is unsupported by the [Writer].
	ErrUnsupportedEntityType = errors.New("unsupported entity type")
	// ErrEmptySourceNode occurs when the entityType is relationship but a payload doesn't contain sourceNode.
	ErrEmptySourceNode = errors.New("empty source node")
	// ErrEmptyTargetNode occurs when the entityType is relationship but a payload doesn't contain targetNode.
	ErrEmptyTargetNode = errors.New("empty target node")
)

Types

type Params

type Params struct {
	Driver       neo4j.DriverWithContext
	DatabaseName string
	EntityType   config.EntityType
	EntityLabels []string
}

Params holds incoming params for the Writer.

type Writer

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

Writer implements a writer logic for the Neo4j Destination.

func New

func New(params Params) *Writer

New creates a new instance of the Writer.

func (*Writer) Write

func (w *Writer) Write(ctx context.Context, record sdk.Record) error

Write writes a record to the destination.