client

package

v0.7.1 Latest Latest Go to latest Published: Dec 26, 2016 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/dmonay/dgraph

Links

Open Source Insights

Documentation ¶

Index ¶

func Date(date time.Time) (*graph.Value, error)
func Datetime(date time.Time) (*graph.Value, error)
func Uid(uid uint64) string
func ValueFromGeoJson(json string) (*graph.Value, error)
type BatchMutation
- func NewBatchMutation(ctx context.Context, conn *grpc.ClientConn, size int, pending int) *BatchMutation
type Counter
type Op
type Req

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Date ¶

func Date(date time.Time) (*graph.Value, error)

func Datetime ¶

func Datetime(date time.Time) (*graph.Value, error)

func Uid ¶

func Uid(uid uint64) string

Uid converts an uint64 to a string, which can be used as part of Subject and ObjectId fields in the graph.NQuad

func ValueFromGeoJson ¶

func ValueFromGeoJson(json string) (*graph.Value, error)

loc, err := client.ValueFromGeoJson(`{"type":"Point","coordinates":[-122.2207184,37.72129059]}`)

if err != nil {
	log.Fatal(err)
}

if err := req.AddMutation(graph.NQuad{
	Subject:     "alice",
	Predicate:   "birthday",
	ObjectValue: loc,
}, client.SET); err != nil {

	log.Fatal(err)
}

Types ¶

type BatchMutation ¶

type BatchMutation struct {
	// contains filtered or unexported fields
}

func NewBatchMutation ¶

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

func (*BatchMutation) AddMutation ¶

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

func (*BatchMutation) Counter ¶

func (batch *BatchMutation) Counter() Counter

func (*BatchMutation) Flush ¶

func (batch *BatchMutation) Flush()

type Counter ¶

type Counter struct {
	Rdfs      uint64
	Mutations uint64
	Elapsed   time.Duration
}

type Op ¶

type Op int

const (
	SET Op = iota
	DEL
)

type Req ¶

type Req struct {
	// contains filtered or unexported fields
}

Req wraps the graph.Request so that we can define helper methods for the client around it.

func (*Req) Request ¶

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

Request returns the graph request object which is sent to the server to perform a query/mutation.

func (*Req) SetQuery ¶

func (req *Req) SetQuery(q string)

SetQuery sets a query as part of the request. Example usage req := client.Req{} req.SetQuery("{ me(_xid_: alice) { name falls.in } }") resp, err := c.Query(context.Background(), req.Request()) Check response and handle errors

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL