json

Documentation

Index

• type KaminoJSONLoader
  • func NewLoader(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoJSONLoader, error)
  • func (jl *KaminoJSONLoader) Close(log *logrus.Entry) error
  • func (jl *KaminoJSONLoader) Load(log *logrus.Entry) (types.Record, error)
  • func (jl *KaminoJSONLoader) Name() string
  • func (jl *KaminoJSONLoader) Next() bool
• type KaminoJSONSaver
  • func NewSaver(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoJSONSaver, error)
  • func (js *KaminoJSONSaver) Close(log *logrus.Entry) error
  • func (js *KaminoJSONSaver) Name() string
  • func (js *KaminoJSONSaver) Reset(log *logrus.Entry) error
  • func (js *KaminoJSONSaver) Save(log *logrus.Entry, record types.Record) error

Types

type KaminoJSONLoader

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

KaminoJSONLoader specifc state for database Saver provider.

func NewLoader

func NewLoader(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoJSONLoader, error)

NewLoader open the encoding process on provider file, read the whole file, unMarshal it and return a Loader compatible object.

func (*KaminoJSONLoader) Close

func (jl *KaminoJSONLoader) Close(log *logrus.Entry) error

Close closes the datasource.

func (*KaminoJSONLoader) Load

func (jl *KaminoJSONLoader) Load(log *logrus.Entry) (types.Record, error)

Load reads the next record and return it.

func (*KaminoJSONLoader) Name

func (jl *KaminoJSONLoader) Name() string

Name give the name of the destination.

func (*KaminoJSONLoader) Next

func (jl *KaminoJSONLoader) Next() bool

Next moves to next record and return false if there is no more records.

type KaminoJSONSaver

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

KaminoJSONSaver specifc state for database Saver provider.

func NewSaver

func NewSaver(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoJSONSaver, error)

NewSaver open the encoding process on provider file and return a Saver compatible object.

func (*KaminoJSONSaver) Close

func (js *KaminoJSONSaver) Close(log *logrus.Entry) error

Close closes the destination.

func (*KaminoJSONSaver) Name

func (js *KaminoJSONSaver) Name() string

Name give the name of the destination.

func (*KaminoJSONSaver) Reset

func (js *KaminoJSONSaver) Reset(log *logrus.Entry) error

Reset reinitialize the destination (if possible).

func (*KaminoJSONSaver) Save

func (js *KaminoJSONSaver) Save(log *logrus.Entry, record types.Record) error

Save writes the record to the destination.