drivers

package
v0.0.26 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 4, 2022 License: MIT Imports: 13 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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"
	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")
)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL