dlframework

package module
v0.2.20 Latest Latest
Warning

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

 Go to latest Published: Jun 20, 2018 License: NCSA Imports: 35 Imported by: 15

README

DLFramework Build Status

Framework Manifest Format

name: MXNet # name of the framework
version: 0.1 # framework version
container: # containers used to perform model prediction
           # multiple platforms can be specified
  amd64:   # if unspecified, then the default container for the framework is used
    gpu: raiproject/carml-mxnet:amd64-cpu
    cpu: raiproject/carml-mxnet:amd64-gpu
  ppc64le:
    cpu: raiproject/carml-mxnet:ppc64le-gpu
    gpu: raiproject/carml-mxnet:ppc64le-gpu

Model Manifest Format

name: InceptionNet # name of your model
framework: # the framework to use
  name: MXNet # framework for the model
  version: ^0.1 # framework version constraint
version: 1.0 # version information in semantic version format
container: # containers used to perform model prediction
           # multiple platforms can be specified
  amd64:   # if unspecified, then the default container for the framework is used
    gpu: raiproject/carml-mxnet:amd64-cpu
    cpu: raiproject/carml-mxnet:amd64-gpu
  ppc64le:
    cpu: raiproject/carml-mxnet:ppc64le-gpu
    gpu: raiproject/carml-mxnet:ppc64le-gpu
description: >
  An image-classification convolutional network.
  Inception achieves 21.2% top-1 and 5.6% top-5 error on the ILSVRC 2012 validation dataset.
  It consists of fewer than 25M parameters.
references: # references to papers / websites / etc.. describing the model
  - https://arxiv.org/pdf/1512.00567.pdf
# license of the model
license: MIT
# inputs to the model 
inputs:
  # first input type for the model
  - type: image
    # description of the first input
    description: the input image
    parameters: # type parameters
      dimensions: [1, 3, 224, 224]
output:
  # the type of the output
  type: feature
  # a description of the output parameter
  description: the output label
  parameters:
    # type parameters 
    features_url: http://data.dmlc.ml/mxnet/models/imagenet/synset.txt
before_preprocess: >
  code... 
preprocess: >
  code... 
after_preprocess: >
  code... 
before_postprocess: >
  code... 
postprocess: >
  code... 
after_postprocess: >
  code... 
model: # specifies model graph and weights resources
  base_url: http://data.dmlc.ml/models/imagenet/inception-bn/
  graph_path: Inception-BN-symbol.json
  weights_path: Inception-BN-0126.params
  is_archive: false # if set, then the base_url is a url to an archive
                    # the graph_path and weights_path then denote the 
                    # file names of the graph and weights within the archive
attributes: # extra network attributes 
  kind: CNN # the kind of neural network (CNN, RNN, ...)
  training_dataset: ImageNet # dataset used to for training
  manifest_author: abduld
hidden: false # hide the model from the frontend

Documentation

Overview

Package dlframework is a reverse proxy.

It translates gRPC into RESTful JSON APIs. 

Package dlframework is a generated protocol buffer package.

It is generated from these files:
	registry.proto
	predictor.proto

It has these top-level messages:
	ErrorStatus
	ContainerHardware
	FrameworkManifest
	ModelManifest
	FrameworkRequest
	FrameworkManifestsResponse
	Agent
	Agents
	ModelRequest
	ModelManifestsResponse
	CPUOptions
	GPUOptions
	ExecutionOptions
	PredictionOptions
	PredictorOpenRequest
	PredictorCloseResponse
	Predictor
	URLsRequest
	ImagesRequest
	DatasetRequest
	Feature
	FeatureResponse
	FeaturesResponse
	ResetRequest
	ResetResponse

Package dlframework is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	Swagger = dlframework_swagger
)

Variables

View Source 
var (
	ErrInvalidLengthPredictor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPredictor   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRegistry = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRegistry   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	RegistryServiceDescription = _Registry_serviceDesc
	PredictServiceDescription  = _Predict_serviceDesc
)
View Source 
var ExecutionOptions_TraceLevel_name = map[int32]string{
	0: "NO_TRACE",
	1: "STEP_TRACE",
	2: "FRAMEWORK_TRACE",
	3: "CPU_ONLY_TRACE",
	4: "HARDWARE_TRACE",
	5: "FULL_TRACE",
}
View Source 
var ExecutionOptions_TraceLevel_value = map[string]int32{
	"NO_TRACE":        0,
	"STEP_TRACE":      1,
	"FRAMEWORK_TRACE": 2,
	"CPU_ONLY_TRACE":  3,
	"HARDWARE_TRACE":  4,
	"FULL_TRACE":      5,
}
View Source 
var Version = "0.2.20"

Functions

func Bhattacharyya added in v0.2.19 

func Bhattacharyya(p, q []float64) float64

Bhattacharyya computes the distance between the probability distributions p and q given by: 

-\ln ( \sum_i \sqrt{p_i q_i} )

The lengths of p and q must be equal. It is assumed that p and q sum to 1.

func Correlation added in v0.2.19 

func Correlation(x, y, weights []float64) float64

Correlation returns the weighted correlation between the samples of x and y with the given means. 

sum_i {w_i (x_i - meanX) * (y_i - meanY)} / (stdX * stdY)

The lengths of x and y must be equal. If weights is nil then all of the weights are 1. If weights is not nil, then len(x) must equal len(weights).

func Covariance added in v0.2.19 

func Covariance(x, y, weights []float64) float64

Covariance returns the weighted covariance between the samples of x and y. 

sum_i {w_i (x_i - meanX) * (y_i - meanY)} / (sum_j {w_j} - 1)

The lengths of x and y must be equal. If weights is nil then all of the weights are 1. If weights is not nil, then len(x) must equal len(weights).

func Hellinger added in v0.2.19 

func Hellinger(p, q []float64) float64

Hellinger computes the distance between the probability distributions p and q given by: 

\sqrt{ 1 - \sum_i \sqrt{p_i q_i} }

The lengths of p and q must be equal. It is assumed that p and q sum to 1.

func JensenShannon added in v0.2.19 

func JensenShannon(p, q []float64) float64

JensenShannon computes the JensenShannon divergence between the distributions p and q. The Jensen-Shannon divergence is defined as 

m = 0.5 * (p + q)
JS(p, q) = 0.5 ( KL(p, m) + KL(q, m) )

Unlike Kullback-Liebler, the Jensen-Shannon distance is symmetric. The value is between 0 and ln(2).

func KullbackLeibler added in v0.2.19 

func KullbackLeibler(p, q []float64) float64

KullbackLeibler computes the Kullback-Leibler distance between the distributions p and q. The natural logarithm is used. 

sum_i(p_i * log(p_i / q_i))

Note that the Kullback-Leibler distance is not symmetric; KullbackLeibler(p,q) != KullbackLeibler(q,p)

func Mean added in v0.2.19 

func Mean(x, weights []float64) float64

Mean computes the weighted mean of the data set. 

sum_i {w_i * x_i} / sum_i {w_i}

If weights is nil then all of the weights are 1. If weights is not nil, then len(x) must equal len(weights).

func PredictorDescription added in v0.2.19 

func PredictorDescription() (desc *descriptor.FileDescriptorSet)

func RegisterPredictHandler added in v0.2.16 

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

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

func RegisterPredictHandlerClient added in v0.2.20 

func RegisterPredictHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PredictClient) error

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

func RegisterPredictHandlerFromEndpoint added in v0.2.16 

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

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

func RegisterPredictServer added in v0.2.16 

func RegisterPredictServer(s *grpc.Server, srv PredictServer)

func RegisterRegistryHandler 

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

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

func RegisterRegistryHandlerClient added in v0.2.20 

func RegisterRegistryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RegistryClient) error

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

func RegisterRegistryHandlerFromEndpoint 

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

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

func RegisterRegistryServer 

func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)

func RegisteredFrameworkNames 

func RegisteredFrameworkNames() []string

func RegisteredModelNames 

func RegisteredModelNames() []string

func RegistryDescription added in v0.2.19 

func RegistryDescription() (desc *descriptor.FileDescriptorSet)

func Sum added in v0.2.19 

func Sum(s []float64) float64

Sum returns the sum of the elements of the slice.

Types

type Agent 

type Agent struct {
	Host         string               `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty" yaml:"host,omitempty"`
	Port         string               `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty" yaml:"port,omitempty"`
	Hostname     string               `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty" yaml:"hostname,omitempty"`
	Architecture string               `protobuf:"bytes,4,opt,name=architecture,proto3" json:"architecture,omitempty" yaml:"architecture,omitempty"`
	Hasgpu       bool                 `protobuf:"varint,5,opt,name=hasgpu,proto3" json:"hasgpu,omitempty" yaml:"hasgpu,omitempty"`
	Cpuinfo      string               `protobuf:"bytes,6,opt,name=cpuinfo,proto3" json:"cpuinfo,omitempty" yaml:"cpuinfo,omitempty"`
	Gpuinfo      string               `protobuf:"bytes,7,opt,name=gpuinfo,proto3" json:"gpuinfo,omitempty" yaml:"gpuinfo,omitempty"`
	Frameworks   []*FrameworkManifest `protobuf:"bytes,8,rep,name=frameworks" json:"frameworks,omitempty" yaml:"frameworks,omitempty"`
	Metadata     map[string]string    `` /* 176-byte string literal not displayed */
}

func NewPopulatedAgent 

func NewPopulatedAgent(r randyRegistry, easy bool) *Agent

func (*Agent) Description added in v0.2.16 

func (this *Agent) Description() (desc *descriptor.FileDescriptorSet)

func (*Agent) Descriptor 

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

func (*Agent) Equal 

func (this *Agent) Equal(that interface{}) bool

func (*Agent) GetArchitecture added in v0.2.19 

func (m *Agent) GetArchitecture() string

func (*Agent) GetCpuinfo added in v0.2.19 

func (m *Agent) GetCpuinfo() string

func (*Agent) GetFrameworks added in v0.2.19 

func (m *Agent) GetFrameworks() []*FrameworkManifest

func (*Agent) GetGpuinfo added in v0.2.19 

func (m *Agent) GetGpuinfo() string

func (*Agent) GetHasgpu added in v0.2.19 

func (m *Agent) GetHasgpu() bool

func (*Agent) GetHost 

func (m *Agent) GetHost() string

func (*Agent) GetHostname added in v0.2.19 

func (m *Agent) GetHostname() string

func (*Agent) GetMetadata added in v0.2.19 

func (m *Agent) GetMetadata() map[string]string

func (*Agent) GetPort 

func (m *Agent) GetPort() string

func (*Agent) GoString 

func (this *Agent) GoString() string

func (*Agent) Marshal 

func (m *Agent) Marshal() (dAtA []byte, err error)

func (*Agent) MarshalTo 

func (m *Agent) MarshalTo(dAtA []byte) (int, error)

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) Reset 

func (m *Agent) Reset()

func (*Agent) Size 

func (m *Agent) Size() (n int)

func (*Agent) String 

func (this *Agent) String() string

func (*Agent) Unmarshal 

func (m *Agent) Unmarshal(dAtA []byte) error

func (*Agent) VerboseEqual 

func (this *Agent) VerboseEqual(that interface{}) error

type Agents 

type Agents struct {
	Agents []*Agent `protobuf:"bytes,1,rep,name=agents" json:"agents,omitempty" yaml:"agents,omitempty"`
}

func NewPopulatedAgents 

func NewPopulatedAgents(r randyRegistry, easy bool) *Agents

func (*Agents) Description added in v0.2.16 

func (this *Agents) Description() (desc *descriptor.FileDescriptorSet)

func (*Agents) Descriptor 

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

func (*Agents) Equal 

func (this *Agents) Equal(that interface{}) bool

func (*Agents) GetAgents 

func (m *Agents) GetAgents() []*Agent

func (*Agents) GoString 

func (this *Agents) GoString() string

func (*Agents) Marshal 

func (m *Agents) Marshal() (dAtA []byte, err error)

func (*Agents) MarshalTo 

func (m *Agents) MarshalTo(dAtA []byte) (int, error)

func (*Agents) ProtoMessage 

func (*Agents) ProtoMessage()

func (*Agents) Reset 

func (m *Agents) Reset()

func (*Agents) Size 

func (m *Agents) Size() (n int)

func (*Agents) String 

func (this *Agents) String() string

func (*Agents) Unmarshal 

func (m *Agents) Unmarshal(dAtA []byte) error

func (*Agents) VerboseEqual 

func (this *Agents) VerboseEqual(that interface{}) error

type CPUOptions added in v0.2.19 

type CPUOptions struct {
}

func NewPopulatedCPUOptions added in v0.2.19 

func NewPopulatedCPUOptions(r randyPredictor, easy bool) *CPUOptions

func (*CPUOptions) Descriptor added in v0.2.19 

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

func (*CPUOptions) Equal added in v0.2.19 

func (this *CPUOptions) Equal(that interface{}) bool

func (*CPUOptions) GoString added in v0.2.19 

func (this *CPUOptions) GoString() string

func (*CPUOptions) Marshal added in v0.2.19 

func (m *CPUOptions) Marshal() (dAtA []byte, err error)

func (*CPUOptions) MarshalTo added in v0.2.19 

func (m *CPUOptions) MarshalTo(dAtA []byte) (int, error)

func (*CPUOptions) ProtoMessage added in v0.2.19 

func (*CPUOptions) ProtoMessage()

func (*CPUOptions) Reset added in v0.2.19 

func (m *CPUOptions) Reset()

func (*CPUOptions) Size added in v0.2.19 

func (m *CPUOptions) Size() (n int)

func (*CPUOptions) String added in v0.2.19 

func (this *CPUOptions) String() string

func (*CPUOptions) Unmarshal added in v0.2.19 

func (m *CPUOptions) Unmarshal(dAtA []byte) error

func (*CPUOptions) VerboseEqual added in v0.2.19 

func (this *CPUOptions) VerboseEqual(that interface{}) error

type ContainerHardware 

type ContainerHardware struct {
	Gpu string `protobuf:"bytes,1,opt,name=gpu,proto3" json:"gpu,omitempty" yaml:"gpu,omitempty"`
	Cpu string `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty" yaml:"cpu,omitempty"`
}

func NewPopulatedContainerHardware 

func NewPopulatedContainerHardware(r randyRegistry, easy bool) *ContainerHardware

func (*ContainerHardware) Description added in v0.2.16 

func (this *ContainerHardware) Description() (desc *descriptor.FileDescriptorSet)

func (*ContainerHardware) Descriptor 

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

func (*ContainerHardware) Equal 

func (this *ContainerHardware) Equal(that interface{}) bool

func (*ContainerHardware) GetCpu 

func (m *ContainerHardware) GetCpu() string

func (*ContainerHardware) GetGpu 

func (m *ContainerHardware) GetGpu() string

func (*ContainerHardware) GoString 

func (this *ContainerHardware) GoString() string

func (*ContainerHardware) Marshal 

func (m *ContainerHardware) Marshal() (dAtA []byte, err error)

func (*ContainerHardware) MarshalTo 

func (m *ContainerHardware) MarshalTo(dAtA []byte) (int, error)

func (*ContainerHardware) ProtoMessage 

func (*ContainerHardware) ProtoMessage()

func (*ContainerHardware) Reset 

func (m *ContainerHardware) Reset()

func (*ContainerHardware) Size 

func (m *ContainerHardware) Size() (n int)

func (*ContainerHardware) String 

func (this *ContainerHardware) String() string

func (*ContainerHardware) Unmarshal 

func (m *ContainerHardware) Unmarshal(dAtA []byte) error

func (*ContainerHardware) VerboseEqual 

func (this *ContainerHardware) VerboseEqual(that interface{}) error

type DatasetRequest added in v0.2.16 

type DatasetRequest struct {
	Predictor *Predictor              `protobuf:"bytes,1,opt,name=predictor" json:"predictor,omitempty" yaml:"predictor,omitempty"`
	Dataset   *DatasetRequest_Dataset `protobuf:"bytes,2,opt,name=dataset" json:"dataset,omitempty" yaml:"dataset,omitempty"`
	Options   *PredictionOptions      `protobuf:"bytes,3,opt,name=options" json:"options,omitempty" yaml:"options,omitempty"`
}

func NewPopulatedDatasetRequest added in v0.2.16 

func NewPopulatedDatasetRequest(r randyPredictor, easy bool) *DatasetRequest

func (*DatasetRequest) Description added in v0.2.16 

func (this *DatasetRequest) Description() (desc *descriptor.FileDescriptorSet)

func (*DatasetRequest) Descriptor added in v0.2.16 

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

func (*DatasetRequest) Equal added in v0.2.16 

func (this *DatasetRequest) Equal(that interface{}) bool

func (*DatasetRequest) GetDataset added in v0.2.16 

func (m *DatasetRequest) GetDataset() *DatasetRequest_Dataset

func (*DatasetRequest) GetOptions added in v0.2.16 

func (m *DatasetRequest) GetOptions() *PredictionOptions

func (*DatasetRequest) GetPredictor added in v0.2.16 

func (m *DatasetRequest) GetPredictor() *Predictor

func (*DatasetRequest) GoString added in v0.2.16 

func (this *DatasetRequest) GoString() string

func (*DatasetRequest) Marshal added in v0.2.16 

func (m *DatasetRequest) Marshal() (dAtA []byte, err error)

func (*DatasetRequest) MarshalTo added in v0.2.16 

func (m *DatasetRequest) MarshalTo(dAtA []byte) (int, error)

func (*DatasetRequest) ProtoMessage added in v0.2.16 

func (*DatasetRequest) ProtoMessage()

func (*DatasetRequest) Reset added in v0.2.16 

func (m *DatasetRequest) Reset()

func (*DatasetRequest) Size added in v0.2.16 

func (m *DatasetRequest) Size() (n int)

func (*DatasetRequest) String added in v0.2.16 

func (this *DatasetRequest) String() string

func (*DatasetRequest) Unmarshal added in v0.2.16 

func (m *DatasetRequest) Unmarshal(dAtA []byte) error

func (*DatasetRequest) VerboseEqual added in v0.2.16 

func (this *DatasetRequest) VerboseEqual(that interface{}) error

type DatasetRequest_Dataset added in v0.2.16 

type DatasetRequest_Dataset struct {
	Category string `protobuf:"bytes,1,opt,name=category,proto3" json:"category,omitempty" yaml:"category,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" yaml:"name,omitempty"`
}

func NewPopulatedDatasetRequest_Dataset added in v0.2.16 

func NewPopulatedDatasetRequest_Dataset(r randyPredictor, easy bool) *DatasetRequest_Dataset

func (*DatasetRequest_Dataset) Descriptor added in v0.2.16 

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

func (*DatasetRequest_Dataset) Equal added in v0.2.16 

func (this *DatasetRequest_Dataset) Equal(that interface{}) bool

func (*DatasetRequest_Dataset) GetCategory added in v0.2.16 

func (m *DatasetRequest_Dataset) GetCategory() string

func (*DatasetRequest_Dataset) GetName added in v0.2.16 

func (m *DatasetRequest_Dataset) GetName() string

func (*DatasetRequest_Dataset) GoString added in v0.2.16 

func (this *DatasetRequest_Dataset) GoString() string

func (*DatasetRequest_Dataset) Marshal added in v0.2.16 

func (m *DatasetRequest_Dataset) Marshal() (dAtA []byte, err error)

func (*DatasetRequest_Dataset) MarshalTo added in v0.2.16 

func (m *DatasetRequest_Dataset) MarshalTo(dAtA []byte) (int, error)

func (*DatasetRequest_Dataset) ProtoMessage added in v0.2.16 

func (*DatasetRequest_Dataset) ProtoMessage()

func (*DatasetRequest_Dataset) Reset added in v0.2.16 

func (m *DatasetRequest_Dataset) Reset()

func (*DatasetRequest_Dataset) Size added in v0.2.16 

func (m *DatasetRequest_Dataset) Size() (n int)

func (*DatasetRequest_Dataset) String added in v0.2.16 

func (this *DatasetRequest_Dataset) String() string

func (*DatasetRequest_Dataset) Unmarshal added in v0.2.16 

func (m *DatasetRequest_Dataset) Unmarshal(dAtA []byte) error

func (*DatasetRequest_Dataset) VerboseEqual added in v0.2.16 

func (this *DatasetRequest_Dataset) VerboseEqual(that interface{}) error

type ErrorStatus 

type ErrorStatus struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty" yaml:"ok,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" yaml:"message,omitempty"`
}

func NewPopulatedErrorStatus 

func NewPopulatedErrorStatus(r randyRegistry, easy bool) *ErrorStatus

func (*ErrorStatus) Description added in v0.2.16 

func (this *ErrorStatus) Description() (desc *descriptor.FileDescriptorSet)

func (*ErrorStatus) Descriptor 

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

func (*ErrorStatus) Equal 

func (this *ErrorStatus) Equal(that interface{}) bool

func (*ErrorStatus) GetMessage 

func (m *ErrorStatus) GetMessage() string

func (*ErrorStatus) GetOk 

func (m *ErrorStatus) GetOk() bool

func (*ErrorStatus) GoString 

func (this *ErrorStatus) GoString() string

func (*ErrorStatus) Marshal 

func (m *ErrorStatus) Marshal() (dAtA []byte, err error)

func (*ErrorStatus) MarshalTo 

func (m *ErrorStatus) MarshalTo(dAtA []byte) (int, error)

func (*ErrorStatus) ProtoMessage 

func (*ErrorStatus) ProtoMessage()

func (*ErrorStatus) Reset 

func (m *ErrorStatus) Reset()

func (*ErrorStatus) Size 

func (m *ErrorStatus) Size() (n int)

func (*ErrorStatus) String 

func (this *ErrorStatus) String() string

func (*ErrorStatus) Unmarshal 

func (m *ErrorStatus) Unmarshal(dAtA []byte) error

func (*ErrorStatus) VerboseEqual 

func (this *ErrorStatus) VerboseEqual(that interface{}) error

type ExecutionOptions added in v0.2.19 

type ExecutionOptions struct {
	TraceLevel ExecutionOptions_TraceLevel `` /* 176-byte string literal not displayed */
	// Time to wait for operation to complete in milliseconds.
	TimeoutInMs int64 `` /* 128-byte string literal not displayed */
	// Map from device type name (e.g., "CPU" or "GPU" ) to maximum
	// number of devices of that type to use.  If a particular device
	// type is not found in the map, the system picks an appropriate
	// number.
	DeviceCount map[string]int32 `` /* 206-byte string literal not displayed */
	// Options that apply to all CPUs.
	CpuOptions *CPUOptions `protobuf:"bytes,4,opt,name=cpu_options,json=cpuOptions" json:"cpu_options,omitempty" yaml:"cpu_options,omitempty"`
	// Options that apply to all GPUs.
	GpuOptions *GPUOptions `protobuf:"bytes,5,opt,name=gpu_options,json=gpuOptions" json:"gpu_options,omitempty" yaml:"gpu_options,omitempty"`
}

func NewPopulatedExecutionOptions added in v0.2.19 

func NewPopulatedExecutionOptions(r randyPredictor, easy bool) *ExecutionOptions

func (*ExecutionOptions) Descriptor added in v0.2.19 

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

func (*ExecutionOptions) Equal added in v0.2.19 

func (this *ExecutionOptions) Equal(that interface{}) bool

func (*ExecutionOptions) GetCpuOptions added in v0.2.19 

func (m *ExecutionOptions) GetCpuOptions() *CPUOptions

func (*ExecutionOptions) GetDeviceCount added in v0.2.19 

func (m *ExecutionOptions) GetDeviceCount() map[string]int32

func (*ExecutionOptions) GetGpuOptions added in v0.2.19 

func (m *ExecutionOptions) GetGpuOptions() *GPUOptions

func (*ExecutionOptions) GetTimeoutInMs added in v0.2.19 

func (m *ExecutionOptions) GetTimeoutInMs() int64

func (*ExecutionOptions) GetTraceLevel added in v0.2.19 

func (m *ExecutionOptions) GetTraceLevel() ExecutionOptions_TraceLevel

func (*ExecutionOptions) GoString added in v0.2.19 

func (this *ExecutionOptions) GoString() string

func (*ExecutionOptions) Marshal added in v0.2.19 

func (m *ExecutionOptions) Marshal() (dAtA []byte, err error)

func (*ExecutionOptions) MarshalTo added in v0.2.19 

func (m *ExecutionOptions) MarshalTo(dAtA []byte) (int, error)

func (*ExecutionOptions) ProtoMessage added in v0.2.19 

func (*ExecutionOptions) ProtoMessage()

func (*ExecutionOptions) Reset added in v0.2.19 

func (m *ExecutionOptions) Reset()

func (*ExecutionOptions) Size added in v0.2.19 

func (m *ExecutionOptions) Size() (n int)

func (*ExecutionOptions) String added in v0.2.19 

func (this *ExecutionOptions) String() string

func (*ExecutionOptions) Unmarshal added in v0.2.19 

func (m *ExecutionOptions) Unmarshal(dAtA []byte) error

func (*ExecutionOptions) VerboseEqual added in v0.2.19 

func (this *ExecutionOptions) VerboseEqual(that interface{}) error

type ExecutionOptions_TraceLevel added in v0.2.19 

type ExecutionOptions_TraceLevel int32
const (
	ExecutionOptions_NO_TRACE        ExecutionOptions_TraceLevel = 0
	ExecutionOptions_STEP_TRACE      ExecutionOptions_TraceLevel = 1
	ExecutionOptions_FRAMEWORK_TRACE ExecutionOptions_TraceLevel = 2
	ExecutionOptions_CPU_ONLY_TRACE  ExecutionOptions_TraceLevel = 3
	ExecutionOptions_HARDWARE_TRACE  ExecutionOptions_TraceLevel = 4
	ExecutionOptions_FULL_TRACE      ExecutionOptions_TraceLevel = 5
)

func (ExecutionOptions_TraceLevel) EnumDescriptor added in v0.2.19 

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

func (ExecutionOptions_TraceLevel) String added in v0.2.19 

func (x ExecutionOptions_TraceLevel) String() string

type Feature added in v0.2.16 

type Feature struct {
	Index       int64             `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty" yaml:"index,omitempty"`
	Name        string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty" yaml:"name,omitempty"`
	Probability float32           `protobuf:"fixed32,3,opt,name=probability,proto3" json:"probability,omitempty" yaml:"probability,omitempty"`
	Metadata    map[string]string `` /* 176-byte string literal not displayed */
}

func NewPopulatedFeature added in v0.2.16 

func NewPopulatedFeature(r randyPredictor, easy bool) *Feature

func (*Feature) Description added in v0.2.16 

func (this *Feature) Description() (desc *descriptor.FileDescriptorSet)

func (*Feature) Descriptor added in v0.2.16 

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

func (*Feature) Equal added in v0.2.16 

func (this *Feature) Equal(that interface{}) bool

func (*Feature) GetIndex added in v0.2.16 

func (m *Feature) GetIndex() int64

func (*Feature) GetMetadata added in v0.2.16 

func (m *Feature) GetMetadata() map[string]string

func (*Feature) GetName added in v0.2.16 

func (m *Feature) GetName() string

func (*Feature) GetProbability added in v0.2.16 

func (m *Feature) GetProbability() float32

func (*Feature) GoString added in v0.2.16 

func (this *Feature) GoString() string

func (*Feature) Marshal added in v0.2.16 

func (m *Feature) Marshal() (dAtA []byte, err error)

func (*Feature) MarshalTo added in v0.2.16 

func (m *Feature) MarshalTo(dAtA []byte) (int, error)

func (*Feature) ProtoMessage added in v0.2.16 

func (*Feature) ProtoMessage()

func (*Feature) Reset added in v0.2.16 

func (m *Feature) Reset()

func (*Feature) Size added in v0.2.16 

func (m *Feature) Size() (n int)

func (*Feature) String added in v0.2.16 

func (this *Feature) String() string

func (*Feature) Unmarshal added in v0.2.16 

func (m *Feature) Unmarshal(dAtA []byte) error

func (*Feature) VerboseEqual added in v0.2.16 

func (this *Feature) VerboseEqual(that interface{}) error

type FeatureResponse added in v0.2.16 

type FeatureResponse struct {
	ID        string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	RequestID string            `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty" yaml:"request_id,omitempty"`
	InputID   string            `protobuf:"bytes,3,opt,name=input_id,json=inputId,proto3" json:"input_id,omitempty" yaml:"input_id,omitempty"`
	Features  []*Feature        `protobuf:"bytes,4,rep,name=features" json:"features,omitempty" yaml:"features,omitempty"`
	Metadata  map[string]string `` /* 176-byte string literal not displayed */
}

func NewPopulatedFeatureResponse added in v0.2.16 

func NewPopulatedFeatureResponse(r randyPredictor, easy bool) *FeatureResponse

func (*FeatureResponse) Description added in v0.2.16 

func (this *FeatureResponse) Description() (desc *descriptor.FileDescriptorSet)

func (*FeatureResponse) Descriptor added in v0.2.16 

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

func (*FeatureResponse) Equal added in v0.2.16 

func (this *FeatureResponse) Equal(that interface{}) bool

func (*FeatureResponse) GetFeatures added in v0.2.16 

func (m *FeatureResponse) GetFeatures() []*Feature

func (*FeatureResponse) GetID added in v0.2.16 

func (m *FeatureResponse) GetID() string

func (*FeatureResponse) GetInputID added in v0.2.16 

func (m *FeatureResponse) GetInputID() string

func (*FeatureResponse) GetMetadata added in v0.2.16 

func (m *FeatureResponse) GetMetadata() map[string]string

func (*FeatureResponse) GetRequestID added in v0.2.16 

func (m *FeatureResponse) GetRequestID() string

func (*FeatureResponse) GoString added in v0.2.16 

func (this *FeatureResponse) GoString() string

func (*FeatureResponse) Marshal added in v0.2.16 

func (m *FeatureResponse) Marshal() (dAtA []byte, err error)

func (*FeatureResponse) MarshalTo added in v0.2.16 

func (m *FeatureResponse) MarshalTo(dAtA []byte) (int, error)

func (*FeatureResponse) ProtoMessage added in v0.2.16 

func (*FeatureResponse) ProtoMessage()

func (*FeatureResponse) Reset added in v0.2.16 

func (m *FeatureResponse) Reset()

func (*FeatureResponse) Size added in v0.2.16 

func (m *FeatureResponse) Size() (n int)

func (*FeatureResponse) String added in v0.2.16 

func (this *FeatureResponse) String() string

func (*FeatureResponse) Unmarshal added in v0.2.16 

func (m *FeatureResponse) Unmarshal(dAtA []byte) error

func (*FeatureResponse) VerboseEqual added in v0.2.16 

func (this *FeatureResponse) VerboseEqual(that interface{}) error

type Features added in v0.2.16 

type Features []*Feature

func (Features) Bhattacharyya added in v0.2.19 

func (p Features) Bhattacharyya(q Features) (float64, error)

func (Features) Correlation added in v0.2.19 

func (p Features) Correlation(q Features) (float64, error)

func (Features) Covariance added in v0.2.19 

func (p Features) Covariance(q Features) (float64, error)

func (Features) Hellinger added in v0.2.19 

func (p Features) Hellinger(q Features) (float64, error)

func (Features) JensenShannon added in v0.2.19 

func (p Features) JensenShannon(q Features) (float64, error)

func (Features) KullbackLeiblerDivergence added in v0.2.19 

func (p Features) KullbackLeiblerDivergence(q Features) (float64, error)

func (Features) Len added in v0.2.16 

func (p Features) Len() int

Len is the number of elements in the collection.

func (Features) Less added in v0.2.16 

func (p Features) Less(i, j int) bool

Less reports whether the element with index i should sort before the element with index j.

func (Features) ProbabilitiesFloat32 added in v0.2.19 

func (p Features) ProbabilitiesFloat32() []float32

func (Features) ProbabilitiesFloat64 added in v0.2.19 

func (p Features) ProbabilitiesFloat64() []float64

func (Features) Sort added in v0.2.16 

func (p Features) Sort()

func (Features) Swap added in v0.2.16 

func (p Features) Swap(i, j int)

Swap swaps the elements with indexes i and j.

func (Features) Take added in v0.2.16 

func (p Features) Take(n int) Features

type FeaturesResponse added in v0.2.16 

type FeaturesResponse struct {
	ID        string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	Responses []*FeatureResponse `protobuf:"bytes,2,rep,name=responses" json:"responses,omitempty" yaml:"responses,omitempty"`
}

func NewPopulatedFeaturesResponse added in v0.2.16 

func NewPopulatedFeaturesResponse(r randyPredictor, easy bool) *FeaturesResponse

func (*FeaturesResponse) Description added in v0.2.16 

func (this *FeaturesResponse) Description() (desc *descriptor.FileDescriptorSet)

func (*FeaturesResponse) Descriptor added in v0.2.16 

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

func (*FeaturesResponse) Equal added in v0.2.16 

func (this *FeaturesResponse) Equal(that interface{}) bool

func (*FeaturesResponse) GetID added in v0.2.16 

func (m *FeaturesResponse) GetID() string

func (*FeaturesResponse) GetResponses added in v0.2.16 

func (m *FeaturesResponse) GetResponses() []*FeatureResponse

func (*FeaturesResponse) GoString added in v0.2.16 

func (this *FeaturesResponse) GoString() string

func (*FeaturesResponse) Marshal added in v0.2.16 

func (m *FeaturesResponse) Marshal() (dAtA []byte, err error)

func (*FeaturesResponse) MarshalTo added in v0.2.16 

func (m *FeaturesResponse) MarshalTo(dAtA []byte) (int, error)

func (*FeaturesResponse) ProtoMessage added in v0.2.16 

func (*FeaturesResponse) ProtoMessage()

func (*FeaturesResponse) Reset added in v0.2.16 

func (m *FeaturesResponse) Reset()

func (*FeaturesResponse) Size added in v0.2.16 

func (m *FeaturesResponse) Size() (n int)

func (*FeaturesResponse) String added in v0.2.16 

func (this *FeaturesResponse) String() string

func (*FeaturesResponse) Unmarshal added in v0.2.16 

func (m *FeaturesResponse) Unmarshal(dAtA []byte) error

func (*FeaturesResponse) VerboseEqual added in v0.2.16 

func (this *FeaturesResponse) VerboseEqual(that interface{}) error

type FrameworkManifest 

type FrameworkManifest struct {
	Name      string                        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" yaml:"name,omitempty"`
	Version   string                        `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty" yaml:"version,omitempty"`
	Container map[string]*ContainerHardware `` /* 172-byte string literal not displayed */
}

func FindFramework 

func FindFramework(name string) (*FrameworkManifest, error)

func Frameworks 

func Frameworks() ([]FrameworkManifest, error)

func NewPopulatedFrameworkManifest 

func NewPopulatedFrameworkManifest(r randyRegistry, easy bool) *FrameworkManifest

func (FrameworkManifest) CanonicalName 

func (f FrameworkManifest) CanonicalName() (string, error)

func (*FrameworkManifest) Description added in v0.2.16 

func (this *FrameworkManifest) Description() (desc *descriptor.FileDescriptorSet)

func (*FrameworkManifest) Descriptor 

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

func (*FrameworkManifest) Equal 

func (this *FrameworkManifest) Equal(that interface{}) bool

func (FrameworkManifest) FindModel 

func (f FrameworkManifest) FindModel(name string) (*ModelManifest, error)

func (*FrameworkManifest) GetContainer 

func (m *FrameworkManifest) GetContainer() map[string]*ContainerHardware

func (*FrameworkManifest) GetName 

func (m *FrameworkManifest) GetName() string

func (*FrameworkManifest) GetVersion 

func (m *FrameworkManifest) GetVersion() string

func (*FrameworkManifest) GoString 

func (this *FrameworkManifest) GoString() string

func (*FrameworkManifest) Marshal 

func (m *FrameworkManifest) Marshal() (dAtA []byte, err error)

func (*FrameworkManifest) MarshalTo 

func (m *FrameworkManifest) MarshalTo(dAtA []byte) (int, error)

func (FrameworkManifest) Models 

func (f FrameworkManifest) Models() []ModelManifest

func (FrameworkManifest) MustCanonicalName 

func (f FrameworkManifest) MustCanonicalName() string

func (*FrameworkManifest) ProtoMessage 

func (*FrameworkManifest) ProtoMessage()

func (FrameworkManifest) Register 

func (f FrameworkManifest) Register() error

func (FrameworkManifest) RegisterNamed 

func (f FrameworkManifest) RegisterNamed(s string) error

func (*FrameworkManifest) Reset 

func (m *FrameworkManifest) Reset()

func (*FrameworkManifest) Size 

func (m *FrameworkManifest) Size() (n int)

func (*FrameworkManifest) String 

func (this *FrameworkManifest) String() string

func (*FrameworkManifest) Unmarshal 

func (m *FrameworkManifest) Unmarshal(dAtA []byte) error

func (*FrameworkManifest) VerboseEqual 

func (this *FrameworkManifest) VerboseEqual(that interface{}) error

func (*FrameworkManifest) WorkDir 

func (f *FrameworkManifest) WorkDir() (string, error)

type FrameworkManifestsResponse 

type FrameworkManifestsResponse struct {
	Manifests []*FrameworkManifest `protobuf:"bytes,1,rep,name=manifests" json:"manifests,omitempty" yaml:"manifests,omitempty"`
}

func NewPopulatedFrameworkManifestsResponse 

func NewPopulatedFrameworkManifestsResponse(r randyRegistry, easy bool) *FrameworkManifestsResponse

func (*FrameworkManifestsResponse) Description added in v0.2.16 

func (this *FrameworkManifestsResponse) Description() (desc *descriptor.FileDescriptorSet)

func (*FrameworkManifestsResponse) Descriptor 

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

func (*FrameworkManifestsResponse) Equal 

func (this *FrameworkManifestsResponse) Equal(that interface{}) bool

func (*FrameworkManifestsResponse) GetManifests 

func (m *FrameworkManifestsResponse) GetManifests() []*FrameworkManifest

func (*FrameworkManifestsResponse) GoString 

func (this *FrameworkManifestsResponse) GoString() string

func (*FrameworkManifestsResponse) Marshal 

func (m *FrameworkManifestsResponse) Marshal() (dAtA []byte, err error)

func (*FrameworkManifestsResponse) MarshalTo 

func (m *FrameworkManifestsResponse) MarshalTo(dAtA []byte) (int, error)

func (*FrameworkManifestsResponse) ProtoMessage 

func (*FrameworkManifestsResponse) ProtoMessage()

func (*FrameworkManifestsResponse) Reset 

func (m *FrameworkManifestsResponse) Reset()

func (*FrameworkManifestsResponse) Size 

func (m *FrameworkManifestsResponse) Size() (n int)

func (*FrameworkManifestsResponse) String 

func (this *FrameworkManifestsResponse) String() string

func (*FrameworkManifestsResponse) Unmarshal 

func (m *FrameworkManifestsResponse) Unmarshal(dAtA []byte) error

func (*FrameworkManifestsResponse) VerboseEqual 

func (this *FrameworkManifestsResponse) VerboseEqual(that interface{}) error

type FrameworkRequest 

type FrameworkRequest struct {
	FrameworkName    string `` /* 132-byte string literal not displayed */
	FrameworkVersion string `` /* 144-byte string literal not displayed */
}

func NewPopulatedFrameworkRequest 

func NewPopulatedFrameworkRequest(r randyRegistry, easy bool) *FrameworkRequest

func (*FrameworkRequest) Description added in v0.2.16 

func (this *FrameworkRequest) Description() (desc *descriptor.FileDescriptorSet)

func (*FrameworkRequest) Descriptor 

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

func (*FrameworkRequest) Equal 

func (this *FrameworkRequest) Equal(that interface{}) bool

func (*FrameworkRequest) GetFrameworkName 

func (m *FrameworkRequest) GetFrameworkName() string

func (*FrameworkRequest) GetFrameworkVersion 

func (m *FrameworkRequest) GetFrameworkVersion() string

func (*FrameworkRequest) GoString 

func (this *FrameworkRequest) GoString() string

func (*FrameworkRequest) Marshal 

func (m *FrameworkRequest) Marshal() (dAtA []byte, err error)

func (*FrameworkRequest) MarshalTo 

func (m *FrameworkRequest) MarshalTo(dAtA []byte) (int, error)

func (*FrameworkRequest) ProtoMessage 

func (*FrameworkRequest) ProtoMessage()

func (*FrameworkRequest) Reset 

func (m *FrameworkRequest) Reset()

func (*FrameworkRequest) Size 

func (m *FrameworkRequest) Size() (n int)

func (*FrameworkRequest) String 

func (this *FrameworkRequest) String() string

func (*FrameworkRequest) Unmarshal 

func (m *FrameworkRequest) Unmarshal(dAtA []byte) error

func (*FrameworkRequest) VerboseEqual 

func (this *FrameworkRequest) VerboseEqual(that interface{}) error

type GPUOptions added in v0.2.19 

type GPUOptions struct {
	// A value between 0 and 1 that indicates what fraction of the
	// available GPU memory to pre-allocate for each process.  1 means
	// to pre-allocate all of the GPU memory, 0.5 means the process
	// allocates ~50% of the available GPU memory.
	PerProcessGpuMemoryFraction float64 `` /* 199-byte string literal not displayed */
	// The type of GPU allocation strategy to use.
	//
	// Allowed values:
	// "": The empty string (default) uses a system-chosen default
	//     which may change over time.
	//
	// "BFC": A "Best-fit with coalescing" algorithm, simplified from a
	//        version of dlmalloc.
	AllocatorType string `` /* 132-byte string literal not displayed */
	// A comma-separated list of GPU ids that determines the 'visible'
	// to 'virtual' mapping of GPU devices.  For example, if TensorFlow
	// can see 8 GPU devices in the process, and one wanted to map
	// visible GPU devices 5 and 3 as "/device:GPU:0", and "/device:GPU:1", then
	// one would specify this field as "5,3".  This field is similar in spirit to
	// the CUDA_VISIBLE_DEVICES environment variable, except it applies to the
	// visible GPU devices in the process.
	//
	// NOTE: The GPU driver provides the process with the visible GPUs
	// in an order which is not guaranteed to have any correlation to
	// the *physical* GPU id in the machine.  This field is used for
	// remapping "visible" to "virtual", which means this operates only
	// after the process starts.  Users are required to use vendor
	// specific mechanisms (e.g., CUDA_VISIBLE_DEVICES) to control the
	// physical to visible device mapping prior to invoking TensorFlow.
	VisibleDeviceList string `` /* 151-byte string literal not displayed */
	// Force all tensors to be gpu_compatible. On a GPU-enabled TensorFlow,
	// enabling this option forces all CPU tensors to be allocated with Cuda
	// pinned memory. Normally, TensorFlow will infer which tensors should be
	// allocated as the pinned memory. But in case where the inference is
	// incomplete, this option can significantly speed up the cross-device memory
	// copy performance as long as it fits the memory.
	// Note that this option is not something that should be
	// enabled by default for unknown or very large models, since all Cuda pinned
	// memory is unpageable, having too much pinned memory might negatively impact
	// the overall host system performance.
	ForceGpuCompatible bool `` /* 156-byte string literal not displayed */
}

func NewPopulatedGPUOptions added in v0.2.19 

func NewPopulatedGPUOptions(r randyPredictor, easy bool) *GPUOptions

func (*GPUOptions) Descriptor added in v0.2.19 

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

func (*GPUOptions) Equal added in v0.2.19 

func (this *GPUOptions) Equal(that interface{}) bool

func (*GPUOptions) GetAllocatorType added in v0.2.19 

func (m *GPUOptions) GetAllocatorType() string

func (*GPUOptions) GetForceGpuCompatible added in v0.2.19 

func (m *GPUOptions) GetForceGpuCompatible() bool

func (*GPUOptions) GetPerProcessGpuMemoryFraction added in v0.2.19 

func (m *GPUOptions) GetPerProcessGpuMemoryFraction() float64

func (*GPUOptions) GetVisibleDeviceList added in v0.2.19 

func (m *GPUOptions) GetVisibleDeviceList() string

func (*GPUOptions) GoString added in v0.2.19 

func (this *GPUOptions) GoString() string

func (*GPUOptions) Marshal added in v0.2.19 

func (m *GPUOptions) Marshal() (dAtA []byte, err error)

func (*GPUOptions) MarshalTo added in v0.2.19 

func (m *GPUOptions) MarshalTo(dAtA []byte) (int, error)

func (*GPUOptions) ProtoMessage added in v0.2.19 

func (*GPUOptions) ProtoMessage()

func (*GPUOptions) Reset added in v0.2.19 

func (m *GPUOptions) Reset()

func (*GPUOptions) Size added in v0.2.19 

func (m *GPUOptions) Size() (n int)

func (*GPUOptions) String added in v0.2.19 

func (this *GPUOptions) String() string

func (*GPUOptions) Unmarshal added in v0.2.19 

func (m *GPUOptions) Unmarshal(dAtA []byte) error

func (*GPUOptions) VerboseEqual added in v0.2.19 

func (this *GPUOptions) VerboseEqual(that interface{}) error

type ImagesRequest added in v0.2.16 

type ImagesRequest struct {
	Predictor *Predictor `protobuf:"bytes,1,opt,name=predictor" json:"predictor,omitempty" yaml:"predictor,omitempty"`
	// A list of Base64 encoded images
	Images  []*ImagesRequest_Image `protobuf:"bytes,2,rep,name=images" json:"images,omitempty" yaml:"images,omitempty"`
	Options *PredictionOptions     `protobuf:"bytes,3,opt,name=options" json:"options,omitempty" yaml:"options,omitempty"`
}

func NewPopulatedImagesRequest added in v0.2.16 

func NewPopulatedImagesRequest(r randyPredictor, easy bool) *ImagesRequest

func (*ImagesRequest) Description added in v0.2.16 

func (this *ImagesRequest) Description() (desc *descriptor.FileDescriptorSet)

func (*ImagesRequest) Descriptor added in v0.2.16 

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

func (*ImagesRequest) Equal added in v0.2.16 

func (this *ImagesRequest) Equal(that interface{}) bool

func (*ImagesRequest) GetImages added in v0.2.16 

func (m *ImagesRequest) GetImages() []*ImagesRequest_Image

func (*ImagesRequest) GetOptions added in v0.2.16 

func (m *ImagesRequest) GetOptions() *PredictionOptions

func (*ImagesRequest) GetPredictor added in v0.2.16 

func (m *ImagesRequest) GetPredictor() *Predictor

func (*ImagesRequest) GoString added in v0.2.16 

func (this *ImagesRequest) GoString() string

func (*ImagesRequest) Marshal added in v0.2.16 

func (m *ImagesRequest) Marshal() (dAtA []byte, err error)

func (*ImagesRequest) MarshalTo added in v0.2.16 

func (m *ImagesRequest) MarshalTo(dAtA []byte) (int, error)

func (*ImagesRequest) ProtoMessage added in v0.2.16 

func (*ImagesRequest) ProtoMessage()

func (*ImagesRequest) Reset added in v0.2.16 

func (m *ImagesRequest) Reset()

func (*ImagesRequest) Size added in v0.2.16 

func (m *ImagesRequest) Size() (n int)

func (*ImagesRequest) String added in v0.2.16 

func (this *ImagesRequest) String() string

func (*ImagesRequest) Unmarshal added in v0.2.16 

func (m *ImagesRequest) Unmarshal(dAtA []byte) error

func (*ImagesRequest) VerboseEqual added in v0.2.16 

func (this *ImagesRequest) VerboseEqual(that interface{}) error

type ImagesRequest_Image added in v0.2.16 

type ImagesRequest_Image struct {
	// An id used to identify the output feature: maps to input_id for output
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	// The image is base64 encoded
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty" yaml:"data,omitempty"`
}

func NewPopulatedImagesRequest_Image added in v0.2.16 

func NewPopulatedImagesRequest_Image(r randyPredictor, easy bool) *ImagesRequest_Image

func (*ImagesRequest_Image) Descriptor added in v0.2.16 

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

func (*ImagesRequest_Image) Equal added in v0.2.16 

func (this *ImagesRequest_Image) Equal(that interface{}) bool

func (*ImagesRequest_Image) GetData added in v0.2.16 

func (m *ImagesRequest_Image) GetData() []byte

func (*ImagesRequest_Image) GetID added in v0.2.16 

func (m *ImagesRequest_Image) GetID() string

func (*ImagesRequest_Image) GoString added in v0.2.16 

func (this *ImagesRequest_Image) GoString() string

func (*ImagesRequest_Image) Marshal added in v0.2.16 

func (m *ImagesRequest_Image) Marshal() (dAtA []byte, err error)

func (*ImagesRequest_Image) MarshalTo added in v0.2.16 

func (m *ImagesRequest_Image) MarshalTo(dAtA []byte) (int, error)

func (*ImagesRequest_Image) ProtoMessage added in v0.2.16 

func (*ImagesRequest_Image) ProtoMessage()

func (*ImagesRequest_Image) Reset added in v0.2.16 

func (m *ImagesRequest_Image) Reset()

func (*ImagesRequest_Image) Size added in v0.2.16 

func (m *ImagesRequest_Image) Size() (n int)

func (*ImagesRequest_Image) String added in v0.2.16 

func (this *ImagesRequest_Image) String() string

func (*ImagesRequest_Image) Unmarshal added in v0.2.16 

func (m *ImagesRequest_Image) Unmarshal(dAtA []byte) error

func (*ImagesRequest_Image) VerboseEqual added in v0.2.16 

func (this *ImagesRequest_Image) VerboseEqual(that interface{}) error

type ModelManifest 

type ModelManifest struct {
	Name              string                        `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty" yaml:"name,omitempty"`
	Version           string                        `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty" yaml:"version,omitempty"`
	Framework         *FrameworkManifest            `protobuf:"bytes,3,opt,name=framework" json:"framework,omitempty" yaml:"framework,omitempty"`
	Container         map[string]*ContainerHardware `` /* 172-byte string literal not displayed */
	Description       string                        `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty" yaml:"description,omitempty"`
	Reference         []string                      `protobuf:"bytes,6,rep,name=reference" json:"reference,omitempty" yaml:"references,omitempty"`
	License           string                        `protobuf:"bytes,7,opt,name=license,proto3" json:"license,omitempty" yaml:"license,omitempty"`
	Inputs            []*ModelManifest_Type         `protobuf:"bytes,8,rep,name=inputs" json:"inputs,omitempty" yaml:"inputs,omitempty"`
	Output            *ModelManifest_Type           `protobuf:"bytes,9,opt,name=output" json:"output,omitempty" yaml:"output,omitempty"`
	BeforePreprocess  string                        `` /* 145-byte string literal not displayed */
	Preprocess        string                        `protobuf:"bytes,11,opt,name=preprocess,proto3" json:"preprocess,omitempty" yaml:"preprocess,omitempty"`
	AfterPreprocess   string                        `` /* 141-byte string literal not displayed */
	BeforePostprocess string                        `` /* 149-byte string literal not displayed */
	Postprocess       string                        `protobuf:"bytes,14,opt,name=postprocess,proto3" json:"postprocess,omitempty" yaml:"postprocess,omitempty"`
	AfterPostprocess  string                        `` /* 145-byte string literal not displayed */
	Model             *ModelManifest_Model          `protobuf:"bytes,16,opt,name=model" json:"model,omitempty" yaml:"model,omitempty"`
	Attributes        map[string]string             `` /* 183-byte string literal not displayed */
	Hidden            bool                          `protobuf:"varint,18,opt,name=hidden,proto3" json:"hidden,omitempty" yaml:"hidden,omitempty"`
}

func FindModel 

func FindModel(name string) (*ModelManifest, error)

func Models 

func Models() ([]ModelManifest, error)

func NewPopulatedModelManifest 

func NewPopulatedModelManifest(r randyRegistry, easy bool) *ModelManifest

func (ModelManifest) CanonicalName 

func (m ModelManifest) CanonicalName() (string, error)

func (*ModelManifest) Descriptor 

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

func (*ModelManifest) Equal 

func (this *ModelManifest) Equal(that interface{}) bool

func (ModelManifest) FrameworkConstraint 

func (m ModelManifest) FrameworkConstraint() (*semver.Constraints, error)

func (*ModelManifest) GetAfterPostprocess 

func (m *ModelManifest) GetAfterPostprocess() string

func (*ModelManifest) GetAfterPreprocess 

func (m *ModelManifest) GetAfterPreprocess() string

func (*ModelManifest) GetAttributes 

func (m *ModelManifest) GetAttributes() map[string]string

func (*ModelManifest) GetBeforePostprocess 

func (m *ModelManifest) GetBeforePostprocess() string

func (*ModelManifest) GetBeforePreprocess 

func (m *ModelManifest) GetBeforePreprocess() string

func (*ModelManifest) GetContainer 

func (m *ModelManifest) GetContainer() map[string]*ContainerHardware

func (*ModelManifest) GetDescription 

func (m *ModelManifest) GetDescription() string

func (*ModelManifest) GetFramework 

func (m *ModelManifest) GetFramework() *FrameworkManifest

func (*ModelManifest) GetHidden 

func (m *ModelManifest) GetHidden() bool

func (*ModelManifest) GetInputs 

func (m *ModelManifest) GetInputs() []*ModelManifest_Type

func (*ModelManifest) GetLicense 

func (m *ModelManifest) GetLicense() string

func (*ModelManifest) GetModel 

func (m *ModelManifest) GetModel() *ModelManifest_Model

func (*ModelManifest) GetName 

func (m *ModelManifest) GetName() string

func (*ModelManifest) GetOutput 

func (m *ModelManifest) GetOutput() *ModelManifest_Type

func (*ModelManifest) GetPostprocess 

func (m *ModelManifest) GetPostprocess() string

func (*ModelManifest) GetPreprocess 

func (m *ModelManifest) GetPreprocess() string

func (*ModelManifest) GetReference 

func (m *ModelManifest) GetReference() []string

func (*ModelManifest) GetVersion 

func (m *ModelManifest) GetVersion() string

func (*ModelManifest) GoString 

func (this *ModelManifest) GoString() string

func (*ModelManifest) Marshal 

func (m *ModelManifest) Marshal() (dAtA []byte, err error)

func (*ModelManifest) MarshalTo 

func (m *ModelManifest) MarshalTo(dAtA []byte) (int, error)

func (ModelManifest) MustCanonicalName 

func (m ModelManifest) MustCanonicalName() string

func (*ModelManifest) ProtoMessage 

func (*ModelManifest) ProtoMessage()

func (ModelManifest) Register 

func (m ModelManifest) Register() error

func (ModelManifest) RegisterNamed 

func (m ModelManifest) RegisterNamed(s string) error

func (*ModelManifest) Reset 

func (m *ModelManifest) Reset()

func (ModelManifest) ResolveFramework 

func (m ModelManifest) ResolveFramework() (FrameworkManifest, error)

func (*ModelManifest) Size 

func (m *ModelManifest) Size() (n int)

func (*ModelManifest) String 

func (this *ModelManifest) String() string

func (*ModelManifest) Unmarshal 

func (m *ModelManifest) Unmarshal(dAtA []byte) error

func (*ModelManifest) Validate 

func (m *ModelManifest) Validate() error

func (*ModelManifest) VerboseEqual 

func (this *ModelManifest) VerboseEqual(that interface{}) error

func (*ModelManifest) WorkDir 

func (m *ModelManifest) WorkDir() (string, error)

type ModelManifest_Model 

type ModelManifest_Model struct {
	BaseUrl         string `protobuf:"bytes,1,opt,name=base_url,json=baseUrl,proto3" json:"base_url,omitempty" yaml:"base_url,omitempty"`
	WeightsPath     string `protobuf:"bytes,2,opt,name=weights_path,json=weightsPath,proto3" json:"weights_path,omitempty" yaml:"weights_path,omitempty"`
	GraphPath       string `protobuf:"bytes,3,opt,name=graph_path,json=graphPath,proto3" json:"graph_path,omitempty" yaml:"graph_path,omitempty"`
	IsArchive       bool   `protobuf:"varint,4,opt,name=is_archive,json=isArchive,proto3" json:"is_archive,omitempty" yaml:"is_archive,omitempty"`
	WeightsChecksum string `` /* 140-byte string literal not displayed */
	GraphChecksum   string `` /* 132-byte string literal not displayed */
}

func NewPopulatedModelManifest_Model 

func NewPopulatedModelManifest_Model(r randyRegistry, easy bool) *ModelManifest_Model

func (*ModelManifest_Model) Descriptor 

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

func (*ModelManifest_Model) Equal 

func (this *ModelManifest_Model) Equal(that interface{}) bool

func (*ModelManifest_Model) GetBaseUrl 

func (m *ModelManifest_Model) GetBaseUrl() string

func (*ModelManifest_Model) GetGraphChecksum added in v0.2.19 

func (m *ModelManifest_Model) GetGraphChecksum() string

func (*ModelManifest_Model) GetGraphPath 

func (m *ModelManifest_Model) GetGraphPath() string

func (*ModelManifest_Model) GetIsArchive 

func (m *ModelManifest_Model) GetIsArchive() bool

func (*ModelManifest_Model) GetWeightsChecksum added in v0.2.19 

func (m *ModelManifest_Model) GetWeightsChecksum() string

func (*ModelManifest_Model) GetWeightsPath 

func (m *ModelManifest_Model) GetWeightsPath() string

func (*ModelManifest_Model) GoString 

func (this *ModelManifest_Model) GoString() string

func (*ModelManifest_Model) Marshal 

func (m *ModelManifest_Model) Marshal() (dAtA []byte, err error)

func (*ModelManifest_Model) MarshalTo 

func (m *ModelManifest_Model) MarshalTo(dAtA []byte) (int, error)

func (*ModelManifest_Model) ProtoMessage 

func (*ModelManifest_Model) ProtoMessage()

func (*ModelManifest_Model) Reset 

func (m *ModelManifest_Model) Reset()

func (*ModelManifest_Model) Size 

func (m *ModelManifest_Model) Size() (n int)

func (*ModelManifest_Model) String 

func (this *ModelManifest_Model) String() string

func (*ModelManifest_Model) Unmarshal 

func (m *ModelManifest_Model) Unmarshal(dAtA []byte) error

func (*ModelManifest_Model) VerboseEqual 

func (this *ModelManifest_Model) VerboseEqual(that interface{}) error

type ModelManifest_Type 

type ModelManifest_Type struct {
	Type        string                                   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty" yaml:"type,omitempty"`
	Description string                                   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty" yaml:"description,omitempty"`
	Parameters  map[string]*ModelManifest_Type_Parameter `` /* 175-byte string literal not displayed */
}

func NewPopulatedModelManifest_Type 

func NewPopulatedModelManifest_Type(r randyRegistry, easy bool) *ModelManifest_Type

func (*ModelManifest_Type) Descriptor 

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

func (*ModelManifest_Type) Equal 

func (this *ModelManifest_Type) Equal(that interface{}) bool

func (*ModelManifest_Type) GetDescription 

func (m *ModelManifest_Type) GetDescription() string

func (*ModelManifest_Type) GetParameters 

func (m *ModelManifest_Type) GetParameters() map[string]*ModelManifest_Type_Parameter

func (*ModelManifest_Type) GetType 

func (m *ModelManifest_Type) GetType() string

func (*ModelManifest_Type) GoString 

func (this *ModelManifest_Type) GoString() string

func (*ModelManifest_Type) Marshal 

func (m *ModelManifest_Type) Marshal() (dAtA []byte, err error)

func (*ModelManifest_Type) MarshalTo 

func (m *ModelManifest_Type) MarshalTo(dAtA []byte) (int, error)

func (*ModelManifest_Type) ProtoMessage 

func (*ModelManifest_Type) ProtoMessage()

func (*ModelManifest_Type) Reset 

func (m *ModelManifest_Type) Reset()

func (*ModelManifest_Type) Size 

func (m *ModelManifest_Type) Size() (n int)

func (*ModelManifest_Type) String 

func (this *ModelManifest_Type) String() string

func (*ModelManifest_Type) Unmarshal 

func (m *ModelManifest_Type) Unmarshal(dAtA []byte) error

func (*ModelManifest_Type) VerboseEqual 

func (this *ModelManifest_Type) VerboseEqual(that interface{}) error

type ModelManifest_Type_Parameter 

type ModelManifest_Type_Parameter struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty" yaml:",inline"`
}

func NewPopulatedModelManifest_Type_Parameter 

func NewPopulatedModelManifest_Type_Parameter(r randyRegistry, easy bool) *ModelManifest_Type_Parameter

func (*ModelManifest_Type_Parameter) Descriptor 

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

func (*ModelManifest_Type_Parameter) Equal 

func (this *ModelManifest_Type_Parameter) Equal(that interface{}) bool

func (*ModelManifest_Type_Parameter) GetValue 

func (m *ModelManifest_Type_Parameter) GetValue() string

func (*ModelManifest_Type_Parameter) GoString 

func (this *ModelManifest_Type_Parameter) GoString() string

func (*ModelManifest_Type_Parameter) Marshal 

func (m *ModelManifest_Type_Parameter) Marshal() (dAtA []byte, err error)

func (*ModelManifest_Type_Parameter) MarshalTo 

func (m *ModelManifest_Type_Parameter) MarshalTo(dAtA []byte) (int, error)

func (*ModelManifest_Type_Parameter) MarshalYAML 

func (param *ModelManifest_Type_Parameter) MarshalYAML() (interface{}, error)

func (*ModelManifest_Type_Parameter) ProtoMessage 

func (*ModelManifest_Type_Parameter) ProtoMessage()

func (*ModelManifest_Type_Parameter) Reset 

func (m *ModelManifest_Type_Parameter) Reset()

func (*ModelManifest_Type_Parameter) Size 

func (m *ModelManifest_Type_Parameter) Size() (n int)

func (*ModelManifest_Type_Parameter) String 

func (this *ModelManifest_Type_Parameter) String() string

func (*ModelManifest_Type_Parameter) Unmarshal 

func (m *ModelManifest_Type_Parameter) Unmarshal(dAtA []byte) error

func (*ModelManifest_Type_Parameter) UnmarshalYAML 

func (param *ModelManifest_Type_Parameter) UnmarshalYAML(unmarshal func(interface{}) error) error

func (*ModelManifest_Type_Parameter) VerboseEqual 

func (this *ModelManifest_Type_Parameter) VerboseEqual(that interface{}) error

type ModelManifestsResponse 

type ModelManifestsResponse struct {
	Manifests []*ModelManifest `protobuf:"bytes,1,rep,name=manifests" json:"manifests,omitempty" yaml:"manifests,omitempty"`
}

func NewPopulatedModelManifestsResponse 

func NewPopulatedModelManifestsResponse(r randyRegistry, easy bool) *ModelManifestsResponse

func (*ModelManifestsResponse) Description added in v0.2.16 

func (this *ModelManifestsResponse) Description() (desc *descriptor.FileDescriptorSet)

func (*ModelManifestsResponse) Descriptor 

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

func (*ModelManifestsResponse) Equal 

func (this *ModelManifestsResponse) Equal(that interface{}) bool

func (*ModelManifestsResponse) GetManifests 

func (m *ModelManifestsResponse) GetManifests() []*ModelManifest

func (*ModelManifestsResponse) GoString 

func (this *ModelManifestsResponse) GoString() string

func (*ModelManifestsResponse) Marshal 

func (m *ModelManifestsResponse) Marshal() (dAtA []byte, err error)

func (*ModelManifestsResponse) MarshalTo 

func (m *ModelManifestsResponse) MarshalTo(dAtA []byte) (int, error)

func (*ModelManifestsResponse) ProtoMessage 

func (*ModelManifestsResponse) ProtoMessage()

func (*ModelManifestsResponse) Reset 

func (m *ModelManifestsResponse) Reset()

func (*ModelManifestsResponse) Size 

func (m *ModelManifestsResponse) Size() (n int)

func (*ModelManifestsResponse) String 

func (this *ModelManifestsResponse) String() string

func (*ModelManifestsResponse) Unmarshal 

func (m *ModelManifestsResponse) Unmarshal(dAtA []byte) error

func (*ModelManifestsResponse) VerboseEqual 

func (this *ModelManifestsResponse) VerboseEqual(that interface{}) error

type ModelRequest 

type ModelRequest struct {
	FrameworkName    string `` /* 132-byte string literal not displayed */
	FrameworkVersion string `` /* 144-byte string literal not displayed */
	ModelName        string `protobuf:"bytes,3,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty" yaml:"model_name,omitempty"`
	ModelVersion     string `` /* 128-byte string literal not displayed */
}

func NewPopulatedModelRequest 

func NewPopulatedModelRequest(r randyRegistry, easy bool) *ModelRequest

func (*ModelRequest) Description added in v0.2.16 

func (this *ModelRequest) Description() (desc *descriptor.FileDescriptorSet)

func (*ModelRequest) Descriptor 

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

func (*ModelRequest) Equal 

func (this *ModelRequest) Equal(that interface{}) bool

func (*ModelRequest) GetFrameworkName 

func (m *ModelRequest) GetFrameworkName() string

func (*ModelRequest) GetFrameworkVersion 

func (m *ModelRequest) GetFrameworkVersion() string

func (*ModelRequest) GetModelName 

func (m *ModelRequest) GetModelName() string

func (*ModelRequest) GetModelVersion 

func (m *ModelRequest) GetModelVersion() string

func (*ModelRequest) GoString 

func (this *ModelRequest) GoString() string

func (*ModelRequest) Marshal 

func (m *ModelRequest) Marshal() (dAtA []byte, err error)

func (*ModelRequest) MarshalTo 

func (m *ModelRequest) MarshalTo(dAtA []byte) (int, error)

func (*ModelRequest) ProtoMessage 

func (*ModelRequest) ProtoMessage()

func (*ModelRequest) Reset 

func (m *ModelRequest) Reset()

func (*ModelRequest) Size 

func (m *ModelRequest) Size() (n int)

func (*ModelRequest) String 

func (this *ModelRequest) String() string

func (*ModelRequest) Unmarshal 

func (m *ModelRequest) Unmarshal(dAtA []byte) error

func (*ModelRequest) VerboseEqual 

func (this *ModelRequest) VerboseEqual(that interface{}) error

type PredictClient added in v0.2.16 

type PredictClient interface {
	// Opens a predictor and returns an id where the predictor
	// is accessible. The id can be used to perform inference
	// requests.
	Open(ctx context.Context, in *PredictorOpenRequest, opts ...grpc.CallOption) (*Predictor, error)
	// Close a predictor clear it's memory.
	Close(ctx context.Context, in *Predictor, opts ...grpc.CallOption) (*PredictorCloseResponse, error)
	// Image method receives a stream of urls and runs
	// the predictor on all the urls. The
	//
	// The result is a prediction feature stream for each url.
	URLs(ctx context.Context, in *URLsRequest, opts ...grpc.CallOption) (*FeaturesResponse, error)
	// Image method receives a stream of urls and runs
	// the predictor on all the urls. The
	//
	// The result is a prediction feature stream for each url.
	URLsStream(ctx context.Context, in *URLsRequest, opts ...grpc.CallOption) (Predict_URLsStreamClient, error)
	// Image method receives a list base64 encoded images and runs
	// the predictor on all the images.
	//
	// The result is a prediction feature list for each image.
	Images(ctx context.Context, in *ImagesRequest, opts ...grpc.CallOption) (*FeaturesResponse, error)
	// Image method receives a list base64 encoded images and runs
	// the predictor on all the images.
	//
	// The result is a prediction feature stream for each image.
	ImagesStream(ctx context.Context, in *ImagesRequest, opts ...grpc.CallOption) (Predict_ImagesStreamClient, error)
	// Dataset method receives a single dataset and runs
	// the predictor on all elements of the dataset.
	//
	// The result is a prediction feature list.
	Dataset(ctx context.Context, in *DatasetRequest, opts ...grpc.CallOption) (*FeaturesResponse, error)
	// Dataset method receives a single dataset and runs
	// the predictor on all elements of the dataset.
	//
	// The result is a prediction feature stream.
	DatasetStream(ctx context.Context, in *DatasetRequest, opts ...grpc.CallOption) (Predict_DatasetStreamClient, error)
	// Clear method clears the internal cache of the predictors
	Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*ResetResponse, error)
}

func NewPredictClient added in v0.2.16 

func NewPredictClient(cc *grpc.ClientConn) PredictClient

type PredictServer added in v0.2.16 

type PredictServer interface {
	// Opens a predictor and returns an id where the predictor
	// is accessible. The id can be used to perform inference
	// requests.
	Open(context.Context, *PredictorOpenRequest) (*Predictor, error)
	// Close a predictor clear it's memory.
	Close(context.Context, *Predictor) (*PredictorCloseResponse, error)
	// Image method receives a stream of urls and runs
	// the predictor on all the urls. The
	//
	// The result is a prediction feature stream for each url.
	URLs(context.Context, *URLsRequest) (*FeaturesResponse, error)
	// Image method receives a stream of urls and runs
	// the predictor on all the urls. The
	//
	// The result is a prediction feature stream for each url.
	URLsStream(*URLsRequest, Predict_URLsStreamServer) error
	// Image method receives a list base64 encoded images and runs
	// the predictor on all the images.
	//
	// The result is a prediction feature list for each image.
	Images(context.Context, *ImagesRequest) (*FeaturesResponse, error)
	// Image method receives a list base64 encoded images and runs
	// the predictor on all the images.
	//
	// The result is a prediction feature stream for each image.
	ImagesStream(*ImagesRequest, Predict_ImagesStreamServer) error
	// Dataset method receives a single dataset and runs
	// the predictor on all elements of the dataset.
	//
	// The result is a prediction feature list.
	Dataset(context.Context, *DatasetRequest) (*FeaturesResponse, error)
	// Dataset method receives a single dataset and runs
	// the predictor on all elements of the dataset.
	//
	// The result is a prediction feature stream.
	DatasetStream(*DatasetRequest, Predict_DatasetStreamServer) error
	// Clear method clears the internal cache of the predictors
	Reset(context.Context, *ResetRequest) (*ResetResponse, error)
}

type Predict_DatasetStreamClient added in v0.2.16 

type Predict_DatasetStreamClient interface {
	Recv() (*FeatureResponse, error)
	grpc.ClientStream
}

type Predict_DatasetStreamServer added in v0.2.16 

type Predict_DatasetStreamServer interface {
	Send(*FeatureResponse) error
	grpc.ServerStream
}

type Predict_ImagesStreamClient added in v0.2.16 

type Predict_ImagesStreamClient interface {
	Recv() (*FeatureResponse, error)
	grpc.ClientStream
}

type Predict_ImagesStreamServer added in v0.2.16 

type Predict_ImagesStreamServer interface {
	Send(*FeatureResponse) error
	grpc.ServerStream
}

type Predict_URLsStreamClient added in v0.2.16 

type Predict_URLsStreamClient interface {
	Recv() (*FeatureResponse, error)
	grpc.ClientStream
}

type Predict_URLsStreamServer added in v0.2.16 

type Predict_URLsStreamServer interface {
	Send(*FeatureResponse) error
	grpc.ServerStream
}

type PredictionOptions added in v0.2.16 

type PredictionOptions struct {
	RequestID        string            `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty" yaml:"request_id,omitempty"`
	FeatureLimit     int32             `` /* 129-byte string literal not displayed */
	BatchSize        uint32            `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty" yaml:"batch_size,omitempty"`
	ExecutionOptions *ExecutionOptions `` /* 137-byte string literal not displayed */
	Agent            string            `protobuf:"bytes,5,opt,name=agent,proto3" json:"agent,omitempty" yaml:"agent,omitempty"`
}

func NewPopulatedPredictionOptions added in v0.2.16 

func NewPopulatedPredictionOptions(r randyPredictor, easy bool) *PredictionOptions

func (*PredictionOptions) Description added in v0.2.16 

func (this *PredictionOptions) Description() (desc *descriptor.FileDescriptorSet)

func (*PredictionOptions) Descriptor added in v0.2.16 

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

func (*PredictionOptions) Equal added in v0.2.16 

func (this *PredictionOptions) Equal(that interface{}) bool

func (*PredictionOptions) GetAgent added in v0.2.19 

func (m *PredictionOptions) GetAgent() string

func (*PredictionOptions) GetBatchSize added in v0.2.19 

func (m *PredictionOptions) GetBatchSize() uint32

func (*PredictionOptions) GetExecutionOptions added in v0.2.19 

func (m *PredictionOptions) GetExecutionOptions() *ExecutionOptions

func (*PredictionOptions) GetFeatureLimit added in v0.2.16 

func (m *PredictionOptions) GetFeatureLimit() int32

func (*PredictionOptions) GetRequestID added in v0.2.16 

func (m *PredictionOptions) GetRequestID() string

func (*PredictionOptions) GoString added in v0.2.16 

func (this *PredictionOptions) GoString() string

func (*PredictionOptions) Marshal added in v0.2.16 

func (m *PredictionOptions) Marshal() (dAtA []byte, err error)

func (*PredictionOptions) MarshalTo added in v0.2.16 

func (m *PredictionOptions) MarshalTo(dAtA []byte) (int, error)

func (*PredictionOptions) ProtoMessage added in v0.2.16 

func (*PredictionOptions) ProtoMessage()

func (*PredictionOptions) Reset added in v0.2.16 

func (m *PredictionOptions) Reset()

func (*PredictionOptions) Size added in v0.2.16 

func (m *PredictionOptions) Size() (n int)

func (*PredictionOptions) String added in v0.2.16 

func (this *PredictionOptions) String() string

func (*PredictionOptions) Unmarshal added in v0.2.16 

func (m *PredictionOptions) Unmarshal(dAtA []byte) error

func (*PredictionOptions) VerboseEqual added in v0.2.16 

func (this *PredictionOptions) VerboseEqual(that interface{}) error

type Predictor added in v0.2.16 

type Predictor struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
}

func NewPopulatedPredictor added in v0.2.16 

func NewPopulatedPredictor(r randyPredictor, easy bool) *Predictor

func (*Predictor) Description added in v0.2.16 

func (this *Predictor) Description() (desc *descriptor.FileDescriptorSet)

func (*Predictor) Descriptor added in v0.2.16 

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

func (*Predictor) Equal added in v0.2.16 

func (this *Predictor) Equal(that interface{}) bool

func (*Predictor) GetID added in v0.2.16 

func (m *Predictor) GetID() string

func (*Predictor) GoString added in v0.2.16 

func (this *Predictor) GoString() string

func (*Predictor) Marshal added in v0.2.16 

func (m *Predictor) Marshal() (dAtA []byte, err error)

func (*Predictor) MarshalTo added in v0.2.16 

func (m *Predictor) MarshalTo(dAtA []byte) (int, error)

func (*Predictor) ProtoMessage added in v0.2.16 

func (*Predictor) ProtoMessage()

func (*Predictor) Reset added in v0.2.16 

func (m *Predictor) Reset()

func (*Predictor) Size added in v0.2.16 

func (m *Predictor) Size() (n int)

func (*Predictor) String added in v0.2.16 

func (this *Predictor) String() string

func (*Predictor) Unmarshal added in v0.2.16 

func (m *Predictor) Unmarshal(dAtA []byte) error

func (*Predictor) VerboseEqual added in v0.2.16 

func (this *Predictor) VerboseEqual(that interface{}) error

type PredictorCloseResponse added in v0.2.16 

type PredictorCloseResponse struct {
}

func NewPopulatedPredictorCloseResponse added in v0.2.16 

func NewPopulatedPredictorCloseResponse(r randyPredictor, easy bool) *PredictorCloseResponse

func (*PredictorCloseResponse) Descriptor added in v0.2.16 

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

func (*PredictorCloseResponse) Equal added in v0.2.16 

func (this *PredictorCloseResponse) Equal(that interface{}) bool

func (*PredictorCloseResponse) GoString added in v0.2.16 

func (this *PredictorCloseResponse) GoString() string

func (*PredictorCloseResponse) Marshal added in v0.2.16 

func (m *PredictorCloseResponse) Marshal() (dAtA []byte, err error)

func (*PredictorCloseResponse) MarshalTo added in v0.2.16 

func (m *PredictorCloseResponse) MarshalTo(dAtA []byte) (int, error)

func (*PredictorCloseResponse) ProtoMessage added in v0.2.16 

func (*PredictorCloseResponse) ProtoMessage()

func (*PredictorCloseResponse) Reset added in v0.2.16 

func (m *PredictorCloseResponse) Reset()

func (*PredictorCloseResponse) Size added in v0.2.16 

func (m *PredictorCloseResponse) Size() (n int)

func (*PredictorCloseResponse) String added in v0.2.16 

func (this *PredictorCloseResponse) String() string

func (*PredictorCloseResponse) Unmarshal added in v0.2.16 

func (m *PredictorCloseResponse) Unmarshal(dAtA []byte) error

func (*PredictorCloseResponse) VerboseEqual added in v0.2.16 

func (this *PredictorCloseResponse) VerboseEqual(that interface{}) error

type PredictorOpenRequest added in v0.2.16 

type PredictorOpenRequest struct {
	ModelName        string             `protobuf:"bytes,1,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty" yaml:"model_name,omitempty"`
	ModelVersion     string             `` /* 128-byte string literal not displayed */
	FrameworkName    string             `` /* 132-byte string literal not displayed */
	FrameworkVersion string             `` /* 144-byte string literal not displayed */
	Options          *PredictionOptions `protobuf:"bytes,5,opt,name=options" json:"options,omitempty" yaml:"options,omitempty"`
}

func NewPopulatedPredictorOpenRequest added in v0.2.16 

func NewPopulatedPredictorOpenRequest(r randyPredictor, easy bool) *PredictorOpenRequest

func (*PredictorOpenRequest) Description added in v0.2.16 

func (this *PredictorOpenRequest) Description() (desc *descriptor.FileDescriptorSet)

func (*PredictorOpenRequest) Descriptor added in v0.2.16 

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

func (*PredictorOpenRequest) Equal added in v0.2.16 

func (this *PredictorOpenRequest) Equal(that interface{}) bool

func (*PredictorOpenRequest) GetFrameworkName added in v0.2.16 

func (m *PredictorOpenRequest) GetFrameworkName() string

func (*PredictorOpenRequest) GetFrameworkVersion added in v0.2.16 

func (m *PredictorOpenRequest) GetFrameworkVersion() string

func (*PredictorOpenRequest) GetModelName added in v0.2.16 

func (m *PredictorOpenRequest) GetModelName() string

func (*PredictorOpenRequest) GetModelVersion added in v0.2.16 

func (m *PredictorOpenRequest) GetModelVersion() string

func (*PredictorOpenRequest) GetOptions added in v0.2.19 

func (m *PredictorOpenRequest) GetOptions() *PredictionOptions

func (*PredictorOpenRequest) GoString added in v0.2.16 

func (this *PredictorOpenRequest) GoString() string

func (*PredictorOpenRequest) Marshal added in v0.2.16 

func (m *PredictorOpenRequest) Marshal() (dAtA []byte, err error)

func (*PredictorOpenRequest) MarshalTo added in v0.2.16 

func (m *PredictorOpenRequest) MarshalTo(dAtA []byte) (int, error)

func (*PredictorOpenRequest) ProtoMessage added in v0.2.16 

func (*PredictorOpenRequest) ProtoMessage()

func (*PredictorOpenRequest) Reset added in v0.2.16 

func (m *PredictorOpenRequest) Reset()

func (*PredictorOpenRequest) Size added in v0.2.16 

func (m *PredictorOpenRequest) Size() (n int)

func (*PredictorOpenRequest) String added in v0.2.16 

func (this *PredictorOpenRequest) String() string

func (*PredictorOpenRequest) Unmarshal added in v0.2.16 

func (m *PredictorOpenRequest) Unmarshal(dAtA []byte) error

func (*PredictorOpenRequest) VerboseEqual added in v0.2.16 

func (this *PredictorOpenRequest) VerboseEqual(that interface{}) error

type RegistryClient 

type RegistryClient interface {
	FrameworkManifests(ctx context.Context, in *FrameworkRequest, opts ...grpc.CallOption) (*FrameworkManifestsResponse, error)
	FrameworkAgents(ctx context.Context, in *FrameworkRequest, opts ...grpc.CallOption) (*Agents, error)
	ModelManifests(ctx context.Context, in *ModelRequest, opts ...grpc.CallOption) (*ModelManifestsResponse, error)
	ModelAgents(ctx context.Context, in *ModelRequest, opts ...grpc.CallOption) (*Agents, error)
}

func NewRegistryClient 

func NewRegistryClient(cc *grpc.ClientConn) RegistryClient

type RegistryServer 

type RegistryServer interface {
	FrameworkManifests(context.Context, *FrameworkRequest) (*FrameworkManifestsResponse, error)
	FrameworkAgents(context.Context, *FrameworkRequest) (*Agents, error)
	ModelManifests(context.Context, *ModelRequest) (*ModelManifestsResponse, error)
	ModelAgents(context.Context, *ModelRequest) (*Agents, error)
}

type ResetRequest added in v0.2.16 

type ResetRequest struct {
	ID        string     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	Predictor *Predictor `protobuf:"bytes,1,opt,name=predictor" json:"predictor,omitempty" yaml:"predictor,omitempty"`
}

func NewPopulatedResetRequest added in v0.2.16 

func NewPopulatedResetRequest(r randyPredictor, easy bool) *ResetRequest

func (*ResetRequest) Description added in v0.2.16 

func (this *ResetRequest) Description() (desc *descriptor.FileDescriptorSet)

func (*ResetRequest) Descriptor added in v0.2.16 

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

func (*ResetRequest) Equal added in v0.2.16 

func (this *ResetRequest) Equal(that interface{}) bool

func (*ResetRequest) GetID added in v0.2.16 

func (m *ResetRequest) GetID() string

func (*ResetRequest) GetPredictor added in v0.2.16 

func (m *ResetRequest) GetPredictor() *Predictor

func (*ResetRequest) GoString added in v0.2.16 

func (this *ResetRequest) GoString() string

func (*ResetRequest) Marshal added in v0.2.16 

func (m *ResetRequest) Marshal() (dAtA []byte, err error)

func (*ResetRequest) MarshalTo added in v0.2.16 

func (m *ResetRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResetRequest) ProtoMessage added in v0.2.16 

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) Reset added in v0.2.16 

func (m *ResetRequest) Reset()

func (*ResetRequest) Size added in v0.2.16 

func (m *ResetRequest) Size() (n int)

func (*ResetRequest) String added in v0.2.16 

func (this *ResetRequest) String() string

func (*ResetRequest) Unmarshal added in v0.2.16 

func (m *ResetRequest) Unmarshal(dAtA []byte) error

func (*ResetRequest) VerboseEqual added in v0.2.16 

func (this *ResetRequest) VerboseEqual(that interface{}) error

type ResetResponse added in v0.2.16 

type ResetResponse struct {
	*Predictor `protobuf:"bytes,1,opt,name=predictor,embedded=predictor" json:"predictor,omitempty" yaml:"predictor,omitempty"`
}

func NewPopulatedResetResponse added in v0.2.16 

func NewPopulatedResetResponse(r randyPredictor, easy bool) *ResetResponse

func (*ResetResponse) Description added in v0.2.16 

func (this *ResetResponse) Description() (desc *descriptor.FileDescriptorSet)

func (*ResetResponse) Descriptor added in v0.2.16 

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

func (*ResetResponse) Equal added in v0.2.16 

func (this *ResetResponse) Equal(that interface{}) bool

func (*ResetResponse) GoString added in v0.2.16 

func (this *ResetResponse) GoString() string

func (*ResetResponse) Marshal added in v0.2.16 

func (m *ResetResponse) Marshal() (dAtA []byte, err error)

func (*ResetResponse) MarshalTo added in v0.2.16 

func (m *ResetResponse) MarshalTo(dAtA []byte) (int, error)

func (*ResetResponse) ProtoMessage added in v0.2.16 

func (*ResetResponse) ProtoMessage()

func (*ResetResponse) Reset added in v0.2.16 

func (m *ResetResponse) Reset()

func (*ResetResponse) Size added in v0.2.16 

func (m *ResetResponse) Size() (n int)

func (*ResetResponse) String added in v0.2.16 

func (this *ResetResponse) String() string

func (*ResetResponse) Unmarshal added in v0.2.16 

func (m *ResetResponse) Unmarshal(dAtA []byte) error

func (*ResetResponse) VerboseEqual added in v0.2.16 

func (this *ResetResponse) VerboseEqual(that interface{}) error

type URLsRequest added in v0.2.16 

type URLsRequest struct {
	Predictor *Predictor         `protobuf:"bytes,1,opt,name=predictor" json:"predictor,omitempty" yaml:"predictor,omitempty"`
	Urls      []*URLsRequest_URL `protobuf:"bytes,2,rep,name=urls" json:"urls,omitempty" yaml:"urls,omitempty"`
	Options   *PredictionOptions `protobuf:"bytes,3,opt,name=options" json:"options,omitempty" yaml:"options,omitempty"`
}

func NewPopulatedURLsRequest added in v0.2.16 

func NewPopulatedURLsRequest(r randyPredictor, easy bool) *URLsRequest

func (*URLsRequest) Description added in v0.2.16 

func (this *URLsRequest) Description() (desc *descriptor.FileDescriptorSet)

func (*URLsRequest) Descriptor added in v0.2.16 

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

func (*URLsRequest) Equal added in v0.2.16 

func (this *URLsRequest) Equal(that interface{}) bool

func (*URLsRequest) GetOptions added in v0.2.16 

func (m *URLsRequest) GetOptions() *PredictionOptions

func (*URLsRequest) GetPredictor added in v0.2.16 

func (m *URLsRequest) GetPredictor() *Predictor

func (*URLsRequest) GetUrls added in v0.2.16 

func (m *URLsRequest) GetUrls() []*URLsRequest_URL

func (*URLsRequest) GoString added in v0.2.16 

func (this *URLsRequest) GoString() string

func (*URLsRequest) Marshal added in v0.2.16 

func (m *URLsRequest) Marshal() (dAtA []byte, err error)

func (*URLsRequest) MarshalTo added in v0.2.16 

func (m *URLsRequest) MarshalTo(dAtA []byte) (int, error)

func (*URLsRequest) ProtoMessage added in v0.2.16 

func (*URLsRequest) ProtoMessage()

func (*URLsRequest) Reset added in v0.2.16 

func (m *URLsRequest) Reset()

func (*URLsRequest) Size added in v0.2.16 

func (m *URLsRequest) Size() (n int)

func (*URLsRequest) String added in v0.2.16 

func (this *URLsRequest) String() string

func (*URLsRequest) Unmarshal added in v0.2.16 

func (m *URLsRequest) Unmarshal(dAtA []byte) error

func (*URLsRequest) VerboseEqual added in v0.2.16 

func (this *URLsRequest) VerboseEqual(that interface{}) error

type URLsRequest_URL added in v0.2.16 

type URLsRequest_URL struct {
	// An id used to identify the output feature: maps to input_id for output
	ID   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty" yaml:"data,omitempty"`
}

func NewPopulatedURLsRequest_URL added in v0.2.16 

func NewPopulatedURLsRequest_URL(r randyPredictor, easy bool) *URLsRequest_URL

func (*URLsRequest_URL) Descriptor added in v0.2.16 

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

func (*URLsRequest_URL) Equal added in v0.2.16 

func (this *URLsRequest_URL) Equal(that interface{}) bool

func (*URLsRequest_URL) GetData added in v0.2.16 

func (m *URLsRequest_URL) GetData() string

func (*URLsRequest_URL) GetID added in v0.2.16 

func (m *URLsRequest_URL) GetID() string

func (*URLsRequest_URL) GoString added in v0.2.16 

func (this *URLsRequest_URL) GoString() string

func (*URLsRequest_URL) Marshal added in v0.2.16 

func (m *URLsRequest_URL) Marshal() (dAtA []byte, err error)

func (*URLsRequest_URL) MarshalTo added in v0.2.16 

func (m *URLsRequest_URL) MarshalTo(dAtA []byte) (int, error)

func (*URLsRequest_URL) ProtoMessage added in v0.2.16 

func (*URLsRequest_URL) ProtoMessage()

func (*URLsRequest_URL) Reset added in v0.2.16 

func (m *URLsRequest_URL) Reset()

func (*URLsRequest_URL) Size added in v0.2.16 

func (m *URLsRequest_URL) Size() (n int)

func (*URLsRequest_URL) String added in v0.2.16 

func (this *URLsRequest_URL) String() string

func (*URLsRequest_URL) Unmarshal added in v0.2.16 

func (m *URLsRequest_URL) Unmarshal(dAtA []byte) error

func (*URLsRequest_URL) VerboseEqual added in v0.2.16 

func (this *URLsRequest_URL) VerboseEqual(that interface{}) error

Source Files

View all Source files

Directories

Path Synopsis
agent
cmd
cmd/client
cmd/client/run
cmd/server
cmd/standalone
options
predict
httpapi
client
client/predict
client/registry
cmd/dlframework-server
models
restapi
Package restapi CarML DLFramework CarML (Cognitive ARtifacts for Machine Learning) is a framework allowing people to develop and deploy machine learning models.
 Package restapi CarML DLFramework CarML (Cognitive ARtifacts for Machine Learning) is a framework allowing people to develop and deploy machine learning models.
restapi/operations
restapi/operations/predict
restapi/operations/registry

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.