package ws
import "entgo.io/ent/dialect/gremlin/internal/ws"
Index ¶
- Variables
- type Conn
- func (c *Conn) Close() error
- func (c *Conn) Execute(ctx context.Context, req *gremlin.Request) (*gremlin.Response, error)
- type Dialer
Variables ¶
var ( // DefaultDialer is a dialer with all fields set to the default values. DefaultDialer = &Dialer{ Dialer: websocket.Dialer{ Proxy: http.ProxyFromEnvironment, HandshakeTimeout: 5 * time.Second, WriteBufferSize: 8192, ReadBufferSize: 8192, }, } // ErrConnClosed is returned by the Conn's Execute method when // the underlying gremlin server connection is closed. ErrConnClosed = errors.New("gremlin: server connection closed") // ErrDuplicateRequest is returned by the Conns Execute method on // request identifier key collision. ErrDuplicateRequest = errors.New("gremlin: duplicate request") )
Types ¶
type Conn ¶
type Conn struct {
// contains filtered or unexported fields
}
Conn performs operations on a gremlin server.
func (*Conn) Close ¶
Close connection with a Gremlin server.
func (*Conn) Execute ¶
Execute executes a request against a Gremlin server.
type Dialer ¶
type Dialer struct { // Underlying websocket dialer. websocket.Dialer // contains filtered or unexported fields }
A Dialer contains options for connecting to Gremlin server.
func (*Dialer) Dial ¶
Dial creates a new connection by calling DialContext with a background context.
func (*Dialer) DialContext ¶
DialContext creates a new Gremlin connection.
Source Files ¶
conn.go
- Version
- v0.14.4 (latest)
- Published
- Mar 17, 2025
- Platform
- linux/amd64
- Imports
- 13 packages
- Last checked
- 1 day ago –
Tools for package owners.