Versions in this module Expand all Collapse all v0 v0.0.10 Apr 16, 2023 Changes in this version + const EventKindCreated + const EventKindDeleted + const ExchangeType + var ErrAlreadyExists = errors.New("E010") + var ErrChannelClosed = errors.New("channel closed") + var ErrInvalidFormat = errors.New("E006") + var ErrInvalidHeader = errors.New("E007") + var ErrInvalidToken = errors.New("E005") + var ErrNotAvailable = errors.New("E003") + var ErrNotFound = errors.New("E002") + var ErrProtectedContent = errors.New("protected content") + var ErrUnauthorized = errors.New("E004") + var ErrUnidentified = errors.New("unidentified") + var ErrUnknown = errors.New("E001") + func GetUidFromGrpcCtx(ctx context.Context, header string, logger *zap.Logger) (int32, error) + func GetUidFromHttpRequest(r *http.Request, header string, logger *zap.Logger) (int32, error) + func NewMongoDBConn(uri, database string) (*mongo.Database, error) + type EventHandler func(ctx context.Context, body []byte) + type RabbitMqEventBus struct + func NewRabbitMqEventBus(chann *amqp.Channel, logger *zap.Logger) *RabbitMqEventBus + func (bus *RabbitMqEventBus) Chann() *amqp.Channel + func (bus *RabbitMqEventBus) Consume(ctx context.Context, queue string, handler EventHandler) error + func (bus *RabbitMqEventBus) QueueBind(exchange, queue string) error