provider

Documentation

Index

• type KaminoProvider
  • func (p *KaminoProvider) NewLoader(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer, ...) (Loader, error)
  • func (p *KaminoProvider) NewSaver(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer, ...) (Saver, error)
• type Loader
• type Provider
• type Saver

Types

type KaminoProvider

type KaminoProvider struct{}

KaminoProvider implement the Provider interface with action on database and files.

func (*KaminoProvider) NewLoader

func (p *KaminoProvider) NewLoader(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer, table string, where string) (Loader, error)

NewLoader analyze the datasource and return object implementing Loader of the asked type.

func (*KaminoProvider) NewSaver

func (p *KaminoProvider) NewSaver(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer, table string, key string, mode string) (Saver, error)

NewSaver analyze the datasource and return object implementing Saver of the asked type.

type Loader

type Loader interface {
	Next() bool
	Load(*logrus.Entry) (types.Record, error)
	Close(*logrus.Entry) error
	Name() string
}

Loader provides way to load record by record.

type Provider

type Provider interface {
	NewLoader(context.Context, *logrus.Entry, datasource.Datasourcer, string, string) (Loader, error)
	NewSaver(context.Context, *logrus.Entry, datasource.Datasourcer, string, string, string) (Saver, error)
}

Provider provides Loader and Saver objects adapted to the datasource.

type Saver

type Saver interface {
	Save(*logrus.Entry, types.Record) error
	Close(*logrus.Entry) error
	Reset(*logrus.Entry) error
	Name() string
}

Saver provides way to save record by record.