initialise

Documentation

Index

• Constants
• type ExternalServiceList
  • func NewServiceList(initialiser Initialiser) ExternalServiceList
  • func (e *ExternalServiceList) GetConsumer(ctx context.Context, cfg *config.Config) (kafkaConsumer kafka.IConsumerGroup, err error)
  • func (e *ExternalServiceList) GetGraphDB(ctx context.Context) (*graph.DB, error)
  • func (e *ExternalServiceList) GetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (healthcheck.HealthCheck, error)
  • func (e *ExternalServiceList) GetImportErrorReporter(observationsImportedErrProducer reporter.KafkaProducer, serviceName string) (errorReporter reporter.ImportErrorReporter, err error)
  • func (e *ExternalServiceList) GetProducer(ctx context.Context, kafkaBrokers []string, topic string, ...) (kafkaProducer kafka.IProducer, err error)
• type Init
  • func (i *Init) DoGetConsumer(ctx context.Context, topic, group string, kafkaConfig *config.KafkaConfig) (kafkaConsumer kafka.IConsumerGroup, err error)
  • func (i *Init) DoGetGraphDB(ctx context.Context) (*graph.DB, error)
  • func (i *Init) DoGetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (healthcheck.HealthCheck, error)
  • func (i *Init) DoGetImportErrorReporter(observationsImportedErrProducer reporter.KafkaProducer, serviceName string) (errorReporter reporter.ImportErrorReporter, err error)
  • func (i *Init) DoGetProducer(ctx context.Context, topic string, kafkaConfig *config.KafkaConfig) (kafkaProducer kafka.IProducer, err error)
• type Initialiser
• type KafkaProducerName
  • func (k KafkaProducerName) String() string

Constants

const (
	ObservationsImported = iota
	ObservationsImportedErr
)

Possible names of Kafka Producers

Types

type ExternalServiceList

type ExternalServiceList struct {
	Consumer                        bool
	ObservationsImportedProducer    bool
	ObservationsImportedErrProducer bool
	Graph                           bool
	ErrorReporter                   bool
	HealthCheck                     bool
	Init                            Initialiser
}

ExternalServiceList represents a list of services

func NewServiceList

func NewServiceList(initialiser Initialiser) ExternalServiceList

NewServiceList creates a new service list with the provided initialiser

func (*ExternalServiceList) GetConsumer

func (e *ExternalServiceList) GetConsumer(ctx context.Context, cfg *config.Config) (kafkaConsumer kafka.IConsumerGroup, err error)

GetConsumer returns a kafka consumer, which might not be initialised yet.

func (*ExternalServiceList) GetGraphDB

func (e *ExternalServiceList) GetGraphDB(ctx context.Context) (*graph.DB, error)

GetGraphDB returns a graphDB

func (*ExternalServiceList) GetHealthCheck

func (e *ExternalServiceList) GetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (healthcheck.HealthCheck, error)

GetHealthCheck creates a healthcheck with versionInfo

func (*ExternalServiceList) GetImportErrorReporter

func (e *ExternalServiceList) GetImportErrorReporter(observationsImportedErrProducer reporter.KafkaProducer, serviceName string) (errorReporter reporter.ImportErrorReporter, err error)

GetImportErrorReporter returns an ErrorImportReporter to send error reports to the import-reporter (only if ObservationsImportedErrProducer is available)

func (*ExternalServiceList) GetProducer

func (e *ExternalServiceList) GetProducer(ctx context.Context, kafkaBrokers []string, topic string, name KafkaProducerName, cfg *config.Config) (kafkaProducer kafka.IProducer, err error)

GetProducer returns a kafka producer, which might not be initialised yet.

type Init

type Init struct{}

Init implements the Initialiser interface to initialise dependencies

func (*Init) DoGetConsumer

func (i *Init) DoGetConsumer(ctx context.Context, topic, group string, kafkaConfig *config.KafkaConfig) (kafkaConsumer kafka.IConsumerGroup, err error)

func (*Init) DoGetGraphDB

func (i *Init) DoGetGraphDB(ctx context.Context) (*graph.DB, error)

func (*Init) DoGetHealthCheck

func (i *Init) DoGetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (healthcheck.HealthCheck, error)

func (*Init) DoGetImportErrorReporter

func (i *Init) DoGetImportErrorReporter(observationsImportedErrProducer reporter.KafkaProducer, serviceName string) (errorReporter reporter.ImportErrorReporter, err error)

func (*Init) DoGetProducer

func (i *Init) DoGetProducer(ctx context.Context, topic string, kafkaConfig *config.KafkaConfig) (kafkaProducer kafka.IProducer, err error)

type Initialiser

type Initialiser interface {
	DoGetConsumer(context.Context, string, string, *config.KafkaConfig) (kafka.IConsumerGroup, error)
	DoGetProducer(context.Context, string, *config.KafkaConfig) (kafka.IProducer, error)
	DoGetImportErrorReporter(reporter.KafkaProducer, string) (reporter.ImportErrorReporter, error)
	DoGetHealthCheck(*config.Config, string, string, string) (healthcheck.HealthCheck, error)
	DoGetGraphDB(context.Context) (*graph.DB, error)
}

type KafkaProducerName

type KafkaProducerName int

KafkaProducerName : Type for kafka producer name used by iota constants

func (KafkaProducerName) String

func (k KafkaProducerName) String() string

Values of the kafka producers names