kedavro

Documentation

Index

• type Field
  • func ParseSchemaField(f interface{}, opts types.Options) (*Field, error)
• type Parser
  • func NewParser(schemaString string, opts ...ParserOption) (Parser, error)
• type ParserOption
  • func WithDateTimeFormat(format string) ParserOption
  • func WithNowForNullTimestamp() ParserOption
  • func WithStringToBool() ParserOption
  • func WithStringToNumber() ParserOption
  • func WithTimestampToMicros() ParserOption
  • func WithTimestampToMillis() ParserOption

Types

type Field

type Field struct {
	HasDefault   bool
	Opts         types.Options
	Name         string
	LogicalType  string
	Type         types.FieldType
	TypeValue    interface{}
	DefaultValue interface{}
	Fields       []*Field
	ParseField   parseFieldFunction
}

func ParseSchemaField

func ParseSchemaField(f interface{}, opts types.Options) (*Field, error)

type Parser

type Parser interface {
	Parse(record []byte) (interface{}, error)
	ParseMap(record map[string]interface{}) (interface{}, error)
}

func NewParser

func NewParser(schemaString string, opts ...ParserOption) (Parser, error)

type ParserOption

type ParserOption func(*types.Options)

ParserOption reconfigure the parser creation.

func WithDateTimeFormat

func WithDateTimeFormat(format string) ParserOption

func WithNowForNullTimestamp

func WithNowForNullTimestamp() ParserOption

func WithStringToBool

func WithStringToBool() ParserOption

func WithStringToNumber

func WithStringToNumber() ParserOption

func WithTimestampToMicros

func WithTimestampToMicros() ParserOption

func WithTimestampToMillis

func WithTimestampToMillis() ParserOption