handler

Documentation

Index

• type CantabularClient
• type CantabularMetadataExport
  • func NewCantabularMetadataExport(cfg config.Config, d DatasetAPIClient, f FilterAPIClient, ...) *CantabularMetadataExport
  • func (h *CantabularMetadataExport) GetFilterDimensions(ctx context.Context, filterOutput filter.Model) ([]dataset.VersionDimension, error)
  • func (h *CantabularMetadataExport) Handle(ctx context.Context, _ int, msg kafka.Message) error
  • func (h *CantabularMetadataExport) UpdateFilterOutput(ctx context.Context, e *event.CSVCreated, csvwInfo, txtInfo *downloadInfo) error
  • func (h *CantabularMetadataExport) UpdateInstance(ctx context.Context, e *event.CSVCreated, csvwInfo, txtInfo *downloadInfo, ...) error
• type DatasetAPIClient
• type Error
  • func (e Error) Code() int
  • func (e Error) Error() string
  • func (e Error) LogData() map[string]interface{}
  • func (e Error) Response() string
  • func (e Error) Unwrap() error
• type FileManager
• type FilterAPIClient
• type Generator
• type PopulationTypesAPIClient

Types

type CantabularClient

type CantabularClient interface {
	GetDimensionsByName(context.Context, cantabular.GetDimensionsByNameRequest) (*cantabular.GetDimensionsResponse, error)
}

type CantabularMetadataExport

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

CantabularMetadataExport is the event handler for the CantabularMetadataExport event

func NewCantabularMetadataExport

func NewCantabularMetadataExport(cfg config.Config, d DatasetAPIClient, f FilterAPIClient, t PopulationTypesAPIClient, c CantabularClient, fm FileManager, p kafka.IProducer, g Generator) *CantabularMetadataExport

NewCantabularMetadataExport creates a new CantabularMetadataExportHandler

func (*CantabularMetadataExport) GetFilterDimensions

func (h *CantabularMetadataExport) GetFilterDimensions(ctx context.Context, filterOutput filter.Model) ([]dataset.VersionDimension, error)

func (*CantabularMetadataExport) Handle

func (h *CantabularMetadataExport) Handle(ctx context.Context, _ int, msg kafka.Message) error

Handle takes a single event

func (*CantabularMetadataExport) UpdateFilterOutput

func (h *CantabularMetadataExport) UpdateFilterOutput(ctx context.Context, e *event.CSVCreated, csvwInfo, txtInfo *downloadInfo) error

func (*CantabularMetadataExport) UpdateInstance

func (h *CantabularMetadataExport) UpdateInstance(ctx context.Context, e *event.CSVCreated, csvwInfo, txtInfo *downloadInfo, collectionID string) error

type DatasetAPIClient

type DatasetAPIClient interface {
	GetVersion(ctx context.Context, userAuthToken, serviceAuthToken, downloadServiceAuthToken, collectionID, datasetID, edition, version string) (dataset.Version, error)
	GetVersionMetadataSelection(ctx context.Context, req dataset.GetVersionMetadataSelectionInput) (*dataset.Metadata, error)
	GetVersionMetadata(ctx context.Context, userAuthToken, serviceAuthToken, collectionID, id, edition, version string) (dataset.Metadata, error)
	GetVersionDimensions(ctx context.Context, userAuthToken, serviceAuthToken, collectionID, id, edition, version string) (dataset.VersionDimensions, error)
	GetOptionsInBatches(ctx context.Context, userAuthToken, serviceAuthToken, collectionID, id, edition, version, dimension string, batchSize, maxWorkers int) (dataset.Options, error)
	PutVersion(ctx context.Context, usrAuthToken, svcAuthToken, collectionID, datasetID, edition, ver string, v dataset.Version) error
	GetMetadataURL(id, edition, version string) (url string)
}

type Error

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

Error is the packages error type

func (Error) Code

func (e Error) Code() int

Code satisfies the coder interface which is used to recover a HTTP status code from an error

func (Error) Error

func (e Error) Error() string

Error satisfies the standard library Go error interface

func (Error) LogData

func (e Error) LogData() map[string]interface{}

LogData satisfies the dataLogger interface which is used to recover log data from an error

func (Error) Response

func (e Error) Response() string

Response satisfies the responser interface which is used to specify a response to be sent to the caller in place of the error text for a given error. This is useful when you don't want sensitive information or implementation details being exposed to the caller which could be used to find exploits in our API

func (Error) Unwrap

func (e Error) Unwrap() error

Unwrap implements the standard library Go unwrapper interface

type FileManager

type FileManager interface {
	Upload(body io.Reader, filename string) (string, error)
	UploadPrivate(body io.Reader, filename, vaultPath string) (string, error)
}

type FilterAPIClient

type FilterAPIClient interface {
	UpdateFilterOutput(ctx context.Context, userAuthToken, serviceAuthToken, downloadServiceToken, filterOutputID string, m *filter.Model) error
	GetOutput(ctx context.Context, userAuthToken, serviceAuthToken, downloadServiceToken, collectionID, filterOutput string) (m filter.Model, err error)
}

type Generator

type Generator interface {
	Timestamp() time.Time
}

type PopulationTypesAPIClient

type PopulationTypesAPIClient interface {
	GetAreaTypes(ctx context.Context, input population.GetAreaTypesInput) (population.GetAreaTypesResponse, error)
}