inputfile

Documentation

Index

• type FileFormat
• type InputFileClient
  • func NewInputFileClient(conf InputFileClientConfig) InputFileClient
  • func (client InputFileClient) Connect(ctx context.Context, writer gallon.WriteCloser) error
• type InputFileClientConfig

Types

type FileFormat

type FileFormat string

const (
	Jsonl FileFormat = "jsonl"
)

type InputFileClient

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

func NewInputFileClient

func NewInputFileClient(conf InputFileClientConfig) InputFileClient

func (InputFileClient) Connect

func (client InputFileClient) Connect(
	ctx context.Context,
	writer gallon.WriteCloser,
) error

type InputFileClientConfig

type InputFileClientConfig struct {
	FilePath   string
	FileFormat FileFormat
	Decoder    func([]byte) (gallon.Record, error)
}