v1

package
v0.5.271 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_github_com_metaprov_modelaapi_services_onlinefeaturestored_v1_onlinefeaturestored_proto protoreflect.FileDescriptor
View Source 
var OnlineFeatureStoreService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.onlinefeaturestored.v1.OnlineFeatureStoreService",
	HandlerType: (*OnlineFeatureStoreServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IngestFeatures",
			Handler:    _OnlineFeatureStoreService_IngestFeatures_Handler,
		},
		{
			MethodName: "DeleteFeature",
			Handler:    _OnlineFeatureStoreService_DeleteFeature_Handler,
		},
		{
			MethodName: "ListFeatures",
			Handler:    _OnlineFeatureStoreService_ListFeatures_Handler,
		},
		{
			MethodName: "GetFeature",
			Handler:    _OnlineFeatureStoreService_GetFeature_Handler,
		},
		{
			MethodName: "UpdateFeature",
			Handler:    _OnlineFeatureStoreService_UpdateFeature_Handler,
		},
		{
			MethodName: "Enrich",
			Handler:    _OnlineFeatureStoreService_Enrich_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/onlinefeaturestored/v1/onlinefeaturestored.proto",
}

OnlineFeatureStoreService_ServiceDesc is the grpc.ServiceDesc for OnlineFeatureStoreService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOnlineFeatureStoreServiceServer 

func RegisterOnlineFeatureStoreServiceServer(s grpc.ServiceRegistrar, srv OnlineFeatureStoreServiceServer)

Types

type CreateFeatureRequest 

type CreateFeatureRequest struct {
	Name           string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ns             string               `protobuf:"bytes,2,opt,name=ns,proto3" json:"ns,omitempty"`
	ConnectionName string               `protobuf:"bytes,3,opt,name=connectionName,proto3" json:"connectionName,omitempty"`
	Connection     *v1alpha1.Connection `protobuf:"bytes,4,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret         map[string][]byte    `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateFeatureRequest) Descriptor deprecated 

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

Deprecated: Use CreateFeatureRequest.ProtoReflect.Descriptor instead.

func (*CreateFeatureRequest) GetConnection added in v0.4.479 

func (x *CreateFeatureRequest) GetConnection() *v1alpha1.Connection

func (*CreateFeatureRequest) GetConnectionName 

func (x *CreateFeatureRequest) GetConnectionName() string

func (*CreateFeatureRequest) GetName 

func (x *CreateFeatureRequest) GetName() string

func (*CreateFeatureRequest) GetNs 

func (x *CreateFeatureRequest) GetNs() string

func (*CreateFeatureRequest) GetSecret 

func (x *CreateFeatureRequest) GetSecret() map[string][]byte

func (*CreateFeatureRequest) ProtoMessage 

func (*CreateFeatureRequest) ProtoMessage()

func (*CreateFeatureRequest) ProtoReflect 

func (x *CreateFeatureRequest) ProtoReflect() protoreflect.Message

func (*CreateFeatureRequest) Reset 

func (x *CreateFeatureRequest) Reset()

func (*CreateFeatureRequest) String 

func (x *CreateFeatureRequest) String() string

type CreateFeatureResponse 

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

func (*CreateFeatureResponse) Descriptor deprecated 

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

Deprecated: Use CreateFeatureResponse.ProtoReflect.Descriptor instead.

func (*CreateFeatureResponse) ProtoMessage 

func (*CreateFeatureResponse) ProtoMessage()

func (*CreateFeatureResponse) ProtoReflect 

func (x *CreateFeatureResponse) ProtoReflect() protoreflect.Message

func (*CreateFeatureResponse) Reset 

func (x *CreateFeatureResponse) Reset()

func (*CreateFeatureResponse) String 

func (x *CreateFeatureResponse) String() string

type DeleteFeatureRequest 

type DeleteFeatureRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ns   string `protobuf:"bytes,2,opt,name=ns,proto3" json:"ns,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFeatureRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFeatureRequest.ProtoReflect.Descriptor instead.

func (*DeleteFeatureRequest) GetName 

func (x *DeleteFeatureRequest) GetName() string

func (*DeleteFeatureRequest) GetNs 

func (x *DeleteFeatureRequest) GetNs() string

func (*DeleteFeatureRequest) ProtoMessage 

func (*DeleteFeatureRequest) ProtoMessage()

func (*DeleteFeatureRequest) ProtoReflect 

func (x *DeleteFeatureRequest) ProtoReflect() protoreflect.Message

func (*DeleteFeatureRequest) Reset 

func (x *DeleteFeatureRequest) Reset()

func (*DeleteFeatureRequest) String 

func (x *DeleteFeatureRequest) String() string

type DeleteFeatureResponse 

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

func (*DeleteFeatureResponse) Descriptor deprecated 

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

Deprecated: Use DeleteFeatureResponse.ProtoReflect.Descriptor instead.

func (*DeleteFeatureResponse) ProtoMessage 

func (*DeleteFeatureResponse) ProtoMessage()

func (*DeleteFeatureResponse) ProtoReflect 

func (x *DeleteFeatureResponse) ProtoReflect() protoreflect.Message

func (*DeleteFeatureResponse) Reset 

func (x *DeleteFeatureResponse) Reset()

func (*DeleteFeatureResponse) String 

func (x *DeleteFeatureResponse) String() string

type EnrichRequest 

type EnrichRequest struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Record string `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*EnrichRequest) Descriptor deprecated 

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

Deprecated: Use EnrichRequest.ProtoReflect.Descriptor instead.

func (*EnrichRequest) GetId 

func (x *EnrichRequest) GetId() string

func (*EnrichRequest) GetRecord 

func (x *EnrichRequest) GetRecord() string

func (*EnrichRequest) ProtoMessage 

func (*EnrichRequest) ProtoMessage()

func (*EnrichRequest) ProtoReflect 

func (x *EnrichRequest) ProtoReflect() protoreflect.Message

func (*EnrichRequest) Reset 

func (x *EnrichRequest) Reset()

func (*EnrichRequest) String 

func (x *EnrichRequest) String() string

type EnrichResponse 

type EnrichResponse struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Record string `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*EnrichResponse) Descriptor deprecated 

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

Deprecated: Use EnrichResponse.ProtoReflect.Descriptor instead.

func (*EnrichResponse) GetId 

func (x *EnrichResponse) GetId() string

func (*EnrichResponse) GetRecord 

func (x *EnrichResponse) GetRecord() string

func (*EnrichResponse) ProtoMessage 

func (*EnrichResponse) ProtoMessage()

func (*EnrichResponse) ProtoReflect 

func (x *EnrichResponse) ProtoReflect() protoreflect.Message

func (*EnrichResponse) Reset 

func (x *EnrichResponse) Reset()

func (*EnrichResponse) String 

func (x *EnrichResponse) String() string

type GetFeatureRequest 

type GetFeatureRequest struct {
	Name          string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ns            string                     `protobuf:"bytes,2,opt,name=ns,proto3" json:"ns,omitempty"`
	FeatureSource *v1alpha11.FeaturesetClass `protobuf:"bytes,3,opt,name=featureSource,proto3" json:"featureSource,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureRequest) Descriptor deprecated 

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

Deprecated: Use GetFeatureRequest.ProtoReflect.Descriptor instead.

func (*GetFeatureRequest) GetFeatureSource added in v0.5.260 

func (x *GetFeatureRequest) GetFeatureSource() *v1alpha11.FeaturesetClass

func (*GetFeatureRequest) GetName 

func (x *GetFeatureRequest) GetName() string

func (*GetFeatureRequest) GetNs 

func (x *GetFeatureRequest) GetNs() string

func (*GetFeatureRequest) ProtoMessage 

func (*GetFeatureRequest) ProtoMessage()

func (*GetFeatureRequest) ProtoReflect 

func (x *GetFeatureRequest) ProtoReflect() protoreflect.Message

func (*GetFeatureRequest) Reset 

func (x *GetFeatureRequest) Reset()

func (*GetFeatureRequest) String 

func (x *GetFeatureRequest) String() string

type GetFeatureResponse 

type GetFeatureResponse struct {
	FeatureSource *v1alpha11.FeaturesetClass `protobuf:"bytes,1,opt,name=featureSource,proto3" json:"featureSource,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureResponse) Descriptor deprecated 

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

Deprecated: Use GetFeatureResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureResponse) GetFeatureSource added in v0.5.260 

func (x *GetFeatureResponse) GetFeatureSource() *v1alpha11.FeaturesetClass

func (*GetFeatureResponse) ProtoMessage 

func (*GetFeatureResponse) ProtoMessage()

func (*GetFeatureResponse) ProtoReflect 

func (x *GetFeatureResponse) ProtoReflect() protoreflect.Message

func (*GetFeatureResponse) Reset 

func (x *GetFeatureResponse) Reset()

func (*GetFeatureResponse) String 

func (x *GetFeatureResponse) String() string

type ListFeaturesRequest 

type ListFeaturesRequest struct {
	Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeaturesRequest) Descriptor deprecated 

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

Deprecated: Use ListFeaturesRequest.ProtoReflect.Descriptor instead.

func (*ListFeaturesRequest) GetNs 

func (x *ListFeaturesRequest) GetNs() string

func (*ListFeaturesRequest) ProtoMessage 

func (*ListFeaturesRequest) ProtoMessage()

func (*ListFeaturesRequest) ProtoReflect 

func (x *ListFeaturesRequest) ProtoReflect() protoreflect.Message

func (*ListFeaturesRequest) Reset 

func (x *ListFeaturesRequest) Reset()

func (*ListFeaturesRequest) String 

func (x *ListFeaturesRequest) String() string

type ListFeaturesResponse 

type ListFeaturesResponse struct {
	FeatureSources *v1alpha11.FeaturesetClassList `protobuf:"bytes,1,opt,name=featureSources,proto3" json:"featureSources,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeaturesResponse) Descriptor deprecated 

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

Deprecated: Use ListFeaturesResponse.ProtoReflect.Descriptor instead.

func (*ListFeaturesResponse) GetFeatureSources added in v0.5.260 

func (x *ListFeaturesResponse) GetFeatureSources() *v1alpha11.FeaturesetClassList

func (*ListFeaturesResponse) ProtoMessage 

func (*ListFeaturesResponse) ProtoMessage()

func (*ListFeaturesResponse) ProtoReflect 

func (x *ListFeaturesResponse) ProtoReflect() protoreflect.Message

func (*ListFeaturesResponse) Reset 

func (x *ListFeaturesResponse) Reset()

func (*ListFeaturesResponse) String 

func (x *ListFeaturesResponse) String() string

type OnlineFeatureStoreServiceClient 

type OnlineFeatureStoreServiceClient interface {
	IngestFeatures(ctx context.Context, in *CreateFeatureRequest, opts ...grpc.CallOption) (*CreateFeatureResponse, error)
	DeleteFeature(ctx context.Context, in *DeleteFeatureRequest, opts ...grpc.CallOption) (*DeleteFeatureResponse, error)
	ListFeatures(ctx context.Context, in *ListFeaturesRequest, opts ...grpc.CallOption) (*ListFeaturesResponse, error)
	GetFeature(ctx context.Context, in *GetFeatureRequest, opts ...grpc.CallOption) (*GetFeatureResponse, error)
	UpdateFeature(ctx context.Context, in *UpdateFeatureRequest, opts ...grpc.CallOption) (*UpdateFeatureResponse, error)
	Enrich(ctx context.Context, in *EnrichRequest, opts ...grpc.CallOption) (*EnrichResponse, error)
}

OnlineFeatureStoreServiceClient is the client API for OnlineFeatureStoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOnlineFeatureStoreServiceClient 

func NewOnlineFeatureStoreServiceClient(cc grpc.ClientConnInterface) OnlineFeatureStoreServiceClient

type OnlineFeatureStoreServiceServer 

type OnlineFeatureStoreServiceServer interface {
	IngestFeatures(context.Context, *CreateFeatureRequest) (*CreateFeatureResponse, error)
	DeleteFeature(context.Context, *DeleteFeatureRequest) (*DeleteFeatureResponse, error)
	ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)
	GetFeature(context.Context, *GetFeatureRequest) (*GetFeatureResponse, error)
	UpdateFeature(context.Context, *UpdateFeatureRequest) (*UpdateFeatureResponse, error)
	Enrich(context.Context, *EnrichRequest) (*EnrichResponse, error)
	// contains filtered or unexported methods
}

OnlineFeatureStoreServiceServer is the server API for OnlineFeatureStoreService service. All implementations must embed UnimplementedOnlineFeatureStoreServiceServer for forward compatibility

type UnimplementedOnlineFeatureStoreServiceServer 

type UnimplementedOnlineFeatureStoreServiceServer struct {
}

UnimplementedOnlineFeatureStoreServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOnlineFeatureStoreServiceServer) DeleteFeature 

func (UnimplementedOnlineFeatureStoreServiceServer) DeleteFeature(context.Context, *DeleteFeatureRequest) (*DeleteFeatureResponse, error)

func (UnimplementedOnlineFeatureStoreServiceServer) Enrich 

func (UnimplementedOnlineFeatureStoreServiceServer) Enrich(context.Context, *EnrichRequest) (*EnrichResponse, error)

func (UnimplementedOnlineFeatureStoreServiceServer) GetFeature 

func (UnimplementedOnlineFeatureStoreServiceServer) GetFeature(context.Context, *GetFeatureRequest) (*GetFeatureResponse, error)

func (UnimplementedOnlineFeatureStoreServiceServer) IngestFeatures added in v0.5.246 

func (UnimplementedOnlineFeatureStoreServiceServer) IngestFeatures(context.Context, *CreateFeatureRequest) (*CreateFeatureResponse, error)

func (UnimplementedOnlineFeatureStoreServiceServer) ListFeatures 

func (UnimplementedOnlineFeatureStoreServiceServer) ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)

func (UnimplementedOnlineFeatureStoreServiceServer) UpdateFeature 

func (UnimplementedOnlineFeatureStoreServiceServer) UpdateFeature(context.Context, *UpdateFeatureRequest) (*UpdateFeatureResponse, error)

type UnsafeOnlineFeatureStoreServiceServer added in v0.4.687 

type UnsafeOnlineFeatureStoreServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeOnlineFeatureStoreServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OnlineFeatureStoreServiceServer will result in compilation errors.

type UpdateFeatureRequest 

type UpdateFeatureRequest struct {
	FeatureSource *v1alpha11.FeaturesetClass `protobuf:"bytes,1,opt,name=featureSource,proto3" json:"featureSource,omitempty"`
	Connection    *v1alpha1.Connection       `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	Secret        map[string][]byte          `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*UpdateFeatureRequest) Descriptor deprecated 

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

Deprecated: Use UpdateFeatureRequest.ProtoReflect.Descriptor instead.

func (*UpdateFeatureRequest) GetConnection 

func (x *UpdateFeatureRequest) GetConnection() *v1alpha1.Connection

func (*UpdateFeatureRequest) GetFeatureSource added in v0.5.260 

func (x *UpdateFeatureRequest) GetFeatureSource() *v1alpha11.FeaturesetClass

func (*UpdateFeatureRequest) GetSecret 

func (x *UpdateFeatureRequest) GetSecret() map[string][]byte

func (*UpdateFeatureRequest) ProtoMessage 

func (*UpdateFeatureRequest) ProtoMessage()

func (*UpdateFeatureRequest) ProtoReflect 

func (x *UpdateFeatureRequest) ProtoReflect() protoreflect.Message

func (*UpdateFeatureRequest) Reset 

func (x *UpdateFeatureRequest) Reset()

func (*UpdateFeatureRequest) String 

func (x *UpdateFeatureRequest) String() string

type UpdateFeatureResponse 

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

func (*UpdateFeatureResponse) Descriptor deprecated 

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

Deprecated: Use UpdateFeatureResponse.ProtoReflect.Descriptor instead.

func (*UpdateFeatureResponse) ProtoMessage 

func (*UpdateFeatureResponse) ProtoMessage()

func (*UpdateFeatureResponse) ProtoReflect 

func (x *UpdateFeatureResponse) ProtoReflect() protoreflect.Message

func (*UpdateFeatureResponse) Reset 

func (x *UpdateFeatureResponse) Reset()

func (*UpdateFeatureResponse) String 

func (x *UpdateFeatureResponse) String() string

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.