dbconnector

package

v1.0.1 Latest Latest Go to latest Published: Oct 20, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rethinkdb/prometheus-exporter

Links

Open Source Insights

Documentation ¶

Index ¶

func PrepareTLSConfig(caFile, certFile, keyFile string) (*tls.Config, error)
type LazyRethinkSession
- func ConnectRethinkDB(addresses []string, username, password string, tlsConfig *tls.Config, ...) *LazyRethinkSession

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func PrepareTLSConfig ¶

func PrepareTLSConfig(caFile, certFile, keyFile string) (*tls.Config, error)

PrepareTLSConfig creates tls.Config with certificate files

Types ¶

type LazyRethinkSession ¶

type LazyRethinkSession struct {
	*r.Session
	// contains filtered or unexported fields
}

LazyRethinkSession is a connection to the rethinkdb. It implements r.QueryExecutor interface. It will make attempt to connect with first call and reconnect after every error.

func ConnectRethinkDB ¶

func ConnectRethinkDB(
	addresses []string,
	username, password string,
	tlsConfig *tls.Config,
	poolSize int,
) *LazyRethinkSession

ConnectRethinkDB establishes lazy rethinkdb connection It will make attempt to connect with first call and reconnect after every error

func (*LazyRethinkSession) Close ¶

func (l *LazyRethinkSession) Close() error

Close closes connections

func (*LazyRethinkSession) Exec ¶

func (l *LazyRethinkSession) Exec(ctx context.Context, q r.Query) error

Exec executes a ReQL query using the session to connect to the database

func (*LazyRethinkSession) IsConnected ¶

func (l *LazyRethinkSession) IsConnected() bool

IsConnected returns true if session has a valid connection.

func (*LazyRethinkSession) Query ¶

func (l *LazyRethinkSession) Query(ctx context.Context, q r.Query) (*r.Cursor, error)

Query executes a ReQL query using the session to connect to the database

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL