factory

Documentation

Index

• func Create(logger *zap.Logger, mqType fv1.MessageQueueType, mqConfig messageQueue.Config, ...) (messageQueue.MessageQueue, error)
• func Register(mqType fv1.MessageQueueType, factory MessageQueueFactory)
• type MessageQueueFactory

Functions

func Create

func Create(logger *zap.Logger, mqType fv1.MessageQueueType, mqConfig messageQueue.Config, routerUrl string) (messageQueue.MessageQueue, error)

func Register

func Register(mqType fv1.MessageQueueType, factory MessageQueueFactory)

Types

type MessageQueueFactory

type MessageQueueFactory interface {
	Create(logger *zap.Logger, config messageQueue.Config, routerURL string) (messageQueue.MessageQueue, error)
}