gallon

package

v0.0.0-...-3b9cb7e Latest Latest Go to latest Published: May 3, 2022 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewGallon(
	input InputPlugin,
	output OutputPlugin,
) Gallon

func (g Gallon) Run() error

type InputPlugin interface {
	Connect(
		ctx context.Context,
		writer WriteCloser,
	) error
}

type OutputPlugin interface {
	Connect(
		ctx context.Context,
		reader Reader,
	) error
}

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

func NewPipe() Pipe

func (w Pipe) Close() error

func (r Pipe) Read(record *Record) error

func (w Pipe) Write(record Record) error

type Reader interface {
	Read(record *Record) error
}

type Record []interface{}

type WriteCloser interface {
	Write(record Record) error
	Close() error
}