streaming

Documentation

Index

• type MapReader
• type MapStream
  • func NewNopMapStream() MapStream
  • func NewSimpleProjectionMapStream(projection map[string]string, staticStore map[string]interface{}) MapStream
  • func NewStandardMapStream() MapStream
• type MapWriter
• type NopMapStream
  • func (ss *NopMapStream) Read() ([]map[string]interface{}, error)
  • func (ss *NopMapStream) Write(input []map[string]interface{}) error
• type SimpleProjectionMapStream
  • func (ss *SimpleProjectionMapStream) Read() ([]map[string]interface{}, error)
  • func (ss *SimpleProjectionMapStream) Write(input []map[string]interface{}) error
• type StackQLReadWriter
• type StackQLReader
• type StackQLWriter
• type StandardMapStream
  • func (ss *StandardMapStream) Read() ([]map[string]interface{}, error)
  • func (ss *StandardMapStream) Write(input []map[string]interface{}) error

Types

type MapReader

type MapReader interface {
	StackQLReader
	Read() ([]map[string]interface{}, error)
}

type MapStream

type MapStream interface {
	MapReader
	MapWriter
}

func NewNopMapStream

func NewNopMapStream() MapStream

func NewSimpleProjectionMapStream

func NewSimpleProjectionMapStream(projection map[string]string, staticStore map[string]interface{}) MapStream

func NewStandardMapStream

func NewStandardMapStream() MapStream

type MapWriter

type MapWriter interface {
	StackQLWriter
	Write([]map[string]interface{}) error
}

type NopMapStream

type NopMapStream struct {
}

func (*NopMapStream) Read

func (ss *NopMapStream) Read() ([]map[string]interface{}, error)

func (*NopMapStream) Write

func (ss *NopMapStream) Write(input []map[string]interface{}) error

type SimpleProjectionMapStream

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

func (*SimpleProjectionMapStream) Read

func (ss *SimpleProjectionMapStream) Read() ([]map[string]interface{}, error)

func (*SimpleProjectionMapStream) Write

func (ss *SimpleProjectionMapStream) Write(input []map[string]interface{}) error

type StackQLReadWriter

type StackQLReadWriter interface {
	StackQLReader
	StackQLWriter
}

type StackQLReader

type StackQLReader interface{}

type StackQLWriter

type StackQLWriter interface{}

type StandardMapStream

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

func (*StandardMapStream) Read

func (ss *StandardMapStream) Read() ([]map[string]interface{}, error)

func (*StandardMapStream) Write

func (ss *StandardMapStream) Write(input []map[string]interface{}) error