recorder

package

v1.0.1 Latest Latest Go to latest Published: Aug 16, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Package recorder contains an acceptor implementation that records the method calls it sees.

This section is empty.

This section is empty.

This section is empty.

type Call struct {
	Multi    *types.MultiBatch
	Table    *types.TableBatch
	Temporal *types.TemporalBatch
}

Call is a union struct that retains the batch that was passed in.

func (c *Call) Count() int

Count returns the number of enclosed mutations.

type Recorder struct {
	Next types.MultiAcceptor // An optional delegate for calls.
	// contains filtered or unexported fields
}

Recorder implements types.MultiAcceptor, recording its inputs. This type is safe for concurrent access.

func (r *Recorder) AcceptMultiBatch(
	ctx context.Context, batch *types.MultiBatch, options *types.AcceptOptions,
) error

AcceptMultiBatch implements types.MultiAcceptor.

func (r *Recorder) AcceptTableBatch(
	ctx context.Context, batch *types.TableBatch, options *types.AcceptOptions,
) error

AcceptTableBatch implements types.TableAcceptor.

func (r *Recorder) AcceptTemporalBatch(
	ctx context.Context, batch *types.TemporalBatch, options *types.AcceptOptions,
) error

AcceptTemporalBatch implements types.TemporalAcceptor.

func (r *Recorder) Calls() []*Call

Calls returns a copy of the recording.

func (r *Recorder) Count() int

Count returns the number of enclosed mutations.