kafkapubsub

Documentation

Index

• Constants
• type Config
• type KafkaPubSub
  • func FromConfig(ctx context.Context, config Config) (*KafkaPubSub, error)
  • func New(_ context.Context, brokers []string, topic string) (*KafkaPubSub, error)
  • func (pub *KafkaPubSub) Name() string
  • func (pub *KafkaPubSub) Send(ctx context.Context, body []byte) error

Constants

const (
	PublisherType = "kafka"
)

Types

type Config

type Config struct {
	Brokers []string `mapstructure:"brokers"`
	Topic   string   `mapstructure:"topic"`
}

type KafkaPubSub

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

func FromConfig

func FromConfig(ctx context.Context, config Config) (*KafkaPubSub, error)

func New

func New(_ context.Context, brokers []string, topic string) (*KafkaPubSub, error)

func (*KafkaPubSub) Name

func (pub *KafkaPubSub) Name() string

func (*KafkaPubSub) Send

func (pub *KafkaPubSub) Send(ctx context.Context, body []byte) error