drivers

Documentation

Index

• type Driver
  • func GetDriver(name DriverName) Driver
• type DriverName

Types

type Driver

type Driver interface {
	LoadEnv(string) error
	LoadFlags() error
	Init() error
	GetWork() (io.Reader, error)
	ClearWork() error
	HandleFailure() error
	Cleanup() error
}

Driver is the interface that must be implemented by a driver.

func GetDriver

func GetDriver(name DriverName) Driver

GetDriver returns the driver with the given name.

type DriverName

type DriverName string

DriverName is the unique name of a driver.

var (
	DriverAWSS3             DriverName = "aws-s3"
	DriverAWSSQS            DriverName = "aws-sqs"
	DriverAWSDynamoDB       DriverName = "aws-dynamo"
	DriverCassandraDB       DriverName = "cassandra"
	DriverCentauriNet       DriverName = "centauri"
	DriverGCPBQ             DriverName = "gcp-bq"
	DriverGCPGCS            DriverName = "gcp-gcs"
	DriverGCPPubSub         DriverName = "gcp-pubsub"
	DriverPostgres          DriverName = "postgres"
	DriverMongoDB           DriverName = "mongodb"
	DriverMySQL             DriverName = "mysql"
	DriverNFS               DriverName = "nfs"
	DriverRabbit            DriverName = "rabbitmq"
	DriverRedisSubscription DriverName = "redis-pubsub"
	DriverRedisList         DriverName = "redis-list"
	DriverLocal             DriverName = "local"
	ErrDriverNotFound                  = errors.New("driver not found")
)