broker

Documentation

Index

• func InitBrokers(opts ...OptionFunc) interfaces.Broker
• type KafkaBroker
  • func NewKafkaBroker(opts ...KafkaOptionFunc) *KafkaBroker
• type KafkaOptionFunc
  • func KafkaSetConfig(cfg *sarama.Config) KafkaOptionFunc
  • func KafkaSetPublisher(pub interfaces.Publisher) KafkaOptionFunc
• type OptionFunc
  • func SetKafka(bk *KafkaBroker) OptionFunc
  • func SetRabbitMQ(bk *RabbitMQBroker) OptionFunc
• type RabbitMQBroker
  • func NewRabbitMQBroker(opts ...RabbitMQOptionFunc) *RabbitMQBroker
• type RabbitMQOptionFunc
  • func RabbitMQSetChannel(ch *amqp.Channel) RabbitMQOptionFunc
  • func RabbitMQSetPublisher(pub interfaces.Publisher) RabbitMQOptionFunc

Functions

func InitBrokers

func InitBrokers(opts ...OptionFunc) interfaces.Broker

InitBrokers init registered broker

* for kafka, pass NewKafkaBroker(...KafkaOptionFunc) in param, init kafka broker configuration from env KAFKA_BROKERS, KAFKA_CLIENT_ID, KAFKA_CLIENT_VERSION

* for rabbitmq, pass NewRabbitMQBroker(...RabbitMQOptionFunc) in param, init rabbitmq broker configuration from env RABBITMQ_BROKER, RABBITMQ_CONSUMER_GROUP, RABBITMQ_EXCHANGE_NAME

Types

type KafkaBroker

type KafkaBroker struct {
	// contains filtered or unexported fields
}

KafkaBroker configuration

func NewKafkaBroker

func NewKafkaBroker(opts ...KafkaOptionFunc) *KafkaBroker

NewKafkaBroker constructor with option, empty option param for default configuration

type KafkaOptionFunc

type KafkaOptionFunc func(*KafkaBroker)

KafkaOptionFunc func type

func KafkaSetConfig

func KafkaSetConfig(cfg *sarama.Config) KafkaOptionFunc

KafkaSetConfig set custom sarama configuration

func KafkaSetPublisher

func KafkaSetPublisher(pub interfaces.Publisher) KafkaOptionFunc

KafkaSetPublisher set custom publisher

type OptionFunc

type OptionFunc func(*brokerInstance)

OptionFunc type

func SetKafka

func SetKafka(bk *KafkaBroker) OptionFunc

SetKafka set kafka broker

func SetRabbitMQ

func SetRabbitMQ(bk *RabbitMQBroker) OptionFunc

SetRabbitMQ set kafka broker

type RabbitMQBroker

type RabbitMQBroker struct {
	// contains filtered or unexported fields
}

RabbitMQBroker broker

func NewRabbitMQBroker

func NewRabbitMQBroker(opts ...RabbitMQOptionFunc) *RabbitMQBroker

NewRabbitMQBroker constructor, connection from RABBITMQ_BROKER environment

type RabbitMQOptionFunc

type RabbitMQOptionFunc func(*RabbitMQBroker)

RabbitMQOptionFunc func type

func RabbitMQSetChannel

func RabbitMQSetChannel(ch *amqp.Channel) RabbitMQOptionFunc

RabbitMQSetChannel set custom channel configuration

func RabbitMQSetPublisher

func RabbitMQSetPublisher(pub interfaces.Publisher) RabbitMQOptionFunc

RabbitMQSetPublisher set custom publisher