clusters

Jan 16, 2024

Changes in this version

type Development

+ func (cluster *Development) Client() transports.Client

Jan 11, 2024

Changes in this version

type Manager

+ func (manager *Manager) RequestAsync(req services.Request) (future futures.Future, err error)

Jan 8, 2024

Changes in this version

type Endpoint

+ func (endpoint *Endpoint) Id() string

type Endpoints

+ func (endpoints *Endpoints) Add(ep *Endpoint)

+ func (endpoints *Endpoints) Get(id []byte) (ep *Endpoint)

+ func (endpoints *Endpoints) Infos() (v services.EndpointInfos)

+ func (endpoints *Endpoints) MaxOne() (ep *Endpoint)

+ func (endpoints *Endpoints) Range(interval versions.Interval) (ep *Endpoint)

+ func (endpoints *Endpoints) Remove(id []byte)

type Registration

+ func (r *Registration) Infos() (v services.EndpointInfos)

+ type SortedVersionEndpoints []*VersionEndpoints

+ func (list SortedVersionEndpoints) Add(ep *Endpoint) SortedVersionEndpoints

+ func (list SortedVersionEndpoints) Get(version versions.Version) *VersionEndpoints

+ func (list SortedVersionEndpoints) Len() int

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

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

+ type VersionEndpoints struct

+ func (endpoints *VersionEndpoints) Add(ep *Endpoint)

+ func (endpoints *VersionEndpoints) Get(id []byte) (ep *Endpoint)

+ func (endpoints *VersionEndpoints) Next() (ep *Endpoint)

+ func (endpoints *VersionEndpoints) Remove(id []byte) (ok bool)

Dec 23, 2023

Changes in this version

type ClusterEndpointsManager

+ FnAddress func(ctx context.Context, endpoint []byte, fnName []byte, ...) (address string, internal bool, has bool)

type Manager

+ func (manager *Manager) FnAddress(ctx context.Context, endpoint []byte, fnName []byte, ...) (address string, internal bool, has bool)

Dec 17, 2023

Changes in this version

+ var File_clusters_transport_proto protoreflect.FileDescriptor

type Cluster

+ Barrier func() (barrier barriers.Barrier)

type Development

+ func (cluster *Development) Barrier() (barrier barriers.Barrier)

type Endpoint

+ func (endpoint *Endpoint) IsHealth() bool

type Entry

+ Value []byte

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

+ func (*Entry) ProtoMessage()

+ func (x *Entry) GetKey() []byte

+ func (x *Entry) GetValue() []byte

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

+ func (x *Entry) Reset()

+ func (x *Entry) String() string

type NodeEventKind

+ func (kind NodeEventKind) String() string

type RequestBody

+ Encoding int64

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

+ func (*RequestBody) ProtoMessage()

+ func (x *RequestBody) GetContextUserValues() []*Entry

+ func (x *RequestBody) GetEncoding() int64

+ func (x *RequestBody) GetParams() []byte

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

+ func (x *RequestBody) Reset()

+ func (x *RequestBody) String() string

type ResponseBody

+ Encoding int64

+ Span *tracings.Span

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

+ func (*ResponseBody) ProtoMessage()

+ func (x *ResponseBody) GetAttachments() []*Entry

+ func (x *ResponseBody) GetData() []byte

+ func (x *ResponseBody) GetEncoding() int64

+ func (x *ResponseBody) GetSpan() *tracings.Span

+ func (x *ResponseBody) GetSucceed() bool

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

+ func (x *ResponseBody) Reset()

+ func (x *ResponseBody) String() string

Nov 22, 2023

Changes in this version

+ const Add

+ const Remove

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

+ var ErrInvalidBody = errors.Warning("fns: invalid body")

+ var ErrInvalidPath = errors.Warning("fns: invalid path")

+ var ErrInvalidRequestVersions = errors.Warning("fns: invalid request versions")

+ 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 New(options Options) (manager services.EndpointsManager, shared shareds.Shared, ...)

+ func NewBarrier(config BarrierConfig, shared shareds.Shared) (b barriers.Barrier)

+ func NewInternalHandler(local services.Endpoints, signature signatures.Signature) transports.MuxHandler

+ func NewSignature(secret string) signatures.Signature

+ func RegisterCluster(name string, cluster Cluster)

+ func RegisterHostRetriever(name string, fn HostRetriever)

+ type Barrier struct

+ func (b *Barrier) Do(ctx context.Context, key []byte, fn func() (result interface{}, err error)) (result barriers.Result, err error)

+ func (b *Barrier) Forget(ctx context.Context, key []byte)

+ type BarrierConfig struct

+ Interval time.Duration

+ Standalone bool

+ TTL time.Duration

+ type BarrierValue []byte

+ func NewBarrierValue() BarrierValue

+ func (bv BarrierValue) Exist() bool

+ func (bv BarrierValue) Failed(v error) (n BarrierValue)

+ func (bv BarrierValue) Forget() BarrierValue

+ func (bv BarrierValue) Forgot() bool

+ func (bv BarrierValue) Succeed(v interface{}) (n BarrierValue, err error)

+ func (bv BarrierValue) Value() (data []byte, err error)

+ type Cluster interface

+ AddService func(service Service)

+ Construct func(options ClusterOptions) (err error)

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

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

+ NodeEvents func() (events <-chan NodeEvent)

+ Shared func() (shared shareds.Shared)

+ func NewDevelopment(dialer transports.Dialer, signature signatures.Signature) Cluster

+ type ClusterBuilderOptions struct

+ Config configures.Config

+ Log logs.Logger

+ type ClusterEndpointsManager interface

+ Address func() string

+ PublicFnAddress func(ctx context.Context, endpoint []byte, fnName []byte, ...) (address string, has bool)

+ func NewManager(id string, version versions.Version, address string, cluster Cluster, ...) ClusterEndpointsManager

+ type ClusterOptions struct

+ Address string

+ Config configures.Config

+ Id string

+ Log logs.Logger

+ Name string

+ Version versions.Version

+ type Config struct

+ Barrier BarrierConfig

+ HostRetriever string

+ Name string

+ Option json.RawMessage

+ Proxy bool

+ Secret string

+ type Development struct

+ func (cluster *Development) AddService(_ Service)

+ func (cluster *Development) Construct(options ClusterOptions) (err error)

+ func (cluster *Development) Join(ctx context.Context) (err error)

+ func (cluster *Development) Leave(_ context.Context) (err error)

+ func (cluster *Development) NodeEvents() (events <-chan NodeEvent)

+ func (cluster *Development) Shared() (shared shareds.Shared)

+ type DevelopmentConfig struct

+ ProxyAddr string

+ type Endpoint struct

+ func NewEndpoint(address string, id string, version versions.Version, name string, ...) (endpoint *Endpoint)

+ func (endpoint *Endpoint) AddFn(name string, internal bool, readonly bool)

+ func (endpoint *Endpoint) Address() string

+ func (endpoint *Endpoint) Document() documents.Endpoint

+ func (endpoint *Endpoint) Functions() services.Fns

+ func (endpoint *Endpoint) Info() services.EndpointInfo

+ func (endpoint *Endpoint) Internal() bool

+ func (endpoint *Endpoint) Name() string

+ func (endpoint *Endpoint) Running() bool

+ func (endpoint *Endpoint) Shutdown(_ context.Context)

+ type Endpoints []*Endpoint

+ func (list Endpoints) Len() int

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

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

+ type Entry struct

+ Key []byte

+ Val json.RawMessage

+ type Fn struct

+ func (fn *Fn) Enable() bool

+ func (fn *Fn) Handle(ctx services.Request) (v interface{}, err error)

+ func (fn *Fn) Internal() bool

+ func (fn *Fn) Name() string

+ func (fn *Fn) Readonly() bool

+ type HostRetriever func() (host string, err error)

+ type InternalHandler struct

+ func (handler *InternalHandler) Construct(_ transports.MuxHandlerOptions) error

+ func (handler *InternalHandler) Handle(w transports.ResponseWriter, r transports.Request)

+ func (handler *InternalHandler) Match(_ context.Context, method []byte, path []byte, header transports.Header) bool

+ func (handler *InternalHandler) Name() string

+ type Manager struct

+ func (manager *Manager) Add(service services.Service) (err error)

+ func (manager *Manager) Address() string

+ func (manager *Manager) Get(ctx context.Context, name []byte, options ...services.EndpointGetOption) (endpoint services.Endpoint, has bool)

+ func (manager *Manager) Info() (infos services.EndpointInfos)

+ func (manager *Manager) Listen(ctx context.Context) (err error)

+ func (manager *Manager) PublicFnAddress(ctx context.Context, endpoint []byte, fnName []byte, ...) (address string, has bool)

+ func (manager *Manager) Request(ctx context.Context, name []byte, fn []byte, param interface{}, ...) (response services.Response, err error)

+ func (manager *Manager) Shutdown(ctx context.Context)

+ type Node struct

+ Address string

+ Id string

+ Services []Service

+ Version versions.Version

+ type NodeEvent struct

+ Kind NodeEventKind

+ Node Node

+ type NodeEventKind int

+ type Nodes []Node

+ func MapEndpointInfosToNodes(infos services.EndpointInfos) (nodes Nodes)

+ func (nodes Nodes) Add(node Node) Nodes

+ func (nodes Nodes) Difference(olds Nodes) (events []NodeEvent)

+ func (nodes Nodes) Len() int

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

+ func (nodes Nodes) Remove(node Node) Nodes

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

+ type Options struct

+ Config Config

+ Dialer transports.Dialer

+ Id string

+ Local services.EndpointsManager

+ Log logs.Logger

+ Name string

+ Port int

+ Version versions.Version

+ Worker workers.Workers

+ type Registration struct

+ func (registration *Registration) Add(endpoint *Endpoint)

+ func (registration *Registration) Get(id []byte) (endpoint *Endpoint, has bool)

+ func (registration *Registration) MaxOne() (endpoint *Endpoint, has bool)

+ func (registration *Registration) Range(interval versions.Interval) (endpoint *Endpoint, has bool)

+ func (registration *Registration) Remove(id string)

+ type Registrations []*Registration

+ func (registrations Registrations) Add(endpoint *Endpoint) Registrations

+ func (registrations Registrations) Get(name []byte) (v *Registration, has bool)

+ func (registrations Registrations) Remove(name string, id string) Registrations

+ type RequestBody struct

+ ContextUserValues []Entry

+ Params json.RawMessage

+ type ResponseAttachment struct

+ Name string

+ Value json.RawMessage

+ func (attachment *ResponseAttachment) Scan(dst interface{}) (err error)

+ type ResponseAttachments []ResponseAttachment

+ func (attachments *ResponseAttachments) Get(name string) (attachment ResponseAttachment, has bool)

+ func (attachments *ResponseAttachments) Set(name string, value interface{}) (err error)

+ type ResponseBody struct

+ Attachments ResponseAttachments

+ Data json.RawMessage

+ Succeed bool

+ type Service struct

+ DocumentRaw []byte

+ Functions services.FnInfos

+ Internal bool

+ Name string

+ func NewService(name string, internal bool, functions services.FnInfos, ...) (service Service, err error)

+ func (service Service) Document() (document documents.Endpoint, err error)