service

Apr 15, 2020

Changes in this version

+ type DatasetClient interface

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

+ PostInstanceDimensions func(ctx context.Context, serviceAuthToken, instanceID string, ...) error

+ PutInstanceData func(ctx context.Context, serviceAuthToken, instanceID string, ...) error

+ type DimensionExtracted struct

+ FileURL string

+ InstanceID string

+ type InputFileAvailable struct

+ FileURL string

+ InstanceID string

+ func (inputFileAvailable *InputFileAvailable) S3URL() (*s3client.S3Url, error)

+ type KafkaProducer interface

+ Channels func() *kafka.ProducerChannels

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

+ type S3Client interface

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

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

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

+ type Service struct

+ AuthToken string

+ AwsSession *session.Session

+ DatasetClient DatasetClient

+ DimensionExtractedProducer KafkaProducer

+ EncryptionDisabled bool

+ S3Clients map[string]S3Client

+ VaultClient VaultClient

+ VaultPath string

+ func (svc *Service) HandleMessage(ctx context.Context, message kafka.Message) (string, error)

+ type VaultClient interface

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