kafka

Documentation

Index

• func NewPublisher(pubsubTopics map[string]*pubsub.Topic) publisher.Publisher
• type RabbitmqPublisher
  • func (p *RabbitmqPublisher) Publish(ctx context.Context, topic string, idempotentId string, event []byte) error

Functions

func NewPublisher

func NewPublisher(pubsubTopics map[string]*pubsub.Topic) publisher.Publisher

Types

type RabbitmqPublisher

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

func (*RabbitmqPublisher) Publish

func (p *RabbitmqPublisher) Publish(ctx context.Context, topic string, idempotentId string, event []byte) error