Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OutWriterProcessor ¶
Types ¶
type AwsLsOutWriter ¶
type AwsLsOutWriter struct {
// contains filtered or unexported fields
}
type DynamoOutWriter ¶
type DynamoOutWriter struct {
// contains filtered or unexported fields
}
type MjsonOutWriter ¶
type MjsonOutWriter struct {
// contains filtered or unexported fields
}
type ParquetOutWriter ¶
type ParquetOutWriter struct {
// contains filtered or unexported fields
}
type S3DeleteOutWriter ¶
type S3DeleteOutWriter struct {
// contains filtered or unexported fields
}
type SqlLiteOutWriter ¶
type SqlLiteOutWriter struct {
// contains filtered or unexported fields
}
type SqsOutWriter ¶
type SqsOutWriter struct {
// contains filtered or unexported fields
}
func (*SqsOutWriter) BufferJsonSize ¶
func (sow *SqsOutWriter) BufferJsonSize(receive rxgo.Observable, opts ...rxgo.Option) rxgo.Observable
Source Files
Click to show internal directories.
Click to hide internal directories.