v1

package
v0.5.300 Latest Latest
Warning

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

 Go to latest Published: Oct 25, 2022 License: Apache-2.0 Imports: 11 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: "Sync",
			Handler:    _OfflineFeatureStoreService_Sync_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 GenerateTrainingDatasetRequest 

type GenerateTrainingDatasetRequest struct {
	Model *v1alpha1.ModelClass `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTrainingDatasetRequest) Descriptor deprecated 

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

Deprecated: Use GenerateTrainingDatasetRequest.ProtoReflect.Descriptor instead.

func (*GenerateTrainingDatasetRequest) GetModel added in v0.5.292 

func (x *GenerateTrainingDatasetRequest) GetModel() *v1alpha1.ModelClass

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 {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateTrainingDatasetResponse) Descriptor deprecated 

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

Deprecated: Use GenerateTrainingDatasetResponse.ProtoReflect.Descriptor instead.

func (*GenerateTrainingDatasetResponse) GetPath added in v0.5.292 

func (x *GenerateTrainingDatasetResponse) GetPath() string

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 OfflineFeatureStoreServiceClient 

type OfflineFeatureStoreServiceClient interface {
	// Sync to the online store
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncResponse, error)
	// Generate training dataset.
	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 {
	// Sync to the online store
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
	// Generate training dataset.
	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 SyncRequest added in v0.5.292 

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

func (*SyncRequest) Descriptor deprecated added in v0.5.292 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) ProtoMessage added in v0.5.292 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect added in v0.5.292 

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

func (*SyncRequest) Reset added in v0.5.292 

func (x *SyncRequest) Reset()

func (*SyncRequest) String added in v0.5.292 

func (x *SyncRequest) String() string

type SyncResponse added in v0.5.292 

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

func (*SyncResponse) Descriptor deprecated added in v0.5.292 

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

Deprecated: Use SyncResponse.ProtoReflect.Descriptor instead.

func (*SyncResponse) ProtoMessage added in v0.5.292 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) ProtoReflect added in v0.5.292 

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

func (*SyncResponse) Reset added in v0.5.292 

func (x *SyncResponse) Reset()

func (*SyncResponse) String added in v0.5.292 

func (x *SyncResponse) String() string

type UnimplementedOfflineFeatureStoreServiceServer 

type UnimplementedOfflineFeatureStoreServiceServer struct {
}

UnimplementedOfflineFeatureStoreServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedOfflineFeatureStoreServiceServer) GenerateTrainingDataset 

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

func (UnimplementedOfflineFeatureStoreServiceServer) Sync added in v0.5.292 

func (UnimplementedOfflineFeatureStoreServiceServer) Sync(context.Context, *SyncRequest) (*SyncResponse, 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.

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.