MCPcopy Create free account
hub / github.com/brimdata/super / Put

Function Put

pkg/storage/engine.go:54–64  ·  view source on GitHub ↗
(ctx context.Context, engine Engine, u *URI, r io.Reader)

Source from the content-addressed store, hash-verified

52}
53
54func Put(ctx context.Context, engine Engine, u *URI, r io.Reader) error {
55 w, err := engine.Put(ctx, u)
56 if err != nil {
57 return err
58 }
59 _, err = io.Copy(w, r)
60 if closeErr := w.Close(); err == nil {
61 err = closeErr
62 }
63 return err
64}
65
66func Get(ctx context.Context, engine Engine, u *URI) ([]byte, error) {
67 r, err := engine.Get(ctx, u)

Callers 6

writeMagicMethod · 0.92
PutMethod · 0.92
putSnapshotMethod · 0.92
putBaseMethod · 0.92
writeTailMethod · 0.92
writeIDFunction · 0.92

Calls 3

PutMethod · 0.65
CloseMethod · 0.65
CopyMethod · 0.45

Tested by

no test coverage detected