loader

type Handler ¶

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

Handler loads promotions from a source file into a data storage

func NewLoader(
	cfg *config.Config, ctx context.Context, swp WriterProvider, src Source, lc Lifecycle,
) *Handler

func (p *Handler) Load() (int64, error)

type Lifecycle ¶

type Lifecycle interface {
	OnFinish(filename string) error
}

Lifecycle exposes hooks to load process

func NewLifecycle() Lifecycle

type Source ¶

type Source interface {
	File(filename string) (*os.File, error)
}

Source abstracts promotions file source loading

func NewSource() Source

type Streamer ¶

type Streamer interface {
	Stream(w io.Writer, chunk []string) error
}

Streamer handles promotions file data chunks

func NewStreamer() Streamer

type Writer ¶

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

func (rw *Writer) Close() error

func (rw *Writer) Write(chunk []byte) (int, error)

type WriterProvider ¶

type WriterProvider func() (io.WriteCloser, error)

func RedisWriterFn(cfg *config.Config) WriterProvider