service

Documentation

Index

• type Handler
  • func NewHandler(service *Service, pool *buffer.Pool, maxDuration time.Duration) *Handler
  • func (h *Handler) ServeHTTP(writer http.ResponseWriter, httpRequest *http.Request)
• type Option
  • func WithDataStorer(storer datastore.Storer) Option
• type Response
  • func (r *Response) IsNil() bool
  • func (r *Response) MarshalJSONObject(enc *gojay.Encoder)
  • func (r *Response) SetError(err error)
• type Service
  • func New(ctx context.Context, fs afs.Service, cfg *config.Model, ...) (*Service, error)
  • func (s *Service) Close() error
  • func (s *Service) Config() *config.Model
  • func (s *Service) Dictionary() *common.Dictionary
  • func (s *Service) Do(ctx context.Context, request *request.Request, response *Response) error
  • func (s *Service) NewRequest() *request.Request

Types

type Handler

type Handler struct {
	// contains filtered or unexported fields
}

Handler converts a model prediction HTTP request to its internal calls.

func NewHandler

func NewHandler(service *Service, pool *buffer.Pool, maxDuration time.Duration) *Handler

NewHandler creates a new HTTP service Handler

func (*Handler) ServeHTTP

func (h *Handler) ServeHTTP(writer http.ResponseWriter, httpRequest *http.Request)

type Option

type Option interface {
	Apply(c *Service)
}

func WithDataStorer

func WithDataStorer(storer datastore.Storer) Option

WithDataStorer creates dictionary option

type Response

type Response struct {
	Status         string
	Error          string
	DictHash       int
	Data           interface{}
	ServiceTimeMcs int
	// contains filtered or unexported fields
}

Response represents service response

func (*Response) IsNil

func (r *Response) IsNil() bool

IsNil returns true if nil (gojay json API)

func (*Response) MarshalJSONObject

func (r *Response) MarshalJSONObject(enc *gojay.Encoder)

MarshalJSONObject marshal response

func (*Response) SetError

func (r *Response) SetError(err error)

SetError sets errors

type Service

type Service struct {

	// reload
	ReloadOK int32
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, fs afs.Service, cfg *config.Model, metrics *gmetric.Service, sema *semaphore.Weighted, datastores map[string]*datastore.Service, options ...Option) (*Service, error)

New creates a service

func (*Service) Close

func (s *Service) Close() error

func (*Service) Config

func (s *Service) Config() *config.Model

func (*Service) Dictionary

func (s *Service) Dictionary() *common.Dictionary

func (*Service) Do

func (s *Service) Do(ctx context.Context, request *request.Request, response *Response) error

func (*Service) NewRequest

func (s *Service) NewRequest() *request.Request

NewRequest should be used for Do()