rethinkdb

Documentation

Index

• func Close()
• func Health() error
• func Init() (err error)
• func New(cfg config.RethinkDB) (*r.Session, error)
• func Session() (*r.Session, error)

Functions

func Close

func Close()

Close closes the RethinkDB session

func Health

func Health() error

Health checks if the RethinkDB connection is healthy

func Init

func Init() (err error)

Init initializes the global RethinkDB session. It reads RethinkDB configuration from config.App.RethinkDB. If RethinkDB is not enabled, it returns nil. The function is thread-safe and ensures the session is initialized only once.

func New

func New(cfg config.RethinkDB) (*r.Session, error)

New returns a new RethinkDB session with given configuration. It's the caller's responsibility to close the session, caller should always call Close() when it's no longer needed.

func Session

func Session() (*r.Session, error)

Session returns the RethinkDB session instance