driver

Mar 24, 2020

Changes in this version

+ type NeptuneDriver struct

+ Pool NeptunePool

+ func New(ctx context.Context, dbAddr string, errs chan error) (*NeptuneDriver, error)

+ func (n *NeptuneDriver) Checker(ctx context.Context, state *health.CheckState) error

+ func (n *NeptuneDriver) Close(ctx context.Context) error

+ func (n *NeptuneDriver) Healthcheck() (s string, err error)

+ type NeptunePool interface

+ Close func()

+ Execute func(query string, bindings, rebindings map[string]string) (resp []gremgo.Response, err error)

+ Get func(query string, bindings, rebindings map[string]string) ([]graphson.Vertex, error)

+ GetCount func(q string, bindings, rebindings map[string]string) (i int64, err error)

+ GetE func(q string, bindings, rebindings map[string]string) (resp interface{}, err error)

+ GetStringList func(query string, bindings, rebindings map[string]string) (vals []string, err error)

+ OpenStreamCursor func(ctx context.Context, query string, bindings, rebindings map[string]string) (stream *gremgo.Stream, err error)