drivers

Documentation

Overview

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

Index

• Variables
• type SubscriberClient

Variables

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

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.