Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) 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.
Click to show internal directories.
Click to hide internal directories.