initialise

Documentation

Index

• Constants
• type ExternalServiceList
  • func (e *ExternalServiceList) GetConsumer(ctx context.Context, cfg *config.Config) (kafkaConsumer *kafka.ConsumerGroup, err error)
  • func (e *ExternalServiceList) GetFileStore(cfg *config.Config, vaultClient *vault.Client) (fileStore *file.Store, err error)
  • func (e *ExternalServiceList) GetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (healthcheck.HealthCheck, error)
  • func (e *ExternalServiceList) GetObservationStore(ctx context.Context) (observationStore *graph.DB, err error)
  • func (e *ExternalServiceList) GetProducer(ctx context.Context, kafkaBrokers []string, topic, kafkaVersion string, ...) (kafkaProducer *kafka.Producer, err error)
  • func (e *ExternalServiceList) GetVault(cfg *config.Config, retries int) (client *vault.Client, err error)
• type KafkaProducerName
  • func (k KafkaProducerName) String() string

Constants

const (
	CSVExported = iota
	Error
)

Possible names of Kafka Producers

Types

type ExternalServiceList

type ExternalServiceList struct {
	Consumer            bool
	CSVExportedProducer bool
	ErrorProducer       bool
	EventConsumer       bool
	FileStore           bool
	ObservationStore    bool
	HealthCheck         bool
	Vault               bool
}

ExternalServiceList represents a list of services

func (*ExternalServiceList) GetConsumer

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

GetConsumer returns a kafka consumer, which might not be initialised

func (*ExternalServiceList) GetFileStore

func (e *ExternalServiceList) GetFileStore(cfg *config.Config, vaultClient *vault.Client) (fileStore *file.Store, err error)

GetFileStore returns an initialised connection to file store

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) GetObservationStore

func (e *ExternalServiceList) GetObservationStore(ctx context.Context) (observationStore *graph.DB, err error)

GetObservationStore returns an initialised connection to observation store (graph database)

func (*ExternalServiceList) GetProducer

func (e *ExternalServiceList) GetProducer(
	ctx context.Context,
	kafkaBrokers []string,
	topic, kafkaVersion string,
	kafkaSecProtocol, kafkaSecCACerts, kafkaSecClientCert, kafkaSecClientKey string, kafkaSecSkipVerify bool,
	name KafkaProducerName,
) (kafkaProducer *kafka.Producer, err error)

GetProducer returns a kafka producer, which might not be initialised

func (*ExternalServiceList) GetVault

func (e *ExternalServiceList) GetVault(cfg *config.Config, retries int) (client *vault.Client, err error)

GetVault returns a vault client

type KafkaProducerName

type KafkaProducerName int

KafkaProducerName represents a type for kafka producer name used by iota constants

func (KafkaProducerName) String

func (k KafkaProducerName) String() string

Values of the kafka producers names