forwarder

Documentation

Index

• type Forwarder
• type KafkaForwarder
  • func NewKafkaForwarder(config *viper.Viper) (*KafkaForwarder, error)
  • func (k KafkaForwarder) Produce(ctx context.Context, topic string, message []byte) (int32, int64, error)

Types

type Forwarder

type Forwarder interface {
	Produce(ctx context.Context, topic string, message []byte) (int32, int64, error)
}

Forwarder is the forwarder of the events

type KafkaForwarder

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

func NewKafkaForwarder

func NewKafkaForwarder(config *viper.Viper) (*KafkaForwarder, error)

func (KafkaForwarder) Produce

func (k KafkaForwarder) Produce(ctx context.Context, topic string, message []byte) (int32, int64, error)