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

Method PoolID

db/api/local.go:122–132  ·  view source on GitHub ↗
(ctx context.Context, poolName string)

Source from the content-addressed store, hash-verified

120}
121
122func (l *local) PoolID(ctx context.Context, poolName string) (ksuid.KSUID, error) {
123 if poolName == "" {
124 return ksuid.Nil, errors.New("no pool name provided")
125 }
126 if id, err := dbid.ParseID(poolName); err == nil {
127 if _, err := l.db.OpenPool(ctx, id); err == nil {
128 return id, nil
129 }
130 }
131 return l.db.PoolID(ctx, poolName)
132}
133
134func (l *local) CommitObject(ctx context.Context, poolID ksuid.KSUID, branchName string) (ksuid.KSUID, error) {
135 return l.db.CommitObject(ctx, poolID, branchName)

Callers 4

AddVectorsMethod · 0.95
DeleteVectorsMethod · 0.95
VacateMethod · 0.95
VacuumMethod · 0.95

Calls 4

ParseIDFunction · 0.92
NewMethod · 0.80
OpenPoolMethod · 0.80
PoolIDMethod · 0.65

Tested by

no test coverage detected