plugin

Documentation

Overview

Package plugin is a proof that the door is open: it implements a source and a sink entirely outside internal/, importing only the public contracts (source, sink, driver, core, change, position, spec) and registering them with the driver registry. The fake_test drives the collapsed runner end-to-end against these two drivers.

Index

• type Sink
  • func (s *Sink) Close() error
  • func (s *Sink) EnsureTable(context.Context, core.TableRef, core.Schema, []string, core.CastPolicy, ...) error
  • func (s *Sink) Position(context.Context, core.TableRef) (string, error)
  • func (s *Sink) Properties(context.Context, core.TableRef) (map[string]string, error)
  • func (s *Sink) SetProperties(context.Context, core.TableRef, map[string]string) error
  • func (s *Sink) Writer(context.Context, core.TableRef, core.CastPolicy, []core.MetadataColumn) (sink.TableWriter, error)
• type Source
  • func (Source) InitialPosition(context.Context) (position.Position, error)
  • func (Source) Introspect(_ context.Context, t spec.Table) (core.TableRef, core.Schema, []core.Warning, error)
  • func (Source) Open(_ context.Context, refs []source.TableRef) (source.Reader, error)
  • func (Source) ParsePosition(s string) (position.Position, error)

Types

type Sink

type Sink struct {
	// contains filtered or unexported fields
}

Sink records committed batches in the shared records singleton.

func (*Sink) Close

func (s *Sink) Close() error

func (*Sink) EnsureTable

func (s *Sink) EnsureTable(context.Context, core.TableRef, core.Schema, []string, core.CastPolicy, dataplane.WriteMode) error

func (*Sink) Position

func (s *Sink) Position(context.Context, core.TableRef) (string, error)

func (*Sink) Properties

func (s *Sink) Properties(context.Context, core.TableRef) (map[string]string, error)

func (*Sink) SetProperties

func (s *Sink) SetProperties(context.Context, core.TableRef, map[string]string) error

func (*Sink) Writer

func (s *Sink) Writer(context.Context, core.TableRef, core.CastPolicy, []core.MetadataColumn) (sink.TableWriter, error)

type Source

type Source struct{}

Source is a stream-only fake: it emits seedRows and holds the stream open until the pipeline cancels it.

func (Source) InitialPosition

func (Source) InitialPosition(context.Context) (position.Position, error)

func (Source) Introspect

func (Source) Introspect(_ context.Context, t spec.Table) (core.TableRef, core.Schema, []core.Warning, error)

func (Source) Open

func (Source) Open(_ context.Context, refs []source.TableRef) (source.Reader, error)

func (Source) ParsePosition

func (Source) ParsePosition(s string) (position.Position, error)