Line data    Source code

       1             : // Copyright 2023 The LevelDB-Go and Pebble Authors. All rights reserved. Use
       2             : // of this source code is governed by a BSD-style license that can be found in
       3             : // the LICENSE file.
       4             : 
       5             : package keyspan
       6             : 
       7             : import "github.com/cockroachdb/pebble/internal/base"
       8             : 
       9             : // Transformer defines a transformation to be applied to a Span.
      10             : type Transformer interface {
      11             :         // Transform takes a Span as input and writes the transformed Span to the
      12             :         // provided output *Span pointer. The output Span's Keys slice may be reused
      13             :         // by Transform to reduce allocations.
      14             :         Transform(cmp base.Compare, in Span, out *Span) error
      15             : }
      16             : 
      17             : // The TransformerFunc type is an adapter to allow the use of ordinary functions
      18             : // as Transformers. If f is a function with the appropriate signature,
      19             : // TransformerFunc(f) is a Transformer that calls f.
      20             : type TransformerFunc func(base.Compare, Span, *Span) error
      21             : 
      22             : // Transform calls f(cmp, in, out).
      23           2 : func (tf TransformerFunc) Transform(cmp base.Compare, in Span, out *Span) error {
      24           2 :         return tf(cmp, in, out)
      25           2 : }
      26             : 
      27           2 : var noopTransform Transformer = TransformerFunc(func(_ base.Compare, s Span, dst *Span) error {
      28           2 :         dst.Start, dst.End = s.Start, s.End
      29           2 :         dst.Keys = append(dst.Keys[:0], s.Keys...)
      30           2 :         return nil
      31           2 : })
      32             : 
      33             : // VisibleTransform filters keys that are invisible at the provided snapshot
      34             : // sequence number.
      35           1 : func VisibleTransform(snapshot uint64) Transformer {
      36           1 :         return TransformerFunc(func(_ base.Compare, s Span, dst *Span) error {
      37           1 :                 dst.Start, dst.End = s.Start, s.End
      38           1 :                 dst.Keys = dst.Keys[:0]
      39           1 :                 for _, k := range s.Keys {
      40           1 :                         // NB: The InternalKeySeqNumMax value is used for the batch snapshot
      41           1 :                         // because a batch's visible span keys are filtered when they're
      42           1 :                         // fragmented. There's no requirement to enforce visibility at
      43           1 :                         // iteration time.
      44           1 :                         if base.Visible(k.SeqNum(), snapshot, base.InternalKeySeqNumMax) {
      45           1 :                                 dst.Keys = append(dst.Keys, k)
      46           1 :                         }
      47             :                 }
      48           1 :                 return nil
      49             :         })
      50             : }