util

Documentation

Index

• Constants
• func CoerceNumber(v interface{}) (float64, error)
• func ConnectToReader(operator SumoOperator, reader io.Reader)
• func ConnectToStdIn(operator SumoOperator)
• func CreateEndRelation() map[string]interface{}
• func CreateMeta(inp map[string]interface{}) map[string]interface{}
• func CreateRelation(inp map[string]interface{}) map[string]interface{}
• func CreateStartRelation() map[string]interface{}
• func CreateStartRelationMeta(origin string) map[string]interface{}
• func ExtractRaw(inp map[string]interface{}) string
• func IsEndRelation(inp map[string]interface{}) bool
• func IsMeta(inp map[string]interface{}) bool
• func IsPlus(inp map[string]interface{}) bool
• func IsRelation(inp map[string]interface{}) bool
• func IsStartRelation(inp map[string]interface{}) bool
• func SortByField(field string, data Datum)
• type By
• type Datum
• type JsonWriter
  • func NewJsonWriter() *JsonWriter
  • func (writer *JsonWriter) Write(inp map[string]interface{})
• type ParseError
  • func (e ParseError) Error() string
• type RawInputHandler
  • func NewRawInputHandler(inp io.Writer) *RawInputHandler
  • func (handler *RawInputHandler) Flush()
  • func (handler *RawInputHandler) Process(inp []byte)
• type SumoAggOperator
• type SumoOperator

Constants

const EndRelation = "EndRelation"

const Meta = "Meta"

const Plus = "PLUS"

const Raw = "_raw"

const Relation = "Relation"

const StartRelation = "StartRelation"

const Type = "_type"

Functions

func CoerceNumber

func CoerceNumber(v interface{}) (float64, error)

func ConnectToReader

func ConnectToReader(operator SumoOperator, reader io.Reader)

func ConnectToStdIn

func ConnectToStdIn(operator SumoOperator)

func CreateEndRelation

func CreateEndRelation() map[string]interface{}

func CreateMeta

func CreateMeta(inp map[string]interface{}) map[string]interface{}

func CreateRelation

func CreateRelation(inp map[string]interface{}) map[string]interface{}

func CreateStartRelation

func CreateStartRelation() map[string]interface{}

func CreateStartRelationMeta

func CreateStartRelationMeta(origin string) map[string]interface{}

func ExtractRaw

func ExtractRaw(inp map[string]interface{}) string

func IsEndRelation

func IsEndRelation(inp map[string]interface{}) bool

func IsMeta

func IsMeta(inp map[string]interface{}) bool

func IsPlus

func IsPlus(inp map[string]interface{}) bool

func IsRelation

func IsRelation(inp map[string]interface{}) bool

func IsStartRelation

func IsStartRelation(inp map[string]interface{}) bool

func SortByField

func SortByField(field string, data Datum)

Types

type By

type By func(p1, p2 *map[string]interface{}) bool

type Datum

type Datum []map[string]interface{}

type JsonWriter

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

func NewJsonWriter

func NewJsonWriter() *JsonWriter

func (*JsonWriter) Write

func (writer *JsonWriter) Write(inp map[string]interface{})

type ParseError

type ParseError string

func (ParseError) Error

func (e ParseError) Error() string

type RawInputHandler

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

func NewRawInputHandler

func NewRawInputHandler(inp io.Writer) *RawInputHandler

func (*RawInputHandler) Flush

func (handler *RawInputHandler) Flush()

func (*RawInputHandler) Process

func (handler *RawInputHandler) Process(inp []byte)

type SumoAggOperator

type SumoAggOperator interface {
	Process(map[string]interface{})
	Flush()
}

type SumoOperator

type SumoOperator interface {
	Process(map[string]interface{})
}