Documentation ¶
Index ¶
Constants ¶
View Source
const ( DefaultContentType = "application/json" DefaultAppID = "ytfeed" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPPublisher ¶
type PublishAMQP ¶
type PublishAMQP struct {
// contains filtered or unexported fields
}
func New ¶
func New(logger ytfeed.Logger, channel AMQPPublisher, exchange, key string, mandatory, immediate bool) (pr *PublishAMQP)
func (*PublishAMQP) DataHandler ¶
func (p *PublishAMQP) DataHandler(ctx context.Context, d *ytfeed.Data)
Click to show internal directories.
Click to hide internal directories.