zipcsv

Documentation

Index

• Variables
• type Config
• type Option
  • func WithColumns(columns []string) Option
  • func WithKeepDownload(keep bool) Option
• type Processor
  • func New(db *sqlx.DB, stepsService StepsService, config Config, opts ...Option) *Processor
  • func (p *Processor) Run(ctx context.Context) error
• type StepsService

Variables

var ErrUnexpectedStatusCode = errors.New("unexpected status code")

Types

type Config

type Config struct {
	Name  string
	Step  string
	Table string
	URL   string
}

type Option

type Option func(*Processor)

func WithColumns

func WithColumns(columns []string) Option

func WithKeepDownload

func WithKeepDownload(keep bool) Option

type Processor

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

func New

func New(db *sqlx.DB, stepsService StepsService, config Config, opts ...Option) *Processor

func (*Processor) Run

func (p *Processor) Run(ctx context.Context) error

type StepsService

type StepsService interface {
	Execute(ctx context.Context, step string, fn func(context.Context) error) error
}