sender

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 20, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BrokerSender added in v0.2.0

type BrokerSender struct {
	BrokerAddress string
	BrokerTryNo   int
	Target        RabbitMQTarget
}

func (*BrokerSender) SendMessage added in v0.2.0

func (s *BrokerSender) SendMessage(message []byte) error

type KafkaSender

type KafkaSender struct {
	Target KafkaTarget
	Debug  bool
}

func (*KafkaSender) SendMessage

func (s *KafkaSender) SendMessage(message []byte) error

type KafkaTarget

type KafkaTarget struct {
	Brokers      []string
	Topic        string
	WriteTimeout time.Duration
}

type RabbitMQSender

type RabbitMQSender struct {
	Target RabbitMQTarget
	Debug  bool
}

func (*RabbitMQSender) SendMessage

func (s *RabbitMQSender) SendMessage(message []byte) error

type RabbitMQTarget

type RabbitMQTarget struct {
	Server       string
	Exchange     string
	RouteKey     string
	WriteTimeout time.Duration
}

type Sender

type Sender interface {
	SendMessage([]byte) error
}

func CreateBrokerSender added in v0.2.0

func CreateBrokerSender(
	brokerAddress string,
	brokerTryNo int,
	rabbitMQServer string,
	exchange string,
	routeKey string,
	writeTimeout time.Duration,
) Sender

func CreateKafkaSender added in v0.6.0

func CreateKafkaSender(
	brokers []string,
	topic string,
	writeTimeout time.Duration,
) Sender

func CreateRabbitMQSender added in v0.2.0

func CreateRabbitMQSender(
	server string,
	exchange string,
	routeKey string,
	writeTimeout time.Duration) Sender

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL