batchwriter

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

type Client interface {
	MigrateTables(context.Context, message.WriteMigrateTables) error
	WriteTableBatch(ctx context.Context, name string, messages message.WriteInserts) error
	DeleteStale(context.Context, message.WriteDeleteStales) error
	DeleteRecord(context.Context, message.WriteDeleteRecords) error
}

type IgnoreMigrateTables struct{}

type Option func(*BatchWriter)

type UnimplementedDeleteRecord struct{}

type UnimplementedDeleteStale struct{}