context

package

Go to main page

Versions in this module

v0

v0.3.0

Apr 14, 2019

v0.2.0

Mar 12, 2019

Changes in this version

type Column

+ GetInputRawColumnNames func() []string

type Context

+ PythonPackages PythonPackages

+ func (ctx *Context) RawColumnInputNames(model *Model) []string

type DataSplit

+ CSVData *userconfig.CSVData

+ type PythonPackage struct

+ PackageKey string

+ SrcKey string

+ func (pythonPackage *PythonPackage) GetResourceType() resource.Type

+ type PythonPackages map[string]*PythonPackage

type RawFloatColumn

+ func (rawColumn *RawFloatColumn) GetInputRawColumnNames() []string

type RawIntColumn

+ func (rawColumn *RawIntColumn) GetInputRawColumnNames() []string

type RawStringColumn

+ func (rawColumn *RawStringColumn) GetInputRawColumnNames() []string

+ type Serial struct

+ DataSplit *DataSplit

+ RawColumnSplit *RawColumnsTypeSplit

+ func (serial Serial) ContextFromSerial() (*Context, error)

type TransformedColumn

+ func (column *TransformedColumn) GetInputRawColumnNames() []string

v0.1.0

Feb 14, 2019

Changes in this version

+ func APIPath(apiName string, appName string) string

+ func APIResourcesAndComputesMatch(ctx1 *Context, ctx2 *Context) bool

+ func DataTypeID(dataType interface{}) string

+ func ExtractResourceIDs(resources []ComputedResource) map[string]bool

+ func ExtractResourceWorkloadIDs(resources []ComputedResource) map[string]string

+ func GetColumnRuntimeTypes(columnInputValues map[string]interface{}, rawColumns RawColumns) (map[string]interface{}, error)

+ func ValidateModelTargetType(targetDataTypeStr string, modelType string) error

+ type API struct

+ Path string

+ type APIs map[string]*API

+ func (apis APIs) OneByID(id string) *API

+ type Aggregate struct

+ Key string

+ Type interface{}

+ func (aggregate *Aggregate) Args() map[string]string

+ func (aggregate *Aggregate) GetType() interface{}

+ type Aggregates map[string]*Aggregate

+ func (aggregates Aggregates) OneByID(id string) *Aggregate

+ type Aggregator struct

+ ImplKey string

+ Namespace *string

+ type Aggregators map[string]*Aggregator

+ func (aggregators Aggregators) OneByID(id string) *Aggregator

+ type App struct

+ ID string

+ type Column interface

+ GetType func() string

+ IsRaw func() bool

+ type Columns map[string]Column

+ func (columns Columns) ID(columnNames []string) string

+ func (columns Columns) IDWithTags(columnNames []string) string

+ type ComputedResource interface

+ GetWorkloadID func() string

+ SetWorkloadID func(string)

+ type ComputedResourceFields struct

+ WorkloadID string

+ func (r *ComputedResourceFields) GetWorkloadID() string

+ func (r *ComputedResourceFields) SetWorkloadID(workloadID string)

+ type Constant struct

+ Key string

+ type Constants map[string]*Constant

+ func (constants Constants) OneByID(id string) *Constant

+ type Context struct

+ APIs APIs

+ Aggregates Aggregates

+ Aggregators Aggregators

+ App *App

+ Constants Constants

+ CortexConfig *CortexConfig

+ DatasetVersion string

+ Environment *Environment

+ ID string

+ Key string

+ Models Models

+ RawColumns RawColumns

+ RawDataset RawDataset

+ Root string

+ StatusPrefix string

+ TransformedColumns TransformedColumns

+ Transformers Transformers

+ func FromMsgpackBytes(b []byte) (*Context, error)

+ func (ctx *Context) APIResourceWorkloadIDs() map[string]string

+ func (ctx *Context) APIResources() []ComputedResource

+ func (ctx *Context) AllComputedResourceDependencies(resourceID string) map[string]bool

+ func (ctx *Context) AllResources() []Resource

+ func (ctx *Context) CheckAllWorkloadIDsPopulated() error

+ func (ctx *Context) ColumnNames() map[string]bool

+ func (ctx *Context) Columns() Columns

+ func (ctx *Context) ComputedResourceIDs() map[string]bool

+ func (ctx *Context) ComputedResourceResourceWorkloadIDs() map[string]string

+ func (ctx *Context) ComputedResourceWorkloadIDs() map[string]bool

+ func (ctx *Context) ComputedResources() []ComputedResource

+ func (ctx *Context) DataComputedResources() []ComputedResource

+ func (ctx *Context) DataResourceWorkloadIDs() map[string]string

+ func (ctx *Context) DirectComputedResourceDependencies(resourceID string) map[string]bool

+ func (ctx *Context) GetColumn(name string) Column

+ func (ctx *Context) OneResourceByID(resourceID string) Resource

+ func (ctx *Context) OneTrainingDatasetByID(id string) *TrainingDataset

+ func (ctx *Context) PopulateWorkloadIDs(resourceWorkloadIDs map[string]string)

+ func (ctx *Context) UnmarshalJSON(b []byte) error

+ func (ctx *Context) Validate() error

+ func (ctx *Context) VisibleResourceByName(name string) (ComputedResource, error)

+ func (ctx *Context) VisibleResourceByNameAndType(name string, resourceTypeStr string) (ComputedResource, error)

+ func (ctx *Context) VisibleResourcesByName(name string) []ComputedResource

+ func (ctx *Context) VisibleResourcesMap() map[string][]ComputedResource

+ func (ctx Context) MarshalJSON() ([]byte, error)

+ func (ctx Context) ToMsgpackBytes() ([]byte, error)

+ func (ctx Context) ToSerial() *ContextSerial

+ type ContextSerial struct

+ DataSplit *DataSplit

+ RawColumnSplit *RawColumnsTypeSplit

+ func (ctxSerial ContextSerial) FromSerial() (*Context, error)

+ type CortexConfig struct

+ APIVersion string

+ Bucket string

+ ID string

+ LogGroup string

+ Region string

+ type DataSplit struct

+ CsvData *userconfig.CsvData

+ ParquetData *userconfig.ParquetData

+ type Environment struct

+ ID string

+ type Model struct

+ Dataset *TrainingDataset

+ ImplID string

+ ImplKey string

+ Key string

+ type Models map[string]*Model

+ func (models Models) GetTrainingDatasets() TrainingDatasets

+ func (models Models) OneByID(id string) *Model

+ type RawColumn interface

+ GetCompute func() *userconfig.SparkCompute

+ GetUserConfig func() userconfig.Resource

+ type RawColumns map[string]RawColumn

+ func (rawColumns RawColumns) ColumnInputsID(columnInputValues map[string]interface{}) string

+ func (rawColumns RawColumns) ColumnInputsIDWithTags(columnInputValues map[string]interface{}) string

+ func (rawColumns RawColumns) OneByID(id string) RawColumn

+ type RawColumnsTypeSplit struct

+ RawFloatColumns map[string]*RawFloatColumn

+ RawIntColumns map[string]*RawIntColumn

+ RawStringColumns map[string]*RawStringColumn

+ type RawDataset struct

+ Key string

+ MetadataKey string

+ type RawFloatColumn struct

+ type RawIntColumn struct

+ type RawStringColumn struct

+ type Resource interface

+ GetID func() string

+ GetIDWithTags func() string

+ GetResourceFields func() *ResourceFields

+ type ResourceFields struct

+ ID string

+ IDWithTags string

+ ResourceType resource.Type

+ func (r *ResourceFields) GetID() string

+ func (r *ResourceFields) GetIDWithTags() string

+ func (r *ResourceFields) GetResourceFields() *ResourceFields

+ type TrainingDataset struct

+ EvalKey string

+ MetadataKey string

+ ModelName string

+ Name string

+ TrainKey string

+ func (trainingDataset *TrainingDataset) GetName() string

+ func (trainingDataset *TrainingDataset) GetResourceType() resource.Type

+ type TrainingDatasets map[string]*TrainingDataset

+ type TransformedColumn struct

+ Type string

+ func (column *TransformedColumn) GetType() string

+ func (transformedColumn *TransformedColumn) Args() map[string]string

+ func (transformedColumn *TransformedColumn) InputAggregateNames(ctx *Context) map[string]bool

+ type TransformedColumns map[string]*TransformedColumn

+ func (transformedColumns TransformedColumns) OneByID(id string) *TransformedColumn

+ type Transformer struct

+ ImplKey string

+ Namespace *string

+ type Transformers map[string]*Transformer

+ func (transformers Transformers) OneByID(id string) *Transformer

+ type ValueResource interface

+ GetType func() interface{}

+ func GetValueResource(name string, constants Constants, aggregates Aggregates) (ValueResource, error)

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