simplestream

type BasicProcessor struct {
	Source
	Destination
}

type CsvSource struct {
	Reader    *csv.Reader
	RowDecode func(row []string, p interface{}) error
}

type Destination interface {
	Put(p interface{}) error
}

type DynamoDBDestination struct {
	DB        *dynamodb.DynamoDB
	TableName string
}

type ErrorDestination struct {
	Output error
}

type ErrorSource struct {
	Output error
}

type ErrorTransformer struct{}

type FilterProcessor struct {
	Source
	FilterConditionFunc func(input interface{}) bool
	Destination
}

type IdentityTransformer struct {
	Transformers []Transformer
}

type Json struct {
	io.Reader
	io.Writer
}

type MultiTransformer struct {
	Transformers []Transformer
}

type NoMoreSourceError struct {
}

type Processor interface {
	Process(input interface{})
}

type Source interface {
	Fetch(p interface{}) error
}

type StringDestination struct {
	Output *string
}

type StringSource struct {
	Output string
}

type TransformProcessor struct {
	Source
	Transformer
	Destination
}

type Transformer interface {
	Transform(input interface{}) (interface{}, error)
}