agent

func (*Agent) Close ¶ added in v0.2.16

func (p *Agent) Close(ctx context.Context, req *dl.Predictor) (*dl.PredictorCloseResponse, error)

Close a predictor clear it's memory.

func (*Agent) Dataset ¶ added in v0.2.16

func (p *Agent) Dataset(ctx context.Context, req *dl.DatasetRequest) (*dl.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.

func (*Agent) DatasetStream ¶ added in v0.2.16

func (p *Agent) DatasetStream(req *dl.DatasetRequest, svr dl.Predict_DatasetStreamServer) error

Dataset method receives a single dataset and runs the predictor on all elements of the dataset.

The result is a prediction feature stream.

func (*Agent) FindFrameworkModel ¶

func (p *Agent) FindFrameworkModel(ctx context.Context, req *dl.PredictorOpenRequest) (*dl.FrameworkManifest, *dl.ModelManifest, error)

func (*Agent) Images ¶ added in v0.2.16

func (p *Agent) Images(ctx context.Context, req *dl.ImagesRequest) (*dl.FeaturesResponse, error)

Image method receives a list base64 encoded images and runs the predictor on all the images.

The result is a prediction feature list for each image.

func (*Agent) ImagesStream ¶ added in v0.2.16

func (p *Agent) ImagesStream(req *dl.ImagesRequest, svr dl.Predict_ImagesStreamServer) error

Image method receives a list base64 encoded images and runs the predictor on all the images.

The result is a prediction feature stream for each image.

func (*Agent) Open ¶ added in v0.2.16

func (p *Agent) Open(ctx context.Context, req *dl.PredictorOpenRequest) (*dl.Predictor, error)

Opens a predictor and returns an id where the predictor is accessible. The id can be used to perform inference requests.

func (*Agent) PublishInPredictor ¶ added in v0.2.16

func (b *Agent) PublishInPredictor(host, prefix string) error

func (*Agent) PublishInRegistery ¶ added in v0.2.16

func (b *Agent) PublishInRegistery(prefix string) error

func (*Agent) RegisterManifests ¶

func (p *Agent) RegisterManifests() (*grpc.Server, error)

func (*Agent) RegisterPredictor ¶

func (p *Agent) RegisterPredictor() (*grpc.Server, error)

func (*Agent) Reset ¶ added in v0.2.16

func (p *Agent) Reset(ctx context.Context, req *dl.ResetRequest) (*dl.ResetResponse, error)

Clear method clears the internal cache of the predictors

func (*Agent) URLs ¶ added in v0.2.16

func (p *Agent) URLs(ctx context.Context, req *dl.URLsRequest) (*dl.FeaturesResponse, error)

Image method receives a stream of urls and runs the predictor on all the urls. The

The result is a prediction feature list for each url.

func (*Agent) URLsStream ¶ added in v0.2.16

func (p *Agent) URLsStream(req *dl.URLsRequest, svr dl.Predict_URLsStreamServer) error

Image method receives a stream of urls and runs the predictor on all the urls. The

The result is a prediction feature stream for each url.

func (*Registry) FrameworkAgents ¶

func (c *Registry) FrameworkAgents(context.Context, *dl.FrameworkRequest) (*dl.Agents, error)

func (*Registry) FrameworkManifests ¶

func (c *Registry) FrameworkManifests(context.Context, *dl.FrameworkRequest) (*dl.FrameworkManifestsResponse, error)

func (*Registry) ModelAgents ¶

func (c *Registry) ModelAgents(context.Context, *dl.ModelRequest) (*dl.Agents, error)

func (*Registry) ModelManifests ¶

func (c *Registry) ModelManifests(context.Context, *dl.ModelRequest) (*dl.ModelManifestsResponse, error)

func (*Registry) PublishInPredictor ¶ added in v0.2.16

func (b *Registry) PublishInPredictor(host, prefix string) error

func (*Registry) PublishInRegistery ¶

func (c *Registry) PublishInRegistery() error