userconfig

package

Go to main page

Versions in this module

v0

v0.12.0

Dec 26, 2019

Changes in this version

+ const ConfigKey

+ const EnvKey

+ func ErrorFieldMustBeDefinedForPredictorType(fieldKey string, predictorType PredictorType) error

+ func ErrorFieldNotSupportedByPredictorType(fieldKey string, predictorType PredictorType) error

+ func PredictorTypeStrings() []string

type ErrorKind

+ const ErrFieldMustBeDefinedForPredictorType

+ const ErrFieldNotSupportedByPredictorType

type Predictor

+ Config map[string]interface{}

+ Env map[string]string

+ SignatureKey *string

+ Type PredictorType

+ func (predictor *Predictor) ONNXValidate() error

+ func (predictor *Predictor) PythonValidate() error

+ func (predictor *Predictor) TensorFlowValidate() error

+ type PredictorType int

+ const ONNXPredictorType

+ const PythonPredictorType

+ const TensorFlowPredictorType

+ const UnknownPredictorType

+ func PredictorTypeFromString(s string) PredictorType

+ func (t *PredictorType) UnmarshalBinary(data []byte) error

+ func (t *PredictorType) UnmarshalText(text []byte) error

+ func (t PredictorType) MarshalBinary() ([]byte, error)

+ func (t PredictorType) MarshalText() ([]byte, error)

+ func (t PredictorType) String() string

v0.11.1

Dec 12, 2019

v0.11.0

Nov 28, 2019

v0.10.3

Nov 21, 2019

v0.10.2

Nov 15, 2019

v0.10.1

Nov 11, 2019

v0.10.0

Nov 5, 2019

Changes in this version

+ const EndpointKey

+ const MetadataKey

+ const ONNXKey

+ const PredictorKey

+ const PythonPathKey

+ const SignatureKeyKey

+ const TensorFlowKey

+ func ErrorDuplicateEndpoints(endpoint string, apiNames ...string) error

+ func ErrorSpecifyOneModelFormatFoundMultiple(found []string, vals ...string) error

+ func ErrorSpecifyOneModelFormatFoundNone(vals ...string) error

+ func ValidatePythonPath(path string, projectFileMap map[string][]byte) error

type API

+ Endpoint *string

+ ONNX *ONNX

+ Predictor *Predictor

+ TensorFlow *TensorFlow

type ErrorKind

+ const ErrDuplicateEndpoints

+ const ErrSpecifyOneModelFormatFoundMultiple

+ const ErrSpecifyOneModelFormatFoundNone

+ type ONNX struct

+ Metadata map[string]interface{}

+ Model string

+ PythonPath *string

+ RequestHandler *string

+ func (onnx *ONNX) UserConfigStr() string

+ func (onnx *ONNX) Validate(projectFileMap map[string][]byte) error

+ type Predictor struct

+ Metadata map[string]interface{}

+ Model *string

+ Path string

+ PythonPath *string

+ func (predictor *Predictor) UserConfigStr() string

+ func (predictor *Predictor) Validate(projectFileMap map[string][]byte) error

+ type TensorFlow struct

+ Metadata map[string]interface{}

+ Model string

+ PythonPath *string

+ RequestHandler *string

+ SignatureKey *string

+ func (tf *TensorFlow) UserConfigStr() string

+ func (tf *TensorFlow) Validate(projectFileMap map[string][]byte) error

v0.9.2

Nov 1, 2019

v0.9.1

Oct 31, 2019

v0.9.0

Oct 15, 2019

Changes in this version

+ func ErrorInvalidTensorFlowDir(path string) error

type ErrorKind

+ const ErrInvalidTensorFlowDir

v0.8.0

Sep 24, 2019

Changes in this version

+ const KeyKey

+ const ModelTypeKey

+ const TFSignatureKeyKey

+ const TrackerKey

+ func ErrorIncompatibleWithModelFormat(configKey string, format ModelFormat) error

+ func ErrorInvalidTensorflowDir(path string) error

+ func ErrorONNXDoesntSupportZip() error

+ func GetTFServingExportFromS3Path(path string, awsClient *aws.Client) (string, error)

+ func IsValidTensorFlowS3Directory(path string, awsClient *aws.Client) bool

+ func ModelTypeStrings() []string

type API

+ TFSignatureKey *string

+ Tracker *Tracker

+ func (api *API) AreProjectFilesRequired() bool

type APIs

+ func (apis APIs) AreProjectFilesRequired() bool

type Config

+ func ReadConfigFile(filePath string, relativePath string) (*Config, error)

+ func (config *Config) AreProjectFilesRequired() bool

type ErrorKind

+ const ErrIncompatibleWithModelFormat

+ const ErrInvalidTensorflowDir

+ const ErrONNXDoesntSupportZip

+ type ModelType int

+ const ClassificationModelType

+ const RegressionModelType

+ const UnknownModelType

+ func ModelTypeFromString(s string) ModelType

+ func (t *ModelType) UnmarshalBinary(data []byte) error

+ func (t *ModelType) UnmarshalText(text []byte) error

+ func (t ModelType) MarshalBinary() ([]byte, error)

+ func (t ModelType) MarshalText() ([]byte, error)

+ func (t ModelType) String() string

+ type Tracker struct

+ Key *string

+ ModelType ModelType

+ func (tracker *Tracker) UserConfigStr() string

v0.7.3

Aug 20, 2019

v0.7.2

Aug 14, 2019

v0.7.1

Aug 9, 2019

v0.7.0

Jul 30, 2019

Changes in this version

+ func ErrorUnableToInferModelFormat() error

type ErrorKind

+ const ErrUnableToInferModelFormat

v0.6.0

Jul 8, 2019

Changes in this version

+ const InitReplicasKey

+ const MaxReplicasKey

+ const MinReplicasKey

+ const ModelFormatKey

+ const RequestHandlerKey

+ const TargetCPUUtilizationKey

+ func ErrorInitReplicasGreaterThanMax(init int32, max int32) error

+ func ErrorInitReplicasLessThanMin(init int32, min int32) error

+ func ErrorMinReplicasGreaterThanMax(min int32, max int32) error

+ func ModelFormatStrings() []string

type API

+ ModelFormat ModelFormat

+ RequestHandler *string

type APICompute

+ InitReplicas int32

+ MaxReplicas int32

+ MinReplicas int32

+ TargetCPUUtilization int32

+ func (ac *APICompute) Validate() error

type ErrorKind

+ const ErrInitReplicasGreaterThanMax

+ const ErrInitReplicasLessThanMin

+ const ErrMinReplicasGreaterThanMax

+ type ModelFormat int

+ const ONNXModelFormat

+ const TensorFlowModelFormat

+ const UnknownModelFormat

+ func ModelFormatFromString(s string) ModelFormat

+ func (t *ModelFormat) UnmarshalBinary(data []byte) error

+ func (t *ModelFormat) UnmarshalText(text []byte) error

+ func (t ModelFormat) MarshalBinary() ([]byte, error)

+ func (t ModelFormat) MarshalText() ([]byte, error)

+ func (t ModelFormat) String() string

type QuantityValidation

+ GreaterThan *k8sresource.Quantity

+ GreaterThanOrEqualTo *k8sresource.Quantity

+ LessThan *k8sresource.Quantity

+ LessThanOrEqualTo *k8sresource.Quantity

v0.5.0

Jun 27, 2019

Changes in this version

+ const CPUKey

+ const DriverCPUKey

+ const DriverMemKey

+ const DriverMemOverheadKey

+ const ExecutorCPUKey

+ const ExecutorMemKey

+ const ExecutorMemOverheadKey

+ const ExecutorsKey

+ const GPUKey

+ const MemKey

+ const MemOverheadFactorKey

+ const ReplicasKey

+ func ErrorInvalidS3PathOrResourceReference(provided string) error

type API

+ func (api *API) UserConfigStr() string

type APICompute

+ func (apiCompute *APICompute) UserConfigStr() string

type Aggregate

+ func (aggregate *Aggregate) UserConfigStr() string

type CSVData

+ Path string

+ func (csvData *CSVData) GetPath() string

type Constant

+ Path *string

type Data

+ GetPath func() string

type ErrorKind

+ const ErrInvalidS3PathOrResourceReference

type Model

+ func (model *Model) UserConfigStr() string

type ModelDataPartitionRatio

+ func (mdpr *ModelDataPartitionRatio) UserConfigStr() string

type ModelEvaluation

+ func (me *ModelEvaluation) UserConfigStr() string

type ModelTraining

+ func (mt *ModelTraining) UserConfigStr() string

type ParquetData

+ Path string

+ func (parqData *ParquetData) GetPath() string

type RawFloatColumn

+ func (column *RawFloatColumn) UserConfigStr() string

type RawInferredColumn

+ func (column *RawInferredColumn) UserConfigStr() string

type RawIntColumn

+ func (column *RawIntColumn) UserConfigStr() string

type RawStringColumn

+ func (column *RawStringColumn) UserConfigStr() string

type ResourceFields

+ func (resourceFields *ResourceFields) UserConfigStr() string

type SparkCompute

+ func (sparkCompute *SparkCompute) UserConfigStr() string

type TFCompute

+ func (tfCompute *TFCompute) UserConfigStr() string

type TransformedColumn

+ func (column *TransformedColumn) UserConfigStr() string

v0.4.1

Jun 17, 2019

Changes in this version

+ const ExternalKey

+ func ErrorExternalNotFound(path string) error

type Constant

+ External *ExternalConstant

type ErrorKind

+ const ErrExternalNotFound

+ type ExternalConstant struct

+ Path string

+ Region string

v0.4.0

Jun 14, 2019

Changes in this version

+ const AggregatorKey

+ const AggregatorPathKey

+ const ArgsKey

+ const BatchSizeKey

+ const ComputeKey

+ const DataKey

+ const DataPartitionRatioKey

+ const DatasetComputeKey

+ const DefaultOptKey

+ const EstimatorKey

+ const EstimatorPathKey

+ const EvaluationKey

+ const ExternalModelKey

+ const FractionOfRowsKey

+ const HparamsKey

+ const InputKey

+ const KeepCheckpointEveryNHoursKey

+ const KeepCheckpointMaxKey

+ const KindKey

+ const LimitKey

+ const LogLevelKey

+ const LogStepCountStepsKey

+ const MaxCountOptKey

+ const MaxKey

+ const MinCountOptKey

+ const MinKey

+ const ModelKey

+ const ModelNameKey

+ const NameKey

+ const NumEpochsKey

+ const NumRowsKey

+ const NumStepsKey

+ const OptionalOptKey

+ const OutputTypeKey

+ const PathKey

+ const PredictionKeyKey

+ const RandomSeedKey

+ const RandomizeKey

+ const RequiredKey

+ const SaveCheckpointsSecsKey

+ const SaveCheckpointsStepsKey

+ const SaveSummaryStepsKey

+ const SchemaKey

+ const ShuffleKey

+ const StartDelaySecsKey

+ const TagsKey

+ const TargetColumnKey

+ const TemplateKey

+ const TfRandomSeedKey

+ const TfRandomizeSeedKey

+ const ThrottleSecsKey

+ const TrainingInputKey

+ const TrainingKey

+ const TransformerKey

+ const TransformerPathKey

+ const TypeKey

+ const UnknownKey

+ const ValueKey

+ const ValuesKey

+ const YAMLKey

+ func CastInputValue(value interface{}, inputSchema *InputSchema) (interface{}, error)

+ func CastOutputValue(value interface{}, outputSchema OutputSchema) (interface{}, error)

+ func DataTypeStr(dataType interface{}) string

+ func DataTypeStrsOr(dataTypes []interface{}) string

+ func DataTypeUserStr(dataType interface{}) string

+ func EnvironmentDataTypeStrings() []string

+ func ErrorCannotBeNull() error

+ func ErrorCannotMixValueAndColumnTypes(provided interface{}) error

+ func ErrorColumnTypeLiteral(provided interface{}) error

+ func ErrorColumnTypeNotAllowed(provided interface{}) error

+ func ErrorCompoundTypeInOutputType(provided interface{}) error

+ func ErrorDuplicateConfig(resourceType resource.Type) error

+ func ErrorDuplicateResourceName(resources ...Resource) error

+ func ErrorDuplicateResourceValue(value string, keys ...string) error

+ func ErrorDuplicateTypeInTypeString(duplicated string, provided string) error

+ func ErrorEnvSchemaMismatch(env1, env2 *Environment) error

+ func ErrorExternalModelNotFound(path string) error

+ func ErrorExtraResourcesWithExternalAPIs(res Resource) error

+ func ErrorGenericTypeMapLength(provided interface{}) error

+ func ErrorImplDoesNotExist(path string) error

+ func ErrorInvalidCompoundType(provided interface{}) error

+ func ErrorInvalidInputType(provided interface{}) error

+ func ErrorInvalidOutputType(provided interface{}) error

+ func ErrorK8sQuantityMustBeInt(quantityStr string) error

+ func ErrorMalformedConfig() error

+ func ErrorMinCountGreaterThanMaxCount() error

+ func ErrorMissingAppDefinition() error

+ func ErrorMixedInputArgOptionsAndUserKeys() error

+ func ErrorMustBeDefined(allowedType interface{}) error

+ func ErrorOneOfPrerequisitesNotDefined(argName string, prerequisites ...string) error

+ func ErrorOptionOnNonIterable(key string) error

+ func ErrorParseConfig() error

+ func ErrorPredictionKeyOnModelWithEstimator() error

+ func ErrorRawColumnNotInEnv(envName string) error

+ func ErrorReadConfig() error

+ func ErrorResourceWrongType(resources []Resource, validResourceTypes ...resource.Type) error

+ func ErrorSpecifyAllOrNone(vals ...string) error

+ func ErrorSpecifyOnlyOne(vals ...string) error

+ func ErrorSpecifyOnlyOneMissing(vals ...string) error

+ func ErrorTemplateExtraArg(template *Template, argName string) error

+ func ErrorTemplateMissingArg(template *Template, argName string) error

+ func ErrorTooFewElements(t configreader.PrimitiveType, minCount int64) error

+ func ErrorTooManyElements(t configreader.PrimitiveType, maxCount int64) error

+ func ErrorTypeListLength(provided interface{}) error

+ func ErrorTypeMapZeroLength(provided interface{}) error

+ func ErrorUndefinedConfig(resourceType resource.Type) error

+ func ErrorUndefinedResource(resourceName string, resourceTypes ...resource.Type) error

+ func ErrorUnsupportedConfigKey() error

+ func ErrorUnsupportedLiteralMapKey(key interface{}, allowedType interface{}) error

+ func ErrorUnsupportedLiteralType(provided interface{}, allowedType interface{}) error

+ func ErrorUnsupportedOutputType(provided interface{}, allowedType interface{}) error

+ func ErrorUserKeysCannotStartWithUnderscore(key string) error

+ func Identify(r Resource) string

+ func QuantityParser(v *QuantityValidation) func(string) (interface{}, error)

+ func QuantityPtrID(quantity *Quantity) string

+ func QuantityPtrsEqual(quantity *Quantity, quantity2 *Quantity) bool

+ func ReadAppName(filePath string, relativePath string) (string, error)

+ func ValidColumnTypeStrings() []string

+ func ValueTypeStrings() []string

+ type API struct

+ Compute *APICompute

+ ExternalModel *ExternalModel

+ Model *string

+ Tags Tags

+ func (api *API) GetResourceType() resource.Type

+ func (api *API) Validate() error

+ type APICompute struct

+ CPU *Quantity

+ GPU int64

+ Mem *Quantity

+ Replicas int32

+ func (apiCompute *APICompute) Equal(apiCompute2 APICompute) bool

+ func (apiCompute *APICompute) ID() string

+ func (apiCompute *APICompute) IDWithoutReplicas() string

+ type APIs []*API

+ func (apis APIs) Names() []string

+ func (apis APIs) Validate() error

+ type Aggregate struct

+ Aggregator string

+ AggregatorPath *string

+ Compute *SparkCompute

+ Input interface{}

+ Tags Tags

+ func (aggregate *Aggregate) GetResourceType() resource.Type

+ func (aggregate *Aggregate) Validate() error

+ type Aggregates []*Aggregate

+ func (aggregates Aggregates) Get(name string) *Aggregate

+ func (aggregates Aggregates) Names() []string

+ func (aggregates Aggregates) Validate() error

+ type Aggregator struct

+ Input *InputSchema

+ OutputType OutputSchema

+ Path string

+ func (aggregator *Aggregator) GetResourceType() resource.Type

+ type Aggregators []*Aggregator

+ func (aggregators Aggregators) Get(name string) *Aggregator

+ func (aggregators Aggregators) Names() []string

+ func (aggregators Aggregators) Validate() error

+ type App struct

+ Name string

+ func (app *App) Validate() error

+ type CSVConfig struct

+ CharToEscapeQuoteEscaping *string

+ Comment *string

+ EmptyValue *string

+ Encoding *string

+ Escape *string

+ Header *bool

+ IgnoreLeadingWhiteSpace *bool

+ IgnoreTrailingWhiteSpace *bool

+ MaxCharsPerColumn *int32

+ MaxColumns *int32

+ Multiline *bool

+ NanValue *string

+ NegativeInf *string

+ NullValue *string

+ PositiveInf *string

+ Quote *string

+ Sep *string

+ type CSVData struct

+ CSVConfig *CSVConfig

+ DropNull bool

+ Schema []string

+ Type EnvironmentDataType

+ func (csvData *CSVData) GetExternalData() ExternalData

+ func (csvData *CSVData) GetIngestedColumnNames() []string

+ func (csvData *CSVData) Validate() error

+ type Column interface

+ IsRaw func() bool

+ type ColumnType int

+ const FloatColumnType

+ const FloatListColumnType

+ const InferredColumnType

+ const IntegerColumnType

+ const IntegerListColumnType

+ const StringColumnType

+ const StringListColumnType

+ const UnknownColumnType

+ func ColumnTypeFromString(s string) ColumnType

+ func (t *ColumnType) UnmarshalBinary(data []byte) error

+ func (t *ColumnType) UnmarshalText(text []byte) error

+ func (t ColumnType) JSONPlaceholder() string

+ func (t ColumnType) MarshalBinary() ([]byte, error)

+ func (t ColumnType) MarshalText() ([]byte, error)

+ func (t ColumnType) String() string

+ type ColumnTypes []ColumnType

+ func (ts ColumnTypes) String() string

+ func (ts ColumnTypes) StringList() []string

+ type CompoundType string

+ func CompoundTypeFromString(val interface{}) (CompoundType, error)

+ func (compoundType *CompoundType) CastValue(value interface{}) (interface{}, error)

+ func (compoundType *CompoundType) IsColumns() bool

+ func (compoundType *CompoundType) IsValues() bool

+ func (compoundType *CompoundType) String() string

+ func (compoundType *CompoundType) SupportsType(t interface{}) bool

+ type Config struct

+ APIs APIs

+ Aggregates Aggregates

+ Aggregators Aggregators

+ App *App

+ Constants Constants

+ Embeds Embeds

+ Environment *Environment

+ Environments Environments

+ Estimators Estimators

+ Models Models

+ RawColumns RawColumns

+ Resources map[string][]Resource

+ Templates Templates

+ TransformedColumns TransformedColumns

+ Transformers Transformers

+ func New(configs map[string][]byte, envName string) (*Config, error)

+ func NewPartialPath(filePath string) (*Config, error)

+ func (config *Config) ColumnNames() []string

+ func (config *Config) IsRawColumn(name string) bool

+ func (config *Config) IsTransformedColumn(name string) bool

+ func (config *Config) MergeBytes(configBytes []byte, filePath string, emb *Embed, template *Template) (*Config, error)

+ func (config *Config) Validate(envName string) error

+ func (config *Config) ValidatePartial() error

+ type Constant struct

+ Tags Tags

+ Type OutputSchema

+ Value interface{}

+ func (constant *Constant) GetResourceType() resource.Type

+ func (constant *Constant) Validate() error

+ type Constants []*Constant

+ func (constants Constants) Names() []string

+ func (constants Constants) Validate() error

+ type Data interface

+ GetExternalData func() ExternalData

+ GetIngestedColumnNames func() []string

+ Validate func() error

+ type Embed struct

+ Args map[string]interface{}

+ Template string

+ func (embed *Embed) GetResourceType() resource.Type

+ type Embeds []*Embed

+ type Environment struct

+ Data Data

+ Limit *Limit

+ LogLevel *LogLevel

+ func (env *Environment) GetResourceType() resource.Type

+ func (env *Environment) Validate() error

+ type EnvironmentDataType int

+ const CSVEnvironmentDataType

+ const ParquetEnvironmentDataType

+ const UnknownEnvironmentDataType

+ func EnvironmentDataTypeFromString(s string) EnvironmentDataType

+ func (t *EnvironmentDataType) UnmarshalBinary(data []byte) error

+ func (t *EnvironmentDataType) UnmarshalText(text []byte) error

+ func (t EnvironmentDataType) MarshalBinary() ([]byte, error)

+ func (t EnvironmentDataType) MarshalText() ([]byte, error)

+ func (t EnvironmentDataType) String() string

+ type Environments []*Environment

+ func (environments Environments) Names() []string

+ func (environments Environments) Validate() error

+ type Error struct

+ Kind ErrorKind

+ func (e Error) Error() string

+ type ErrorKind int

+ const ErrCannotBeNull

+ const ErrCannotMixValueAndColumnTypes

+ const ErrColumnTypeLiteral

+ const ErrColumnTypeNotAllowed

+ const ErrCompoundTypeInOutputType

+ const ErrDuplicateConfig

+ const ErrDuplicateResourceName

+ const ErrDuplicateResourceValue

+ const ErrDuplicateTypeInTypeString

+ const ErrEnvSchemaMismatch

+ const ErrExternalModelNotFound

+ const ErrExtraResourcesWithExternalAPIs

+ const ErrGenericTypeMapLength

+ const ErrImplDoesNotExist

+ const ErrInvalidCompoundType

+ const ErrInvalidInputType

+ const ErrInvalidOutputType

+ const ErrK8sQuantityMustBeInt

+ const ErrMalformedConfig

+ const ErrMinCountGreaterThanMaxCount

+ const ErrMissingAppDefinition

+ const ErrMixedInputArgOptionsAndUserKeys

+ const ErrMustBeDefined

+ const ErrOneOfPrerequisitesNotDefined

+ const ErrOptionOnNonIterable

+ const ErrParseConfig

+ const ErrPredictionKeyOnModelWithEstimator

+ const ErrRawColumnNotInEnv

+ const ErrReadConfig

+ const ErrResourceWrongType

+ const ErrSpecifyAllOrNone

+ const ErrSpecifyOnlyOne

+ const ErrSpecifyOnlyOneMissing

+ const ErrTemplateExtraArg

+ const ErrTemplateMissingArg

+ const ErrTooFewElements

+ const ErrTooManyElements

+ const ErrTypeListLength

+ const ErrTypeMapZeroLength

+ const ErrUndefinedConfig

+ const ErrUndefinedResource

+ const ErrUnknown

+ const ErrUnsupportedConfigKey

+ const ErrUnsupportedLiteralMapKey

+ const ErrUnsupportedLiteralType

+ const ErrUnsupportedOutputType

+ const ErrUserKeysCannotStartWithUnderscore

+ func (t *ErrorKind) UnmarshalBinary(data []byte) error

+ func (t *ErrorKind) UnmarshalText(text []byte) error

+ func (t ErrorKind) MarshalBinary() ([]byte, error)

+ func (t ErrorKind) MarshalText() ([]byte, error)

+ func (t ErrorKind) String() string

+ type Estimator struct

+ Hparams *InputSchema

+ Input *InputSchema

+ Path string

+ PredictionKey string

+ TargetColumn *CompoundType

+ TrainingInput *InputSchema

+ func (estimator *Estimator) GetResourceType() resource.Type

+ type Estimators []*Estimator

+ func (estimators Estimators) Get(name string) *Estimator

+ func (estimators Estimators) Names() []string

+ func (estimators Estimators) Validate() error

+ type ExternalData struct

+ Path string

+ Region string

+ type ExternalModel struct

+ Path string

+ Region string

+ type InputSchema struct

+ AllowNull bool

+ Default interface{}

+ MaxCount *int64

+ MinCount *int64

+ Optional bool

+ Type InputTypeSchema

+ func ValidateInputSchema(in interface{}, disallowColumnTypes bool, isAlreadyParsed bool) (*InputSchema, error)

+ type InputTypeSchema interface

+ func ValidateInputTypeSchema(in interface{}, disallowColumnTypes bool, isAlreadyParsed bool) (InputTypeSchema, error)

+ type Limit struct

+ FractionOfRows *float32

+ NumRows *int64

+ RandomSeed *int64

+ Randomize *bool

+ type LogLevel struct

+ Spark string

+ Tensorflow string

+ type Model struct

+ Compute *TFCompute

+ DataPartitionRatio *ModelDataPartitionRatio

+ DatasetCompute *SparkCompute

+ Estimator string

+ EstimatorPath *string

+ Evaluation *ModelEvaluation

+ Hparams interface{}

+ Input interface{}

+ PredictionKey string

+ Tags Tags

+ TargetColumn string

+ Training *ModelTraining

+ TrainingInput interface{}

+ func (model *Model) GetResourceType() resource.Type

+ func (model *Model) Validate() error

+ type ModelDataPartitionRatio struct

+ Evaluation *float64

+ Training *float64

+ type ModelEvaluation struct

+ BatchSize int64

+ NumEpochs *int64

+ NumSteps *int64

+ Shuffle bool

+ StartDelaySecs int64

+ ThrottleSecs int64

+ type ModelTraining struct

+ BatchSize int64

+ KeepCheckpointEveryNHours int64

+ KeepCheckpointMax int64

+ LogStepCountSteps int64

+ NumEpochs *int64

+ NumSteps *int64

+ SaveCheckpointsSecs *int64

+ SaveCheckpointsSteps *int64

+ SaveSummarySteps int64

+ Shuffle bool

+ TfRandomSeed int64

+ TfRandomizeSeed bool

+ type Models []*Model

+ func (models Models) Names() []string

+ func (models Models) Validate() error

+ type OutputSchema interface

+ func ValidateOutputSchema(in interface{}) (OutputSchema, error)

+ type ParquetColumn struct

+ ParquetColumnName string

+ RawColumn string

+ type ParquetData struct

+ DropNull bool

+ Schema []*ParquetColumn

+ Type EnvironmentDataType

+ func (parqData *ParquetData) GetExternalData() ExternalData

+ func (parqData *ParquetData) GetIngestedColumnNames() []string

+ func (parqData *ParquetData) Validate() error

+ type Quantity struct

+ UserString string

+ func (quantity *Quantity) Equal(quantity2 Quantity) bool

+ func (quantity *Quantity) ID() string

+ func (quantity *Quantity) SplitInTwo() (*k8sresource.Quantity, *k8sresource.Quantity)

+ func (quantity *Quantity) String() string

+ func (quantity *Quantity) ToFloat32() float32

+ func (quantity *Quantity) ToKi() int64

+ func (quantity *Quantity) UnmarshalBinary(data []byte) error

+ func (quantity *Quantity) UnmarshalJSON(data []byte) error

+ func (quantity *Quantity) UnmarshalText(data []byte) error

+ func (quantity Quantity) MarshalBinary() ([]byte, error)

+ func (quantity Quantity) MarshalJSON() ([]byte, error)

+ func (quantity Quantity) MarshalText() ([]byte, error)

+ type QuantityValidation struct

+ Int bool

+ Min k8sresource.Quantity

+ type RawColumn interface

+ GetColumnType func() ColumnType

+ GetCompute func() *SparkCompute

+ type RawColumns []RawColumn

+ func (rawColumns RawColumns) Get(name string) RawColumn

+ func (rawColumns RawColumns) Names() []string

+ func (rawColumns RawColumns) Validate() error

+ type RawFloatColumn struct

+ Compute *SparkCompute

+ Max *float32

+ Min *float32

+ Required bool

+ Tags Tags

+ Type ColumnType

+ Values []float32

+ func (column *RawFloatColumn) GetColumnType() ColumnType

+ func (column *RawFloatColumn) GetCompute() *SparkCompute

+ func (column *RawFloatColumn) GetResourceType() resource.Type

+ func (column *RawFloatColumn) IsRaw() bool

+ type RawInferredColumn struct

+ Compute *SparkCompute

+ Type ColumnType

+ func (column *RawInferredColumn) GetColumnType() ColumnType

+ func (column *RawInferredColumn) GetCompute() *SparkCompute

+ func (column *RawInferredColumn) GetResourceType() resource.Type

+ func (column *RawInferredColumn) IsRaw() bool

+ type RawIntColumn struct

+ Compute *SparkCompute

+ Max *int64

+ Min *int64

+ Required bool

+ Tags Tags

+ Type ColumnType

+ Values []int64

+ func (column *RawIntColumn) GetColumnType() ColumnType

+ func (column *RawIntColumn) GetCompute() *SparkCompute

+ func (column *RawIntColumn) GetResourceType() resource.Type

+ func (column *RawIntColumn) IsRaw() bool

+ type RawStringColumn struct

+ Compute *SparkCompute

+ Required bool

+ Tags Tags

+ Type ColumnType

+ Values []string

+ func (column *RawStringColumn) GetColumnType() ColumnType

+ func (column *RawStringColumn) GetCompute() *SparkCompute

+ func (column *RawStringColumn) GetResourceType() resource.Type

+ func (column *RawStringColumn) IsRaw() bool

+ type Resource interface

+ GetEmbed func() *Embed

+ GetFilePath func() string

+ GetIndex func() int

+ GetName func() string

+ GetResourceType func() resource.Type

+ SetEmbed func(*Embed)

+ SetFilePath func(string)

+ SetIndex func(int)

+ func FindDuplicateResourceName(resources ...Resource) []Resource

+ type ResourceFields struct

+ Embed *Embed

+ FilePath string

+ Index int

+ Name string

+ func (resourceFields *ResourceFields) GetEmbed() *Embed

+ func (resourceFields *ResourceFields) GetFilePath() string

+ func (resourceFields *ResourceFields) GetIndex() int

+ func (resourceFields *ResourceFields) GetName() string

+ func (resourceFields *ResourceFields) SetEmbed(embed *Embed)

+ func (resourceFields *ResourceFields) SetFilePath(filePath string)

+ func (resourceFields *ResourceFields) SetIndex(index int)

+ type SparkCompute struct

+ DriverCPU Quantity

+ DriverMem Quantity

+ DriverMemOverhead *Quantity

+ ExecutorCPU Quantity

+ ExecutorMem Quantity

+ ExecutorMemOverhead *Quantity

+ Executors int32

+ MemOverheadFactor *float64

+ func MaxSparkCompute(sparkComputes ...*SparkCompute) *SparkCompute

+ func (sparkCompute *SparkCompute) ID() string

+ type TFCompute struct

+ CPU *Quantity

+ GPU *int64

+ Mem *Quantity

+ func MaxTFCompute(tfComputes ...*TFCompute) *TFCompute

+ func (tfCompute *TFCompute) ID() string

+ type Tags map[string]interface

+ func (tags Tags) ID() string

+ type Template struct

+ YAML string

+ func (template *Template) GetResourceType() resource.Type

+ func (template *Template) Populate(emb *Embed) (string, error)

+ func (template *Template) VariableNames() []string

+ type Templates []*Template

+ func (templates Templates) Map() map[string]*Template

+ func (templates Templates) Names() []string

+ func (templates Templates) Validate() error

+ type TransformedColumn struct

+ Compute *SparkCompute

+ Input interface{}

+ Tags Tags

+ Transformer string

+ TransformerPath *string

+ func (column *TransformedColumn) GetResourceType() resource.Type

+ func (column *TransformedColumn) IsRaw() bool

+ func (column *TransformedColumn) Validate() error

+ type TransformedColumns []*TransformedColumn

+ func (columns TransformedColumns) Get(name string) *TransformedColumn

+ func (columns TransformedColumns) Names() []string

+ func (columns TransformedColumns) Validate() error

+ type Transformer struct

+ Input *InputSchema

+ OutputType ColumnType

+ Path string

+ func (transformer *Transformer) GetResourceType() resource.Type

+ type Transformers []*Transformer

+ func (transformers Transformers) Get(name string) *Transformer

+ func (transformers Transformers) Names() []string

+ func (transformers Transformers) Validate() error

+ type ValueType int

+ const BoolValueType

+ const FloatValueType

+ const IntegerValueType

+ const StringValueType

+ const UnknownValueType

+ func ValueTypeFromString(s string) ValueType

+ func (t *ValueType) CastValue(value interface{}) (interface{}, error)

+ func (t *ValueType) UnmarshalBinary(data []byte) error

+ func (t *ValueType) UnmarshalText(text []byte) error

+ func (t ValueType) MarshalBinary() ([]byte, error)

+ func (t ValueType) MarshalText() ([]byte, error)

+ func (t ValueType) String() string

+ type ValueTypes []ValueType

+ func (ts ValueTypes) String() string

+ func (ts ValueTypes) StringList() []string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL