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
- type Definition
- type RawDefinition
- type Record
- type Schema
- type Schemer
- type 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
- type ValueType
Constants ¶
This section is empty.
Variables ¶
View Source
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 UnmarshalDefinition ¶
func UnmarshalDefinition(data interface{}, d *Definition) error
func UnmarshalJSON ¶ added in v0.0.4
Types ¶
type Context ¶
type Context struct {
// contains filtered or unexported fields
}
func NewContext ¶
func NewContext() *Context
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 Schema ¶
type Schema struct { Fields map[string]*Definition Mutex sync.RWMutex }
func (*Schema) GetDefinition ¶
func (s *Schema) GetDefinition(valuePath string) *Definition
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 ¶ added in v0.0.10
func (t *Transformer) GetDestinationSchema() *Schema
func (*Transformer) GetSourceSchema ¶ added in v0.0.10
func (t *Transformer) GetSourceSchema() *Schema
func (*Transformer) SetDestinationSchema ¶ added in v0.0.4
func (t *Transformer) SetDestinationSchema(schema *Schema)
func (*Transformer) SetScript ¶
func (t *Transformer) SetScript(script string) error
func (*Transformer) SetSourceSchema ¶ added in v0.0.4
func (t *Transformer) SetSourceSchema(schema *Schema)
type Value ¶
type Value struct { Definition *Definition Data interface{} }
func NewValue ¶
func NewValue(def *Definition) *Value
Source Files ¶
Click to show internal directories.
Click to hide internal directories.