service

Apr 14, 2023

Changes in this version

+ var ErrSharedSecretKeyNotAgreed = errors.New(448, "***SHARED SECRET NOT AGREED***", "shared secret key was not agreed")

type ClusterBuilderOptions

+ Port int

type TransportHandlerOptions

+ Runtime *Runtime

type TransportMiddlewareOptions

+ Runtime *Runtime

Apr 13, 2023

Changes in this version

+ func SharedCache(ctx context.Context) (store shareds.Caches)

+ type Certificate interface

+ ExpireAT func() time.Time

+ Id func() string

+ Key func() []byte

+ Kind func() string

+ Password func() []byte

+ SecretKey func() []byte

type Certificates

+ Get func(ctx context.Context, id string) (certificate Certificate, err errors.CodeError)

Apr 13, 2023

Changes in this version

+ var ErrSharedSecretKeyOutOfDate = errors.New(468, "***SHARED SECRET KEY OUT OF DATE***", ...)

+ func CacheControl(ctx context.Context, result interface{}, ttl time.Duration)

+ func FetchCacheControl(ctx context.Context, service string, fn string, arg Argument) (etag string, status int, contentType string, contentLength string, ...)

+ func RemoveCacheControl(ctx context.Context, service string, fn string, arg Argument)

Apr 11, 2023

Changes in this version

+ func TransportResponseWriter(ctx context.Context) (w transports.ResponseWriter, has bool)

Apr 11, 2023

Changes in this version

+ func CacheControlFetch(ctx context.Context, r Request) (etag string, status int, contentType string, contentLength string, ...)

+ func CacheControlRemove(ctx context.Context, r Request)

+ func CacheControlUpdate(ctx context.Context, r Request, result interface{}, ttl time.Duration)

+ type Certificates interface

+ GetExchangeKey func(ctx context.Context, appId string) (exchangeKey []byte, has bool, err errors.CodeError)

+ Issue func(ctx context.Context, appId string, appName string, expirations time.Duration) (publicPEM []byte, privatePEM []byte, err errors.CodeError)

+ Revoke func(ctx context.Context, appId string) (err errors.CodeError)

+ Root func(ctx context.Context, kind string) (appId string, publicPEM []byte, privatePEM []byte, password []byte, ...)

+ SaveExchangeKey func(ctx context.Context, appId string, exchangeKey []byte, ttl time.Duration) (err errors.CodeError)

+ SaveRoot func(ctx context.Context, kind string, appId string, publicPEM []byte, ...) (err errors.CodeError)

+ Verify func(ctx context.Context, publicPEM []byte) (ok bool, err errors.CodeError)

+ type ETags struct

type RequestHeader

+ func (header RequestHeader) CacheControlDisabled() (ok bool)

+ func (header RequestHeader) DisableCacheControl()

+ func (header RequestHeader) EnableCacheControl(etag []byte)

type RequestOption

+ func DisableRequestCacheControl() RequestOption

type Shared

+ Caches func() (cache shareds.Caches)

type Span

+ Latency_ string

Apr 8, 2023

Changes in this version

+ var ErrDeviceId = errors.Warning("fns: device id was required")

+ var ErrNotFound = errors.NotFound("fns: no handlers accept request")

+ var ErrServiceOverload = errors.Unavailable("fns: service is overload").WithMeta("fns", "overload")

+ var ErrSessionOutOfDate = errors.New(468, "***SESSION OUT OF DATE***", "need to create session")

+ var ErrSignatureLost = errors.New(488, "***SIGNATURE LOST***", "X-Fns-Signature was required")

+ var ErrSignatureUnverified = errors.New(458, "***SIGNATURE INVALID***", "X-Fns-Signature was invalid")

+ var ErrTooEarly = errors.New(http.StatusTooEarly, "***TOO EARLY***", ...)

+ var ErrTooMayRequest = errors.New(http.StatusTooManyRequests, "***TOO MANY REQUEST***", ...)

+ var ErrUnavailable = errors.Unavailable("fns: service is closed")

+ func Abort()

+ func DataPlate(ctx context.Context) (appId string, appName string, appVersion versions.Version)

+ func EnableCacheControl(ctx context.Context, ttl time.Duration)

+ func Running(ctx context.Context) (signal <-chan struct{})

type ClusterConfig

+ CacheDefaultTTL string

+ MaxCacheSize string

type Config

+ Services json.RawMessage

+ Transport *TransportConfig

+ func (config *Config) Service(name string) (conf configures.Config, err error)

type EndpointDiscoveryGetOption

+ func Versions(requestVersions RequestVersions) EndpointDiscoveryGetOption

type Endpoints

+ func (e *Endpoints) Runtime() (rt *Runtime)

type EndpointsOptions

+ Proxy *TransportOptions

+ Transport *TransportOptions

type Node

+ Services []string

+ type RateLimitCounter interface

+ Build func(options RateLimitCounterOptions) (err error)

+ Close func()

+ Decr func(ctx context.Context, key string) (err error)

+ Incr func(ctx context.Context, key string) (ok bool, err error)

+ Name func() (name string)

+ type RateLimitCounterOptions struct

+ AppId string

+ AppName string

+ AppStatus *Status

+ AppVersion versions.Version

+ Config configures.Config

+ Discovery EndpointDiscovery

+ Log logs.Logger

+ Shared Shared

type Registrations

+ func (r *Registrations) FetchDocuments(ctx context.Context) (v documents.Documents, err error)

+ func (r *Registrations) FetchNodeDocuments(ctx context.Context, node *Node) (v documents.Documents, err error)

+ func (r *Registrations) GetNodeServices(ctx context.Context, node *Node) (names []string, err error)

+ func (r *Registrations) ListMembers(ctx context.Context) (members Nodes, err error)

+ func (r *Registrations) Refresh(ctx context.Context)

type Request

+ AcceptedVersions func() (acceptedVersions RequestVersions)

type RequestHeader

+ func (header RequestHeader) Clone() RequestHeader

+ func (header RequestHeader) Del(key string)

+ func (header RequestHeader) Empty() bool

+ func (header RequestHeader) SetAcceptVersions(rvs RequestVersions)

+ func (header RequestHeader) SetDeviceId(id string)

+ func (header RequestHeader) SetDeviceIp(ip string)

+ type RequestLimiterConfig struct

+ MaxPerDeviceRequest int64

+ RetryAfter string

type RequestOption

+ func WithRequestHeader(header transports.Header) RequestOption

+ func WithRequestVersions(acceptedVersions RequestVersions) RequestOption

+ type RequestVersion struct

+ Begin versions.Version

+ End versions.Version

+ Exact bool

+ Pattern string

+ func ParseRequestVersion(s string) (rv *RequestVersion, err error)

+ func (rv *RequestVersion) Accept(serviceName string, target versions.Version) (ok bool)

+ func (rv *RequestVersion) String() string

+ type RequestVersions []*RequestVersion

+ func AllowAllRequestVersions() RequestVersions

+ func ParseRequestVersionFromHeader(header transports.Header) (rvs RequestVersions, has bool, err error)

+ func (rvs RequestVersions) Accept(serviceName string, target versions.Version) (ok bool)

+ func (rvs RequestVersions) Empty() (ok bool)

+ func (rvs RequestVersions) String() string

+ type Runtime struct

+ func GetRuntime(ctx context.Context) (v *Runtime)

+ func (rt *Runtime) AppId() string

+ func (rt *Runtime) AppName() string

+ func (rt *Runtime) AppStatus() *Status

+ func (rt *Runtime) AppVersion() versions.Version

+ func (rt *Runtime) Barrier() Barrier

+ func (rt *Runtime) Discovery() EndpointDiscovery

+ func (rt *Runtime) RootLog() logs.Logger

+ func (rt *Runtime) SetIntoContext(ctx context.Context) context.Context

+ func (rt *Runtime) Shared() Shared

+ func (rt *Runtime) Signer() *secret.Signer

+ func (rt *Runtime) Workers() Workers

+ type ServicesSupplier interface

+ Services func() (services []Service)

+ type Status struct

+ func (status *Status) Closed() (ok bool)

+ func (status *Status) Serving() (ok bool)

+ func (status *Status) Starting() (ok bool)

+ type TransportConfig struct

+ Cors *transports.CorsConfig

+ Handlers json.RawMessage

+ Middlewares json.RawMessage

+ Name string

+ Options json.RawMessage

+ Port int

+ TLS *TLSConfig

+ func (config *TransportConfig) ConvertToTransportsOptions(log logs.Logger, handler transports.Handler) (options transports.Options, err error)

+ func (config *TransportConfig) HandlersConfig() (conf configures.Config, err error)

+ func (config *TransportConfig) MiddlewaresConfig() (conf configures.Config, err error)

+ type TransportHandler interface

+ Accept func(r *transports.Request) (ok bool)

+ Build func(options TransportHandlerOptions) (err error)

+ Close func() (err error)

+ Name func() (name string)

+ type TransportHandlerOptions struct

+ AppId string

+ AppName string

+ AppStatus *Status

+ AppVersion versions.Version

+ Config configures.Config

+ Discovery EndpointDiscovery

+ Log logs.Logger

+ Shared Shared

+ type TransportMiddleware interface

+ Build func(options TransportMiddlewareOptions) (err error)

+ Close func() (err error)

+ Handler func(next transports.Handler) transports.Handler

+ Name func() (name string)

+ func CacheControlMiddleware() TransportMiddleware

+ func CustomizeRateLimitMiddleware(counter RateLimitCounter) TransportMiddleware

+ func RateLimitMiddleware() TransportMiddleware

+ func SignatureMiddleware() TransportMiddleware

+ type TransportMiddlewareOptions struct

+ AppId string

+ AppName string

+ AppStatus *Status

+ AppVersion versions.Version

+ Config configures.Config

+ Discovery EndpointDiscovery

+ Log logs.Logger

+ Shared Shared

+ type TransportOptions struct

+ Handlers []TransportHandler

+ Middlewares []TransportMiddleware

Mar 27, 2023

Changes in this version

type Abstract

+ func (svc *Abstract) Document() (doc Document)

type RequestUserId

+ func (id RequestUserId) Exist() (ok bool)

Mar 24, 2023

Changes in this version

type Config

+ Proxy *ProxyConfig

+ type Documents map[string]VersionedDocuments

+ func (documents Documents) Merge(o Documents) Documents

+ type ProxyConfig struct

+ EnableDevMode bool

+ type RegistrationList []*Registration

+ func (list RegistrationList) Len() int

+ func (list RegistrationList) Less(i, j int) bool

+ func (list RegistrationList) MaxVersion() (r *Registration)

+ func (list RegistrationList) MinVersion() (r *Registration)

+ func (list RegistrationList) Swap(i, j int)

type Registrations

+ func (r *Registrations) List() (values map[string]RegistrationList)

+ type VersionedDocument struct

+ Description string

+ Elements json.RawMessage

+ Fns json.RawMessage

+ Name string

+ Version versions.Version

+ type VersionedDocuments []*VersionedDocument

+ func (documents VersionedDocuments) Len() int

+ func (documents VersionedDocuments) Less(i, j int) bool

+ func (documents VersionedDocuments) Merge(o VersionedDocuments) VersionedDocuments

+ func (documents VersionedDocuments) Swap(i, j int)

Mar 23, 2023

Changes in this version

type ClusterBuilderOptions

+ DevMode bool

type ClusterConfig

+ FetchMembersInterval string

type EndpointsOptions

+ ProxyMode bool

type FastHttpClientOptions

+ MaxConnDuration string

+ MaxConnWaitTimeout string

+ MaxIdleConnDuration string

+ ReadTimeout string

+ WriteTimeout string

type FastHttpOptions

+ KeepHijackedConns bool

+ MaxIdleWorkerDuration string

+ MaxRequestsPerConn int

+ ReadBufferSize string

+ ReadTimeout string

+ StreamRequestBody bool

+ TCPKeepalive bool

+ TCPKeepalivePeriod string

+ WriteBufferSize string

+ WriteTimeout string

+ type ProxyHandler struct

+ func (proxy *ProxyHandler) Accept(request *http.Request) (ok bool)

+ func (proxy *ProxyHandler) Build(options *HttpHandlerOptions) (err error)

+ func (proxy *ProxyHandler) Close()

+ func (proxy *ProxyHandler) Name() (name string)

+ func (proxy *ProxyHandler) ServeHTTP(writer http.ResponseWriter, r *http.Request)

type Registrations

+ func (r *Registrations) MergeNodes(nodes Nodes) (err error)

Mar 21, 2023

Changes in this version

+ type HttpHandlerWithServices interface

+ Services func() (services []Service)

Mar 20, 2023

Changes in this version

+ func AbortApplication()

+ func ApplicationRunning(ctx context.Context) (signal <-chan struct{})

+ func DefaultConfigRetrieverOption() (option configures.RetrieverOption)

+ func GetApplication(ctx context.Context) (appId string, appName string, appVersion versions.Version)

+ func GetSigner(ctx context.Context) (signer *secret.Signer)

+ func NewFuture() (p Promise, f Future)

+ func RegisterClusterBuilder(name string, builder ClusterBuilder)

+ func SharedLock(ctx context.Context, key []byte, ttl time.Duration) (locker shared.Locker, err errors.CodeError)

+ func SharedStore(ctx context.Context) (store shared.Store)

+ func Todo(ctx context.Context, endpoints *Endpoints) context.Context

type Abstract

+ func (svc *Abstract) AppId() (id string)

+ func (svc *Abstract) AppName() (name string)

+ func (svc *Abstract) AppVersion() (version versions.Version)

+ func (svc *Abstract) Barrier(ctx context.Context, name string, arg Argument, ...) (result interface{}, err errors.CodeError)

type Argument

+ HashCode func() (code uint64)

+ type AutoMaxProcsConfig struct

+ Max int

+ Min int

type Barrier

+ func GetBarrier(ctx context.Context) (barrier Barrier)

+ type Cluster interface

+ Join func(ctx context.Context) (err error)

+ Leave func(ctx context.Context) (err error)

+ Nodes func(ctx context.Context) (nodes Nodes, err error)

+ Shared func() (shared Shared)

+ type ClusterBuilder func(options ClusterBuilderOptions) (cluster Cluster, err error)

+ type ClusterBuilderOptions struct

+ AppId string

+ AppName string

+ AppVersion versions.Version

+ Config *ClusterConfig

+ Log logs.Logger

+ type ClusterConfig struct

+ DevMode *ClusterDevMode

+ Kind string

+ Options json.RawMessage

+ Shared *SharedConfig

+ type ClusterDevMode struct

+ ProxyAddress string

+ TLS *TLSConfig

type ComponentOptions

+ AppId string

+ AppName string

+ AppVersion versions.Version

+ type Config struct

+ Cluster *ClusterConfig

+ Http *HttpConfig

+ Log *LogConfig

+ Runtime *RuntimeConfig

+ type CorsConfig struct

+ AllowCredentials bool

+ AllowPrivateNetwork bool

+ AllowedHeaders []string

+ AllowedOrigins []string

+ ExposedHeaders []string

+ MaxAge int

type Endpoint

+ Document func() (document Document)

+ Internal func() (ok bool)

+ Name func() (name string)

+ RequestSync func(ctx context.Context, r Request) (result FutureResult, err errors.CodeError)

+ type EndpointDiscoveryGetOption func(options *EndpointDiscoveryGetOptions)

+ func Exact(id string) EndpointDiscoveryGetOption

+ func Native() EndpointDiscoveryGetOption

+ func VersionRange(left versions.Version, right versions.Version) EndpointDiscoveryGetOption

+ type EndpointDiscoveryGetOptions struct

type Endpoints

+ func (e *Endpoints) Deploy(svc Service) (err error)

+ func (e *Endpoints) Get(ctx context.Context, service string, options ...EndpointDiscoveryGetOption) (v Endpoint, has bool)

+ func (e *Endpoints) Listen(ctx context.Context) (err error)

+ func (e *Endpoints) Log() (log logs.Logger)

+ func (e *Endpoints) Running() (ok bool)

type EndpointsOptions

+ AppName string

+ AppVersion versions.Version

+ Config configures.Config

+ Http Http

+ HttpHandlers []HttpHandler

+ OpenApiVersion string

+ type FastHttp struct

+ func (srv *FastHttp) Build(options HttpOptions) (err error)

+ func (srv *FastHttp) Close() (err error)

+ func (srv *FastHttp) Dial(address string) (client HttpClient, err error)

+ func (srv *FastHttp) ListenAndServe() (err error)

+ func (srv *FastHttp) Name() (name string)

+ type FastHttpClient struct

+ func (client *FastHttpClient) Close()

+ func (client *FastHttpClient) Get(ctx context.Context, path string, header http.Header) (status int, respHeader http.Header, respBody []byte, err error)

+ func (client *FastHttpClient) Post(ctx context.Context, path string, header http.Header, body []byte) (status int, respHeader http.Header, respBody []byte, err error)

+ type FastHttpClientOptions struct

+ DialDualStack bool

+ MaxConnSeconds int

+ MaxConnWaitTimeoutSeconds int

+ MaxConnsPerHost int

+ MaxIdemponentCallAttempts int

+ MaxIdleConnSeconds int

+ MaxResponseBodySize string

+ ReadBufferSize string

+ ReadTimeoutSeconds int

+ WriteBufferSize string

+ WriteTimeoutSeconds int

+ type FastHttpOptions struct

+ Client *FastHttpClientOptions

+ MaxRequestBodySize string

+ MaxWorkerIdleSeconds int

+ ReadTimeoutSeconds int

+ ReduceMemoryUsage bool

type FnDocument

+ Errors func() (errs []FnErrorDocument)

+ type FnErrorDocument interface

+ Descriptions func() map[string]string

+ Name func() string

+ type Future interface

+ Get func(ctx context.Context) (result FutureResult, err errors.CodeError)

type FutureResult

+ Exist func() (ok bool)

+ Scan func(v interface{}) (err errors.CodeError)

+ type HandlersOptions struct

+ AppId string

+ AppName string

+ AppVersion versions.Version

+ Config configures.Config

+ Discovery EndpointDiscovery

+ Log logs.Logger

+ Running *flags.Flag

+ type Http interface

+ Build func(options HttpOptions) (err error)

+ Close func() (err error)

+ ListenAndServe func() (err error)

+ Name func() (name string)

+ type HttpClient interface

+ Close func()

+ Get func(ctx context.Context, path string, header http.Header) (status int, respHeader http.Header, respBody []byte, err error)

+ Post func(ctx context.Context, path string, header http.Header, body []byte) (status int, respHeader http.Header, respBody []byte, err error)

+ type HttpClientDialer interface

+ Dial func(address string) (client HttpClient, err error)

+ type HttpConfig struct

+ Cors *CorsConfig

+ Handlers json.RawMessage

+ Options json.RawMessage

+ Port int

+ TLS *TLSConfig

+ type HttpHandler interface

+ Accept func(request *http.Request) (ok bool)

+ Build func(options *HttpHandlerOptions) (err error)

+ Close func()

+ Name func() (name string)

+ type HttpHandlerOptions struct

+ AppId string

+ AppName string

+ AppVersion versions.Version

+ Config configures.Config

+ Discovery EndpointDiscovery

+ Log logs.Logger

+ type HttpHandlers struct

+ func NewHttpHandlers(options HandlersOptions) (handlers *HttpHandlers, err errors.CodeError)

+ func (handlers *HttpHandlers) Append(h HttpHandler) (err errors.CodeError)

+ func (handlers *HttpHandlers) Close()

+ func (handlers *HttpHandlers) HandlerNames() (names []string)

+ func (handlers *HttpHandlers) ServeHTTP(writer http.ResponseWriter, request *http.Request)

+ type HttpOptions struct

+ ClientTLS *tls.Config

+ Handler http.Handler

+ Log logs.Logger

+ Options json.RawMessage

+ Port int

+ ServerTLS *tls.Config

+ func NewHttpOptions(config *HttpConfig, log logs.Logger, handler http.Handler) (opt HttpOptions, err error)

+ type LogConfig struct

+ Color bool

+ Formatter string

+ Level string

+ type Node struct

+ Address string

+ Id string

+ Name string

+ Version versions.Version

+ type Nodes []Node

+ func (nodes Nodes) Len() int

+ func (nodes Nodes) Less(i, j int) bool

+ func (nodes Nodes) Swap(i, j int)

type Options

+ AppId string

+ AppName string

+ AppVersion versions.Version

+ type Promise interface

+ Close func()

+ Failed func(err errors.CodeError)

+ Succeed func(v interface{})

+ type Registration struct

+ func (registration *Registration) Document() (document Document)

+ func (registration *Registration) Internal() (ok bool)

+ func (registration *Registration) Key() (key string)

+ func (registration *Registration) Name() (name string)

+ func (registration *Registration) Request(ctx context.Context, r Request) (future Future)

+ func (registration *Registration) RequestSync(ctx context.Context, r Request) (result FutureResult, err errors.CodeError)

+ type Registrations struct

+ func (r *Registrations) Add(registration *Registration)

+ func (r *Registrations) AddNode(node Node) (err error)

+ func (r *Registrations) Close()

+ func (r *Registrations) Get(name string, vrb versions.Version, vre versions.Version) (registration *Registration, has bool)

+ func (r *Registrations) GetExact(name string, id string) (registration *Registration, has bool)

+ func (r *Registrations) Ids() (ids []string)

+ func (r *Registrations) Remove(id string)

type Request

+ Trunk func() (trunk RequestTrunk)

type RequestHeader

+ Add func(key string, value string)

+ Authorization func() (authorization string, has bool)

+ DeviceId func() (id string)

+ DeviceIp func() (ip string)

+ ForEach func(fn func(key string, values []string) (next bool))

+ MapToHttpHeader func() (v http.Header)

+ Set func(key string, value string)

+ VersionRange func() (left versions.Version, right versions.Version, err error)

+ type RequestOption func(*RequestOptions)

+ func WithDeviceId(id string) RequestOption

+ func WithDeviceIp(ip string) RequestOption

+ func WithHttpRequestHeader(header http.Header) RequestOption

+ func WithInternalRequest() RequestOption

+ func WithRequestId(id string) RequestOption

+ func WithRequestTrunk(trunk RequestTrunk) RequestOption

+ func WithRequestUser(id RequestUserId, attributes *json.Object) RequestOption

+ type RequestOptions struct

+ type RequestTrunk interface

+ ForEach func(fn func(key string, value []byte) (next bool))

+ Get func(key string) (value []byte, has bool)

+ Put func(key string, value []byte)

+ ReadFrom func(o RequestTrunk)

+ Remove func(key string)

type RequestUser

+ SetAttributes func(attributes *json.Object)

+ SetId func(id RequestUserId)

+ type RequestUserId string

+ func (id RequestUserId) Int() (n int64)

+ func (id RequestUserId) String() string

+ type RuntimeConfig struct

+ AutoMaxProcs AutoMaxProcsConfig

+ HandleTimeoutSeconds int

+ LocalSharedStoreCacheSize string

+ MaxWorkers int

+ SecretKey string

+ WorkerMaxIdleSeconds int

+ type Shared interface

+ Lockers func() (lockers shared.Lockers)

+ Store func() (store shared.Store)

+ type SharedConfig struct

+ BarrierDisabled bool

+ BarrierTTLMilliseconds uint64

type Span

+ Children_ []*Span

+ FinishedAT_ time.Time

+ Fn_ string

+ Id_ string

+ Service_ string

+ StartAT_ time.Time

+ Tags_ map[string]string

+ TracerId_ string

+ type TLSConfig struct

+ Kind string

+ Options json.RawMessage

+ func (config *TLSConfig) Config() (serverTLS *tls.Config, clientTLS *tls.Config, err error)

type Tracer

+ RootSpan func() (span *Span)

+ type Workers interface

+ Dispatch func(ctx context.Context, task workers.Task) (ok bool)

+ MustDispatch func(ctx context.Context, task workers.Task)

Oct 15, 2022

Changes in this version

+ func TODO(ctx context.Context, ep Endpoints) context.Context

Oct 14, 2022

Changes in this version

type RequestUser

+ func GetRequestUser(ctx context.Context) (user RequestUser, authenticated bool)

Oct 6, 2022

Changes in this version

type Document

+ Elements func() (elements map[string]ElementDocument)

Aug 23, 2022

Changes in this version

type RequestLocal

+ func NewRequestLocal() (v RequestLocal)

Jun 21, 2022

Changes in this version

+ func ApplicationIsRunning(ctx context.Context) (ok bool)

+ func CanAccessInternal(ctx context.Context) (ok bool)

+ func Fork(ctx context.Context, task Task)

+ func GetApplicationId(ctx context.Context) (appId string)

+ func GetLog(ctx context.Context) (log logs.Logger)

+ func GetOutboundChannel(ctx context.Context, listener string, name string) (channel listeners.OutboundChannel, has bool)

+ func SetLog(ctx context.Context, log logs.Logger) context.Context

+ func SetRequest(ctx context.Context, r Request) context.Context

+ func SetTracer(ctx context.Context) context.Context

+ func TryFork(ctx context.Context, task Task) (ok bool)

+ type Abstract struct

+ func NewAbstract(name string, internal bool, components ...Component) Abstract

+ func (svc *Abstract) Build(options Options) (err error)

+ func (svc *Abstract) Close()

+ func (svc *Abstract) Components() (components map[string]Component)

+ func (svc *Abstract) Internal() (internal bool)

+ func (svc *Abstract) Log() (log logs.Logger)

+ func (svc *Abstract) Name() (name string)

+ type Argument interface

+ As func(v interface{}) (err errors.CodeError)

+ func EmptyArgument() (arg Argument)

+ func NewArgument(v interface{}) (arg Argument)

+ type Barrier interface

+ Do func(ctx context.Context, key string, ...) (result interface{}, err errors.CodeError, shared bool)

+ Forget func(ctx context.Context, key string)

+ type Component interface

+ Build func(options ComponentOptions) (err error)

+ Close func()

+ Name func() (name string)

+ func GetComponent(ctx context.Context, key string) (v Component, has bool)

+ type ComponentOptions struct

+ Config configuares.Config

+ Log logs.Logger

+ type Document interface

+ Description func() (description string)

+ Fns func() []FnDocument

+ Name func() (name string)

+ type ElementDocument interface

+ Key func() (v string)

+ Schema func() (schema *oas.Schema)

+ type Empty struct

+ type Endpoint interface

+ Request func(ctx context.Context, fn string, argument Argument) (result Result)

+ func GetEndpoint(ctx context.Context, name string) (v Endpoint, has bool)

+ func GetExactEndpoint(ctx context.Context, name string, id string) (v Endpoint, has bool)

+ type EndpointDiscovery interface

+ Get func(ctx context.Context, service string) (endpoint Endpoint, has bool)

+ GetExact func(ctx context.Context, service string, id string) (endpoint Endpoint, has bool)

+ type Endpoints interface

+ Close func()

+ Documents func() (v map[string]Document)

+ Mount func(svc Service)

+ RegisterOutboundChannels func(name string, channels listeners.OutboundChannels)

+ SetupContext func(ctx context.Context) context.Context

+ func NewEndpoints(options EndpointsOptions) (v Endpoints)

+ type EndpointsOptions struct

+ AppId string

+ Barrier Barrier

+ Discovery EndpointDiscovery

+ HandleTimeout time.Duration

+ Log logs.Logger

+ MaxIdleWorkerDuration time.Duration

+ MaxWorkers int

+ Running *commons.SafeFlag

+ type FnDocument interface

+ Argument func() (argument ElementDocument)

+ Authorization func() (has bool)

+ Deprecated func() (deprecated bool)

+ Description func() (description string)

+ Name func() (name string)

+ Result func() (result ElementDocument)

+ Title func() (title string)

+ type FutureResult interface

+ func NewResult() FutureResult

+ type Handler interface

+ Handle func(ctx context.Context, r Request) (v interface{}, err errors.CodeError)

+ type Listenable interface

+ Listen func(ctx context.Context) (err error)

+ Sharing func() (ok bool)

+ type Metric struct

+ ErrorCode int

+ ErrorName string

+ Fn string

+ Latency time.Duration

+ Service string

+ Succeed bool

+ type Options struct

+ Config configuares.Config

+ Log logs.Logger

+ type Request interface

+ Argument func() (argument Argument)

+ Authorization func() (v string)

+ Fn func() (service string, fn string)

+ Hash func() (code string)

+ Header func() (header RequestHeader)

+ Id func() (id string)

+ Internal func() (ok bool)

+ Local func() (local RequestLocal)

+ RemoteIp func() (v string)

+ SetUser func(id string, attr *json.Object)

+ User func() (user RequestUser)

+ func GetRequest(ctx context.Context) (r Request, has bool)

+ func NewInternalRequest(service string, fn string, arg interface{}) (r Request, err errors.CodeError)

+ func NewRequest(req *http.Request) (r Request, err errors.CodeError)

+ type RequestHeader interface

+ Contains func(key string) (ok bool)

+ Get func(key string) (value string)

+ Raw func() (v http.Header)

+ Values func(key string) (values []string)

+ func NewRequestHeader(value http.Header) RequestHeader

+ type RequestLocal interface

+ Put func(key string, value interface{})

+ Remove func(key string)

+ Scan func(key string, value interface{}) (has bool, err errors.CodeError)

+ type RequestUser interface

+ Attributes func() (attributes *json.Object)

+ Authenticated func() (ok bool)

+ Id func() (id string)

+ IntId func() (id int64)

+ func NewRequestUser(id string, attributes *json.Object) (u RequestUser)

+ type Result interface

+ Get func(ctx context.Context, v interface{}) (has bool, err errors.CodeError)

+ Value func(ctx context.Context) (value interface{}, has bool, err errors.CodeError)

+ type ResultWriter interface

+ Failed func(err errors.CodeError)

+ Succeed func(v interface{})

+ type Service interface

+ Build func(options Options) (err error)

+ Close func()

+ Components func() (components map[string]Component)

+ Document func() (doc Document)

+ Handle func(context context.Context, fn string, argument Argument) (v interface{}, err errors.CodeError)

+ Internal func() (internal bool)

+ Name func() (name string)

+ type Span interface

+ AddTag func(key string, value string)

+ AppendChild func(children ...Span)

+ Children func() (v []Span)

+ Finish func()

+ FinishedAT func() (v time.Time)

+ Id func() (v string)

+ Latency func() (v time.Duration)

+ Parent func() (v Span)

+ StartAT func() (v time.Time)

+ Tags func() (v map[string]string)

+ TracerId func() (v string)

+ func DecodeSpan(p []byte) (v Span, err errors.CodeError)

+ type Task interface

+ Execute func(ctx context.Context)

+ Name func() (name string)

+ type Tracer interface

+ Id func() (id string)

+ Span func() (span Span)

+ StartSpan func(service string, fn string) (span Span)

+ func GetTracer(ctx context.Context) (t Tracer, has bool)

+ func NewTracer(id string) Tracer