avro

package
v1.19.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 13, 2025 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PrintRecord

func PrintRecord(prefix string, record map[string]interface{})

Types

type Avro

type Avro struct {
	Find Find `cmd:"" help:"Find and print record in remote avro file."`
	List List `cmd:"" help:"List all avro files and the first id in the file."`
}

type Find

type Find struct {
	WithAvroFiles
	KeyField string `arg:"" help:"Primary key field name to search for"`
	KeyValue string `arg:"" help:"Value of the primary key to search for"`
	Debug    bool   `help:"Enable debug mode"`
}

func (*Find) Run

func (f *Find) Run() error

type List added in v1.19.0

type List struct {
	WithAvroFiles
	KeyField string `arg:"" help:"Primary key field name to search for"`
}

func (*List) Run added in v1.19.0

func (f *List) Run() error

type WithAvroFiles added in v1.19.0

type WithAvroFiles struct {
	Bucket string `arg:"" help:"GCS bucket name"`
	Prefix string `arg:"" help:"Prefix path in the bucket to search Avro files"`
}

func (*WithAvroFiles) ForEach added in v1.19.0

func (f *WithAvroFiles) ForEach(cb func(bucket *storage.BucketHandle, name string) error) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL