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

Get returns the driver with the given name.

type DriverName

type DriverName string

var (
	ActiveMQ          DriverName = "activemq"
	AWSS3             DriverName = "aws-s3"
	AWSSQS            DriverName = "aws-sqs"
	AWSDynamoDB       DriverName = "aws-dynamo"
	CassandraDB       DriverName = "cassandra"
	Centauri          DriverName = "centauri"
	Elasticsearch     DriverName = "elasticsearch"
	HTTP              DriverName = "http"
	Kafka             DriverName = "kafka"
	GCPBQ             DriverName = "gcp-bq"
	GCPGCS            DriverName = "gcp-gcs"
	GCPPubSub         DriverName = "gcp-pubsub"
	MongoDB           DriverName = "mongodb"
	MySQL             DriverName = "mysql"
	Nats              DriverName = "nats"
	NSQ               DriverName = "nsq"
	NFS               DriverName = "nfs"
	Postgres          DriverName = "postgres"
	Pulsar            DriverName = "pulsar"
	Rabbit            DriverName = "rabbitmq"
	RedisList         DriverName = "redis-list"
	RedisSubscription DriverName = "redis-pubsub"
	RedisStream       DriverName = "redis-stream"
	Local             DriverName = "local"
	ErrDriverNotFound            = errors.New("driver not found")
)