dlframework

package module
v1.4.21 Latest Latest
Warning

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

Go to latest
Published: Jun 14, 2022 License: NCSA Imports: 46 Imported by: 15

README

DLFramework

Build Status Build Status

Deep Learning Framework contains common code used for the MLModelScope agents.

Evaluation

contains commands that help summarize and visualize the experiments results.

Framework

Agents

Allows applications to connect to a message queue to get prediction jobs to be run and returns result via the message queue and to a mongodb for archiving.

Server

Setup the Cobra commandline interface to run buildtime, completion, env, predict, worker, info and other commands.

Core Prediction

Handles the setup of a prediction but requires a framework to actually run model. Predictions process is shared between the cli and the mq agent and should behave identically.

httpapi

(This is deprecated) Creates an api to run predicts against, this is being replaced with new functions in mlmodelscope-api

registryquery

(This is deprecated) communication with the Consul registry storing what models and frameworks are available, this is being replaced with new functions in mlmodelscope-api

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")
	ErrUnexpectedEndOfGroupFeatures = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthPredictor        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPredictor          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPredictor = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthRegistry        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRegistry          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRegistry = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	RegistryServiceDescription = _Registry_serviceDesc
	PredictServiceDescription  = _Predict_serviceDesc
)
View Source
var DefaultModelElementType = "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",
	11:  "GENERAL",
	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,
	"GENERAL":         11,
	"RAW":             100,
}
View Source
var Version = "1.4.21"

Functions

func Bhattacharyya added in v0.2.19

func Bhattacharyya(p, q []float64) float64

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

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

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

func CheckIfFileExistsAndMatchesChecksum added in v1.4.8

func CheckIfFileExistsAndMatchesChecksum(fullPathToFile string, checksum string) (err error, matches bool)

func CleanString added in v0.3.0

func CleanString(str string) string

func Correlation added in v0.2.19

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

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

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

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

func Covariance added in v0.2.19

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

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

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

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

func DownloadFile added in v1.4.8

func DownloadFile(urlToDownload string, checksum string, workDir string) error

func FeaturesDescription added in v0.3.0

func Hellinger added in v0.2.19

func Hellinger(p, q []float64) float64

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

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

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

func JensenShannon added in v0.2.19

func JensenShannon(p, q []float64) float64

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

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

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

func KullbackLeibler added in v0.2.19

func KullbackLeibler(p, q []float64) float64

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

sum_i(p_i * log(p_i / q_i))

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

func Mean added in v0.2.19

func Mean(x, weights []float64) float64

Mean computes the weighted mean of the data set.

sum_i {w_i * x_i} / sum_i {w_i}

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

func Partition added in v0.3.0

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

func PartitionStringList added in v0.3.0

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

func PredictorDescription added in v0.2.19

func RegisterPredictHandler added in v0.2.16

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

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

func RegisterPredictHandlerClient added in v0.2.20

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

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

func RegisterPredictHandlerFromEndpoint added in v0.2.16

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

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

func RegisterPredictHandlerServer added in v1.3.6

func RegisterPredictHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PredictServer) error

RegisterPredictHandlerServer registers the http handlers for service Predict to "mux". UnaryRPC :call PredictServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPredictHandlerFromEndpoint instead.

func RegisterPredictServer added in v0.2.16

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

func RegisterRegistryHandler

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

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

func RegisterRegistryHandlerClient added in v0.2.20

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

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

func RegisterRegistryHandlerFromEndpoint

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

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

func RegisterRegistryHandlerServer added in v1.3.6

func RegisterRegistryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RegistryServer) error

RegisterRegistryHandlerServer registers the http handlers for service Registry to "mux". UnaryRPC :call RegistryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRegistryHandlerFromEndpoint instead.

func RegisterRegistryServer

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

func RegisteredFrameworkNames

func RegisteredFrameworkNames() []string

func RegistryDescription added in v0.2.19

func Sum added in v0.2.19

func Sum(s []float64) float64

Sum returns the sum of the elements of the slice.

Types

type Agent

type Agent struct {
	Host         string               `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty" yaml:"host,omitempty"`
	Port         string               `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty" yaml:"port,omitempty"`
	Hostname     string               `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty" yaml:"hostname,omitempty"`
	Architecture string               `protobuf:"bytes,4,opt,name=architecture,proto3" json:"architecture,omitempty" yaml:"architecture,omitempty"`
	Hasgpu       bool                 `protobuf:"varint,5,opt,name=hasgpu,proto3" json:"hasgpu,omitempty" yaml:"hasgpu,omitempty"`
	Cpuinfo      string               `protobuf:"bytes,6,opt,name=cpuinfo,proto3" json:"cpuinfo,omitempty" yaml:"cpuinfo,omitempty"`
	Gpuinfo      string               `protobuf:"bytes,7,opt,name=gpuinfo,proto3" json:"gpuinfo,omitempty" yaml:"gpuinfo,omitempty"`
	Frameworks   []*FrameworkManifest `protobuf:"bytes,8,rep,name=frameworks,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 added in v0.2.16

func (*Agent) Descriptor

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

func (*Agent) Equal

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

func (*Agent) GetArchitecture added in v0.2.19

func (m *Agent) GetArchitecture() string

func (*Agent) GetCpuinfo added in v0.2.19

func (m *Agent) GetCpuinfo() string

func (*Agent) GetFrameworks added in v0.2.19

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

func (*Agent) GetGpuinfo added in v0.2.19

func (m *Agent) GetGpuinfo() string

func (*Agent) GetHasgpu added in v0.2.19

func (m *Agent) GetHasgpu() bool

func (*Agent) GetHost

func (m *Agent) GetHost() string

func (*Agent) GetHostname added in v0.2.19

func (m *Agent) GetHostname() string

func (*Agent) GetMetadata added in v0.2.19

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

func (*Agent) GetPort

func (m *Agent) GetPort() string

func (*Agent) GoString

func (this *Agent) GoString() string

func (*Agent) Marshal

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

func (*Agent) MarshalTo

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

func (*Agent) MarshalToSizedBuffer added in v1.3.6

func (m *Agent) MarshalToSizedBuffer(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 added in v0.3.0

func (m *Agent) XXX_DiscardUnknown()

func (*Agent) XXX_Marshal added in v0.3.0

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

func (*Agent) XXX_Merge added in v0.3.0

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

func (*Agent) XXX_Size added in v0.3.0

func (m *Agent) XXX_Size() int

func (*Agent) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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) MarshalToSizedBuffer added in v1.3.6

func (m *Agents) MarshalToSizedBuffer(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 added in v0.3.0

func (m *Agents) XXX_DiscardUnknown()

func (*Agents) XXX_Marshal added in v0.3.0

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

func (*Agents) XXX_Merge added in v0.3.0

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

func (*Agents) XXX_Size added in v0.3.0

func (m *Agents) XXX_Size() int

func (*Agents) XXX_Unmarshal added in v0.3.0

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

type Audio added in v0.3.0

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 added in v0.3.0

func NewPopulatedAudio(r randyFeatures, easy bool) *Audio

func (*Audio) Description added in v0.3.0

func (*Audio) Descriptor added in v0.3.0

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

func (*Audio) Equal added in v0.3.0

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

func (*Audio) GetData added in v0.3.0

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

func (*Audio) GetFormat added in v0.3.0

func (m *Audio) GetFormat() string

func (*Audio) GoString added in v0.3.0

func (this *Audio) GoString() string

func (*Audio) Marshal added in v0.3.0

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

func (*Audio) MarshalTo added in v0.3.0

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

func (*Audio) MarshalToSizedBuffer added in v1.3.6

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

func (*Audio) ProtoMessage added in v0.3.0

func (*Audio) ProtoMessage()

func (*Audio) Reset added in v0.3.0

func (m *Audio) Reset()

func (*Audio) Size added in v0.3.0

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

func (*Audio) String added in v0.3.0

func (this *Audio) String() string

func (*Audio) Unmarshal added in v0.3.0

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

func (*Audio) VerboseEqual added in v0.3.0

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

func (*Audio) XXX_DiscardUnknown added in v0.3.0

func (m *Audio) XXX_DiscardUnknown()

func (*Audio) XXX_Marshal added in v0.3.0

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

func (*Audio) XXX_Merge added in v0.3.0

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

func (*Audio) XXX_Size added in v0.3.0

func (m *Audio) XXX_Size() int

func (*Audio) XXX_Unmarshal added in v0.3.0

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

type BoundingBox added in v0.3.0

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 added in v0.3.0

func NewPopulatedBoundingBox(r randyFeatures, easy bool) *BoundingBox

func (*BoundingBox) Area added in v0.3.0

func (b *BoundingBox) Area() float32

func (*BoundingBox) Description added in v0.3.0

func (*BoundingBox) Descriptor added in v0.3.0

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

func (*BoundingBox) Equal added in v0.3.0

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

func (*BoundingBox) GetIndex added in v0.3.0

func (m *BoundingBox) GetIndex() int32

func (*BoundingBox) GetLabel added in v0.3.0

func (m *BoundingBox) GetLabel() string

func (*BoundingBox) GetXmax added in v0.3.0

func (m *BoundingBox) GetXmax() float32

func (*BoundingBox) GetXmin added in v0.3.0

func (m *BoundingBox) GetXmin() float32

func (*BoundingBox) GetYmax added in v0.3.0

func (m *BoundingBox) GetYmax() float32

func (*BoundingBox) GetYmin added in v0.3.0

func (m *BoundingBox) GetYmin() float32

func (*BoundingBox) GoString added in v0.3.0

func (this *BoundingBox) GoString() string

func (*BoundingBox) Height added in v0.3.0

func (b *BoundingBox) Height() float32

func (*BoundingBox) Marshal added in v0.3.0

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

func (*BoundingBox) MarshalTo added in v0.3.0

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

func (*BoundingBox) MarshalToSizedBuffer added in v1.3.6

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

func (*BoundingBox) ProtoMessage added in v0.3.0

func (*BoundingBox) ProtoMessage()

func (*BoundingBox) Reset added in v0.3.0

func (m *BoundingBox) Reset()

func (*BoundingBox) Size added in v0.3.0

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

func (*BoundingBox) String added in v0.3.0

func (this *BoundingBox) String() string

func (*BoundingBox) ToXYWH added in v0.3.0

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

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

func (*BoundingBox) ToxyXY added in v0.3.0

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

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

func (*BoundingBox) Unmarshal added in v0.3.0

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

func (*BoundingBox) VerboseEqual added in v0.3.0

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

func (*BoundingBox) Width added in v0.3.0

func (b *BoundingBox) Width() float32

func (*BoundingBox) XXX_DiscardUnknown added in v0.3.0

func (m *BoundingBox) XXX_DiscardUnknown()

func (*BoundingBox) XXX_Marshal added in v0.3.0

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

func (*BoundingBox) XXX_Merge added in v0.3.0

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

func (*BoundingBox) XXX_Size added in v0.3.0

func (m *BoundingBox) XXX_Size() int

func (*BoundingBox) XXX_Unmarshal added in v0.3.0

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

type CPUOptions added in v0.2.19

type CPUOptions struct {
}

func NewPopulatedCPUOptions added in v0.2.19

func NewPopulatedCPUOptions(r randyPredictor, easy bool) *CPUOptions

func (*CPUOptions) Descriptor added in v0.2.19

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

func (*CPUOptions) Equal added in v0.2.19

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

func (*CPUOptions) GoString added in v0.2.19

func (this *CPUOptions) GoString() string

func (*CPUOptions) Marshal added in v0.2.19

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

func (*CPUOptions) MarshalTo added in v0.2.19

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

func (*CPUOptions) MarshalToSizedBuffer added in v1.3.6

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

func (*CPUOptions) ProtoMessage added in v0.2.19

func (*CPUOptions) ProtoMessage()

func (*CPUOptions) Reset added in v0.2.19

func (m *CPUOptions) Reset()

func (*CPUOptions) Size added in v0.2.19

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

func (*CPUOptions) String added in v0.2.19

func (this *CPUOptions) String() string

func (*CPUOptions) Unmarshal added in v0.2.19

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

func (*CPUOptions) VerboseEqual added in v0.2.19

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

func (*CPUOptions) XXX_DiscardUnknown added in v0.3.0

func (m *CPUOptions) XXX_DiscardUnknown()

func (*CPUOptions) XXX_Marshal added in v0.3.0

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

func (*CPUOptions) XXX_Merge added in v0.3.0

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

func (*CPUOptions) XXX_Size added in v0.3.0

func (m *CPUOptions) XXX_Size() int

func (*CPUOptions) XXX_Unmarshal added in v0.3.0

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

type Classification added in v0.3.0

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 added in v0.3.0

func NewPopulatedClassification(r randyFeatures, easy bool) *Classification

func (*Classification) Description added in v0.3.0

func (*Classification) Descriptor added in v0.3.0

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

func (*Classification) Equal added in v0.3.0

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

func (*Classification) GetIndex added in v0.3.0

func (m *Classification) GetIndex() int32

func (*Classification) GetLabel added in v0.3.0

func (m *Classification) GetLabel() string

func (*Classification) GoString added in v0.3.0

func (this *Classification) GoString() string

func (*Classification) Marshal added in v0.3.0

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

func (*Classification) MarshalTo added in v0.3.0

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

func (*Classification) MarshalToSizedBuffer added in v1.3.6

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

func (*Classification) ProtoMessage added in v0.3.0

func (*Classification) ProtoMessage()

func (*Classification) Reset added in v0.3.0

func (m *Classification) Reset()

func (*Classification) Size added in v0.3.0

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

func (*Classification) String added in v0.3.0

func (this *Classification) String() string

func (*Classification) Unmarshal added in v0.3.0

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

func (*Classification) VerboseEqual added in v0.3.0

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

func (*Classification) XXX_DiscardUnknown added in v0.3.0

func (m *Classification) XXX_DiscardUnknown()

func (*Classification) XXX_Marshal added in v0.3.0

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

func (*Classification) XXX_Merge added in v0.3.0

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

func (*Classification) XXX_Size added in v0.3.0

func (m *Classification) XXX_Size() int

func (*Classification) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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) MarshalToSizedBuffer added in v1.3.6

func (m *ContainerHardware) MarshalToSizedBuffer(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 added in v0.3.0

func (m *ContainerHardware) XXX_DiscardUnknown()

func (*ContainerHardware) XXX_Marshal added in v0.3.0

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

func (*ContainerHardware) XXX_Merge added in v0.3.0

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

func (*ContainerHardware) XXX_Size added in v0.3.0

func (m *ContainerHardware) XXX_Size() int

func (*ContainerHardware) XXX_Unmarshal added in v0.3.0

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

type DatasetRequest added in v0.2.16

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 added in v0.2.16

func NewPopulatedDatasetRequest(r randyPredictor, easy bool) *DatasetRequest

func (*DatasetRequest) Description added in v0.2.16

func (*DatasetRequest) Descriptor added in v0.2.16

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

func (*DatasetRequest) Equal added in v0.2.16

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

func (*DatasetRequest) GetDataset added in v0.2.16

func (m *DatasetRequest) GetDataset() *DatasetRequest_Dataset

func (*DatasetRequest) GetOptions added in v0.2.16

func (m *DatasetRequest) GetOptions() *PredictionOptions

func (*DatasetRequest) GetPredictor added in v0.2.16

func (m *DatasetRequest) GetPredictor() *Predictor

func (*DatasetRequest) GoString added in v0.2.16

func (this *DatasetRequest) GoString() string

func (*DatasetRequest) Marshal added in v0.2.16

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

func (*DatasetRequest) MarshalTo added in v0.2.16

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

func (*DatasetRequest) MarshalToSizedBuffer added in v1.3.6

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

func (*DatasetRequest) ProtoMessage added in v0.2.16

func (*DatasetRequest) ProtoMessage()

func (*DatasetRequest) Reset added in v0.2.16

func (m *DatasetRequest) Reset()

func (*DatasetRequest) Size added in v0.2.16

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

func (*DatasetRequest) String added in v0.2.16

func (this *DatasetRequest) String() string

func (*DatasetRequest) Unmarshal added in v0.2.16

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

func (*DatasetRequest) VerboseEqual added in v0.2.16

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

func (*DatasetRequest) XXX_DiscardUnknown added in v0.3.0

func (m *DatasetRequest) XXX_DiscardUnknown()

func (*DatasetRequest) XXX_Marshal added in v0.3.0

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

func (*DatasetRequest) XXX_Merge added in v0.3.0

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

func (*DatasetRequest) XXX_Size added in v0.3.0

func (m *DatasetRequest) XXX_Size() int

func (*DatasetRequest) XXX_Unmarshal added in v0.3.0

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

type DatasetRequest_Dataset added in v0.2.16

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

func NewPopulatedDatasetRequest_Dataset added in v0.2.16

func NewPopulatedDatasetRequest_Dataset(r randyPredictor, easy bool) *DatasetRequest_Dataset

func (*DatasetRequest_Dataset) Descriptor added in v0.2.16

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

func (*DatasetRequest_Dataset) Equal added in v0.2.16

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

func (*DatasetRequest_Dataset) GetCategory added in v0.2.16

func (m *DatasetRequest_Dataset) GetCategory() string

func (*DatasetRequest_Dataset) GetName added in v0.2.16

func (m *DatasetRequest_Dataset) GetName() string

func (*DatasetRequest_Dataset) GoString added in v0.2.16

func (this *DatasetRequest_Dataset) GoString() string

func (*DatasetRequest_Dataset) Marshal added in v0.2.16

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

func (*DatasetRequest_Dataset) MarshalTo added in v0.2.16

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

func (*DatasetRequest_Dataset) MarshalToSizedBuffer added in v1.3.6

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

func (*DatasetRequest_Dataset) ProtoMessage added in v0.2.16

func (*DatasetRequest_Dataset) ProtoMessage()

func (*DatasetRequest_Dataset) Reset added in v0.2.16

func (m *DatasetRequest_Dataset) Reset()

func (*DatasetRequest_Dataset) Size added in v0.2.16

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

func (*DatasetRequest_Dataset) String added in v0.2.16

func (this *DatasetRequest_Dataset) String() string

func (*DatasetRequest_Dataset) Unmarshal added in v0.2.16

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

func (*DatasetRequest_Dataset) VerboseEqual added in v0.2.16

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

func (*DatasetRequest_Dataset) XXX_DiscardUnknown added in v0.3.0

func (m *DatasetRequest_Dataset) XXX_DiscardUnknown()

func (*DatasetRequest_Dataset) XXX_Marshal added in v0.3.0

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

func (*DatasetRequest_Dataset) XXX_Merge added in v0.3.0

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

func (*DatasetRequest_Dataset) XXX_Size added in v0.3.0

func (m *DatasetRequest_Dataset) XXX_Size() int

func (*DatasetRequest_Dataset) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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) MarshalToSizedBuffer added in v1.3.6

func (m *ErrorStatus) MarshalToSizedBuffer(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 added in v0.3.0

func (m *ErrorStatus) XXX_DiscardUnknown()

func (*ErrorStatus) XXX_Marshal added in v0.3.0

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

func (*ErrorStatus) XXX_Merge added in v0.3.0

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

func (*ErrorStatus) XXX_Size added in v0.3.0

func (m *ErrorStatus) XXX_Size() int

func (*ErrorStatus) XXX_Unmarshal added in v0.3.0

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

type ExecutionOptions added in v0.2.19

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 added in v0.2.19

func NewPopulatedExecutionOptions(r randyPredictor, easy bool) *ExecutionOptions

func (*ExecutionOptions) Descriptor added in v0.2.19

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

func (*ExecutionOptions) Equal added in v0.2.19

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

func (*ExecutionOptions) GetCpuOptions added in v0.2.19

func (m *ExecutionOptions) GetCpuOptions() *CPUOptions

func (*ExecutionOptions) GetDeviceCount added in v0.2.19

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

func (*ExecutionOptions) GetGpuOptions added in v0.2.19

func (m *ExecutionOptions) GetGpuOptions() *GPUOptions

func (*ExecutionOptions) GetTimeoutInMs added in v0.2.19

func (m *ExecutionOptions) GetTimeoutInMs() uint64

func (*ExecutionOptions) GetTraceId added in v0.3.0

func (m *ExecutionOptions) GetTraceId() *TraceID

func (*ExecutionOptions) GetTraceLevel added in v0.2.19

func (m *ExecutionOptions) GetTraceLevel() ExecutionOptions_TraceLevel

func (*ExecutionOptions) GoString added in v0.2.19

func (this *ExecutionOptions) GoString() string

func (*ExecutionOptions) Marshal added in v0.2.19

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

func (*ExecutionOptions) MarshalTo added in v0.2.19

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

func (*ExecutionOptions) MarshalToSizedBuffer added in v1.3.6

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

func (*ExecutionOptions) ProtoMessage added in v0.2.19

func (*ExecutionOptions) ProtoMessage()

func (*ExecutionOptions) Reset added in v0.2.19

func (m *ExecutionOptions) Reset()

func (*ExecutionOptions) Size added in v0.2.19

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

func (*ExecutionOptions) String added in v0.2.19

func (this *ExecutionOptions) String() string

func (*ExecutionOptions) Unmarshal added in v0.2.19

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

func (*ExecutionOptions) VerboseEqual added in v0.2.19

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

func (*ExecutionOptions) XXX_DiscardUnknown added in v0.3.0

func (m *ExecutionOptions) XXX_DiscardUnknown()

func (*ExecutionOptions) XXX_Marshal added in v0.3.0

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

func (*ExecutionOptions) XXX_Merge added in v0.3.0

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

func (*ExecutionOptions) XXX_Size added in v0.3.0

func (m *ExecutionOptions) XXX_Size() int

func (*ExecutionOptions) XXX_Unmarshal added in v0.3.0

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

type ExecutionOptions_TraceLevel added in v0.2.19

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 added in v0.2.19

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

func (ExecutionOptions_TraceLevel) String added in v0.2.19

type Feature added in v0.2.16

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_General
	//	*Feature_Raw
	Feature isFeature_Feature `protobuf_oneof:"feature"`
}

func NewPopulatedFeature added in v0.2.16

func NewPopulatedFeature(r randyFeatures, easy bool) *Feature

func (*Feature) Description added in v0.2.16

func (*Feature) Descriptor added in v0.2.16

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

func (*Feature) Equal added in v0.2.16

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

func (*Feature) GetAudio added in v0.3.0

func (m *Feature) GetAudio() *Audio

func (*Feature) GetBoundingBox added in v0.3.0

func (m *Feature) GetBoundingBox() *BoundingBox

func (*Feature) GetClassification added in v0.3.0

func (m *Feature) GetClassification() *Classification

func (*Feature) GetFeature added in v0.3.0

func (m *Feature) GetFeature() isFeature_Feature

func (*Feature) GetGeneral added in v1.4.0

func (m *Feature) GetGeneral() *General

func (*Feature) GetGeolocation added in v0.3.0

func (m *Feature) GetGeolocation() *GeoLocation

func (*Feature) GetID added in v0.3.0

func (m *Feature) GetID() string

func (*Feature) GetImage added in v0.3.0

func (m *Feature) GetImage() *Image

func (*Feature) GetInstanceSegment added in v0.3.0

func (m *Feature) GetInstanceSegment() *InstanceSegment

func (*Feature) GetMetadata added in v0.2.16

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

func (*Feature) GetProbability added in v0.2.16

func (m *Feature) GetProbability() float32

func (*Feature) GetRaw added in v0.3.0

func (m *Feature) GetRaw() *Raw

func (*Feature) GetRawImage added in v0.3.0

func (m *Feature) GetRawImage() *RawImage

func (*Feature) GetRegion added in v0.3.0

func (m *Feature) GetRegion() *Region

func (*Feature) GetSemanticSegment added in v0.3.0

func (m *Feature) GetSemanticSegment() *SemanticSegment

func (*Feature) GetText added in v0.3.0

func (m *Feature) GetText() *Text

func (*Feature) GetType added in v0.3.0

func (m *Feature) GetType() FeatureType

func (*Feature) GoString added in v0.2.16

func (this *Feature) GoString() string

func (*Feature) Marshal added in v0.2.16

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

func (*Feature) MarshalTo added in v0.2.16

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

func (*Feature) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature) ProtoMessage added in v0.2.16

func (*Feature) ProtoMessage()

func (*Feature) Reset added in v0.2.16

func (m *Feature) Reset()

func (*Feature) Size added in v0.2.16

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

func (*Feature) String added in v0.2.16

func (this *Feature) String() string

func (*Feature) Unmarshal added in v0.2.16

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

func (*Feature) VerboseEqual added in v0.2.16

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

func (*Feature) XXX_DiscardUnknown added in v0.3.0

func (m *Feature) XXX_DiscardUnknown()

func (*Feature) XXX_Marshal added in v0.3.0

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

func (*Feature) XXX_Merge added in v0.3.0

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

func (*Feature) XXX_OneofWrappers added in v1.3.6

func (*Feature) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Feature) XXX_Size added in v0.3.0

func (m *Feature) XXX_Size() int

func (*Feature) XXX_Unmarshal added in v0.3.0

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

type FeatureCompareMethod added in v0.3.0

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

func FeatureCompareMethodString added in v0.3.0

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 added in v0.3.0

func FeatureCompareMethodValues() []FeatureCompareMethod

FeatureCompareMethodValues returns all values of the enum

func (FeatureCompareMethod) IsAFeatureCompareMethod added in v0.3.0

func (i FeatureCompareMethod) IsAFeatureCompareMethod() bool

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

func (FeatureCompareMethod) MarshalJSON added in v0.3.0

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

MarshalJSON implements the json.Marshaler interface for FeatureCompareMethod

func (FeatureCompareMethod) String added in v0.3.0

func (i FeatureCompareMethod) String() string

func (*FeatureCompareMethod) UnmarshalJSON added in v0.3.0

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

UnmarshalJSON implements the json.Unmarshaler interface for FeatureCompareMethod

type FeatureResponse added in v0.2.16

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

func NewPopulatedFeatureResponse added in v0.2.16

func NewPopulatedFeatureResponse(r randyPredictor, easy bool) *FeatureResponse

func (*FeatureResponse) Description added in v0.2.16

func (*FeatureResponse) Descriptor added in v0.2.16

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

func (*FeatureResponse) Equal added in v0.2.16

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

func (*FeatureResponse) GetFeatures added in v0.2.16

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

func (*FeatureResponse) GetID added in v0.2.16

func (m *FeatureResponse) GetID() string

func (*FeatureResponse) GetInputID added in v0.2.16

func (m *FeatureResponse) GetInputID() string

func (*FeatureResponse) GetMetadata added in v0.2.16

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

func (*FeatureResponse) GetRequestID added in v0.2.16

func (m *FeatureResponse) GetRequestID() string

func (*FeatureResponse) GoString added in v0.2.16

func (this *FeatureResponse) GoString() string

func (*FeatureResponse) Marshal added in v0.2.16

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

func (*FeatureResponse) MarshalTo added in v0.2.16

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

func (*FeatureResponse) MarshalToSizedBuffer added in v1.3.6

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

func (*FeatureResponse) ProtoMessage added in v0.2.16

func (*FeatureResponse) ProtoMessage()

func (*FeatureResponse) Reset added in v0.2.16

func (m *FeatureResponse) Reset()

func (*FeatureResponse) Size added in v0.2.16

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

func (*FeatureResponse) String added in v0.2.16

func (this *FeatureResponse) String() string

func (*FeatureResponse) Unmarshal added in v0.2.16

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

func (*FeatureResponse) VerboseEqual added in v0.2.16

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

func (*FeatureResponse) XXX_DiscardUnknown added in v0.3.0

func (m *FeatureResponse) XXX_DiscardUnknown()

func (*FeatureResponse) XXX_Marshal added in v0.3.0

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

func (*FeatureResponse) XXX_Merge added in v0.3.0

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

func (*FeatureResponse) XXX_Size added in v0.3.0

func (m *FeatureResponse) XXX_Size() int

func (*FeatureResponse) XXX_Unmarshal added in v0.3.0

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

type FeatureType added in v0.3.0

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_GENERAL         FeatureType = 11
	FeatureType_RAW             FeatureType = 100
)

func (FeatureType) EnumDescriptor added in v0.3.0

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

func (FeatureType) String added in v0.3.0

func (x FeatureType) String() string

type Feature_Audio added in v0.3.0

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

func NewPopulatedFeature_Audio added in v0.3.0

func NewPopulatedFeature_Audio(r randyFeatures, easy bool) *Feature_Audio

func (*Feature_Audio) Equal added in v0.3.0

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

func (*Feature_Audio) GoString added in v0.3.0

func (this *Feature_Audio) GoString() string

func (*Feature_Audio) MarshalTo added in v0.3.0

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

func (*Feature_Audio) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_Audio) Size added in v0.3.0

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

func (*Feature_Audio) String added in v0.3.0

func (this *Feature_Audio) String() string

func (*Feature_Audio) VerboseEqual added in v0.3.0

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

type Feature_BoundingBox added in v0.3.0

type Feature_BoundingBox struct {
	BoundingBox *BoundingBox `` /* 129-byte string literal not displayed */
}

func NewPopulatedFeature_BoundingBox added in v0.3.0

func NewPopulatedFeature_BoundingBox(r randyFeatures, easy bool) *Feature_BoundingBox

func (*Feature_BoundingBox) Equal added in v0.3.0

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

func (*Feature_BoundingBox) GoString added in v0.3.0

func (this *Feature_BoundingBox) GoString() string

func (*Feature_BoundingBox) MarshalTo added in v0.3.0

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

func (*Feature_BoundingBox) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_BoundingBox) Size added in v0.3.0

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

func (*Feature_BoundingBox) String added in v0.3.0

func (this *Feature_BoundingBox) String() string

func (*Feature_BoundingBox) VerboseEqual added in v0.3.0

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

type Feature_Classification added in v0.3.0

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

func NewPopulatedFeature_Classification added in v0.3.0

func NewPopulatedFeature_Classification(r randyFeatures, easy bool) *Feature_Classification

func (*Feature_Classification) Equal added in v0.3.0

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

func (*Feature_Classification) GoString added in v0.3.0

func (this *Feature_Classification) GoString() string

func (*Feature_Classification) MarshalTo added in v0.3.0

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

func (*Feature_Classification) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_Classification) Size added in v0.3.0

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

func (*Feature_Classification) String added in v0.3.0

func (this *Feature_Classification) String() string

func (*Feature_Classification) VerboseEqual added in v0.3.0

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

type Feature_General added in v1.4.0

type Feature_General struct {
	General *General `protobuf:"bytes,16,opt,name=general,proto3,oneof" json:"general,omitempty" yaml:"general,omitempty"`
}

func NewPopulatedFeature_General added in v1.4.0

func NewPopulatedFeature_General(r randyFeatures, easy bool) *Feature_General

func (*Feature_General) Equal added in v1.4.0

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

func (*Feature_General) GoString added in v1.4.0

func (this *Feature_General) GoString() string

func (*Feature_General) MarshalTo added in v1.4.0

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

func (*Feature_General) MarshalToSizedBuffer added in v1.4.0

func (m *Feature_General) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Feature_General) Size added in v1.4.0

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

func (*Feature_General) String added in v1.4.0

func (this *Feature_General) String() string

func (*Feature_General) VerboseEqual added in v1.4.0

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

type Feature_Geolocation added in v0.3.0

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

func NewPopulatedFeature_Geolocation added in v0.3.0

func NewPopulatedFeature_Geolocation(r randyFeatures, easy bool) *Feature_Geolocation

func (*Feature_Geolocation) Equal added in v0.3.0

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

func (*Feature_Geolocation) GoString added in v0.3.0

func (this *Feature_Geolocation) GoString() string

func (*Feature_Geolocation) MarshalTo added in v0.3.0

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

func (*Feature_Geolocation) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_Geolocation) Size added in v0.3.0

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

func (*Feature_Geolocation) String added in v0.3.0

func (this *Feature_Geolocation) String() string

func (*Feature_Geolocation) VerboseEqual added in v0.3.0

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

type Feature_Image added in v0.3.0

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

func NewPopulatedFeature_Image added in v0.3.0

func NewPopulatedFeature_Image(r randyFeatures, easy bool) *Feature_Image

func (*Feature_Image) Equal added in v0.3.0

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

func (*Feature_Image) GoString added in v0.3.0

func (this *Feature_Image) GoString() string

func (*Feature_Image) MarshalTo added in v0.3.0

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

func (*Feature_Image) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_Image) Size added in v0.3.0

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

func (*Feature_Image) String added in v0.3.0

func (this *Feature_Image) String() string

func (*Feature_Image) VerboseEqual added in v0.3.0

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

type Feature_InstanceSegment added in v0.3.0

type Feature_InstanceSegment struct {
	InstanceSegment *InstanceSegment `` /* 146-byte string literal not displayed */
}

func NewPopulatedFeature_InstanceSegment added in v0.3.0

func NewPopulatedFeature_InstanceSegment(r randyFeatures, easy bool) *Feature_InstanceSegment

func (*Feature_InstanceSegment) Equal added in v0.3.0

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

func (*Feature_InstanceSegment) GoString added in v0.3.0

func (this *Feature_InstanceSegment) GoString() string

func (*Feature_InstanceSegment) MarshalTo added in v0.3.0

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

func (*Feature_InstanceSegment) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_InstanceSegment) Size added in v0.3.0

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

func (*Feature_InstanceSegment) String added in v0.3.0

func (this *Feature_InstanceSegment) String() string

func (*Feature_InstanceSegment) VerboseEqual added in v0.3.0

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

type Feature_Raw added in v0.3.0

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

func NewPopulatedFeature_Raw added in v0.3.0

func NewPopulatedFeature_Raw(r randyFeatures, easy bool) *Feature_Raw

func (*Feature_Raw) Equal added in v0.3.0

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

func (*Feature_Raw) GoString added in v0.3.0

func (this *Feature_Raw) GoString() string

func (*Feature_Raw) MarshalTo added in v0.3.0

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

func (*Feature_Raw) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_Raw) Size added in v0.3.0

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

func (*Feature_Raw) String added in v0.3.0

func (this *Feature_Raw) String() string

func (*Feature_Raw) VerboseEqual added in v0.3.0

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

type Feature_RawImage added in v0.3.0

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

func NewPopulatedFeature_RawImage added in v0.3.0

func NewPopulatedFeature_RawImage(r randyFeatures, easy bool) *Feature_RawImage

func (*Feature_RawImage) Equal added in v0.3.0

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

func (*Feature_RawImage) GoString added in v0.3.0

func (this *Feature_RawImage) GoString() string

func (*Feature_RawImage) MarshalTo added in v0.3.0

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

func (*Feature_RawImage) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_RawImage) Size added in v0.3.0

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

func (*Feature_RawImage) String added in v0.3.0

func (this *Feature_RawImage) String() string

func (*Feature_RawImage) VerboseEqual added in v0.3.0

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

type Feature_Region added in v0.3.0

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

func NewPopulatedFeature_Region added in v0.3.0

func NewPopulatedFeature_Region(r randyFeatures, easy bool) *Feature_Region

func (*Feature_Region) Equal added in v0.3.0

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

func (*Feature_Region) GoString added in v0.3.0

func (this *Feature_Region) GoString() string

func (*Feature_Region) MarshalTo added in v0.3.0

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

func (*Feature_Region) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_Region) Size added in v0.3.0

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

func (*Feature_Region) String added in v0.3.0

func (this *Feature_Region) String() string

func (*Feature_Region) VerboseEqual added in v0.3.0

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

type Feature_SemanticSegment added in v0.3.0

type Feature_SemanticSegment struct {
	SemanticSegment *SemanticSegment `` /* 147-byte string literal not displayed */
}

func NewPopulatedFeature_SemanticSegment added in v0.3.0

func NewPopulatedFeature_SemanticSegment(r randyFeatures, easy bool) *Feature_SemanticSegment

func (*Feature_SemanticSegment) Equal added in v0.3.0

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

func (*Feature_SemanticSegment) GoString added in v0.3.0

func (this *Feature_SemanticSegment) GoString() string

func (*Feature_SemanticSegment) MarshalTo added in v0.3.0

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

func (*Feature_SemanticSegment) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_SemanticSegment) Size added in v0.3.0

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

func (*Feature_SemanticSegment) String added in v0.3.0

func (this *Feature_SemanticSegment) String() string

func (*Feature_SemanticSegment) VerboseEqual added in v0.3.0

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

type Feature_Text added in v0.3.0

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

func NewPopulatedFeature_Text added in v0.3.0

func NewPopulatedFeature_Text(r randyFeatures, easy bool) *Feature_Text

func (*Feature_Text) Equal added in v0.3.0

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

func (*Feature_Text) GoString added in v0.3.0

func (this *Feature_Text) GoString() string

func (*Feature_Text) MarshalTo added in v0.3.0

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

func (*Feature_Text) MarshalToSizedBuffer added in v1.3.6

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

func (*Feature_Text) Size added in v0.3.0

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

func (*Feature_Text) String added in v0.3.0

func (this *Feature_Text) String() string

func (*Feature_Text) VerboseEqual added in v0.3.0

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

type Features added in v0.2.16

type Features []*Feature

func (Features) Bhattacharyya added in v0.2.19

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

func (Features) Correlation added in v0.2.19

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

func (Features) Covariance added in v0.2.19

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

func (Features) Hellinger added in v0.2.19

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

func (Features) JensenShannon added in v0.2.19

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

func (Features) KullbackLeiblerDivergence added in v0.2.19

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

func (Features) Len added in v0.2.16

func (p Features) Len() int

Len is the number of elements in the collection.

func (Features) Less added in v0.2.16

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

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

func (Features) ProbabilitiesApplySoftmaxFloat32 added in v0.3.0

func (p Features) ProbabilitiesApplySoftmaxFloat32() Features

func (Features) ProbabilitiesApplySoftmaxFloat64 added in v0.3.0

func (p Features) ProbabilitiesApplySoftmaxFloat64() Features

func (Features) ProbabilitiesFloat32 added in v0.2.19

func (p Features) ProbabilitiesFloat32() []float32

func (Features) ProbabilitiesFloat64 added in v0.2.19

func (p Features) ProbabilitiesFloat64() []float64

func (Features) ProbabilitiesSoftmaxFloat32 added in v0.3.0

func (p Features) ProbabilitiesSoftmaxFloat32() []float32

func (Features) ProbabilitiesSoftmaxFloat64 added in v0.3.0

func (p Features) ProbabilitiesSoftmaxFloat64() []float64

func (Features) Sort added in v0.2.16

func (p Features) Sort()

func (Features) Swap added in v0.2.16

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

Swap swaps the elements with indexes i and j.

func (Features) Take added in v0.2.16

func (p Features) Take(n int) Features

type FeaturesResponse added in v0.2.16

type FeaturesResponse struct {
	ID                   string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" yaml:"id,omitempty"`
	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 added in v0.2.16

func NewPopulatedFeaturesResponse(r randyPredictor, easy bool) *FeaturesResponse

func (*FeaturesResponse) Description added in v0.2.16

func (*FeaturesResponse) Descriptor added in v0.2.16

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

func (*FeaturesResponse) Equal added in v0.2.16

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

func (*FeaturesResponse) GetDuration added in v0.3.0

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

func (*FeaturesResponse) GetDurationForInference added in v0.3.0

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

func (*FeaturesResponse) GetID added in v0.2.16

func (m *FeaturesResponse) GetID() string

func (*FeaturesResponse) GetResponses added in v0.2.16

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

func (*FeaturesResponse) GetTraceId added in v0.3.0

func (m *FeaturesResponse) GetTraceId() *TraceID

func (*FeaturesResponse) GoString added in v0.2.16

func (this *FeaturesResponse) GoString() string

func (*FeaturesResponse) Marshal added in v0.2.16

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

func (*FeaturesResponse) MarshalTo added in v0.2.16

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

func (*FeaturesResponse) MarshalToSizedBuffer added in v1.3.6

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

func (*FeaturesResponse) ProtoMessage added in v0.2.16

func (*FeaturesResponse) ProtoMessage()

func (*FeaturesResponse) Reset added in v0.2.16

func (m *FeaturesResponse) Reset()

func (*FeaturesResponse) Size added in v0.2.16

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

func (*FeaturesResponse) String added in v0.2.16

func (this *FeaturesResponse) String() string

func (*FeaturesResponse) Unmarshal added in v0.2.16

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

func (*FeaturesResponse) VerboseEqual added in v0.2.16

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

func (*FeaturesResponse) XXX_DiscardUnknown added in v0.3.0

func (m *FeaturesResponse) XXX_DiscardUnknown()

func (*FeaturesResponse) XXX_Marshal added in v0.3.0

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

func (*FeaturesResponse) XXX_Merge added in v0.3.0

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

func (*FeaturesResponse) XXX_Size added in v0.3.0

func (m *FeaturesResponse) XXX_Size() int

func (*FeaturesResponse) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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) GetModelManifestFromUrl added in v1.4.6

func (f FrameworkManifest) GetModelManifestFromUrl(url string) (*ModelManifest, error)

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) MarshalToSizedBuffer added in v1.3.6

func (m *FrameworkManifest) MarshalToSizedBuffer(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 added in v0.3.0

func (m *FrameworkManifest) XXX_DiscardUnknown()

func (*FrameworkManifest) XXX_Marshal added in v0.3.0

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

func (*FrameworkManifest) XXX_Merge added in v0.3.0

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

func (*FrameworkManifest) XXX_Size added in v0.3.0

func (m *FrameworkManifest) XXX_Size() int

func (*FrameworkManifest) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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) MarshalToSizedBuffer added in v1.3.6

func (m *FrameworkManifestsResponse) MarshalToSizedBuffer(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 added in v0.3.0

func (m *FrameworkManifestsResponse) XXX_DiscardUnknown()

func (*FrameworkManifestsResponse) XXX_Marshal added in v0.3.0

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

func (*FrameworkManifestsResponse) XXX_Merge added in v0.3.0

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

func (*FrameworkManifestsResponse) XXX_Size added in v0.3.0

func (m *FrameworkManifestsResponse) XXX_Size() int

func (*FrameworkManifestsResponse) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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) MarshalToSizedBuffer added in v1.3.6

func (m *FrameworkRequest) MarshalToSizedBuffer(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 added in v0.3.0

func (m *FrameworkRequest) XXX_DiscardUnknown()

func (*FrameworkRequest) XXX_Marshal added in v0.3.0

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

func (*FrameworkRequest) XXX_Merge added in v0.3.0

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

func (*FrameworkRequest) XXX_Size added in v0.3.0

func (m *FrameworkRequest) XXX_Size() int

func (*FrameworkRequest) XXX_Unmarshal added in v0.3.0

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

type GPUOptions added in v0.2.19

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

func NewPopulatedGPUOptions added in v0.2.19

func NewPopulatedGPUOptions(r randyPredictor, easy bool) *GPUOptions

func (*GPUOptions) Descriptor added in v0.2.19

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

func (*GPUOptions) Equal added in v0.2.19

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

func (*GPUOptions) GetAllocatorType added in v0.2.19

func (m *GPUOptions) GetAllocatorType() string

func (*GPUOptions) GetForceGpuCompatible added in v0.2.19

func (m *GPUOptions) GetForceGpuCompatible() bool

func (*GPUOptions) GetPerProcessGpuMemoryFraction added in v0.2.19

func (m *GPUOptions) GetPerProcessGpuMemoryFraction() float64

func (*GPUOptions) GetVisibleDeviceList added in v0.2.19

func (m *GPUOptions) GetVisibleDeviceList() string

func (*GPUOptions) GoString added in v0.2.19

func (this *GPUOptions) GoString() string

func (*GPUOptions) Marshal added in v0.2.19

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

func (*GPUOptions) MarshalTo added in v0.2.19

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

func (*GPUOptions) MarshalToSizedBuffer added in v1.3.6

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

func (*GPUOptions) ProtoMessage added in v0.2.19

func (*GPUOptions) ProtoMessage()

func (*GPUOptions) Reset added in v0.2.19

func (m *GPUOptions) Reset()

func (*GPUOptions) Size added in v0.2.19

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

func (*GPUOptions) String added in v0.2.19

func (this *GPUOptions) String() string

func (*GPUOptions) Unmarshal added in v0.2.19

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

func (*GPUOptions) VerboseEqual added in v0.2.19

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

func (*GPUOptions) XXX_DiscardUnknown added in v0.3.0

func (m *GPUOptions) XXX_DiscardUnknown()

func (*GPUOptions) XXX_Marshal added in v0.3.0

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

func (*GPUOptions) XXX_Merge added in v0.3.0

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

func (*GPUOptions) XXX_Size added in v0.3.0

func (m *GPUOptions) XXX_Size() int

func (*GPUOptions) XXX_Unmarshal added in v0.3.0

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

type General added in v1.4.0

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

func NewPopulatedGeneral added in v1.4.0

func NewPopulatedGeneral(r randyFeatures, easy bool) *General

func (*General) Description added in v1.4.0

func (*General) Descriptor added in v1.4.0

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

func (*General) Equal added in v1.4.0

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

func (*General) GetData added in v1.4.0

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

func (*General) GoString added in v1.4.0

func (this *General) GoString() string

func (*General) Marshal added in v1.4.0

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

func (*General) MarshalTo added in v1.4.0

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

func (*General) MarshalToSizedBuffer added in v1.4.0

func (m *General) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*General) ProtoMessage added in v1.4.0

func (*General) ProtoMessage()

func (*General) Reset added in v1.4.0

func (m *General) Reset()

func (*General) Size added in v1.4.0

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

func (*General) String added in v1.4.0

func (this *General) String() string

func (*General) Unmarshal added in v1.4.0

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

func (*General) VerboseEqual added in v1.4.0

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

func (*General) XXX_DiscardUnknown added in v1.4.0

func (m *General) XXX_DiscardUnknown()

func (*General) XXX_Marshal added in v1.4.0

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

func (*General) XXX_Merge added in v1.4.0

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

func (*General) XXX_Size added in v1.4.0

func (m *General) XXX_Size() int

func (*General) XXX_Unmarshal added in v1.4.0

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

type GeoLocation added in v0.3.0

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 added in v0.3.0

func NewPopulatedGeoLocation(r randyFeatures, easy bool) *GeoLocation

func (*GeoLocation) Description added in v0.3.0

func (*GeoLocation) Descriptor added in v0.3.0

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

func (*GeoLocation) Equal added in v0.3.0

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

func (*GeoLocation) GetIndex added in v0.3.0

func (m *GeoLocation) GetIndex() int32

func (*GeoLocation) GetLatitude added in v0.3.0

func (m *GeoLocation) GetLatitude() float32

func (*GeoLocation) GetLongitude added in v0.3.0

func (m *GeoLocation) GetLongitude() float32

func (*GeoLocation) GoString added in v0.3.0

func (this *GeoLocation) GoString() string

func (*GeoLocation) Marshal added in v0.3.0

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

func (*GeoLocation) MarshalTo added in v0.3.0

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

func (*GeoLocation) MarshalToSizedBuffer added in v1.3.6

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

func (*GeoLocation) ProtoMessage added in v0.3.0

func (*GeoLocation) ProtoMessage()

func (*GeoLocation) Reset added in v0.3.0

func (m *GeoLocation) Reset()

func (*GeoLocation) Size added in v0.3.0

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

func (*GeoLocation) String added in v0.3.0

func (this *GeoLocation) String() string

func (*GeoLocation) Unmarshal added in v0.3.0

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

func (*GeoLocation) VerboseEqual added in v0.3.0

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

func (*GeoLocation) XXX_DiscardUnknown added in v0.3.0

func (m *GeoLocation) XXX_DiscardUnknown()

func (*GeoLocation) XXX_Marshal added in v0.3.0

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

func (*GeoLocation) XXX_Merge added in v0.3.0

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

func (*GeoLocation) XXX_Size added in v0.3.0

func (m *GeoLocation) XXX_Size() int

func (*GeoLocation) XXX_Unmarshal added in v0.3.0

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

type Image added in v0.3.0

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 added in v0.3.0

func NewPopulatedImage(r randyFeatures, easy bool) *Image

func (*Image) Descriptor added in v0.3.0

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

func (*Image) Equal added in v0.3.0

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

func (*Image) GetData added in v0.3.0

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

func (*Image) GetID added in v0.3.0

func (m *Image) GetID() string

func (*Image) GoString added in v0.3.0

func (this *Image) GoString() string

func (*Image) Marshal added in v0.3.0

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

func (*Image) MarshalTo added in v0.3.0

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

func (*Image) MarshalToSizedBuffer added in v1.3.6

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

func (*Image) ProtoMessage added in v0.3.0

func (*Image) ProtoMessage()

func (*Image) Reset added in v0.3.0

func (m *Image) Reset()

func (*Image) Size added in v0.3.0

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

func (*Image) String added in v0.3.0

func (this *Image) String() string

func (*Image) Unmarshal added in v0.3.0

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

func (*Image) VerboseEqual added in v0.3.0

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

func (*Image) XXX_DiscardUnknown added in v0.3.0

func (m *Image) XXX_DiscardUnknown()

func (*Image) XXX_Marshal added in v0.3.0

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

func (*Image) XXX_Merge added in v0.3.0

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

func (*Image) XXX_Size added in v0.3.0

func (m *Image) XXX_Size() int

func (*Image) XXX_Unmarshal added in v0.3.0

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

type ImagesRequest added in v0.2.16

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 added in v0.2.16

func NewPopulatedImagesRequest(r randyPredictor, easy bool) *ImagesRequest

func (*ImagesRequest) Description added in v0.2.16

func (*ImagesRequest) Descriptor added in v0.2.16

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

func (*ImagesRequest) Equal added in v0.2.16

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

func (*ImagesRequest) GetImages added in v0.2.16

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

func (*ImagesRequest) GetOptions added in v0.2.16

func (m *ImagesRequest) GetOptions() *PredictionOptions

func (*ImagesRequest) GetPredictor added in v0.2.16

func (m *ImagesRequest) GetPredictor() *Predictor

func (*ImagesRequest) GoString added in v0.2.16

func (this *ImagesRequest) GoString() string

func (*ImagesRequest) Marshal added in v0.2.16

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

func (*ImagesRequest) MarshalTo added in v0.2.16

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

func (*ImagesRequest) MarshalToSizedBuffer added in v1.3.6

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

func (*ImagesRequest) ProtoMessage added in v0.2.16

func (*ImagesRequest) ProtoMessage()

func (*ImagesRequest) Reset added in v0.2.16

func (m *ImagesRequest) Reset()

func (*ImagesRequest) Size added in v0.2.16

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

func (*ImagesRequest) String added in v0.2.16

func (this *ImagesRequest) String() string

func (*ImagesRequest) Unmarshal added in v0.2.16

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

func (*ImagesRequest) VerboseEqual added in v0.2.16

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

func (*ImagesRequest) XXX_DiscardUnknown added in v0.3.0

func (m *ImagesRequest) XXX_DiscardUnknown()

func (*ImagesRequest) XXX_Marshal added in v0.3.0

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

func (*ImagesRequest) XXX_Merge added in v0.3.0

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

func (*ImagesRequest) XXX_Size added in v0.3.0

func (m *ImagesRequest) XXX_Size() int

func (*ImagesRequest) XXX_Unmarshal added in v0.3.0

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

type InstanceSegment added in v0.3.0

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 added in v0.3.0

func NewPopulatedInstanceSegment(r randyFeatures, easy bool) *InstanceSegment

func (*InstanceSegment) Description added in v0.3.0

func (*InstanceSegment) Descriptor added in v0.3.0

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

func (*InstanceSegment) Equal added in v0.3.0

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

func (*InstanceSegment) GetFloatMask added in v0.3.0

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

func (*InstanceSegment) GetHeight added in v0.3.0

func (m *InstanceSegment) GetHeight() int32

func (*InstanceSegment) GetIndex added in v0.3.0

func (m *InstanceSegment) GetIndex() int32

func (*InstanceSegment) GetIntMask added in v0.3.0

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

func (*InstanceSegment) GetLabel added in v0.3.0

func (m *InstanceSegment) GetLabel() string

func (*InstanceSegment) GetMaskType added in v0.3.0

func (m *InstanceSegment) GetMaskType() string

func (*InstanceSegment) GetWidth added in v0.3.0

func (m *InstanceSegment) GetWidth() int32

func (*InstanceSegment) GetXmax added in v0.3.0

func (m *InstanceSegment) GetXmax() float32

func (*InstanceSegment) GetXmin added in v0.3.0

func (m *InstanceSegment) GetXmin() float32

func (*InstanceSegment) GetYmax added in v0.3.0

func (m *InstanceSegment) GetYmax() float32

func (*InstanceSegment) GetYmin added in v0.3.0

func (m *InstanceSegment) GetYmin() float32

func (*InstanceSegment) GoString added in v0.3.0

func (this *InstanceSegment) GoString() string

func (*InstanceSegment) Marshal added in v0.3.0

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

func (*InstanceSegment) MarshalTo added in v0.3.0

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

func (*InstanceSegment) MarshalToSizedBuffer added in v1.3.6

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

func (*InstanceSegment) ProtoMessage added in v0.3.0

func (*InstanceSegment) ProtoMessage()

func (*InstanceSegment) Reset added in v0.3.0

func (m *InstanceSegment) Reset()

func (*InstanceSegment) Size added in v0.3.0

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

func (*InstanceSegment) String added in v0.3.0

func (this *InstanceSegment) String() string

func (*InstanceSegment) Unmarshal added in v0.3.0

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

func (*InstanceSegment) VerboseEqual added in v0.3.0

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

func (*InstanceSegment) XXX_DiscardUnknown added in v0.3.0

func (m *InstanceSegment) XXX_DiscardUnknown()

func (*InstanceSegment) XXX_Marshal added in v0.3.0

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

func (*InstanceSegment) XXX_Merge added in v0.3.0

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

func (*InstanceSegment) XXX_Size added in v0.3.0

func (m *InstanceSegment) XXX_Size() int

func (*InstanceSegment) XXX_Unmarshal added in v0.3.0

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

type Modality added in v0.3.0

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

func ParseModality added in v1.4.7

func ParseModality(input string) Modality

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"`
	Outputs           []*ModelManifest_Type         `protobuf:"bytes,9,rep,name=outputs,proto3" json:"outputs,omitempty" yaml:"outputs,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"`
	Modality          string                        `protobuf:"bytes,19,opt,name=modality,proto3" json:"modality,omitempty" yaml:"modality,omitempty"`
}

func NewPopulatedModelManifest

func NewPopulatedModelManifest(r randyRegistry, easy bool) *ModelManifest

func (*ModelManifest) CanonicalModality added in v1.4.0

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

func (ModelManifest) CanonicalName

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

func (*ModelManifest) Descriptor

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

func (*ModelManifest) DownloadIfNeeded added in v1.4.8

func (m *ModelManifest) DownloadIfNeeded() (err error)

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 added in v0.3.0

func (model ModelManifest) GetElementType(idxList ...int) string

func (*ModelManifest) GetFramework

func (m *ModelManifest) GetFramework() *FrameworkManifest

func (*ModelManifest) GetHidden

func (m *ModelManifest) GetHidden() bool

func (ModelManifest) GetInputDimensions added in v0.3.0

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

func (*ModelManifest) GetInputs

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

func (*ModelManifest) GetLicense

func (m *ModelManifest) GetLicense() string

func (*ModelManifest) GetModality added in v1.4.0

func (m *ModelManifest) GetModality() string

func (*ModelManifest) GetModel

func (m *ModelManifest) GetModel() *ModelManifest_Model

func (*ModelManifest) GetName

func (m *ModelManifest) GetName() string

func (*ModelManifest) GetOutputs added in v1.4.2

func (m *ModelManifest) GetOutputs() []*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) MarshalToSizedBuffer added in v1.3.6

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

func (ModelManifest) MustCanonicalName

func (m ModelManifest) MustCanonicalName() string

func (ModelManifest) MustResolveFramework added in v0.3.0

func (m ModelManifest) MustResolveFramework() FrameworkManifest

func (*ModelManifest) ProtoMessage

func (*ModelManifest) ProtoMessage()

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 added in v0.3.0

func (m *ModelManifest) XXX_DiscardUnknown()

func (*ModelManifest) XXX_Marshal added in v0.3.0

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

func (*ModelManifest) XXX_Merge added in v0.3.0

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

func (*ModelManifest) XXX_Size added in v0.3.0

func (m *ModelManifest) XXX_Size() int

func (*ModelManifest) XXX_Unmarshal added in v0.3.0

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 */
	FeaturesPath     string `` /* 128-byte string literal not displayed */
	FeaturesChecksum string `` /* 144-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) GetFeaturesChecksum added in v1.4.2

func (m *ModelManifest_Model) GetFeaturesChecksum() string

func (*ModelManifest_Model) GetFeaturesPath added in v1.4.2

func (m *ModelManifest_Model) GetFeaturesPath() string

func (*ModelManifest_Model) GetGraphChecksum added in v0.2.19

func (m *ModelManifest_Model) GetGraphChecksum() string

func (*ModelManifest_Model) GetGraphPath

func (m *ModelManifest_Model) GetGraphPath() string

func (*ModelManifest_Model) GetIsArchive

func (m *ModelManifest_Model) GetIsArchive() bool

func (*ModelManifest_Model) GetWeightsChecksum added in v0.2.19

func (m *ModelManifest_Model) GetWeightsChecksum() string

func (*ModelManifest_Model) GetWeightsPath

func (m *ModelManifest_Model) GetWeightsPath() string

func (*ModelManifest_Model) GoString

func (this *ModelManifest_Model) GoString() string

func (*ModelManifest_Model) Marshal

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

func (*ModelManifest_Model) MarshalTo

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

func (*ModelManifest_Model) MarshalToSizedBuffer added in v1.3.6

func (m *ModelManifest_Model) MarshalToSizedBuffer(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 added in v0.3.0

func (m *ModelManifest_Model) XXX_DiscardUnknown()

func (*ModelManifest_Model) XXX_Marshal added in v0.3.0

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

func (*ModelManifest_Model) XXX_Merge added in v0.3.0

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

func (*ModelManifest_Model) XXX_Size added in v0.3.0

func (m *ModelManifest_Model) XXX_Size() int

func (*ModelManifest_Model) XXX_Unmarshal added in v0.3.0

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) MarshalToSizedBuffer added in v1.3.6

func (m *ModelManifest_Type) MarshalToSizedBuffer(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 added in v0.3.0

func (m *ModelManifest_Type) XXX_DiscardUnknown()

func (*ModelManifest_Type) XXX_Marshal added in v0.3.0

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

func (*ModelManifest_Type) XXX_Merge added in v0.3.0

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

func (*ModelManifest_Type) XXX_Size added in v0.3.0

func (m *ModelManifest_Type) XXX_Size() int

func (*ModelManifest_Type) XXX_Unmarshal added in v0.3.0

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) MarshalToSizedBuffer added in v1.3.6

func (m *ModelManifest_Type_Parameter) MarshalToSizedBuffer(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 added in v0.3.0

func (m *ModelManifest_Type_Parameter) XXX_DiscardUnknown()

func (*ModelManifest_Type_Parameter) XXX_Marshal added in v0.3.0

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

func (*ModelManifest_Type_Parameter) XXX_Merge added in v0.3.0

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

func (*ModelManifest_Type_Parameter) XXX_Size added in v0.3.0

func (m *ModelManifest_Type_Parameter) XXX_Size() int

func (*ModelManifest_Type_Parameter) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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) MarshalToSizedBuffer added in v1.3.6

func (m *ModelManifestsResponse) MarshalToSizedBuffer(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 added in v0.3.0

func (m *ModelManifestsResponse) XXX_DiscardUnknown()

func (*ModelManifestsResponse) XXX_Marshal added in v0.3.0

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

func (*ModelManifestsResponse) XXX_Merge added in v0.3.0

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

func (*ModelManifestsResponse) XXX_Size added in v0.3.0

func (m *ModelManifestsResponse) XXX_Size() int

func (*ModelManifestsResponse) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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) MarshalToSizedBuffer added in v1.3.6

func (m *ModelRequest) MarshalToSizedBuffer(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 added in v0.3.0

func (m *ModelRequest) XXX_DiscardUnknown()

func (*ModelRequest) XXX_Marshal added in v0.3.0

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

func (*ModelRequest) XXX_Merge added in v0.3.0

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

func (*ModelRequest) XXX_Size added in v0.3.0

func (m *ModelRequest) XXX_Size() int

func (*ModelRequest) XXX_Unmarshal added in v0.3.0

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

type PredictClient added in v0.2.16

type PredictClient interface {
	// Opens a predictor and returns an id where the predictor
	// is accessible. The id can be used to perform inference
	// requests.
	Open(ctx context.Context, in *PredictorOpenRequest, opts ...grpc.CallOption) (*Predictor, error)
	// Close a predictor clear it's memory.
	Close(ctx context.Context, in *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 added in v0.2.16

func NewPredictClient(cc *grpc.ClientConn) PredictClient

type PredictServer added in v0.2.16

type PredictServer interface {
	// Opens a predictor and returns an id where the predictor
	// is accessible. The id can be used to perform inference
	// requests.
	Open(context.Context, *PredictorOpenRequest) (*Predictor, error)
	// Close a predictor clear it's memory.
	Close(context.Context, *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 added in v0.3.0

type PredictionHandle int64

type PredictionOptions added in v0.2.16

type PredictionOptions struct {
	RequestID        string            `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty" yaml:"request_id,omitempty"`
	FeatureLimit     int32             `` /* 129-byte string literal not displayed */
	BatchSize        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 added in v0.2.16

func NewPopulatedPredictionOptions(r randyPredictor, easy bool) *PredictionOptions

func (*PredictionOptions) Description added in v0.2.16

func (*PredictionOptions) Descriptor added in v0.2.16

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

func (*PredictionOptions) Equal added in v0.2.16

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

func (*PredictionOptions) GetAgent added in v0.2.19

func (m *PredictionOptions) GetAgent() string

func (*PredictionOptions) GetBatchSize added in v0.2.19

func (m *PredictionOptions) GetBatchSize() int32

func (*PredictionOptions) GetExecutionOptions added in v0.2.19

func (m *PredictionOptions) GetExecutionOptions() *ExecutionOptions

func (*PredictionOptions) GetFeatureLimit added in v0.2.16

func (m *PredictionOptions) GetFeatureLimit() int32

func (*PredictionOptions) GetGpuMetrics added in v0.3.0

func (m *PredictionOptions) GetGpuMetrics() string

func (*PredictionOptions) GetRequestID added in v0.2.16

func (m *PredictionOptions) GetRequestID() string

func (*PredictionOptions) GoString added in v0.2.16

func (this *PredictionOptions) GoString() string

func (*PredictionOptions) Marshal added in v0.2.16

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

func (*PredictionOptions) MarshalTo added in v0.2.16

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

func (*PredictionOptions) MarshalToSizedBuffer added in v1.3.6

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

func (*PredictionOptions) ProtoMessage added in v0.2.16

func (*PredictionOptions) ProtoMessage()

func (*PredictionOptions) Reset added in v0.2.16

func (m *PredictionOptions) Reset()

func (*PredictionOptions) Size added in v0.2.16

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

func (*PredictionOptions) String added in v0.2.16

func (this *PredictionOptions) String() string

func (*PredictionOptions) Unmarshal added in v0.2.16

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

func (*PredictionOptions) VerboseEqual added in v0.2.16

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

func (*PredictionOptions) XXX_DiscardUnknown added in v0.3.0

func (m *PredictionOptions) XXX_DiscardUnknown()

func (*PredictionOptions) XXX_Marshal added in v0.3.0

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

func (*PredictionOptions) XXX_Merge added in v0.3.0

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

func (*PredictionOptions) XXX_Size added in v0.3.0

func (m *PredictionOptions) XXX_Size() int

func (*PredictionOptions) XXX_Unmarshal added in v0.3.0

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

type Predictor added in v0.2.16

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

func NewPopulatedPredictor added in v0.2.16

func NewPopulatedPredictor(r randyPredictor, easy bool) *Predictor

func (*Predictor) Description added in v0.2.16

func (*Predictor) Descriptor added in v0.2.16

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

func (*Predictor) Equal added in v0.2.16

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

func (*Predictor) GetDuration added in v0.3.0

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

func (*Predictor) GetID added in v0.2.16

func (m *Predictor) GetID() string

func (*Predictor) GoString added in v0.2.16

func (this *Predictor) GoString() string

func (*Predictor) Marshal added in v0.2.16

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

func (*Predictor) MarshalTo added in v0.2.16

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

func (*Predictor) MarshalToSizedBuffer added in v1.3.6

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

func (*Predictor) ProtoMessage added in v0.2.16

func (*Predictor) ProtoMessage()

func (*Predictor) Reset added in v0.2.16

func (m *Predictor) Reset()

func (*Predictor) Size added in v0.2.16

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

func (*Predictor) String added in v0.2.16

func (this *Predictor) String() string

func (*Predictor) Unmarshal added in v0.2.16

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

func (*Predictor) VerboseEqual added in v0.2.16

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

func (*Predictor) XXX_DiscardUnknown added in v0.3.0

func (m *Predictor) XXX_DiscardUnknown()

func (*Predictor) XXX_Marshal added in v0.3.0

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

func (*Predictor) XXX_Merge added in v0.3.0

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

func (*Predictor) XXX_Size added in v0.3.0

func (m *Predictor) XXX_Size() int

func (*Predictor) XXX_Unmarshal added in v0.3.0

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

type PredictorCloseRequest added in v0.3.0

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 added in v0.3.0

func NewPopulatedPredictorCloseRequest(r randyPredictor, easy bool) *PredictorCloseRequest

func (*PredictorCloseRequest) Description added in v0.3.0

func (*PredictorCloseRequest) Descriptor added in v0.3.0

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

func (*PredictorCloseRequest) Equal added in v0.3.0

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

func (*PredictorCloseRequest) GetForce added in v0.3.0

func (m *PredictorCloseRequest) GetForce() bool

func (*PredictorCloseRequest) GetPredictor added in v0.3.0

func (m *PredictorCloseRequest) GetPredictor() *Predictor

func (*PredictorCloseRequest) GoString added in v0.3.0

func (this *PredictorCloseRequest) GoString() string

func (*PredictorCloseRequest) Marshal added in v0.3.0

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

func (*PredictorCloseRequest) MarshalTo added in v0.3.0

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

func (*PredictorCloseRequest) MarshalToSizedBuffer added in v1.3.6

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

func (*PredictorCloseRequest) ProtoMessage added in v0.3.0

func (*PredictorCloseRequest) ProtoMessage()

func (*PredictorCloseRequest) Reset added in v0.3.0

func (m *PredictorCloseRequest) Reset()

func (*PredictorCloseRequest) Size added in v0.3.0

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

func (*PredictorCloseRequest) String added in v0.3.0

func (this *PredictorCloseRequest) String() string

func (*PredictorCloseRequest) Unmarshal added in v0.3.0

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

func (*PredictorCloseRequest) VerboseEqual added in v0.3.0

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

func (*PredictorCloseRequest) XXX_DiscardUnknown added in v0.3.0

func (m *PredictorCloseRequest) XXX_DiscardUnknown()

func (*PredictorCloseRequest) XXX_Marshal added in v0.3.0

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

func (*PredictorCloseRequest) XXX_Merge added in v0.3.0

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

func (*PredictorCloseRequest) XXX_Size added in v0.3.0

func (m *PredictorCloseRequest) XXX_Size() int

func (*PredictorCloseRequest) XXX_Unmarshal added in v0.3.0

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

type PredictorCloseResponse added in v0.2.16

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

func NewPopulatedPredictorCloseResponse added in v0.2.16

func NewPopulatedPredictorCloseResponse(r randyPredictor, easy bool) *PredictorCloseResponse

func (*PredictorCloseResponse) Descriptor added in v0.2.16

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

func (*PredictorCloseResponse) Equal added in v0.2.16

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

func (*PredictorCloseResponse) GetDuration added in v0.3.0

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

func (*PredictorCloseResponse) GoString added in v0.2.16

func (this *PredictorCloseResponse) GoString() string

func (*PredictorCloseResponse) Marshal added in v0.2.16

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

func (*PredictorCloseResponse) MarshalTo added in v0.2.16

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

func (*PredictorCloseResponse) MarshalToSizedBuffer added in v1.3.6

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

func (*PredictorCloseResponse) ProtoMessage added in v0.2.16

func (*PredictorCloseResponse) ProtoMessage()

func (*PredictorCloseResponse) Reset added in v0.2.16

func (m *PredictorCloseResponse) Reset()

func (*PredictorCloseResponse) Size added in v0.2.16

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

func (*PredictorCloseResponse) String added in v0.2.16

func (this *PredictorCloseResponse) String() string

func (*PredictorCloseResponse) Unmarshal added in v0.2.16

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

func (*PredictorCloseResponse) VerboseEqual added in v0.2.16

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

func (*PredictorCloseResponse) XXX_DiscardUnknown added in v0.3.0

func (m *PredictorCloseResponse) XXX_DiscardUnknown()

func (*PredictorCloseResponse) XXX_Marshal added in v0.3.0

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

func (*PredictorCloseResponse) XXX_Merge added in v0.3.0

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

func (*PredictorCloseResponse) XXX_Size added in v0.3.0

func (m *PredictorCloseResponse) XXX_Size() int

func (*PredictorCloseResponse) XXX_Unmarshal added in v0.3.0

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

type PredictorOpenRequest added in v0.2.16

type PredictorOpenRequest struct {
	ModelName        string             `protobuf:"bytes,1,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty" yaml:"model_name,omitempty"`
	ModelVersion     string             `` /* 128-byte string literal not displayed */
	FrameworkName    string             `` /* 132-byte string literal not displayed */
	FrameworkVersion string             `` /* 144-byte string literal not displayed */
	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 added in v0.2.16

func NewPopulatedPredictorOpenRequest(r randyPredictor, easy bool) *PredictorOpenRequest

func (*PredictorOpenRequest) Description added in v0.2.16

func (*PredictorOpenRequest) Descriptor added in v0.2.16

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

func (*PredictorOpenRequest) Equal added in v0.2.16

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

func (*PredictorOpenRequest) GetFrameworkName added in v0.2.16

func (m *PredictorOpenRequest) GetFrameworkName() string

func (*PredictorOpenRequest) GetFrameworkVersion added in v0.2.16

func (m *PredictorOpenRequest) GetFrameworkVersion() string

func (*PredictorOpenRequest) GetModelName added in v0.2.16

func (m *PredictorOpenRequest) GetModelName() string

func (*PredictorOpenRequest) GetModelVersion added in v0.2.16

func (m *PredictorOpenRequest) GetModelVersion() string

func (*PredictorOpenRequest) GetOptions added in v0.2.19

func (m *PredictorOpenRequest) GetOptions() *PredictionOptions

func (*PredictorOpenRequest) GetPersist added in v0.3.0

func (m *PredictorOpenRequest) GetPersist() bool

func (*PredictorOpenRequest) GoString added in v0.2.16

func (this *PredictorOpenRequest) GoString() string

func (*PredictorOpenRequest) Marshal added in v0.2.16

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

func (*PredictorOpenRequest) MarshalTo added in v0.2.16

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

func (*PredictorOpenRequest) MarshalToSizedBuffer added in v1.3.6

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

func (*PredictorOpenRequest) ProtoMessage added in v0.2.16

func (*PredictorOpenRequest) ProtoMessage()

func (*PredictorOpenRequest) Reset added in v0.2.16

func (m *PredictorOpenRequest) Reset()

func (*PredictorOpenRequest) Size added in v0.2.16

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

func (*PredictorOpenRequest) String added in v0.2.16

func (this *PredictorOpenRequest) String() string

func (*PredictorOpenRequest) Unmarshal added in v0.2.16

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

func (*PredictorOpenRequest) VerboseEqual added in v0.2.16

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

func (*PredictorOpenRequest) XXX_DiscardUnknown added in v0.3.0

func (m *PredictorOpenRequest) XXX_DiscardUnknown()

func (*PredictorOpenRequest) XXX_Marshal added in v0.3.0

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

func (*PredictorOpenRequest) XXX_Merge added in v0.3.0

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

func (*PredictorOpenRequest) XXX_Size added in v0.3.0

func (m *PredictorOpenRequest) XXX_Size() int

func (*PredictorOpenRequest) XXX_Unmarshal added in v0.3.0

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

type Raw added in v0.3.0

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 added in v0.3.0

func NewPopulatedRaw(r randyFeatures, easy bool) *Raw

func (*Raw) Description added in v0.3.0

func (*Raw) Descriptor added in v0.3.0

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

func (*Raw) Equal added in v0.3.0

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

func (*Raw) GetData added in v0.3.0

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

func (*Raw) GetFormat added in v0.3.0

func (m *Raw) GetFormat() string

func (*Raw) GoString added in v0.3.0

func (this *Raw) GoString() string

func (*Raw) Marshal added in v0.3.0

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

func (*Raw) MarshalTo added in v0.3.0

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

func (*Raw) MarshalToSizedBuffer added in v1.3.6

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

func (*Raw) ProtoMessage added in v0.3.0

func (*Raw) ProtoMessage()

func (*Raw) Reset added in v0.3.0

func (m *Raw) Reset()

func (*Raw) Size added in v0.3.0

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

func (*Raw) String added in v0.3.0

func (this *Raw) String() string

func (*Raw) Unmarshal added in v0.3.0

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

func (*Raw) VerboseEqual added in v0.3.0

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

func (*Raw) XXX_DiscardUnknown added in v0.3.0

func (m *Raw) XXX_DiscardUnknown()

func (*Raw) XXX_Marshal added in v0.3.0

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

func (*Raw) XXX_Merge added in v0.3.0

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

func (*Raw) XXX_Size added in v0.3.0

func (m *Raw) XXX_Size() int

func (*Raw) XXX_Unmarshal added in v0.3.0

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

type RawImage added in v0.3.0

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 added in v0.3.0

func NewPopulatedRawImage(r randyFeatures, easy bool) *RawImage

func (*RawImage) Descriptor added in v0.3.0

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

func (*RawImage) Equal added in v0.3.0

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

func (*RawImage) GetChannels added in v0.3.0

func (m *RawImage) GetChannels() int32

func (*RawImage) GetCharList added in v0.3.0

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

func (*RawImage) GetCompressedData added in v0.3.0

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

func (*RawImage) GetDataType added in v0.3.0

func (m *RawImage) GetDataType() string

func (*RawImage) GetFloatList added in v0.3.0

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

func (*RawImage) GetHeight added in v0.3.0

func (m *RawImage) GetHeight() int32

func (*RawImage) GetID added in v0.3.0

func (m *RawImage) GetID() string

func (*RawImage) GetJpegData added in v0.3.0

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

func (*RawImage) GetWidth added in v0.3.0

func (m *RawImage) GetWidth() int32

func (*RawImage) GoString added in v0.3.0

func (this *RawImage) GoString() string

func (*RawImage) Marshal added in v0.3.0

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

func (*RawImage) MarshalTo added in v0.3.0

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

func (*RawImage) MarshalToSizedBuffer added in v1.3.6

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

func (*RawImage) ProtoMessage added in v0.3.0

func (*RawImage) ProtoMessage()

func (*RawImage) Reset added in v0.3.0

func (m *RawImage) Reset()

func (*RawImage) Size added in v0.3.0

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

func (*RawImage) String added in v0.3.0

func (this *RawImage) String() string

func (*RawImage) Unmarshal added in v0.3.0

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

func (*RawImage) VerboseEqual added in v0.3.0

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

func (*RawImage) XXX_DiscardUnknown added in v0.3.0

func (m *RawImage) XXX_DiscardUnknown()

func (*RawImage) XXX_Marshal added in v0.3.0

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

func (*RawImage) XXX_Merge added in v0.3.0

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

func (*RawImage) XXX_Size added in v0.3.0

func (m *RawImage) XXX_Size() int

func (*RawImage) XXX_Unmarshal added in v0.3.0

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

type Region added in v0.3.0

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 added in v0.3.0

func NewPopulatedRegion(r randyFeatures, easy bool) *Region

func (*Region) Description added in v0.3.0

func (*Region) Descriptor added in v0.3.0

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

func (*Region) Equal added in v0.3.0

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

func (*Region) GetData added in v0.3.0

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

func (*Region) GetFormat added in v0.3.0

func (m *Region) GetFormat() string

func (*Region) GoString added in v0.3.0

func (this *Region) GoString() string

func (*Region) Marshal added in v0.3.0

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

func (*Region) MarshalTo added in v0.3.0

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

func (*Region) MarshalToSizedBuffer added in v1.3.6

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

func (*Region) ProtoMessage added in v0.3.0

func (*Region) ProtoMessage()

func (*Region) Reset added in v0.3.0

func (m *Region) Reset()

func (*Region) Size added in v0.3.0

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

func (*Region) String added in v0.3.0

func (this *Region) String() string

func (*Region) Unmarshal added in v0.3.0

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

func (*Region) VerboseEqual added in v0.3.0

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

func (*Region) XXX_DiscardUnknown added in v0.3.0

func (m *Region) XXX_DiscardUnknown()

func (*Region) XXX_Marshal added in v0.3.0

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

func (*Region) XXX_Merge added in v0.3.0

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

func (*Region) XXX_Size added in v0.3.0

func (m *Region) XXX_Size() int

func (*Region) XXX_Unmarshal added in v0.3.0

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 added in v0.2.16

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

func NewPopulatedResetRequest added in v0.2.16

func NewPopulatedResetRequest(r randyPredictor, easy bool) *ResetRequest

func (*ResetRequest) Description added in v0.2.16

func (*ResetRequest) Descriptor added in v0.2.16

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

func (*ResetRequest) Equal added in v0.2.16

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

func (*ResetRequest) GetID added in v0.2.16

func (m *ResetRequest) GetID() string

func (*ResetRequest) GetPredictor added in v0.2.16

func (m *ResetRequest) GetPredictor() *Predictor

func (*ResetRequest) GoString added in v0.2.16

func (this *ResetRequest) GoString() string

func (*ResetRequest) Marshal added in v0.2.16

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

func (*ResetRequest) MarshalTo added in v0.2.16

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

func (*ResetRequest) MarshalToSizedBuffer added in v1.3.6

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

func (*ResetRequest) ProtoMessage added in v0.2.16

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) Reset added in v0.2.16

func (m *ResetRequest) Reset()

func (*ResetRequest) Size added in v0.2.16

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

func (*ResetRequest) String added in v0.2.16

func (this *ResetRequest) String() string

func (*ResetRequest) Unmarshal added in v0.2.16

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

func (*ResetRequest) VerboseEqual added in v0.2.16

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

func (*ResetRequest) XXX_DiscardUnknown added in v0.3.0

func (m *ResetRequest) XXX_DiscardUnknown()

func (*ResetRequest) XXX_Marshal added in v0.3.0

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

func (*ResetRequest) XXX_Merge added in v0.3.0

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

func (*ResetRequest) XXX_Size added in v0.3.0

func (m *ResetRequest) XXX_Size() int

func (*ResetRequest) XXX_Unmarshal added in v0.3.0

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

type ResetResponse added in v0.2.16

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

func NewPopulatedResetResponse added in v0.2.16

func NewPopulatedResetResponse(r randyPredictor, easy bool) *ResetResponse

func (*ResetResponse) Description added in v0.2.16

func (*ResetResponse) Descriptor added in v0.2.16

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

func (*ResetResponse) Equal added in v0.2.16

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

func (*ResetResponse) GoString added in v0.2.16

func (this *ResetResponse) GoString() string

func (*ResetResponse) Marshal added in v0.2.16

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

func (*ResetResponse) MarshalTo added in v0.2.16

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

func (*ResetResponse) MarshalToSizedBuffer added in v1.3.6

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

func (*ResetResponse) ProtoMessage added in v0.2.16

func (*ResetResponse) ProtoMessage()

func (*ResetResponse) Reset added in v0.2.16

func (m *ResetResponse) Reset()

func (*ResetResponse) Size added in v0.2.16

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

func (*ResetResponse) String added in v0.2.16

func (this *ResetResponse) String() string

func (*ResetResponse) Unmarshal added in v0.2.16

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

func (*ResetResponse) VerboseEqual added in v0.2.16

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

func (*ResetResponse) XXX_DiscardUnknown added in v0.3.0

func (m *ResetResponse) XXX_DiscardUnknown()

func (*ResetResponse) XXX_Marshal added in v0.3.0

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

func (*ResetResponse) XXX_Merge added in v0.3.0

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

func (*ResetResponse) XXX_Size added in v0.3.0

func (m *ResetResponse) XXX_Size() int

func (*ResetResponse) XXX_Unmarshal added in v0.3.0

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

type SemanticSegment added in v0.3.0

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"`
	Labels  []string `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty" yaml:"labels,omitempty"`
}

func NewPopulatedSemanticSegment added in v0.3.0

func NewPopulatedSemanticSegment(r randyFeatures, easy bool) *SemanticSegment

func (*SemanticSegment) Description added in v0.3.0

func (*SemanticSegment) Descriptor added in v0.3.0

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

func (*SemanticSegment) Equal added in v0.3.0

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

func (*SemanticSegment) GetHeight added in v0.3.0

func (m *SemanticSegment) GetHeight() int32

func (*SemanticSegment) GetIntMask added in v0.3.0

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

func (*SemanticSegment) GetLabels added in v1.4.19

func (m *SemanticSegment) GetLabels() []string

func (*SemanticSegment) GetWidth added in v0.3.0

func (m *SemanticSegment) GetWidth() int32

func (*SemanticSegment) GoString added in v0.3.0

func (this *SemanticSegment) GoString() string

func (*SemanticSegment) Marshal added in v0.3.0

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

func (*SemanticSegment) MarshalTo added in v0.3.0

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

func (*SemanticSegment) MarshalToSizedBuffer added in v1.3.6

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

func (*SemanticSegment) ProtoMessage added in v0.3.0

func (*SemanticSegment) ProtoMessage()

func (*SemanticSegment) Reset added in v0.3.0

func (m *SemanticSegment) Reset()

func (*SemanticSegment) Size added in v0.3.0

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

func (*SemanticSegment) String added in v0.3.0

func (this *SemanticSegment) String() string

func (*SemanticSegment) Unmarshal added in v0.3.0

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

func (*SemanticSegment) VerboseEqual added in v0.3.0

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

func (*SemanticSegment) XXX_DiscardUnknown added in v0.3.0

func (m *SemanticSegment) XXX_DiscardUnknown()

func (*SemanticSegment) XXX_Marshal added in v0.3.0

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

func (*SemanticSegment) XXX_Merge added in v0.3.0

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

func (*SemanticSegment) XXX_Size added in v0.3.0

func (m *SemanticSegment) XXX_Size() int

func (*SemanticSegment) XXX_Unmarshal added in v0.3.0

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

type Text added in v0.3.0

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

func NewPopulatedText added in v0.3.0

func NewPopulatedText(r randyFeatures, easy bool) *Text

func (*Text) Description added in v0.3.0

func (*Text) Descriptor added in v0.3.0

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

func (*Text) Equal added in v0.3.0

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

func (*Text) GetData added in v0.3.0

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

func (*Text) GoString added in v0.3.0

func (this *Text) GoString() string

func (*Text) Marshal added in v0.3.0

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

func (*Text) MarshalTo added in v0.3.0

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

func (*Text) MarshalToSizedBuffer added in v1.3.6

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

func (*Text) ProtoMessage added in v0.3.0

func (*Text) ProtoMessage()

func (*Text) Reset added in v0.3.0

func (m *Text) Reset()

func (*Text) Size added in v0.3.0

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

func (*Text) String added in v0.3.0

func (this *Text) String() string

func (*Text) Unmarshal added in v0.3.0

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

func (*Text) VerboseEqual added in v0.3.0

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

func (*Text) XXX_DiscardUnknown added in v0.3.0

func (m *Text) XXX_DiscardUnknown()

func (*Text) XXX_Marshal added in v0.3.0

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

func (*Text) XXX_Merge added in v0.3.0

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

func (*Text) XXX_Size added in v0.3.0

func (m *Text) XXX_Size() int

func (*Text) XXX_Unmarshal added in v0.3.0

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

type TextRequest added in v0.3.0

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 added in v0.3.0

func NewPopulatedTextRequest(r randyPredictor, easy bool) *TextRequest

func (*TextRequest) Description added in v0.3.0

func (*TextRequest) Descriptor added in v0.3.0

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

func (*TextRequest) Equal added in v0.3.0

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

func (*TextRequest) GetOptions added in v0.3.0

func (m *TextRequest) GetOptions() *PredictionOptions

func (*TextRequest) GetPredictor added in v0.3.0

func (m *TextRequest) GetPredictor() *Predictor

func (*TextRequest) GetTexts added in v0.3.0

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

func (*TextRequest) GoString added in v0.3.0

func (this *TextRequest) GoString() string

func (*TextRequest) Marshal added in v0.3.0

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

func (*TextRequest) MarshalTo added in v0.3.0

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

func (*TextRequest) MarshalToSizedBuffer added in v1.3.6

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

func (*TextRequest) ProtoMessage added in v0.3.0

func (*TextRequest) ProtoMessage()

func (*TextRequest) Reset added in v0.3.0

func (m *TextRequest) Reset()

func (*TextRequest) Size added in v0.3.0

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

func (*TextRequest) String added in v0.3.0

func (this *TextRequest) String() string

func (*TextRequest) Unmarshal added in v0.3.0

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

func (*TextRequest) VerboseEqual added in v0.3.0

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

func (*TextRequest) XXX_DiscardUnknown added in v0.3.0

func (m *TextRequest) XXX_DiscardUnknown()

func (*TextRequest) XXX_Marshal added in v0.3.0

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

func (*TextRequest) XXX_Merge added in v0.3.0

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

func (*TextRequest) XXX_Size added in v0.3.0

func (m *TextRequest) XXX_Size() int

func (*TextRequest) XXX_Unmarshal added in v0.3.0

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

type TraceID added in v0.3.0

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

func NewPopulatedTraceID added in v0.3.0

func NewPopulatedTraceID(r randyPredictor, easy bool) *TraceID

func (*TraceID) Descriptor added in v0.3.0

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

func (*TraceID) Equal added in v0.3.0

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

func (*TraceID) GetId added in v0.3.0

func (m *TraceID) GetId() string

func (*TraceID) GoString added in v0.3.0

func (this *TraceID) GoString() string

func (*TraceID) Marshal added in v0.3.0

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

func (*TraceID) MarshalTo added in v0.3.0

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

func (*TraceID) MarshalToSizedBuffer added in v1.3.6

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

func (*TraceID) ProtoMessage added in v0.3.0

func (*TraceID) ProtoMessage()

func (*TraceID) Reset added in v0.3.0

func (m *TraceID) Reset()

func (*TraceID) Size added in v0.3.0

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

func (*TraceID) String added in v0.3.0

func (this *TraceID) String() string

func (*TraceID) Unmarshal added in v0.3.0

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

func (*TraceID) VerboseEqual added in v0.3.0

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

func (*TraceID) XXX_DiscardUnknown added in v0.3.0

func (m *TraceID) XXX_DiscardUnknown()

func (*TraceID) XXX_Marshal added in v0.3.0

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

func (*TraceID) XXX_Merge added in v0.3.0

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

func (*TraceID) XXX_Size added in v0.3.0

func (m *TraceID) XXX_Size() int

func (*TraceID) XXX_Unmarshal added in v0.3.0

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

type URLsRequest added in v0.2.16

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 added in v0.2.16

func NewPopulatedURLsRequest(r randyPredictor, easy bool) *URLsRequest

func (*URLsRequest) Description added in v0.2.16

func (*URLsRequest) Descriptor added in v0.2.16

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

func (*URLsRequest) Equal added in v0.2.16

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

func (*URLsRequest) GetOptions added in v0.2.16

func (m *URLsRequest) GetOptions() *PredictionOptions

func (*URLsRequest) GetPredictor added in v0.2.16

func (m *URLsRequest) GetPredictor() *Predictor

func (*URLsRequest) GetUrls added in v0.2.16

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

func (*URLsRequest) GoString added in v0.2.16

func (this *URLsRequest) GoString() string

func (*URLsRequest) Marshal added in v0.2.16

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

func (*URLsRequest) MarshalTo added in v0.2.16

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

func (*URLsRequest) MarshalToSizedBuffer added in v1.3.6

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

func (*URLsRequest) ProtoMessage added in v0.2.16

func (*URLsRequest) ProtoMessage()

func (*URLsRequest) Reset added in v0.2.16

func (m *URLsRequest) Reset()

func (*URLsRequest) Size added in v0.2.16

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

func (*URLsRequest) String added in v0.2.16

func (this *URLsRequest) String() string

func (*URLsRequest) Unmarshal added in v0.2.16

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

func (*URLsRequest) VerboseEqual added in v0.2.16

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

func (*URLsRequest) XXX_DiscardUnknown added in v0.3.0

func (m *URLsRequest) XXX_DiscardUnknown()

func (*URLsRequest) XXX_Marshal added in v0.3.0

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

func (*URLsRequest) XXX_Merge added in v0.3.0

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

func (*URLsRequest) XXX_Size added in v0.3.0

func (m *URLsRequest) XXX_Size() int

func (*URLsRequest) XXX_Unmarshal added in v0.3.0

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

type URLsRequest_URL added in v0.2.16

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

func NewPopulatedURLsRequest_URL added in v0.2.16

func NewPopulatedURLsRequest_URL(r randyPredictor, easy bool) *URLsRequest_URL

func (*URLsRequest_URL) Descriptor added in v0.2.16

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

func (*URLsRequest_URL) Equal added in v0.2.16

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

func (*URLsRequest_URL) GetData added in v0.2.16

func (m *URLsRequest_URL) GetData() string

func (*URLsRequest_URL) GetID added in v0.2.16

func (m *URLsRequest_URL) GetID() string

func (*URLsRequest_URL) GoString added in v0.2.16

func (this *URLsRequest_URL) GoString() string

func (*URLsRequest_URL) Marshal added in v0.2.16

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

func (*URLsRequest_URL) MarshalTo added in v0.2.16

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

func (*URLsRequest_URL) MarshalToSizedBuffer added in v1.3.6

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

func (*URLsRequest_URL) ProtoMessage added in v0.2.16

func (*URLsRequest_URL) ProtoMessage()

func (*URLsRequest_URL) Reset added in v0.2.16

func (m *URLsRequest_URL) Reset()

func (*URLsRequest_URL) Size added in v0.2.16

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

func (*URLsRequest_URL) String added in v0.2.16

func (this *URLsRequest_URL) String() string

func (*URLsRequest_URL) Unmarshal added in v0.2.16

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

func (*URLsRequest_URL) VerboseEqual added in v0.2.16

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

func (*URLsRequest_URL) XXX_DiscardUnknown added in v0.3.0

func (m *URLsRequest_URL) XXX_DiscardUnknown()

func (*URLsRequest_URL) XXX_Marshal added in v0.3.0

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

func (*URLsRequest_URL) XXX_Merge added in v0.3.0

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

func (*URLsRequest_URL) XXX_Size added in v0.3.0

func (m *URLsRequest_URL) XXX_Size() int

func (*URLsRequest_URL) XXX_Unmarshal added in v0.3.0

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

type UnimplementedPredictServer added in v0.3.0

type UnimplementedPredictServer struct {
}

UnimplementedPredictServer can be embedded to have forward compatible implementations.

func (*UnimplementedPredictServer) Close added in v0.3.0

func (*UnimplementedPredictServer) Dataset added in v0.3.0

func (*UnimplementedPredictServer) Images added in v0.3.0

func (*UnimplementedPredictServer) Open added in v0.3.0

func (*UnimplementedPredictServer) Reset added in v0.3.0

func (*UnimplementedPredictServer) URLs added in v0.3.0

type UnimplementedRegistryServer added in v0.3.0

type UnimplementedRegistryServer struct {
}

UnimplementedRegistryServer can be embedded to have forward compatible implementations.

func (*UnimplementedRegistryServer) FrameworkAgents added in v0.3.0

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

func (*UnimplementedRegistryServer) FrameworkManifests added in v0.3.0

func (*UnimplementedRegistryServer) ModelAgents added in v0.3.0

func (*UnimplementedRegistryServer) ModelManifests added in v0.3.0

Directories

Path Synopsis
cmd
run
cmd
httpapi
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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL