Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NeptuneDriver ¶
type NeptuneDriver struct {
Pool NeptunePool // Defined with an interface to support mocking.
}
func (*NeptuneDriver) Checker ¶
func (n *NeptuneDriver) Checker(ctx context.Context, state *health.CheckState) error
Checker checks health of Neptune and updates the provided CheckState accordingly
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.
Source Files
Click to show internal directories.
Click to hide internal directories.