moleculer

package module

Go to main page

Versions in this module

v0

v0.3.5

Apr 15, 2024

Changes in this version

type Node

+ GetHost func() string

v0.3.4

Apr 12, 2024

Changes in this version

type Config

+ UpdateNodeMetricsFrequency time.Duration

+ type ForEachNodeFunc func(node Node) bool

type Node

+ GetCpu func() int64

+ GetCpuSequence func() int64

+ GetHostname func() string

+ GetIpList func() []string

+ GetPort func() int

+ GetSequence func() int64

+ GetUdpAddress func() string

+ IsLocal func() bool

+ UpdateInfo func(info map[string]interface{}) []map[string]interface{}

+ UpdateMetrics func()

+ type Registry interface

+ AddOfflineNode func(nodeID, hostname, ipAddress string, port int) Node

+ DisconnectNode func(nodeID string)

+ ForEachNode func(ForEachNodeFunc)

+ GetLocalNode func() Node

+ GetNodeByAddress func(host string) Node

+ GetNodeByID func(nodeID string) Node

+ RemoteNodeInfoReceived func(message Payload)

v0.3.3

Mar 7, 2024

v0.3.2

Apr 18, 2022

v0.3.1

Apr 18, 2022

v0.3.0

Jun 13, 2021

Changes in this version

type BrokerContext

+ Caller func() string

type BrokerDelegates

+ InstanceID InstanceIDFunc

+ type InstanceIDFunc func() string

v0.2.7

May 16, 2021

v0.2.6

May 16, 2021

v0.2.5

May 1, 2020

Changes in this version

type Payload

+ At func(index int) Payload

+ ErrorPayload func() Payload

v0.2.4

Apr 14, 2020

Changes in this version

type Payload

+ MapOver func(tranform func(in Payload) Payload) Payload

v0.2.3

Mar 11, 2020

v0.2.2

Mar 11, 2020

Changes in this version

type Config

+ StrategyFactory StrategyFactoryFunc

+ type StrategyFactoryFunc func() interface

v0.2.1

Sep 18, 2019

Changes in this version

type Config

+ Services map[string]interface{}

v0.2.0

Aug 18, 2019

Changes in this version

type Payload

+ Only func(path string) Payload

v0.1.5

May 29, 2019

v0.1.4

May 28, 2019

v0.1.3

May 24, 2019

Changes in this version

type BrokerContext

+ WaitFor func(services ...string) error

type BrokerDelegates

+ WaitFor WaitForFunc

type Payload

+ ByteArray func() []byte

+ type WaitForFunc func(...string) error

v0.1.2

May 9, 2019

Changes in this version

type Payload

+ Sort func(field string) Payload

v0.1.1

May 7, 2019

Changes in this version

type BrokerContext

+ Call func(actionName string, params interface{}, opts ...Options) chan Payload

+ Emit func(eventName string, params interface{}, groups ...string)

+ UpdateMeta func(Payload)

type Config

+ OfflineTimeout time.Duration

type Context

+ Meta func() Payload

+ Payload func() Payload

type Node

+ Available func()

+ type Options struct

+ Meta Payload

+ NodeID string

v0.1.0

Apr 29, 2019

Changes in this version

+ var DefaultConfig = Config

+ type Action struct

+ Description string

+ Handler ActionHandler

+ Name string

+ Schema ActionSchema

+ Settings map[string]interface{}

+ type ActionDelegateFunc func(context BrokerContext, opts ...OptionsFunc) chan Payload

+ type ActionHandler func(context Context, params Payload) interface

+ type ActionSchema interface

+ type BrokerContext interface

+ ActionName func() string

+ AsMap func() map[string]interface{}

+ ChildActionContext func(actionName string, params Payload, opts ...OptionsFunc) BrokerContext

+ ChildEventContext func(eventName string, params Payload, groups []string, broadcast bool) BrokerContext

+ EventName func() string

+ Groups func() []string

+ ID func() string

+ IsBroadcast func() bool

+ Logger func() *log.Entry

+ Meta func() *map[string]interface{}

+ Payload func() Payload

+ Publish func(...interface{})

+ RequestID func() string

+ SetTargetNodeID func(targetNodeID string)

+ TargetNodeID func() string

+ type BrokerContextFunc func() BrokerContext

+ type BrokerDelegates struct

+ ActionDelegate ActionDelegateFunc

+ BroadcastEvent EmitEventFunc

+ BrokerContext BrokerContextFunc

+ Bus BusFunc

+ Config Config

+ EmitEvent EmitEventFunc

+ HandleRemoteEvent EmitEventFunc

+ IsStarted isStartedFunc

+ LocalNode LocalNodeFunc

+ Logger LoggerFunc

+ MiddlewareHandler MiddlewareHandlerFunc

+ MultActionDelegate MultActionDelegateFunc

+ Publish PublishFunc

+ ServiceForAction ServiceForActionFunc

+ type BusFunc func() *bus.Emitter

+ type Config struct

+ Created func()

+ DisableInternalMiddlewares bool

+ DisableInternalServices bool

+ DiscoverNodeID func() string

+ DontWaitForNeighbours bool

+ HeartbeatFrequency time.Duration

+ HeartbeatTimeout time.Duration

+ LogFormat string

+ LogLevel string

+ MCallTimeout time.Duration

+ MaxCallLevel int

+ Metrics bool

+ MetricsRate float32

+ Middlewares []Middlewares

+ Namespace string

+ NeighboursCheckTimeout time.Duration

+ OfflineCheckFrequency time.Duration

+ RequestTimeout time.Duration

+ RetryPolicy RetryPolicy

+ Started func()

+ Stopped func()

+ Transporter string

+ TransporterFactory TransporterFactoryFunc

+ WaitForDependenciesTimeout time.Duration

+ WaitForNeighboursInterval time.Duration

+ type Context interface

+ Broadcast func(eventName string, params interface{}, groups ...string)

+ Call func(actionName string, params interface{}, opts ...OptionsFunc) chan Payload

+ Emit func(eventName string, params interface{}, groups ...string)

+ Logger func() *log.Entry

+ MCall func(map[string]map[string]interface{}) chan map[string]Payload

+ type CreatedFunc func(ServiceSchema, *log.Entry)

+ type EmitEventFunc func(context BrokerContext)

+ type Event struct

+ Group string

+ Handler EventHandler

+ Name string

+ type EventHandler func(context Context, params Payload)

+ type ForEachFunc func(iterator func(key interface{}, value Payload) bool)

+ type LifecycleFunc func(BrokerContext, ServiceSchema)

+ type LocalNodeFunc func() Node

+ type LoggerFunc func(name string, value string) *log.Entry

+ type Middleware interface

+ CallHandlers func(name string, params interface{}) interface{}

+ type MiddlewareHandler func(params interface{}, next func(...interface{}))

+ type MiddlewareHandlerFunc func(name string, params interface{}) interface

+ type Middlewares map[string]MiddlewareHandler

+ type Mixin struct

+ Actions []Action

+ Created CreatedFunc

+ Dependencies []string

+ Events []Event

+ Hooks map[string]interface{}

+ Metadata map[string]interface{}

+ Name string

+ Settings map[string]interface{}

+ Started LifecycleFunc

+ Stopped LifecycleFunc

+ type MultActionDelegateFunc func(callMaps map[string]map[string]interface{}) chan map[string]Payload

+ type Node interface

+ ExportAsMap func() map[string]interface{}

+ GetID func() string

+ HeartBeat func(heartbeat map[string]interface{})

+ IncreaseSequence func()

+ IsAvailable func() bool

+ IsExpired func(timeout time.Duration) bool

+ Publish func(service map[string]interface{})

+ Unavailable func()

+ Update func(info map[string]interface{}) bool

+ type ObjectSchema struct

+ Source interface{}

+ type OptionsFunc func(key string) interface

+ type Payload interface

+ Add func(field string, value interface{}) Payload

+ AddItem func(value interface{}) Payload

+ AddMany func(map[string]interface{}) Payload

+ Array func() []Payload

+ Bool func() bool

+ BoolArray func() []bool

+ Bson func() bson.M

+ BsonArray func() bson.A

+ Error func() error

+ Exists func() bool

+ First func() Payload

+ Float func() float64

+ Float32 func() float32

+ Float32Array func() []float32

+ FloatArray func() []float64

+ ForEach func(iterator func(key interface{}, value Payload) bool)

+ Get func(path string) Payload

+ Int func() int

+ Int64 func() int64

+ Int64Array func() []int64

+ IntArray func() []int

+ IsArray func() bool

+ IsError func() bool

+ IsMap func() bool

+ Len func() int

+ Map func() map[string]Payload

+ MapArray func() []map[string]interface{}

+ RawMap func() map[string]interface{}

+ Remove func(fields ...string) Payload

+ String func() string

+ StringArray func() []string

+ StringIdented func(string) string

+ Time func() time.Time

+ TimeArray func() []time.Time

+ Uint func() uint64

+ UintArray func() []uint64

+ Value func() interface{}

+ ValueArray func() []interface{}

+ type PublishFunc func(...interface{})

+ type RetryPolicy struct

+ Check func(error) bool

+ Delay int

+ Enabled bool

+ Factor int

+ MaxDelay int

+ Retries int

+ type ServiceForActionFunc func(string) *ServiceSchema

+ type ServiceSchema struct

+ Actions []Action

+ Created CreatedFunc

+ Dependencies []string

+ Events []Event

+ Hooks map[string]interface{}

+ Metadata map[string]interface{}

+ Mixins []Mixin

+ Name string

+ Settings map[string]interface{}

+ Started LifecycleFunc

+ Stopped LifecycleFunc

+ Version string

+ type TransporterFactoryFunc func() interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL