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
- Variables
- func Bhattacharyya(p, q []float64) float64
- func Correlation(x, y, weights []float64) float64
- func Covariance(x, y, weights []float64) float64
- func Hellinger(p, q []float64) float64
- func JensenShannon(p, q []float64) float64
- func KullbackLeibler(p, q []float64) float64
- func Mean(x, weights []float64) float64
- func PredictorDescription() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func RegisterPredictHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterPredictHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterPredictServer(s *grpc.Server, srv PredictServer)
- func RegisterRegistryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterRegistryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)
- func RegisteredFrameworkNames() []string
- func RegisteredModelNames() []string
- func RegistryDescription() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func Sum(s []float64) float64
- type Agent
- func (this *Agent) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*Agent) Descriptor() ([]byte, []int)
- func (this *Agent) Equal(that interface{}) bool
- func (m *Agent) GetArchitecture() string
- func (m *Agent) GetCpuinfo() string
- func (m *Agent) GetFrameworks() []*FrameworkManifest
- func (m *Agent) GetGpuinfo() string
- func (m *Agent) GetHasgpu() bool
- func (m *Agent) GetHost() string
- func (m *Agent) GetHostname() string
- func (m *Agent) GetMetadata() map[string]string
- func (m *Agent) GetPort() string
- func (this *Agent) GoString() string
- func (m *Agent) Marshal() (dAtA []byte, err error)
- func (m *Agent) MarshalTo(dAtA []byte) (int, error)
- func (*Agent) ProtoMessage()
- func (m *Agent) Reset()
- func (m *Agent) Size() (n int)
- func (this *Agent) String() string
- func (m *Agent) Unmarshal(dAtA []byte) error
- func (this *Agent) VerboseEqual(that interface{}) error
- type Agents
- func (this *Agents) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*Agents) Descriptor() ([]byte, []int)
- func (this *Agents) Equal(that interface{}) bool
- func (m *Agents) GetAgents() []*Agent
- func (this *Agents) GoString() string
- func (m *Agents) Marshal() (dAtA []byte, err error)
- func (m *Agents) MarshalTo(dAtA []byte) (int, error)
- func (*Agents) ProtoMessage()
- func (m *Agents) Reset()
- func (m *Agents) Size() (n int)
- func (this *Agents) String() string
- func (m *Agents) Unmarshal(dAtA []byte) error
- func (this *Agents) VerboseEqual(that interface{}) error
- type CPUOptions
- func (*CPUOptions) Descriptor() ([]byte, []int)
- func (this *CPUOptions) Equal(that interface{}) bool
- func (this *CPUOptions) GoString() string
- func (m *CPUOptions) Marshal() (dAtA []byte, err error)
- func (m *CPUOptions) MarshalTo(dAtA []byte) (int, error)
- func (*CPUOptions) ProtoMessage()
- func (m *CPUOptions) Reset()
- func (m *CPUOptions) Size() (n int)
- func (this *CPUOptions) String() string
- func (m *CPUOptions) Unmarshal(dAtA []byte) error
- func (this *CPUOptions) VerboseEqual(that interface{}) error
- type ContainerHardware
- func (this *ContainerHardware) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*ContainerHardware) Descriptor() ([]byte, []int)
- func (this *ContainerHardware) Equal(that interface{}) bool
- func (m *ContainerHardware) GetCpu() string
- func (m *ContainerHardware) GetGpu() string
- func (this *ContainerHardware) GoString() string
- func (m *ContainerHardware) Marshal() (dAtA []byte, err error)
- func (m *ContainerHardware) MarshalTo(dAtA []byte) (int, error)
- func (*ContainerHardware) ProtoMessage()
- func (m *ContainerHardware) Reset()
- func (m *ContainerHardware) Size() (n int)
- func (this *ContainerHardware) String() string
- func (m *ContainerHardware) Unmarshal(dAtA []byte) error
- func (this *ContainerHardware) VerboseEqual(that interface{}) error
- type DatasetRequest
- func (this *DatasetRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*DatasetRequest) Descriptor() ([]byte, []int)
- func (this *DatasetRequest) Equal(that interface{}) bool
- func (m *DatasetRequest) GetDataset() *DatasetRequest_Dataset
- func (m *DatasetRequest) GetOptions() *PredictionOptions
- func (m *DatasetRequest) GetPredictor() *Predictor
- func (this *DatasetRequest) GoString() string
- func (m *DatasetRequest) Marshal() (dAtA []byte, err error)
- func (m *DatasetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*DatasetRequest) ProtoMessage()
- func (m *DatasetRequest) Reset()
- func (m *DatasetRequest) Size() (n int)
- func (this *DatasetRequest) String() string
- func (m *DatasetRequest) Unmarshal(dAtA []byte) error
- func (this *DatasetRequest) VerboseEqual(that interface{}) error
- type DatasetRequest_Dataset
- func (*DatasetRequest_Dataset) Descriptor() ([]byte, []int)
- func (this *DatasetRequest_Dataset) Equal(that interface{}) bool
- func (m *DatasetRequest_Dataset) GetCategory() string
- func (m *DatasetRequest_Dataset) GetName() string
- func (this *DatasetRequest_Dataset) GoString() string
- func (m *DatasetRequest_Dataset) Marshal() (dAtA []byte, err error)
- func (m *DatasetRequest_Dataset) MarshalTo(dAtA []byte) (int, error)
- func (*DatasetRequest_Dataset) ProtoMessage()
- func (m *DatasetRequest_Dataset) Reset()
- func (m *DatasetRequest_Dataset) Size() (n int)
- func (this *DatasetRequest_Dataset) String() string
- func (m *DatasetRequest_Dataset) Unmarshal(dAtA []byte) error
- func (this *DatasetRequest_Dataset) VerboseEqual(that interface{}) error
- type ErrorStatus
- func (this *ErrorStatus) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*ErrorStatus) Descriptor() ([]byte, []int)
- func (this *ErrorStatus) Equal(that interface{}) bool
- func (m *ErrorStatus) GetMessage() string
- func (m *ErrorStatus) GetOk() bool
- func (this *ErrorStatus) GoString() string
- func (m *ErrorStatus) Marshal() (dAtA []byte, err error)
- func (m *ErrorStatus) MarshalTo(dAtA []byte) (int, error)
- func (*ErrorStatus) ProtoMessage()
- func (m *ErrorStatus) Reset()
- func (m *ErrorStatus) Size() (n int)
- func (this *ErrorStatus) String() string
- func (m *ErrorStatus) Unmarshal(dAtA []byte) error
- func (this *ErrorStatus) VerboseEqual(that interface{}) error
- type ExecutionOptions
- func (*ExecutionOptions) Descriptor() ([]byte, []int)
- func (this *ExecutionOptions) Equal(that interface{}) bool
- func (m *ExecutionOptions) GetCpuOptions() *CPUOptions
- func (m *ExecutionOptions) GetDeviceCount() map[string]int32
- func (m *ExecutionOptions) GetGpuOptions() *GPUOptions
- func (m *ExecutionOptions) GetTimeoutInMs() int64
- func (m *ExecutionOptions) GetTraceLevel() ExecutionOptions_TraceLevel
- func (this *ExecutionOptions) GoString() string
- func (m *ExecutionOptions) Marshal() (dAtA []byte, err error)
- func (m *ExecutionOptions) MarshalTo(dAtA []byte) (int, error)
- func (*ExecutionOptions) ProtoMessage()
- func (m *ExecutionOptions) Reset()
- func (m *ExecutionOptions) Size() (n int)
- func (this *ExecutionOptions) String() string
- func (m *ExecutionOptions) Unmarshal(dAtA []byte) error
- func (this *ExecutionOptions) VerboseEqual(that interface{}) error
- type ExecutionOptions_TraceLevel
- type Feature
- func (this *Feature) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*Feature) Descriptor() ([]byte, []int)
- func (this *Feature) Equal(that interface{}) bool
- func (m *Feature) GetIndex() int64
- func (m *Feature) GetMetadata() map[string]string
- func (m *Feature) GetName() string
- func (m *Feature) GetProbability() float32
- func (this *Feature) GoString() string
- func (m *Feature) Marshal() (dAtA []byte, err error)
- func (m *Feature) MarshalTo(dAtA []byte) (int, error)
- func (*Feature) ProtoMessage()
- func (m *Feature) Reset()
- func (m *Feature) Size() (n int)
- func (this *Feature) String() string
- func (m *Feature) Unmarshal(dAtA []byte) error
- func (this *Feature) VerboseEqual(that interface{}) error
- type FeatureResponse
- func (this *FeatureResponse) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*FeatureResponse) Descriptor() ([]byte, []int)
- func (this *FeatureResponse) Equal(that interface{}) bool
- func (m *FeatureResponse) GetFeatures() []*Feature
- func (m *FeatureResponse) GetID() string
- func (m *FeatureResponse) GetInputID() string
- func (m *FeatureResponse) GetMetadata() map[string]string
- func (m *FeatureResponse) GetRequestID() string
- func (this *FeatureResponse) GoString() string
- func (m *FeatureResponse) Marshal() (dAtA []byte, err error)
- func (m *FeatureResponse) MarshalTo(dAtA []byte) (int, error)
- func (*FeatureResponse) ProtoMessage()
- func (m *FeatureResponse) Reset()
- func (m *FeatureResponse) Size() (n int)
- func (this *FeatureResponse) String() string
- func (m *FeatureResponse) Unmarshal(dAtA []byte) error
- func (this *FeatureResponse) VerboseEqual(that interface{}) error
- type Features
- func (p Features) Bhattacharyya(q Features) (float64, error)
- func (p Features) Correlation(q Features) (float64, error)
- func (p Features) Covariance(q Features) (float64, error)
- func (p Features) Hellinger(q Features) (float64, error)
- func (p Features) JensenShannon(q Features) (float64, error)
- func (p Features) KullbackLeiblerDivergence(q Features) (float64, error)
- func (p Features) Len() int
- func (p Features) Less(i, j int) bool
- func (p Features) ProbabilitiesFloat32() []float32
- func (p Features) ProbabilitiesFloat64() []float64
- func (p Features) Sort()
- func (p Features) Swap(i, j int)
- func (p Features) Take(n int) Features
- type FeaturesResponse
- func (this *FeaturesResponse) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*FeaturesResponse) Descriptor() ([]byte, []int)
- func (this *FeaturesResponse) Equal(that interface{}) bool
- func (m *FeaturesResponse) GetID() string
- func (m *FeaturesResponse) GetResponses() []*FeatureResponse
- func (this *FeaturesResponse) GoString() string
- func (m *FeaturesResponse) Marshal() (dAtA []byte, err error)
- func (m *FeaturesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*FeaturesResponse) ProtoMessage()
- func (m *FeaturesResponse) Reset()
- func (m *FeaturesResponse) Size() (n int)
- func (this *FeaturesResponse) String() string
- func (m *FeaturesResponse) Unmarshal(dAtA []byte) error
- func (this *FeaturesResponse) VerboseEqual(that interface{}) error
- type FrameworkManifest
- func (f FrameworkManifest) CanonicalName() (string, error)
- func (this *FrameworkManifest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*FrameworkManifest) Descriptor() ([]byte, []int)
- func (this *FrameworkManifest) Equal(that interface{}) bool
- func (f FrameworkManifest) FindModel(name string) (*ModelManifest, error)
- func (m *FrameworkManifest) GetContainer() map[string]*ContainerHardware
- func (m *FrameworkManifest) GetName() string
- func (m *FrameworkManifest) GetVersion() string
- func (this *FrameworkManifest) GoString() string
- func (m *FrameworkManifest) Marshal() (dAtA []byte, err error)
- func (m *FrameworkManifest) MarshalTo(dAtA []byte) (int, error)
- func (f FrameworkManifest) Models() []ModelManifest
- func (f FrameworkManifest) MustCanonicalName() string
- func (*FrameworkManifest) ProtoMessage()
- func (f FrameworkManifest) Register() error
- func (f FrameworkManifest) RegisterNamed(s string) error
- func (m *FrameworkManifest) Reset()
- func (m *FrameworkManifest) Size() (n int)
- func (this *FrameworkManifest) String() string
- func (m *FrameworkManifest) Unmarshal(dAtA []byte) error
- func (this *FrameworkManifest) VerboseEqual(that interface{}) error
- func (f *FrameworkManifest) WorkDir() (string, error)
- type FrameworkManifestsResponse
- func (this *FrameworkManifestsResponse) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*FrameworkManifestsResponse) Descriptor() ([]byte, []int)
- func (this *FrameworkManifestsResponse) Equal(that interface{}) bool
- func (m *FrameworkManifestsResponse) GetManifests() []*FrameworkManifest
- func (this *FrameworkManifestsResponse) GoString() string
- func (m *FrameworkManifestsResponse) Marshal() (dAtA []byte, err error)
- func (m *FrameworkManifestsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*FrameworkManifestsResponse) ProtoMessage()
- func (m *FrameworkManifestsResponse) Reset()
- func (m *FrameworkManifestsResponse) Size() (n int)
- func (this *FrameworkManifestsResponse) String() string
- func (m *FrameworkManifestsResponse) Unmarshal(dAtA []byte) error
- func (this *FrameworkManifestsResponse) VerboseEqual(that interface{}) error
- type FrameworkRequest
- func (this *FrameworkRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*FrameworkRequest) Descriptor() ([]byte, []int)
- func (this *FrameworkRequest) Equal(that interface{}) bool
- func (m *FrameworkRequest) GetFrameworkName() string
- func (m *FrameworkRequest) GetFrameworkVersion() string
- func (this *FrameworkRequest) GoString() string
- func (m *FrameworkRequest) Marshal() (dAtA []byte, err error)
- func (m *FrameworkRequest) MarshalTo(dAtA []byte) (int, error)
- func (*FrameworkRequest) ProtoMessage()
- func (m *FrameworkRequest) Reset()
- func (m *FrameworkRequest) Size() (n int)
- func (this *FrameworkRequest) String() string
- func (m *FrameworkRequest) Unmarshal(dAtA []byte) error
- func (this *FrameworkRequest) VerboseEqual(that interface{}) error
- type GPUOptions
- func (*GPUOptions) Descriptor() ([]byte, []int)
- func (this *GPUOptions) Equal(that interface{}) bool
- func (m *GPUOptions) GetAllocatorType() string
- func (m *GPUOptions) GetForceGpuCompatible() bool
- func (m *GPUOptions) GetPerProcessGpuMemoryFraction() float64
- func (m *GPUOptions) GetVisibleDeviceList() string
- func (this *GPUOptions) GoString() string
- func (m *GPUOptions) Marshal() (dAtA []byte, err error)
- func (m *GPUOptions) MarshalTo(dAtA []byte) (int, error)
- func (*GPUOptions) ProtoMessage()
- func (m *GPUOptions) Reset()
- func (m *GPUOptions) Size() (n int)
- func (this *GPUOptions) String() string
- func (m *GPUOptions) Unmarshal(dAtA []byte) error
- func (this *GPUOptions) VerboseEqual(that interface{}) error
- type ImagesRequest
- func (this *ImagesRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*ImagesRequest) Descriptor() ([]byte, []int)
- func (this *ImagesRequest) Equal(that interface{}) bool
- func (m *ImagesRequest) GetImages() []*ImagesRequest_Image
- func (m *ImagesRequest) GetOptions() *PredictionOptions
- func (m *ImagesRequest) GetPredictor() *Predictor
- func (this *ImagesRequest) GoString() string
- func (m *ImagesRequest) Marshal() (dAtA []byte, err error)
- func (m *ImagesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ImagesRequest) ProtoMessage()
- func (m *ImagesRequest) Reset()
- func (m *ImagesRequest) Size() (n int)
- func (this *ImagesRequest) String() string
- func (m *ImagesRequest) Unmarshal(dAtA []byte) error
- func (this *ImagesRequest) VerboseEqual(that interface{}) error
- type ImagesRequest_Image
- func (*ImagesRequest_Image) Descriptor() ([]byte, []int)
- func (this *ImagesRequest_Image) Equal(that interface{}) bool
- func (m *ImagesRequest_Image) GetData() []byte
- func (m *ImagesRequest_Image) GetID() string
- func (this *ImagesRequest_Image) GoString() string
- func (m *ImagesRequest_Image) Marshal() (dAtA []byte, err error)
- func (m *ImagesRequest_Image) MarshalTo(dAtA []byte) (int, error)
- func (*ImagesRequest_Image) ProtoMessage()
- func (m *ImagesRequest_Image) Reset()
- func (m *ImagesRequest_Image) Size() (n int)
- func (this *ImagesRequest_Image) String() string
- func (m *ImagesRequest_Image) Unmarshal(dAtA []byte) error
- func (this *ImagesRequest_Image) VerboseEqual(that interface{}) error
- type ModelManifest
- func (m ModelManifest) CanonicalName() (string, error)
- func (*ModelManifest) Descriptor() ([]byte, []int)
- func (this *ModelManifest) Equal(that interface{}) bool
- func (m ModelManifest) FrameworkConstraint() (*semver.Constraints, error)
- func (m *ModelManifest) GetAfterPostprocess() string
- func (m *ModelManifest) GetAfterPreprocess() string
- func (m *ModelManifest) GetAttributes() map[string]string
- func (m *ModelManifest) GetBeforePostprocess() string
- func (m *ModelManifest) GetBeforePreprocess() string
- func (m *ModelManifest) GetContainer() map[string]*ContainerHardware
- func (m *ModelManifest) GetDescription() string
- func (m *ModelManifest) GetFramework() *FrameworkManifest
- func (m *ModelManifest) GetHidden() bool
- func (m *ModelManifest) GetInputs() []*ModelManifest_Type
- func (m *ModelManifest) GetLicense() string
- func (m *ModelManifest) GetModel() *ModelManifest_Model
- func (m *ModelManifest) GetName() string
- func (m *ModelManifest) GetOutput() *ModelManifest_Type
- func (m *ModelManifest) GetPostprocess() string
- func (m *ModelManifest) GetPreprocess() string
- func (m *ModelManifest) GetReference() []string
- func (m *ModelManifest) GetVersion() string
- func (this *ModelManifest) GoString() string
- func (m *ModelManifest) Marshal() (dAtA []byte, err error)
- func (m *ModelManifest) MarshalTo(dAtA []byte) (int, error)
- func (m ModelManifest) MustCanonicalName() string
- func (*ModelManifest) ProtoMessage()
- func (m ModelManifest) Register() error
- func (m ModelManifest) RegisterNamed(s string) error
- func (m *ModelManifest) Reset()
- func (m ModelManifest) ResolveFramework() (FrameworkManifest, error)
- func (m *ModelManifest) Size() (n int)
- func (this *ModelManifest) String() string
- func (m *ModelManifest) Unmarshal(dAtA []byte) error
- func (m *ModelManifest) Validate() error
- func (this *ModelManifest) VerboseEqual(that interface{}) error
- func (m *ModelManifest) WorkDir() (string, error)
- type ModelManifest_Model
- func (*ModelManifest_Model) Descriptor() ([]byte, []int)
- func (this *ModelManifest_Model) Equal(that interface{}) bool
- func (m *ModelManifest_Model) GetBaseUrl() string
- func (m *ModelManifest_Model) GetGraphChecksum() string
- func (m *ModelManifest_Model) GetGraphPath() string
- func (m *ModelManifest_Model) GetIsArchive() bool
- func (m *ModelManifest_Model) GetWeightsChecksum() string
- func (m *ModelManifest_Model) GetWeightsPath() string
- func (this *ModelManifest_Model) GoString() string
- func (m *ModelManifest_Model) Marshal() (dAtA []byte, err error)
- func (m *ModelManifest_Model) MarshalTo(dAtA []byte) (int, error)
- func (*ModelManifest_Model) ProtoMessage()
- func (m *ModelManifest_Model) Reset()
- func (m *ModelManifest_Model) Size() (n int)
- func (this *ModelManifest_Model) String() string
- func (m *ModelManifest_Model) Unmarshal(dAtA []byte) error
- func (this *ModelManifest_Model) VerboseEqual(that interface{}) error
- type ModelManifest_Type
- func (*ModelManifest_Type) Descriptor() ([]byte, []int)
- func (this *ModelManifest_Type) Equal(that interface{}) bool
- func (m *ModelManifest_Type) GetDescription() string
- func (m *ModelManifest_Type) GetParameters() map[string]*ModelManifest_Type_Parameter
- func (m *ModelManifest_Type) GetType() string
- func (this *ModelManifest_Type) GoString() string
- func (m *ModelManifest_Type) Marshal() (dAtA []byte, err error)
- func (m *ModelManifest_Type) MarshalTo(dAtA []byte) (int, error)
- func (*ModelManifest_Type) ProtoMessage()
- func (m *ModelManifest_Type) Reset()
- func (m *ModelManifest_Type) Size() (n int)
- func (this *ModelManifest_Type) String() string
- func (m *ModelManifest_Type) Unmarshal(dAtA []byte) error
- func (this *ModelManifest_Type) VerboseEqual(that interface{}) error
- type ModelManifest_Type_Parameter
- func (*ModelManifest_Type_Parameter) Descriptor() ([]byte, []int)
- func (this *ModelManifest_Type_Parameter) Equal(that interface{}) bool
- func (m *ModelManifest_Type_Parameter) GetValue() string
- func (this *ModelManifest_Type_Parameter) GoString() string
- func (m *ModelManifest_Type_Parameter) Marshal() (dAtA []byte, err error)
- func (m *ModelManifest_Type_Parameter) MarshalTo(dAtA []byte) (int, error)
- func (param *ModelManifest_Type_Parameter) MarshalYAML() (interface{}, error)
- func (*ModelManifest_Type_Parameter) ProtoMessage()
- func (m *ModelManifest_Type_Parameter) Reset()
- func (m *ModelManifest_Type_Parameter) Size() (n int)
- func (this *ModelManifest_Type_Parameter) String() string
- func (m *ModelManifest_Type_Parameter) Unmarshal(dAtA []byte) error
- func (param *ModelManifest_Type_Parameter) UnmarshalYAML(unmarshal func(interface{}) error) error
- func (this *ModelManifest_Type_Parameter) VerboseEqual(that interface{}) error
- type ModelManifestsResponse
- func (this *ModelManifestsResponse) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*ModelManifestsResponse) Descriptor() ([]byte, []int)
- func (this *ModelManifestsResponse) Equal(that interface{}) bool
- func (m *ModelManifestsResponse) GetManifests() []*ModelManifest
- func (this *ModelManifestsResponse) GoString() string
- func (m *ModelManifestsResponse) Marshal() (dAtA []byte, err error)
- func (m *ModelManifestsResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ModelManifestsResponse) ProtoMessage()
- func (m *ModelManifestsResponse) Reset()
- func (m *ModelManifestsResponse) Size() (n int)
- func (this *ModelManifestsResponse) String() string
- func (m *ModelManifestsResponse) Unmarshal(dAtA []byte) error
- func (this *ModelManifestsResponse) VerboseEqual(that interface{}) error
- type ModelRequest
- func (this *ModelRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*ModelRequest) Descriptor() ([]byte, []int)
- func (this *ModelRequest) Equal(that interface{}) bool
- func (m *ModelRequest) GetFrameworkName() string
- func (m *ModelRequest) GetFrameworkVersion() string
- func (m *ModelRequest) GetModelName() string
- func (m *ModelRequest) GetModelVersion() string
- func (this *ModelRequest) GoString() string
- func (m *ModelRequest) Marshal() (dAtA []byte, err error)
- func (m *ModelRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ModelRequest) ProtoMessage()
- func (m *ModelRequest) Reset()
- func (m *ModelRequest) Size() (n int)
- func (this *ModelRequest) String() string
- func (m *ModelRequest) Unmarshal(dAtA []byte) error
- func (this *ModelRequest) VerboseEqual(that interface{}) error
- type PredictClient
- type PredictServer
- type Predict_DatasetStreamClient
- type Predict_DatasetStreamServer
- type Predict_ImagesStreamClient
- type Predict_ImagesStreamServer
- type Predict_URLsStreamClient
- type Predict_URLsStreamServer
- type PredictionOptions
- func (this *PredictionOptions) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*PredictionOptions) Descriptor() ([]byte, []int)
- func (this *PredictionOptions) Equal(that interface{}) bool
- func (m *PredictionOptions) GetAgent() string
- func (m *PredictionOptions) GetBatchSize() uint32
- func (m *PredictionOptions) GetExecutionOptions() *ExecutionOptions
- func (m *PredictionOptions) GetFeatureLimit() int32
- func (m *PredictionOptions) GetRequestID() string
- func (this *PredictionOptions) GoString() string
- func (m *PredictionOptions) Marshal() (dAtA []byte, err error)
- func (m *PredictionOptions) MarshalTo(dAtA []byte) (int, error)
- func (*PredictionOptions) ProtoMessage()
- func (m *PredictionOptions) Reset()
- func (m *PredictionOptions) Size() (n int)
- func (this *PredictionOptions) String() string
- func (m *PredictionOptions) Unmarshal(dAtA []byte) error
- func (this *PredictionOptions) VerboseEqual(that interface{}) error
- type Predictor
- func (this *Predictor) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*Predictor) Descriptor() ([]byte, []int)
- func (this *Predictor) Equal(that interface{}) bool
- func (m *Predictor) GetID() string
- func (this *Predictor) GoString() string
- func (m *Predictor) Marshal() (dAtA []byte, err error)
- func (m *Predictor) MarshalTo(dAtA []byte) (int, error)
- func (*Predictor) ProtoMessage()
- func (m *Predictor) Reset()
- func (m *Predictor) Size() (n int)
- func (this *Predictor) String() string
- func (m *Predictor) Unmarshal(dAtA []byte) error
- func (this *Predictor) VerboseEqual(that interface{}) error
- type PredictorCloseResponse
- func (*PredictorCloseResponse) Descriptor() ([]byte, []int)
- func (this *PredictorCloseResponse) Equal(that interface{}) bool
- func (this *PredictorCloseResponse) GoString() string
- func (m *PredictorCloseResponse) Marshal() (dAtA []byte, err error)
- func (m *PredictorCloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (*PredictorCloseResponse) ProtoMessage()
- func (m *PredictorCloseResponse) Reset()
- func (m *PredictorCloseResponse) Size() (n int)
- func (this *PredictorCloseResponse) String() string
- func (m *PredictorCloseResponse) Unmarshal(dAtA []byte) error
- func (this *PredictorCloseResponse) VerboseEqual(that interface{}) error
- type PredictorOpenRequest
- func (this *PredictorOpenRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*PredictorOpenRequest) Descriptor() ([]byte, []int)
- func (this *PredictorOpenRequest) Equal(that interface{}) bool
- func (m *PredictorOpenRequest) GetFrameworkName() string
- func (m *PredictorOpenRequest) GetFrameworkVersion() string
- func (m *PredictorOpenRequest) GetModelName() string
- func (m *PredictorOpenRequest) GetModelVersion() string
- func (m *PredictorOpenRequest) GetOptions() *PredictionOptions
- func (this *PredictorOpenRequest) GoString() string
- func (m *PredictorOpenRequest) Marshal() (dAtA []byte, err error)
- func (m *PredictorOpenRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PredictorOpenRequest) ProtoMessage()
- func (m *PredictorOpenRequest) Reset()
- func (m *PredictorOpenRequest) Size() (n int)
- func (this *PredictorOpenRequest) String() string
- func (m *PredictorOpenRequest) Unmarshal(dAtA []byte) error
- func (this *PredictorOpenRequest) VerboseEqual(that interface{}) error
- type RegistryClient
- type RegistryServer
- type ResetRequest
- func (this *ResetRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*ResetRequest) Descriptor() ([]byte, []int)
- func (this *ResetRequest) Equal(that interface{}) bool
- func (m *ResetRequest) GetID() string
- func (m *ResetRequest) GetPredictor() *Predictor
- func (this *ResetRequest) GoString() string
- func (m *ResetRequest) Marshal() (dAtA []byte, err error)
- func (m *ResetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ResetRequest) ProtoMessage()
- func (m *ResetRequest) Reset()
- func (m *ResetRequest) Size() (n int)
- func (this *ResetRequest) String() string
- func (m *ResetRequest) Unmarshal(dAtA []byte) error
- func (this *ResetRequest) VerboseEqual(that interface{}) error
- type ResetResponse
- func (this *ResetResponse) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*ResetResponse) Descriptor() ([]byte, []int)
- func (this *ResetResponse) Equal(that interface{}) bool
- func (this *ResetResponse) GoString() string
- func (m *ResetResponse) Marshal() (dAtA []byte, err error)
- func (m *ResetResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ResetResponse) ProtoMessage()
- func (m *ResetResponse) Reset()
- func (m *ResetResponse) Size() (n int)
- func (this *ResetResponse) String() string
- func (m *ResetResponse) Unmarshal(dAtA []byte) error
- func (this *ResetResponse) VerboseEqual(that interface{}) error
- type URLsRequest
- func (this *URLsRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
- func (*URLsRequest) Descriptor() ([]byte, []int)
- func (this *URLsRequest) Equal(that interface{}) bool
- func (m *URLsRequest) GetOptions() *PredictionOptions
- func (m *URLsRequest) GetPredictor() *Predictor
- func (m *URLsRequest) GetUrls() []*URLsRequest_URL
- func (this *URLsRequest) GoString() string
- func (m *URLsRequest) Marshal() (dAtA []byte, err error)
- func (m *URLsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*URLsRequest) ProtoMessage()
- func (m *URLsRequest) Reset()
- func (m *URLsRequest) Size() (n int)
- func (this *URLsRequest) String() string
- func (m *URLsRequest) Unmarshal(dAtA []byte) error
- func (this *URLsRequest) VerboseEqual(that interface{}) error
- type URLsRequest_URL
- func (*URLsRequest_URL) Descriptor() ([]byte, []int)
- func (this *URLsRequest_URL) Equal(that interface{}) bool
- func (m *URLsRequest_URL) GetData() string
- func (m *URLsRequest_URL) GetID() string
- func (this *URLsRequest_URL) GoString() string
- func (m *URLsRequest_URL) Marshal() (dAtA []byte, err error)
- func (m *URLsRequest_URL) MarshalTo(dAtA []byte) (int, error)
- func (*URLsRequest_URL) ProtoMessage()
- func (m *URLsRequest_URL) Reset()
- func (m *URLsRequest_URL) Size() (n int)
- func (this *URLsRequest_URL) String() string
- func (m *URLsRequest_URL) Unmarshal(dAtA []byte) error
- func (this *URLsRequest_URL) VerboseEqual(that interface{}) error
Constants ¶
const (
Swagger = dlframework_swagger
)
Variables ¶
var ( ErrInvalidLengthPredictor = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPredictor = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthRegistry = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRegistry = fmt.Errorf("proto: integer overflow") )
var ( RegistryServiceDescription = _Registry_serviceDesc PredictServiceDescription = _Predict_serviceDesc )
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",
}
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,
}
var Version = "0.2.19"
Functions ¶
func Bhattacharyya ¶ added in v0.2.19
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
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
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
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
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
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
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 *github_com_gogo_protobuf_protoc_gen_gogo_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 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 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 *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
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 (*Agent) Description ¶ added in v0.2.16
func (this *Agent) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
func (*Agent) Descriptor ¶
func (*Agent) GetArchitecture ¶ added in v0.2.19
func (*Agent) GetCpuinfo ¶ added in v0.2.19
func (*Agent) GetFrameworks ¶ added in v0.2.19
func (m *Agent) GetFrameworks() []*FrameworkManifest
func (*Agent) GetGpuinfo ¶ added in v0.2.19
func (*Agent) GetHostname ¶ added in v0.2.19
func (*Agent) GetMetadata ¶ added in v0.2.19
func (*Agent) ProtoMessage ¶
func (*Agent) ProtoMessage()
func (*Agent) VerboseEqual ¶
type Agents ¶
type Agents struct {
Agents []*Agent `protobuf:"bytes,1,rep,name=agents" json:"agents,omitempty" yaml:"agents,omitempty"`
}
func NewPopulatedAgents ¶
func (*Agents) Description ¶ added in v0.2.16
func (this *Agents) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
func (*Agents) Descriptor ¶
func (*Agents) ProtoMessage ¶
func (*Agents) ProtoMessage()
func (*Agents) VerboseEqual ¶
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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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) 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 (*Feature) Description ¶ added in v0.2.16
func (this *Feature) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
func (*Feature) Descriptor ¶ added in v0.2.16
func (*Feature) GetMetadata ¶ added in v0.2.16
func (*Feature) GetProbability ¶ added in v0.2.16
func (*Feature) ProtoMessage ¶ added in v0.2.16
func (*Feature) ProtoMessage()
func (*Feature) VerboseEqual ¶ added in v0.2.16
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 *github_com_gogo_protobuf_protoc_gen_gogo_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 (Features) Correlation ¶ added in v0.2.19
func (Features) Covariance ¶ added in v0.2.19
func (Features) JensenShannon ¶ added in v0.2.19
func (Features) KullbackLeiblerDivergence ¶ added in v0.2.19
func (Features) Less ¶ added in v0.2.16
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 (Features) ProbabilitiesFloat64 ¶ added in v0.2.19
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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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) 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 *github_com_gogo_protobuf_protoc_gen_gogo_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) 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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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) 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 *github_com_gogo_protobuf_protoc_gen_gogo_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 (*Predictor) Description ¶ added in v0.2.16
func (this *Predictor) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)
func (*Predictor) Descriptor ¶ added in v0.2.16
func (*Predictor) ProtoMessage ¶ added in v0.2.16
func (*Predictor) ProtoMessage()
func (*Predictor) VerboseEqual ¶ added in v0.2.16
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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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 *github_com_gogo_protobuf_protoc_gen_gogo_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 ¶
Directories ¶
Path | Synopsis |
---|---|
httpapi
|
|
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. |