(ref blob.Ref, data string)
| 109 | } |
| 110 | |
| 111 | func (st *shareTester) putRaw(ref blob.Ref, data string) { |
| 112 | if _, err := blobserver.Receive(ctxbg, st.sto, ref, strings.NewReader(data)); err != nil { |
| 113 | st.t.Fatalf("error storing %q: %v", ref, err) |
| 114 | } |
| 115 | if st.handler.idx != nil { |
| 116 | if _, err := st.handler.idx.ReceiveBlob(ctxbg, ref, strings.NewReader(data)); err != nil { |
| 117 | st.t.Fatalf("error indexing %q, with schema \n%q\n: %v", ref, data, err) |
| 118 | } |
| 119 | } |
| 120 | } |
| 121 | |
| 122 | func (st *shareTester) put(blob *schema.Blob) { |
| 123 | st.putRaw(blob.BlobRef(), blob.JSON()) |
no test coverage detected