v1

Documentation

Index

• Variables
• func RegisterBatchServer(s *grpc.Server, srv BatchServer)
• type BatchClient
  • func NewBatchClient(cc grpc.ClientConnInterface) BatchClient
• type BatchPredictRequest
  • func (*BatchPredictRequest) Descriptor() ([]byte, []int)
  • func (x *BatchPredictRequest) GetFromBucket() *v1alpha11.VirtualBucket
  • func (x *BatchPredictRequest) GetFromConnection() *v1alpha11.Connection
  • func (x *BatchPredictRequest) GetFromSecret() map[string][]byte
  • func (x *BatchPredictRequest) GetPrediction() *v1alpha1.Prediction
  • func (x *BatchPredictRequest) GetTargetBucket() *v1alpha11.VirtualBucket
  • func (x *BatchPredictRequest) GetToConnection() *v1alpha11.Connection
  • func (x *BatchPredictRequest) GetToSecret() map[string][]byte
  • func (*BatchPredictRequest) ProtoMessage()
  • func (x *BatchPredictRequest) ProtoReflect() protoreflect.Message
  • func (x *BatchPredictRequest) Reset()
  • func (x *BatchPredictRequest) String() string
• type BatchPredictResponse
  • func (*BatchPredictResponse) Descriptor() ([]byte, []int)
  • func (*BatchPredictResponse) ProtoMessage()
  • func (x *BatchPredictResponse) ProtoReflect() protoreflect.Message
  • func (x *BatchPredictResponse) Reset()
  • func (x *BatchPredictResponse) String() string
• type BatchServer
• type UnimplementedBatchServer
  • func (*UnimplementedBatchServer) BatchPredict(context.Context, *BatchPredictRequest) (*BatchPredictResponse, error)
  • func (*UnimplementedBatchServer) Shutdown(context.Context, *empty.Empty) (*empty.Empty, error)

Variables

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 *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, 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

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

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, *empty.Empty) (*empty.Empty, error)
}

BatchServer is the server API for Batch service.

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, *empty.Empty) (*empty.Empty, error)