Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ErrVaultFilenameEmpty = errors.New("vault filename required but was empty")
ErrVaultFilenameEmpty is an error returned when trying to obtain a PSK for an empty file name
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct {
// contains filtered or unexported fields
}
Consumer consumes event messages.
type Handler ¶
type Handler interface {
Handle(ctx context.Context, ImageUploaded *ImageUploaded) error
}
Handler represents a handler for processing a single event.
type ImageAPIClient ¶
type ImageAPIClient interface {
Checker(ctx context.Context, state *healthcheck.CheckState) error
PostDownloadVariant(ctx context.Context, userAuthToken, serviceAuthToken, collectionID, imageID string, data image.NewImageDownload) (image.ImageDownload, error)
PutDownloadVariant(ctx context.Context, userAuthToken, serviceAuthToken, collectionID, imageID, variant string, data image.ImageDownload) (image.ImageDownload, error)
}
ImageAPIClient defines the required methods from image API client
type ImageUploaded ¶
type ImageUploaded struct {
Path string `avro:"path"`
ImageID string `avro:"image_id"`
Filename string `avro:"filename"`
}
ImageUploaded provides an avro structure for an image uploaded event
type ImageUploadedHandler ¶
type ImageUploadedHandler struct {
AuthToken string
S3Upload S3Reader
S3Private S3Writer
VaultCli VaultClient
VaultPath string
ImageCli ImageAPIClient
DownloadServiceURL string
}
ImageUploadedHandler ...
func (*ImageUploadedHandler) Handle ¶
func (h *ImageUploadedHandler) Handle(ctx context.Context, event *ImageUploaded) (err error)
Handle takes a single event. It reads the PSK from Vault, uses it to decrypt the encrypted file from the uploaded S3 bucket, and writes it to the private bucket with a new vault psk for encryption. It also calls the API to create a new download variant and to update it after the variant has been imported.
type MessageConsumer ¶
type MessageConsumer interface {
Channels() *kafka.ConsumerGroupChannels
Release()
}
MessageConsumer provides a generic interface for consuming []byte messages
type S3Reader ¶
type S3Reader interface {
Checker(ctx context.Context, state *healthcheck.CheckState) error
Session() *session.Session
BucketName() string
Get(key string) (io.ReadCloser, *int64, error)
GetWithPSK(key string, psk []byte) (io.ReadCloser, *int64, error)
}
S3Reader defines the required methods from dp-s3 to read data to an AWS S3 Bucket
type S3Writer ¶
type S3Writer interface {
Checker(ctx context.Context, state *healthcheck.CheckState) error
Session() *session.Session
BucketName() string
Upload(input *s3manager.UploadInput, options ...func(*s3manager.Uploader)) (*s3manager.UploadOutput, error)
UploadWithPSK(input *s3manager.UploadInput, psk []byte) (*s3manager.UploadOutput, error)
}
S3Writer defines the required methods from dp-s3 to interact with a particular bucket of AWS S3
type VaultClient ¶
type VaultClient interface {
ReadKey(path, key string) (string, error)
WriteKey(path, key, value string) error
Checker(ctx context.Context, state *healthcheck.CheckState) error
}
VaultClient defines the required methods from dp-vault client
Source Files
Directories