cAmqp

Feb 22, 2024

Changes in this version

+ const AmqpConfigName

type AmqpComponent

+ func (i *AmqpComponent) InjectConf(config cComponents.ConfigInterface) bool

+ func (i *AmqpComponent) Listen() []*cComponents.ConfigListener

+ type AmqpContainer struct

Feb 4, 2024

Changes in this version

+ type AmqpComponent struct

+ func (k *AmqpComponent) Inject(instance any)

+ func (k *AmqpComponent) ListenConf() map[string]cComponents.ListenConfigFunc

+ func (k *AmqpComponent) Load()

Feb 4, 2024

Changes in this version

+ const ConfigName

+ var Component = &KafkaComponent

+ func ListenConf(instance any)

+ type KafkaComponent struct

+ func (k *KafkaComponent) Inject(instance any)

+ func (k *KafkaComponent) ListenConf() map[string]cComponents.ListenConfigFunc

+ func (k *KafkaComponent) Load()

Sep 20, 2023

Changes in this version

type ConsumeOption

+ UUID string

type ProduceOption

+ UUID string

Sep 20, 2023

Changes in this version

+ type ChannelType string

+ const ChannelType_Consumer

+ const ChannelType_Producer

Aug 10, 2023

Changes in this version

+ const AmqpChannelConnectionErr

Aug 9, 2023

Changes in this version

+ const AmqpClientConnectionErr

May 6, 2023

Changes in this version

+ const ConfChannelConfEmptyErr

+ const ConfChannelNotSetErr

type ConsumeOption

+ ChannelConf *AmqpConf_Channel

type ProduceOption

+ ChannelConf *AmqpConf_Channel

May 5, 2023

Changes in this version

+ func DelChannel(name string)

May 4, 2023

Changes in this version

type ProduceOption

+ RoutingKey string

Apr 25, 2023

Changes in this version

type ConsumeOption

+ BindFinish chan bool

Apr 24, 2023

Changes in this version

+ func AddChannel(name string, channel AmqpConf_Channel)

Mar 23, 2023

Changes in this version

type ConsumeOption

+ BasicGet bool

Feb 12, 2023

Changes in this version

+ const ConsumeAckTypeError

Feb 12, 2023

Changes in this version

+ const ConfChannelNotFoundErr

+ const ConfClientNotFoundErr

type AmqpConf

+ HealthCheck int64

type AmqpConf_Channel

+ Multi bool

type ConsumeOption

+ Channel string

type ProduceOption

+ Channel string

Feb 9, 2023

Changes in this version

type AmqpConf

+ Channels map[string]*AmqpConf_Channel

+ type AmqpConf_Channel struct

+ AutoDeleted bool

+ Connection string

+ ExchangeName string

+ ExchangeType ExchangeTypeName

+ QueueName string

+ RoutingKey string

type ConsumeOption

+ ChannelName string

+ Consume ConsumerOption

+ type ConsumerOption struct

+ Arguments map[string]interface{}

+ AutoACK bool

+ ConsumerTag string

+ Exclusive bool

+ NoLocal bool

+ NoWait bool

+ type ExchangeDeclareOption struct

+ Arguments amqp.Table

+ Internal bool

+ NoWait bool

type ProduceOption

+ ChannelName string

+ Publish PublishOption

+ type PublishOption struct

+ Immediate bool

+ Mandatory bool

+ Message amqp.Publishing

+ type QueueDeclareOption struct

+ Arguments map[string]interface{}

+ Exclusive bool

+ NoWait bool

Dec 14, 2023

Changes in this version

+ func Confirm(ctx *gin.Context, data amqp091.Delivery, ack AckType)

+ func Consume(ctx *gin.Context, option ConsumeOption) (err error)

+ func InjectConf(config interface{})

+ func Load()

+ func Produce(ctx *gin.Context, option ProduceOption) (err error)

+ type AckType uint8

+ const ACK

+ const DROP

+ const NACK

+ const REQUEUE

+ type AmqpConf struct

+ Connections map[string]*AmqpConf_Connection

+ Drivers map[string]*AmqpConf_Driver

+ func GetConf() *AmqpConf

+ func (i *AmqpConf) ConfigName() string

+ type AmqpConf_Connection struct

+ Heartbeat int64

+ Host string

+ Password string

+ Port int64

+ Username string

+ VHost string

+ type AmqpConf_Driver struct

+ Connection string

+ ExchangeName string

+ ExchangeType ExchangeTypeName

+ QueueName string

+ RoutingKey string

+ type AmqpError string

+ const AckTypeErr

+ const AmqpChannelCloseErr

+ const AmqpConfConnectionNotFoundErr

+ const AmqpConfDriverNameNotFoundErr

+ const AmqpConfDriverNotFoundErr

+ func (e AmqpError) Error() string

+ type BindHandlerFunc func(ctx *gin.Context, status bool, params amqp091.Table)

+ type BindOption struct

+ Arguments amqp091.Table

+ NoWait bool

+ type ConnectionType string

+ const ConnectionType_Consumer

+ const ConnectionType_Producer

+ type ConsumeOption struct

+ Arguments amqp091.Table

+ AutoAck bool

+ BatchSize int64

+ Bind BindOption

+ BindHandler BindHandlerFunc

+ ConsumeType ConsumeType

+ DriverConf *AmqpConf_Driver

+ DriverName string

+ Exchange ExchangeOption

+ Exclusive bool

+ FinishHandler ParamsHandlerFunc

+ Handler MessageHandlerFunc

+ NoLocal bool

+ NoWait bool

+ Params amqp091.Table

+ PauseHandler PauseHandlerFunc

+ Queue QueueOption

+ StartHandler ParamsHandlerFunc

+ Tag string

+ WaitCount int64

+ WaitTime int64

+ type ConsumeType uint8

+ const ConsumeType_BasicConsume

+ const ConsumeType_BasicGet

+ type ExchangeOption struct

+ Arguments amqp091.Table

+ AutoDeleted bool

+ Durable bool

+ Internal bool

+ NoWait bool

+ type ExchangeTypeName string

+ const EXCHANGE_TYPE_DIRECT

+ const EXCHANGE_TYPE_FANOUT

+ const EXCHANGE_TYPE_HEADERS

+ const EXCHANGE_TYPE_TOPIC

+ type MessageHandlerFunc func(ctx *gin.Context, delivery []amqp091.Delivery)

+ type ParamsHandlerFunc func(ctx *gin.Context, params amqp091.Table) error

+ type PauseHandlerFunc func(ctx *gin.Context, params amqp091.Table) bool

+ type ProduceOption struct

+ Bind BindOption

+ DriverConf *AmqpConf_Driver

+ DriverName string

+ Exchange ExchangeOption

+ Immediate bool

+ Mandatory bool

+ Message amqp091.Publishing

+ OnlyPush bool

+ Queue QueueOption

+ type QueueOption struct

+ Arguments amqp091.Table

+ AutoDeleted bool

+ Durable bool

+ Exclusive bool

+ NoWait bool