yaml

Documentation

Index

• type KaminoYAMLLoader
  • func NewLoader(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoYAMLLoader, error)
  • func (yl *KaminoYAMLLoader) Close(log *logrus.Entry) error
  • func (yl *KaminoYAMLLoader) Load(log *logrus.Entry) (types.Record, error)
  • func (yl *KaminoYAMLLoader) Name() string
  • func (yl *KaminoYAMLLoader) Next() bool
• type KaminoYAMLSaver
  • func NewSaver(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoYAMLSaver, error)
  • func (ys *KaminoYAMLSaver) Close(log *logrus.Entry) error
  • func (ys *KaminoYAMLSaver) Name() string
  • func (ys *KaminoYAMLSaver) Reset(log *logrus.Entry) error
  • func (ys *KaminoYAMLSaver) Save(log *logrus.Entry, record types.Record) error

Types

type KaminoYAMLLoader

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

KaminoYAMLLoader specifc state for database Saver provider.

func NewLoader

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

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

func (*KaminoYAMLLoader) Close

func (yl *KaminoYAMLLoader) Close(log *logrus.Entry) error

Close closes the datasource.

func (*KaminoYAMLLoader) Load

func (yl *KaminoYAMLLoader) Load(log *logrus.Entry) (types.Record, error)

Load reads the next record and return it.

func (*KaminoYAMLLoader) Name

func (yl *KaminoYAMLLoader) Name() string

Name give the name of the destination.

func (*KaminoYAMLLoader) Next

func (yl *KaminoYAMLLoader) Next() bool

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

type KaminoYAMLSaver

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

KaminoYAMLSaver specifc state for database Saver provider.

func NewSaver

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

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

func (*KaminoYAMLSaver) Close

func (ys *KaminoYAMLSaver) Close(log *logrus.Entry) error

Close closes the destination.

func (*KaminoYAMLSaver) Name

func (ys *KaminoYAMLSaver) Name() string

Name give the name of the destination.

func (*KaminoYAMLSaver) Reset

func (ys *KaminoYAMLSaver) Reset(log *logrus.Entry) error

Reset reinitialize the destination (if possible).

func (*KaminoYAMLSaver) Save

func (ys *KaminoYAMLSaver) Save(log *logrus.Entry, record types.Record) error

Save writes the record to the destination.