Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

service

package

Go to main page

Versions in this module

v1

v1.0.0

May 27, 2022

Changes in this version

type DatasetAPIClient

+ GetVersionMetadataSelection func(context.Context, dataset.GetVersionMetadataSelectionInput) (*dataset.Metadata, error)

v0

v0.1.0

Jan 7, 2022

Changes in this version

+ const VaultRetries

+ var GetDatasetAPIClient = func(cfg *config.Config) DatasetAPIClient

+ var GetGenerator = func() Generator

+ var GetHTTPServer = func(bindAddr string, router http.Handler) HTTPServer

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

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

+ var GetKafkaProducer = func(ctx context.Context, cfg *config.Config) (kafka.IProducer, error)

+ var GetS3Clients = func(cfg *config.Config) (privateClient, publicClient S3Client, err error)

+ var GetVault = func(cfg *config.Config) (VaultClient, error)

+ var OneAndOnlyOneWorker int = 1

+ type DatasetAPIClient interface

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

+ GetInstance func(ctx context.Context, ...) (m dataset.Instance, eTag string, err error)

+ GetVersionMetadata func(ctx context.Context, ...) (dataset.Metadata, error)

+ PutVersion func(ctx context.Context, ...) error

+ type Generator interface

+ NewPSK func() ([]byte, 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()

+ SubscribeAll func(s healthcheck.Subscriber)

+ type Initialiser interface

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

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

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

+ type S3Client interface

+ BucketName func() string

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

+ Get func(key string) (io.ReadCloser, *int64, error)

+ GetWithPSK func(key string, psk []byte) (io.ReadCloser, *int64, error)

+ Head func(key string) (*s3.HeadObjectOutput, error)

+ Session func() *session.Session

+ UploadWithContext func(ctx context.Context, input *s3manager.UploadInput, ...) (*s3manager.UploadOutput, error)

+ UploadWithPSKAndContext func(ctx context.Context, input *s3manager.UploadInput, psk []byte, ...) (*s3manager.UploadOutput, error)

+ type Service struct

+ Cfg *config.Config

+ Consumer kafka.IConsumerGroup

+ DatasetAPIClient DatasetAPIClient

+ HealthCheck HealthChecker

+ Producer kafka.IProducer

+ S3Private S3Client

+ S3Public S3Client

+ Server HTTPServer

+ VaultClient VaultClient

+ func New() *Service

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

+ func (svc *Service) Init(ctx context.Context, cfg *config.Config, buildTime, gitCommit, version string) error

+ func (svc *Service) Start(ctx context.Context, svcErrors chan error)

+ type VaultClient interface

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

+ ReadKey func(path, key string) (string, error)

+ WriteKey func(path, key, value string) error