common

package
v0.0.0-...-ebe581b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 22, 2024 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Algorithm_name = map[int32]string{
	0: "LINEAR_REGRESSION_VL",
	1: "LOGIC_REGRESSION_VL",
	2: "DNN_PADDLEFL_VL",
}
View Source 
var Algorithm_value = map[string]int32{
	"LINEAR_REGRESSION_VL": 0,
	"LOGIC_REGRESSION_VL":  1,
	"DNN_PADDLEFL_VL":      2,
}
View Source 
var CaseType_name = map[int32]string{
	0: "Regression",
	1: "BinaryClass",
}
View Source 
var CaseType_value = map[string]int32{
	"Regression":  0,
	"BinaryClass": 1,
}
View Source 
var EvaluationRule_name = map[int32]string{
	0: "ErRandomSplit",
	1: "ErCrossVal",
	2: "ErLOO",
}
View Source 
var EvaluationRule_value = map[string]int32{
	"ErRandomSplit": 0,
	"ErCrossVal":    1,
	"ErLOO":         2,
}
View Source 
var RegMode_name = map[int32]string{
	0: "Reg_None",
	1: "Reg_Lasso",
	2: "Reg_Ridge",
}
View Source 
var RegMode_value = map[string]int32{
	"Reg_None":  0,
	"Reg_Lasso": 1,
	"Reg_Ridge": 2,
}
View Source 
var TaskType_name = map[int32]string{
	0: "LEARN",
	1: "PREDICT",
}
View Source 
var TaskType_value = map[string]int32{
	"LEARN":   0,
	"PREDICT": 1,
}

Functions

This section is empty.

Types

type Algorithm 

type Algorithm int32

Algorithm is a list of algorithms offered 

const (
	Algorithm_LINEAR_REGRESSION_VL Algorithm = 0
	Algorithm_LOGIC_REGRESSION_VL  Algorithm = 1
	Algorithm_DNN_PADDLEFL_VL      Algorithm = 2
)

func (Algorithm) EnumDescriptor 

func (Algorithm) EnumDescriptor() ([]byte, []int)

func (Algorithm) String 

func (x Algorithm) String() string

type BinaryClassCaseMetricScores 

type BinaryClassCaseMetricScores struct {
	CaseType             CaseType                                              `protobuf:"varint,1,opt,name=caseType,proto3,enum=common.CaseType" json:"caseType,omitempty"`
	AvgAccuracy          float64                                               `protobuf:"fixed64,2,opt,name=avgAccuracy,proto3" json:"avgAccuracy,omitempty"`
	AvgPrecision         float64                                               `protobuf:"fixed64,3,opt,name=avgPrecision,proto3" json:"avgPrecision,omitempty"`
	AvgRecall            float64                                               `protobuf:"fixed64,4,opt,name=avgRecall,proto3" json:"avgRecall,omitempty"`
	AvgF1Score           float64                                               `protobuf:"fixed64,5,opt,name=avgF1Score,proto3" json:"avgF1Score,omitempty"`
	AvgAUC               float64                                               `protobuf:"fixed64,6,opt,name=avgAUC,proto3" json:"avgAUC,omitempty"`
	MetricsPerFold       map[int32]*BinaryClassCaseMetricScores_MetricsPerFold `` /* 170-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                              `json:"-"`
	XXX_unrecognized     []byte                                                `json:"-"`
	XXX_sizecache        int32                                                 `json:"-"`
}

BinaryClassCaseMetricScores contains the metric scores of binary classfication

func (*BinaryClassCaseMetricScores) Descriptor 

func (*BinaryClassCaseMetricScores) Descriptor() ([]byte, []int)

func (*BinaryClassCaseMetricScores) GetAvgAUC 

func (m *BinaryClassCaseMetricScores) GetAvgAUC() float64

func (*BinaryClassCaseMetricScores) GetAvgAccuracy 

func (m *BinaryClassCaseMetricScores) GetAvgAccuracy() float64

func (*BinaryClassCaseMetricScores) GetAvgF1Score 

func (m *BinaryClassCaseMetricScores) GetAvgF1Score() float64

func (*BinaryClassCaseMetricScores) GetAvgPrecision 

func (m *BinaryClassCaseMetricScores) GetAvgPrecision() float64

func (*BinaryClassCaseMetricScores) GetAvgRecall 

func (m *BinaryClassCaseMetricScores) GetAvgRecall() float64

func (*BinaryClassCaseMetricScores) GetCaseType 

func (m *BinaryClassCaseMetricScores) GetCaseType() CaseType

func (*BinaryClassCaseMetricScores) GetMetricsPerFold 

func (m *BinaryClassCaseMetricScores) GetMetricsPerFold() map[int32]*BinaryClassCaseMetricScores_MetricsPerFold

func (*BinaryClassCaseMetricScores) ProtoMessage 

func (*BinaryClassCaseMetricScores) ProtoMessage()

func (*BinaryClassCaseMetricScores) Reset 

func (m *BinaryClassCaseMetricScores) Reset()

func (*BinaryClassCaseMetricScores) String 

func (m *BinaryClassCaseMetricScores) String() string

func (*BinaryClassCaseMetricScores) XXX_DiscardUnknown 

func (m *BinaryClassCaseMetricScores) XXX_DiscardUnknown()

func (*BinaryClassCaseMetricScores) XXX_Marshal 

func (m *BinaryClassCaseMetricScores) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BinaryClassCaseMetricScores) XXX_Merge 

func (m *BinaryClassCaseMetricScores) XXX_Merge(src proto.Message)

func (*BinaryClassCaseMetricScores) XXX_Size 

func (m *BinaryClassCaseMetricScores) XXX_Size() int

func (*BinaryClassCaseMetricScores) XXX_Unmarshal 

func (m *BinaryClassCaseMetricScores) XXX_Unmarshal(b []byte) error

type BinaryClassCaseMetricScores_MetricsPerFold 

type BinaryClassCaseMetricScores_MetricsPerFold struct {
	Accuracy             float64                              `protobuf:"fixed64,1,opt,name=accuracy,proto3" json:"accuracy,omitempty"`
	Precision            float64                              `protobuf:"fixed64,2,opt,name=precision,proto3" json:"precision,omitempty"`
	Recall               float64                              `protobuf:"fixed64,3,opt,name=recall,proto3" json:"recall,omitempty"`
	F1Score              float64                              `protobuf:"fixed64,4,opt,name=F1Score,proto3" json:"F1Score,omitempty"`
	AUC                  float64                              `protobuf:"fixed64,5,opt,name=AUC,proto3" json:"AUC,omitempty"`
	ROC                  []*BinaryClassCaseMetricScores_Point `protobuf:"bytes,6,rep,name=ROC,proto3" json:"ROC,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                             `json:"-"`
	XXX_unrecognized     []byte                               `json:"-"`
	XXX_sizecache        int32                                `json:"-"`
}

func (*BinaryClassCaseMetricScores_MetricsPerFold) Descriptor 

func (*BinaryClassCaseMetricScores_MetricsPerFold) Descriptor() ([]byte, []int)

func (*BinaryClassCaseMetricScores_MetricsPerFold) GetAUC 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) GetAUC() float64

func (*BinaryClassCaseMetricScores_MetricsPerFold) GetAccuracy 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) GetAccuracy() float64

func (*BinaryClassCaseMetricScores_MetricsPerFold) GetF1Score 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) GetF1Score() float64

func (*BinaryClassCaseMetricScores_MetricsPerFold) GetPrecision 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) GetPrecision() float64

func (*BinaryClassCaseMetricScores_MetricsPerFold) GetROC 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) GetROC() []*BinaryClassCaseMetricScores_Point

func (*BinaryClassCaseMetricScores_MetricsPerFold) GetRecall 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) GetRecall() float64

func (*BinaryClassCaseMetricScores_MetricsPerFold) ProtoMessage 

func (*BinaryClassCaseMetricScores_MetricsPerFold) ProtoMessage()

func (*BinaryClassCaseMetricScores_MetricsPerFold) Reset 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) Reset()

func (*BinaryClassCaseMetricScores_MetricsPerFold) String 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) String() string

func (*BinaryClassCaseMetricScores_MetricsPerFold) XXX_DiscardUnknown 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) XXX_DiscardUnknown()

func (*BinaryClassCaseMetricScores_MetricsPerFold) XXX_Marshal 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BinaryClassCaseMetricScores_MetricsPerFold) XXX_Merge 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) XXX_Merge(src proto.Message)

func (*BinaryClassCaseMetricScores_MetricsPerFold) XXX_Size 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) XXX_Size() int

func (*BinaryClassCaseMetricScores_MetricsPerFold) XXX_Unmarshal 

func (m *BinaryClassCaseMetricScores_MetricsPerFold) XXX_Unmarshal(b []byte) error

type BinaryClassCaseMetricScores_Point 

type BinaryClassCaseMetricScores_Point struct {
	// A point on roc is represented by [3]float64, [FPR, TPR, threshold]([x,y,threshold])
	P                    []float64 `protobuf:"fixed64,1,rep,packed,name=p,proto3" json:"p,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*BinaryClassCaseMetricScores_Point) Descriptor 

func (*BinaryClassCaseMetricScores_Point) Descriptor() ([]byte, []int)

func (*BinaryClassCaseMetricScores_Point) GetP 

func (m *BinaryClassCaseMetricScores_Point) GetP() []float64

func (*BinaryClassCaseMetricScores_Point) ProtoMessage 

func (*BinaryClassCaseMetricScores_Point) ProtoMessage()

func (*BinaryClassCaseMetricScores_Point) Reset 

func (m *BinaryClassCaseMetricScores_Point) Reset()

func (*BinaryClassCaseMetricScores_Point) String 

func (m *BinaryClassCaseMetricScores_Point) String() string

func (*BinaryClassCaseMetricScores_Point) XXX_DiscardUnknown 

func (m *BinaryClassCaseMetricScores_Point) XXX_DiscardUnknown()

func (*BinaryClassCaseMetricScores_Point) XXX_Marshal 

func (m *BinaryClassCaseMetricScores_Point) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BinaryClassCaseMetricScores_Point) XXX_Merge 

func (m *BinaryClassCaseMetricScores_Point) XXX_Merge(src proto.Message)

func (*BinaryClassCaseMetricScores_Point) XXX_Size 

func (m *BinaryClassCaseMetricScores_Point) XXX_Size() int

func (*BinaryClassCaseMetricScores_Point) XXX_Unmarshal 

func (m *BinaryClassCaseMetricScores_Point) XXX_Unmarshal(b []byte) error

type CaseType 

type CaseType int32

CaseType defines the types of problems 

const (
	CaseType_Regression  CaseType = 0
	CaseType_BinaryClass CaseType = 1
)

func (CaseType) EnumDescriptor 

func (CaseType) EnumDescriptor() ([]byte, []int)

func (CaseType) String 

func (x CaseType) String() string

type CrossVal 

type CrossVal struct {
	Folds                int32    `protobuf:"varint,1,opt,name=folds,proto3" json:"folds,omitempty"`
	Shuffle              bool     `protobuf:"varint,2,opt,name=shuffle,proto3" json:"shuffle,omitempty"`
	Repeated             bool     `protobuf:"varint,3,opt,name=repeated,proto3" json:"repeated,omitempty"`
	RepeatTimes          int32    `protobuf:"varint,4,opt,name=repeatTimes,proto3" json:"repeatTimes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CrossVal lists all parameters required in Cross Validation

func (*CrossVal) Descriptor 

func (*CrossVal) Descriptor() ([]byte, []int)

func (*CrossVal) GetFolds 

func (m *CrossVal) GetFolds() int32

func (*CrossVal) GetRepeatTimes 

func (m *CrossVal) GetRepeatTimes() int32

func (*CrossVal) GetRepeated 

func (m *CrossVal) GetRepeated() bool

func (*CrossVal) GetShuffle 

func (m *CrossVal) GetShuffle() bool

func (*CrossVal) ProtoMessage 

func (*CrossVal) ProtoMessage()

func (*CrossVal) Reset 

func (m *CrossVal) Reset()

func (*CrossVal) String 

func (m *CrossVal) String() string

func (*CrossVal) XXX_DiscardUnknown 

func (m *CrossVal) XXX_DiscardUnknown()

func (*CrossVal) XXX_Marshal 

func (m *CrossVal) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrossVal) XXX_Merge 

func (m *CrossVal) XXX_Merge(src proto.Message)

func (*CrossVal) XXX_Size 

func (m *CrossVal) XXX_Size() int

func (*CrossVal) XXX_Unmarshal 

func (m *CrossVal) XXX_Unmarshal(b []byte) error

type EvaluationMetricScores 

type EvaluationMetricScores struct {
	// Types that are valid to be assigned to Payload:
	//	*EvaluationMetricScores_BinaryClassCaseMetricScores
	//	*EvaluationMetricScores_RegressionCaseMetricScores
	Payload              isEvaluationMetricScores_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

EvaluationMetricScores defines model evaluation results, covering all supported metrics

func (*EvaluationMetricScores) Descriptor 

func (*EvaluationMetricScores) Descriptor() ([]byte, []int)

func (*EvaluationMetricScores) GetBinaryClassCaseMetricScores 

func (m *EvaluationMetricScores) GetBinaryClassCaseMetricScores() *BinaryClassCaseMetricScores

func (*EvaluationMetricScores) GetPayload 

func (m *EvaluationMetricScores) GetPayload() isEvaluationMetricScores_Payload

func (*EvaluationMetricScores) GetRegressionCaseMetricScores 

func (m *EvaluationMetricScores) GetRegressionCaseMetricScores() *RegressionCaseMetricScores

func (*EvaluationMetricScores) ProtoMessage 

func (*EvaluationMetricScores) ProtoMessage()

func (*EvaluationMetricScores) Reset 

func (m *EvaluationMetricScores) Reset()

func (*EvaluationMetricScores) String 

func (m *EvaluationMetricScores) String() string

func (*EvaluationMetricScores) XXX_DiscardUnknown 

func (m *EvaluationMetricScores) XXX_DiscardUnknown()

func (*EvaluationMetricScores) XXX_Marshal 

func (m *EvaluationMetricScores) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvaluationMetricScores) XXX_Merge 

func (m *EvaluationMetricScores) XXX_Merge(src proto.Message)

func (*EvaluationMetricScores) XXX_OneofWrappers 

func (*EvaluationMetricScores) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*EvaluationMetricScores) XXX_Size 

func (m *EvaluationMetricScores) XXX_Size() int

func (*EvaluationMetricScores) XXX_Unmarshal 

func (m *EvaluationMetricScores) XXX_Unmarshal(b []byte) error

type EvaluationMetricScores_BinaryClassCaseMetricScores 

type EvaluationMetricScores_BinaryClassCaseMetricScores struct {
	BinaryClassCaseMetricScores *BinaryClassCaseMetricScores `protobuf:"bytes,1,opt,name=binaryClassCaseMetricScores,proto3,oneof"`
}

type EvaluationMetricScores_RegressionCaseMetricScores 

type EvaluationMetricScores_RegressionCaseMetricScores struct {
	RegressionCaseMetricScores *RegressionCaseMetricScores `protobuf:"bytes,2,opt,name=RegressionCaseMetricScores,proto3,oneof"`
}

type EvaluationParams 

type EvaluationParams struct {
	Enable               bool           `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	EvalRule             EvaluationRule `protobuf:"varint,2,opt,name=evalRule,proto3,enum=common.EvaluationRule" json:"evalRule,omitempty"`
	RandomSplit          *RandomSplit   `protobuf:"bytes,3,opt,name=randomSplit,proto3" json:"randomSplit,omitempty"`
	Cv                   *CrossVal      `protobuf:"bytes,4,opt,name=cv,proto3" json:"cv,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

EvaluationParams lists all the parameters for model evaluation

func (*EvaluationParams) Descriptor 

func (*EvaluationParams) Descriptor() ([]byte, []int)

func (*EvaluationParams) GetCv 

func (m *EvaluationParams) GetCv() *CrossVal

func (*EvaluationParams) GetEnable 

func (m *EvaluationParams) GetEnable() bool

func (*EvaluationParams) GetEvalRule 

func (m *EvaluationParams) GetEvalRule() EvaluationRule

func (*EvaluationParams) GetRandomSplit 

func (m *EvaluationParams) GetRandomSplit() *RandomSplit

func (*EvaluationParams) ProtoMessage 

func (*EvaluationParams) ProtoMessage()

func (*EvaluationParams) Reset 

func (m *EvaluationParams) Reset()

func (*EvaluationParams) String 

func (m *EvaluationParams) String() string

func (*EvaluationParams) XXX_DiscardUnknown 

func (m *EvaluationParams) XXX_DiscardUnknown()

func (*EvaluationParams) XXX_Marshal 

func (m *EvaluationParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvaluationParams) XXX_Merge 

func (m *EvaluationParams) XXX_Merge(src proto.Message)

func (*EvaluationParams) XXX_Size 

func (m *EvaluationParams) XXX_Size() int

func (*EvaluationParams) XXX_Unmarshal 

func (m *EvaluationParams) XXX_Unmarshal(b []byte) error

type EvaluationRule 

type EvaluationRule int32

EvaluationRule defines the ways of evaluation 

const (
	// to divide the dataset randomly by percentage,
	// which represents the subset as validation set, and the rest is training set.
	EvaluationRule_ErRandomSplit EvaluationRule = 0
	// Cross Validation
	EvaluationRule_ErCrossVal EvaluationRule = 1
	// Leave One Out and is suitable for small datasets
	EvaluationRule_ErLOO EvaluationRule = 2
)

func (EvaluationRule) EnumDescriptor 

func (EvaluationRule) EnumDescriptor() ([]byte, []int)

func (EvaluationRule) String 

func (x EvaluationRule) String() string

type LiveEvaluationParams 

type LiveEvaluationParams struct {
	Enable               bool         `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	RandomSplit          *RandomSplit `protobuf:"bytes,2,opt,name=randomSplit,proto3" json:"randomSplit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

LiveEvaluationParams lists all the parameters for live model evaluation

func (*LiveEvaluationParams) Descriptor 

func (*LiveEvaluationParams) Descriptor() ([]byte, []int)

func (*LiveEvaluationParams) GetEnable 

func (m *LiveEvaluationParams) GetEnable() bool

func (*LiveEvaluationParams) GetRandomSplit 

func (m *LiveEvaluationParams) GetRandomSplit() *RandomSplit

func (*LiveEvaluationParams) ProtoMessage 

func (*LiveEvaluationParams) ProtoMessage()

func (*LiveEvaluationParams) Reset 

func (m *LiveEvaluationParams) Reset()

func (*LiveEvaluationParams) String 

func (m *LiveEvaluationParams) String() string

func (*LiveEvaluationParams) XXX_DiscardUnknown 

func (m *LiveEvaluationParams) XXX_DiscardUnknown()

func (*LiveEvaluationParams) XXX_Marshal 

func (m *LiveEvaluationParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LiveEvaluationParams) XXX_Merge 

func (m *LiveEvaluationParams) XXX_Merge(src proto.Message)

func (*LiveEvaluationParams) XXX_Size 

func (m *LiveEvaluationParams) XXX_Size() int

func (*LiveEvaluationParams) XXX_Unmarshal 

func (m *LiveEvaluationParams) XXX_Unmarshal(b []byte) error

type PaddleFLParams 

type PaddleFLParams struct {
	Role                 int32    `protobuf:"varint,1,opt,name=role,proto3" json:"role,omitempty"`
	Nodes                []string `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PaddleFLParams defines node's role and mpc network using paddlefl.

func (*PaddleFLParams) Descriptor 

func (*PaddleFLParams) Descriptor() ([]byte, []int)

func (*PaddleFLParams) GetNodes 

func (m *PaddleFLParams) GetNodes() []string

func (*PaddleFLParams) GetRole 

func (m *PaddleFLParams) GetRole() int32

func (*PaddleFLParams) ProtoMessage 

func (*PaddleFLParams) ProtoMessage()

func (*PaddleFLParams) Reset 

func (m *PaddleFLParams) Reset()

func (*PaddleFLParams) String 

func (m *PaddleFLParams) String() string

func (*PaddleFLParams) XXX_DiscardUnknown 

func (m *PaddleFLParams) XXX_DiscardUnknown()

func (*PaddleFLParams) XXX_Marshal 

func (m *PaddleFLParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PaddleFLParams) XXX_Merge 

func (m *PaddleFLParams) XXX_Merge(src proto.Message)

func (*PaddleFLParams) XXX_Size 

func (m *PaddleFLParams) XXX_Size() int

func (*PaddleFLParams) XXX_Unmarshal 

func (m *PaddleFLParams) XXX_Unmarshal(b []byte) error

type PredictTaskResult 

type PredictTaskResult struct {
	TaskID               string   `protobuf:"bytes,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Success              bool     `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Outcomes             []byte   `protobuf:"bytes,3,opt,name=outcomes,proto3" json:"outcomes,omitempty"`
	ErrMsg               string   `protobuf:"bytes,4,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PredictTaskResult defines final result of prediction

func (*PredictTaskResult) Descriptor 

func (*PredictTaskResult) Descriptor() ([]byte, []int)

func (*PredictTaskResult) GetErrMsg 

func (m *PredictTaskResult) GetErrMsg() string

func (*PredictTaskResult) GetOutcomes 

func (m *PredictTaskResult) GetOutcomes() []byte

func (*PredictTaskResult) GetSuccess 

func (m *PredictTaskResult) GetSuccess() bool

func (*PredictTaskResult) GetTaskID 

func (m *PredictTaskResult) GetTaskID() string

func (*PredictTaskResult) ProtoMessage 

func (*PredictTaskResult) ProtoMessage()

func (*PredictTaskResult) Reset 

func (m *PredictTaskResult) Reset()

func (*PredictTaskResult) String 

func (m *PredictTaskResult) String() string

func (*PredictTaskResult) XXX_DiscardUnknown 

func (m *PredictTaskResult) XXX_DiscardUnknown()

func (*PredictTaskResult) XXX_Marshal 

func (m *PredictTaskResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictTaskResult) XXX_Merge 

func (m *PredictTaskResult) XXX_Merge(src proto.Message)

func (*PredictTaskResult) XXX_Size 

func (m *PredictTaskResult) XXX_Size() int

func (*PredictTaskResult) XXX_Unmarshal 

func (m *PredictTaskResult) XXX_Unmarshal(b []byte) error

type RandomSplit 

type RandomSplit struct {
	PercentLO            int32    `protobuf:"varint,1,opt,name=percentLO,proto3" json:"percentLO,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RandomSplit defines the way to divide the dataset randomly by percentage

func (*RandomSplit) Descriptor 

func (*RandomSplit) Descriptor() ([]byte, []int)

func (*RandomSplit) GetPercentLO 

func (m *RandomSplit) GetPercentLO() int32

func (*RandomSplit) ProtoMessage 

func (*RandomSplit) ProtoMessage()

func (*RandomSplit) Reset 

func (m *RandomSplit) Reset()

func (*RandomSplit) String 

func (m *RandomSplit) String() string

func (*RandomSplit) XXX_DiscardUnknown 

func (m *RandomSplit) XXX_DiscardUnknown()

func (*RandomSplit) XXX_Marshal 

func (m *RandomSplit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RandomSplit) XXX_Merge 

func (m *RandomSplit) XXX_Merge(src proto.Message)

func (*RandomSplit) XXX_Size 

func (m *RandomSplit) XXX_Size() int

func (*RandomSplit) XXX_Unmarshal 

func (m *RandomSplit) XXX_Unmarshal(b []byte) error

type RegMode 

type RegMode int32

RegMode regulation mode for training 

const (
	RegMode_Reg_None  RegMode = 0
	RegMode_Reg_Lasso RegMode = 1
	RegMode_Reg_Ridge RegMode = 2
)

func (RegMode) EnumDescriptor 

func (RegMode) EnumDescriptor() ([]byte, []int)

func (RegMode) String 

func (x RegMode) String() string

type RegressionCaseMetricScores 

type RegressionCaseMetricScores struct {
	CaseType             CaseType          `protobuf:"varint,1,opt,name=caseType,proto3,enum=common.CaseType" json:"caseType,omitempty"`
	RMSEs                map[int32]float64 `` /* 154-byte string literal not displayed */
	MeanRMSE             float64           `protobuf:"fixed64,3,opt,name=meanRMSE,proto3" json:"meanRMSE,omitempty"`
	StdDevRMSE           float64           `protobuf:"fixed64,4,opt,name=stdDevRMSE,proto3" json:"stdDevRMSE,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

RegressionCaseMetricScores contains the metric scores of regression

func (*RegressionCaseMetricScores) Descriptor 

func (*RegressionCaseMetricScores) Descriptor() ([]byte, []int)

func (*RegressionCaseMetricScores) GetCaseType 

func (m *RegressionCaseMetricScores) GetCaseType() CaseType

func (*RegressionCaseMetricScores) GetMeanRMSE 

func (m *RegressionCaseMetricScores) GetMeanRMSE() float64

func (*RegressionCaseMetricScores) GetRMSEs 

func (m *RegressionCaseMetricScores) GetRMSEs() map[int32]float64

func (*RegressionCaseMetricScores) GetStdDevRMSE 

func (m *RegressionCaseMetricScores) GetStdDevRMSE() float64

func (*RegressionCaseMetricScores) ProtoMessage 

func (*RegressionCaseMetricScores) ProtoMessage()

func (*RegressionCaseMetricScores) Reset 

func (m *RegressionCaseMetricScores) Reset()

func (*RegressionCaseMetricScores) String 

func (m *RegressionCaseMetricScores) String() string

func (*RegressionCaseMetricScores) XXX_DiscardUnknown 

func (m *RegressionCaseMetricScores) XXX_DiscardUnknown()

func (*RegressionCaseMetricScores) XXX_Marshal 

func (m *RegressionCaseMetricScores) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegressionCaseMetricScores) XXX_Merge 

func (m *RegressionCaseMetricScores) XXX_Merge(src proto.Message)

func (*RegressionCaseMetricScores) XXX_Size 

func (m *RegressionCaseMetricScores) XXX_Size() int

func (*RegressionCaseMetricScores) XXX_Unmarshal 

func (m *RegressionCaseMetricScores) XXX_Unmarshal(b []byte) error

type StartTaskRequest 

type StartTaskRequest struct {
	TaskID               string          `protobuf:"bytes,2,opt,name=taskID,proto3" json:"taskID,omitempty"`
	File                 []byte          `protobuf:"bytes,3,opt,name=file,proto3" json:"file,omitempty"`
	Hosts                []string        `protobuf:"bytes,4,rep,name=hosts,proto3" json:"hosts,omitempty"`
	Params               *TaskParams     `protobuf:"bytes,5,opt,name=params,proto3" json:"params,omitempty"`
	PaddleFLParams       *PaddleFLParams `protobuf:"bytes,6,opt,name=paddleFLParams,proto3" json:"paddleFLParams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

StartTaskRequest is message sent to a cluster member to start a training task or predicting task.

func (*StartTaskRequest) Descriptor 

func (*StartTaskRequest) Descriptor() ([]byte, []int)

func (*StartTaskRequest) GetFile 

func (m *StartTaskRequest) GetFile() []byte

func (*StartTaskRequest) GetHosts 

func (m *StartTaskRequest) GetHosts() []string

func (*StartTaskRequest) GetPaddleFLParams 

func (m *StartTaskRequest) GetPaddleFLParams() *PaddleFLParams

func (*StartTaskRequest) GetParams 

func (m *StartTaskRequest) GetParams() *TaskParams

func (*StartTaskRequest) GetTaskID 

func (m *StartTaskRequest) GetTaskID() string

func (*StartTaskRequest) ProtoMessage 

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) Reset 

func (m *StartTaskRequest) Reset()

func (*StartTaskRequest) String 

func (m *StartTaskRequest) String() string

func (*StartTaskRequest) XXX_DiscardUnknown 

func (m *StartTaskRequest) XXX_DiscardUnknown()

func (*StartTaskRequest) XXX_Marshal 

func (m *StartTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartTaskRequest) XXX_Merge 

func (m *StartTaskRequest) XXX_Merge(src proto.Message)

func (*StartTaskRequest) XXX_Size 

func (m *StartTaskRequest) XXX_Size() int

func (*StartTaskRequest) XXX_Unmarshal 

func (m *StartTaskRequest) XXX_Unmarshal(b []byte) error

type StopTaskRequest 

type StopTaskRequest struct {
	TaskID               string      `protobuf:"bytes,2,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Params               *TaskParams `protobuf:"bytes,4,opt,name=params,proto3" json:"params,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

StopTaskRequest is message sent to a cluster member to stop a training task or predicting task.

func (*StopTaskRequest) Descriptor 

func (*StopTaskRequest) Descriptor() ([]byte, []int)

func (*StopTaskRequest) GetParams 

func (m *StopTaskRequest) GetParams() *TaskParams

func (*StopTaskRequest) GetTaskID 

func (m *StopTaskRequest) GetTaskID() string

func (*StopTaskRequest) ProtoMessage 

func (*StopTaskRequest) ProtoMessage()

func (*StopTaskRequest) Reset 

func (m *StopTaskRequest) Reset()

func (*StopTaskRequest) String 

func (m *StopTaskRequest) String() string

func (*StopTaskRequest) XXX_DiscardUnknown 

func (m *StopTaskRequest) XXX_DiscardUnknown()

func (*StopTaskRequest) XXX_Marshal 

func (m *StopTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopTaskRequest) XXX_Merge 

func (m *StopTaskRequest) XXX_Merge(src proto.Message)

func (*StopTaskRequest) XXX_Size 

func (m *StopTaskRequest) XXX_Size() int

func (*StopTaskRequest) XXX_Unmarshal 

func (m *StopTaskRequest) XXX_Unmarshal(b []byte) error

type TaskParams 

type TaskParams struct {
	Algo                 Algorithm             `protobuf:"varint,1,opt,name=algo,proto3,enum=common.Algorithm" json:"algo,omitempty"`
	TaskType             TaskType              `protobuf:"varint,2,opt,name=taskType,proto3,enum=common.TaskType" json:"taskType,omitempty"`
	TrainParams          *TrainParams          `protobuf:"bytes,3,opt,name=trainParams,proto3" json:"trainParams,omitempty"`
	ModelTaskID          string                `protobuf:"bytes,4,opt,name=modelTaskID,proto3" json:"modelTaskID,omitempty"`
	ModelParams          *TrainModels          `protobuf:"bytes,5,opt,name=modelParams,proto3" json:"modelParams,omitempty"`
	EvalParams           *EvaluationParams     `protobuf:"bytes,6,opt,name=evalParams,proto3" json:"evalParams,omitempty"`
	LivalParams          *LiveEvaluationParams `protobuf:"bytes,7,opt,name=livalParams,proto3" json:"livalParams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

TaskParams lists all the parameters in a task

func (*TaskParams) Descriptor 

func (*TaskParams) Descriptor() ([]byte, []int)

func (*TaskParams) GetAlgo 

func (m *TaskParams) GetAlgo() Algorithm

func (*TaskParams) GetEvalParams 

func (m *TaskParams) GetEvalParams() *EvaluationParams

func (*TaskParams) GetLivalParams 

func (m *TaskParams) GetLivalParams() *LiveEvaluationParams

func (*TaskParams) GetModelParams 

func (m *TaskParams) GetModelParams() *TrainModels

func (*TaskParams) GetModelTaskID 

func (m *TaskParams) GetModelTaskID() string

func (*TaskParams) GetTaskType 

func (m *TaskParams) GetTaskType() TaskType

func (*TaskParams) GetTrainParams 

func (m *TaskParams) GetTrainParams() *TrainParams

func (*TaskParams) ProtoMessage 

func (*TaskParams) ProtoMessage()

func (*TaskParams) Reset 

func (m *TaskParams) Reset()

func (*TaskParams) String 

func (m *TaskParams) String() string

func (*TaskParams) XXX_DiscardUnknown 

func (m *TaskParams) XXX_DiscardUnknown()

func (*TaskParams) XXX_Marshal 

func (m *TaskParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskParams) XXX_Merge 

func (m *TaskParams) XXX_Merge(src proto.Message)

func (*TaskParams) XXX_Size 

func (m *TaskParams) XXX_Size() int

func (*TaskParams) XXX_Unmarshal 

func (m *TaskParams) XXX_Unmarshal(b []byte) error

type TaskType 

type TaskType int32

TaskType defines types of task 

const (
	TaskType_LEARN   TaskType = 0
	TaskType_PREDICT TaskType = 1
)

func (TaskType) EnumDescriptor 

func (TaskType) EnumDescriptor() ([]byte, []int)

func (TaskType) String 

func (x TaskType) String() string

type TrainModels 

type TrainModels struct {
	Thetas               map[string]float64 `` /* 155-byte string literal not displayed */
	Xbars                map[string]float64 `` /* 153-byte string literal not displayed */
	Sigmas               map[string]float64 `` /* 155-byte string literal not displayed */
	Label                string             `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	IsTagPart            bool               `protobuf:"varint,5,opt,name=isTagPart,proto3" json:"isTagPart,omitempty"`
	IdName               string             `protobuf:"bytes,6,opt,name=idName,proto3" json:"idName,omitempty"`
	Path                 string             `protobuf:"bytes,7,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

TrainModels is final result of distributed training

func (*TrainModels) Descriptor 

func (*TrainModels) Descriptor() ([]byte, []int)

func (*TrainModels) GetIdName 

func (m *TrainModels) GetIdName() string

func (*TrainModels) GetIsTagPart 

func (m *TrainModels) GetIsTagPart() bool

func (*TrainModels) GetLabel 

func (m *TrainModels) GetLabel() string

func (*TrainModels) GetPath 

func (m *TrainModels) GetPath() string

func (*TrainModels) GetSigmas 

func (m *TrainModels) GetSigmas() map[string]float64

func (*TrainModels) GetThetas 

func (m *TrainModels) GetThetas() map[string]float64

func (*TrainModels) GetXbars 

func (m *TrainModels) GetXbars() map[string]float64

func (*TrainModels) ProtoMessage 

func (*TrainModels) ProtoMessage()

func (*TrainModels) Reset 

func (m *TrainModels) Reset()

func (*TrainModels) String 

func (m *TrainModels) String() string

func (*TrainModels) XXX_DiscardUnknown 

func (m *TrainModels) XXX_DiscardUnknown()

func (*TrainModels) XXX_Marshal 

func (m *TrainModels) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrainModels) XXX_Merge 

func (m *TrainModels) XXX_Merge(src proto.Message)

func (*TrainModels) XXX_Size 

func (m *TrainModels) XXX_Size() int

func (*TrainModels) XXX_Unmarshal 

func (m *TrainModels) XXX_Unmarshal(b []byte) error

type TrainParams 

type TrainParams struct {
	Label                string   `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	LabelName            string   `protobuf:"bytes,2,opt,name=labelName,proto3" json:"labelName,omitempty"`
	RegMode              RegMode  `protobuf:"varint,3,opt,name=regMode,proto3,enum=common.RegMode" json:"regMode,omitempty"`
	RegParam             float64  `protobuf:"fixed64,4,opt,name=regParam,proto3" json:"regParam,omitempty"`
	Alpha                float64  `protobuf:"fixed64,5,opt,name=alpha,proto3" json:"alpha,omitempty"`
	Amplitude            float64  `protobuf:"fixed64,6,opt,name=amplitude,proto3" json:"amplitude,omitempty"`
	Accuracy             int64    `protobuf:"varint,7,opt,name=accuracy,proto3" json:"accuracy,omitempty"`
	IsTagPart            bool     `protobuf:"varint,8,opt,name=isTagPart,proto3" json:"isTagPart,omitempty"`
	IdName               string   `protobuf:"bytes,9,opt,name=idName,proto3" json:"idName,omitempty"`
	BatchSize            int64    `protobuf:"varint,10,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TrainParams lists all the parameters for training

func (*TrainParams) Descriptor 

func (*TrainParams) Descriptor() ([]byte, []int)

func (*TrainParams) GetAccuracy 

func (m *TrainParams) GetAccuracy() int64

func (*TrainParams) GetAlpha 

func (m *TrainParams) GetAlpha() float64

func (*TrainParams) GetAmplitude 

func (m *TrainParams) GetAmplitude() float64

func (*TrainParams) GetBatchSize 

func (m *TrainParams) GetBatchSize() int64

func (*TrainParams) GetIdName 

func (m *TrainParams) GetIdName() string

func (*TrainParams) GetIsTagPart 

func (m *TrainParams) GetIsTagPart() bool

func (*TrainParams) GetLabel 

func (m *TrainParams) GetLabel() string

func (*TrainParams) GetLabelName 

func (m *TrainParams) GetLabelName() string

func (*TrainParams) GetRegMode 

func (m *TrainParams) GetRegMode() RegMode

func (*TrainParams) GetRegParam 

func (m *TrainParams) GetRegParam() float64

func (*TrainParams) ProtoMessage 

func (*TrainParams) ProtoMessage()

func (*TrainParams) Reset 

func (m *TrainParams) Reset()

func (*TrainParams) String 

func (m *TrainParams) String() string

func (*TrainParams) XXX_DiscardUnknown 

func (m *TrainParams) XXX_DiscardUnknown()

func (*TrainParams) XXX_Marshal 

func (m *TrainParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrainParams) XXX_Merge 

func (m *TrainParams) XXX_Merge(src proto.Message)

func (*TrainParams) XXX_Size 

func (m *TrainParams) XXX_Size() int

func (*TrainParams) XXX_Unmarshal 

func (m *TrainParams) XXX_Unmarshal(b []byte) error

type TrainTaskResult 

type TrainTaskResult struct {
	TaskID           string                  `protobuf:"bytes,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Success          bool                    `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Model            []byte                  `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	ErrMsg           string                  `protobuf:"bytes,4,opt,name=errMsg,proto3" json:"errMsg,omitempty"`
	EvalMetricScores *EvaluationMetricScores `protobuf:"bytes,6,opt,name=evalMetricScores,proto3" json:"evalMetricScores,omitempty"`
	// trainSet is training set after Sample Alignment, and will be used in evaluation,
	// and it will be deleted from TrainTaskResult after evaluation
	TrainSet             []*TrainTaskResult_FileRow `protobuf:"bytes,5,rep,name=trainSet,proto3" json:"trainSet,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

TrainTaskResult defines final result of training

func (*TrainTaskResult) Descriptor 

func (*TrainTaskResult) Descriptor() ([]byte, []int)

func (*TrainTaskResult) GetErrMsg 

func (m *TrainTaskResult) GetErrMsg() string

func (*TrainTaskResult) GetEvalMetricScores 

func (m *TrainTaskResult) GetEvalMetricScores() *EvaluationMetricScores

func (*TrainTaskResult) GetModel 

func (m *TrainTaskResult) GetModel() []byte

func (*TrainTaskResult) GetSuccess 

func (m *TrainTaskResult) GetSuccess() bool

func (*TrainTaskResult) GetTaskID 

func (m *TrainTaskResult) GetTaskID() string

func (*TrainTaskResult) GetTrainSet 

func (m *TrainTaskResult) GetTrainSet() []*TrainTaskResult_FileRow

func (*TrainTaskResult) ProtoMessage 

func (*TrainTaskResult) ProtoMessage()

func (*TrainTaskResult) Reset 

func (m *TrainTaskResult) Reset()

func (*TrainTaskResult) String 

func (m *TrainTaskResult) String() string

func (*TrainTaskResult) XXX_DiscardUnknown 

func (m *TrainTaskResult) XXX_DiscardUnknown()

func (*TrainTaskResult) XXX_Marshal 

func (m *TrainTaskResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrainTaskResult) XXX_Merge 

func (m *TrainTaskResult) XXX_Merge(src proto.Message)

func (*TrainTaskResult) XXX_Size 

func (m *TrainTaskResult) XXX_Size() int

func (*TrainTaskResult) XXX_Unmarshal 

func (m *TrainTaskResult) XXX_Unmarshal(b []byte) error

type TrainTaskResult_FileRow 

type TrainTaskResult_FileRow struct {
	Row                  []string `protobuf:"bytes,1,rep,name=row,proto3" json:"row,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TrainTaskResult_FileRow) Descriptor 

func (*TrainTaskResult_FileRow) Descriptor() ([]byte, []int)

func (*TrainTaskResult_FileRow) GetRow 

func (m *TrainTaskResult_FileRow) GetRow() []string

func (*TrainTaskResult_FileRow) ProtoMessage 

func (*TrainTaskResult_FileRow) ProtoMessage()

func (*TrainTaskResult_FileRow) Reset 

func (m *TrainTaskResult_FileRow) Reset()

func (*TrainTaskResult_FileRow) String 

func (m *TrainTaskResult_FileRow) String() string

func (*TrainTaskResult_FileRow) XXX_DiscardUnknown 

func (m *TrainTaskResult_FileRow) XXX_DiscardUnknown()

func (*TrainTaskResult_FileRow) XXX_Marshal 

func (m *TrainTaskResult_FileRow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TrainTaskResult_FileRow) XXX_Merge 

func (m *TrainTaskResult_FileRow) XXX_Merge(src proto.Message)

func (*TrainTaskResult_FileRow) XXX_Size 

func (m *TrainTaskResult_FileRow) XXX_Size() int

func (*TrainTaskResult_FileRow) XXX_Unmarshal 

func (m *TrainTaskResult_FileRow) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.