driver

Documentation

Index

• type NeptuneDriver
  • func New(ctx context.Context, dbAddr string, errs chan error) (*NeptuneDriver, error)
  • func (n *NeptuneDriver) Close(ctx context.Context) error
  • func (n *NeptuneDriver) Healthcheck() (s string, err error)
• type NeptunePool

Types

type NeptuneDriver

type NeptuneDriver struct {
	Pool NeptunePool // Defined with an interface to support mocking.
}

func New

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

func (*NeptuneDriver) Close

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

func (*NeptuneDriver) Healthcheck

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

Healthcheck calls neptune to check its health status

type NeptunePool

type NeptunePool interface {
	Close()
	Execute(query string, bindings, rebindings map[string]string) (resp []gremgo.Response, err error)
	Get(query string, bindings, rebindings map[string]string) ([]graphson.Vertex, error)
	GetCount(q string, bindings, rebindings map[string]string) (i int64, err error)
	GetE(q string, bindings, rebindings map[string]string) (resp interface{}, err error)
	OpenStreamCursor(ctx context.Context, query string, bindings, rebindings map[string]string) (stream *gremgo.Stream, err error)
	GetStringList(query string, bindings, rebindings map[string]string) (vals []string, err error)
}

NeptunePool defines the contract required of the gremgo connection Pool by the Neptune.Driver.