dummy.go

package pumps

import (
	"context"

	"github.com/TykTechnologies/logrus"
)

type DummyPump struct {
	timeout int
}

var dummyPrefix = "dummy-pump"

func (p *DummyPump) New() Pump {
	newPump := DummyPump{}
	return &newPump
}

func (p *DummyPump) GetName() string {
	return "Dummy Pump"
}

func (p *DummyPump) Init(conf interface{}) error {
	log.WithFields(logrus.Fields{
		"prefix": dummyPrefix,
	}).Debug("Dummy Initialized")
	return nil
}

func (p *DummyPump) WriteData(ctx context.Context, data []interface{}) error {
	log.WithFields(logrus.Fields{
		"prefix": dummyPrefix,
	}).Info("Writing ", len(data), " records")
	return nil
}

func (p *DummyPump) SetTimeout(timeout int) {
	p.timeout = timeout
}

func (p *DummyPump) GetTimeout() int {
	return p.timeout
}