download

Documentation

Index

• type GenerateDownloadsEvent
• type Generator
  • func (gen *Generator) Generate(ctx context.Context, datasetID string, instanceID string, edition string, ...) error
• type GeneratorError
  • func (genErr GeneratorError) Error() string
• type KafkaProducer

Types

type GenerateDownloadsEvent

type GenerateDownloadsEvent interface {
	Marshal(s interface{}) ([]byte, error)
}

GenerateDownloadsEvent marshal the event into avro format

type Generator

type Generator struct {
	Producer   KafkaProducer
	Marshaller GenerateDownloadsEvent
}

Generator kicks off a full dataset version download task

func (*Generator) Generate

func (gen *Generator) Generate(ctx context.Context, datasetID string, instanceID string, edition string, version string) error

Generate the full file download files for the specified dataset/edition/version

type GeneratorError

type GeneratorError struct {
	// contains filtered or unexported fields
}

GeneratorError is a wrapper for errors returned from the Generator

func (GeneratorError) Error

func (genErr GeneratorError) Error() string

Error return details about the error

type KafkaProducer

type KafkaProducer interface {
	Output() chan []byte
}

KafkaProducer sends an outbound kafka message