dlframework

package module
v0.2.23-0...-4aaa12c Latest Latest
Warning

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

 Go to latest Published: May 17, 2020 License: NCSA Imports: 42 Imported by: 41

README

DLFramework

Build Status Build Status

This repo contains common code of MLModelScope agents.

Documentation

Overview

Package dlframework is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

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 (
	ErrInvalidLengthFeatures = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFeatures   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthPredictor = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPredictor   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthRegistry = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRegistry   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	RegistryServiceDescription = _Registry_serviceDesc
	PredictServiceDescription  = _Predict_serviceDesc
)
View Source 
var DefaultModelElementType string = "float32"
View Source 
var ExecutionOptions_TraceLevel_name = map[int32]string{
	0: "NO_TRACE",
	1: "APPLICATION_TRACE",
	2: "MODEL_TRACE",
	3: "FRAMEWORK_TRACE",
	4: "ML_LIBRARY_TRACE",
	5: "SYSTEM_LIBRARY_TRACE",
	6: "HARDWARE_TRACE",
	7: "FULL_TRACE",
}
View Source 
var ExecutionOptions_TraceLevel_value = map[string]int32{
	"NO_TRACE":             0,
	"APPLICATION_TRACE":    1,
	"MODEL_TRACE":          2,
	"FRAMEWORK_TRACE":      3,
	"ML_LIBRARY_TRACE":     4,
	"SYSTEM_LIBRARY_TRACE": 5,
	"HARDWARE_TRACE":       6,
	"FULL_TRACE":           7,
}
View Source 
var FeatureType_name = map[int32]string{
	0:   "UNKNOWN",
	1:   "IMAGE",
	2:   "RAW_IMAGE",
	3:   "CLASSIFICATION",
	4:   "BOUNDINGBOX",
	5:   "SEMANTICSEGMENT",
	6:   "INSTANCESEGMENT",
	7:   "GEOLOCATION",
	8:   "REGION",
	9:   "TEXT",
	10:  "AUDIO",
	100: "RAW",
}
View Source 
var FeatureType_value = map[string]int32{
	"UNKNOWN":         0,
	"IMAGE":           1,
	"RAW_IMAGE":       2,
	"CLASSIFICATION":  3,
	"BOUNDINGBOX":     4,
	"SEMANTICSEGMENT": 5,
	"INSTANCESEGMENT": 6,
	"GEOLOCATION":     7,
	"REGION":          8,
	"TEXT":            9,
	"AUDIO":           10,
	"RAW":             100,
}
View Source 
var Version = "0.2.22"

Functions

func Bhattacharyya 

func Bhattacharyya(p, q []float64) float64

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

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

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

func CleanString 

func CleanString(str string) string

func Correlation 

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

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

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

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

func Covariance 

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

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

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

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

func FeaturesDescription 

func FeaturesDescription() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func Hellinger 

func Hellinger(p, q []float64) float64

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

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

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

func JensenShannon 

func JensenShannon(p, q []float64) float64

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

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

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

func KullbackLeibler 

func KullbackLeibler(p, q []float64) float64

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

sum_i(p_i * log(p_i / q_i))

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

func Mean 

func Mean(x, weights []float64) float64

Mean computes the weighted mean of the data set. 

sum_i {w_i * x_i} / sum_i {w_i}

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

func Partition 

func Partition(in []interface{}, partitionSize int) (out [][]interface{})

func PartitionStringList 

func PartitionStringList(in []string, partitionSize int) (out [][]string)

func PredictorDescription 

func PredictorDescription() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func RegisterPredictHandler 

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

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

func RegisterPredictHandlerClient 

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

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

func RegisterPredictHandlerFromEndpoint 

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 

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

func RegisterRegistryHandler 

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

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

func RegisterRegistryHandlerClient 

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

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

func RegisterRegistryHandlerFromEndpoint 

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

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

func RegisterRegistryServer 

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

func RegisteredFrameworkNames 

func RegisteredFrameworkNames() []string

func RegisteredModelNames 

func RegisteredModelNames() []string

func RegistryDescription 

func RegistryDescription() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func Sum 

func Sum(s []float64) float64

Sum returns the sum of the elements of the slice.

Types

type Agent 

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

func NewPopulatedAgent 

func NewPopulatedAgent(r randyRegistry, easy bool) *Agent

func (*Agent) Description 

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

func (*Agent) Descriptor 

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

func (*Agent) Equal 

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

func (*Agent) GetArchitecture 

func (m *Agent) GetArchitecture() string

func (*Agent) GetCpuinfo 

func (m *Agent) GetCpuinfo() string

func (*Agent) GetFrameworks 

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

func (*Agent) GetGpuinfo 

func (m *Agent) GetGpuinfo() string

func (*Agent) GetHasgpu 

func (m *Agent) GetHasgpu() bool

func (*Agent) GetHost 

func (m *Agent) GetHost() string

func (*Agent) GetHostname 

func (m *Agent) GetHostname() string

func (*Agent) GetMetadata 

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

func (*Agent) GetPort 

func (m *Agent) GetPort() string

func (*Agent) GoString 

func (this *Agent) GoString() string

func (*Agent) Marshal 

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

func (*Agent) MarshalTo 

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

func (*Agent) ProtoMessage 

func (*Agent) ProtoMessage()

func (*Agent) Reset 

func (m *Agent) Reset()

func (*Agent) Size 

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

func (*Agent) String 

func (this *Agent) String() string

func (*Agent) Unmarshal 

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

func (*Agent) VerboseEqual 

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

func (*Agent) XXX_DiscardUnknown 

func (m *Agent) XXX_DiscardUnknown()

func (*Agent) XXX_Marshal 

func (m *Agent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Agent) XXX_Merge 

func (m *Agent) XXX_Merge(src proto.Message)

func (*Agent) XXX_Size 

func (m *Agent) XXX_Size() int

func (*Agent) XXX_Unmarshal 

func (m *Agent) XXX_Unmarshal(b []byte) error

type Agents 

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

func NewPopulatedAgents 

func NewPopulatedAgents(r randyRegistry, easy bool) *Agents

func (*Agents) Description 

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

func (*Agents) Descriptor 

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

func (*Agents) Equal 

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

func (*Agents) GetAgents 

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

func (*Agents) GoString 

func (this *Agents) GoString() string

func (*Agents) Marshal 

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

func (*Agents) MarshalTo 

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

func (*Agents) ProtoMessage 

func (*Agents) ProtoMessage()

func (*Agents) Reset 

func (m *Agents) Reset()

func (*Agents) Size 

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

func (*Agents) String 

func (this *Agents) String() string

func (*Agents) Unmarshal 

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

func (*Agents) VerboseEqual 

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

func (*Agents) XXX_DiscardUnknown 

func (m *Agents) XXX_DiscardUnknown()

func (*Agents) XXX_Marshal 

func (m *Agents) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Agents) XXX_Merge 

func (m *Agents) XXX_Merge(src proto.Message)

func (*Agents) XXX_Size 

func (m *Agents) XXX_Size() int

func (*Agents) XXX_Unmarshal 

func (m *Agents) XXX_Unmarshal(b []byte) error

type Audio 

type Audio struct {
	Data   []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty" yaml:"data,omitempty"`
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty" yaml:"format,omitempty"`
}

func NewPopulatedAudio 

func NewPopulatedAudio(r randyFeatures, easy bool) *Audio

func (*Audio) Description 

func (this *Audio) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*Audio) Descriptor 

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

func (*Audio) Equal 

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

func (*Audio) GetData 

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

func (*Audio) GetFormat 

func (m *Audio) GetFormat() string

func (*Audio) GoString 

func (this *Audio) GoString() string

func (*Audio) Marshal 

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

func (*Audio) MarshalTo 

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

func (*Audio) ProtoMessage 

func (*Audio) ProtoMessage()

func (*Audio) Reset 

func (m *Audio) Reset()

func (*Audio) Size 

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

func (*Audio) String 

func (this *Audio) String() string

func (*Audio) Unmarshal 

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

func (*Audio) VerboseEqual 

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

func (*Audio) XXX_DiscardUnknown 

func (m *Audio) XXX_DiscardUnknown()

func (*Audio) XXX_Marshal 

func (m *Audio) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Audio) XXX_Merge 

func (m *Audio) XXX_Merge(src proto.Message)

func (*Audio) XXX_Size 

func (m *Audio) XXX_Size() int

func (*Audio) XXX_Unmarshal 

func (m *Audio) XXX_Unmarshal(b []byte) error

type BoundingBox 

type BoundingBox struct {
	Index int32   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty" yaml:"index,omitempty"`
	Label string  `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty" yaml:"label,omitempty"`
	Xmin  float32 `protobuf:"fixed32,3,opt,name=xmin,proto3" json:"xmin,omitempty" yaml:"xmin,omitempty"`
	Xmax  float32 `protobuf:"fixed32,4,opt,name=xmax,proto3" json:"xmax,omitempty" yaml:"xmax,omitempty"`
	Ymin  float32 `protobuf:"fixed32,5,opt,name=ymin,proto3" json:"ymin,omitempty" yaml:"ymin,omitempty"`
	Ymax  float32 `protobuf:"fixed32,6,opt,name=ymax,proto3" json:"ymax,omitempty" yaml:"ymax,omitempty"`
}

func NewPopulatedBoundingBox 

func NewPopulatedBoundingBox(r randyFeatures, easy bool) *BoundingBox

func (*BoundingBox) Area 

func (b *BoundingBox) Area() float32

func (*BoundingBox) Description 

func (this *BoundingBox) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*BoundingBox) Descriptor 

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

func (*BoundingBox) Equal 

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

func (*BoundingBox) GetIndex 

func (m *BoundingBox) GetIndex() int32

func (*BoundingBox) GetLabel 

func (m *BoundingBox) GetLabel() string

func (*BoundingBox) GetXmax 

func (m *BoundingBox) GetXmax() float32

func (*BoundingBox) GetXmin 

func (m *BoundingBox) GetXmin() float32

func (*BoundingBox) GetYmax 

func (m *BoundingBox) GetYmax() float32

func (*BoundingBox) GetYmin 

func (m *BoundingBox) GetYmin() float32

func (*BoundingBox) GoString 

func (this *BoundingBox) GoString() string

func (*BoundingBox) Height 

func (b *BoundingBox) Height() float32

func (*BoundingBox) Marshal 

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

func (*BoundingBox) MarshalTo 

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

func (*BoundingBox) ProtoMessage 

func (*BoundingBox) ProtoMessage()

func (*BoundingBox) Reset 

func (m *BoundingBox) Reset()

func (*BoundingBox) Size 

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

func (*BoundingBox) String 

func (this *BoundingBox) String() string

func (*BoundingBox) ToXYWH 

func (b *BoundingBox) ToXYWH() []float32

returns a list of the form [xmin, ymin, width, height]

func (*BoundingBox) ToxyXY 

func (b *BoundingBox) ToxyXY() []float32

returns a list of the form [xmin, ymin, XMAX, YMAX]

func (*BoundingBox) Unmarshal 

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

func (*BoundingBox) VerboseEqual 

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

func (*BoundingBox) Width 

func (b *BoundingBox) Width() float32

func (*BoundingBox) XXX_DiscardUnknown 

func (m *BoundingBox) XXX_DiscardUnknown()

func (*BoundingBox) XXX_Marshal 

func (m *BoundingBox) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BoundingBox) XXX_Merge 

func (m *BoundingBox) XXX_Merge(src proto.Message)

func (*BoundingBox) XXX_Size 

func (m *BoundingBox) XXX_Size() int

func (*BoundingBox) XXX_Unmarshal 

func (m *BoundingBox) XXX_Unmarshal(b []byte) error

type CPUOptions 

type CPUOptions struct {
}

func NewPopulatedCPUOptions 

func NewPopulatedCPUOptions(r randyPredictor, easy bool) *CPUOptions

func (*CPUOptions) Descriptor 

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

func (*CPUOptions) Equal 

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

func (*CPUOptions) GoString 

func (this *CPUOptions) GoString() string

func (*CPUOptions) Marshal 

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

func (*CPUOptions) MarshalTo 

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

func (*CPUOptions) ProtoMessage 

func (*CPUOptions) ProtoMessage()

func (*CPUOptions) Reset 

func (m *CPUOptions) Reset()

func (*CPUOptions) Size 

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

func (*CPUOptions) String 

func (this *CPUOptions) String() string

func (*CPUOptions) Unmarshal 

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

func (*CPUOptions) VerboseEqual 

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

func (*CPUOptions) XXX_DiscardUnknown 

func (m *CPUOptions) XXX_DiscardUnknown()

func (*CPUOptions) XXX_Marshal 

func (m *CPUOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CPUOptions) XXX_Merge 

func (m *CPUOptions) XXX_Merge(src proto.Message)

func (*CPUOptions) XXX_Size 

func (m *CPUOptions) XXX_Size() int

func (*CPUOptions) XXX_Unmarshal 

func (m *CPUOptions) XXX_Unmarshal(b []byte) error

type Classification 

type Classification struct {
	Index int32  `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty" yaml:"index,omitempty"`
	Label string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty" yaml:"label,omitempty"`
}

func NewPopulatedClassification 

func NewPopulatedClassification(r randyFeatures, easy bool) *Classification

func (*Classification) Description 

func (this *Classification) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*Classification) Descriptor 

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

func (*Classification) Equal 

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

func (*Classification) GetIndex 

func (m *Classification) GetIndex() int32

func (*Classification) GetLabel 

func (m *Classification) GetLabel() string

func (*Classification) GoString 

func (this *Classification) GoString() string

func (*Classification) Marshal 

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

func (*Classification) MarshalTo 

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

func (*Classification) ProtoMessage 

func (*Classification) ProtoMessage()

func (*Classification) Reset 

func (m *Classification) Reset()

func (*Classification) Size 

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

func (*Classification) String 

func (this *Classification) String() string

func (*Classification) Unmarshal 

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

func (*Classification) VerboseEqual 

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

func (*Classification) XXX_DiscardUnknown 

func (m *Classification) XXX_DiscardUnknown()

func (*Classification) XXX_Marshal 

func (m *Classification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Classification) XXX_Merge 

func (m *Classification) XXX_Merge(src proto.Message)

func (*Classification) XXX_Size 

func (m *Classification) XXX_Size() int

func (*Classification) XXX_Unmarshal 

func (m *Classification) XXX_Unmarshal(b []byte) 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 

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

func (*ContainerHardware) XXX_DiscardUnknown 

func (m *ContainerHardware) XXX_DiscardUnknown()

func (*ContainerHardware) XXX_Marshal 

func (m *ContainerHardware) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerHardware) XXX_Merge 

func (m *ContainerHardware) XXX_Merge(src proto.Message)

func (*ContainerHardware) XXX_Size 

func (m *ContainerHardware) XXX_Size() int

func (*ContainerHardware) XXX_Unmarshal 

func (m *ContainerHardware) XXX_Unmarshal(b []byte) error

type DatasetRequest 

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

func NewPopulatedDatasetRequest 

func NewPopulatedDatasetRequest(r randyPredictor, easy bool) *DatasetRequest

func (*DatasetRequest) Description 

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

func (*DatasetRequest) Descriptor 

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

func (*DatasetRequest) Equal 

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

func (*DatasetRequest) GetDataset 

func (m *DatasetRequest) GetDataset() *DatasetRequest_Dataset

func (*DatasetRequest) GetOptions 

func (m *DatasetRequest) GetOptions() *PredictionOptions

func (*DatasetRequest) GetPredictor 

func (m *DatasetRequest) GetPredictor() *Predictor

func (*DatasetRequest) GoString 

func (this *DatasetRequest) GoString() string

func (*DatasetRequest) Marshal 

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

func (*DatasetRequest) MarshalTo 

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

func (*DatasetRequest) ProtoMessage 

func (*DatasetRequest) ProtoMessage()

func (*DatasetRequest) Reset 

func (m *DatasetRequest) Reset()

func (*DatasetRequest) Size 

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

func (*DatasetRequest) String 

func (this *DatasetRequest) String() string

func (*DatasetRequest) Unmarshal 

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

func (*DatasetRequest) VerboseEqual 

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

func (*DatasetRequest) XXX_DiscardUnknown 

func (m *DatasetRequest) XXX_DiscardUnknown()

func (*DatasetRequest) XXX_Marshal 

func (m *DatasetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatasetRequest) XXX_Merge 

func (m *DatasetRequest) XXX_Merge(src proto.Message)

func (*DatasetRequest) XXX_Size 

func (m *DatasetRequest) XXX_Size() int

func (*DatasetRequest) XXX_Unmarshal 

func (m *DatasetRequest) XXX_Unmarshal(b []byte) error

type DatasetRequest_Dataset 

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 

func NewPopulatedDatasetRequest_Dataset(r randyPredictor, easy bool) *DatasetRequest_Dataset

func (*DatasetRequest_Dataset) Descriptor 

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

func (*DatasetRequest_Dataset) Equal 

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

func (*DatasetRequest_Dataset) GetCategory 

func (m *DatasetRequest_Dataset) GetCategory() string

func (*DatasetRequest_Dataset) GetName 

func (m *DatasetRequest_Dataset) GetName() string

func (*DatasetRequest_Dataset) GoString 

func (this *DatasetRequest_Dataset) GoString() string

func (*DatasetRequest_Dataset) Marshal 

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

func (*DatasetRequest_Dataset) MarshalTo 

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

func (*DatasetRequest_Dataset) ProtoMessage 

func (*DatasetRequest_Dataset) ProtoMessage()

func (*DatasetRequest_Dataset) Reset 

func (m *DatasetRequest_Dataset) Reset()

func (*DatasetRequest_Dataset) Size 

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

func (*DatasetRequest_Dataset) String 

func (this *DatasetRequest_Dataset) String() string

func (*DatasetRequest_Dataset) Unmarshal 

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

func (*DatasetRequest_Dataset) VerboseEqual 

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

func (*DatasetRequest_Dataset) XXX_DiscardUnknown 

func (m *DatasetRequest_Dataset) XXX_DiscardUnknown()

func (*DatasetRequest_Dataset) XXX_Marshal 

func (m *DatasetRequest_Dataset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DatasetRequest_Dataset) XXX_Merge 

func (m *DatasetRequest_Dataset) XXX_Merge(src proto.Message)

func (*DatasetRequest_Dataset) XXX_Size 

func (m *DatasetRequest_Dataset) XXX_Size() int

func (*DatasetRequest_Dataset) XXX_Unmarshal 

func (m *DatasetRequest_Dataset) XXX_Unmarshal(b []byte) 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 

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) 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

func (*ErrorStatus) XXX_DiscardUnknown 

func (m *ErrorStatus) XXX_DiscardUnknown()

func (*ErrorStatus) XXX_Marshal 

func (m *ErrorStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorStatus) XXX_Merge 

func (m *ErrorStatus) XXX_Merge(src proto.Message)

func (*ErrorStatus) XXX_Size 

func (m *ErrorStatus) XXX_Size() int

func (*ErrorStatus) XXX_Unmarshal 

func (m *ErrorStatus) XXX_Unmarshal(b []byte) error

type ExecutionOptions 

type ExecutionOptions struct {
	TraceId    *TraceID                    `protobuf:"bytes,1,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty" yaml:"trace_id,omitempty"`
	TraceLevel ExecutionOptions_TraceLevel `` /* 183-byte string literal not displayed */
	// Time to wait for operation to complete in milliseconds.
	TimeoutInMs uint64 `` /* 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 `` /* 213-byte string literal not displayed */
	// Options that apply to all CPUs.
	CpuOptions *CPUOptions `protobuf:"bytes,5,opt,name=cpu_options,json=cpuOptions,proto3" json:"cpu_options,omitempty" yaml:"cpu_options,omitempty"`
	// Options that apply to all GPUs.
	GpuOptions *GPUOptions `protobuf:"bytes,6,opt,name=gpu_options,json=gpuOptions,proto3" json:"gpu_options,omitempty" yaml:"gpu_options,omitempty"`
}

func NewPopulatedExecutionOptions 

func NewPopulatedExecutionOptions(r randyPredictor, easy bool) *ExecutionOptions

func (*ExecutionOptions) Descriptor 

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

func (*ExecutionOptions) Equal 

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

func (*ExecutionOptions) GetCpuOptions 

func (m *ExecutionOptions) GetCpuOptions() *CPUOptions

func (*ExecutionOptions) GetDeviceCount 

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

func (*ExecutionOptions) GetGpuOptions 

func (m *ExecutionOptions) GetGpuOptions() *GPUOptions

func (*ExecutionOptions) GetTimeoutInMs 

func (m *ExecutionOptions) GetTimeoutInMs() uint64

func (*ExecutionOptions) GetTraceId 

func (m *ExecutionOptions) GetTraceId() *TraceID

func (*ExecutionOptions) GetTraceLevel 

func (m *ExecutionOptions) GetTraceLevel() ExecutionOptions_TraceLevel

func (*ExecutionOptions) GoString 

func (this *ExecutionOptions) GoString() string

func (*ExecutionOptions) Marshal 

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

func (*ExecutionOptions) MarshalTo 

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

func (*ExecutionOptions) ProtoMessage 

func (*ExecutionOptions) ProtoMessage()

func (*ExecutionOptions) Reset 

func (m *ExecutionOptions) Reset()

func (*ExecutionOptions) Size 

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

func (*ExecutionOptions) String 

func (this *ExecutionOptions) String() string

func (*ExecutionOptions) Unmarshal 

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

func (*ExecutionOptions) VerboseEqual 

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

func (*ExecutionOptions) XXX_DiscardUnknown 

func (m *ExecutionOptions) XXX_DiscardUnknown()

func (*ExecutionOptions) XXX_Marshal 

func (m *ExecutionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionOptions) XXX_Merge 

func (m *ExecutionOptions) XXX_Merge(src proto.Message)

func (*ExecutionOptions) XXX_Size 

func (m *ExecutionOptions) XXX_Size() int

func (*ExecutionOptions) XXX_Unmarshal 

func (m *ExecutionOptions) XXX_Unmarshal(b []byte) error

type ExecutionOptions_TraceLevel 

type ExecutionOptions_TraceLevel int32
const (
	ExecutionOptions_NO_TRACE             ExecutionOptions_TraceLevel = 0
	ExecutionOptions_APPLICATION_TRACE    ExecutionOptions_TraceLevel = 1
	ExecutionOptions_MODEL_TRACE          ExecutionOptions_TraceLevel = 2
	ExecutionOptions_FRAMEWORK_TRACE      ExecutionOptions_TraceLevel = 3
	ExecutionOptions_ML_LIBRARY_TRACE     ExecutionOptions_TraceLevel = 4
	ExecutionOptions_SYSTEM_LIBRARY_TRACE ExecutionOptions_TraceLevel = 5
	ExecutionOptions_HARDWARE_TRACE       ExecutionOptions_TraceLevel = 6
	ExecutionOptions_FULL_TRACE           ExecutionOptions_TraceLevel = 7
)

func (ExecutionOptions_TraceLevel) EnumDescriptor 

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

func (ExecutionOptions_TraceLevel) String 

func (x ExecutionOptions_TraceLevel) String() string

type Feature 

type Feature struct {
	ID          string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	Type        FeatureType       `` /* 130-byte string literal not displayed */
	Probability float32           `protobuf:"fixed32,4,opt,name=probability,proto3" json:"probability,omitempty" yaml:"probability,omitempty"`
	Metadata    map[string]string `` /* 183-byte string literal not displayed */
	// Types that are valid to be assigned to Feature:
	//	*Feature_Image
	//	*Feature_RawImage
	//	*Feature_Classification
	//	*Feature_BoundingBox
	//	*Feature_SemanticSegment
	//	*Feature_InstanceSegment
	//	*Feature_Text
	//	*Feature_Region
	//	*Feature_Audio
	//	*Feature_Geolocation
	//	*Feature_Raw
	Feature isFeature_Feature `protobuf_oneof:"feature"`
}

func NewPopulatedFeature 

func NewPopulatedFeature(r randyFeatures, easy bool) *Feature

func (*Feature) Description 

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

func (*Feature) Descriptor 

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

func (*Feature) Equal 

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

func (*Feature) GetAudio 

func (m *Feature) GetAudio() *Audio

func (*Feature) GetBoundingBox 

func (m *Feature) GetBoundingBox() *BoundingBox

func (*Feature) GetClassification 

func (m *Feature) GetClassification() *Classification

func (*Feature) GetFeature 

func (m *Feature) GetFeature() isFeature_Feature

func (*Feature) GetGeolocation 

func (m *Feature) GetGeolocation() *GeoLocation

func (*Feature) GetID 

func (m *Feature) GetID() string

func (*Feature) GetImage 

func (m *Feature) GetImage() *Image

func (*Feature) GetInstanceSegment 

func (m *Feature) GetInstanceSegment() *InstanceSegment

func (*Feature) GetMetadata 

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

func (*Feature) GetProbability 

func (m *Feature) GetProbability() float32

func (*Feature) GetRaw 

func (m *Feature) GetRaw() *Raw

func (*Feature) GetRawImage 

func (m *Feature) GetRawImage() *RawImage

func (*Feature) GetRegion 

func (m *Feature) GetRegion() *Region

func (*Feature) GetSemanticSegment 

func (m *Feature) GetSemanticSegment() *SemanticSegment

func (*Feature) GetText 

func (m *Feature) GetText() *Text

func (*Feature) GetType 

func (m *Feature) GetType() FeatureType

func (*Feature) GoString 

func (this *Feature) GoString() string

func (*Feature) Marshal 

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

func (*Feature) MarshalTo 

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

func (*Feature) ProtoMessage 

func (*Feature) ProtoMessage()

func (*Feature) Reset 

func (m *Feature) Reset()

func (*Feature) Size 

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

func (*Feature) String 

func (this *Feature) String() string

func (*Feature) Unmarshal 

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

func (*Feature) VerboseEqual 

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

func (*Feature) XXX_DiscardUnknown 

func (m *Feature) XXX_DiscardUnknown()

func (*Feature) XXX_Marshal 

func (m *Feature) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Feature) XXX_Merge 

func (m *Feature) XXX_Merge(src proto.Message)

func (*Feature) XXX_OneofFuncs 

func (*Feature) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Feature) XXX_Size 

func (m *Feature) XXX_Size() int

func (*Feature) XXX_Unmarshal 

func (m *Feature) XXX_Unmarshal(b []byte) error

type FeatureCompareMethod 

type FeatureCompareMethod int
const (
	FeatureCompuareAutomatic FeatureCompareMethod = iota
	FeatureCompareTextEditDistance
	FeatureCompareBoundingBoxIOU
)

func FeatureCompareMethodString 

func FeatureCompareMethodString(s string) (FeatureCompareMethod, error)

FeatureCompareMethodString retrieves an enum value from the enum constants string name. Throws an error if the param is not part of the enum.

func FeatureCompareMethodValues 

func FeatureCompareMethodValues() []FeatureCompareMethod

FeatureCompareMethodValues returns all values of the enum

func (FeatureCompareMethod) IsAFeatureCompareMethod 

func (i FeatureCompareMethod) IsAFeatureCompareMethod() bool

IsAFeatureCompareMethod returns "true" if the value is listed in the enum definition. "false" otherwise

func (FeatureCompareMethod) MarshalJSON 

func (i FeatureCompareMethod) MarshalJSON() ([]byte, error)

MarshalJSON implements the json.Marshaler interface for FeatureCompareMethod

func (FeatureCompareMethod) String 

func (i FeatureCompareMethod) String() string

func (*FeatureCompareMethod) UnmarshalJSON 

func (i *FeatureCompareMethod) UnmarshalJSON(data []byte) error

UnmarshalJSON implements the json.Unmarshaler interface for FeatureCompareMethod

type FeatureResponse 

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,proto3" json:"features,omitempty" yaml:"features,omitempty"`
	Metadata  map[string]string `` /* 183-byte string literal not displayed */
}

func NewPopulatedFeatureResponse 

func NewPopulatedFeatureResponse(r randyPredictor, easy bool) *FeatureResponse

func (*FeatureResponse) Description 

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

func (*FeatureResponse) Descriptor 

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

func (*FeatureResponse) Equal 

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

func (*FeatureResponse) GetFeatures 

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

func (*FeatureResponse) GetID 

func (m *FeatureResponse) GetID() string

func (*FeatureResponse) GetInputID 

func (m *FeatureResponse) GetInputID() string

func (*FeatureResponse) GetMetadata 

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

func (*FeatureResponse) GetRequestID 

func (m *FeatureResponse) GetRequestID() string

func (*FeatureResponse) GoString 

func (this *FeatureResponse) GoString() string

func (*FeatureResponse) Marshal 

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

func (*FeatureResponse) MarshalTo 

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

func (*FeatureResponse) ProtoMessage 

func (*FeatureResponse) ProtoMessage()

func (*FeatureResponse) Reset 

func (m *FeatureResponse) Reset()

func (*FeatureResponse) Size 

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

func (*FeatureResponse) String 

func (this *FeatureResponse) String() string

func (*FeatureResponse) Unmarshal 

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

func (*FeatureResponse) VerboseEqual 

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

func (*FeatureResponse) XXX_DiscardUnknown 

func (m *FeatureResponse) XXX_DiscardUnknown()

func (*FeatureResponse) XXX_Marshal 

func (m *FeatureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeatureResponse) XXX_Merge 

func (m *FeatureResponse) XXX_Merge(src proto.Message)

func (*FeatureResponse) XXX_Size 

func (m *FeatureResponse) XXX_Size() int

func (*FeatureResponse) XXX_Unmarshal 

func (m *FeatureResponse) XXX_Unmarshal(b []byte) error

type FeatureType 

type FeatureType int32
const (
	FeatureType_UNKNOWN         FeatureType = 0
	FeatureType_IMAGE           FeatureType = 1
	FeatureType_RAW_IMAGE       FeatureType = 2
	FeatureType_CLASSIFICATION  FeatureType = 3
	FeatureType_BOUNDINGBOX     FeatureType = 4
	FeatureType_SEMANTICSEGMENT FeatureType = 5
	FeatureType_INSTANCESEGMENT FeatureType = 6
	FeatureType_GEOLOCATION     FeatureType = 7
	FeatureType_REGION          FeatureType = 8
	FeatureType_TEXT            FeatureType = 9
	FeatureType_AUDIO           FeatureType = 10
	FeatureType_RAW             FeatureType = 100
)

func (FeatureType) EnumDescriptor 

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

func (FeatureType) String 

func (x FeatureType) String() string

type Feature_Audio 

type Feature_Audio struct {
	Audio *Audio `protobuf:"bytes,14,opt,name=audio,proto3,oneof"`
}

func NewPopulatedFeature_Audio 

func NewPopulatedFeature_Audio(r randyFeatures, easy bool) *Feature_Audio

func (*Feature_Audio) Equal 

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

func (*Feature_Audio) GoString 

func (this *Feature_Audio) GoString() string

func (*Feature_Audio) MarshalTo 

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

func (*Feature_Audio) Size 

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

func (*Feature_Audio) String 

func (this *Feature_Audio) String() string

func (*Feature_Audio) VerboseEqual 

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

type Feature_BoundingBox 

type Feature_BoundingBox struct {
	BoundingBox *BoundingBox `protobuf:"bytes,9,opt,name=bounding_box,json=boundingBox,proto3,oneof"`
}

func NewPopulatedFeature_BoundingBox 

func NewPopulatedFeature_BoundingBox(r randyFeatures, easy bool) *Feature_BoundingBox

func (*Feature_BoundingBox) Equal 

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

func (*Feature_BoundingBox) GoString 

func (this *Feature_BoundingBox) GoString() string

func (*Feature_BoundingBox) MarshalTo 

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

func (*Feature_BoundingBox) Size 

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

func (*Feature_BoundingBox) String 

func (this *Feature_BoundingBox) String() string

func (*Feature_BoundingBox) VerboseEqual 

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

type Feature_Classification 

type Feature_Classification struct {
	Classification *Classification `protobuf:"bytes,8,opt,name=classification,proto3,oneof"`
}

func NewPopulatedFeature_Classification 

func NewPopulatedFeature_Classification(r randyFeatures, easy bool) *Feature_Classification

func (*Feature_Classification) Equal 

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

func (*Feature_Classification) GoString 

func (this *Feature_Classification) GoString() string

func (*Feature_Classification) MarshalTo 

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

func (*Feature_Classification) Size 

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

func (*Feature_Classification) String 

func (this *Feature_Classification) String() string

func (*Feature_Classification) VerboseEqual 

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

type Feature_Geolocation 

type Feature_Geolocation struct {
	Geolocation *GeoLocation `protobuf:"bytes,15,opt,name=geolocation,proto3,oneof"`
}

func NewPopulatedFeature_Geolocation 

func NewPopulatedFeature_Geolocation(r randyFeatures, easy bool) *Feature_Geolocation

func (*Feature_Geolocation) Equal 

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

func (*Feature_Geolocation) GoString 

func (this *Feature_Geolocation) GoString() string

func (*Feature_Geolocation) MarshalTo 

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

func (*Feature_Geolocation) Size 

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

func (*Feature_Geolocation) String 

func (this *Feature_Geolocation) String() string

func (*Feature_Geolocation) VerboseEqual 

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

type Feature_Image 

type Feature_Image struct {
	Image *Image `protobuf:"bytes,6,opt,name=image,proto3,oneof"`
}

func NewPopulatedFeature_Image 

func NewPopulatedFeature_Image(r randyFeatures, easy bool) *Feature_Image

func (*Feature_Image) Equal 

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

func (*Feature_Image) GoString 

func (this *Feature_Image) GoString() string

func (*Feature_Image) MarshalTo 

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

func (*Feature_Image) Size 

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

func (*Feature_Image) String 

func (this *Feature_Image) String() string

func (*Feature_Image) VerboseEqual 

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

type Feature_InstanceSegment 

type Feature_InstanceSegment struct {
	InstanceSegment *InstanceSegment `protobuf:"bytes,11,opt,name=instance_segment,json=instanceSegment,proto3,oneof"`
}

func NewPopulatedFeature_InstanceSegment 

func NewPopulatedFeature_InstanceSegment(r randyFeatures, easy bool) *Feature_InstanceSegment

func (*Feature_InstanceSegment) Equal 

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

func (*Feature_InstanceSegment) GoString 

func (this *Feature_InstanceSegment) GoString() string

func (*Feature_InstanceSegment) MarshalTo 

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

func (*Feature_InstanceSegment) Size 

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

func (*Feature_InstanceSegment) String 

func (this *Feature_InstanceSegment) String() string

func (*Feature_InstanceSegment) VerboseEqual 

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

type Feature_Raw 

type Feature_Raw struct {
	Raw *Raw `protobuf:"bytes,1000,opt,name=raw,proto3,oneof"`
}

func NewPopulatedFeature_Raw 

func NewPopulatedFeature_Raw(r randyFeatures, easy bool) *Feature_Raw

func (*Feature_Raw) Equal 

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

func (*Feature_Raw) GoString 

func (this *Feature_Raw) GoString() string

func (*Feature_Raw) MarshalTo 

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

func (*Feature_Raw) Size 

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

func (*Feature_Raw) String 

func (this *Feature_Raw) String() string

func (*Feature_Raw) VerboseEqual 

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

type Feature_RawImage 

type Feature_RawImage struct {
	RawImage *RawImage `protobuf:"bytes,7,opt,name=raw_image,json=rawImage,proto3,oneof"`
}

func NewPopulatedFeature_RawImage 

func NewPopulatedFeature_RawImage(r randyFeatures, easy bool) *Feature_RawImage

func (*Feature_RawImage) Equal 

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

func (*Feature_RawImage) GoString 

func (this *Feature_RawImage) GoString() string

func (*Feature_RawImage) MarshalTo 

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

func (*Feature_RawImage) Size 

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

func (*Feature_RawImage) String 

func (this *Feature_RawImage) String() string

func (*Feature_RawImage) VerboseEqual 

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

type Feature_Region 

type Feature_Region struct {
	Region *Region `protobuf:"bytes,13,opt,name=region,proto3,oneof"`
}

func NewPopulatedFeature_Region 

func NewPopulatedFeature_Region(r randyFeatures, easy bool) *Feature_Region

func (*Feature_Region) Equal 

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

func (*Feature_Region) GoString 

func (this *Feature_Region) GoString() string

func (*Feature_Region) MarshalTo 

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

func (*Feature_Region) Size 

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

func (*Feature_Region) String 

func (this *Feature_Region) String() string

func (*Feature_Region) VerboseEqual 

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

type Feature_SemanticSegment 

type Feature_SemanticSegment struct {
	SemanticSegment *SemanticSegment `protobuf:"bytes,10,opt,name=semantic_segment,json=semanticSegment,proto3,oneof"`
}

func NewPopulatedFeature_SemanticSegment 

func NewPopulatedFeature_SemanticSegment(r randyFeatures, easy bool) *Feature_SemanticSegment

func (*Feature_SemanticSegment) Equal 

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

func (*Feature_SemanticSegment) GoString 

func (this *Feature_SemanticSegment) GoString() string

func (*Feature_SemanticSegment) MarshalTo 

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

func (*Feature_SemanticSegment) Size 

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

func (*Feature_SemanticSegment) String 

func (this *Feature_SemanticSegment) String() string

func (*Feature_SemanticSegment) VerboseEqual 

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

type Feature_Text 

type Feature_Text struct {
	Text *Text `protobuf:"bytes,12,opt,name=text,proto3,oneof"`
}

func NewPopulatedFeature_Text 

func NewPopulatedFeature_Text(r randyFeatures, easy bool) *Feature_Text

func (*Feature_Text) Equal 

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

func (*Feature_Text) GoString 

func (this *Feature_Text) GoString() string

func (*Feature_Text) MarshalTo 

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

func (*Feature_Text) Size 

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

func (*Feature_Text) String 

func (this *Feature_Text) String() string

func (*Feature_Text) VerboseEqual 

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

type Features 

type Features []*Feature

func (Features) Bhattacharyya 

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

func (Features) Correlation 

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

func (Features) Covariance 

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

func (Features) Hellinger 

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

func (Features) JensenShannon 

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

func (Features) KullbackLeiblerDivergence 

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

func (Features) Len 

func (p Features) Len() int

Len is the number of elements in the collection.

func (Features) Less 

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

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

func (Features) ProbabilitiesApplySoftmaxFloat32 

func (p Features) ProbabilitiesApplySoftmaxFloat32() Features

func (Features) ProbabilitiesApplySoftmaxFloat64 

func (p Features) ProbabilitiesApplySoftmaxFloat64() Features

func (Features) ProbabilitiesFloat32 

func (p Features) ProbabilitiesFloat32() []float32

func (Features) ProbabilitiesFloat64 

func (p Features) ProbabilitiesFloat64() []float64

func (Features) ProbabilitiesSoftmaxFloat32 

func (p Features) ProbabilitiesSoftmaxFloat32() []float32

func (Features) ProbabilitiesSoftmaxFloat64 

func (p Features) ProbabilitiesSoftmaxFloat64() []float64

func (Features) Sort 

func (p Features) Sort()

func (Features) Swap 

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

Swap swaps the elements with indexes i and j.

func (Features) Take 

func (p Features) Take(n int) Features

type FeaturesResponse 

type FeaturesResponse struct {
	ID                   string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	TraceId              *TraceID           `protobuf:"bytes,2,opt,name=trace_id,json=traceId,proto3" json:"trace_id,omitempty" yaml:"trace_id,omitempty"`
	Responses            []*FeatureResponse `protobuf:"bytes,3,rep,name=responses,proto3" json:"responses,omitempty" yaml:"responses,omitempty"`
	DurationForInference *time.Duration     `` /* 175-byte string literal not displayed */
	Duration             *time.Duration     `protobuf:"bytes,5,opt,name=duration,proto3,stdduration" json:"duration,omitempty" yaml:"duration,omitempty"`
}

func NewPopulatedFeaturesResponse 

func NewPopulatedFeaturesResponse(r randyPredictor, easy bool) *FeaturesResponse

func (*FeaturesResponse) Description 

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

func (*FeaturesResponse) Descriptor 

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

func (*FeaturesResponse) Equal 

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

func (*FeaturesResponse) GetDuration 

func (m *FeaturesResponse) GetDuration() *time.Duration

func (*FeaturesResponse) GetDurationForInference 

func (m *FeaturesResponse) GetDurationForInference() *time.Duration

func (*FeaturesResponse) GetID 

func (m *FeaturesResponse) GetID() string

func (*FeaturesResponse) GetResponses 

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

func (*FeaturesResponse) GetTraceId 

func (m *FeaturesResponse) GetTraceId() *TraceID

func (*FeaturesResponse) GoString 

func (this *FeaturesResponse) GoString() string

func (*FeaturesResponse) Marshal 

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

func (*FeaturesResponse) MarshalTo 

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

func (*FeaturesResponse) ProtoMessage 

func (*FeaturesResponse) ProtoMessage()

func (*FeaturesResponse) Reset 

func (m *FeaturesResponse) Reset()

func (*FeaturesResponse) Size 

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

func (*FeaturesResponse) String 

func (this *FeaturesResponse) String() string

func (*FeaturesResponse) Unmarshal 

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

func (*FeaturesResponse) VerboseEqual 

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

func (*FeaturesResponse) XXX_DiscardUnknown 

func (m *FeaturesResponse) XXX_DiscardUnknown()

func (*FeaturesResponse) XXX_Marshal 

func (m *FeaturesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeaturesResponse) XXX_Merge 

func (m *FeaturesResponse) XXX_Merge(src proto.Message)

func (*FeaturesResponse) XXX_Size 

func (m *FeaturesResponse) XXX_Size() int

func (*FeaturesResponse) XXX_Unmarshal 

func (m *FeaturesResponse) XXX_Unmarshal(b []byte) 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 `` /* 186-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 

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)

func (*FrameworkManifest) XXX_DiscardUnknown 

func (m *FrameworkManifest) XXX_DiscardUnknown()

func (*FrameworkManifest) XXX_Marshal 

func (m *FrameworkManifest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrameworkManifest) XXX_Merge 

func (m *FrameworkManifest) XXX_Merge(src proto.Message)

func (*FrameworkManifest) XXX_Size 

func (m *FrameworkManifest) XXX_Size() int

func (*FrameworkManifest) XXX_Unmarshal 

func (m *FrameworkManifest) XXX_Unmarshal(b []byte) error

type FrameworkManifestsResponse 

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

func NewPopulatedFrameworkManifestsResponse 

func NewPopulatedFrameworkManifestsResponse(r randyRegistry, easy bool) *FrameworkManifestsResponse

func (*FrameworkManifestsResponse) Description 

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

func (*FrameworkManifestsResponse) XXX_DiscardUnknown 

func (m *FrameworkManifestsResponse) XXX_DiscardUnknown()

func (*FrameworkManifestsResponse) XXX_Marshal 

func (m *FrameworkManifestsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrameworkManifestsResponse) XXX_Merge 

func (m *FrameworkManifestsResponse) XXX_Merge(src proto.Message)

func (*FrameworkManifestsResponse) XXX_Size 

func (m *FrameworkManifestsResponse) XXX_Size() int

func (*FrameworkManifestsResponse) XXX_Unmarshal 

func (m *FrameworkManifestsResponse) XXX_Unmarshal(b []byte) 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 

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) 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

func (*FrameworkRequest) XXX_DiscardUnknown 

func (m *FrameworkRequest) XXX_DiscardUnknown()

func (*FrameworkRequest) XXX_Marshal 

func (m *FrameworkRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FrameworkRequest) XXX_Merge 

func (m *FrameworkRequest) XXX_Merge(src proto.Message)

func (*FrameworkRequest) XXX_Size 

func (m *FrameworkRequest) XXX_Size() int

func (*FrameworkRequest) XXX_Unmarshal 

func (m *FrameworkRequest) XXX_Unmarshal(b []byte) error

type GPUOptions 

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 

func NewPopulatedGPUOptions(r randyPredictor, easy bool) *GPUOptions

func (*GPUOptions) Descriptor 

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

func (*GPUOptions) Equal 

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

func (*GPUOptions) GetAllocatorType 

func (m *GPUOptions) GetAllocatorType() string

func (*GPUOptions) GetForceGpuCompatible 

func (m *GPUOptions) GetForceGpuCompatible() bool

func (*GPUOptions) GetPerProcessGpuMemoryFraction 

func (m *GPUOptions) GetPerProcessGpuMemoryFraction() float64

func (*GPUOptions) GetVisibleDeviceList 

func (m *GPUOptions) GetVisibleDeviceList() string

func (*GPUOptions) GoString 

func (this *GPUOptions) GoString() string

func (*GPUOptions) Marshal 

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

func (*GPUOptions) MarshalTo 

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

func (*GPUOptions) ProtoMessage 

func (*GPUOptions) ProtoMessage()

func (*GPUOptions) Reset 

func (m *GPUOptions) Reset()

func (*GPUOptions) Size 

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

func (*GPUOptions) String 

func (this *GPUOptions) String() string

func (*GPUOptions) Unmarshal 

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

func (*GPUOptions) VerboseEqual 

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

func (*GPUOptions) XXX_DiscardUnknown 

func (m *GPUOptions) XXX_DiscardUnknown()

func (*GPUOptions) XXX_Marshal 

func (m *GPUOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GPUOptions) XXX_Merge 

func (m *GPUOptions) XXX_Merge(src proto.Message)

func (*GPUOptions) XXX_Size 

func (m *GPUOptions) XXX_Size() int

func (*GPUOptions) XXX_Unmarshal 

func (m *GPUOptions) XXX_Unmarshal(b []byte) error

type GeoLocation 

type GeoLocation struct {
	Index     int32   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty" yaml:"index,omitempty"`
	Latitude  float32 `protobuf:"fixed32,2,opt,name=latitude,proto3" json:"latitude,omitempty" yaml:"latitude,omitempty"`
	Longitude float32 `protobuf:"fixed32,3,opt,name=longitude,proto3" json:"longitude,omitempty" yaml:"longitude,omitempty"`
}

func NewPopulatedGeoLocation 

func NewPopulatedGeoLocation(r randyFeatures, easy bool) *GeoLocation

func (*GeoLocation) Description 

func (this *GeoLocation) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*GeoLocation) Descriptor 

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

func (*GeoLocation) Equal 

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

func (*GeoLocation) GetIndex 

func (m *GeoLocation) GetIndex() int32

func (*GeoLocation) GetLatitude 

func (m *GeoLocation) GetLatitude() float32

func (*GeoLocation) GetLongitude 

func (m *GeoLocation) GetLongitude() float32

func (*GeoLocation) GoString 

func (this *GeoLocation) GoString() string

func (*GeoLocation) Marshal 

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

func (*GeoLocation) MarshalTo 

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

func (*GeoLocation) ProtoMessage 

func (*GeoLocation) ProtoMessage()

func (*GeoLocation) Reset 

func (m *GeoLocation) Reset()

func (*GeoLocation) Size 

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

func (*GeoLocation) String 

func (this *GeoLocation) String() string

func (*GeoLocation) Unmarshal 

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

func (*GeoLocation) VerboseEqual 

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

func (*GeoLocation) XXX_DiscardUnknown 

func (m *GeoLocation) XXX_DiscardUnknown()

func (*GeoLocation) XXX_Marshal 

func (m *GeoLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GeoLocation) XXX_Merge 

func (m *GeoLocation) XXX_Merge(src proto.Message)

func (*GeoLocation) XXX_Size 

func (m *GeoLocation) XXX_Size() int

func (*GeoLocation) XXX_Unmarshal 

func (m *GeoLocation) XXX_Unmarshal(b []byte) error

type Image 

type 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 NewPopulatedImage 

func NewPopulatedImage(r randyFeatures, easy bool) *Image

func (*Image) Descriptor 

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

func (*Image) Equal 

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

func (*Image) GetData 

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

func (*Image) GetID 

func (m *Image) GetID() string

func (*Image) GoString 

func (this *Image) GoString() string

func (*Image) Marshal 

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

func (*Image) MarshalTo 

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

func (*Image) ProtoMessage 

func (*Image) ProtoMessage()

func (*Image) Reset 

func (m *Image) Reset()

func (*Image) Size 

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

func (*Image) String 

func (this *Image) String() string

func (*Image) Unmarshal 

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

func (*Image) VerboseEqual 

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

func (*Image) XXX_DiscardUnknown 

func (m *Image) XXX_DiscardUnknown()

func (*Image) XXX_Marshal 

func (m *Image) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Image) XXX_Merge 

func (m *Image) XXX_Merge(src proto.Message)

func (*Image) XXX_Size 

func (m *Image) XXX_Size() int

func (*Image) XXX_Unmarshal 

func (m *Image) XXX_Unmarshal(b []byte) error

type ImagesRequest 

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

func NewPopulatedImagesRequest 

func NewPopulatedImagesRequest(r randyPredictor, easy bool) *ImagesRequest

func (*ImagesRequest) Description 

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

func (*ImagesRequest) Descriptor 

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

func (*ImagesRequest) Equal 

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

func (*ImagesRequest) GetImages 

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

func (*ImagesRequest) GetOptions 

func (m *ImagesRequest) GetOptions() *PredictionOptions

func (*ImagesRequest) GetPredictor 

func (m *ImagesRequest) GetPredictor() *Predictor

func (*ImagesRequest) GoString 

func (this *ImagesRequest) GoString() string

func (*ImagesRequest) Marshal 

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

func (*ImagesRequest) MarshalTo 

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

func (*ImagesRequest) ProtoMessage 

func (*ImagesRequest) ProtoMessage()

func (*ImagesRequest) Reset 

func (m *ImagesRequest) Reset()

func (*ImagesRequest) Size 

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

func (*ImagesRequest) String 

func (this *ImagesRequest) String() string

func (*ImagesRequest) Unmarshal 

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

func (*ImagesRequest) VerboseEqual 

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

func (*ImagesRequest) XXX_DiscardUnknown 

func (m *ImagesRequest) XXX_DiscardUnknown()

func (*ImagesRequest) XXX_Marshal 

func (m *ImagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ImagesRequest) XXX_Merge 

func (m *ImagesRequest) XXX_Merge(src proto.Message)

func (*ImagesRequest) XXX_Size 

func (m *ImagesRequest) XXX_Size() int

func (*ImagesRequest) XXX_Unmarshal 

func (m *ImagesRequest) XXX_Unmarshal(b []byte) error

type InstanceSegment 

type InstanceSegment struct {
	Index     int32     `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty" yaml:"index,omitempty"`
	Label     string    `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty" yaml:"label,omitempty"`
	Xmin      float32   `protobuf:"fixed32,3,opt,name=xmin,proto3" json:"xmin,omitempty" yaml:"xmin,omitempty"`
	Xmax      float32   `protobuf:"fixed32,4,opt,name=xmax,proto3" json:"xmax,omitempty" yaml:"xmax,omitempty"`
	Ymin      float32   `protobuf:"fixed32,5,opt,name=ymin,proto3" json:"ymin,omitempty" yaml:"ymin,omitempty"`
	Ymax      float32   `protobuf:"fixed32,6,opt,name=ymax,proto3" json:"ymax,omitempty" yaml:"ymax,omitempty"`
	MaskType  string    `protobuf:"bytes,7,opt,name=mask_type,json=maskType,proto3" json:"mask_type,omitempty" yaml:"mask_type,omitempty"`
	Height    int32     `protobuf:"varint,8,opt,name=height,proto3" json:"height,omitempty" yaml:"height,omitempty"`
	Width     int32     `protobuf:"varint,9,opt,name=width,proto3" json:"width,omitempty" yaml:"width,omitempty"`
	IntMask   []int32   `protobuf:"varint,10,rep,packed,name=int_mask,json=intMask,proto3" json:"int_mask,omitempty" yaml:"int_mask,omitempty"`
	FloatMask []float32 `` /* 126-byte string literal not displayed */
}

func NewPopulatedInstanceSegment 

func NewPopulatedInstanceSegment(r randyFeatures, easy bool) *InstanceSegment

func (*InstanceSegment) Description 

func (this *InstanceSegment) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*InstanceSegment) Descriptor 

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

func (*InstanceSegment) Equal 

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

func (*InstanceSegment) GetFloatMask 

func (m *InstanceSegment) GetFloatMask() []float32

func (*InstanceSegment) GetHeight 

func (m *InstanceSegment) GetHeight() int32

func (*InstanceSegment) GetIndex 

func (m *InstanceSegment) GetIndex() int32

func (*InstanceSegment) GetIntMask 

func (m *InstanceSegment) GetIntMask() []int32

func (*InstanceSegment) GetLabel 

func (m *InstanceSegment) GetLabel() string

func (*InstanceSegment) GetMaskType 

func (m *InstanceSegment) GetMaskType() string

func (*InstanceSegment) GetWidth 

func (m *InstanceSegment) GetWidth() int32

func (*InstanceSegment) GetXmax 

func (m *InstanceSegment) GetXmax() float32

func (*InstanceSegment) GetXmin 

func (m *InstanceSegment) GetXmin() float32

func (*InstanceSegment) GetYmax 

func (m *InstanceSegment) GetYmax() float32

func (*InstanceSegment) GetYmin 

func (m *InstanceSegment) GetYmin() float32

func (*InstanceSegment) GoString 

func (this *InstanceSegment) GoString() string

func (*InstanceSegment) Marshal 

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

func (*InstanceSegment) MarshalTo 

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

func (*InstanceSegment) ProtoMessage 

func (*InstanceSegment) ProtoMessage()

func (*InstanceSegment) Reset 

func (m *InstanceSegment) Reset()

func (*InstanceSegment) Size 

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

func (*InstanceSegment) String 

func (this *InstanceSegment) String() string

func (*InstanceSegment) Unmarshal 

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

func (*InstanceSegment) VerboseEqual 

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

func (*InstanceSegment) XXX_DiscardUnknown 

func (m *InstanceSegment) XXX_DiscardUnknown()

func (*InstanceSegment) XXX_Marshal 

func (m *InstanceSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceSegment) XXX_Merge 

func (m *InstanceSegment) XXX_Merge(src proto.Message)

func (*InstanceSegment) XXX_Size 

func (m *InstanceSegment) XXX_Size() int

func (*InstanceSegment) XXX_Unmarshal 

func (m *InstanceSegment) XXX_Unmarshal(b []byte) error

type Modality 

type Modality string
const (
	UnknownModality                   Modality = "unknown_modality"
	ImageObjectDetectionModality      Modality = "image_object_detection"
	ImageClassificationModality       Modality = "image_classification"
	ImageInstanceSegmentationModality Modality = "image_instance_segmentation"
	ImageSemanticSegmentationModality Modality = "image_semantic_segmentation"
	ImageEnhancementModality          Modality = "image_enhancement"
	RawModality                       Modality = "raw"
)

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,proto3" json:"framework,omitempty" yaml:"framework,omitempty"`
	Container         map[string]*ContainerHardware `` /* 186-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,proto3" 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,proto3" json:"inputs,omitempty" yaml:"inputs,omitempty"`
	Output            *ModelManifest_Type           `protobuf:"bytes,9,opt,name=output,proto3" 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,proto3" json:"model,omitempty" yaml:"model,omitempty"`
	Attributes        map[string]string             `` /* 190-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) GetElementType 

func (model ModelManifest) GetElementType() string

func (*ModelManifest) GetFramework 

func (m *ModelManifest) GetFramework() *FrameworkManifest

func (*ModelManifest) GetHidden 

func (m *ModelManifest) GetHidden() bool

func (ModelManifest) GetInputDimensions 

func (model ModelManifest) GetInputDimensions() ([]int, error)

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) Modality 

func (m *ModelManifest) Modality() (Modality, error)

func (ModelManifest) MustCanonicalName 

func (m ModelManifest) MustCanonicalName() string

func (ModelManifest) MustResolveFramework 

func (m ModelManifest) MustResolveFramework() FrameworkManifest

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)

func (*ModelManifest) XXX_DiscardUnknown 

func (m *ModelManifest) XXX_DiscardUnknown()

func (*ModelManifest) XXX_Marshal 

func (m *ModelManifest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelManifest) XXX_Merge 

func (m *ModelManifest) XXX_Merge(src proto.Message)

func (*ModelManifest) XXX_Size 

func (m *ModelManifest) XXX_Size() int

func (*ModelManifest) XXX_Unmarshal 

func (m *ModelManifest) XXX_Unmarshal(b []byte) 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 

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 

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

func (*ModelManifest_Model) XXX_DiscardUnknown 

func (m *ModelManifest_Model) XXX_DiscardUnknown()

func (*ModelManifest_Model) XXX_Marshal 

func (m *ModelManifest_Model) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelManifest_Model) XXX_Merge 

func (m *ModelManifest_Model) XXX_Merge(src proto.Message)

func (*ModelManifest_Model) XXX_Size 

func (m *ModelManifest_Model) XXX_Size() int

func (*ModelManifest_Model) XXX_Unmarshal 

func (m *ModelManifest_Model) XXX_Unmarshal(b []byte) 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 `` /* 189-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

func (*ModelManifest_Type) XXX_DiscardUnknown 

func (m *ModelManifest_Type) XXX_DiscardUnknown()

func (*ModelManifest_Type) XXX_Marshal 

func (m *ModelManifest_Type) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelManifest_Type) XXX_Merge 

func (m *ModelManifest_Type) XXX_Merge(src proto.Message)

func (*ModelManifest_Type) XXX_Size 

func (m *ModelManifest_Type) XXX_Size() int

func (*ModelManifest_Type) XXX_Unmarshal 

func (m *ModelManifest_Type) XXX_Unmarshal(b []byte) 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

func (*ModelManifest_Type_Parameter) XXX_DiscardUnknown 

func (m *ModelManifest_Type_Parameter) XXX_DiscardUnknown()

func (*ModelManifest_Type_Parameter) XXX_Marshal 

func (m *ModelManifest_Type_Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelManifest_Type_Parameter) XXX_Merge 

func (m *ModelManifest_Type_Parameter) XXX_Merge(src proto.Message)

func (*ModelManifest_Type_Parameter) XXX_Size 

func (m *ModelManifest_Type_Parameter) XXX_Size() int

func (*ModelManifest_Type_Parameter) XXX_Unmarshal 

func (m *ModelManifest_Type_Parameter) XXX_Unmarshal(b []byte) error

type ModelManifestsResponse 

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

func NewPopulatedModelManifestsResponse 

func NewPopulatedModelManifestsResponse(r randyRegistry, easy bool) *ModelManifestsResponse

func (*ModelManifestsResponse) Description 

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

func (*ModelManifestsResponse) XXX_DiscardUnknown 

func (m *ModelManifestsResponse) XXX_DiscardUnknown()

func (*ModelManifestsResponse) XXX_Marshal 

func (m *ModelManifestsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelManifestsResponse) XXX_Merge 

func (m *ModelManifestsResponse) XXX_Merge(src proto.Message)

func (*ModelManifestsResponse) XXX_Size 

func (m *ModelManifestsResponse) XXX_Size() int

func (*ModelManifestsResponse) XXX_Unmarshal 

func (m *ModelManifestsResponse) XXX_Unmarshal(b []byte) 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 

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) 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

func (*ModelRequest) XXX_DiscardUnknown 

func (m *ModelRequest) XXX_DiscardUnknown()

func (*ModelRequest) XXX_Marshal 

func (m *ModelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ModelRequest) XXX_Merge 

func (m *ModelRequest) XXX_Merge(src proto.Message)

func (*ModelRequest) XXX_Size 

func (m *ModelRequest) XXX_Size() int

func (*ModelRequest) XXX_Unmarshal 

func (m *ModelRequest) XXX_Unmarshal(b []byte) error

type PredictClient 

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 *PredictorCloseRequest, opts ...grpc.CallOption) (*PredictorCloseResponse, error)
	// URLs method receives a list of urls and runs
	// the predictor on all the urls.
	// The result is a list of predicted features for all the urls.
	URLs(ctx context.Context, in *URLsRequest, opts ...grpc.CallOption) (*FeaturesResponse, error)
	// Images method receives a list of 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)
	// 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)
	// Reset method clears the internal cache of the predictors
	Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*ResetResponse, error)
}

PredictClient is the client API for Predict service.

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

func NewPredictClient 

func NewPredictClient(cc *grpc.ClientConn) PredictClient

type PredictServer 

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, *PredictorCloseRequest) (*PredictorCloseResponse, error)
	// URLs method receives a list of urls and runs
	// the predictor on all the urls.
	// The result is a list of predicted features for all the urls.
	URLs(context.Context, *URLsRequest) (*FeaturesResponse, error)
	// Images method receives a list of 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)
	// 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)
	// Reset method clears the internal cache of the predictors
	Reset(context.Context, *ResetRequest) (*ResetResponse, error)
}

PredictServer is the server API for Predict service.

type PredictionHandle 

type PredictionHandle int64

type PredictionOptions 

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        int32             `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty" yaml:"batch_size,omitempty"`
	ExecutionOptions *ExecutionOptions `` /* 144-byte string literal not displayed */
	Agent            string            `protobuf:"bytes,5,opt,name=agent,proto3" json:"agent,omitempty" yaml:"agent,omitempty"`
	GpuMetrics       string            `protobuf:"bytes,6,opt,name=gpu_metrics,json=gpuMetrics,proto3" json:"gpu_metrics,omitempty" yaml:"gpu_metrics,omitempty"`
}

func NewPopulatedPredictionOptions 

func NewPopulatedPredictionOptions(r randyPredictor, easy bool) *PredictionOptions

func (*PredictionOptions) Description 

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

func (*PredictionOptions) Descriptor 

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

func (*PredictionOptions) Equal 

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

func (*PredictionOptions) GetAgent 

func (m *PredictionOptions) GetAgent() string

func (*PredictionOptions) GetBatchSize 

func (m *PredictionOptions) GetBatchSize() int32

func (*PredictionOptions) GetExecutionOptions 

func (m *PredictionOptions) GetExecutionOptions() *ExecutionOptions

func (*PredictionOptions) GetFeatureLimit 

func (m *PredictionOptions) GetFeatureLimit() int32

func (*PredictionOptions) GetGpuMetrics 

func (m *PredictionOptions) GetGpuMetrics() string

func (*PredictionOptions) GetRequestID 

func (m *PredictionOptions) GetRequestID() string

func (*PredictionOptions) GoString 

func (this *PredictionOptions) GoString() string

func (*PredictionOptions) Marshal 

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

func (*PredictionOptions) MarshalTo 

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

func (*PredictionOptions) ProtoMessage 

func (*PredictionOptions) ProtoMessage()

func (*PredictionOptions) Reset 

func (m *PredictionOptions) Reset()

func (*PredictionOptions) Size 

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

func (*PredictionOptions) String 

func (this *PredictionOptions) String() string

func (*PredictionOptions) Unmarshal 

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

func (*PredictionOptions) VerboseEqual 

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

func (*PredictionOptions) XXX_DiscardUnknown 

func (m *PredictionOptions) XXX_DiscardUnknown()

func (*PredictionOptions) XXX_Marshal 

func (m *PredictionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictionOptions) XXX_Merge 

func (m *PredictionOptions) XXX_Merge(src proto.Message)

func (*PredictionOptions) XXX_Size 

func (m *PredictionOptions) XXX_Size() int

func (*PredictionOptions) XXX_Unmarshal 

func (m *PredictionOptions) XXX_Unmarshal(b []byte) error

type Predictor 

type Predictor struct {
	ID       string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	Duration *time.Duration `protobuf:"bytes,2,opt,name=duration,proto3,stdduration" json:"duration,omitempty" yaml:"duration,omitempty"`
}

func NewPopulatedPredictor 

func NewPopulatedPredictor(r randyPredictor, easy bool) *Predictor

func (*Predictor) Description 

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

func (*Predictor) Descriptor 

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

func (*Predictor) Equal 

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

func (*Predictor) GetDuration 

func (m *Predictor) GetDuration() *time.Duration

func (*Predictor) GetID 

func (m *Predictor) GetID() string

func (*Predictor) GoString 

func (this *Predictor) GoString() string

func (*Predictor) Marshal 

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

func (*Predictor) MarshalTo 

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

func (*Predictor) ProtoMessage 

func (*Predictor) ProtoMessage()

func (*Predictor) Reset 

func (m *Predictor) Reset()

func (*Predictor) Size 

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

func (*Predictor) String 

func (this *Predictor) String() string

func (*Predictor) Unmarshal 

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

func (*Predictor) VerboseEqual 

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

func (*Predictor) XXX_DiscardUnknown 

func (m *Predictor) XXX_DiscardUnknown()

func (*Predictor) XXX_Marshal 

func (m *Predictor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Predictor) XXX_Merge 

func (m *Predictor) XXX_Merge(src proto.Message)

func (*Predictor) XXX_Size 

func (m *Predictor) XXX_Size() int

func (*Predictor) XXX_Unmarshal 

func (m *Predictor) XXX_Unmarshal(b []byte) error

type PredictorCloseRequest 

type PredictorCloseRequest struct {
	Predictor *Predictor `protobuf:"bytes,1,opt,name=predictor,proto3" json:"predictor,omitempty" yaml:"predictor,omitempty"`
	Force     bool       `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty" yaml:"force,omitempty"`
}

func NewPopulatedPredictorCloseRequest 

func NewPopulatedPredictorCloseRequest(r randyPredictor, easy bool) *PredictorCloseRequest

func (*PredictorCloseRequest) Description 

func (this *PredictorCloseRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*PredictorCloseRequest) Descriptor 

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

func (*PredictorCloseRequest) Equal 

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

func (*PredictorCloseRequest) GetForce 

func (m *PredictorCloseRequest) GetForce() bool

func (*PredictorCloseRequest) GetPredictor 

func (m *PredictorCloseRequest) GetPredictor() *Predictor

func (*PredictorCloseRequest) GoString 

func (this *PredictorCloseRequest) GoString() string

func (*PredictorCloseRequest) Marshal 

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

func (*PredictorCloseRequest) MarshalTo 

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

func (*PredictorCloseRequest) ProtoMessage 

func (*PredictorCloseRequest) ProtoMessage()

func (*PredictorCloseRequest) Reset 

func (m *PredictorCloseRequest) Reset()

func (*PredictorCloseRequest) Size 

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

func (*PredictorCloseRequest) String 

func (this *PredictorCloseRequest) String() string

func (*PredictorCloseRequest) Unmarshal 

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

func (*PredictorCloseRequest) VerboseEqual 

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

func (*PredictorCloseRequest) XXX_DiscardUnknown 

func (m *PredictorCloseRequest) XXX_DiscardUnknown()

func (*PredictorCloseRequest) XXX_Marshal 

func (m *PredictorCloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictorCloseRequest) XXX_Merge 

func (m *PredictorCloseRequest) XXX_Merge(src proto.Message)

func (*PredictorCloseRequest) XXX_Size 

func (m *PredictorCloseRequest) XXX_Size() int

func (*PredictorCloseRequest) XXX_Unmarshal 

func (m *PredictorCloseRequest) XXX_Unmarshal(b []byte) error

type PredictorCloseResponse 

type PredictorCloseResponse struct {
	Duration *time.Duration `protobuf:"bytes,1,opt,name=duration,proto3,stdduration" json:"duration,omitempty" yaml:"duration,omitempty"`
}

func NewPopulatedPredictorCloseResponse 

func NewPopulatedPredictorCloseResponse(r randyPredictor, easy bool) *PredictorCloseResponse

func (*PredictorCloseResponse) Descriptor 

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

func (*PredictorCloseResponse) Equal 

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

func (*PredictorCloseResponse) GetDuration 

func (m *PredictorCloseResponse) GetDuration() *time.Duration

func (*PredictorCloseResponse) GoString 

func (this *PredictorCloseResponse) GoString() string

func (*PredictorCloseResponse) Marshal 

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

func (*PredictorCloseResponse) MarshalTo 

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

func (*PredictorCloseResponse) ProtoMessage 

func (*PredictorCloseResponse) ProtoMessage()

func (*PredictorCloseResponse) Reset 

func (m *PredictorCloseResponse) Reset()

func (*PredictorCloseResponse) Size 

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

func (*PredictorCloseResponse) String 

func (this *PredictorCloseResponse) String() string

func (*PredictorCloseResponse) Unmarshal 

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

func (*PredictorCloseResponse) VerboseEqual 

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

func (*PredictorCloseResponse) XXX_DiscardUnknown 

func (m *PredictorCloseResponse) XXX_DiscardUnknown()

func (*PredictorCloseResponse) XXX_Marshal 

func (m *PredictorCloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictorCloseResponse) XXX_Merge 

func (m *PredictorCloseResponse) XXX_Merge(src proto.Message)

func (*PredictorCloseResponse) XXX_Size 

func (m *PredictorCloseResponse) XXX_Size() int

func (*PredictorCloseResponse) XXX_Unmarshal 

func (m *PredictorCloseResponse) XXX_Unmarshal(b []byte) error

type PredictorOpenRequest 

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 */
	Persist          bool               `protobuf:"varint,5,opt,name=persist,proto3" json:"persist,omitempty" yaml:"persist,omitempty"`
	Options          *PredictionOptions `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty" yaml:"options,omitempty"`
}

func NewPopulatedPredictorOpenRequest 

func NewPopulatedPredictorOpenRequest(r randyPredictor, easy bool) *PredictorOpenRequest

func (*PredictorOpenRequest) Description 

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

func (*PredictorOpenRequest) Descriptor 

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

func (*PredictorOpenRequest) Equal 

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

func (*PredictorOpenRequest) GetFrameworkName 

func (m *PredictorOpenRequest) GetFrameworkName() string

func (*PredictorOpenRequest) GetFrameworkVersion 

func (m *PredictorOpenRequest) GetFrameworkVersion() string

func (*PredictorOpenRequest) GetModelName 

func (m *PredictorOpenRequest) GetModelName() string

func (*PredictorOpenRequest) GetModelVersion 

func (m *PredictorOpenRequest) GetModelVersion() string

func (*PredictorOpenRequest) GetOptions 

func (m *PredictorOpenRequest) GetOptions() *PredictionOptions

func (*PredictorOpenRequest) GetPersist 

func (m *PredictorOpenRequest) GetPersist() bool

func (*PredictorOpenRequest) GoString 

func (this *PredictorOpenRequest) GoString() string

func (*PredictorOpenRequest) Marshal 

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

func (*PredictorOpenRequest) MarshalTo 

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

func (*PredictorOpenRequest) ProtoMessage 

func (*PredictorOpenRequest) ProtoMessage()

func (*PredictorOpenRequest) Reset 

func (m *PredictorOpenRequest) Reset()

func (*PredictorOpenRequest) Size 

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

func (*PredictorOpenRequest) String 

func (this *PredictorOpenRequest) String() string

func (*PredictorOpenRequest) Unmarshal 

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

func (*PredictorOpenRequest) VerboseEqual 

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

func (*PredictorOpenRequest) XXX_DiscardUnknown 

func (m *PredictorOpenRequest) XXX_DiscardUnknown()

func (*PredictorOpenRequest) XXX_Marshal 

func (m *PredictorOpenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PredictorOpenRequest) XXX_Merge 

func (m *PredictorOpenRequest) XXX_Merge(src proto.Message)

func (*PredictorOpenRequest) XXX_Size 

func (m *PredictorOpenRequest) XXX_Size() int

func (*PredictorOpenRequest) XXX_Unmarshal 

func (m *PredictorOpenRequest) XXX_Unmarshal(b []byte) error

type Raw 

type Raw struct {
	Data   []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty" yaml:"data,omitempty"`
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty" yaml:"format,omitempty"`
}

func NewPopulatedRaw 

func NewPopulatedRaw(r randyFeatures, easy bool) *Raw

func (*Raw) Description 

func (this *Raw) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*Raw) Descriptor 

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

func (*Raw) Equal 

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

func (*Raw) GetData 

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

func (*Raw) GetFormat 

func (m *Raw) GetFormat() string

func (*Raw) GoString 

func (this *Raw) GoString() string

func (*Raw) Marshal 

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

func (*Raw) MarshalTo 

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

func (*Raw) ProtoMessage 

func (*Raw) ProtoMessage()

func (*Raw) Reset 

func (m *Raw) Reset()

func (*Raw) Size 

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

func (*Raw) String 

func (this *Raw) String() string

func (*Raw) Unmarshal 

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

func (*Raw) VerboseEqual 

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

func (*Raw) XXX_DiscardUnknown 

func (m *Raw) XXX_DiscardUnknown()

func (*Raw) XXX_Marshal 

func (m *Raw) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Raw) XXX_Merge 

func (m *Raw) XXX_Merge(src proto.Message)

func (*Raw) XXX_Size 

func (m *Raw) XXX_Size() int

func (*Raw) XXX_Unmarshal 

func (m *Raw) XXX_Unmarshal(b []byte) error

type RawImage 

type RawImage 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"`
	DataType  string    `protobuf:"bytes,2,opt,name=data_type,json=dataType,proto3" json:"data_type,omitempty" yaml:"data_type,omitempty"`
	CharList  []int32   `protobuf:"varint,3,rep,packed,name=char_list,json=charList,proto3" json:"char_list,omitempty" yaml:"char_list,omitempty"`
	FloatList []float32 `protobuf:"fixed32,4,rep,packed,name=float_list,json=floatList,proto3" json:"float_list,omitempty" yaml:"float_list,omitempty"`
	Width     int32     `protobuf:"varint,5,opt,name=width,proto3" json:"width,omitempty" yaml:"width,omitempty"`
	Height    int32     `protobuf:"varint,6,opt,name=height,proto3" json:"height,omitempty" yaml:"height,omitempty"`
	Channels  int32     `protobuf:"varint,7,opt,name=channels,proto3" json:"channels,omitempty" yaml:"channels,omitempty"`
	// compressed data is only used by the webserver and javascript codes
	CompressedData []byte `` /* 136-byte string literal not displayed */
	// jpeg data is only used by the webserver and javascript codes
	JpegData []byte `protobuf:"bytes,9,opt,name=jpeg_data,json=jpegData,proto3" json:"jpeg_data,omitempty" yaml:"jpeg_data,omitempty"`
}

func NewPopulatedRawImage 

func NewPopulatedRawImage(r randyFeatures, easy bool) *RawImage

func (*RawImage) Descriptor 

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

func (*RawImage) Equal 

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

func (*RawImage) GetChannels 

func (m *RawImage) GetChannels() int32

func (*RawImage) GetCharList 

func (m *RawImage) GetCharList() []int32

func (*RawImage) GetCompressedData 

func (m *RawImage) GetCompressedData() []byte

func (*RawImage) GetDataType 

func (m *RawImage) GetDataType() string

func (*RawImage) GetFloatList 

func (m *RawImage) GetFloatList() []float32

func (*RawImage) GetHeight 

func (m *RawImage) GetHeight() int32

func (*RawImage) GetID 

func (m *RawImage) GetID() string

func (*RawImage) GetJpegData 

func (m *RawImage) GetJpegData() []byte

func (*RawImage) GetWidth 

func (m *RawImage) GetWidth() int32

func (*RawImage) GoString 

func (this *RawImage) GoString() string

func (*RawImage) Marshal 

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

func (*RawImage) MarshalTo 

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

func (*RawImage) ProtoMessage 

func (*RawImage) ProtoMessage()

func (*RawImage) Reset 

func (m *RawImage) Reset()

func (*RawImage) Size 

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

func (*RawImage) String 

func (this *RawImage) String() string

func (*RawImage) Unmarshal 

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

func (*RawImage) VerboseEqual 

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

func (*RawImage) XXX_DiscardUnknown 

func (m *RawImage) XXX_DiscardUnknown()

func (*RawImage) XXX_Marshal 

func (m *RawImage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawImage) XXX_Merge 

func (m *RawImage) XXX_Merge(src proto.Message)

func (*RawImage) XXX_Size 

func (m *RawImage) XXX_Size() int

func (*RawImage) XXX_Unmarshal 

func (m *RawImage) XXX_Unmarshal(b []byte) error

type Region 

type Region struct {
	Data   []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty" yaml:"data,omitempty"`
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty" yaml:"format,omitempty"`
}

func NewPopulatedRegion 

func NewPopulatedRegion(r randyFeatures, easy bool) *Region

func (*Region) Description 

func (this *Region) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*Region) Descriptor 

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

func (*Region) Equal 

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

func (*Region) GetData 

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

func (*Region) GetFormat 

func (m *Region) GetFormat() string

func (*Region) GoString 

func (this *Region) GoString() string

func (*Region) Marshal 

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

func (*Region) MarshalTo 

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

func (*Region) ProtoMessage 

func (*Region) ProtoMessage()

func (*Region) Reset 

func (m *Region) Reset()

func (*Region) Size 

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

func (*Region) String 

func (this *Region) String() string

func (*Region) Unmarshal 

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

func (*Region) VerboseEqual 

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

func (*Region) XXX_DiscardUnknown 

func (m *Region) XXX_DiscardUnknown()

func (*Region) XXX_Marshal 

func (m *Region) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Region) XXX_Merge 

func (m *Region) XXX_Merge(src proto.Message)

func (*Region) XXX_Size 

func (m *Region) XXX_Size() int

func (*Region) XXX_Unmarshal 

func (m *Region) XXX_Unmarshal(b []byte) 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)
}

RegistryClient is the client API for Registry service.

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

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)
}

RegistryServer is the server API for Registry service.

type ResetRequest 

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,proto3" json:"predictor,omitempty" yaml:"predictor,omitempty"`
}

func NewPopulatedResetRequest 

func NewPopulatedResetRequest(r randyPredictor, easy bool) *ResetRequest

func (*ResetRequest) Description 

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

func (*ResetRequest) Descriptor 

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

func (*ResetRequest) Equal 

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

func (*ResetRequest) GetID 

func (m *ResetRequest) GetID() string

func (*ResetRequest) GetPredictor 

func (m *ResetRequest) GetPredictor() *Predictor

func (*ResetRequest) GoString 

func (this *ResetRequest) GoString() string

func (*ResetRequest) Marshal 

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

func (*ResetRequest) MarshalTo 

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

func (*ResetRequest) ProtoMessage 

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) Reset 

func (m *ResetRequest) Reset()

func (*ResetRequest) Size 

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

func (*ResetRequest) String 

func (this *ResetRequest) String() string

func (*ResetRequest) Unmarshal 

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

func (*ResetRequest) VerboseEqual 

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

func (*ResetRequest) XXX_DiscardUnknown 

func (m *ResetRequest) XXX_DiscardUnknown()

func (*ResetRequest) XXX_Marshal 

func (m *ResetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetRequest) XXX_Merge 

func (m *ResetRequest) XXX_Merge(src proto.Message)

func (*ResetRequest) XXX_Size 

func (m *ResetRequest) XXX_Size() int

func (*ResetRequest) XXX_Unmarshal 

func (m *ResetRequest) XXX_Unmarshal(b []byte) error

type ResetResponse 

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

func NewPopulatedResetResponse 

func NewPopulatedResetResponse(r randyPredictor, easy bool) *ResetResponse

func (*ResetResponse) Description 

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

func (*ResetResponse) Descriptor 

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

func (*ResetResponse) Equal 

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

func (*ResetResponse) GoString 

func (this *ResetResponse) GoString() string

func (*ResetResponse) Marshal 

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

func (*ResetResponse) MarshalTo 

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

func (*ResetResponse) ProtoMessage 

func (*ResetResponse) ProtoMessage()

func (*ResetResponse) Reset 

func (m *ResetResponse) Reset()

func (*ResetResponse) Size 

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

func (*ResetResponse) String 

func (this *ResetResponse) String() string

func (*ResetResponse) Unmarshal 

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

func (*ResetResponse) VerboseEqual 

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

func (*ResetResponse) XXX_DiscardUnknown 

func (m *ResetResponse) XXX_DiscardUnknown()

func (*ResetResponse) XXX_Marshal 

func (m *ResetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetResponse) XXX_Merge 

func (m *ResetResponse) XXX_Merge(src proto.Message)

func (*ResetResponse) XXX_Size 

func (m *ResetResponse) XXX_Size() int

func (*ResetResponse) XXX_Unmarshal 

func (m *ResetResponse) XXX_Unmarshal(b []byte) error

type SemanticSegment 

type SemanticSegment struct {
	Height  int32   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty" yaml:"height,omitempty"`
	Width   int32   `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty" yaml:"width,omitempty"`
	IntMask []int32 `protobuf:"varint,3,rep,packed,name=int_mask,json=intMask,proto3" json:"int_mask,omitempty" yaml:"int_mask,omitempty"`
}

func NewPopulatedSemanticSegment 

func NewPopulatedSemanticSegment(r randyFeatures, easy bool) *SemanticSegment

func (*SemanticSegment) Description 

func (this *SemanticSegment) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*SemanticSegment) Descriptor 

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

func (*SemanticSegment) Equal 

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

func (*SemanticSegment) GetHeight 

func (m *SemanticSegment) GetHeight() int32

func (*SemanticSegment) GetIntMask 

func (m *SemanticSegment) GetIntMask() []int32

func (*SemanticSegment) GetWidth 

func (m *SemanticSegment) GetWidth() int32

func (*SemanticSegment) GoString 

func (this *SemanticSegment) GoString() string

func (*SemanticSegment) Marshal 

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

func (*SemanticSegment) MarshalTo 

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

func (*SemanticSegment) ProtoMessage 

func (*SemanticSegment) ProtoMessage()

func (*SemanticSegment) Reset 

func (m *SemanticSegment) Reset()

func (*SemanticSegment) Size 

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

func (*SemanticSegment) String 

func (this *SemanticSegment) String() string

func (*SemanticSegment) Unmarshal 

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

func (*SemanticSegment) VerboseEqual 

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

func (*SemanticSegment) XXX_DiscardUnknown 

func (m *SemanticSegment) XXX_DiscardUnknown()

func (*SemanticSegment) XXX_Marshal 

func (m *SemanticSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SemanticSegment) XXX_Merge 

func (m *SemanticSegment) XXX_Merge(src proto.Message)

func (*SemanticSegment) XXX_Size 

func (m *SemanticSegment) XXX_Size() int

func (*SemanticSegment) XXX_Unmarshal 

func (m *SemanticSegment) XXX_Unmarshal(b []byte) error

type Text 

type Text struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty" yaml:"data,omitempty"`
}

func NewPopulatedText 

func NewPopulatedText(r randyFeatures, easy bool) *Text

func (*Text) Description 

func (this *Text) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*Text) Descriptor 

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

func (*Text) Equal 

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

func (*Text) GetData 

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

func (*Text) GoString 

func (this *Text) GoString() string

func (*Text) Marshal 

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

func (*Text) MarshalTo 

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

func (*Text) ProtoMessage 

func (*Text) ProtoMessage()

func (*Text) Reset 

func (m *Text) Reset()

func (*Text) Size 

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

func (*Text) String 

func (this *Text) String() string

func (*Text) Unmarshal 

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

func (*Text) VerboseEqual 

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

func (*Text) XXX_DiscardUnknown 

func (m *Text) XXX_DiscardUnknown()

func (*Text) XXX_Marshal 

func (m *Text) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Text) XXX_Merge 

func (m *Text) XXX_Merge(src proto.Message)

func (*Text) XXX_Size 

func (m *Text) XXX_Size() int

func (*Text) XXX_Unmarshal 

func (m *Text) XXX_Unmarshal(b []byte) error

type TextRequest 

type TextRequest struct {
	Predictor *Predictor `protobuf:"bytes,1,opt,name=predictor,proto3" json:"predictor,omitempty" yaml:"predictor,omitempty"`
	// A list of Base64 encoded texts
	Texts   []*Text            `protobuf:"bytes,2,rep,name=texts,proto3" json:"texts,omitempty" yaml:"texts,omitempty"`
	Options *PredictionOptions `protobuf:"bytes,3,opt,name=options,proto3" json:"options,omitempty" yaml:"options,omitempty"`
}

func NewPopulatedTextRequest 

func NewPopulatedTextRequest(r randyPredictor, easy bool) *TextRequest

func (*TextRequest) Description 

func (this *TextRequest) Description() (desc *github_com_gogo_protobuf_protoc_gen_gogo_descriptor.FileDescriptorSet)

func (*TextRequest) Descriptor 

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

func (*TextRequest) Equal 

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

func (*TextRequest) GetOptions 

func (m *TextRequest) GetOptions() *PredictionOptions

func (*TextRequest) GetPredictor 

func (m *TextRequest) GetPredictor() *Predictor

func (*TextRequest) GetTexts 

func (m *TextRequest) GetTexts() []*Text

func (*TextRequest) GoString 

func (this *TextRequest) GoString() string

func (*TextRequest) Marshal 

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

func (*TextRequest) MarshalTo 

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

func (*TextRequest) ProtoMessage 

func (*TextRequest) ProtoMessage()

func (*TextRequest) Reset 

func (m *TextRequest) Reset()

func (*TextRequest) Size 

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

func (*TextRequest) String 

func (this *TextRequest) String() string

func (*TextRequest) Unmarshal 

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

func (*TextRequest) VerboseEqual 

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

func (*TextRequest) XXX_DiscardUnknown 

func (m *TextRequest) XXX_DiscardUnknown()

func (*TextRequest) XXX_Marshal 

func (m *TextRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TextRequest) XXX_Merge 

func (m *TextRequest) XXX_Merge(src proto.Message)

func (*TextRequest) XXX_Size 

func (m *TextRequest) XXX_Size() int

func (*TextRequest) XXX_Unmarshal 

func (m *TextRequest) XXX_Unmarshal(b []byte) error

type TraceID 

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

func NewPopulatedTraceID 

func NewPopulatedTraceID(r randyPredictor, easy bool) *TraceID

func (*TraceID) Descriptor 

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

func (*TraceID) Equal 

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

func (*TraceID) GetId 

func (m *TraceID) GetId() string

func (*TraceID) GoString 

func (this *TraceID) GoString() string

func (*TraceID) Marshal 

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

func (*TraceID) MarshalTo 

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

func (*TraceID) ProtoMessage 

func (*TraceID) ProtoMessage()

func (*TraceID) Reset 

func (m *TraceID) Reset()

func (*TraceID) Size 

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

func (*TraceID) String 

func (this *TraceID) String() string

func (*TraceID) Unmarshal 

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

func (*TraceID) VerboseEqual 

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

func (*TraceID) XXX_DiscardUnknown 

func (m *TraceID) XXX_DiscardUnknown()

func (*TraceID) XXX_Marshal 

func (m *TraceID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TraceID) XXX_Merge 

func (m *TraceID) XXX_Merge(src proto.Message)

func (*TraceID) XXX_Size 

func (m *TraceID) XXX_Size() int

func (*TraceID) XXX_Unmarshal 

func (m *TraceID) XXX_Unmarshal(b []byte) error

type URLsRequest 

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

func NewPopulatedURLsRequest 

func NewPopulatedURLsRequest(r randyPredictor, easy bool) *URLsRequest

func (*URLsRequest) Description 

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

func (*URLsRequest) Descriptor 

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

func (*URLsRequest) Equal 

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

func (*URLsRequest) GetOptions 

func (m *URLsRequest) GetOptions() *PredictionOptions

func (*URLsRequest) GetPredictor 

func (m *URLsRequest) GetPredictor() *Predictor

func (*URLsRequest) GetUrls 

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

func (*URLsRequest) GoString 

func (this *URLsRequest) GoString() string

func (*URLsRequest) Marshal 

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

func (*URLsRequest) MarshalTo 

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

func (*URLsRequest) ProtoMessage 

func (*URLsRequest) ProtoMessage()

func (*URLsRequest) Reset 

func (m *URLsRequest) Reset()

func (*URLsRequest) Size 

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

func (*URLsRequest) String 

func (this *URLsRequest) String() string

func (*URLsRequest) Unmarshal 

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

func (*URLsRequest) VerboseEqual 

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

func (*URLsRequest) XXX_DiscardUnknown 

func (m *URLsRequest) XXX_DiscardUnknown()

func (*URLsRequest) XXX_Marshal 

func (m *URLsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*URLsRequest) XXX_Merge 

func (m *URLsRequest) XXX_Merge(src proto.Message)

func (*URLsRequest) XXX_Size 

func (m *URLsRequest) XXX_Size() int

func (*URLsRequest) XXX_Unmarshal 

func (m *URLsRequest) XXX_Unmarshal(b []byte) error

type URLsRequest_URL 

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 

func NewPopulatedURLsRequest_URL(r randyPredictor, easy bool) *URLsRequest_URL

func (*URLsRequest_URL) Descriptor 

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

func (*URLsRequest_URL) Equal 

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

func (*URLsRequest_URL) GetData 

func (m *URLsRequest_URL) GetData() string

func (*URLsRequest_URL) GetID 

func (m *URLsRequest_URL) GetID() string

func (*URLsRequest_URL) GoString 

func (this *URLsRequest_URL) GoString() string

func (*URLsRequest_URL) Marshal 

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

func (*URLsRequest_URL) MarshalTo 

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

func (*URLsRequest_URL) ProtoMessage 

func (*URLsRequest_URL) ProtoMessage()

func (*URLsRequest_URL) Reset 

func (m *URLsRequest_URL) Reset()

func (*URLsRequest_URL) Size 

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

func (*URLsRequest_URL) String 

func (this *URLsRequest_URL) String() string

func (*URLsRequest_URL) Unmarshal 

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

func (*URLsRequest_URL) VerboseEqual 

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

func (*URLsRequest_URL) XXX_DiscardUnknown 

func (m *URLsRequest_URL) XXX_DiscardUnknown()

func (*URLsRequest_URL) XXX_Marshal 

func (m *URLsRequest_URL) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*URLsRequest_URL) XXX_Merge 

func (m *URLsRequest_URL) XXX_Merge(src proto.Message)

func (*URLsRequest_URL) XXX_Size 

func (m *URLsRequest_URL) XXX_Size() int

func (*URLsRequest_URL) XXX_Unmarshal 

func (m *URLsRequest_URL) XXX_Unmarshal(b []byte) error

type UnimplementedPredictServer 

type UnimplementedPredictServer struct {
}

UnimplementedPredictServer can be embedded to have forward compatible implementations.

func (*UnimplementedPredictServer) Close 

func (*UnimplementedPredictServer) Close(ctx context.Context, req *PredictorCloseRequest) (*PredictorCloseResponse, error)

func (*UnimplementedPredictServer) Dataset 

func (*UnimplementedPredictServer) Dataset(ctx context.Context, req *DatasetRequest) (*FeaturesResponse, error)

func (*UnimplementedPredictServer) Images 

func (*UnimplementedPredictServer) Images(ctx context.Context, req *ImagesRequest) (*FeaturesResponse, error)

func (*UnimplementedPredictServer) Open 

func (*UnimplementedPredictServer) Open(ctx context.Context, req *PredictorOpenRequest) (*Predictor, error)

func (*UnimplementedPredictServer) Reset 

func (*UnimplementedPredictServer) Reset(ctx context.Context, req *ResetRequest) (*ResetResponse, error)

func (*UnimplementedPredictServer) URLs 

func (*UnimplementedPredictServer) URLs(ctx context.Context, req *URLsRequest) (*FeaturesResponse, error)

type UnimplementedRegistryServer 

type UnimplementedRegistryServer struct {
}

UnimplementedRegistryServer can be embedded to have forward compatible implementations.

func (*UnimplementedRegistryServer) FrameworkAgents 

func (*UnimplementedRegistryServer) FrameworkAgents(ctx context.Context, req *FrameworkRequest) (*Agents, error)

func (*UnimplementedRegistryServer) FrameworkManifests 

func (*UnimplementedRegistryServer) FrameworkManifests(ctx context.Context, req *FrameworkRequest) (*FrameworkManifestsResponse, error)

func (*UnimplementedRegistryServer) ModelAgents 

func (*UnimplementedRegistryServer) ModelAgents(ctx context.Context, req *ModelRequest) (*Agents, error)

func (*UnimplementedRegistryServer) ModelManifests 

func (*UnimplementedRegistryServer) ModelManifests(ctx context.Context, req *ModelRequest) (*ModelManifestsResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
agent
cmd
cmd/client
cmd/client/run
cmd/server
feature
options
predictor
httpapi
client
client/authentication
client/predict
client/registry
cmd/dlframework-server
models
restapi
Package restapi MLModelScope MLModelScope is a hardware/software agnostic platform to facilitate the evaluation, measurement, and introspection of ML models within AI pipelines.
 Package restapi MLModelScope MLModelScope is a hardware/software agnostic platform to facilitate the evaluation, measurement, and introspection of ML models within AI pipelines.
restapi/operations
restapi/operations/authentication
restapi/operations/predict
restapi/operations/registry

Jump to

Keyboard shortcuts

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