dlframework

package module
v0.2.15 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2017 License: NCSA Imports: 30 Imported by: 15

README

DLFramework

Framework Manifest Format

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

Model Manifest Format

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

Documentation

Overview 

Package dlframework is a generated protocol buffer package.

It is generated from these files:
	dlframework.proto

It has these top-level messages:
	ErrorStatus
	ContainerHardware
	FrameworkManifest
	ModelManifest
	FrameworkRequest
	FrameworkManifestsResponse
	Agent
	Agents
	ModelRequest
	ModelManifestsResponse
	PredictRequest
	PredictionFeature
	PredictResponse

Package dlframework is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	Swagger = dlframework_swagger
)

Variables

View Source 
var (
	ErrInvalidLengthDlframework = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDlframework   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	RegistryServiceDescription  = _Registry_serviceDesc
	PredictorServiceDescription = _Predictor_serviceDesc
)

Functions

func RegisterPredictorHandler 

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

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

func RegisterPredictorHandlerFromEndpoint 

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

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

func RegisterPredictorServer 

func RegisterPredictorServer(s *grpc.Server, srv PredictorServer)

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

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"`
}

func NewPopulatedAgent 

func NewPopulatedAgent(r randyDlframework, easy bool) *Agent

func (*Agent) Descriptor 

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

func (*Agent) Equal 

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

func (*Agent) GetHost 

func (m *Agent) GetHost() string

func (*Agent) GetPort 

func (m *Agent) GetPort() string

func (*Agent) GoString 

func (this *Agent) GoString() string

func (*Agent) Marshal 

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

func (*Agent) MarshalTo 

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

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) Reset 

func (m *Agent) Reset()

func (*Agent) Size 

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

func (*Agent) String 

func (this *Agent) String() string

func (*Agent) Unmarshal 

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

func (*Agent) VerboseEqual 

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

type Agents 

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

func NewPopulatedAgents 

func NewPopulatedAgents(r randyDlframework, easy bool) *Agents

func (*Agents) Descriptor 

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

func (*Agents) Equal 

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

func (*Agents) GetAgents 

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

func (*Agents) GoString 

func (this *Agents) GoString() string

func (*Agents) Marshal 

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

func (*Agents) MarshalTo 

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

func (*Agents) ProtoMessage 

func (*Agents) ProtoMessage()

func (*Agents) Reset 

func (m *Agents) Reset()

func (*Agents) Size 

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

func (*Agents) String 

func (this *Agents) String() string

func (*Agents) Unmarshal 

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

func (*Agents) VerboseEqual 

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

type 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 randyDlframework, easy bool) *ContainerHardware

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 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 randyDlframework, easy bool) *ErrorStatus

func (*ErrorStatus) Descriptor 

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

func (*ErrorStatus) Equal 

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

func (*ErrorStatus) GetMessage 

func (m *ErrorStatus) GetMessage() string

func (*ErrorStatus) GetOk 

func (m *ErrorStatus) GetOk() bool

func (*ErrorStatus) GoString 

func (this *ErrorStatus) GoString() string

func (*ErrorStatus) Marshal 

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

func (*ErrorStatus) MarshalTo 

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

func (*ErrorStatus) ProtoMessage 

func (*ErrorStatus) ProtoMessage()

func (*ErrorStatus) Reset 

func (m *ErrorStatus) Reset()

func (*ErrorStatus) Size 

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

func (*ErrorStatus) String 

func (this *ErrorStatus) String() string

func (*ErrorStatus) Unmarshal 

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

func (*ErrorStatus) VerboseEqual 

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

type 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 randyDlframework, easy bool) *FrameworkManifest

func (FrameworkManifest) CanonicalName 

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

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 randyDlframework, easy bool) *FrameworkManifestsResponse

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 randyDlframework, easy bool) *FrameworkRequest

func (*FrameworkRequest) Descriptor 

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

func (*FrameworkRequest) Equal 

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

func (*FrameworkRequest) GetFrameworkName 

func (m *FrameworkRequest) GetFrameworkName() string

func (*FrameworkRequest) GetFrameworkVersion 

func (m *FrameworkRequest) GetFrameworkVersion() string

func (*FrameworkRequest) GoString 

func (this *FrameworkRequest) GoString() string

func (*FrameworkRequest) Marshal 

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

func (*FrameworkRequest) MarshalTo 

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

func (*FrameworkRequest) ProtoMessage 

func (*FrameworkRequest) ProtoMessage()

func (*FrameworkRequest) Reset 

func (m *FrameworkRequest) Reset()

func (*FrameworkRequest) Size 

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

func (*FrameworkRequest) String 

func (this *FrameworkRequest) String() string

func (*FrameworkRequest) Unmarshal 

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

func (*FrameworkRequest) VerboseEqual 

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

type 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 randyDlframework, easy bool) *ModelManifest

func (ModelManifest) CanonicalName 

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

func (*ModelManifest) Descriptor 

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

func (*ModelManifest) Equal 

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

func (ModelManifest) FrameworkConstraint 

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

func (*ModelManifest) GetAfterPostprocess 

func (m *ModelManifest) GetAfterPostprocess() string

func (*ModelManifest) GetAfterPreprocess 

func (m *ModelManifest) GetAfterPreprocess() string

func (*ModelManifest) GetAttributes 

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

func (*ModelManifest) GetBeforePostprocess 

func (m *ModelManifest) GetBeforePostprocess() string

func (*ModelManifest) GetBeforePreprocess 

func (m *ModelManifest) GetBeforePreprocess() string

func (*ModelManifest) GetContainer 

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

func (*ModelManifest) GetDescription 

func (m *ModelManifest) GetDescription() string

func (*ModelManifest) GetFramework 

func (m *ModelManifest) GetFramework() *FrameworkManifest

func (*ModelManifest) GetHidden 

func (m *ModelManifest) GetHidden() bool

func (*ModelManifest) GetInputs 

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

func (*ModelManifest) GetLicense 

func (m *ModelManifest) GetLicense() string

func (*ModelManifest) GetModel 

func (m *ModelManifest) GetModel() *ModelManifest_Model

func (*ModelManifest) GetName 

func (m *ModelManifest) GetName() string

func (*ModelManifest) GetOutput 

func (m *ModelManifest) GetOutput() *ModelManifest_Type

func (*ModelManifest) GetPostprocess 

func (m *ModelManifest) GetPostprocess() string

func (*ModelManifest) GetPreprocess 

func (m *ModelManifest) GetPreprocess() string

func (*ModelManifest) GetReference 

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

func (*ModelManifest) GetVersion 

func (m *ModelManifest) GetVersion() string

func (*ModelManifest) GoString 

func (this *ModelManifest) GoString() string

func (*ModelManifest) Marshal 

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

func (*ModelManifest) MarshalTo 

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

func (ModelManifest) MustCanonicalName 

func (m ModelManifest) MustCanonicalName() string

func (*ModelManifest) ProtoMessage 

func (*ModelManifest) ProtoMessage()

func (ModelManifest) Register 

func (m ModelManifest) Register() error

func (ModelManifest) RegisterNamed 

func (m ModelManifest) RegisterNamed(s string) error

func (*ModelManifest) Reset 

func (m *ModelManifest) Reset()

func (ModelManifest) ResolveFramework 

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

func (*ModelManifest) Size 

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

func (*ModelManifest) String 

func (this *ModelManifest) String() string

func (*ModelManifest) Unmarshal 

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

func (*ModelManifest) Validate 

func (m *ModelManifest) Validate() error

func (*ModelManifest) VerboseEqual 

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

func (*ModelManifest) WorkDir 

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

type ModelManifest_Model 

type ModelManifest_Model struct {
	BaseUrl     string `protobuf:"bytes,1,opt,name=base_url,json=baseUrl,proto3" json:"base_url,omitempty" yaml:"base_url,omitempty"`
	WeightsPath string `protobuf:"bytes,2,opt,name=weights_path,json=weightsPath,proto3" json:"weights_path,omitempty" yaml:"weights_path,omitempty"`
	GraphPath   string `protobuf:"bytes,3,opt,name=graph_path,json=graphPath,proto3" json:"graph_path,omitempty" yaml:"graph_path,omitempty"`
	IsArchive   bool   `protobuf:"varint,4,opt,name=is_archive,json=isArchive,proto3" json:"is_archive,omitempty" yaml:"is_archive,omitempty"`
}

func NewPopulatedModelManifest_Model 

func NewPopulatedModelManifest_Model(r randyDlframework, 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) GetGraphPath 

func (m *ModelManifest_Model) GetGraphPath() string

func (*ModelManifest_Model) GetIsArchive 

func (m *ModelManifest_Model) GetIsArchive() bool

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 randyDlframework, 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 randyDlframework, 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 randyDlframework, easy bool) *ModelManifestsResponse

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 randyDlframework, easy bool) *ModelRequest

func (*ModelRequest) Descriptor 

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

func (*ModelRequest) Equal 

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

func (*ModelRequest) GetFrameworkName 

func (m *ModelRequest) GetFrameworkName() string

func (*ModelRequest) GetFrameworkVersion 

func (m *ModelRequest) GetFrameworkVersion() string

func (*ModelRequest) GetModelName 

func (m *ModelRequest) GetModelName() string

func (*ModelRequest) GetModelVersion 

func (m *ModelRequest) GetModelVersion() string

func (*ModelRequest) GoString 

func (this *ModelRequest) GoString() string

func (*ModelRequest) Marshal 

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

func (*ModelRequest) MarshalTo 

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

func (*ModelRequest) ProtoMessage 

func (*ModelRequest) ProtoMessage()

func (*ModelRequest) Reset 

func (m *ModelRequest) Reset()

func (*ModelRequest) Size 

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

func (*ModelRequest) String 

func (this *ModelRequest) String() string

func (*ModelRequest) Unmarshal 

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

func (*ModelRequest) VerboseEqual 

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

type PredictRequest 

type PredictRequest 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 */
	Limit            int32  `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty" yaml:"limit,omitempty"`
	Data             []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty" yaml:"data,omitempty"`
}

func NewPopulatedPredictRequest 

func NewPopulatedPredictRequest(r randyDlframework, easy bool) *PredictRequest

func (*PredictRequest) Descriptor 

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

func (*PredictRequest) Equal 

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

func (*PredictRequest) GetData 

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

func (*PredictRequest) GetFrameworkName 

func (m *PredictRequest) GetFrameworkName() string

func (*PredictRequest) GetFrameworkVersion 

func (m *PredictRequest) GetFrameworkVersion() string

func (*PredictRequest) GetLimit 

func (m *PredictRequest) GetLimit() int32

func (*PredictRequest) GetModelName 

func (m *PredictRequest) GetModelName() string

func (*PredictRequest) GetModelVersion 

func (m *PredictRequest) GetModelVersion() string

func (*PredictRequest) GoString 

func (this *PredictRequest) GoString() string

func (*PredictRequest) Marshal 

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

func (*PredictRequest) MarshalTo 

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

func (*PredictRequest) ProtoMessage 

func (*PredictRequest) ProtoMessage()

func (*PredictRequest) Reset 

func (m *PredictRequest) Reset()

func (*PredictRequest) Size 

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

func (*PredictRequest) String 

func (this *PredictRequest) String() string

func (*PredictRequest) Unmarshal 

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

func (*PredictRequest) VerboseEqual 

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

type PredictResponse 

type PredictResponse struct {
	Id       string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	Features []*PredictionFeature `protobuf:"bytes,2,rep,name=features" json:"features,omitempty" yaml:"features,omitempty"`
	Error    *ErrorStatus         `protobuf:"bytes,3,opt,name=error" json:"error,omitempty" yaml:"error,omitempty"`
}

func NewPopulatedPredictResponse 

func NewPopulatedPredictResponse(r randyDlframework, easy bool) *PredictResponse

func (*PredictResponse) Descriptor 

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

func (*PredictResponse) Equal 

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

func (*PredictResponse) GetError 

func (m *PredictResponse) GetError() *ErrorStatus

func (*PredictResponse) GetFeatures 

func (m *PredictResponse) GetFeatures() []*PredictionFeature

func (*PredictResponse) GetId 

func (m *PredictResponse) GetId() string

func (*PredictResponse) GoString 

func (this *PredictResponse) GoString() string

func (*PredictResponse) Marshal 

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

func (*PredictResponse) MarshalTo 

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

func (*PredictResponse) ProtoMessage 

func (*PredictResponse) ProtoMessage()

func (*PredictResponse) Reset 

func (m *PredictResponse) Reset()

func (*PredictResponse) Size 

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

func (*PredictResponse) String 

func (this *PredictResponse) String() string

func (*PredictResponse) Unmarshal 

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

func (*PredictResponse) VerboseEqual 

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

type PredictionFeature 

type PredictionFeature 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"`
}

func NewPopulatedPredictionFeature 

func NewPopulatedPredictionFeature(r randyDlframework, easy bool) *PredictionFeature

func (*PredictionFeature) Descriptor 

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

func (*PredictionFeature) Equal 

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

func (*PredictionFeature) GetIndex 

func (m *PredictionFeature) GetIndex() int64

func (*PredictionFeature) GetName 

func (m *PredictionFeature) GetName() string

func (*PredictionFeature) GetProbability 

func (m *PredictionFeature) GetProbability() float32

func (*PredictionFeature) GoString 

func (this *PredictionFeature) GoString() string

func (*PredictionFeature) Marshal 

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

func (*PredictionFeature) MarshalTo 

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

func (*PredictionFeature) ProtoMessage 

func (*PredictionFeature) ProtoMessage()

func (*PredictionFeature) Reset 

func (m *PredictionFeature) Reset()

func (*PredictionFeature) Size 

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

func (*PredictionFeature) String 

func (this *PredictionFeature) String() string

func (*PredictionFeature) Unmarshal 

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

func (*PredictionFeature) VerboseEqual 

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

type PredictionFeatures 

type PredictionFeatures []*PredictionFeature

func (PredictionFeatures) Len 

func (p PredictionFeatures) Len() int

Len is the number of elements in the collection.

func (PredictionFeatures) Less 

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

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

func (PredictionFeatures) Sort 

func (p PredictionFeatures) Sort()

func (PredictionFeatures) Swap 

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

Swap swaps the elements with indexes i and j.

func (PredictionFeatures) Take 

func (p PredictionFeatures) Take(n int) PredictionFeatures

type PredictorClient 

type PredictorClient interface {
	Predict(ctx context.Context, in *PredictRequest, opts ...grpc.CallOption) (*PredictResponse, error)
}

func NewPredictorClient 

func NewPredictorClient(cc *grpc.ClientConn) PredictorClient

type PredictorServer 

type PredictorServer interface {
	Predict(context.Context, *PredictRequest) (*PredictResponse, 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)
}

Source Files

View all Source files

Directories

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.