Files
storage/neo4j/README.md
René 9f8091caff
Some checks failed
Release Drafter (All) / changes (push) Has been cancelled
Sync docs / sync-docs (push) Has been cancelled
Tests ArangoDB / Tests (1.19.x) (push) Has been cancelled
Tests ArangoDB / Tests (1.20.x) (push) Has been cancelled
Tests ArangoDB / Tests (1.21.x) (push) Has been cancelled
Tests Azure Blob / Tests (1.19.x) (push) Has been cancelled
Tests Azure Blob / Tests (1.20.x) (push) Has been cancelled
Tests Azure Blob / Tests (1.21.x) (push) Has been cancelled
Tests Badger / Tests (1.19.x) (push) Has been cancelled
Tests Badger / Tests (1.20.x) (push) Has been cancelled
Tests Badger / Tests (1.21.x) (push) Has been cancelled
Tests Bbolt / Tests (1.19.x) (push) Has been cancelled
Tests Bbolt / Tests (1.20.x) (push) Has been cancelled
Tests Bbolt / Tests (1.21.x) (push) Has been cancelled
Tests Clickhouse / Tests (1.22.x) (push) Has been cancelled
Tests Clickhouse / Tests (1.23.x) (push) Has been cancelled
Tests Clickhouse / Tests (1.24.x) (push) Has been cancelled
Tests CloudflareKV / Tests (1.21.x) (push) Has been cancelled
Tests CloudflareKV / Tests (1.22.x) (push) Has been cancelled
Tests Coherence / Tests (1.19.x) (push) Has been cancelled
Tests Coherence / Tests (1.20.x) (push) Has been cancelled
Tests Coherence / Tests (1.21.x) (push) Has been cancelled
Tests Coherence / Tests (1.22.x) (push) Has been cancelled
Tests Couchbase / Tests (1.22.x) (push) Has been cancelled
Tests Couchbase / Tests (1.23.x) (push) Has been cancelled
Tests Couchbase / Tests (1.24.x) (push) Has been cancelled
Tests DynamoDB / Tests (1.22.x) (push) Has been cancelled
Tests DynamoDB / Tests (1.23.x) (push) Has been cancelled
Tests DynamoDB / Tests (1.24.x) (push) Has been cancelled
Tests Etcd / Tests (1.19.x) (push) Has been cancelled
Tests Etcd / Tests (1.20.x) (push) Has been cancelled
Tests Etcd / Tests (1.21.x) (push) Has been cancelled
Tests LevelDB / Tests (1.23.x) (push) Has been cancelled
Tests LevelDB / Tests (1.24.x) (push) Has been cancelled
Tests Memcache / Tests (1.19.x) (push) Has been cancelled
Tests Memcache / Tests (1.20.x) (push) Has been cancelled
Tests Memcache / Tests (1.21.x) (push) Has been cancelled
Tests Local Storage / Tests (1.19.x) (push) Has been cancelled
Tests Local Storage / Tests (1.20.x) (push) Has been cancelled
Tests Local Storage / Tests (1.21.x) (push) Has been cancelled
Tests Minio / Tests (1.22.x) (push) Has been cancelled
Tests Minio / Tests (1.23.x) (push) Has been cancelled
Tests Minio / Tests (1.24.x) (push) Has been cancelled
Tests Local Storage / Tests (1.22.x) (push) Has been cancelled
Tests Mongodb / Tests (1.22.x) (push) Has been cancelled
Tests Mongodb / Tests (1.23.x) (push) Has been cancelled
Tests Mongodb / Tests (1.24.x) (push) Has been cancelled
Tests MSSQL / Tests (1.19.x) (push) Has been cancelled
Tests MSSQL / Tests (1.20.x) (push) Has been cancelled
Tests MSSQL / Tests (1.21.x) (push) Has been cancelled
Tests MySQL / Tests (1.22.x) (push) Has been cancelled
Tests MySQL / Tests (1.23.x) (push) Has been cancelled
Tests MySQL / Tests (1.24.x) (push) Has been cancelled
Tests Nats Driver / Tests (1.22.x) (push) Has been cancelled
Tests Nats Driver / Tests (1.23.x) (push) Has been cancelled
Tests Nats Driver / Tests (1.24.x) (push) Has been cancelled
Tests Neo4j / Tests (1.23.x) (push) Has been cancelled
Tests pebble / Tests (1.19.x) (push) Has been cancelled
Tests pebble / Tests (1.20.x) (push) Has been cancelled
Tests pebble / Tests (1.21.x) (push) Has been cancelled
Tests Postgres / Tests (1.22.x) (push) Has been cancelled
Tests Postgres / Tests (1.23.x) (push) Has been cancelled
Tests Postgres / Tests (1.24.x) (push) Has been cancelled
Tests Redis / Tests (1.19.x, 6.x) (push) Has been cancelled
Tests Redis / Tests (1.19.x, 7.x) (push) Has been cancelled
Tests Redis / Tests (1.20.x, 6.x) (push) Has been cancelled
Tests Redis / Tests (1.20.x, 7.x) (push) Has been cancelled
Tests Redis / Tests (1.21.x, 6.x) (push) Has been cancelled
Tests Redis / Tests (1.21.x, 7.x) (push) Has been cancelled
Tests Ristretto / Tests (1.19.x) (push) Has been cancelled
Tests Ristretto / Tests (1.20.x) (push) Has been cancelled
Tests Ristretto / Tests (1.21.x) (push) Has been cancelled
Tests Rueidis / Tests (1.20.x, 6.x) (push) Has been cancelled
Tests Rueidis / Tests (1.20.x, 7.x) (push) Has been cancelled
Tests Rueidis / Tests (1.21.x, 6.x) (push) Has been cancelled
Tests Rueidis / Tests (1.21.x, 7.x) (push) Has been cancelled
Tests S3 / Tests (1.21.x) (push) Has been cancelled
Tests S3 / Tests (1.22.x) (push) Has been cancelled
Tests S3 / Tests (1.23.x) (push) Has been cancelled
Tests ScyllaDb / Tests (1.20.x) (push) Has been cancelled
Tests ScyllaDb / Tests (1.21.x) (push) Has been cancelled
Tests Sqlite3 / Tests (1.19.x) (push) Has been cancelled
Tests Sqlite3 / Tests (1.20.x) (push) Has been cancelled
Tests Sqlite3 / Tests (1.21.x) (push) Has been cancelled
Tests Valkey / Tests (1.23.x, 7.x) (push) Has been cancelled
Tests Valkey / Tests (1.23.x, 8.x) (push) Has been cancelled
Release Drafter (All) / release-drafter (push) Has been cancelled
Fix badges
2025-03-23 16:33:25 +01:00

3.9 KiB

id, title
id title
neo4j Neo4j

Release Discord Test A Neo4j storage driver using neo4j/neo4j-go-driver.

Note: Requires latest two releases of Golang

Table of Contents

Signatures

func New(config ...Config) *Storage
func (s *Storage) Get(key string) ([]byte, error)
func (s *Storage) Set(key string, val []byte, exp time.Duration) error
func (s *Storage) Delete(key string) error
func (s *Storage) Reset() error
func (s *Storage) Close() error
func (s *Storage) Conn() neo4j.DriverWithContext

Installation

Neo4j is tested on the 2 last Go versions with support for modules. So make sure to initialize one first if you didn't do that yet:

go mod init github.com/<user>/<repo>

And then install the neo4j implementation:

go get github.com/gofiber/storage/neo4j

Examples

Import the storage package.

import "github.com/gofiber/storage/neo4j"

You can use the following possibilities to create a storage:

The neo4j package name used in this example is the package name (and default import name) for this storage driver. Feel free import it with a custom name to avoid confusing it with the neo4j-go-driver package which also uses neo4j as package name (and default import name).

// Initialize default config
store := neo4j.New()

// Initialize custom config
store := neo4j.New(neo4j.Config{
 DB:              driver,
 Node:            "fiber_storage",
 Reset:           false,
 GCInterval:      10 * time.Second,
})

Config

The neo4j, auth, and config package names used here belong to the neo4j-go-driver package.

// Config defines the config for storage.
type Config struct {
 // Connection pool
 //
 // DB neo4j.DriverWithContext object will override connection URI and other connection fields.
 //
 // Optional. Default is nil.
 DB neo4j.DriverWithContext

 // Target Server
 //
 // Optional. Default is "neo4j://localhost"
 URI string

 // Connection authentication
 //
 // Auth auth.TokenManager will override Username and Password fields
 //
 // Optional. Default is nil.
 Auth auth.TokenManager

 // Connection configurations
 //
 // Optional. Default is nil
 Configurations []func(*config.Config)

 // Server username
 //
 // Optional. Default is ""
 Username string

 // Server password
 //
 // Optional. Default is ""
 Password string

 // Node name
 //
 // Optional. Default is "fiber_storage"
 Node string

 // Reset clears any existing keys (Nodes)
 //
 // Optional. Default is false
 Reset bool

 // Time before deleting expired keys (Nodes)
 //
 // Optional. Default is 10 * time.Second
 GCInterval time.Duration
}

A note on Authentication

If auth is enabled on your server, then authentication must be provided in one of the three ways (the previous overrides the next):

  • Via the connection pool, neo4j.DriverWithContext, provided on the DB field.
  • Via the Auth field: it must be an auth.TokenManager whose value is any one but neo4j.NoAuth().
  • By setting both Username and Password fields: This will cause this storage driver to use Basic Auth.

Otherwise, your neo4j driver will panic with authorization error.

In contrast, if auth is disabled on your server, there's no need to provide any authentication parameter.

Default Config

Used only for optional fields

var ConfigDefault = Config{
 URI: "neo4j://localhost",
 Node:          "fiber_storage",
 Reset:         false,
 GCInterval:    10 * time.Second,
}