Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gremgo

package module

Go to main page

Versions in this module

v1

v1.1.0

Sep 7, 2023

Changes in this version

type DialerConfig

+ func SetTLSClientConfig(conf *tls.Config) DialerConfig

v1.0.3

Apr 21, 2023

v1.0.2

Jun 3, 2021

v1.0.1

Dec 11, 2020

v1.0.0

Jun 22, 2020

Changes in this version

+ const StatusAuthenticate

+ const StatusInvalidRequestArguments

+ const StatusMalformedRequest

+ const StatusNoContent

+ const StatusPartialContent

+ const StatusScriptEvaluationError

+ const StatusServerError

+ const StatusServerSerializationError

+ const StatusServerTimeout

+ const StatusSuccess

+ const StatusUnauthorized

+ var ErrBadConn = errors.New("bad conn")

+ var ErrGraphDBClosed = errors.New("graphdb is closed")

+ var ErrorConnectionDisposed = errors.New("you cannot write on a disposed connection")

+ var ErrorNoGraphTags = errors.New("does not contain any graph tags")

+ var ErrorUnsupportedPropertyType = errors.New("unsupported property map value type")

+ func GremlinForVertex(label string, data interface{}) (gremAdd, gremGet string, err error)

+ type Client struct

+ Errored bool

+ func Dial(conn dialer, errs chan error) (c Client, err error)

+ func DialCtx(ctx context.Context, conn dialer, errs chan error) (c Client, err error)

+ func (c *Client) AddE(label, fromId, toId string, props map[string]interface{}) (resp interface{}, err error)

+ func (c *Client) AddEdgeCtx(ctx context.Context, label, fromId, toId string, props map[string]interface{}) (resp interface{}, err error)

+ func (c *Client) AddV(label string, data interface{}, bindings, rebindings map[string]string) (vert graphson.Vertex, err error)

+ func (c *Client) AddVertexCtx(ctx context.Context, label string, data interface{}, ...) (vert graphson.Vertex, err error)

+ func (c *Client) Close()

+ func (c *Client) Execute(query string, bindings, rebindings map[string]string) (resp []Response, err error)

+ func (c *Client) ExecuteCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (resp []Response, err error)

+ func (c *Client) ExecuteFile(path string, bindings, rebindings map[string]string) (resp []Response, err error)

+ func (c *Client) Get(query string, bindings, rebindings map[string]string) (res []graphson.Vertex, err error)

+ func (c *Client) GetCount(query string, bindings, rebindings map[string]string) (i int64, err error)

+ func (c *Client) GetCountCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (i int64, err error)

+ func (c *Client) GetCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (res []graphson.Vertex, err error)

+ func (c *Client) GetE(query string, bindings, rebindings map[string]string) (res []graphson.Edge, err error)

+ func (c *Client) GetEdgeCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (res []graphson.Edge, err error)

+ func (c *Client) GetProperties(query string, bindings, rebindings map[string]string) (vals map[string][]interface{}, err error)

+ func (c *Client) GetPropertiesCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (vals map[string][]interface{}, err error)

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

+ func (c *Client) GetStringListCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (vals []string, err error)

+ func (c *Client) OpenCursorCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (cursor *Cursor, err error)

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

+ func (c *Client) ReadCursorCtx(ctx context.Context, cursor *Cursor) (res []graphson.Vertex, eof bool, err error)

+ type Cursor struct

+ ID string

+ type DialerConfig func(*Ws)

+ func SetAuthentication(username string, password string) DialerConfig

+ func SetPingInterval(seconds int) DialerConfig

+ func SetReadingWait(seconds int) DialerConfig

+ func SetTimeout(seconds int) DialerConfig

+ func SetWritingWait(seconds int) DialerConfig

+ type Pool struct

+ MaxLifetime time.Duration

+ MaxOpen int

+ func NewPool(dial func() (*Client, error)) *Pool

+ func NewPoolWithDialerCtx(ctx context.Context, dbURL string, errs chan error, cfgs ...DialerConfig) *Pool

+ func (p *Pool) AddE(label, fromId, toId string, props map[string]interface{}) (resp interface{}, err error)

+ func (p *Pool) AddEdgeCtx(ctx context.Context, label, fromId, toId string, props map[string]interface{}) (resp interface{}, err error)

+ func (p *Pool) AddV(label string, i interface{}, bindings, rebindings map[string]string) (resp graphson.Vertex, err error)

+ func (p *Pool) AddVertexCtx(ctx context.Context, label string, i interface{}, ...) (resp graphson.Vertex, err error)

+ func (p *Pool) Close()

+ func (p *Pool) Execute(query string, bindings, rebindings map[string]string) (resp []Response, err error)

+ func (p *Pool) ExecuteCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (resp []Response, err error)

+ func (p *Pool) ExecuteFile(path string, bindings, rebindings map[string]string) (resp []Response, err error)

+ func (p *Pool) Get(query string, bindings, rebindings map[string]string) (resp []graphson.Vertex, err error)

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

+ func (p *Pool) GetCountCtx(ctx context.Context, q string, bindings, rebindings map[string]string) (i int64, err error)

+ func (p *Pool) GetCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (resp []graphson.Vertex, err error)

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

+ func (p *Pool) GetEdgeCtx(ctx context.Context, q string, bindings, rebindings map[string]string) (resp interface{}, err error)

+ func (p *Pool) GetProperties(q string, bindings, rebindings map[string]string) (vals map[string][]interface{}, err error)

+ func (p *Pool) GetPropertiesCtx(ctx context.Context, q string, bindings, rebindings map[string]string) (vals map[string][]interface{}, err error)

+ func (p *Pool) GetStringList(q string, bindings, rebindings map[string]string) (vals []string, err error)

+ func (p *Pool) GetStringListCtx(ctx context.Context, q string, bindings, rebindings map[string]string) (vals []string, err error)

+ func (p *Pool) OpenCursorCtx(ctx context.Context, query string, bindings, rebindings map[string]string) (cursor *Cursor, err error)

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

+ func (p *Pool) ReadCursorCtx(ctx context.Context, cursor *Cursor) (res []graphson.Vertex, eof bool, err error)

+ type Response struct

+ RequestID string

+ Result Result

+ Status Status

+ func (r Response) ToString() string

+ type Result struct

+ Data json.RawMessage

+ Meta map[string]interface{}

+ type Retriever interface

+ type Status struct

+ Attributes map[string]interface{}

+ Code int

+ Message string

+ type Stream struct

+ func (s *Stream) Close(ctx context.Context) error

+ func (s *Stream) Read() (string, error)

+ type Ws struct

+ func NewDialer(host string, configs ...DialerConfig) (dialer *Ws)

+ func (ws *Ws) IsConnected() bool

+ func (ws *Ws) IsDisposed() bool