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

Method CreatePool

db/api/remote.go:56–70  ·  view source on GitHub ↗
(ctx context.Context, name string, sortKeys order.SortKeys, seekStride int, thresh int64)

Source from the content-addressed store, hash-verified

54}
55
56func (r *remote) CreatePool(ctx context.Context, name string, sortKeys order.SortKeys, seekStride int, thresh int64) (ksuid.KSUID, error) {
57 res, err := r.conn.CreatePool(ctx, api.PoolPostRequest{
58 Name: name,
59 SortKeys: api.SortKeys{
60 Order: sortKeys.Primary().Order,
61 Keys: field.List{sortKeys.Primary().Key},
62 },
63 SeekStride: seekStride,
64 Thresh: thresh,
65 })
66 if err != nil {
67 return ksuid.Nil, err
68 }
69 return res.Pool.ID, err
70}
71
72func (r *remote) CreateBranch(ctx context.Context, poolID ksuid.KSUID, name string, at ksuid.KSUID) error {
73 _, err := r.conn.CreateBranch(ctx, poolID, api.BranchPostRequest{

Callers

nothing calls this directly

Calls 2

PrimaryMethod · 0.80
CreatePoolMethod · 0.65

Tested by

no test coverage detected