go_embulk

README

Go-Embulk

Implementation Embulk in Go.

Usage

package main

import (
	"bytes"
	"io"
	"log"
	"os"

	"github.com/garupanojisan/go-embulk"
)

func main() {
	g := &go_embulk.GoEmbulk{
		Input: bytes.NewBufferString("hello go-embulk"),
		Outputs: []io.Writer{
			os.Stdout,
		},
	}

	if err := g.Run(); err != nil {
		log.Fatal(err)
	}
}

Input

Input struct should implements io.Reader.

For example,

type ExampleInput struct {
}

func (s *ExampleInput) Read(p []byte) error {
    // do something (e.g. initialization, authentication, etc...)
    
    // set data into p

    // do something
}

Output

Output struct should implements io.Writer.

type ExampleOutput struct {
}

func (s *ExampleOutput) Write(data []byte) (int, error) {
    // do something (e.g. initialization, authentication, etc...)
    
    // write data

    // do something
}

Documentation

Index

• Constants
• type GoEmbulk
  • func (g *GoEmbulk) Run() error
• type Input
• type Output

Constants

const MinRead int = 512

Types

type GoEmbulk

type GoEmbulk struct {
	Input   Input
	Outputs []Output
}

func (*GoEmbulk) Run

func (g *GoEmbulk) Run() error

type Input

type Input interface {
	io.Reader
	Init() error
	Finalize() error
}

type Output

type Output interface {
	io.Writer
	Init() error
	Finalize() error
}