comswitch

Documentation

Index

• Variables
• func IsHttpHandler(handler string) bool
• type FactoryType
  • func (this FactoryType) NewConsumer(basectx context.Context, config util.Config, ...) (err error)
  • func (this FactoryType) NewProducer(basectx context.Context, config util.Config) (result com.ProducerInterface, err error)
• type Producer
  • func (this *Producer) Produce(topic string, message string) (err error)
  • func (this *Producer) ProduceWithKey(topic string, key string, message string) (err error)

Variables

var Factory = FactoryType{}

Functions

func IsHttpHandler

func IsHttpHandler(handler string) bool

Types

type FactoryType

type FactoryType struct{}

func (FactoryType) NewConsumer

func (this FactoryType) NewConsumer(basectx context.Context, config util.Config, responseListener func(msg string) error, errorListener func(msg string) error) (err error)

func (FactoryType) NewProducer

func (this FactoryType) NewProducer(basectx context.Context, config util.Config) (result com.ProducerInterface, err error)

type Producer

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

func (*Producer) Produce

func (this *Producer) Produce(topic string, message string) (err error)

func (*Producer) ProduceWithKey

func (this *Producer) ProduceWithKey(topic string, key string, message string) (err error)