service

type EventConsumer interface {
	Close(ctx context.Context) (err error)
}

type ExternalServiceList struct {
	HealthCheck   bool
	KafkaConsumer bool
	S3Client      bool
	ESClient      bool
	ZebedeeClient bool
	Init          Initialiser
}

type HTTPServer interface {
	ListenAndServe() error
	Shutdown(ctx context.Context) error
}

type HealthChecker interface {
	Handler(w http.ResponseWriter, req *http.Request)
	Start(ctx context.Context)
	Stop()
	AddCheck(name string, checker healthcheck.Checker) (err error)
}

type Init struct{}

type Initialiser interface {
	DoGetHTTPServer(bindAddr string, router http.Handler) HTTPServer
	DoGetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (HealthChecker, error)
	DoGetKafkaConsumer(ctx context.Context, kafkaCfg *config.KafkaConfig) (kafka.IConsumerGroup, error)
	DoGetS3Client(cfg *config.S3Config) (sitemap.S3Client, error)
	DoGetESClients(ctx context.Context, cfg *config.OpenSearchConfig) (dpEsClient.Client, *es710.Client, error)
	DoGetZebedeeClient(cfg *config.Config) clients.ZebedeeClient
}

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