Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMessageHandler ¶
func NewMessageHandler(logger *otelzap.Logger, batcher batcher) consumer.MessageHandler
func WithQueue ¶
func WithQueue(queueConfig *mqs.QueueConfig) func(opts *LogMQOption)
Types ¶
type LogAWSInfra ¶
type LogAWSInfra struct {
// contains filtered or unexported fields
}
func (*LogAWSInfra) DeclareInfrastructure ¶
func (i *LogAWSInfra) DeclareInfrastructure(ctx context.Context) error
type LogInfra ¶
func NewLogAWSInfra ¶
func NewLogAWSInfra(config *mqs.AWSSQSConfig) LogInfra
func NewLogRabbitMQInfra ¶
func NewLogRabbitMQInfra(config *mqs.RabbitMQConfig) LogInfra
type LogMQ ¶
type LogMQ struct {
// contains filtered or unexported fields
}
func New ¶
func New(opts ...func(opts *LogMQOption)) *LogMQ
type LogMQOption ¶
type LogMQOption struct {
QueueConfig *mqs.QueueConfig
}
type LogRabbitMQInfra ¶
type LogRabbitMQInfra struct {
// contains filtered or unexported fields
}
func (*LogRabbitMQInfra) DeclareInfrastructure ¶
func (i *LogRabbitMQInfra) DeclareInfrastructure(ctx context.Context) error
Source Files
Click to show internal directories.
Click to hide internal directories.