Versions in this module Expand all Collapse all v0 v0.1.0 Aug 6, 2024 Changes in this version + var ErrorReason_name = map[int32]string + var ErrorReason_value = map[string]int32 + var ExchangeDirect = amqp.ExchangeDirect + var ExchangeFanout = amqp.ExchangeFanout + var ExchangeHeaders = amqp.ExchangeHeaders + var ExchangeTopic = amqp.ExchangeTopic + var File_queue_rabbitmq_conf_proto protoreflect.FileDescriptor + func Client(ctx context.Context, msg []byte) []byte + func ErrorChannelClosed(format string, args ...interface{}) *errors.Error + func ErrorDisconnect(format string, args ...interface{}) *errors.Error + func ErrorUnkown(format string, args ...interface{}) *errors.Error + func IsChannelClosed(err error) bool + func IsDisconnect(err error) bool + func IsUnkown(err error) bool + func MustNewListener(c *ListenerConf, handler ConsumeHandler) queue.MessageQueue + func NewListener(c *ListenerConf, handler ConsumeHandler) (consumer queue.MessageQueue, err error) + func Server(msg []byte) (context.Context, context.CancelFunc, []byte, error) + type Admin struct + func MustNewAdmin(c *RabbitConf) *Admin + func (q *Admin) Bind(queueName string, routekey string, exchange, kind string, args amqp.Table) error + type AdminExchangeConf struct + AutoDelete bool + Durable bool + Internal bool + Kind string + Name string + NoWait bool + func (*AdminExchangeConf) Descriptor() ([]byte, []int) + func (*AdminExchangeConf) ProtoMessage() + func (m *AdminExchangeConf) Validate() error + func (m *AdminExchangeConf) ValidateAll() error + func (x *AdminExchangeConf) GetAutoDelete() bool + func (x *AdminExchangeConf) GetDurable() bool + func (x *AdminExchangeConf) GetInternal() bool + func (x *AdminExchangeConf) GetKind() string + func (x *AdminExchangeConf) GetName() string + func (x *AdminExchangeConf) GetNoWait() bool + func (x *AdminExchangeConf) ProtoReflect() protoreflect.Message + func (x *AdminExchangeConf) Reset() + func (x *AdminExchangeConf) String() string + type AdminExchangeConfMultiError []error + func (m AdminExchangeConfMultiError) AllErrors() []error + func (m AdminExchangeConfMultiError) Error() string + type AdminExchangeConfValidationError struct + func (e AdminExchangeConfValidationError) Cause() error + func (e AdminExchangeConfValidationError) Error() string + func (e AdminExchangeConfValidationError) ErrorName() string + func (e AdminExchangeConfValidationError) Field() string + func (e AdminExchangeConfValidationError) Key() bool + func (e AdminExchangeConfValidationError) Reason() string + type AdminQueueConf struct + AutoDelete bool + Durable bool + Exclusive bool + Name string + NoWait bool + func (*AdminQueueConf) Descriptor() ([]byte, []int) + func (*AdminQueueConf) ProtoMessage() + func (m *AdminQueueConf) Validate() error + func (m *AdminQueueConf) ValidateAll() error + func (x *AdminQueueConf) GetAutoDelete() bool + func (x *AdminQueueConf) GetDurable() bool + func (x *AdminQueueConf) GetExclusive() bool + func (x *AdminQueueConf) GetName() string + func (x *AdminQueueConf) GetNoWait() bool + func (x *AdminQueueConf) ProtoReflect() protoreflect.Message + func (x *AdminQueueConf) Reset() + func (x *AdminQueueConf) String() string + type AdminQueueConfMultiError []error + func (m AdminQueueConfMultiError) AllErrors() []error + func (m AdminQueueConfMultiError) Error() string + type AdminQueueConfValidationError struct + func (e AdminQueueConfValidationError) Cause() error + func (e AdminQueueConfValidationError) Error() string + func (e AdminQueueConfValidationError) ErrorName() string + func (e AdminQueueConfValidationError) Field() string + func (e AdminQueueConfValidationError) Key() bool + func (e AdminQueueConfValidationError) Reason() string + type ConsumeHandle func(ctx context.Context, topic string, key, message []byte) error + type ConsumeHandler interface + Consume func(ctx context.Context, topic string, key, message []byte) error + type ConsumerConf struct + Consumer string + Name string + func (*ConsumerConf) Descriptor() ([]byte, []int) + func (*ConsumerConf) ProtoMessage() + func (m *ConsumerConf) Validate() error + func (m *ConsumerConf) ValidateAll() error + func (x *ConsumerConf) GetConsumer() string + func (x *ConsumerConf) GetName() string + func (x *ConsumerConf) ProtoReflect() protoreflect.Message + func (x *ConsumerConf) Reset() + func (x *ConsumerConf) String() string + type ConsumerConfMultiError []error + func (m ConsumerConfMultiError) AllErrors() []error + func (m ConsumerConfMultiError) Error() string + type ConsumerConfValidationError struct + func (e ConsumerConfValidationError) Cause() error + func (e ConsumerConfValidationError) Error() string + func (e ConsumerConfValidationError) ErrorName() string + func (e ConsumerConfValidationError) Field() string + func (e ConsumerConfValidationError) Key() bool + func (e ConsumerConfValidationError) Reason() string + type Data struct + Body []byte + Md map[string]string + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (m *Data) Validate() error + func (m *Data) ValidateAll() error + func (x *Data) GetBody() []byte + func (x *Data) GetMd() map[string]string + func (x *Data) ProtoReflect() protoreflect.Message + func (x *Data) Reset() + func (x *Data) String() string + type DataMultiError []error + func (m DataMultiError) AllErrors() []error + func (m DataMultiError) Error() string + type DataValidationError struct + func (e DataValidationError) Cause() error + func (e DataValidationError) Error() string + func (e DataValidationError) ErrorName() string + func (e DataValidationError) Field() string + func (e DataValidationError) Key() bool + func (e DataValidationError) Reason() string + type ErrorReason int32 + const ErrorReason_CHANNEL_CLOSED + const ErrorReason_DISCONNECT + const ErrorReason_UNKOWN + func (ErrorReason) Descriptor() protoreflect.EnumDescriptor + func (ErrorReason) EnumDescriptor() ([]byte, []int) + func (ErrorReason) Type() protoreflect.EnumType + func (x ErrorReason) Enum() *ErrorReason + func (x ErrorReason) Number() protoreflect.EnumNumber + func (x ErrorReason) String() string + type ExchangeConf struct + Exchange string + Key string + func (*ExchangeConf) Descriptor() ([]byte, []int) + func (*ExchangeConf) ProtoMessage() + func (m *ExchangeConf) Validate() error + func (m *ExchangeConf) ValidateAll() error + func (x *ExchangeConf) GetExchange() string + func (x *ExchangeConf) GetKey() string + func (x *ExchangeConf) ProtoReflect() protoreflect.Message + func (x *ExchangeConf) Reset() + func (x *ExchangeConf) String() string + type ExchangeConfMultiError []error + func (m ExchangeConfMultiError) AllErrors() []error + func (m ExchangeConfMultiError) Error() string + type ExchangeConfValidationError struct + func (e ExchangeConfValidationError) Cause() error + func (e ExchangeConfValidationError) Error() string + func (e ExchangeConfValidationError) ErrorName() string + func (e ExchangeConfValidationError) Field() string + func (e ExchangeConfValidationError) Key() bool + func (e ExchangeConfValidationError) Reason() string + type ListenerConf struct + Queues []*ConsumerConf + Rabbit *RabbitConf + func (*ListenerConf) Descriptor() ([]byte, []int) + func (*ListenerConf) ProtoMessage() + func (m *ListenerConf) Validate() error + func (m *ListenerConf) ValidateAll() error + func (x *ListenerConf) GetQueues() []*ConsumerConf + func (x *ListenerConf) GetRabbit() *RabbitConf + func (x *ListenerConf) ProtoReflect() protoreflect.Message + func (x *ListenerConf) Reset() + func (x *ListenerConf) String() string + type ListenerConfMultiError []error + func (m ListenerConfMultiError) AllErrors() []error + func (m ListenerConfMultiError) Error() string + type ListenerConfValidationError struct + func (e ListenerConfValidationError) Cause() error + func (e ListenerConfValidationError) Error() string + func (e ListenerConfValidationError) ErrorName() string + func (e ListenerConfValidationError) Field() string + func (e ListenerConfValidationError) Key() bool + func (e ListenerConfValidationError) Reason() string + type ProducerConf struct + ContentType string + Rabbit *RabbitConf + func (*ProducerConf) Descriptor() ([]byte, []int) + func (*ProducerConf) ProtoMessage() + func (m *ProducerConf) Validate() error + func (m *ProducerConf) ValidateAll() error + func (x *ProducerConf) GetContentType() string + func (x *ProducerConf) GetRabbit() *RabbitConf + func (x *ProducerConf) ProtoReflect() protoreflect.Message + func (x *ProducerConf) Reset() + func (x *ProducerConf) String() string + type ProducerConfMultiError []error + func (m ProducerConfMultiError) AllErrors() []error + func (m ProducerConfMultiError) Error() string + type ProducerConfValidationError struct + func (e ProducerConfValidationError) Cause() error + func (e ProducerConfValidationError) Error() string + func (e ProducerConfValidationError) ErrorName() string + func (e ProducerConfValidationError) Field() string + func (e ProducerConfValidationError) Key() bool + func (e ProducerConfValidationError) Reason() string + type QueueConf struct + Name string + func (*QueueConf) Descriptor() ([]byte, []int) + func (*QueueConf) ProtoMessage() + func (m *QueueConf) Validate() error + func (m *QueueConf) ValidateAll() error + func (x *QueueConf) GetName() string + func (x *QueueConf) ProtoReflect() protoreflect.Message + func (x *QueueConf) Reset() + func (x *QueueConf) String() string + type QueueConfMultiError []error + func (m QueueConfMultiError) AllErrors() []error + func (m QueueConfMultiError) Error() string + type QueueConfValidationError struct + func (e QueueConfValidationError) Cause() error + func (e QueueConfValidationError) Error() string + func (e QueueConfValidationError) ErrorName() string + func (e QueueConfValidationError) Field() string + func (e QueueConfValidationError) Key() bool + func (e QueueConfValidationError) Reason() string + type RabbitConf struct + Host string + Password string + Port int32 + Username string + VHost string + func (*RabbitConf) Descriptor() ([]byte, []int) + func (*RabbitConf) ProtoMessage() + func (c *RabbitConf) URL() string + func (m *RabbitConf) Validate() error + func (m *RabbitConf) ValidateAll() error + func (x *RabbitConf) GetHost() string + func (x *RabbitConf) GetPassword() string + func (x *RabbitConf) GetPort() int32 + func (x *RabbitConf) GetUsername() string + func (x *RabbitConf) GetVHost() string + func (x *RabbitConf) ProtoReflect() protoreflect.Message + func (x *RabbitConf) Reset() + func (x *RabbitConf) String() string + type RabbitConfMultiError []error + func (m RabbitConfMultiError) AllErrors() []error + func (m RabbitConfMultiError) Error() string + type RabbitConfValidationError struct + func (e RabbitConfValidationError) Cause() error + func (e RabbitConfValidationError) Error() string + func (e RabbitConfValidationError) ErrorName() string + func (e RabbitConfValidationError) Field() string + func (e RabbitConfValidationError) Key() bool + func (e RabbitConfValidationError) Reason() string + type RabbitListener struct + func (s *RabbitListener) Name() string + func (s *RabbitListener) Start(context.Context) error + func (s *RabbitListener) Stop(context.Context) error + type RabbitMqSender struct + ContentType string + func (q *RabbitMqSender) Close() error + func (q *RabbitMqSender) Name() string + func (q *RabbitMqSender) Send(ctx context.Context, header map[string]interface{}, exchange string, ...) error + type Sender interface + Close func() error + Name func() string + Send func(ctx context.Context, header map[string]interface{}, exchange string, ...) error + func MustNewSender(c *ProducerConf) Sender
Go to main page