internal

package

v0.0.0-...-8ad4bea Latest Latest Go to latest Published: Feb 29, 2024 License: MIT Imports: 11 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

type CloudEventsReader interface {
	Read(ctx context.Context) (cloudevents.Event, error)
}

type CloudEventsSender interface {
	Send(messages ...cloudevents.Event) error
}

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

func NewConsumer(eventReader CloudEventsReader, logger *Logger) Consumer

func (p Consumer) Run(ctx context.Context)

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

func NewKafkaCloudEventsReader(reader kafkaMessageReader) KafkaCloudEventsReader

func (r KafkaCloudEventsReader) Read(ctx context.Context) (cloudevents.Event, error)

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

func NewKafkaCloudEventsSender(conn kafkaWriteConn) KafkaCloudEventsSender

func (s KafkaCloudEventsSender) Send(messages ...cloudevents.Event) error

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

func NewLogger() *Logger

func (l *Logger) Error(args ...any)

func (l *Logger) Fatal(args ...any)

func (l *Logger) Info(args ...any)

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

func NewProducer(eventSender CloudEventsSender, logger *Logger) Producer

func (p Producer) Run(ctx context.Context)