kafka_adapter

Documentation

Index

• type KafkaAdapter
  • func New(w *kafka.Writer) *KafkaAdapter
  • func (k *KafkaAdapter) Close() error
  • func (k *KafkaAdapter) Listener(ctx context.Context, fn func(discourse.Message) error, ...) error
  • func (k *KafkaAdapter) Publish(ctx context.Context, message discourse.Publisher) error

Types

type KafkaAdapter

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

func New

func New(w *kafka.Writer) *KafkaAdapter

func (*KafkaAdapter) Close

func (k *KafkaAdapter) Close() error

func (*KafkaAdapter) Listener

func (k *KafkaAdapter) Listener(ctx context.Context, fn func(discourse.Message) error, cfgSubcription discourse.Subscription) error

func (*KafkaAdapter) Publish

func (k *KafkaAdapter) Publish(ctx context.Context, message discourse.Publisher) error