rabbitmq

Documentation

Overview

Package redis contains the domain concept definitions needed to support Magistrala redis events source service functionality.

It provides the abstraction of the redis stream and its operations.

Index

• Variables
• func NewPublisher(ctx context.Context, url, stream string) (events.Publisher, error)
• func NewSubscriber(url, stream, consumer string, logger *slog.Logger) (events.Subscriber, error)

Variables

var (

	// ErrEmptyStream is returned when stream name is empty.
	ErrEmptyStream = errors.New("stream name cannot be empty")

	// ErrEmptyConsumer is returned when consumer name is empty.
	ErrEmptyConsumer = errors.New("consumer name cannot be empty")
)

Functions

func NewPublisher

func NewPublisher(ctx context.Context, url, stream string) (events.Publisher, error)

func NewSubscriber

func NewSubscriber(url, stream, consumer string, logger *slog.Logger) (events.Subscriber, error)