maps2avro

Documentation

Index

• func MapsToStdoutFromSchema(schema string) func(iter.Seq2[map[string]any, error]) util.IO[util.Void]
• func MapsToWriter(ctx context.Context, s ha.Schema, m iter.Seq2[map[string]any, error], ...) error
• func SchemaStringMapsToStdout(ctx context.Context, schema string, m iter.Seq2[map[string]any, error]) error
• func SchemaStringToMapsToWriter(ctx context.Context, schema string, m iter.Seq2[map[string]any, error], ...) error

Functions

func MapsToStdoutFromSchema

func MapsToStdoutFromSchema(
	schema string,
) func(iter.Seq2[map[string]any, error]) util.IO[util.Void]

func MapsToWriter

func MapsToWriter(
	ctx context.Context,
	s ha.Schema,
	m iter.Seq2[map[string]any, error],
	w io.Writer,
) error

func SchemaStringMapsToStdout

func SchemaStringMapsToStdout(
	ctx context.Context,
	schema string,
	m iter.Seq2[map[string]any, error],
) error

func SchemaStringToMapsToWriter

func SchemaStringToMapsToWriter(
	ctx context.Context,
	schema string,
	m iter.Seq2[map[string]any, error],
	w io.Writer,
) error