avro

package
v1.18.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PrintRecord

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

Types

type Avro

type Avro struct {
	Find Find `cmd:"" help:"Find and print record in remote avro file."`
}

type Find

type Find struct {
	Bucket   string `arg:"" help:"GCS bucket name"`
	Prefix   string `arg:"" help:"Prefix path in the bucket to search Avro files"`
	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

func (*Find) SearchAvroRecord

func (f *Find) SearchAvroRecord(ctx context.Context, bucketName, prefix, keyField string, keyValue interface{}) (map[string]interface{}, error)

SearchAvroRecord searches for a record with the given primary key across all Avro files

Jump to

Keyboard shortcuts

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