uuid2int

package module

v0.0.0-...-5e8611a Latest Latest Go to latest Published: Jan 16, 2025 License: Apache-2.0 Imports: 4 Imported by: 0

README ¶

go-avro-uuid2int

UUID field values in AVRO records -> (32-bit) Serial values in AVRO records

Documentation ¶

Index ¶

Constants
Variables
func AnyToUuid(i any) (gu.UUID, error)
func MapToUuid(m map[string]any, uuidColumnName string) (gu.UUID, error)
func MapToUuidAllowMissing(m map[string]any, uuidColumnName string, allowMissing bool) (gu.UUID, error)
type Codec
type DecodeConfig
type EncodeConfig
type UuidMapInt

Constants ¶

View Source

const BlobSizeMaxDefault int = 1048576

View Source

const BlockLengthDefault int = 100

View Source

const UuidSize int = 16

Variables ¶

View Source

var (
	ErrUuidMissing error = errors.New("uuid missing")
	ErrInvalidUuid error = errors.New("invalid uuid")

	ErrUnexpectedUuid error = errors.New("unexpected uuid")

	ErrAnyNil error = errors.New("nil any got")
)

Functions ¶

func AnyToUuid ¶

func AnyToUuid(
	i any,
) (gu.UUID, error)

func MapToUuid ¶

func MapToUuid(
	m map[string]any,
	uuidColumnName string,
) (gu.UUID, error)

func MapToUuidAllowMissing ¶

func MapToUuidAllowMissing(
	m map[string]any,
	uuidColumnName string,
	allowMissing bool,
) (gu.UUID, error)

Types ¶

type Codec ¶

type Codec string

const (
	CodecNull    Codec = "null"
	CodecDeflate Codec = "deflate"
	CodecSnappy  Codec = "snappy"
	CodecZstd    Codec = "zstandard"
	CodecBzip2   Codec = "bzip2"
	CodecXz      Codec = "xz"
)

type DecodeConfig ¶

type DecodeConfig struct {
	BlobSizeMax int
}

var DecodeConfigDefault DecodeConfig = DecodeConfig{
	BlobSizeMax: BlobSizeMaxDefault,
}

type EncodeConfig ¶

type EncodeConfig struct {
	BlockLength int
	Codec
}

var EncodeConfigDefault EncodeConfig = EncodeConfig{
	BlockLength: BlockLengthDefault,
	Codec:       CodecNull,
}

type UuidMapInt ¶

type UuidMapInt map[gu.UUID]int32

func (UuidMapInt) ColumnNameToMapd ¶

func (m UuidMapInt) ColumnNameToMapd(
	colname string,
) func(iter.Seq2[map[string]any, error]) iter.Seq2[map[string]any, error]

func (UuidMapInt) ColumnNameToMapdAllowMissing ¶

func (m UuidMapInt) ColumnNameToMapdAllowMissing(
	colname string,
	allowMissingUuid bool,
) func(iter.Seq2[map[string]any, error]) iter.Seq2[map[string]any, error]

func (UuidMapInt) MapsToMaps ¶

func (m UuidMapInt) MapsToMaps(
	original iter.Seq2[map[string]any, error],
	uuidColumnName string,
) iter.Seq2[map[string]any, error]

func (UuidMapInt) MapsToMapsAllowMissing ¶

func (m UuidMapInt) MapsToMapsAllowMissing(
	original iter.Seq2[map[string]any, error],
	uuidColumnName string,
	allowMissingUuid bool,
) iter.Seq2[map[string]any, error]

Source Files ¶

View all Source files

uuid2int.go

Directories ¶

Path	Synopsis
avro
dec/hamba
enc/hamba
cmd
avro-uuid2serial command
sorted2map
util
uuid2int
sorted2iter

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