v1

package
v0.5.289 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 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_offlinefeaturestored_v1_offlinefeaturestored_proto protoreflect.FileDescriptor
View Source 
var OfflineFeatureStoreService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "github.com.metaprov.modelaapi.services.offlinefeaturestored.v1.OfflineFeatureStoreService",
	HandlerType: (*OfflineFeatureStoreServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateFeature",
			Handler:    _OfflineFeatureStoreService_CreateFeature_Handler,
		},
		{
			MethodName: "DeleteFeature",
			Handler:    _OfflineFeatureStoreService_DeleteFeature_Handler,
		},
		{
			MethodName: "UpdateFeature",
			Handler:    _OfflineFeatureStoreService_UpdateFeature_Handler,
		},
		{
			MethodName: "ListFeatures",
			Handler:    _OfflineFeatureStoreService_ListFeatures_Handler,
		},
		{
			MethodName: "GetFeature",
			Handler:    _OfflineFeatureStoreService_GetFeature_Handler,
		},
		{
			MethodName: "GenerateTrainingDataset",
			Handler:    _OfflineFeatureStoreService_GenerateTrainingDataset_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/metaprov/modelaapi/services/offlinefeaturestored/v1/offlinefeaturestored.proto",
}

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

Functions

func RegisterOfflineFeatureStoreServiceServer 

func RegisterOfflineFeatureStoreServiceServer(s grpc.ServiceRegistrar, srv OfflineFeatureStoreServiceServer)

Types

type CreateFeatureRequest 

type CreateFeatureRequest struct {
	FeatureSource *v1alpha1.FeatureGroup `protobuf:"bytes,1,opt,name=featureSource,proto3" json:"featureSource,omitempty"`
	Connection    *v1alpha11.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 (*CreateFeatureRequest) Descriptor deprecated 

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

Deprecated: Use CreateFeatureRequest.ProtoReflect.Descriptor instead.

func (*CreateFeatureRequest) GetConnection 

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

func (*CreateFeatureRequest) GetFeatureSource added in v0.5.260 

func (x *CreateFeatureRequest) GetFeatureSource() *v1alpha1.FeatureGroup

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 GenerateTrainingDatasetRequest 

type GenerateTrainingDatasetRequest 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"`
	Features *v1alpha1.FeatureGroupList `protobuf:"bytes,3,opt,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTrainingDatasetRequest) Descriptor deprecated 

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

Deprecated: Use GenerateTrainingDatasetRequest.ProtoReflect.Descriptor instead.

func (*GenerateTrainingDatasetRequest) GetFeatures added in v0.4.479 

func (x *GenerateTrainingDatasetRequest) GetFeatures() *v1alpha1.FeatureGroupList

func (*GenerateTrainingDatasetRequest) GetName 

func (x *GenerateTrainingDatasetRequest) GetName() string

func (*GenerateTrainingDatasetRequest) GetNs 

func (x *GenerateTrainingDatasetRequest) GetNs() string

func (*GenerateTrainingDatasetRequest) ProtoMessage 

func (*GenerateTrainingDatasetRequest) ProtoMessage()

func (*GenerateTrainingDatasetRequest) ProtoReflect 

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

func (*GenerateTrainingDatasetRequest) Reset 

func (x *GenerateTrainingDatasetRequest) Reset()

func (*GenerateTrainingDatasetRequest) String 

func (x *GenerateTrainingDatasetRequest) String() string

type GenerateTrainingDatasetResponse 

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

func (*GenerateTrainingDatasetResponse) Descriptor deprecated 

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

Deprecated: Use GenerateTrainingDatasetResponse.ProtoReflect.Descriptor instead.

func (*GenerateTrainingDatasetResponse) ProtoMessage 

func (*GenerateTrainingDatasetResponse) ProtoMessage()

func (*GenerateTrainingDatasetResponse) ProtoReflect 

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

func (*GenerateTrainingDatasetResponse) Reset 

func (x *GenerateTrainingDatasetResponse) Reset()

func (*GenerateTrainingDatasetResponse) String 

func (x *GenerateTrainingDatasetResponse) 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"`
	// contains filtered or unexported fields
}

func (*GetFeatureRequest) Descriptor deprecated 

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

Deprecated: Use GetFeatureRequest.ProtoReflect.Descriptor instead.

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 {
	Feature *v1alpha1.FeatureGroup `protobuf:"bytes,1,opt,name=feature,proto3" json:"feature,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFeatureResponse) Descriptor deprecated 

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

Deprecated: Use GetFeatureResponse.ProtoReflect.Descriptor instead.

func (*GetFeatureResponse) GetFeature added in v0.4.479 

func (x *GetFeatureResponse) GetFeature() *v1alpha1.FeatureGroup

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 {
	Features *v1alpha1.FeatureGroupList `protobuf:"bytes,3,opt,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFeaturesResponse) Descriptor deprecated 

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

Deprecated: Use ListFeaturesResponse.ProtoReflect.Descriptor instead.

func (*ListFeaturesResponse) GetFeatures added in v0.4.479 

func (x *ListFeaturesResponse) GetFeatures() *v1alpha1.FeatureGroupList

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 OfflineFeatureStoreServiceClient 

type OfflineFeatureStoreServiceClient interface {
	CreateFeature(ctx context.Context, in *CreateFeatureRequest, opts ...grpc.CallOption) (*CreateFeatureResponse, error)
	DeleteFeature(ctx context.Context, in *DeleteFeatureRequest, opts ...grpc.CallOption) (*DeleteFeatureResponse, error)
	UpdateFeature(ctx context.Context, in *UpdateFeatureRequest, opts ...grpc.CallOption) (*UpdateFeatureResponse, error)
	ListFeatures(ctx context.Context, in *ListFeaturesRequest, opts ...grpc.CallOption) (*ListFeaturesResponse, error)
	GetFeature(ctx context.Context, in *GetFeatureRequest, opts ...grpc.CallOption) (*GetFeatureResponse, error)
	GenerateTrainingDataset(ctx context.Context, in *GenerateTrainingDatasetRequest, opts ...grpc.CallOption) (*GenerateTrainingDatasetResponse, error)
}

OfflineFeatureStoreServiceClient is the client API for OfflineFeatureStoreService 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 NewOfflineFeatureStoreServiceClient 

func NewOfflineFeatureStoreServiceClient(cc grpc.ClientConnInterface) OfflineFeatureStoreServiceClient

type OfflineFeatureStoreServiceServer 

type OfflineFeatureStoreServiceServer interface {
	CreateFeature(context.Context, *CreateFeatureRequest) (*CreateFeatureResponse, error)
	DeleteFeature(context.Context, *DeleteFeatureRequest) (*DeleteFeatureResponse, error)
	UpdateFeature(context.Context, *UpdateFeatureRequest) (*UpdateFeatureResponse, error)
	ListFeatures(context.Context, *ListFeaturesRequest) (*ListFeaturesResponse, error)
	GetFeature(context.Context, *GetFeatureRequest) (*GetFeatureResponse, error)
	GenerateTrainingDataset(context.Context, *GenerateTrainingDatasetRequest) (*GenerateTrainingDatasetResponse, error)
	// contains filtered or unexported methods
}

OfflineFeatureStoreServiceServer is the server API for OfflineFeatureStoreService service. All implementations must embed UnimplementedOfflineFeatureStoreServiceServer for forward compatibility

type UnimplementedOfflineFeatureStoreServiceServer 

type UnimplementedOfflineFeatureStoreServiceServer struct {
}

UnimplementedOfflineFeatureStoreServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOfflineFeatureStoreServiceServer) CreateFeature 

func (UnimplementedOfflineFeatureStoreServiceServer) CreateFeature(context.Context, *CreateFeatureRequest) (*CreateFeatureResponse, error)

func (UnimplementedOfflineFeatureStoreServiceServer) DeleteFeature 

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

func (UnimplementedOfflineFeatureStoreServiceServer) GenerateTrainingDataset 

func (UnimplementedOfflineFeatureStoreServiceServer) GenerateTrainingDataset(context.Context, *GenerateTrainingDatasetRequest) (*GenerateTrainingDatasetResponse, error)

func (UnimplementedOfflineFeatureStoreServiceServer) GetFeature 

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

func (UnimplementedOfflineFeatureStoreServiceServer) ListFeatures 

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

func (UnimplementedOfflineFeatureStoreServiceServer) UpdateFeature 

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

type UnsafeOfflineFeatureStoreServiceServer added in v0.4.687 

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

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

type UpdateFeatureRequest 

type UpdateFeatureRequest struct {
	FeatureSource *v1alpha1.FeatureGroup `protobuf:"bytes,1,opt,name=featureSource,proto3" json:"featureSource,omitempty"`
	Connection    *v1alpha11.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() *v1alpha11.Connection

func (*UpdateFeatureRequest) GetFeatureSource added in v0.5.260 

func (x *UpdateFeatureRequest) GetFeatureSource() *v1alpha1.FeatureGroup

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.