drivers

package
Version: v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Aug 2, 2020 License: Apache-2.0 Imports: 3 Imported by: 1

Documentation

Overview

Package drivers contains all the drivers required to connect to different brokers, under a single easy to use interface.

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrInvalidDriver error
	ErrInvalidDriver = errors.New("driver: Invalid driver specified")
	// ErrInvalidConfigSignature error
	ErrInvalidConfigSignature = errors.New("driver: Invalid config signature for specifie driver")
)

Functions

This section is empty.

Types

type SubscriberClient

type SubscriberClient interface {
	// Subscribe method subscribes to the specified topic
	// and returns the gocloud pubsub Subscription
	Subscribe(context.Context, string) (*pubsub.Subscription, error)

	Close(context.Context) error
}

SubscriberClient connects to the specific pubsub broker using specific drivers, it also hides the specific driver implementation for subscribing to topics And gives a single interface for all driver types.

Source Files

Directories

Path Synopsis
Package gcpdriver contains Google Cloud Pub/Sub driver for unifrost.StreamHandler
Package gcpdriver contains Google Cloud Pub/Sub driver for unifrost.StreamHandler
Package kafkadriver contains Apache Kafka message bus driver for unifrost.StreamHandler
Package kafkadriver contains Apache Kafka message bus driver for unifrost.StreamHandler
Package memdriver contains In-memory testing driver for unifrost.StreamHandler
Package memdriver contains In-memory testing driver for unifrost.StreamHandler
Package natsdriver contains NATS driver for unifrost.StreamHandler
Package natsdriver contains NATS driver for unifrost.StreamHandler
Package rabbitdriver contains RabbitMQ driver for unifrost.StreamHandler
Package rabbitdriver contains RabbitMQ driver for unifrost.StreamHandler
Package sqsdriver contains Amazon SQS driver for unifrost.StreamHandler
Package sqsdriver contains Amazon SQS driver for unifrost.StreamHandler

Jump to

Keyboard shortcuts

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