pkg

Mar 17, 2021

Changes in this version

+ var ErrShouldDrop = errors.New("unprocessed message")

+ type ConsumerWorker interface

+ Consume func(context.Context, []byte) error

+ type MQConsumer struct

+ func NewConsumer(ctx context.Context, worker ConsumerWorker, config *MqConfig) *MQConsumer

+ func (c *MQConsumer) Start()

+ func (c *MQConsumer) Stop()

+ type MqConfig struct

+ Addr string

+ ConsumerTag string

+ Exchange string

+ ExchangeType string

+ Queue string

+ RoutingKey string

+ type MqProducer struct

+ func NewMqProducer(config *MqConfig) (*MqProducer, error)

+ func (mq *MqProducer) Destroy()

+ func (mq *MqProducer) Publish(msg interface{}) (err error)

Mar 15, 2021

Changes in this version

+ type ES struct

+ func NewES(debug bool, hosts ...string) (*ES, error)

+ func (es *ES) BulkProcess(ctx context.Context, ch <-chan ESDoc, batch, worker int) (err error)

+ func (es *ES) Client() *elastic.Client

+ type ESDoc interface

+ ID func() string

+ Index func() string

Mar 15, 2021

Changes in this version

+ func WithSampleLog() zerolog.Logger

+ type DB struct

+ func NewDB(debug bool, dsn string) (*DB, error)

+ func NewDBWithMockForTest(debug bool, conn *sql.DB) (*DB, error)

+ func (db *DB) GetDriver() *gorm.DB

+ func (db *DB) QueryMore(sql string, args ...interface{}) (*sql.Rows, error)

+ func (db *DB) QueryOne(dest interface{}, sql string, args ...interface{}) error

+ func (db *DB) ScanRows(rows *sql.Rows, dest interface{}) error

Mar 12, 2021

Changes in this version

+ var ErrorNilInput = newE("parse of nil")

+ var ErrorNonPointer = newE("parse of non-pointer")

+ var ErrorNonStruct = newE("parse of non-struct ptr")

+ func GetLogger() zerolog.Logger

+ func InitLogger(debug bool)

+ func MapConfig(dest interface{}) error

+ func MustMapConfig(dest interface{}) error

+ func WithLoggerLevel(level zerolog.Level) zerolog.Logger

+ type ConfigError struct

+ func (c ConfigError) Error() string