destination

type Config struct {
	config.Config

	// KeyColumn is a column name that is used to detect if the target table already contains the record.
	// Max length is 64, see [MySQL Identifier Length Limits].
	//
	// [MySQL Identifier Length Limits]: https://dev.mysql.com/doc/refman/8.0/en/identifier-length.html
	KeyColumn string `key:"keyColumn" validate:"required,max=64"`
}

type Destination struct {
	sdk.UnimplementedDestination
	// contains filtered or unexported fields
}

type Writer interface {
	Write(ctx context.Context, record sdk.Record) error
	Close() error
}