injector

Documentation

Index

• func MakeKafkaConsumer(endpoints Endpoints, logger log.Logger, ...) (kafka.Consumer, error)
• type Endpoints
  • func MakeEndpoints(svc Service) Endpoints
• type Service
  • func NewService(logger log.Logger, metrics metrics.MetricsPublisher) Service

Functions

func MakeKafkaConsumer

func MakeKafkaConsumer(endpoints Endpoints, logger log.Logger, schemaRegistry *schema_registry.SchemaRegistry, kafkaConfig *kafka.Config) (kafka.Consumer, error)

Types

type Endpoints

type Endpoints interface {
	Insert() endpoint.Endpoint
}

func MakeEndpoints

func MakeEndpoints(svc Service) Endpoints

type Service

type Service interface {
	Insert(records []*models.Record) error
	ReadinessCheck() bool
}

func NewService

func NewService(logger log.Logger, metrics metrics.MetricsPublisher) Service