grpc

README

Feast gRPC 扩展包

Feast gRPC 客户端实现，位于扩展包中，独立管理依赖。

架构说明

领域层接口：feature.FeatureService（核心包）

• 这是推荐使用的接口，位于领域层
• 所有特征服务都应实现此接口

基础设施层接口：ext/feast/http.Client（扩展包）

• 这是 Feast 特定的接口，位于基础设施层
• gRPC 客户端也实现此接口（与 HTTP 客户端共享接口）

推荐使用方式：通过适配器将 Feast 适配为 feature.FeatureService

安装

go get github.com/rushteam/reckit/ext/feast/grpc

使用方式

方式 1：通过适配器使用（推荐）

import (
    "github.com/rushteam/reckit/feature"
    feasthttp "github.com/rushteam/reckit/ext/feast/http"
    feastgrpc "github.com/rushteam/reckit/ext/feast/grpc"
)

// 1. 创建 Feast gRPC 客户端（基础设施层）
feastClient, err := feastgrpc.NewGrpcClient("localhost", 6565, "my_project")
if err != nil {
    log.Fatal(err)
}
defer feastClient.Close()

// 2. 创建特征映射配置（使用 HTTP 包的 FeatureMapping）
mapping := &feasthttp.FeatureMapping{
    UserFeatures: []string{"user_stats:age", "user_stats:gender"},
    ItemFeatures: []string{"item_stats:price", "item_stats:category"},
    UserEntityKey: "user_id",
    ItemEntityKey: "item_id",
}

// 3. 创建适配器（将 Feast 适配为 feature.FeatureService）
featureService := feasthttp.NewFeatureServiceAdapter(feastClient, mapping)

// 4. 作为 feature.FeatureService 使用（领域层接口）
var fs feature.FeatureService = featureService

方式 2：直接使用 Feast 客户端（不推荐）

import (
    feasthttp "github.com/rushteam/reckit/ext/feast/http"
    feastgrpc "github.com/rushteam/reckit/ext/feast/grpc"
)

// 直接使用基础设施层接口（不推荐，应使用领域层接口）
client, err := feastgrpc.NewGrpcClient("localhost", 6565, "my_project")
var c feasthttp.Client = client // gRPC 客户端也实现 http.Client 接口

依赖

• github.com/rushteam/reckit - 核心包（领域层接口 feature.FeatureService）
• github.com/rushteam/reckit/ext/feast/http - HTTP 扩展包（共享接口和适配器）
• github.com/feast-dev/feast/sdk/go - Feast 官方 SDK

自行实现

你也可以参考此实现，自行实现 feature.FeatureService 接口，满足你的特定需求。

Documentation

Index

• type GrpcClient
  • func NewGrpcClient(host string, port int, project string, opts ...http.ClientOption) (*GrpcClient, error)
  • func (c *GrpcClient) Close() error
  • func (c *GrpcClient) GetFeatureService(ctx context.Context) (*http.FeatureServiceInfo, error)
  • func (c *GrpcClient) GetHistoricalFeatures(ctx context.Context, req *http.GetHistoricalFeaturesRequest) (*http.GetHistoricalFeaturesResponse, error)
  • func (c *GrpcClient) GetOnlineFeatures(ctx context.Context, req *http.GetOnlineFeaturesRequest) (*http.GetOnlineFeaturesResponse, error)
  • func (c *GrpcClient) ListFeatures(ctx context.Context) ([]http.Feature, error)
  • func (c *GrpcClient) Materialize(ctx context.Context, req *http.MaterializeRequest) error

Types

type GrpcClient

type GrpcClient struct {
	Project  string
	Endpoint string
	// contains filtered or unexported fields
}

GrpcClient 是基于官方 Feast Go SDK 的 gRPC 客户端实现。

注意：此实现位于扩展包中，需要单独引入：

go get github.com/rushteam/reckit/ext/feast/grpc

func NewGrpcClient

func NewGrpcClient(host string, port int, project string, opts ...http.ClientOption) (*GrpcClient, error)

NewGrpcClient 创建一个基于官方 SDK 的 Feast gRPC 客户端。

func (*GrpcClient) Close

func (c *GrpcClient) Close() error

Close 关闭客户端连接（实现 http.Client 接口）

func (*GrpcClient) GetFeatureService

func (c *GrpcClient) GetFeatureService(ctx context.Context) (*http.FeatureServiceInfo, error)

func (*GrpcClient) GetHistoricalFeatures

func (c *GrpcClient) GetHistoricalFeatures(ctx context.Context, req *http.GetHistoricalFeaturesRequest) (*http.GetHistoricalFeaturesResponse, error)

func (*GrpcClient) GetOnlineFeatures

func (c *GrpcClient) GetOnlineFeatures(ctx context.Context, req *http.GetOnlineFeaturesRequest) (*http.GetOnlineFeaturesResponse, error)

GetOnlineFeatures 实现 Client 接口

func (*GrpcClient) ListFeatures

func (c *GrpcClient) ListFeatures(ctx context.Context) ([]http.Feature, error)

func (*GrpcClient) Materialize

func (c *GrpcClient) Materialize(ctx context.Context, req *http.MaterializeRequest) error