ogiproducer

Documentation

Index

• Variables
• func Produce(topic string, message []byte, messageKey string)
• type Echo
  • func (e *Echo) Close()
  • func (e *Echo) Produce(topic string, message []byte, messageKey string)
• type NewProducerFunc
• type Producer
  • func NewEchoProducer() Producer
  • func NewProducer() Producer
  • func NewProducerPlugin() Producer
• type ProducerPlugin
  • func (plugin *ProducerPlugin) Close()
  • func (plugin *ProducerPlugin) Produce(topic string, message []byte, messageKey string)

Variables

var (
	ProducerPluginPath = golenv.OverrideIfEnv("PRODUCER_PLUGIN_PATH", "./producer.so")
)

var (
	ProducerType = golenv.OverrideIfEnv("PRODUCER_TYPE", "echo")
)

Functions

func Produce

func Produce(topic string, message []byte, messageKey string)

Types

type Echo

type Echo struct {
}

func (*Echo) Close

func (e *Echo) Close()

func (*Echo) Produce

func (e *Echo) Produce(topic string, message []byte, messageKey string)

type NewProducerFunc

type NewProducerFunc func() Producer

type Producer

type Producer interface {
	Produce(string, []byte, string)
	Close()
}

func NewEchoProducer

func NewEchoProducer() Producer

func NewProducer

func NewProducer() Producer

func NewProducerPlugin

func NewProducerPlugin() Producer

type ProducerPlugin

type ProducerPlugin struct {
	Name        string
	CloseFunc   plugin.Symbol
	ProduceFunc plugin.Symbol
}

func (*ProducerPlugin) Close

func (plugin *ProducerPlugin) Close()

func (*ProducerPlugin) Produce

func (plugin *ProducerPlugin) Produce(topic string, message []byte, messageKey string)