publisher

Documentation

Index

• Constants
• type KafkaPublisher
  • func NewKafkaPublisher(client sarama.Client, async bool) *KafkaPublisher
  • func (p *KafkaPublisher) PublishMessage(ctx context.Context, args *candishared.PublisherArgument) (err error)
• type RabbitMQPublisher
  • func NewRabbitMQPublisher(conn *amqp.Connection) *RabbitMQPublisher
  • func (r *RabbitMQPublisher) PublishMessage(ctx context.Context, args *candishared.PublisherArgument) (err error)

Constants

const (
	// RabbitMQDelayHeader header key
	RabbitMQDelayHeader = "x-delay"
)

Types

type KafkaPublisher

type KafkaPublisher struct {
	// contains filtered or unexported fields
}

KafkaPublisher kafka

func NewKafkaPublisher

func NewKafkaPublisher(client sarama.Client, async bool) *KafkaPublisher

NewKafkaPublisher constructor

func (*KafkaPublisher) PublishMessage

func (p *KafkaPublisher) PublishMessage(ctx context.Context, args *candishared.PublisherArgument) (err error)

PublishMessage method

type RabbitMQPublisher

type RabbitMQPublisher struct {
	// contains filtered or unexported fields
}

RabbitMQPublisher rabbitmq

func NewRabbitMQPublisher

func NewRabbitMQPublisher(conn *amqp.Connection) *RabbitMQPublisher

NewRabbitMQPublisher constructor

func (*RabbitMQPublisher) PublishMessage

func (r *RabbitMQPublisher) PublishMessage(ctx context.Context, args *candishared.PublisherArgument) (err error)

PublishMessage method