destination

Documentation

Index

• type Config
• type Destination
  • func NewDestination[E storage.Entry](config *Config, dst Destinationer[E], b database.BuildDb) (*Destination[E], error)
  • func NewInsertSliceMap(config *Config, b database.BuildDb) (*Destination[storage.MapEntry], error)
  • func NewInsertSliceSlice(config *Config, fields []string, b database.BuildDb) (*Destination[storage.SliceEntry], error)
  • func NewUpdateSliceMap(config *Config, idName string, b database.BuildDb) (*Destination[storage.MapEntry], error)
  • func (d *Destination[E]) Accept() (err error)
  • func (d *Destination[E]) Close() error
  • func (d *Destination[E]) DB() *database.DB
  • func (d *Destination[E]) Done()
  • func (d *Destination[E]) Finish()
  • func (d *Destination[E]) PageSize() int64
  • func (d *Destination[E]) Receive(items []E)
  • func (d *Destination[E]) State() []string
  • func (d *Destination[E]) Summary() []string
  • func (d *Destination[E]) TableName() string
  • func (d *Destination[E]) Title() string
• type Destinationer
• type InsertSliceMap
  • func (i *InsertSliceMap) Exec(d *Destination[storage.MapEntry], items storage.MapEntries) error
• type InsertSliceSlice
  • func (i *InsertSliceSlice) Exec(d *Destination[storage.SliceEntry], items storage.SliceEntries) error
• type UpdateSliceMap
  • func (u *UpdateSliceMap) Exec(d *Destination[storage.MapEntry], items storage.MapEntries) error

Types

type Config

type Config struct {
	IsTruncate  bool
	Concurrency int
	PageSize    int64
	TableName   string
}

type Destination

type Destination[E storage.Entry] struct {
	storage.Storage
	// contains filtered or unexported fields
}

func NewDestination

func NewDestination[E storage.Entry](config *Config, dst Destinationer[E], b database.BuildDb) (*Destination[E], error)

func NewInsertSliceMap

func NewInsertSliceMap(config *Config, b database.BuildDb) (*Destination[storage.MapEntry], error)

func NewInsertSliceSlice

func NewInsertSliceSlice(config *Config, fields []string, b database.BuildDb) (*Destination[storage.SliceEntry], error)

func NewUpdateSliceMap

func NewUpdateSliceMap(config *Config, idName string, b database.BuildDb) (*Destination[storage.MapEntry], error)

func (*Destination[E]) Accept

func (d *Destination[E]) Accept() (err error)

func (*Destination[E]) Close

func (d *Destination[E]) Close() error

func (*Destination[E]) DB

func (d *Destination[E]) DB() *database.DB

func (*Destination[E]) Done

func (d *Destination[E]) Done()

func (*Destination[E]) Finish

func (d *Destination[E]) Finish()

func (*Destination[E]) PageSize

func (d *Destination[E]) PageSize() int64

func (*Destination[E]) Receive

func (d *Destination[E]) Receive(items []E)

func (*Destination[E]) State

func (d *Destination[E]) State() []string

func (*Destination[E]) Summary

func (d *Destination[E]) Summary() []string

func (*Destination[E]) TableName

func (d *Destination[E]) TableName() string

func (*Destination[E]) Title

func (d *Destination[E]) Title() string

type Destinationer

type Destinationer[E storage.Entry] interface {
	Exec(d *Destination[E], items []E) error
}

type InsertSliceMap

type InsertSliceMap struct {
}

func (*InsertSliceMap) Exec

func (i *InsertSliceMap) Exec(d *Destination[storage.MapEntry], items storage.MapEntries) error

type InsertSliceSlice

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

func (*InsertSliceSlice) Exec

func (i *InsertSliceSlice) Exec(d *Destination[storage.SliceEntry], items storage.SliceEntries) error

type UpdateSliceMap

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

func (*UpdateSliceMap) Exec

func (u *UpdateSliceMap) Exec(d *Destination[storage.MapEntry], items storage.MapEntries) error