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

Method Query

db/api/remote.go:124–130  ·  view source on GitHub ↗
(ctx context.Context, inputs []srcfiles.Input)

Source from the content-addressed store, hash-verified

122}
123
124func (r *remote) Query(ctx context.Context, inputs []srcfiles.Input) (vio.Scanner, error) {
125 res, err := r.conn.Query(ctx, inputs)
126 if err != nil {
127 return nil, err
128 }
129 return queryio.NewScanner(ctx, res.Body)
130}
131
132func (r *remote) Delete(ctx context.Context, poolID ksuid.KSUID, branchName string, tags []ksuid.KSUID, commit api.CommitMessage) (ksuid.KSUID, error) {
133 res, err := r.conn.Delete(ctx, poolID, branchName, tags, commit)

Callers

nothing calls this directly

Calls 2

NewScannerFunction · 0.92
QueryMethod · 0.65

Tested by

no test coverage detected