userconfig

package

Versions in this module

v0

v0.12.0

Dec 26, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.11.0

Nov 28, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.10.3

Nov 21, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.10.2

Nov 15, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.10.1

Nov 11, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.10.0

Nov 5, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.9.1

Oct 31, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.9.0

Oct 15, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func ErrorInvalidTensorFlowDir(path string) error

type ErrorKind

+ const ErrInvalidTensorFlowDir

v0.8.0

Sep 24, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.7.2

Aug 14, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.7.1

Aug 9, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.7.0

Jul 30, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ func ErrorUnableToInferModelFormat() error

type ErrorKind

+ const ErrUnableToInferModelFormat

v0.6.0

Jul 8, 2019 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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