eventsource

Documentation

Index

• type KafkaSource
  • func NewKafkaSource(config *eventbusv1alpha1.KafkaBus, logger *zap.SugaredLogger) *KafkaSource
  • func (s *KafkaSource) Connect(string) (eventbuscommon.EventSourceConnection, error)
  • func (s *KafkaSource) Initialize() error
• type KafkaSourceConnection
  • func (c *KafkaSourceConnection) Close() error
  • func (c *KafkaSourceConnection) IsClosed() bool
  • func (c *KafkaSourceConnection) Publish(ctx context.Context, msg common.Message) error

Types

type KafkaSource

type KafkaSource struct {
	*base.Kafka
	// contains filtered or unexported fields
}

func NewKafkaSource

func NewKafkaSource(config *eventbusv1alpha1.KafkaBus, logger *zap.SugaredLogger) *KafkaSource

func (*KafkaSource) Connect

func (s *KafkaSource) Connect(string) (eventbuscommon.EventSourceConnection, error)

func (*KafkaSource) Initialize

func (s *KafkaSource) Initialize() error

type KafkaSourceConnection

type KafkaSourceConnection struct {
	*base.KafkaConnection
	Topic    string
	Client   sarama.Client
	Producer sarama.SyncProducer
}

func (*KafkaSourceConnection) Close

func (c *KafkaSourceConnection) Close() error

func (*KafkaSourceConnection) IsClosed

func (c *KafkaSourceConnection) IsClosed() bool

func (*KafkaSourceConnection) Publish

func (c *KafkaSourceConnection) Publish(ctx context.Context, msg common.Message) error