httpapis

Documentation

Index

• Variables
• func WithConfig(config *FeastHttpClientConfig) optparams.Option[FeastHttpClientConfig]
• func WithQueryAddress(address string) optparams.Option[FeastHttpClientConfig]
• func WithQueryTimeout(timeout int) optparams.Option[FeastHttpClientConfig]
• type FeastHttpClient
  • func New(opts ...optparams.Option[FeastHttpClientConfig]) *FeastHttpClient
  • func (c *FeastHttpClient) GetOnlineFeatures(q *GetOnlineFeaturesHttpReq) (*GetOnlineFeaturesHttpResp, error)
  • func (c *FeastHttpClient) Health() error
  • func (c *FeastHttpClient) Init(opts ...optparams.Option[FeastHttpClientConfig]) error
  • func (c *FeastHttpClient) Push(q *PushReqest) error
• type FeastHttpClientConfig
• type GetOnlineFeaturesHttpReq
• type GetOnlineFeaturesHttpResp
• type GetOnlineFeaturesHttpRespMetaData
• type GetOnlineFeaturesHttpRespResult
• type PushReqest

Variables

var DefaultSDK = New()

DefaultSDK 默认的sdk,需要使用Init方法初始化

var ErrClientInited = errors.New("client already inited")

var ErrClientNotInit = errors.New("client not init")

var ErrHttpQueryNotOK = errors.New("http query not ok")

Functions

func WithConfig

func WithConfig(config *FeastHttpClientConfig) optparams.Option[FeastHttpClientConfig]

UntilEnd NewCtx方法的参数,用于设置ctx为不会超时

func WithQueryAddress

func WithQueryAddress(address string) optparams.Option[FeastHttpClientConfig]

WithQueryAddress Init方法的参数,用于设置sdk请求的地址 @params address ...string 连接服务的主机地址

func WithQueryTimeout

func WithQueryTimeout(timeout int) optparams.Option[FeastHttpClientConfig]

WithQueryTimeout sdk.Init方法的参数,用于设置sdk请求服务的最大超时时间 @params wait int 请求服务的最大超时时间,单位ms

Types

type FeastHttpClient

type FeastHttpClient struct {
	SDKConfig *FeastHttpClientConfig
	// contains filtered or unexported fields
}

func New

func New(opts ...optparams.Option[FeastHttpClientConfig]) *FeastHttpClient

func (*FeastHttpClient) GetOnlineFeatures

func (c *FeastHttpClient) GetOnlineFeatures(q *GetOnlineFeaturesHttpReq) (*GetOnlineFeaturesHttpResp, error)

GetOnlineFeatures 获取数据接口 @params q *GetOnlineFeaturesHttpReq 请求数据 @returns *GetOnlineFeaturesHttpResp 返回数据

func (*FeastHttpClient) Health

func (c *FeastHttpClient) Health() error

Health 健康检查接口

func (*FeastHttpClient) Init

func (c *FeastHttpClient) Init(opts ...optparams.Option[FeastHttpClientConfig]) error

Init 初始化

func (*FeastHttpClient) Push

func (c *FeastHttpClient) Push(q *PushReqest) error

Push 推送数据接口 @params q *PushReqest push请求

type FeastHttpClientConfig

type FeastHttpClientConfig struct {
	Query_Address string `json:"query_address" jsonschema:"required,description=连接服务的主机地址"`
	Query_Timeout int    `json:"query_timeout,omitempty" jsonschema:"description=请求服务的最大超时时间单位ms"`
}

type GetOnlineFeaturesHttpReq

type GetOnlineFeaturesHttpReq struct {
	FullFeatureNames bool           `json:"full_feature_names"`
	Entities         map[string]any `json:"entities"`
	FeatureService   string         `json:"feature_service,omitempty"`
	Features         []string       `json:"features,omitempty"`
}

type GetOnlineFeaturesHttpResp

type GetOnlineFeaturesHttpResp struct {
	MetaData *GetOnlineFeaturesHttpRespMetaData `json:"metadata"`
	Results  []*GetOnlineFeaturesHttpRespResult `json:"results"`
}

type GetOnlineFeaturesHttpRespMetaData

type GetOnlineFeaturesHttpRespMetaData struct {
	FeatureNames []string `json:"feature_names"`
}

type GetOnlineFeaturesHttpRespResult

type GetOnlineFeaturesHttpRespResult struct {
	EventTimestamps []string `json:"event_timestamps"`
	Statuses        []string `json:"statuses"`
	Values          []any    `json:"values"`
}

type PushReqest

type PushReqest struct {
	PushSourceName     string         `json:"push_source_name"`
	DF                 map[string]any `json:"df"`
	AllowRegistryCache bool           `json:"allow_registry_cache"`
	To                 string         `json:"to"`
}

PushReqest push接口的请求结构