Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TargetInterface ¶
type TargetInterface interface { // InitializeRelation takes a relation definition and a CSV file as a reader and // creates the relation in the target and populates it with data from the CSV InitializeRelation(ctx context.Context, relation *db.Relation, r io.Reader) error // VerifyRelation takes a relation definition and checks that the relation in the target // matches the schema VerifyRelation(ctx context.Context, relation *db.Relation) (bool, error) // Write accepts a batch of WAL transactions and writes them to the target Write(ctx context.Context, batch []*db.WalTransaction) error // Close does any needed cleanup and closes any open connections Close(ctx context.Context) error }
Click to show internal directories.
Click to hide internal directories.