service

Jan 3, 2025

Changes in this version

type ExternalServiceList

+ S3Client bool

+ func (e *ExternalServiceList) GetS3Client(cfg *config.Config, bucketName string) (file.S3Client, error)

Mar 14, 2024

Changes in this version

type ExternalServiceList

+ FilesService bool

+ KafkaFilePublishedConsumer bool

+ KafkaImagePublishedConsumer bool

+ func (e *ExternalServiceList) GetFilesService(ctx context.Context, cfg *config.Config) file.FilesService

+ func (e *ExternalServiceList) GetKafkaFilePublishedConsumer(ctx context.Context, cfg *config.Config) (KafkaConsumer, error)

+ func (e *ExternalServiceList) GetKafkaImagePublishedConsumer(ctx context.Context, cfg *config.Config) (KafkaConsumer, error)

type Init

+ func (e *Init) DoGetFilesService(_ context.Context, cfg *config.Config) file.FilesService

+ func (e *Init) DoGetKafkaFilePublishedConsumer(ctx context.Context, cfg *config.Config) (KafkaConsumer, error)

+ func (e *Init) DoGetKafkaImagePublishedConsumer(ctx context.Context, cfg *config.Config) (KafkaConsumer, error)

+ func (e *Init) DoGetKafkaTopicConsumer(ctx context.Context, cfg *config.Config, topic string) (KafkaConsumer, error)

type Initialiser

+ DoGetFilesService func(ctx context.Context, cfg *config.Config) file.FilesService

+ DoGetKafkaFilePublishedConsumer func(ctx context.Context, cfg *config.Config) (KafkaConsumer, error)

+ DoGetKafkaImagePublishedConsumer func(ctx context.Context, cfg *config.Config) (KafkaConsumer, error)

type KafkaConsumer

+ RegisterBatchHandler func(ctx context.Context, batchHandler kafka.BatchHandler) error

+ Start func() error

+ StateWait func(state kafka.State)

+ Stop func() error

type Service

+ FilesClient file.FilesService

+ KafkaFilePublishedConsumer KafkaConsumer

+ KafkaImagePublishedConsumer KafkaConsumer

May 23, 2022

Changes in this version

type ExternalServiceList

+ KafkaConsumerV3Published bool

+ S3ClientV2 bool

+ func (e *ExternalServiceList) GetKafkaConsumerV3(ctx context.Context, cfg *config.Config) (KafkaConsumerV3, error)

+ func (e *ExternalServiceList) GetS3ClientV2(cfg *config.Config, bucketName string) (file.S3ClientV2, error)

type Init

+ func (e *Init) DoGetKafkaV3Consumer(ctx context.Context, cfg *config.Config) (KafkaConsumerV3, error)

+ func (e *Init) DoGetS3ClientV2(awsRegion, bucketName string) (file.S3ClientV2, error)

type Initialiser

+ DoGetKafkaV3Consumer func(ctx context.Context, cfg *config.Config) (KafkaConsumerV3, error)

+ DoGetS3ClientV2 func(awsRegion, bucketName string) (file.S3ClientV2, error)

+ type KafkaConsumerV3 interface

+ RegisterHandler func(ctx context.Context, h kafkaV3.Handler) error

+ Start func() error

Aug 26, 2021

Changes in this version

type KafkaConsumer

+ Initialise func(ctx context.Context) error

+ IsInitialised func() bool

type Service

+ KafkaConsumerGroup KafkaConsumer

Dec 8, 2020

Changes in this version

type ExternalServiceList

+ ImageAPI bool

+ Vault bool

type Init

+ func (e *Init) DoGetS3ClientWithSession(bucketName string, encryptionEnabled bool, s *session.Session) event.S3Reader

type Initialiser

+ DoGetS3ClientWithSession func(bucketName string, encryptionEnabled bool, s *session.Session) event.S3Reader

+ type KafkaConsumer interface

+ Channels func() *kafka.ConsumerGroupChannels

+ Checker func(ctx context.Context, state *healthcheck.CheckState) error

+ Close func(ctx context.Context) (err error)

+ Release func()

+ StopListeningToConsumer func(ctx context.Context) (err error)

Jul 10, 2020

Changes in this version

+ type EventConsumer interface

+ Close func(ctx context.Context) (err error)

+ Consume func(ctx context.Context, messageConsumer event.MessageConsumer, ...)

type ExternalServiceList

+ S3Private bool

+ S3Public bool

+ func (e *ExternalServiceList) GetS3Clients(cfg *config.Config) (s3Public event.S3Uploader, s3Private event.S3Client, err error)

type Init

+ func (e *Init) DoGetS3Client(awsRegion, bucketName string, encryptionEnabled bool) (event.S3Client, error)

+ func (e *Init) DoGetS3UploaderWithSession(bucketName string, encryptionEnabled bool, s *session.Session) event.S3Uploader

type Initialiser

+ DoGetS3Client func(awsRegion, bucketName string, encryptionEnabled bool) (event.S3Client, error)

+ DoGetS3UploaderWithSession func(bucketName string, encryptionEnabled bool, s *session.Session) event.S3Uploader

type Service

+ EventConsumer EventConsumer

+ S3Private event.S3Client

+ S3Public event.S3Uploader

Jun 19, 2020

Changes in this version

type ExternalServiceList

+ KafkaConsumerPublished bool

+ func (e *ExternalServiceList) GetImageAPIClient(cfg *config.Config) ImageAPIClient

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

+ func (e *ExternalServiceList) GetVault(cfg *config.Config) (VaultClient, error)

+ type ImageAPIClient interface

+ Checker func(ctx context.Context, state *healthcheck.CheckState) error

type Init

+ func (e *Init) DoGetImageAPIClient(imageAPIURL string) ImageAPIClient

+ func (e *Init) DoGetKafkaConsumer(ctx context.Context, cfg *config.Config) (kafka.IConsumerGroup, error)

+ func (e *Init) DoGetVault(vaultToken, vaultAddress string, retries int) (VaultClient, error)

type Initialiser

+ DoGetImageAPIClient func(imageAPIURL string) ImageAPIClient

+ DoGetKafkaConsumer func(ctx context.Context, cfg *config.Config) (kafka.IConsumerGroup, error)

+ DoGetVault func(vaultToken, vaultAddress string, retries int) (VaultClient, error)

type Service

+ ImageAPICli ImageAPIClient

+ KafkaConsumer kafka.IConsumerGroup

+ VaultCli VaultClient

+ type VaultClient interface

+ Checker func(ctx context.Context, state *healthcheck.CheckState) error

Jun 12, 2020

Changes in this version

+ type ExternalServiceList struct

+ HealthCheck bool

+ Init Initialiser

+ func NewServiceList(initialiser Initialiser) *ExternalServiceList

+ func (e *ExternalServiceList) GetHTTPServer(bindAddr string, router http.Handler) HTTPServer

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

+ type HTTPServer interface

+ ListenAndServe func() error

+ Shutdown func(ctx context.Context) error

+ type HealthChecker interface

+ AddCheck func(name string, checker healthcheck.Checker) (err error)

+ Handler func(w http.ResponseWriter, req *http.Request)

+ Start func(ctx context.Context)

+ Stop func()

+ type Init struct

+ func (e *Init) DoGetHTTPServer(bindAddr string, router http.Handler) HTTPServer

+ func (e *Init) DoGetHealthCheck(cfg *config.Config, buildTime, gitCommit, version string) (HealthChecker, error)

+ type Initialiser interface

+ DoGetHTTPServer func(bindAddr string, router http.Handler) HTTPServer

+ DoGetHealthCheck func(cfg *config.Config, buildTime, gitCommit, version string) (HealthChecker, error)

+ type Service struct

+ API *api.API

+ Config *config.Config

+ HealthCheck HealthChecker

+ Router *mux.Router

+ Server HTTPServer

+ ServiceList *ExternalServiceList

+ func Run(ctx context.Context, cfg *config.Config, serviceList *ExternalServiceList, ...) (*Service, error)

+ func (svc *Service) Close(ctx context.Context) error