Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StreamParseOutput ¶
func StreamParseOutput(stdout io.ReadCloser, consumer PortionConsumer) error
Types ¶
type OutputRepresentation ¶
type OutputRepresentation struct { State interface{} //[tableName] - {} Streams map[string]*StreamRepresentation }
func ParseOutput ¶
func ParseOutput(stdout io.ReadCloser) (*OutputRepresentation, error)
type PortionConsumer ¶
type PortionConsumer interface {
Consume(representation *OutputRepresentation) error
}
type SchemaRecord ¶
type StreamRepresentation ¶
type StreamRepresentation struct { BatchHeader *schema.BatchHeader KeyFields []string Objects []map[string]interface{} }
Click to show internal directories.
Click to hide internal directories.