Method mutate

dgraph/cmd/live/batch.go:158–169

(req *request)

}

func (l *loader) mutate(req *request) error {
	atomic.AddInt32(&l.inflight, 1)
	defer atomic.AddInt32(&l.inflight, -1)
	txn := l.dc.NewTxn()
	req.CommitNow = true
	request := &api.Request{
		CommitNow: true,
		Mutations: []*api.Mutation{req.Mutation},
	}
	_, err := txn.Do(l.opts.Ctx, request)
	return err
}

func (l *loader) request(req *request) {
	err := l.mutate(req)