fns

Dec 17, 2023

Changes in this version

type Option

+ func LogWriters(writers ...logs.Writer) Option

Nov 22, 2023

Changes in this version

type Option

+ func Handler(handler transports.MuxHandler) Option

+ func Middleware(middleware transports.Middleware) Option

Apr 8, 2023

Changes in this version

type Option

+ func Proxy(tr *TransportOptions) Option

+ func Transport(tr *TransportOptions) Option

+ type TransportOptions struct

+ func TransportOption() *TransportOptions

+ func (options *TransportOptions) Append(handlers ...service.TransportHandler) *TransportOptions

+ func (options *TransportOptions) Use(middlewares ...service.TransportMiddleware) *TransportOptions

Mar 23, 2023

Changes in this version

type Option

+ func ProxyMode() Option

Mar 20, 2023

Changes in this version

type Application

+ Quit func()

type ExecuteOption

+ func ExecuteAsInternalRequest() ExecuteOption

+ func ExecuteWithRequestUser(user service.RequestUser) ExecuteOption

type Option

+ func Id(id string) Option

+ func Name(name string) Option

+ func OpenApiVersion(version string) Option

Nov 7, 2022

Changes in this version

+ type ExecuteOption func(*ExecuteOptions) error

+ func ExecuteWithUser(user service.RequestUser) ExecuteOption

+ type ExecuteOptions struct

Oct 15, 2022

Changes in this version

type Application

+ Execute func(ctx context.Context, serviceName string, fn string, argument interface{}) (result interface{}, err errors.CodeError)

+ RunWithHooks func(ctx context.Context, hook ...Hook) (err error)

type Hook

+ Name func() (name string)

+ type HookOptions struct

+ Config configures.Config

+ Log logs.Logger

Oct 7, 2022

Changes in this version

type Option

+ func Handlers(handlers ...server.Handler) Option

Jun 21, 2022

Changes in this version

type Option

+ func Barrier(barrier service.Barrier) Option

+ func ClusterClientBuilder(builder cluster.ClientBuilder) Option

+ func ExtraListeners(lns ...listeners.Listener) Option

+ func InterceptorHandlers(handlers ...server.InterceptorHandler) Option

+ func MAXPROCS(min int, max int) Option

+ func RegisterValidator(register validators.ValidateRegister) Option

+ func SecretKey(data string) Option

+ func Server(server server.Http) Option

+ func ShutdownTimeout(timeout time.Duration) Option

Feb 21, 2022

Changes in this version

type Context

+ Fork func() (v Context)

Feb 13, 2022

Changes in this version

+ func RegisterServiceBarrierRetriever(name string, retriever ServiceBarrierRetriever)

+ type ServiceBarrier interface

+ Do func(key string, fn func() (v interface{}, err error)) (v interface{}, err error, shared bool)

+ Forget func(key string)

+ type ServiceBarrierRetriever func() (b ServiceBarrier)

Jan 26, 2022

Changes in this version

type ServiceMeta

+ func (meta ServiceMeta) Merge(o ServiceMeta)

Jan 22, 2022

Changes in this version

type Context

+ func WithInternalRequest(ctx Context) Context

Jan 20, 2022

Changes in this version

+ type UserId interface

+ Int func() (v int)

+ String func() (v string)

Jan 19, 2022

Changes in this version

type AbstractService

+ func (s AbstractService) HandleInGroup(ctx Context, fn string, arg Argument, ...) (v interface{}, err errors.CodeError)

type Argument

+ Hash func(ctx Context) (p string)

Jan 11, 2022

Changes in this version

+ type AbstractService struct

+ func NewAbstractService() AbstractService

+ func NewAbstractServiceWithOption(option ServiceOption) AbstractService

+ func (s AbstractService) Build(config configuares.Config) (err error)

+ func (s AbstractService) Meta() (v ServiceMeta)

type AppRuntime

+ ServiceMeta func() (meta ServiceMeta)

type Context

+ func WithServiceMeta(ctx Context, meta ServiceMeta) Context

+ type ServiceMeta map[string]interface

+ func (meta ServiceMeta) Get(key string) (v interface{}, has bool)

+ func (meta ServiceMeta) Set(key string, value interface{})

+ func NewServiceMeta() ServiceMeta

+ type ServiceMetaBuilder func(config configuares.Config) (meta ServiceMeta, err error)

+ type ServiceOption struct

+ MetaBuilder ServiceMetaBuilder

Jan 10, 2022

Changes in this version

type ObjectDocument

+ Example interface{}

+ func StructObjectDocument(pkg string, name string, title string, description string) *ObjectDocument

+ func (obj *ObjectDocument) SetDescription(description string) *ObjectDocument

+ func (obj *ObjectDocument) SetExample(example interface{}) *ObjectDocument

+ func (obj *ObjectDocument) SetFormat(format string) *ObjectDocument

+ func (obj *ObjectDocument) SetTitle(title string) *ObjectDocument

+ func (obj *ObjectDocument) SetValidation(validation string) *ObjectDocument

Jan 9, 2022

Changes in this version

type FnDocument

+ func (doc *FnDocument) SetArgument(v *ObjectDocument)

+ func (doc *FnDocument) SetResult(v *ObjectDocument)

type ObjectDocument

+ Additional bool

+ Deprecated bool

+ Package string

+ Required bool

+ Validation string

+ func Int32ObjectDocument() *ObjectDocument

+ func JsonRawObjectDocument() *ObjectDocument

+ func NewObjectDocument(pkg string, name string, typ string, format string, title string, ...) *ObjectDocument

+ func (obj *ObjectDocument) AddEnum(v ...interface{}) *ObjectDocument

+ func (obj *ObjectDocument) AsDeprecated() *ObjectDocument

+ func (obj *ObjectDocument) AsRequired(validation string) *ObjectDocument

Jan 7, 2022

Changes in this version

type ApplicationConfig

+ Contact *appContact

+ Description string

+ License *appLicense

+ Terms string

+ type FnDocument struct

+ Argument ObjectDocument

+ Deprecated bool

+ Description string

+ HasAuthorization bool

+ Name string

+ Result ObjectDocument

+ Title string

+ func NewFnDocument(name string, title string, description string, hasAuthorization bool, ...) *FnDocument

type HttpConfig

+ TLS *HttpTlsConfig

+ type HttpTlsConfig struct

+ Enable bool

+ PrivateKey string

+ PublicKey string

+ type ObjectDocument struct

+ Description string

+ Enum []interface{}

+ Format string

+ Name string

+ Properties []ObjectPropertyDocument

+ Title string

+ Type string

+ func ArrayObjectDocument(name string, title string, description string, item ObjectPropertyDocument) ObjectDocument

+ func BoolObjectDocument(name string, title string, description string) ObjectDocument

+ func DateObjectDocument(name string, title string, description string) ObjectDocument

+ func DateTimeObjectDocument(name string, title string, description string) ObjectDocument

+ func EmptyObjectDocument(name string, title string, description string) ObjectDocument

+ func Float32ObjectDocument(name string, title string, description string) ObjectDocument

+ func Float64ObjectDocument(name string, title string, description string) ObjectDocument

+ func Int64ObjectDocument(name string, title string, description string) ObjectDocument

+ func IntObjectDocument(name string, title string, description string) ObjectDocument

+ func MapObjectDocument(name string, title string, description string, item ObjectPropertyDocument) ObjectDocument

+ func ObjectObjectDocument(name string, title string, description string) ObjectDocument

+ func RawObjectDocument() ObjectDocument

+ func StringObjectDocument(name string, title string, description string) ObjectDocument

+ func (obj ObjectDocument) AddProperty(prop ObjectPropertyDocument)

+ type ObjectPropertyDocument struct

+ Description string

+ Enum []interface{}

+ Format string

+ Name string

+ Reference *ObjectDocument

+ Required bool

+ Title string

+ Type string

+ func ArrayObjectPropertyDocument(name string, title string, description string, item ObjectDocument) ObjectPropertyDocument

+ func BoolObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func DateObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func DateTimeObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func Float32ObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func Float64ObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func Int32ObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func Int64ObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func IntObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func MapObjectPropertyDocument(name string, title string, description string, item ObjectDocument) ObjectPropertyDocument

+ func RawObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

+ func RefObjectPropertyDocument(name string, title string, description string, ref ObjectDocument) ObjectPropertyDocument

+ func StringObjectPropertyDocument(name string, title string, description string) ObjectPropertyDocument

type ServiceDocument

+ func NewServiceDocument(namespace string, description string) *ServiceDocument

+ func (doc *ServiceDocument) AddFn(fn FnDocument)

Jan 6, 2022

Changes in this version

type Service

+ Document func() (doc *ServiceDocument)

+ Shutdown func() (err error)

Jan 6, 2022

Changes in this version

type ServiceDiscovery

+ Registrations func() (registrations map[string]*Registration)

+ type ServiceDocument struct

+ Definitions map[string]*json.Object

+ Description string

+ Fns map[string]*json.Object

+ Namespace string

Nov 23, 2021

Changes in this version

type Context

+ InternalRequested func() (ok bool)

Sep 30, 2021

Changes in this version

type Argument

+ func EmptyArgument() (arg Argument)

Sep 23, 2021

Changes in this version

+ var File_message_proto protoreflect.FileDescriptor

+ type RemoteRequest struct

+ Arg []byte

+ Meta []byte

+ func (*RemoteRequest) Descriptor() ([]byte, []int)

+ func (*RemoteRequest) ProtoMessage()

+ func (x *RemoteRequest) GetArg() []byte

+ func (x *RemoteRequest) GetMeta() []byte

+ func (x *RemoteRequest) ProtoReflect() protoreflect.Message

+ func (x *RemoteRequest) Reset()

+ func (x *RemoteRequest) String() string

Sep 13, 2021

Changes in this version

type CorsConfig

+ Enable bool

Sep 11, 2021

Changes in this version

type HttpConfig

+ ReadBufferSize string

+ WriteBufferSize string

Sep 7, 2021

Changes in this version

type HookUnit

+ Authorization []byte

Sep 6, 2021

Changes in this version

type Option

+ func GOPROCS(min int, max int) Option

type Options

+ MaxPROCS int

+ MinPROCS int

Sep 5, 2021

Changes in this version

+ func ConfigActiveFromENV(key string) (active string)

+ func RegisterPermissionsDefinitionsLoaderRetriever(kind string, retriever PermissionsDefinitionsLoaderRetriever)

+ type AbstractServiceDiscovery struct

+ Clients *HttpClients

+ Local ServiceDiscovery

+ Manager *RegistrationsManager

+ func NewAbstractServiceDiscovery(clients *HttpClients) AbstractServiceDiscovery

+ func (discovery *AbstractServiceDiscovery) Close()

+ func (discovery *AbstractServiceDiscovery) IsLocal(namespace string) (ok bool)

+ func (discovery *AbstractServiceDiscovery) Proxy(ctx Context, namespace string) (proxy ServiceProxy, err errors.CodeError)

+ type AppRuntime interface

+ Authorizations func() (authorizations Authorizations)

+ ClusterMode func() (ok bool)

+ HttpClient func() (client HttpClient)

+ Log func() (log logs.Logger)

+ Permissions func() (permissions Permissions)

+ PublicAddress func() (address string)

+ ServiceProxy func(ctx Context, namespace string) (proxy ServiceProxy, err error)

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

type ApplicationConfig

+ Concurrency int

type Context

+ App func() (app AppRuntime)

type ContextMeta

+ DelExactProxyServiceAddress func(namespace string)

+ GetExactProxyServiceAddress func(namespace string) (address string, has bool)

+ Remove func(key string)

+ SetExactProxyServiceAddress func(namespace string, address string)

type HookUnit

+ HandleError errors.CodeError

+ RequestId string

+ RequestUser User

+ type HttpClient interface

+ Delete func(url string, head http.Header, timeout time.Duration) (response *HttpResponse, err error)

+ Get func(url string, head http.Header, timeout time.Duration) (response *HttpResponse, err error)

+ Post func(url string, head http.Header, body []byte, timeout time.Duration) (response *HttpResponse, err error)

+ Put func(url string, head http.Header, body []byte, timeout time.Duration) (response *HttpResponse, err error)

+ type HttpClients struct

+ func NewHttpClients(poolSize int) (hc *HttpClients)

+ func (hc *HttpClients) Close()

+ type HttpResponse struct

+ Body []byte

+ Head http.Header

+ Status int

+ type LocaledServiceProxy struct

+ func NewLocaledServiceProxy(service Service) *LocaledServiceProxy

+ func (proxy *LocaledServiceProxy) Request(ctx Context, fn string, argument Argument) (result Result)

type Permissions

+ SaveUserRoles func(ctx Context, roles ...string) (err errors.CodeError)

type PermissionsConfig

+ Loader string

+ type PermissionsDefinitions struct

+ func (d *PermissionsDefinitions) Accessible(namespace string, fn string, roles []string) (accessible bool)

+ func (d *PermissionsDefinitions) Add(namespace string, fn string, role string, accessible bool)

+ type PermissionsDefinitionsLoader interface

+ Load func() (definitions *PermissionsDefinitions, err errors.CodeError)

+ type PermissionsDefinitionsLoaderRetriever func(config configuares.Raw) (loader PermissionsDefinitionsLoader, err error)

+ type Registration struct

+ Address string

+ Id string

+ Namespace string

+ Reversion int64

+ func (r Registration) Key() (key string)

+ type Registrations struct

+ func NewRegistrations() (registrations *Registrations)

+ func (r *Registrations) Append(v Registration)

+ func (r *Registrations) Next() (v *Registration, has bool)

+ func (r *Registrations) Remove(v Registration)

+ func (r *Registrations) Size() (size int)

+ type RegistrationsManager struct

+ func (manager *RegistrationsManager) Append(registration Registration)

+ func (manager *RegistrationsManager) CheckRegistration(registration Registration) (ok bool)

+ func (manager *RegistrationsManager) Close()

+ func (manager *RegistrationsManager) Get(namespace string) (registration *Registration, exists bool)

+ func (manager *RegistrationsManager) ListenProblemChan()

+ func (manager *RegistrationsManager) ProblemChan() (ch chan<- *Registration)

+ func (manager *RegistrationsManager) Registrations() (v []Registration)

+ func (manager *RegistrationsManager) Remove(registration Registration)

type RemotedServiceProxy

+ func NewRemotedServiceProxy(clients *HttpClients, registration *Registration, ...) (proxy *RemotedServiceProxy)

type Service

+ Internal func() (internal bool)

type ServiceDiscoveryOption

+ HttpClients *HttpClients

type ServicesConfig

+ HttpClientPoolSize int

type User

+ Authorization func() (authorization []byte, has bool)

+ SetAuthorization func(authorization []byte)

Aug 27, 2021

Changes in this version

+ const B

+ const EB

+ const GB

+ const KB

+ const MB

+ const PB

+ const TB

+ func RegisterAuthorizationsRetriever(kind string, retriever AuthorizationsRetriever)

+ func RegisterPermissionsRetriever(kind string, retriever PermissionsRetriever)

+ func RegisterServiceDiscoveryRetriever(kind string, retriever ServiceDiscoveryRetriever)

+ func UID() (id string)

+ type Application interface

+ Deploy func(service ...Service) (err error)

+ Log func() (log logs.Logger)

+ Run func(ctx sc.Context) (err error)

+ Sync func()

+ SyncWithTimeout func(timeout time.Duration)

+ func New(options ...Option) (app Application, err error)

+ type ApplicationConfig struct

+ Http HttpConfig

+ Log LogConfig

+ Name string

+ Services ServicesConfig

+ type Argument interface

+ As func(v interface{}) (err error)

+ func NewArgument(v interface{}) (arg Argument, err error)

+ type Authorizations interface

+ Active func(user User) (err error)

+ Decode func(token []byte, user User) (err error)

+ Encode func(user User) (token []byte, err error)

+ Revoke func(user User) (err error)

+ type AuthorizationsConfig struct

+ Config configuares.Raw

+ Enable bool

+ Kind string

+ type AuthorizationsRetriever func(config configuares.Raw) (authorizations Authorizations, err error)

+ type Context interface

+ Authorization func() (value []byte)

+ Log func() (log logs.Logger)

+ Meta func() (meta ContextMeta)

+ RequestId func() (id string)

+ ServiceProxy func(namespace string) (proxy ServiceProxy, err error)

+ Timeout func() (has bool)

+ User func() (user User)

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

+ func WithFn(ctx Context, fnName string) Context

+ func WithNamespace(ctx Context, namespace string) Context

+ type ContextMeta interface

+ Decode func(value []byte) (ok bool)

+ Encode func() (value []byte)

+ Exists func(key string) (has bool)

+ Get func(key string, value interface{}) (err error)

+ GetBool func(key string) (value bool, has bool)

+ GetDuration func(key string) (value time.Duration, has bool)

+ GetFloat32 func(key string) (value float32, has bool)

+ GetFloat64 func(key string) (value float64, has bool)

+ GetInt func(key string) (value int, has bool)

+ GetInt32 func(key string) (value int32, has bool)

+ GetInt64 func(key string) (value int64, has bool)

+ GetString func(key string) (value string, has bool)

+ GetTime func(key string) (value time.Time, has bool)

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

+ type CorsConfig struct

+ AllowCredentials bool

+ AllowedHeaders []string

+ AllowedMethods []string

+ AllowedOrigins []string

+ Enabled bool

+ ExposedHeaders []string

+ MaxAge int

+ type DiscoveryConfig struct

+ Config configuares.Raw

+ Enable bool

+ Kind string

+ type Empty struct

+ type Hook interface

+ Build func(config configuares.Config) (err error)

+ Close func()

+ Handle func(unit HookUnit)

+ type HookUnit struct

+ Error errors.CodeError

+ FnName string

+ Latency time.Duration

+ Namespace string

+ RequestSize int64

+ ResponseSize int64

+ type HttpConfig struct

+ Cors CorsConfig

+ Host string

+ KeepAlive bool

+ KeepalivePeriodSecond int

+ MaxConnectionsPerIP int

+ MaxRequestsPerConnection int

+ Port int

+ PublicHost string

+ PublicPort int

+ RequestTimeoutSeconds int

+ type LogConfig struct

+ Color bool

+ Formatter string

+ Level string

+ type Option func(*Options) error

+ func ConfigRetriever(path string, format string, active string, prefix string, splitter byte) Option

+ func CustomizeValidate(validate *validator.Validate) Option

+ func Hooks(hooks ...Hook) Option

+ func SecretKeyFile(path string) Option

+ func Version(version string) Option

+ type Options struct

+ ConfigRetrieverOption configuares.RetrieverOption

+ Hooks []Hook

+ SecretKey []byte

+ Validate *validator.Validate

+ Version string

+ type Permissions interface

+ Validate func(ctx Context, namespace string, fnName string, user User) (err error)

+ type PermissionsConfig struct

+ Config configuares.Raw

+ Enable bool

+ Kind string

+ type PermissionsRetriever func(config configuares.Raw) (permission Permissions, err error)

+ type RemotedServiceProxy struct

+ func (proxy *RemotedServiceProxy) Request(ctx Context, fn string, argument Argument) (result Result)

+ type Result interface

+ Failed func(err errors.CodeError)

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

+ Succeed func(v interface{})

+ func AsyncResult() Result

+ func SyncResult() Result

+ type Service interface

+ Build func(config configuares.Config) (err error)

+ Close func() (err error)

+ Description func() (description []byte)

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

+ Namespace func() (namespace string)

+ type ServiceDiscovery interface

+ Close func()

+ IsLocal func(namespace string) (ok bool)

+ Proxy func(namespace string) (proxy ServiceProxy, err errors.CodeError)

+ Publish func(service Service) (err error)

+ type ServiceDiscoveryOption struct

+ Address string

+ Config []byte

+ ServerId string

+ type ServiceDiscoveryRetriever func(options ServiceDiscoveryOption) (discovery ServiceDiscovery, err error)

+ type ServiceProxy interface

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

+ type ServiceRequestHeader interface

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

+ type Services interface

+ Build func(config ServicesConfig) (err error)

+ Close func()

+ DecodeAuthorization func(ctx Context, value []byte) (err errors.CodeError)

+ Description func(namespace string) (description []byte)

+ Exist func(namespace string) (ok bool)

+ Mount func(service Service) (err error)

+ PermissionAllow func(ctx Context, namespace string, fn string) (err errors.CodeError)

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

+ type ServicesConfig struct

+ Authorization AuthorizationsConfig

+ Concurrency int

+ Discovery DiscoveryConfig

+ HandleTimeoutSecond int

+ MaxIdleTimeSecond int

+ Permission PermissionsConfig

+ ReduceMemoryUsage bool

+ type User interface

+ Active func() (err error)

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

+ Encode func() (value []byte, err error)

+ Exists func() (ok bool)

+ Id func() (id string)

+ Principals func() (principal *json.Object)

+ Revoke func() (err error)

+ String func() (value string)