client

Oct 9, 2017

Changes in this version

type Dgraph

+ func (d *Dgraph) DropAll() error

type Req

+ func (req *Req) DeleteAll()

+ func (req *Req) DeleteObject(v interface{}) error

+ func (req *Req) SetObject(v interface{}) error

Sep 20, 2017

Changes in this version

+ var DefaultOptions = BatchMutationOptions

+ var ErrConnected = errors.New("Edge already connected to another node.")

+ var ErrEmptyPredicate = errors.New("Edge should have a predicate set.")

+ var ErrEmptyVar = errors.New("Empty variable name.")

+ var ErrEmptyXid = errors.New("Empty XID node.")

+ var ErrInvalidSubject = errors.New("Edge should have one of Subject/SubjectVar set.")

+ var ErrInvalidType = errors.New("Invalid value type")

+ var ErrMaxTries = errors.New("Max retries exceeded for request while doing batch mutations.")

+ var ErrNotConnected = errors.New("Edge needs to be connected to another node or a value.")

+ var ErrValue = errors.New("Edge already has a value.")

+ func Unmarshal(n []*protos.Node, v interface{}) error

+ type BatchMutationOptions struct

+ Ctx context.Context

+ MaxRetries uint32

+ Pending int

+ PrintCounters bool

+ Size int

+ type Dgraph struct

+ func NewClient(clients []protos.DgraphClient, opts BatchMutationOptions, clientDir string) *Dgraph

+ func NewDgraphClient(conns []*grpc.ClientConn, opts BatchMutationOptions, clientDir string) *Dgraph

+ func (d *Dgraph) AddSchema(s protos.SchemaUpdate) error

+ func (d *Dgraph) BatchDelete(e Edge) error

+ func (d *Dgraph) BatchFlush() error

+ func (d *Dgraph) BatchSet(e Edge) error

+ func (d *Dgraph) BatchSetWithMark(r *Req, file string, line uint64) error

+ func (d *Dgraph) CheckVersion(ctx context.Context)

+ func (d *Dgraph) Checkpoint(file string) (uint64, error)

+ func (d *Dgraph) Close() error

+ func (d *Dgraph) Counter() Counter

+ func (d *Dgraph) NewSyncMarks(files []string) error

+ func (d *Dgraph) NodeBlank(varname string) (Node, error)

+ func (d *Dgraph) NodeUid(uid uint64) Node

+ func (d *Dgraph) NodeUidVar(name string) (Node, error)

+ func (d *Dgraph) NodeXid(xid string, storeXid bool) (Node, error)

+ func (d *Dgraph) Run(ctx context.Context, req *Req) (*protos.Response, error)

+ func (d *Dgraph) SetSchemaBlocking(ctx context.Context, q string) error

+ type Edge struct

+ func DeletePredicate(pred string) Edge

+ func NewEdge(nq protos.NQuad) Edge

+ func (e *Edge) AddFacet(key, val string)

+ func (e *Edge) ConnectTo(n Node) error

+ func (e *Edge) Delete() error

+ func (e *Edge) SetValueBool(val bool) error

+ func (e *Edge) SetValueBytes(val []byte) error

+ func (e *Edge) SetValueDatetime(dateTime time.Time) error

+ func (e *Edge) SetValueDefault(val string) error

+ func (e *Edge) SetValueFloat(val float64) error

+ func (e *Edge) SetValueGeoGeometry(g geom.T) error

+ func (e *Edge) SetValueGeoJson(json string) error

+ func (e *Edge) SetValueInt(val int64) error

+ func (e *Edge) SetValuePassword(val string) error

+ func (e *Edge) SetValueString(val string) error

+ func (e *Edge) SetValueStringWithLang(val string, lang string) error

+ type Node struct

+ func (n *Node) ConnectTo(pred string, n1 Node) Edge

+ func (n *Node) Delete() Edge

+ func (n *Node) Edge(pred string) Edge

+ func (n Node) String() string

type Req

+ func (req *Req) AddSchema(s protos.SchemaUpdate) error

+ func (req *Req) Delete(e Edge) error

+ func (req *Req) Set(e Edge) error

+ func (req *Req) SetQueryWithVariables(q string, vars map[string]string)

+ func (req *Req) SetSchema(q string)

+ func (req *Req) Size() int

Feb 22, 2017

Changes in this version

+ func Password(val string, nq *graph.NQuad) error

Jan 27, 2017

Changes in this version

+ func Bool(val bool, nq *graph.NQuad) error

+ func Date(date time.Time, nq *graph.NQuad) error

+ func Datetime(date time.Time, nq *graph.NQuad) error

+ func Float(val float64, nq *graph.NQuad) error

+ func Int(val int32, nq *graph.NQuad) error

+ func Str(val string, nq *graph.NQuad) error

+ func Uid(uid uint64) string

+ func ValueFromGeoJson(json string, nq *graph.NQuad) error

+ type BatchMutation struct

+ func NewBatchMutation(ctx context.Context, conn *grpc.ClientConn, size int, pending int) *BatchMutation

+ func (batch *BatchMutation) AddMutation(nq graph.NQuad, op Op) error

+ func (batch *BatchMutation) Counter() Counter

+ func (batch *BatchMutation) Flush()

+ type Counter struct

+ Elapsed time.Duration

+ Mutations uint64

+ Rdfs uint64

+ type Op int

+ const DEL

+ const SET

+ type Req struct

+ func (req *Req) AddMutation(nq graph.NQuad, op Op) error

+ func (req *Req) Request() *graph.Request

+ func (req *Req) SetQuery(q string)