readers

Documentation

Index

• type DefaultReader
  • func NewDefaultReader() *DefaultReader
  • func (r *DefaultReader) AppendHook(h Hook) *DefaultReader
  • func (r *DefaultReader) Read(path string) (map[string]int, error)
• type FastReader
  • func NewFastReader() *FastReader
  • func (r *FastReader) AppendHook(h Hook) *FastReader
  • func (r *FastReader) Read(path string) (map[string]int, error)
  • func (r *FastReader) SetChunckSize(sz int) *FastReader
• type Hook
  • func NewPostgreSQLHook(connection string) (Hook, error)
• type PostgreSQLHook
  • func (h *PostgreSQLHook) Run(token string)
• type Reader

Types

type DefaultReader

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

func NewDefaultReader

func NewDefaultReader() *DefaultReader

func (*DefaultReader) AppendHook

func (r *DefaultReader) AppendHook(h Hook) *DefaultReader

func (*DefaultReader) Read

func (r *DefaultReader) Read(path string) (map[string]int, error)

type FastReader

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

func NewFastReader

func NewFastReader() *FastReader

func (*FastReader) AppendHook

func (r *FastReader) AppendHook(h Hook) *FastReader

func (*FastReader) Read

func (r *FastReader) Read(path string) (map[string]int, error)

func (*FastReader) SetChunckSize

func (r *FastReader) SetChunckSize(sz int) *FastReader

type Hook

type Hook interface {
	Run(token string)
}

func NewPostgreSQLHook

func NewPostgreSQLHook(connection string) (Hook, error)

type PostgreSQLHook

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

func (*PostgreSQLHook) Run

func (h *PostgreSQLHook) Run(token string)

type Reader

type Reader interface {
	Read(path string) (map[string]int, error)
}