bolt

Documentation

Overview

Package bolt contains implementations of the database functionality.

Index

• Constants
• func Connect(ctx context.Context, serverName string, conn net.Conn, auth map[string]any, ...) (db.Connection, error)
• func IsTimeoutError(err error) bool
• func NewBolt3(serverName string, conn net.Conn, logger log.Logger, boltLog log.BoltLogger) *bolt3
• func NewBolt4(serverName string, conn net.Conn, logger log.Logger, boltLog log.BoltLogger) *bolt4
• func NewBolt5(serverName string, conn net.Conn, logger log.Logger, boltLog log.BoltLogger) *bolt5
• type ConnectionReadCanceled
  • func (crc *ConnectionReadCanceled) Error() string
• type ConnectionReadTimeout
  • func (crt *ConnectionReadTimeout) Error() string
• type ConnectionWriteCanceled
  • func (cwc *ConnectionWriteCanceled) Error() string
• type ConnectionWriteTimeout
  • func (cwt *ConnectionWriteTimeout) Error() string

Constants

const InvalidTransactionError = "invalid transaction handle"

Functions

func Connect

func Connect(ctx context.Context, serverName string, conn net.Conn, auth map[string]any, userAgent string, routingContext map[string]string, logger log.Logger, boltLog log.BoltLogger) (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 IsTimeoutError

func IsTimeoutError(err error) bool

func NewBolt3

func NewBolt3(serverName string, conn net.Conn, logger log.Logger, boltLog log.BoltLogger) *bolt3

func NewBolt4

func NewBolt4(serverName string, conn net.Conn, logger log.Logger, boltLog log.BoltLogger) *bolt4

func NewBolt5

func NewBolt5(serverName string, conn net.Conn, logger log.Logger, boltLog log.BoltLogger) *bolt5

Types

type ConnectionReadCanceled

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

func (*ConnectionReadCanceled) Error

func (crc *ConnectionReadCanceled) Error() string

type ConnectionReadTimeout

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

func (*ConnectionReadTimeout) Error

func (crt *ConnectionReadTimeout) Error() string

type ConnectionWriteCanceled

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

func (*ConnectionWriteCanceled) Error

func (cwc *ConnectionWriteCanceled) Error() string

type ConnectionWriteTimeout

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

func (*ConnectionWriteTimeout) Error

func (cwt *ConnectionWriteTimeout) Error() string