extractors

Documentation

Index

• type DbExtractor
• type Extractor
• type MongoExtractor
  • func NewMongoExtractor(db *libdb.MongoDB, proto proto.Message) *MongoExtractor
  • func (ex *MongoExtractor) Done()
  • func (ex *MongoExtractor) Get() (time.Time, proto.Message, error)
  • func (ex *MongoExtractor) Next() bool
  • func (ex *MongoExtractor) SetDebug(debug bool)
  • func (ex *MongoExtractor) StartQuery(collectionName string, IDFieldName string, query *ReplayQuery) error
• type PostgresExtractor
  • func NewPostgresExtractor(db *libdb.PostgresDB, extractor DbExtractor) *PostgresExtractor
  • func (ex *PostgresExtractor) Done()
  • func (ex *PostgresExtractor) Get() (time.Time, proto.Message, error)
  • func (ex *PostgresExtractor) Next() bool
  • func (ex *PostgresExtractor) SetDebug(debug bool)
  • func (ex *PostgresExtractor) StartQuery(tableName string, IDFieldName string, query *ReplayQuery) error
• type ReplayQuery

Types

type DbExtractor

type DbExtractor interface {
	GetAll(*sql.Rows, *gorm.DB) (time.Time, proto.Message, error)
	GetInstance() interface{}
}

DbExtractor ...

type Extractor

type Extractor interface {
	Get() (time.Time, proto.Message, error)
	StartQuery(sourceName string, IDFieldName string, query *ReplayQuery) error
	Next() bool
	Done()
	SetDebug(bool)
}

Extractor ...

type MongoExtractor

type MongoExtractor struct {
	Proto proto.Message
	DB    *libdb.MongoDB

	IDFieldName string
	// contains filtered or unexported fields
}

MongoExtractor ...

func NewMongoExtractor

func NewMongoExtractor(db *libdb.MongoDB, proto proto.Message) *MongoExtractor

NewMongoExtractor ...

func (*MongoExtractor) Done

func (ex *MongoExtractor) Done()

Done ...

func (*MongoExtractor) Get

func (ex *MongoExtractor) Get() (time.Time, proto.Message, error)

Get ...

func (*MongoExtractor) Next

func (ex *MongoExtractor) Next() bool

Next ...

func (*MongoExtractor) SetDebug

func (ex *MongoExtractor) SetDebug(debug bool)

SetDebug ...

func (*MongoExtractor) StartQuery

func (ex *MongoExtractor) StartQuery(collectionName string, IDFieldName string, query *ReplayQuery) error

StartQuery ...

type PostgresExtractor

type PostgresExtractor struct {
	Extractor DbExtractor
	DB        *libdb.PostgresDB

	IDFieldName string
	// contains filtered or unexported fields
}

PostgresExtractor ...

func NewPostgresExtractor

func NewPostgresExtractor(db *libdb.PostgresDB, extractor DbExtractor) *PostgresExtractor

NewPostgresExtractor ...

func (*PostgresExtractor) Done

func (ex *PostgresExtractor) Done()

Done ...

func (*PostgresExtractor) Get

func (ex *PostgresExtractor) Get() (time.Time, proto.Message, error)

Get ...

func (*PostgresExtractor) Next

func (ex *PostgresExtractor) Next() bool

Next ...

func (*PostgresExtractor) SetDebug

func (ex *PostgresExtractor) SetDebug(debug bool)

SetDebug ...

func (*PostgresExtractor) StartQuery

func (ex *PostgresExtractor) StartQuery(tableName string, IDFieldName string, query *ReplayQuery) error

StartQuery ...

type ReplayQuery

type ReplayQuery struct {
	IncludeIds *[]string
	Timerange  *pb.Timerange
	SortColumn string
	Limit      *int
	Offset     int
}

ReplayQuery ...