transform

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

type Option func(*Options)

type Options struct {
	// CloudFunctions enables support for cloud functions within the transform library.
	CloudFunctions bool

	// FetchConfigs enables support for fetch configurations wtihin the transform library.
	FetchConfigs bool

	// Parallel enables support for parallelization within the transform library.
	Parallel bool

	// GCSClient is a client for downloading from GCS. If unset, the default third party GCS client will be used.
	GCSClient gcsutil.StorageClient
}

type TransformationConfig struct {
	LogTrace     bool
	SkipBundling bool
}

type Transformer interface {
	// Transform transforms given JSONToken (parsed JSON) into a target JSONToken using the
	// config.
	Transform(jsonutil.JSONToken) (jsonutil.JSONToken, error)
	// JSONtoJSON transforms given raw JSON into a target raw JSON using the config.
	JSONtoJSON(json.RawMessage) (json.RawMessage, error)

	// ParseJSON parses given raw JSON into a JSONToken.
	ParseJSON(json.RawMessage) (jsonutil.JSONToken, error)

	// LoadProjectors registers all given projectors in the config.
	LoadProjectors([]*mappb.ProjectorDefinition) error

	// Registry returns the registry used in Transformer.
	Registry() *types.Registry

	// HasPostProcessProjector returns true iff a post process projector is set.
	HasPostProcessProjector() bool
}