Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broker ¶ added in v1.7.0
type Broker struct {
// contains filtered or unexported fields
}
Broker model
func InitBrokers ¶
func InitBrokers(opts ...OptionFunc) *Broker
InitBrokers init registered broker for publisher or consumer
* 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
func (*Broker) Disconnect ¶ added in v1.7.0
Disconnect disconnect all registered broker
func (*Broker) GetBrokers ¶ added in v1.7.0
func (b *Broker) GetBrokers() map[types.Worker]interfaces.Broker
GetBrokers get all registered broker
type KafkaBroker ¶ added in v1.0.4
type KafkaBroker struct {
// contains filtered or unexported fields
}
KafkaBroker configuration
func NewKafkaBroker ¶ added in v1.0.4
func NewKafkaBroker(opts ...KafkaOptionFunc) *KafkaBroker
NewKafkaBroker setup kafka configuration for publisher or consumer, empty option param for default configuration
func (*KafkaBroker) Disconnect ¶ added in v1.7.0
func (k *KafkaBroker) Disconnect(ctx context.Context) error
Disconnect method
func (*KafkaBroker) GetConfiguration ¶ added in v1.7.0
func (k *KafkaBroker) GetConfiguration() interface{}
GetConfiguration method
func (*KafkaBroker) GetPublisher ¶ added in v1.7.0
func (k *KafkaBroker) GetPublisher() interfaces.Publisher
GetPublisher method
func (*KafkaBroker) Health ¶ added in v1.7.0
func (k *KafkaBroker) Health() map[string]error
Health method
type KafkaOptionFunc ¶ added in v1.0.4
type KafkaOptionFunc func(*KafkaBroker)
KafkaOptionFunc func type
func KafkaSetConfig ¶ added in v1.0.4
func KafkaSetConfig(cfg *sarama.Config) KafkaOptionFunc
KafkaSetConfig set custom sarama configuration
func KafkaSetPublisher ¶ added in v1.0.4
func KafkaSetPublisher(pub interfaces.Publisher) KafkaOptionFunc
KafkaSetPublisher set custom publisher
type OptionFunc ¶ added in v1.0.4
type OptionFunc func(*Broker)
OptionFunc type
func SetKafka ¶ added in v1.0.4
func SetKafka(bk interfaces.Broker) OptionFunc
SetKafka setup kafka broker for publisher or consumer
func SetRabbitMQ ¶ added in v1.0.4
func SetRabbitMQ(bk interfaces.Broker) OptionFunc
SetRabbitMQ setup rabbitmq broker for publisher or consumer
type RabbitMQBroker ¶ added in v1.0.4
type RabbitMQBroker struct {
// contains filtered or unexported fields
}
RabbitMQBroker broker
func NewRabbitMQBroker ¶ added in v1.0.4
func NewRabbitMQBroker(opts ...RabbitMQOptionFunc) *RabbitMQBroker
NewRabbitMQBroker constructor, connection from RABBITMQ_BROKER environment
func (*RabbitMQBroker) Disconnect ¶ added in v1.7.0
func (r *RabbitMQBroker) Disconnect(ctx context.Context) error
Disconnect method
func (*RabbitMQBroker) GetConfiguration ¶ added in v1.7.0
func (r *RabbitMQBroker) GetConfiguration() interface{}
GetConfiguration method
func (*RabbitMQBroker) GetPublisher ¶ added in v1.7.0
func (r *RabbitMQBroker) GetPublisher() interfaces.Publisher
GetPublisher method
func (*RabbitMQBroker) Health ¶ added in v1.7.0
func (r *RabbitMQBroker) Health() map[string]error
Health method
type RabbitMQOptionFunc ¶ added in v1.0.6
type RabbitMQOptionFunc func(*RabbitMQBroker)
RabbitMQOptionFunc func type
func RabbitMQSetChannel ¶ added in v1.0.6
func RabbitMQSetChannel(ch *amqp.Channel) RabbitMQOptionFunc
RabbitMQSetChannel set custom channel configuration
func RabbitMQSetPublisher ¶ added in v1.0.6
func RabbitMQSetPublisher(pub interfaces.Publisher) RabbitMQOptionFunc
RabbitMQSetPublisher set custom publisher
Source Files