eas

package
v2.4.6 Latest Latest
Warning

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

 Go to latest Published: Dec 24, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Eas_Processor_FM        = "ALINK_FM"
	Eas_Processor_PMML      = "PMML"
	Eas_Processor_TF        = "TensorFlow"
	Eas_Processor_TFServing = "TFServing"
	Eas_Processor_EASYREC   = "EasyRec"
	Eas_Processor_LINUCB    = "Linucb"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type EasModel 

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

func NewEasModel 

func NewEasModel(name string) *EasModel

func (*EasModel) Init 

func (m *EasModel) Init(conf *recconf.AlgoConfig) error

func (*EasModel) Run 

func (m *EasModel) Run(algoData interface{}) (interface{}, error)

type EasRequest 

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

func (*EasRequest) GetResponseFunc 

func (r *EasRequest) GetResponseFunc() response.ResponseFunc

func (*EasRequest) SetAuth 

func (r *EasRequest) SetAuth(auth string)

func (*EasRequest) SetResponseFunc 

func (r *EasRequest) SetResponseFunc(name string)

func (*EasRequest) SetServiceName 

func (r *EasRequest) SetServiceName(name string)

func (*EasRequest) SetTimeout 

func (r *EasRequest) SetTimeout(timeout int)

func (*EasRequest) SetUrl 

func (r *EasRequest) SetUrl(url string)

type EasyrecClassificationResponse added in v2.4.6 

type EasyrecClassificationResponse struct {
	EasyrecResponse
	// contains filtered or unexported fields
}

func (*EasyrecClassificationResponse) GetClassifyMap added in v2.4.6 

func (r *EasyrecClassificationResponse) GetClassifyMap() map[string][]float64

type EasyrecRequest 

type EasyrecRequest struct {
	EasRequest
	EasClient *eas.PredictClient
}

func (*EasyrecRequest) Invoke 

func (r *EasyrecRequest) Invoke(requestData interface{}) (response interface{}, err error)

type EasyrecResponse 

type EasyrecResponse struct {
	RawFeatures      string
	GenerateFeatures *bytes.Buffer
	ContextFeatures  string
	// contains filtered or unexported fields
}

func (*EasyrecResponse) GetModuleType 

func (r *EasyrecResponse) GetModuleType() bool

func (*EasyrecResponse) GetScore 

func (r *EasyrecResponse) GetScore() float64

func (*EasyrecResponse) GetScoreMap 

func (r *EasyrecResponse) GetScoreMap() map[string]float64

type EasyrecUserEmbResponse 

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

func (*EasyrecUserEmbResponse) GetModuleType 

func (r *EasyrecUserEmbResponse) GetModuleType() bool

func (*EasyrecUserEmbResponse) GetScore 

func (r *EasyrecUserEmbResponse) GetScore() float64

func (*EasyrecUserEmbResponse) GetScoreMap 

func (r *EasyrecUserEmbResponse) GetScoreMap() map[string]float64

func (*EasyrecUserEmbResponse) GetUserEmb 

func (r *EasyrecUserEmbResponse) GetUserEmb() string

type EasyrecUserRealtimeEmbeddingMindResponse 

type EasyrecUserRealtimeEmbeddingMindResponse struct {
	DimSize          int
	DimLength        int
	UserEmbedding    string
	EmbeddingList    []*EmbeddingInfo
	GenerateFeatures *bytes.Buffer
}

func (*EasyrecUserRealtimeEmbeddingMindResponse) GetDimLength 

func (r *EasyrecUserRealtimeEmbeddingMindResponse) GetDimLength() int

func (*EasyrecUserRealtimeEmbeddingMindResponse) GetDimSize 

func (r *EasyrecUserRealtimeEmbeddingMindResponse) GetDimSize() int

func (*EasyrecUserRealtimeEmbeddingMindResponse) GetEmbeddingList 

func (r *EasyrecUserRealtimeEmbeddingMindResponse) GetEmbeddingList() []*EmbeddingInfo

func (*EasyrecUserRealtimeEmbeddingMindResponse) GetModuleType 

func (r *EasyrecUserRealtimeEmbeddingMindResponse) GetModuleType() bool

func (*EasyrecUserRealtimeEmbeddingMindResponse) GetScore 

func (r *EasyrecUserRealtimeEmbeddingMindResponse) GetScore() float64

func (*EasyrecUserRealtimeEmbeddingMindResponse) GetScoreMap 

func (r *EasyrecUserRealtimeEmbeddingMindResponse) GetScoreMap() map[string]float64

func (*EasyrecUserRealtimeEmbeddingMindResponse) GetUserEmbedding 

func (r *EasyrecUserRealtimeEmbeddingMindResponse) GetUserEmbedding() string

type EasyrecUserRealtimeEmbeddingResponse 

type EasyrecUserRealtimeEmbeddingResponse struct {
	EmbeddingList    []*EmbeddingInfo
	UserEmbedding    string
	GenerateFeatures *bytes.Buffer
}

func (*EasyrecUserRealtimeEmbeddingResponse) GetEmbeddingList 

func (r *EasyrecUserRealtimeEmbeddingResponse) GetEmbeddingList() []*EmbeddingInfo

func (*EasyrecUserRealtimeEmbeddingResponse) GetModuleType 

func (r *EasyrecUserRealtimeEmbeddingResponse) GetModuleType() bool

func (*EasyrecUserRealtimeEmbeddingResponse) GetScore 

func (r *EasyrecUserRealtimeEmbeddingResponse) GetScore() float64

func (*EasyrecUserRealtimeEmbeddingResponse) GetScoreMap 

func (r *EasyrecUserRealtimeEmbeddingResponse) GetScoreMap() map[string]float64

func (*EasyrecUserRealtimeEmbeddingResponse) GetUserEmbedding 

func (r *EasyrecUserRealtimeEmbeddingResponse) GetUserEmbedding() string

type EmbeddingInfo 

type EmbeddingInfo struct {
	ItemId string
	Score  float64
}

type FMRequest 

type FMRequest struct {
	EasRequest
	// contains filtered or unexported fields
}

func NewFMRequest 

func NewFMRequest() *FMRequest

func (*FMRequest) Invoke 

func (r *FMRequest) Invoke(requestData interface{}) (body interface{}, err error)

type HttpEasyrecRequest 

type HttpEasyrecRequest struct {
	EasRequest
}

func (*HttpEasyrecRequest) Invoke 

func (r *HttpEasyrecRequest) Invoke(requestData interface{}) (response interface{}, err error)

type IEasRequest 

type IEasRequest interface {
	Invoke(requestData interface{}) (body interface{}, err error)
	GetResponseFunc() response.ResponseFunc
}

type LincubRequest 

type LincubRequest struct {
	EasRequest
}

func (*LincubRequest) Invoke 

func (r *LincubRequest) Invoke(requestData interface{}) (body interface{}, err error)

type LincubRequestData 

type LincubRequestData struct {
	RequestId    string                   `json:"request_id"`
	Scene        string                   `json:"scene"`
	AlgoName     string                   `json:"algo"`
	UserId       string                   `json:"user_id"`
	Items        []string                 `json:"items"`
	Limit        int                      `json:"limit"`
	UserFeature  map[string]interface{}   `json:"user_feature"`
	ItemFeatures []map[string]interface{} `json:"item_features"`
}

type LinucbResponse 

type LinucbResponse struct {
	ErrorCode    int                   `json:"error_code"`
	ErrorMessage string                `json:"error_message"`
	Data         []*LinucbResponseItem `json:"data"`
}

type LinucbResponseItem 

type LinucbResponseItem struct {
	ItemId string  `json:"id"`
	Score  float64 `json:"score"`
}

func LinucbResponseFunc 

func LinucbResponseFunc(data interface{}) (ret []*LinucbResponseItem, err error)

func (*LinucbResponseItem) GetModuleType 

func (r *LinucbResponseItem) GetModuleType() bool

func (*LinucbResponseItem) GetScore 

func (r *LinucbResponseItem) GetScore() float64

func (*LinucbResponseItem) GetScoreMap 

func (r *LinucbResponseItem) GetScoreMap() map[string]float64

type PMMLRequest 

type PMMLRequest struct {
	EasRequest
}

func (*PMMLRequest) Invoke 

func (r *PMMLRequest) Invoke(requestData interface{}) (body interface{}, err error)

type TFRequest 

type TFRequest struct {
	EasRequest
	SignatureName string
	Outputs       []string
}

func (*TFRequest) Invoke 

func (r *TFRequest) Invoke(requestData interface{}) (response interface{}, err error)

func (*TFRequest) SetOutputs 

func (r *TFRequest) SetOutputs(outputs []string)

func (*TFRequest) SetSignatureName 

func (r *TFRequest) SetSignatureName(name string)

type TFServingRequest 

type TFServingRequest struct {
	EasRequest
	SignatureName string
	ModelName     string
	Outputs       []string
	Client        tensorflow_serving.PredictionServiceClient
}

func (*TFServingRequest) Invoke 

func (r *TFServingRequest) Invoke(requestData interface{}) (response interface{}, err error)

func (*TFServingRequest) SetModelName 

func (r *TFServingRequest) SetModelName(name string)

func (*TFServingRequest) SetOutputs 

func (r *TFServingRequest) SetOutputs(outputs []string)

func (*TFServingRequest) SetSignatureName 

func (r *TFServingRequest) SetSignatureName(name string)

type TorchrecEmbeddingItemsResponse added in v2.4.0 

type TorchrecEmbeddingItemsResponse struct {
	EmbeddingItems []*EmbeddingInfo
}

func (*TorchrecEmbeddingItemsResponse) GetEmbeddingItems added in v2.4.0 

func (r *TorchrecEmbeddingItemsResponse) GetEmbeddingItems() []*EmbeddingInfo

func (*TorchrecEmbeddingItemsResponse) GetModuleType added in v2.4.0 

func (r *TorchrecEmbeddingItemsResponse) GetModuleType() bool

func (*TorchrecEmbeddingItemsResponse) GetScore added in v2.4.0 

func (r *TorchrecEmbeddingItemsResponse) GetScore() float64

func (*TorchrecEmbeddingItemsResponse) GetScoreMap added in v2.4.0 

func (r *TorchrecEmbeddingItemsResponse) GetScoreMap() map[string]float64

type TorchrecEmbeddingResponse added in v2.2.5 

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

func (*TorchrecEmbeddingResponse) GetEmbedding added in v2.2.5 

func (r *TorchrecEmbeddingResponse) GetEmbedding() []float32

func (*TorchrecEmbeddingResponse) GetEmbeddingSize added in v2.2.5 

func (r *TorchrecEmbeddingResponse) GetEmbeddingSize() int

func (*TorchrecEmbeddingResponse) GetModuleType added in v2.2.5 

func (r *TorchrecEmbeddingResponse) GetModuleType() bool

func (*TorchrecEmbeddingResponse) GetScore added in v2.2.5 

func (r *TorchrecEmbeddingResponse) GetScore() float64

func (*TorchrecEmbeddingResponse) GetScoreMap added in v2.2.5 

func (r *TorchrecEmbeddingResponse) GetScoreMap() map[string]float64

Source Files

View all Source files

Directories

Path Synopsis

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.