v1

package
v0.4.671 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 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_batchpredictord_v1_batchpredictord_proto protoreflect.FileDescriptor

Functions

func RegisterBatchServer 

func RegisterBatchServer(s *grpc.Server, srv BatchServer)

Types

type BatchClient 

type BatchClient interface {
	// Ingest a new dataset to the store, the store creates a new layouts and set of keys
	// for the new dataset
	BatchPredict(ctx context.Context, in *BatchPredictRequest, opts ...grpc.CallOption) (*BatchPredictResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

BatchClient is the client API for Batch service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBatchClient 

func NewBatchClient(cc grpc.ClientConnInterface) BatchClient

type BatchPredictRequest 

type BatchPredictRequest struct {
	Prediction     *v1alpha1.Prediction     `protobuf:"bytes,1,opt,name=prediction,proto3" json:"prediction,omitempty"`
	FromBucket     *v1alpha11.VirtualBucket `protobuf:"bytes,2,opt,name=fromBucket,proto3" json:"fromBucket,omitempty"`
	FromConnection *v1alpha11.Connection    `protobuf:"bytes,3,opt,name=fromConnection,proto3" json:"fromConnection,omitempty"`
	FromSecret     map[string][]byte        `` /* 161-byte string literal not displayed */
	TargetBucket   *v1alpha11.VirtualBucket `protobuf:"bytes,5,opt,name=targetBucket,proto3" json:"targetBucket,omitempty"`
	ToConnection   *v1alpha11.Connection    `protobuf:"bytes,6,opt,name=toConnection,proto3" json:"toConnection,omitempty"`
	ToSecret       map[string][]byte        `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

A request to batch predictor

func (*BatchPredictRequest) Descriptor deprecated 

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

Deprecated: Use BatchPredictRequest.ProtoReflect.Descriptor instead.

func (*BatchPredictRequest) GetFromBucket 

func (x *BatchPredictRequest) GetFromBucket() *v1alpha11.VirtualBucket

func (*BatchPredictRequest) GetFromConnection 

func (x *BatchPredictRequest) GetFromConnection() *v1alpha11.Connection

func (*BatchPredictRequest) GetFromSecret 

func (x *BatchPredictRequest) GetFromSecret() map[string][]byte

func (*BatchPredictRequest) GetPrediction 

func (x *BatchPredictRequest) GetPrediction() *v1alpha1.Prediction

func (*BatchPredictRequest) GetTargetBucket 

func (x *BatchPredictRequest) GetTargetBucket() *v1alpha11.VirtualBucket

func (*BatchPredictRequest) GetToConnection 

func (x *BatchPredictRequest) GetToConnection() *v1alpha11.Connection

func (*BatchPredictRequest) GetToSecret 

func (x *BatchPredictRequest) GetToSecret() map[string][]byte

func (*BatchPredictRequest) ProtoMessage 

func (*BatchPredictRequest) ProtoMessage()

func (*BatchPredictRequest) ProtoReflect 

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

func (*BatchPredictRequest) Reset 

func (x *BatchPredictRequest) Reset()

func (*BatchPredictRequest) String 

func (x *BatchPredictRequest) String() string

type BatchPredictResponse 

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

func (*BatchPredictResponse) Descriptor deprecated 

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

Deprecated: Use BatchPredictResponse.ProtoReflect.Descriptor instead.

func (*BatchPredictResponse) ProtoMessage 

func (*BatchPredictResponse) ProtoMessage()

func (*BatchPredictResponse) ProtoReflect 

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

func (*BatchPredictResponse) Reset 

func (x *BatchPredictResponse) Reset()

func (*BatchPredictResponse) String 

func (x *BatchPredictResponse) String() string

type BatchServer 

type BatchServer interface {
	// Ingest a new dataset to the store, the store creates a new layouts and set of keys
	// for the new dataset
	BatchPredict(context.Context, *BatchPredictRequest) (*BatchPredictResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
}

BatchServer is the server API for Batch service.

type ShutdownRequest added in v0.4.644 

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

func (*ShutdownRequest) Descriptor deprecated added in v0.4.644 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage added in v0.4.644 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect added in v0.4.644 

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

func (*ShutdownRequest) Reset added in v0.4.644 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String added in v0.4.644 

func (x *ShutdownRequest) String() string

type ShutdownResponse added in v0.4.643 

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

func (*ShutdownResponse) Descriptor deprecated added in v0.4.643 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage added in v0.4.643 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect added in v0.4.643 

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

func (*ShutdownResponse) Reset added in v0.4.643 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String added in v0.4.643 

func (x *ShutdownResponse) String() string

type UnimplementedBatchServer 

type UnimplementedBatchServer struct {
}

UnimplementedBatchServer can be embedded to have forward compatible implementations.

func (*UnimplementedBatchServer) BatchPredict 

func (*UnimplementedBatchServer) BatchPredict(context.Context, *BatchPredictRequest) (*BatchPredictResponse, error)

func (*UnimplementedBatchServer) Shutdown 

func (*UnimplementedBatchServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

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.