Versions in this module Expand all Collapse all v1 v1.2.0 Sep 11, 2026 v1.1.0 Sep 10, 2026 Changes in this version + var Triggers = []Trigger + func CanonicalKey(dt arrow.DataType) string + func LatticeArray(key string, null bool) (arrow.Array, error) + func LatticeKeys() []string + func LatticeListWithNullElement(key string) (arrow.Array, error) + func LatticeString(v string) arrow.Array + func Pipelines(t *testing.T, s PipelineSubject) + func Sinks(t *testing.T, s SinkSubject) + func Types(t *testing.T, s TypeSubject) + type PipelineSubject struct + Break func(t *testing.T) + Heal func(t *testing.T) + Integration string + KeepsState bool + NewSink func(t *testing.T) core.Sink + Options func(r *Recorder) []core.TurbineOption + ReadBack func(t *testing.T) []Row + type Proxy struct + Addr string + func NewProxy(t *testing.T, nw *testcontainers.DockerNetwork, upstream string) *Proxy + func (p *Proxy) Break(t *testing.T) + func (p *Proxy) Heal(t *testing.T) + type Recorder struct + func (r *Recorder) Events() []string + func (r *Recorder) Offsets() *RecordingOffsets + func (r *Recorder) Tx() *RecordingTx + type RecordingOffsets struct + func (o *RecordingOffsets) Save(ctx context.Context, marks *core.Marks) error + type RecordingTx struct + func (x *RecordingTx) Commit(ctx context.Context) error + func (x *RecordingTx) Rollback(ctx context.Context) error + type Row map[string]any + type SinkSubject struct + Break func(t *testing.T) + Heal func(t *testing.T) + Integration string + New func(t *testing.T) core.Sink + OrderedReadBack bool + ReadBack func(t *testing.T) []Row + Table func(t *testing.T, id int64) arrow.Table + type Trigger string + const TriggerBatchFull + const TriggerDrain + const TriggerInterval + const TriggerSourceClosed + type TypeDestination struct + ReadBack func(t *testing.T) (any, error) + ReadBackNullElement func(t *testing.T) (bool, error) + Sink core.Sink + type TypeSubject struct + Declared []coverage.TypeDecl + Integration string + ListElementNulls coverage.NullRule + Nulls coverage.NullRule + Prepare func(t *testing.T, key, columnType string) TypeDestination
Go to main page