bolt

Documentation

Overview

Package bolt contains implementations of the database functionality.

Index

• Constants
• func Connect(ctx context.Context, serverName string, conn net.Conn, auth *db.ReAuthToken, ...) (db.Connection, error)
• func NewBolt3(serverName string, conn io.ReadWriteCloser, ...) *bolt3
• func NewBolt4(serverName string, conn io.ReadWriteCloser, ...) *bolt4
• func NewBolt5(serverName string, conn io.ReadWriteCloser, ...) *bolt5
• type ConnectionErrorListener

Constants

const DefaultReadBufferSize = 8192

DefaultReadBufferSize specifies the default size (in bytes) of the buffer used for reading data from the network connection.

Functions

func Connect

func Connect(ctx context.Context,
	serverName string,
	conn net.Conn,
	auth *db.ReAuthToken,
	userAgent string,
	routingContext map[string]string,
	errorListener ConnectionErrorListener,
	logger log.Logger,
	boltLogger log.BoltLogger,
	notificationConfig db.NotificationConfig,
	readBufferSize int,
) (db.Connection, error)

Connect initiates the negotiation of the Bolt protocol version. Returns the instance of bolt protocol implementing the low-level Connection interface.

func NewBolt3

func NewBolt3(
	serverName string,
	conn io.ReadWriteCloser,
	errorListener ConnectionErrorListener,
	logger log.Logger,
	boltLog log.BoltLogger,
) *bolt3

func NewBolt4

func NewBolt4(
	serverName string,
	conn io.ReadWriteCloser,
	errorListener ConnectionErrorListener,
	logger log.Logger,
	boltLog log.BoltLogger,
) *bolt4

func NewBolt5

func NewBolt5(
	serverName string,
	conn io.ReadWriteCloser,
	errorListener ConnectionErrorListener,
	logger log.Logger,
	boltLog log.BoltLogger,
) *bolt5

Types

type ConnectionErrorListener

type ConnectionErrorListener interface {
	OnNeo4jError(context.Context, idb.Connection, *db.Neo4jError) error
	OnIoError(context.Context, idb.Connection, error)
	OnDialError(context.Context, string, error)
}