(ctx context.Context, name string, sortKeys order.SortKeys, seekStride int, thresh int64)
| 64 | } |
| 65 | |
| 66 | func (l *local) CreatePool(ctx context.Context, name string, sortKeys order.SortKeys, seekStride int, thresh int64) (ksuid.KSUID, error) { |
| 67 | if name == "" { |
| 68 | return ksuid.Nil, errors.New("no pool name provided") |
| 69 | } |
| 70 | pool, err := l.db.CreatePool(ctx, name, sortKeys, seekStride, thresh) |
| 71 | if err != nil { |
| 72 | return ksuid.Nil, err |
| 73 | } |
| 74 | return pool.ID, nil |
| 75 | } |
| 76 | |
| 77 | func (l *local) RemovePool(ctx context.Context, id ksuid.KSUID) error { |
| 78 | return l.db.RemovePool(ctx, id) |
nothing calls this directly
no test coverage detected