Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AmqpDelivery ¶
func (*AmqpDelivery) Ack ¶
func (d *AmqpDelivery) Ack(multiple bool) error
func (*AmqpDelivery) GetBody ¶
func (d *AmqpDelivery) GetBody() []byte
func (*AmqpDelivery) Nack ¶
func (d *AmqpDelivery) Nack(multiple, requeue bool) error
type ElasticHandler ¶
func NewElasticHandler ¶
func NewElasticHandler() (*ElasticHandler, error)
func (*ElasticHandler) BulkInsert ¶
func (handler *ElasticHandler) BulkInsert(calls []*entity.ElasticCdr) (error, []*entity.SqlCdr, []*entity.SqlCdr)
func (*ElasticHandler) BulkStatus ¶
func (*ElasticHandler) Init ¶
func (handler *ElasticHandler) Init() error
type PostgresHandler ¶
func NewPostgresHandler ¶
func NewPostgresHandler() (*PostgresHandler, error)
func (*PostgresHandler) CreateTable ¶
func (handler *PostgresHandler) CreateTable(query string) error
func (*PostgresHandler) ExecuteQuery ¶
func (handler *PostgresHandler) ExecuteQuery(query string, params ...interface{}) error
func (*PostgresHandler) GetRows ¶
func (handler *PostgresHandler) GetRows(query string, params ...interface{}) (interfaces.Row, error)
type PostgresRow ¶
func (PostgresRow) Close ¶
func (r PostgresRow) Close() error
func (PostgresRow) Next ¶
func (r PostgresRow) Next() bool
func (PostgresRow) Scan ¶
func (r PostgresRow) Scan(dest ...interface{}) error
type PublisherHandler ¶
type PublisherHandler RabbitHandler
func NewRabbitPublisherHandler ¶
func NewRabbitPublisherHandler() *PublisherHandler
func (*PublisherHandler) DeclareExchange ¶
func (handler *PublisherHandler) DeclareExchange(exchType, exchName string) error
func (*PublisherHandler) GetAmqpMsg ¶
func (handler *PublisherHandler) GetAmqpMsg(exchName, exchType, routingKey string) (<-chan entity.Delivery, error)
func (*PublisherHandler) InitRabbitConn ¶
func (handler *PublisherHandler) InitRabbitConn(connectionString, exchangeName, exchangeType string)
type RabbitHandler ¶
type ReceiverHandler ¶
type ReceiverHandler RabbitHandler
func NewRabbitReceiverHandler ¶
func NewRabbitReceiverHandler() *ReceiverHandler
func (*ReceiverHandler) DeclareExchange ¶
func (handler *ReceiverHandler) DeclareExchange(exchType, exchName string) error
func (*ReceiverHandler) InitRabbitConn ¶
func (handler *ReceiverHandler) InitRabbitConn(connectionString, exchangeName, exchangeType string)
func (*ReceiverHandler) PublishMessage ¶
func (handler *ReceiverHandler) PublishMessage(calls []*entity.SqlCdr, routingKey, exchangeName string) error
Source Files
Click to show internal directories.
Click to hide internal directories.