event.go

// Code generated by github.com/actgardner/gogen-avro. DO NOT EDIT.
/*
 * SOURCE:
 *     union.avsc
 */
package avro

import (
	"io"
	
	"github.com/actgardner/gogen-avro/vm/types"
	"github.com/actgardner/gogen-avro/vm"
	"github.com/actgardner/gogen-avro/compiler"
)

  
type Event struct { 
	// Unique ID for this event.
	
		Id string
	

	// Start IP of this observation's IP range.
	
		Start_ip Ip_address
	

	// End IP of this observation's IP range.
	
		End_ip Ip_address
	

}

func DeserializeEvent(r io.Reader) (t Event, err error) {
	deser, err := compiler.CompileSchemaBytes([]byte(t.Schema()), []byte(t.Schema()))
	if err == nil {
		err = vm.Eval(r, deser, &t)
	}
	return
}

func DeserializeEventFromSchema(r io.Reader, schema string) (t Event, err error) {
	deser, err := compiler.CompileSchemaBytes([]byte(schema), []byte(t.Schema()))
	if err == nil {
		err = vm.Eval(r, deser, &t)
	}
	return
}

func writeEvent(r Event, w io.Writer) error {
	var err error
	
	err = vm.WriteString( r.Id, w)
	if err != nil {
		return err			
	}
	
	err = writeIp_address( r.Start_ip, w)
	if err != nil {
		return err			
	}
	
	err = writeIp_address( r.End_ip, w)
	if err != nil {
		return err			
	}
	
	return err
}

func (r Event) Serialize(w io.Writer) error {
	return writeEvent(r, w)
}

func (r Event) Schema() string {
	return "{\"fields\":[{\"doc\":\"Unique ID for this event.\",\"metadata\":{\"key\":\"field1\"},\"name\":\"id\",\"type\":\"string\"},{\"doc\":\"Start IP of this observation's IP range.\",\"metadata\":{\"key\":\"field2\"},\"name\":\"start_ip\",\"type\":{\"key\":\"value\",\"metadata\":{\"a\":\"b\",\"c\":123},\"name\":\"ip_address\",\"size\":16,\"type\":\"fixed\"}},{\"doc\":\"End IP of this observation's IP range.\",\"metadata\":{\"key\":\"field3\"},\"name\":\"end_ip\",\"type\":\"ip_address\"}],\"metadata\":{\"key\":\"value\"},\"name\":\"event\",\"subject\":\"event\",\"type\":\"record\"}"
}

func (r Event) SchemaName() string {
	return "event"
}

func (_ *Event) SetBoolean(v bool) { panic("Unsupported operation") }
func (_ *Event) SetInt(v int32) { panic("Unsupported operation") }
func (_ *Event) SetLong(v int64) { panic("Unsupported operation") }
func (_ *Event) SetFloat(v float32) { panic("Unsupported operation") }
func (_ *Event) SetDouble(v float64) { panic("Unsupported operation") }
func (_ *Event) SetBytes(v []byte) { panic("Unsupported operation") }
func (_ *Event) SetString(v string) { panic("Unsupported operation") }
func (_ *Event) SetUnionElem(v int64) { panic("Unsupported operation") }

func (r *Event) Get(i int) types.Field {
	switch (i) {
	
	case 0:
		
		
			return (*types.String)(&r.Id)
		
	
	case 1:
		
		
			return &r.Start_ip
		
	
	case 2:
		
		
			return &r.End_ip
		
	
	default:
		panic("Unknown field index")
	}
}

func (r *Event) SetDefault(i int) {
	switch (i) { 
	default:
		panic("Unknown field index")
	}
}

func (r *Event) Clear(i int) {
	switch (i) { 
	default:
		panic("Non-optional field index")
	}
}

func (_ *Event) AppendMap(key string) types.Field { panic("Unsupported operation") }
func (_ *Event) AppendArray() types.Field { panic("Unsupported operation") }
func (_ *Event) Finalize() { }