Versions in this module Expand all Collapse all v0 v0.12.5 Jul 6, 2022 v0.12.4 Jul 5, 2022 v0.12.3 Jul 2, 2022 v0.12.2 Jul 2, 2022 v0.12.1 Jun 22, 2022 Changes in this version + func Publish(ctx context.Context, argument PublishArgument) (ok bool, err errors.CodeError) + func RegisterConsumerHandler(name string, builder ConsumerHandlerBuilder) + func Service() service.Service + type ClientTLSConfig struct + CA string + Cert string + InsecureSkipVerify bool + Key string + type Config struct + Consumers map[string]*ConsumerConfig + Options *OptionsConfig + Producers map[string]*ProducerConfig + URI string + type Consumer struct + func (consumer *Consumer) Close() (err error) + func (consumer *Consumer) Consume(ctx context.Context) (err error) + type ConsumerConfig struct + Arguments map[string]interface{} + AutoAck bool + Exclusive bool + Handler string + HandlerOptions json.RawMessage + NoLocal bool + NoWait bool + Queue string + type ConsumerHandler interface + Handle func(ctx context.Context, message ConsumerMessage) + type ConsumerHandlerBuilder func(options ConsumerHandlerOptions) (handler ConsumerHandler, err error) + type ConsumerHandlerOptions struct + Config configuares.Config + Log logs.Logger + type ConsumerMessage interface + Ack func() (err error) + Body func() (body []byte) + ContentType func() (contentType string) + Id func() (id string) + Raw func() (raw *amqp.Delivery) + Reject func() (err error) + Type func() (typ string) + type DefaultConsumerMessage struct + func (msg *DefaultConsumerMessage) Ack() (err error) + func (msg *DefaultConsumerMessage) Body() (body []byte) + func (msg *DefaultConsumerMessage) ContentType() (contentType string) + func (msg *DefaultConsumerMessage) Id() (id string) + func (msg *DefaultConsumerMessage) Raw() (raw *amqp.Delivery) + func (msg *DefaultConsumerMessage) Reject() (err error) + func (msg *DefaultConsumerMessage) Type() (typ string) + type Message struct + Argument json.RawMessage + Fn string + Service string + type OptionsConfig struct + AMQPlainAuth *amqp.AMQPlainAuth + ChannelMax int + ClientTLS *ClientTLSConfig + FrameSize int + HeartbeatSeconds int + Locale string + Vhost string + type Producer struct + func (producer *Producer) Close() (err error) + func (producer *Producer) Publish(_ context.Context, msg ProducerMessage) (ok bool, err errors.CodeError) + type ProducerConfig struct + ConfirmMode bool + Exchange string + Immediate bool + Key string + Mandatory bool + Size int + type ProducerMessage interface + Body func() (body []byte) + ContentType func() (contentType string) + type PublishArgument struct + Body json.RawMessage + Name string + type PublishResult struct + Succeed bool