service

Documentation

Index

• type Handler
  • func NewHandler(service *Service, pool *buffer.Pool, maxDuration time.Duration) *Handler
  • func (h *Handler) NewContext() (context.Context, context.CancelFunc)
  • func (h *Handler) ServeHTTP(writer http.ResponseWriter, request *http.Request)
• type Option
  • func WithDataStorer(storer datastore.Storer) Option
• type Request
  • func (r *Request) NKeys() int
  • func (r *Request) Put(key string, value string) error
  • func (r *Request) UnmarshalJSONObject(dec *gojay.Decoder, key string) error
  • func (r *Request) Validate() error
• 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, response *Response) error
  • func (s *Service) NewRequest() *Request

Types

type Handler

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

func NewHandler

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

NewHandler creates a new HTTP service Handler

func (*Handler) NewContext

func (h *Handler) NewContext() (context.Context, context.CancelFunc)

NewContext creates a new context

func (*Handler) ServeHTTP

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

ServeHTTP serve HTTP

type Option

type Option interface {
	Apply(c *Service)
}

func WithDataStorer

func WithDataStorer(storer datastore.Storer) Option

WithDataStorer creates dictionary option

type Request

type Request struct {
	Body  []byte
	Feeds []interface{}
	// contains filtered or unexported fields
}

Request represent a request

func (*Request) NKeys

func (r *Request) NKeys() int

NKeys returns object keys

func (*Request) Put

func (r *Request) Put(key string, value string) error

Put puts data to request

func (*Request) UnmarshalJSONObject

func (r *Request) UnmarshalJSONObject(dec *gojay.Decoder, key string) error

UnmarshalJSONObject umarshal

func (*Request) Validate

func (r *Request) Validate() error

Validate validates if request is valid

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 {
	// contains filtered or unexported fields
}

Service represents ml service

func New

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

New creates a service

func (*Service) Close

func (s *Service) Close() error

Close closes service

func (*Service) Config

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

Config returns service config

func (*Service) Dictionary

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

Dictionary returns servie dictionary

func (*Service) Do

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

Do handles service request

func (*Service) NewRequest

func (s *Service) NewRequest() *Request

NewRequest creates a new request