rabbitmq

package

Go to main page

Versions in this module

v0

v0.1.1

Mar 4, 2026

Changes in this version

+ const Name

+ var File_queue_rabbitmq_ecode_proto protoreflect.FileDescriptor

+ func NewSender(c *queue.Conf) (queue.Pusher, error)

type RabbitListener

+ func (s *RabbitListener) Close() error

+ func (s *RabbitListener) Subscribe(topic string, handler queue.ConsumeHandle, opts ...queue.SubscribeOption) (queue.Subscriber, error)

type RabbitMqSender

+ func (q *RabbitMqSender) Push(ctx context.Context, exchange string, routeKey []byte, msg []byte) error

+ func (q *RabbitMqSender) PushWithPartition(ctx context.Context, exchange string, routeKey []byte, msg []byte, ...) error

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL