upiv1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2023 License: Apache-2.0 Imports: 18 Imported by: 8

Documentation

Overview

Package upiv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package upiv1 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_DOUBLE",
		2: "TYPE_INTEGER",
		3: "TYPE_STRING",
	}
	Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"TYPE_DOUBLE":      1,
		"TYPE_INTEGER":     2,
		"TYPE_STRING":      3,
	}
)

Enum value maps for Type.

View Source 
var File_caraml_upi_v1_header_proto protoreflect.FileDescriptor
View Source 
var File_caraml_upi_v1_observation_log_proto protoreflect.FileDescriptor
View Source 
var File_caraml_upi_v1_prediction_log_proto protoreflect.FileDescriptor
View Source 
var File_caraml_upi_v1_router_log_proto protoreflect.FileDescriptor
View Source 
var File_caraml_upi_v1_table_proto protoreflect.FileDescriptor
View Source 
var File_caraml_upi_v1_type_proto protoreflect.FileDescriptor
View Source 
var File_caraml_upi_v1_upi_proto protoreflect.FileDescriptor
View Source 
var File_caraml_upi_v1_variable_proto protoreflect.FileDescriptor
View Source 
var ObservationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "caraml.upi.v1.ObservationService",
	HandlerType: (*ObservationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "LogObservations",
			Handler:    _ObservationService_LogObservations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "caraml/upi/v1/observation_log.proto",
}

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

View Source 
var UniversalPredictionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "caraml.upi.v1.UniversalPredictionService",
	HandlerType: (*UniversalPredictionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PredictValues",
			Handler:    _UniversalPredictionService_PredictValues_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "caraml/upi/v1/upi.proto",
}

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

Functions

func RegisterObservationServiceHandler 

func RegisterObservationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterObservationServiceHandler registers the http handlers for service ObservationService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterObservationServiceHandlerClient 

func RegisterObservationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ObservationServiceClient) error

RegisterObservationServiceHandlerClient registers the http handlers for service ObservationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ObservationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ObservationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ObservationServiceClient" to call the correct interceptors.

func RegisterObservationServiceHandlerFromEndpoint 

func RegisterObservationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterObservationServiceHandlerFromEndpoint is same as RegisterObservationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterObservationServiceHandlerServer 

func RegisterObservationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ObservationServiceServer) error

RegisterObservationServiceHandlerServer registers the http handlers for service ObservationService to "mux". UnaryRPC :call ObservationServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterObservationServiceHandlerFromEndpoint instead.

func RegisterObservationServiceServer 

func RegisterObservationServiceServer(s grpc.ServiceRegistrar, srv ObservationServiceServer)

func RegisterUniversalPredictionServiceHandler 

func RegisterUniversalPredictionServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterUniversalPredictionServiceHandler registers the http handlers for service UniversalPredictionService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterUniversalPredictionServiceHandlerClient 

func RegisterUniversalPredictionServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client UniversalPredictionServiceClient) error

RegisterUniversalPredictionServiceHandlerClient registers the http handlers for service UniversalPredictionService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "UniversalPredictionServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "UniversalPredictionServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "UniversalPredictionServiceClient" to call the correct interceptors.

func RegisterUniversalPredictionServiceHandlerFromEndpoint 

func RegisterUniversalPredictionServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterUniversalPredictionServiceHandlerFromEndpoint is same as RegisterUniversalPredictionServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterUniversalPredictionServiceHandlerServer 

func RegisterUniversalPredictionServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server UniversalPredictionServiceServer) error

RegisterUniversalPredictionServiceHandlerServer registers the http handlers for service UniversalPredictionService to "mux". UnaryRPC :call UniversalPredictionServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterUniversalPredictionServiceHandlerFromEndpoint instead.

func RegisterUniversalPredictionServiceServer 

func RegisterUniversalPredictionServiceServer(s grpc.ServiceRegistrar, srv UniversalPredictionServiceServer)

Types

type Column 

type Column struct {

	// Column's name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Column's type
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=caraml.upi.v1.Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Column represent a column definition within a table

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetName 

func (x *Column) GetName() string

func (*Column) GetType 

func (x *Column) GetType() Type

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string
type Header struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

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

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetKey 

func (x *Header) GetKey() string

func (*Header) GetValue 

func (x *Header) GetValue() string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

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

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type LogObservationsRequest 

type LogObservationsRequest struct {

	// List of observations per request
	Observations []*ObservationLog `protobuf:"bytes,1,rep,name=observations,proto3" json:"observations,omitempty"`
	// contains filtered or unexported fields
}

func (*LogObservationsRequest) Descriptor deprecated 

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

Deprecated: Use LogObservationsRequest.ProtoReflect.Descriptor instead.

func (*LogObservationsRequest) GetObservations 

func (x *LogObservationsRequest) GetObservations() []*ObservationLog

func (*LogObservationsRequest) ProtoMessage 

func (*LogObservationsRequest) ProtoMessage()

func (*LogObservationsRequest) ProtoReflect 

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

func (*LogObservationsRequest) Reset 

func (x *LogObservationsRequest) Reset()

func (*LogObservationsRequest) String 

func (x *LogObservationsRequest) String() string

type LogObservationsResponse 

type LogObservationsResponse struct {

	// Unique identifier to identify records from a batch of observation logs
	ObservationBatchId string `protobuf:"bytes,1,opt,name=observation_batch_id,json=observationBatchId,proto3" json:"observation_batch_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogObservationsResponse) Descriptor deprecated 

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

Deprecated: Use LogObservationsResponse.ProtoReflect.Descriptor instead.

func (*LogObservationsResponse) GetObservationBatchId 

func (x *LogObservationsResponse) GetObservationBatchId() string

func (*LogObservationsResponse) ProtoMessage 

func (*LogObservationsResponse) ProtoMessage()

func (*LogObservationsResponse) ProtoReflect 

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

func (*LogObservationsResponse) Reset 

func (x *LogObservationsResponse) Reset()

func (*LogObservationsResponse) String 

func (x *LogObservationsResponse) String() string

type ModelInput 

type ModelInput struct {

	// JSON-representation of features table. "table_schema_version" field describe the encoding of this field.
	FeaturesTable *structpb.Struct `protobuf:"bytes,1,opt,name=features_table,json=featuresTable,proto3" json:"features_table,omitempty"`
	// JSON-representation of entities table. "table_schema_version" field describe the encoding of this field.
	EntitiesTable *structpb.Struct `protobuf:"bytes,2,opt,name=entities_table,json=entitiesTable,proto3" json:"entities_table,omitempty"`
	// JSON-representation of raw_features table. "table_schema_version" field describe the encoding of this field.
	RawFeatures *structpb.Struct `protobuf:"bytes,3,opt,name=raw_features,json=rawFeatures,proto3" json:"raw_features,omitempty"`
	// Context of the prediction request.
	PredictionContext []*Variable `protobuf:"bytes,4,rep,name=prediction_context,json=predictionContext,proto3" json:"prediction_context,omitempty"`
	// map containing request headers/metadata
	Headers []*Header `protobuf:"bytes,10,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

Model input stores information of all input for prediction process. The information in model input are extracted from the prediction request received by model.

func (*ModelInput) Descriptor deprecated 

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

Deprecated: Use ModelInput.ProtoReflect.Descriptor instead.

func (*ModelInput) GetEntitiesTable 

func (x *ModelInput) GetEntitiesTable() *structpb.Struct

func (*ModelInput) GetFeaturesTable 

func (x *ModelInput) GetFeaturesTable() *structpb.Struct

func (*ModelInput) GetHeaders 

func (x *ModelInput) GetHeaders() []*Header

func (*ModelInput) GetPredictionContext 

func (x *ModelInput) GetPredictionContext() []*Variable

func (*ModelInput) GetRawFeatures 

func (x *ModelInput) GetRawFeatures() *structpb.Struct

func (*ModelInput) ProtoMessage 

func (*ModelInput) ProtoMessage()

func (*ModelInput) ProtoReflect 

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

func (*ModelInput) Reset 

func (x *ModelInput) Reset()

func (*ModelInput) String 

func (x *ModelInput) String() string

type ModelMetadata 

type ModelMetadata struct {

	// Model name that produce prediction
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Model version that produce prediction
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ModelMetadata) Descriptor deprecated 

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

Deprecated: Use ModelMetadata.ProtoReflect.Descriptor instead.

func (*ModelMetadata) GetName 

func (x *ModelMetadata) GetName() string

func (*ModelMetadata) GetVersion 

func (x *ModelMetadata) GetVersion() string

func (*ModelMetadata) ProtoMessage 

func (*ModelMetadata) ProtoMessage()

func (*ModelMetadata) ProtoReflect 

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

func (*ModelMetadata) Reset 

func (x *ModelMetadata) Reset()

func (*ModelMetadata) String 

func (x *ModelMetadata) String() string

type ModelOutput 

type ModelOutput struct {

	// JSON-representation of prediction result table. "table_schema_version" field describe the encoding of this field.
	PredictionResultsTable *structpb.Struct `` /* 129-byte string literal not displayed */
	// Context of the prediction response.
	PredictionContext []*Variable `protobuf:"bytes,2,rep,name=prediction_context,json=predictionContext,proto3" json:"prediction_context,omitempty"`
	// map containing response headers/metadata
	Headers []*Header `protobuf:"bytes,10,rep,name=headers,proto3" json:"headers,omitempty"`
	// grpc status of the response from model (see https://grpc.github.io/grpc/core/md_doc_statuscodes.html)
	Status uint32 `protobuf:"varint,11,opt,name=status,proto3" json:"status,omitempty"`
	// grpc message
	Message string `protobuf:"bytes,12,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Model output stores information of all output produced from prediction process. Model output is extracted from the prediction response sent by model.

func (*ModelOutput) Descriptor deprecated 

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

Deprecated: Use ModelOutput.ProtoReflect.Descriptor instead.

func (*ModelOutput) GetHeaders 

func (x *ModelOutput) GetHeaders() []*Header

func (*ModelOutput) GetMessage 

func (x *ModelOutput) GetMessage() string

func (*ModelOutput) GetPredictionContext 

func (x *ModelOutput) GetPredictionContext() []*Variable

func (*ModelOutput) GetPredictionResultsTable 

func (x *ModelOutput) GetPredictionResultsTable() *structpb.Struct

func (*ModelOutput) GetStatus 

func (x *ModelOutput) GetStatus() uint32

func (*ModelOutput) ProtoMessage 

func (*ModelOutput) ProtoMessage()

func (*ModelOutput) ProtoReflect 

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

func (*ModelOutput) Reset 

func (x *ModelOutput) Reset()

func (*ModelOutput) String 

func (x *ModelOutput) String() string

type ObservationLog 

type ObservationLog struct {

	// Unique identifier of a prediction response returned by prediction service.
	// This information is used to join the prediction to an observation.
	PredictionId string `protobuf:"bytes,1,opt,name=prediction_id,json=predictionId,proto3" json:"prediction_id,omitempty"`
	// Prediction requests may contain multiple prediction instances.
	// The row_id identifies a particular prediction instance that was used to produce an observation.
	// This information is used to join the prediction to an observation.
	RowId string `protobuf:"bytes,2,opt,name=row_id,json=rowId,proto3" json:"row_id,omitempty"`
	// The name of the observation target. This information is used to join the prediction to an observation.
	TargetName string `protobuf:"bytes,3,opt,name=target_name,json=targetName,proto3" json:"target_name,omitempty"`
	// The ground-truth value. It can be a double, string or integer type.
	ObservationValues []*Variable `protobuf:"bytes,4,rep,name=observation_values,json=observationValues,proto3" json:"observation_values,omitempty"`
	// A set of key-value pairs to provide additional context for the observation.
	ObservationContext []*Variable `protobuf:"bytes,5,rep,name=observation_context,json=observationContext,proto3" json:"observation_context,omitempty"`
	// Timestamp when the observation is made
	ObservationTimestamp *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=observation_timestamp,json=observationTimestamp,proto3" json:"observation_timestamp,omitempty"`
	// contains filtered or unexported fields
}

ObservationLog represents ground truth signals to be combined with the prediction log produced by CaraML prediction service to form data sets used for training ML models

func (*ObservationLog) Descriptor deprecated 

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

Deprecated: Use ObservationLog.ProtoReflect.Descriptor instead.

func (*ObservationLog) GetObservationContext 

func (x *ObservationLog) GetObservationContext() []*Variable

func (*ObservationLog) GetObservationTimestamp 

func (x *ObservationLog) GetObservationTimestamp() *timestamppb.Timestamp

func (*ObservationLog) GetObservationValues 

func (x *ObservationLog) GetObservationValues() []*Variable

func (*ObservationLog) GetPredictionId 

func (x *ObservationLog) GetPredictionId() string

func (*ObservationLog) GetRowId 

func (x *ObservationLog) GetRowId() string

func (*ObservationLog) GetTargetName 

func (x *ObservationLog) GetTargetName() string

func (*ObservationLog) ProtoMessage 

func (*ObservationLog) ProtoMessage()

func (*ObservationLog) ProtoReflect 

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

func (*ObservationLog) Reset 

func (x *ObservationLog) Reset()

func (*ObservationLog) String 

func (x *ObservationLog) String() string

type ObservationLogKey 

type ObservationLogKey struct {

	// Id to uniquely identify records from a batch of observation logs
	ObservationBatchId string `protobuf:"bytes,1,opt,name=observation_batch_id,json=observationBatchId,proto3" json:"observation_batch_id,omitempty"`
	// Unique identifier of a prediction response returned by prediction service.
	// This information is used to join the prediction to an observation.
	PredictionId string `protobuf:"bytes,2,opt,name=prediction_id,json=predictionId,proto3" json:"prediction_id,omitempty"`
	// Prediction requests may contain multiple prediction instances.
	// The row_id identifies a particular prediction instance that was used to produce an observation.
	// This information is used to join the prediction to an observation.
	RowId string `protobuf:"bytes,3,opt,name=row_id,json=rowId,proto3" json:"row_id,omitempty"`
	// contains filtered or unexported fields
}

ObservationLogKey contains necessary values for generating unique records for downstream usages, eg. Dataset Generation Service

func (*ObservationLogKey) Descriptor deprecated 

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

Deprecated: Use ObservationLogKey.ProtoReflect.Descriptor instead.

func (*ObservationLogKey) GetObservationBatchId 

func (x *ObservationLogKey) GetObservationBatchId() string

func (*ObservationLogKey) GetPredictionId 

func (x *ObservationLogKey) GetPredictionId() string

func (*ObservationLogKey) GetRowId 

func (x *ObservationLogKey) GetRowId() string

func (*ObservationLogKey) ProtoMessage 

func (*ObservationLogKey) ProtoMessage()

func (*ObservationLogKey) ProtoReflect 

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

func (*ObservationLogKey) Reset 

func (x *ObservationLogKey) Reset()

func (*ObservationLogKey) String 

func (x *ObservationLogKey) String() string

type ObservationServiceClient 

type ObservationServiceClient interface {
	LogObservations(ctx context.Context, in *LogObservationsRequest, opts ...grpc.CallOption) (*LogObservationsResponse, error)
}

ObservationServiceClient is the client API for ObservationService 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 NewObservationServiceClient 

func NewObservationServiceClient(cc grpc.ClientConnInterface) ObservationServiceClient

type ObservationServiceServer 

type ObservationServiceServer interface {
	LogObservations(context.Context, *LogObservationsRequest) (*LogObservationsResponse, error)
}

ObservationServiceServer is the server API for ObservationService service. All implementations should embed UnimplementedObservationServiceServer for forward compatibility

type PredictValuesRequest 

type PredictValuesRequest struct {

	// Prediction table contains instances to be predicted.
	// Each row in the table correspond to one prediction instance.
	// Prediction table should contain all preprocessed feature that model use to perform prediction.
	// The column ordering in the prediction table must be the same as feature order expected by model in the case of standard model.
	// Prediction table can be populated via 3 ways:
	// - By performing preprocessing in the client-side and sent as part of original request.
	// - By transforming feature values stored in transformer_inputs.
	// - By retrieving precomputed feature value from feature store.
	// Row ID of the prediction_table must be populated by the client and can be used
	// to join a row in prediction_table with another row in the prediction_result_table,
	// and to track predictions generated by multiple models.
	// The user is expected to include row ID (along with prediction ID)
	// when calling the observations API so that predictions
	// and observations can be joined.
	// NOTE: the ordering of rows might differ in the response but the number of row must remain the same.
	PredictionTable *Table `protobuf:"bytes,1,opt,name=prediction_table,json=predictionTable,proto3" json:"prediction_table,omitempty"`
	// Transformer input contains list of tables and variables that can be used to enrich prediction_table using transformer.
	// Typically transformer_inputs contains:
	// - unprocessed/raw features that requires further transformation.
	// - list of entities for which their precomputed features are retrieved from feature store using standard transformer.
	TransformerInput *TransformerInput `protobuf:"bytes,4,opt,name=transformer_input,json=transformerInput,proto3" json:"transformer_input,omitempty"`
	// Name of the concept we wish to predict.
	// For example in context of iris classification problem it can be "iris-species"
	TargetName string `protobuf:"bytes,2,opt,name=target_name,json=targetName,proto3" json:"target_name,omitempty"`
	// Prediction context may contain additional data applicable to all prediction instances
	// For example it can be used to store information for traffic rules, experimentation
	// or tracking purposes.
	// Eg. country_code, service_type, service_area_id
	PredictionContext []*Variable `protobuf:"bytes,3,rep,name=prediction_context,json=predictionContext,proto3" json:"prediction_context,omitempty"`
	// Request metadata
	Metadata *RequestMetadata `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

Represents a request to predict multiple values

func (*PredictValuesRequest) Descriptor deprecated 

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

Deprecated: Use PredictValuesRequest.ProtoReflect.Descriptor instead.

func (*PredictValuesRequest) GetMetadata 

func (x *PredictValuesRequest) GetMetadata() *RequestMetadata

func (*PredictValuesRequest) GetPredictionContext 

func (x *PredictValuesRequest) GetPredictionContext() []*Variable

func (*PredictValuesRequest) GetPredictionTable 

func (x *PredictValuesRequest) GetPredictionTable() *Table

func (*PredictValuesRequest) GetTargetName 

func (x *PredictValuesRequest) GetTargetName() string

func (*PredictValuesRequest) GetTransformerInput 

func (x *PredictValuesRequest) GetTransformerInput() *TransformerInput

func (*PredictValuesRequest) ProtoMessage 

func (*PredictValuesRequest) ProtoMessage()

func (*PredictValuesRequest) ProtoReflect 

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

func (*PredictValuesRequest) Reset 

func (x *PredictValuesRequest) Reset()

func (*PredictValuesRequest) String 

func (x *PredictValuesRequest) String() string

type PredictValuesResponse 

type PredictValuesResponse struct {

	// Prediction results corresponding to the
	// prediction rows provided in the request.
	// NOTE: the ordering of prediction_result_rows might differ with prediction_table in the request but the number of row must match with the prediction_table
	PredictionResultTable *Table `` /* 126-byte string literal not displayed */
	// Target name as defined in the request metadata
	TargetName string `protobuf:"bytes,2,opt,name=target_name,json=targetName,proto3" json:"target_name,omitempty"`
	// Extensible field to cover unforeseen requirements
	PredictionContext []*Variable `protobuf:"bytes,3,rep,name=prediction_context,json=predictionContext,proto3" json:"prediction_context,omitempty"`
	// Response metadata
	Metadata *ResponseMetadata `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*PredictValuesResponse) Descriptor deprecated 

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

Deprecated: Use PredictValuesResponse.ProtoReflect.Descriptor instead.

func (*PredictValuesResponse) GetMetadata 

func (x *PredictValuesResponse) GetMetadata() *ResponseMetadata

func (*PredictValuesResponse) GetPredictionContext 

func (x *PredictValuesResponse) GetPredictionContext() []*Variable

func (*PredictValuesResponse) GetPredictionResultTable 

func (x *PredictValuesResponse) GetPredictionResultTable() *Table

func (*PredictValuesResponse) GetTargetName 

func (x *PredictValuesResponse) GetTargetName() string

func (*PredictValuesResponse) ProtoMessage 

func (*PredictValuesResponse) ProtoMessage()

func (*PredictValuesResponse) ProtoReflect 

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

func (*PredictValuesResponse) Reset 

func (x *PredictValuesResponse) Reset()

func (*PredictValuesResponse) String 

func (x *PredictValuesResponse) String() string

type PredictionLog 

type PredictionLog struct {

	// Unique identifier of prediction.
	PredictionId string `protobuf:"bytes,1,opt,name=prediction_id,json=predictionId,proto3" json:"prediction_id,omitempty"`
	// Target name / concept to be predicted by the prediction.
	TargetName string `protobuf:"bytes,2,opt,name=target_name,json=targetName,proto3" json:"target_name,omitempty"`
	// Project name that host the model performing prediction.
	ProjectName string `protobuf:"bytes,3,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	// Model name performing the prediction.
	ModelName string `protobuf:"bytes,4,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	// Model version performing the prediction.
	ModelVersion string `protobuf:"bytes,5,opt,name=model_version,json=modelVersion,proto3" json:"model_version,omitempty"`
	// Input of the prediction process
	Input *ModelInput `protobuf:"bytes,10,opt,name=input,proto3" json:"input,omitempty"`
	// Output of the prediction process
	Output *ModelOutput `protobuf:"bytes,11,opt,name=output,proto3" json:"output,omitempty"`
	// Timestamp of the corresponding prediction request
	RequestTimestamp *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=request_timestamp,json=requestTimestamp,proto3" json:"request_timestamp,omitempty"`
	// Schema version of raw_features, features, entities, and prediction results fields are formatted
	// I.e. for version 1, all of those fields will be formatted as a modified JSON SPLIT representation of a table
	TableSchemaVersion uint32 `protobuf:"varint,100,opt,name=table_schema_version,json=tableSchemaVersion,proto3" json:"table_schema_version,omitempty"`
	// contains filtered or unexported fields
}

PredictionLog stores information of prediction request handled by a specific model version.

func (*PredictionLog) Descriptor deprecated 

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

Deprecated: Use PredictionLog.ProtoReflect.Descriptor instead.

func (*PredictionLog) GetInput 

func (x *PredictionLog) GetInput() *ModelInput

func (*PredictionLog) GetModelName 

func (x *PredictionLog) GetModelName() string

func (*PredictionLog) GetModelVersion 

func (x *PredictionLog) GetModelVersion() string

func (*PredictionLog) GetOutput 

func (x *PredictionLog) GetOutput() *ModelOutput

func (*PredictionLog) GetPredictionId 

func (x *PredictionLog) GetPredictionId() string

func (*PredictionLog) GetProjectName 

func (x *PredictionLog) GetProjectName() string

func (*PredictionLog) GetRequestTimestamp 

func (x *PredictionLog) GetRequestTimestamp() *timestamppb.Timestamp

func (*PredictionLog) GetTableSchemaVersion 

func (x *PredictionLog) GetTableSchemaVersion() uint32

func (*PredictionLog) GetTargetName 

func (x *PredictionLog) GetTargetName() string

func (*PredictionLog) ProtoMessage 

func (*PredictionLog) ProtoMessage()

func (*PredictionLog) ProtoReflect 

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

func (*PredictionLog) Reset 

func (x *PredictionLog) Reset()

func (*PredictionLog) String 

func (x *PredictionLog) String() string

type RequestMetadata 

type RequestMetadata struct {

	// Unique identifier for each request. Optional.
	// Prediction ID will generated by the platform. The user is expected
	// include the prediction ID (along with row ID) when calling
	// the observations API so that predictions and observations can be joined.
	// Prediction ID is needed because row ID may not be globally unique
	// across requests (only locally unique within each request).
	// If there are experiments with alternative models, the mapping
	// from prediciton ID to treatment ID will be logged by the platform
	PredictionId string `protobuf:"bytes,1,opt,name=prediction_id,json=predictionId,proto3" json:"prediction_id,omitempty"`
	// Timestamp of the request
	RequestTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=request_timestamp,json=requestTimestamp,proto3" json:"request_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestMetadata) Descriptor deprecated 

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

Deprecated: Use RequestMetadata.ProtoReflect.Descriptor instead.

func (*RequestMetadata) GetPredictionId 

func (x *RequestMetadata) GetPredictionId() string

func (*RequestMetadata) GetRequestTimestamp 

func (x *RequestMetadata) GetRequestTimestamp() *timestamppb.Timestamp

func (*RequestMetadata) ProtoMessage 

func (*RequestMetadata) ProtoMessage()

func (*RequestMetadata) ProtoReflect 

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

func (*RequestMetadata) Reset 

func (x *RequestMetadata) Reset()

func (*RequestMetadata) String 

func (x *RequestMetadata) String() string

type ResponseMetadata 

type ResponseMetadata struct {

	// Prediction ID generated by the platform.
	// The user is expected include the prediction ID (along with row ID) when calling
	// the observations API so that predictions and observations can be joined.
	// Prediction ID is needed because row ID may not be globally unique
	// across requests (only locally unique within each request).
	// If there are experiments with alternative models, the mapping
	// from prediciton ID to treatment ID will be logged by the platform
	PredictionId string `protobuf:"bytes,1,opt,name=prediction_id,json=predictionId,proto3" json:"prediction_id,omitempty"`
	// List of model that produces the prediction
	// This field is repeated to cater for use case such as ensembling several model production results
	Models []*ModelMetadata `protobuf:"bytes,2,rep,name=models,proto3" json:"models,omitempty"`
	// Name of the experiment that is used to produce the response
	// The value might be empty if experimentation is not involved to produce response
	ExperimentName string `protobuf:"bytes,3,opt,name=experiment_name,json=experimentName,proto3" json:"experiment_name,omitempty"`
	// Name of the treatment chosen from the experiment to produce the response
	// The value might be empty if experimentation is not involved to produce response
	TreatmentName string `protobuf:"bytes,4,opt,name=treatment_name,json=treatmentName,proto3" json:"treatment_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ResponseMetadata) Descriptor deprecated 

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

Deprecated: Use ResponseMetadata.ProtoReflect.Descriptor instead.

func (*ResponseMetadata) GetExperimentName 

func (x *ResponseMetadata) GetExperimentName() string

func (*ResponseMetadata) GetModels 

func (x *ResponseMetadata) GetModels() []*ModelMetadata

func (*ResponseMetadata) GetPredictionId 

func (x *ResponseMetadata) GetPredictionId() string

func (*ResponseMetadata) GetTreatmentName 

func (x *ResponseMetadata) GetTreatmentName() string

func (*ResponseMetadata) ProtoMessage 

func (*ResponseMetadata) ProtoMessage()

func (*ResponseMetadata) ProtoReflect 

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

func (*ResponseMetadata) Reset 

func (x *ResponseMetadata) Reset()

func (*ResponseMetadata) String 

func (x *ResponseMetadata) String() string

type RouterInput 

type RouterInput struct {

	// JSON-representation of prediction_table of the UPI request to router. "table_schema_version" field describe the encoding of this field.
	PredictionTable *structpb.Struct `protobuf:"bytes,1,opt,name=prediction_table,json=predictionTable,proto3" json:"prediction_table,omitempty"`
	// List of tables in the transformer inputs in JSON format. "table_schema_version" field describe the encoding of this field.
	TransformerTables []*structpb.Struct `protobuf:"bytes,2,rep,name=transformer_tables,json=transformerTables,proto3" json:"transformer_tables,omitempty"`
	// List of variables extracted from "transformer_inputs"
	TransformerVariables []*Variable `protobuf:"bytes,3,rep,name=transformer_variables,json=transformerVariables,proto3" json:"transformer_variables,omitempty"`
	// Context of the prediction request.
	PredictionContext []*Variable `protobuf:"bytes,4,rep,name=prediction_context,json=predictionContext,proto3" json:"prediction_context,omitempty"`
	// map containing request headers/metadata
	Headers []*Header `protobuf:"bytes,10,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

Input received by router. These informations are extracted from the request received by the router.

func (*RouterInput) Descriptor deprecated 

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

Deprecated: Use RouterInput.ProtoReflect.Descriptor instead.

func (*RouterInput) GetHeaders 

func (x *RouterInput) GetHeaders() []*Header

func (*RouterInput) GetPredictionContext 

func (x *RouterInput) GetPredictionContext() []*Variable

func (*RouterInput) GetPredictionTable 

func (x *RouterInput) GetPredictionTable() *structpb.Struct

func (*RouterInput) GetTransformerTables 

func (x *RouterInput) GetTransformerTables() []*structpb.Struct

func (*RouterInput) GetTransformerVariables 

func (x *RouterInput) GetTransformerVariables() []*Variable

func (*RouterInput) ProtoMessage 

func (*RouterInput) ProtoMessage()

func (*RouterInput) ProtoReflect 

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

func (*RouterInput) Reset 

func (x *RouterInput) Reset()

func (*RouterInput) String 

func (x *RouterInput) String() string

type RouterLog 

type RouterLog struct {

	// Unique identifier of prediction.
	PredictionId string `protobuf:"bytes,1,opt,name=prediction_id,json=predictionId,proto3" json:"prediction_id,omitempty"`
	// Target name / concept to be predicted by the prediction.
	TargetName string `protobuf:"bytes,2,opt,name=target_name,json=targetName,proto3" json:"target_name,omitempty"`
	// Project name that host the router.
	ProjectName string `protobuf:"bytes,3,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
	// Name of the router.
	RouterName string `protobuf:"bytes,4,opt,name=router_name,json=routerName,proto3" json:"router_name,omitempty"`
	// Router version.
	RouterVersion string `protobuf:"bytes,5,opt,name=router_version,json=routerVersion,proto3" json:"router_version,omitempty"`
	// Routing logic describes the decision that was made within the router to produce the router output
	RoutingLogic *RoutingLogic `protobuf:"bytes,10,opt,name=routing_logic,json=routingLogic,proto3" json:"routing_logic,omitempty"`
	// Input of the router
	RouterInput *RouterInput `protobuf:"bytes,11,opt,name=router_input,json=routerInput,proto3" json:"router_input,omitempty"`
	// Output of the router
	RouterOutput *RouterOutput `protobuf:"bytes,12,opt,name=router_output,json=routerOutput,proto3" json:"router_output,omitempty"`
	// Timestamp of the corresponding prediction request
	RequestTimestamp *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=request_timestamp,json=requestTimestamp,proto3" json:"request_timestamp,omitempty"`
	// Schema version of raw_features, features, entities, and prediction results fields are formatted
	// I.e. for version 1, all of those fields will be formatted as a modified JSON SPLIT representation of a table
	TableSchemaVersion uint32 `protobuf:"varint,100,opt,name=table_schema_version,json=tableSchemaVersion,proto3" json:"table_schema_version,omitempty"`
	// contains filtered or unexported fields
}

RouterLog stores information of a multi-model orchestration performed by a router.

func (*RouterLog) Descriptor deprecated 

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

Deprecated: Use RouterLog.ProtoReflect.Descriptor instead.

func (*RouterLog) GetPredictionId 

func (x *RouterLog) GetPredictionId() string

func (*RouterLog) GetProjectName 

func (x *RouterLog) GetProjectName() string

func (*RouterLog) GetRequestTimestamp 

func (x *RouterLog) GetRequestTimestamp() *timestamppb.Timestamp

func (*RouterLog) GetRouterInput 

func (x *RouterLog) GetRouterInput() *RouterInput

func (*RouterLog) GetRouterName 

func (x *RouterLog) GetRouterName() string

func (*RouterLog) GetRouterOutput 

func (x *RouterLog) GetRouterOutput() *RouterOutput

func (*RouterLog) GetRouterVersion 

func (x *RouterLog) GetRouterVersion() string

func (*RouterLog) GetRoutingLogic 

func (x *RouterLog) GetRoutingLogic() *RoutingLogic

func (*RouterLog) GetTableSchemaVersion 

func (x *RouterLog) GetTableSchemaVersion() uint32

func (*RouterLog) GetTargetName 

func (x *RouterLog) GetTargetName() string

func (*RouterLog) ProtoMessage 

func (*RouterLog) ProtoMessage()

func (*RouterLog) ProtoReflect 

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

func (*RouterLog) Reset 

func (x *RouterLog) Reset()

func (*RouterLog) String 

func (x *RouterLog) String() string

type RouterOutput 

type RouterOutput struct {

	// JSON-representation of prediction result table returned by router. "table_schema_version" field describe the encoding of this field.
	PredictionResultsTable *structpb.Struct `` /* 129-byte string literal not displayed */
	// Context of the prediction response.
	PredictionContext []*Variable `protobuf:"bytes,2,rep,name=prediction_context,json=predictionContext,proto3" json:"prediction_context,omitempty"`
	// map containing response headers/metadata
	Headers []*Header `protobuf:"bytes,10,rep,name=headers,proto3" json:"headers,omitempty"`
	// grpc status of the response from model (see https://grpc.github.io/grpc/core/md_doc_statuscodes.html)
	Status uint32 `protobuf:"varint,11,opt,name=status,proto3" json:"status,omitempty"`
	// grpc message
	Message string `protobuf:"bytes,12,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Output produced by router. These informations are extracted from the response produced by the router.

func (*RouterOutput) Descriptor deprecated 

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

Deprecated: Use RouterOutput.ProtoReflect.Descriptor instead.

func (*RouterOutput) GetHeaders 

func (x *RouterOutput) GetHeaders() []*Header

func (*RouterOutput) GetMessage 

func (x *RouterOutput) GetMessage() string

func (*RouterOutput) GetPredictionContext 

func (x *RouterOutput) GetPredictionContext() []*Variable

func (*RouterOutput) GetPredictionResultsTable 

func (x *RouterOutput) GetPredictionResultsTable() *structpb.Struct

func (*RouterOutput) GetStatus 

func (x *RouterOutput) GetStatus() uint32

func (*RouterOutput) ProtoMessage 

func (*RouterOutput) ProtoMessage()

func (*RouterOutput) ProtoReflect 

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

func (*RouterOutput) Reset 

func (x *RouterOutput) Reset()

func (*RouterOutput) String 

func (x *RouterOutput) String() string

type RoutingLogic 

type RoutingLogic struct {

	// List of models that was involved in producing the router output.
	// Router can behave as multiplexer or combiner.
	// In multiplexer case, the router will select 1 out of many models, thus this field will only have 1 entry.
	// In combiner case, this field can contain more than 1 entries.
	// This field will be used to join witht the prediction log.
	Models []*ModelMetadata `protobuf:"bytes,1,rep,name=models,proto3" json:"models,omitempty"`
	// Traffic rule that was used to route the prediction request (optional).
	TrafficRule string `protobuf:"bytes,2,opt,name=traffic_rule,json=trafficRule,proto3" json:"traffic_rule,omitempty"`
	// Experiment name that was used to handle the prediction request (optional).
	ExperimentName string `protobuf:"bytes,3,opt,name=experiment_name,json=experimentName,proto3" json:"experiment_name,omitempty"`
	// Treatment name from the experiment that was used to handle the prediction request (optional).
	TreatmentName string `protobuf:"bytes,4,opt,name=treatment_name,json=treatmentName,proto3" json:"treatment_name,omitempty"`
	// contains filtered or unexported fields
}

Routing logic describes the decision that was made within the router to produce the router output

func (*RoutingLogic) Descriptor deprecated 

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

Deprecated: Use RoutingLogic.ProtoReflect.Descriptor instead.

func (*RoutingLogic) GetExperimentName 

func (x *RoutingLogic) GetExperimentName() string

func (*RoutingLogic) GetModels 

func (x *RoutingLogic) GetModels() []*ModelMetadata

func (*RoutingLogic) GetTrafficRule 

func (x *RoutingLogic) GetTrafficRule() string

func (*RoutingLogic) GetTreatmentName 

func (x *RoutingLogic) GetTreatmentName() string

func (*RoutingLogic) ProtoMessage 

func (*RoutingLogic) ProtoMessage()

func (*RoutingLogic) ProtoReflect 

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

func (*RoutingLogic) Reset 

func (x *RoutingLogic) Reset()

func (*RoutingLogic) String 

func (x *RoutingLogic) String() string

type Row 

type Row struct {

	// Id of the particular row in a table.
	// The row id should be at least locally unique within the table.
	// Row ID must be populated for prediction_table
	RowId string `protobuf:"bytes,1,opt,name=row_id,json=rowId,proto3" json:"row_id,omitempty"`
	// List of values within a row.
	// It is table's creator responsibility to ensure that the number of entry
	// values matches with the length of columns in the table.
	Values []*Value `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Row represents list of value stored within a row of a table

func (*Row) Descriptor deprecated 

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetRowId 

func (x *Row) GetRowId() string

func (*Row) GetValues 

func (x *Row) GetValues() []*Value

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect 

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

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) String 

func (x *Row) String() string

type Table 

type Table struct {

	// Table's name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Columns stores schema informations of all columns in the table.
	Columns []*Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	// Rows stores list of row values in the table.
	Rows []*Row `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

Table represents a 2D data structure that has one or more columns with potentially different types

func (*Table) Descriptor deprecated 

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

Deprecated: Use Table.ProtoReflect.Descriptor instead.

func (*Table) GetColumns 

func (x *Table) GetColumns() []*Column

func (*Table) GetName 

func (x *Table) GetName() string

func (*Table) GetRows 

func (x *Table) GetRows() []*Row

func (*Table) ProtoMessage 

func (*Table) ProtoMessage()

func (*Table) ProtoReflect 

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

func (*Table) Reset 

func (x *Table) Reset()

func (*Table) String 

func (x *Table) String() string

type TransformerInput 

type TransformerInput struct {

	// List of tables
	// All tables must have unique name.
	// Each table doesn't need to have same number of row.
	Tables []*Table `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// List of variables
	Variables []*Variable `protobuf:"bytes,2,rep,name=variables,proto3" json:"variables,omitempty"`
	// contains filtered or unexported fields
}

Transformer input contains additional information that can be used to enrich prediction_table using standard transformer. All tables and variables within transformer input will be imported to the standard transformer runtime automatically.

func (*TransformerInput) Descriptor deprecated 

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

Deprecated: Use TransformerInput.ProtoReflect.Descriptor instead.

func (*TransformerInput) GetTables 

func (x *TransformerInput) GetTables() []*Table

func (*TransformerInput) GetVariables 

func (x *TransformerInput) GetVariables() []*Variable

func (*TransformerInput) ProtoMessage 

func (*TransformerInput) ProtoMessage()

func (*TransformerInput) ProtoReflect 

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

func (*TransformerInput) Reset 

func (x *TransformerInput) Reset()

func (*TransformerInput) String 

func (x *TransformerInput) String() string

type Type 

type Type int32

Type supported by UPI 

const (
	Type_TYPE_UNSPECIFIED Type = 0
	// Double precision floating number (64-bit)
	Type_TYPE_DOUBLE Type = 1
	// 64-bit Integer
	Type_TYPE_INTEGER Type = 2
	// String
	Type_TYPE_STRING Type = 3
)

func (Type) Descriptor 

func (Type) Descriptor() protoreflect.EnumDescriptor

func (Type) Enum 

func (x Type) Enum() *Type

func (Type) EnumDescriptor deprecated 

func (Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Type.Descriptor instead.

func (Type) Number 

func (x Type) Number() protoreflect.EnumNumber

func (Type) String 

func (x Type) String() string

func (Type) Type 

func (Type) Type() protoreflect.EnumType

type UnimplementedObservationServiceServer 

type UnimplementedObservationServiceServer struct {
}

UnimplementedObservationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedObservationServiceServer) LogObservations 

func (UnimplementedObservationServiceServer) LogObservations(context.Context, *LogObservationsRequest) (*LogObservationsResponse, error)

type UnimplementedUniversalPredictionServiceServer 

type UnimplementedUniversalPredictionServiceServer struct {
}

UnimplementedUniversalPredictionServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedUniversalPredictionServiceServer) PredictValues 

func (UnimplementedUniversalPredictionServiceServer) PredictValues(context.Context, *PredictValuesRequest) (*PredictValuesResponse, error)

type UniversalPredictionServiceClient 

type UniversalPredictionServiceClient interface {
	PredictValues(ctx context.Context, in *PredictValuesRequest, opts ...grpc.CallOption) (*PredictValuesResponse, error)
}

UniversalPredictionServiceClient is the client API for UniversalPredictionService 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 NewUniversalPredictionServiceClient 

func NewUniversalPredictionServiceClient(cc grpc.ClientConnInterface) UniversalPredictionServiceClient

type UniversalPredictionServiceServer 

type UniversalPredictionServiceServer interface {
	PredictValues(context.Context, *PredictValuesRequest) (*PredictValuesResponse, error)
}

UniversalPredictionServiceServer is the server API for UniversalPredictionService service. All implementations should embed UnimplementedUniversalPredictionServiceServer for forward compatibility

type UnsafeObservationServiceServer 

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

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

type UnsafeUniversalPredictionServiceServer 

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

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

type Value 

type Value struct {

	// One of following field will be set depending on the column's type
	DoubleValue  float64 `protobuf:"fixed64,1,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"`
	IntegerValue int64   `protobuf:"varint,2,opt,name=integer_value,json=integerValue,proto3" json:"integer_value,omitempty"`
	StringValue  string  `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
	// Flag to be used to signify that the value is null
	IsNull bool `protobuf:"varint,10,opt,name=is_null,json=isNull,proto3" json:"is_null,omitempty"`
	// contains filtered or unexported fields
}

Value of a cell within a table. Value is nullable.

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetDoubleValue 

func (x *Value) GetDoubleValue() float64

func (*Value) GetIntegerValue 

func (x *Value) GetIntegerValue() int64

func (*Value) GetIsNull 

func (x *Value) GetIsNull() bool

func (*Value) GetStringValue 

func (x *Value) GetStringValue() string

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

type Variable 

type Variable struct {

	// Name describing what the value represents.
	// Uses include:
	// - Ensuring ML models process columns in the correct order
	// - Defining a Feast row entity name
	// - Parsing metadata to apply traffic rules
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the variable
	Type Type `protobuf:"varint,2,opt,name=type,proto3,enum=caraml.upi.v1.Type" json:"type,omitempty"`
	// One of the following field will be set depending on the type
	DoubleValue  float64 `protobuf:"fixed64,3,opt,name=double_value,json=doubleValue,proto3" json:"double_value,omitempty"`
	IntegerValue int64   `protobuf:"varint,4,opt,name=integer_value,json=integerValue,proto3" json:"integer_value,omitempty"`
	StringValue  string  `protobuf:"bytes,5,opt,name=string_value,json=stringValue,proto3" json:"string_value,omitempty"`
	// contains filtered or unexported fields
}

Represents a named and typed data point. Can be used as a prediction input, output or metadata. Oneof types are avoided as these can be difficult to handle

func (*Variable) Descriptor deprecated 

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

Deprecated: Use Variable.ProtoReflect.Descriptor instead.

func (*Variable) GetDoubleValue 

func (x *Variable) GetDoubleValue() float64

func (*Variable) GetIntegerValue 

func (x *Variable) GetIntegerValue() int64

func (*Variable) GetName 

func (x *Variable) GetName() string

func (*Variable) GetStringValue 

func (x *Variable) GetStringValue() string

func (*Variable) GetType 

func (x *Variable) GetType() Type

func (*Variable) ProtoMessage 

func (*Variable) ProtoMessage()

func (*Variable) ProtoReflect 

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

func (*Variable) Reset 

func (x *Variable) Reset()

func (*Variable) String 

func (x *Variable) 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.