schemer

README

schemer

Data serialization library

Documentation

Index

• Variables
• func Unmarshal(data map[string]interface{}, s *Schema) error
• func UnmarshalDefinition(data interface{}, d *Definition) error
• func UnmarshalJSON(source []byte, s *Schema) error
• type Context
  • func NewContext() *Context
  • func (ctx *Context) IsReady() bool
  • func (ctx *Context) PreloadScript(p *goja.Program) error
• type Definition
  • func NewDefinition(t ValueType) *Definition
• type RawDefinition
• type Record
  • func NewRecord(schema *Schema, raw map[string]interface{}) *Record
  • func (r *Record) GetValue(valuePath string) *Value
• type Schema
  • func NewSchema() *Schema
  • func (s *Schema) GetDefinition(valuePath string) *Definition
  • func (s *Schema) Normalize(data map[string]interface{}) map[string]interface{}
  • func (s *Schema) Scan(data map[string]interface{}) *Record
• type Schemer
  • func NewSchemer() *Schemer
• type Transformer
  • func NewTransformer(source *Schema, dest *Schema) *Transformer
  • func (t *Transformer) GetDestinationSchema() *Schema
  • func (t *Transformer) GetSourceSchema() *Schema
  • func (t *Transformer) SetDestinationSchema(schema *Schema)
  • func (t *Transformer) SetScript(script string) error
  • func (t *Transformer) SetSourceSchema(schema *Schema)
  • func (t *Transformer) Transform(env map[string]interface{}, input map[string]interface{}) ([]map[string]interface{}, error)
• type Value
  • func NewValue(def *Definition) *Value
• type ValueType

Variables

var ValueTypes = map[string]ValueType{
	"string": TYPE_STRING,
	"binary": TYPE_BINARY,
	"int":    TYPE_INT64,
	"uint":   TYPE_UINT64,
	"float":  TYPE_FLOAT64,
	"bool":   TYPE_BOOLEAN,
	"time":   TYPE_TIME,
	"array":  TYPE_ARRAY,
	"map":    TYPE_MAP,
	"any":    TYPE_ANY,
}

Functions

func Unmarshal

func Unmarshal(data map[string]interface{}, s *Schema) error

func UnmarshalDefinition

func UnmarshalDefinition(data interface{}, d *Definition) error

func UnmarshalJSON

func UnmarshalJSON(source []byte, s *Schema) error

Types

type Context

type Context struct {
	// contains filtered or unexported fields
}

func NewContext

func NewContext() *Context

func (*Context) IsReady

func (ctx *Context) IsReady() bool

func (*Context) PreloadScript

func (ctx *Context) PreloadScript(p *goja.Program) error

type Definition

type Definition struct {
	Definition *Schema
	Type       ValueType
	Subtype    ValueType
	Info       interface{}
	NotNull    bool
}

func NewDefinition

func NewDefinition(t ValueType) *Definition

type RawDefinition

type RawDefinition struct {
	Type    string                 `mapstructure:"type"`
	Subtype string                 `mapstructure:"subtype"`
	Fields  map[string]interface{} `mapstructure:"fields"`
	NotNull bool                   `mapstructure:"notNull"`
}

type Record

type Record struct {
	// contains filtered or unexported fields
}

func NewRecord

func NewRecord(schema *Schema, raw map[string]interface{}) *Record

func (*Record) GetValue

func (r *Record) GetValue(valuePath string) *Value

type Schema

type Schema struct {
	Fields map[string]*Definition
	Mutex  sync.RWMutex
}

func NewSchema

func NewSchema() *Schema

func (*Schema) GetDefinition

func (s *Schema) GetDefinition(valuePath string) *Definition

func (*Schema) Normalize

func (s *Schema) Normalize(data map[string]interface{}) map[string]interface{}

func (*Schema) Scan

func (s *Schema) Scan(data map[string]interface{}) *Record

type Schemer

type Schemer struct {
	// contains filtered or unexported fields
}

func NewSchemer

func NewSchemer() *Schemer

type Transformer

type Transformer struct {
	// contains filtered or unexported fields
}

func NewTransformer

func NewTransformer(source *Schema, dest *Schema) *Transformer

func (*Transformer) GetDestinationSchema

func (t *Transformer) GetDestinationSchema() *Schema

func (*Transformer) GetSourceSchema

func (t *Transformer) GetSourceSchema() *Schema

func (*Transformer) SetDestinationSchema

func (t *Transformer) SetDestinationSchema(schema *Schema)

func (*Transformer) SetScript

func (t *Transformer) SetScript(script string) error

func (*Transformer) SetSourceSchema

func (t *Transformer) SetSourceSchema(schema *Schema)

func (*Transformer) Transform

func (t *Transformer) Transform(env map[string]interface{}, input map[string]interface{}) ([]map[string]interface{}, error)

type Value

type Value struct {
	Definition *Definition
	Data       interface{}
}

func NewValue

func NewValue(def *Definition) *Value

type ValueType

type ValueType int32

const (
	TYPE_BOOLEAN ValueType = 0
	TYPE_BINARY  ValueType = 1
	TYPE_STRING  ValueType = 2
	TYPE_UINT64  ValueType = 3
	TYPE_INT64   ValueType = 4
	TYPE_FLOAT64 ValueType = 5
	TYPE_ARRAY   ValueType = 6
	TYPE_MAP     ValueType = 7
	TYPE_TIME    ValueType = 8
	TYPE_NULL    ValueType = 9
	TYPE_ANY     ValueType = 10
)