jsonline

Documentation

Index

• func JSONToDictionary(jsonline []byte) (model.Dictionary, error)
• func JSONToPackedDictionary(jsonline []byte) (model.Dictionary, error)
• func NewPackedSource(file io.Reader) model.Source
• func NewSink(file io.Writer) model.SinkProcess
• func NewSinkWithContext(file io.Writer, counter string) model.SinkProcess
• func NewSource(file io.Reader) model.Source
• type Sink
  • func (s Sink) Open() error
  • func (s Sink) ProcessDictionary(dictionary model.Entry) error
• type Source
  • func (s *Source) Err() error
  • func (s *Source) Next() bool
  • func (s *Source) Open() error
  • func (s *Source) Value() model.Entry

Functions

func JSONToDictionary

func JSONToDictionary(jsonline []byte) (model.Dictionary, error)

JSONToDictionary return a model.Dictionary from a jsonline

func JSONToPackedDictionary

func JSONToPackedDictionary(jsonline []byte) (model.Dictionary, error)

JSONToPackedDictionary return a packed model.Dictionary from a jsonline

func NewPackedSource

func NewPackedSource(file io.Reader) model.Source

NewPackedSource creates a new packed Source.

func NewSink

func NewSink(file io.Writer) model.SinkProcess

NewSink creates a new Sink.

func NewSinkWithContext

func NewSinkWithContext(file io.Writer, counter string) model.SinkProcess

NewSinkWithContext creates a new Sink.

func NewSource

func NewSource(file io.Reader) model.Source

NewSource creates a new Source.

Types

type Sink

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

func (Sink) Open

func (s Sink) Open() error

func (Sink) ProcessDictionary

func (s Sink) ProcessDictionary(dictionary model.Entry) error

type Source

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

Source export line to JSON format.

func (*Source) Err

func (s *Source) Err() error

func (*Source) Next

func (s *Source) Next() bool

Next convert next line to model.Dictionary

func (*Source) Open

func (s *Source) Open() error

func (*Source) Value

func (s *Source) Value() model.Entry