service

Feb 10, 2025

Changes in this version

+ func WithContinueOnRecover(v bool) *continueOnRecover

Aug 30, 2023

Changes in this version

type Service

+ func (s *Service) Signature() *domain.Signature

+ func (s *Service) Stats() map[string]interface{}

Sep 7, 2023

Changes in this version

+ func WithMaxEvaluatorWait(wait time.Duration) *maxEvaluatorWait

Jul 24, 2023

Changes in this version

type Service

+ func (s *Service) Sema() *semaph.Semaph

Mar 29, 2023

Changes in this version

type Service

+ ReloadOK int32

Oct 1, 2022

Changes in this version

+ type Handler struct

+ 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 interface

+ Apply func(c *Service)

+ func WithDataStorer(storer datastore.Storer) Option

+ type Request struct

+ Body []byte

+ Feeds []interface{}

+ 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 struct

+ Data interface{}

+ DictHash int

+ Error string

+ ServiceTimeMcs int

+ Status string

+ func (r *Response) IsNil() bool

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

+ func (r *Response) SetError(err error)

+ type Service struct

+ 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