nucleo

package module

Go to main page

Versions in this module

v0

v0.1.5

Nov 24, 2023

v0.1.4

Nov 23, 2023

Changes in this version

type BrokerContext

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

+ SetPayloadSchema func(schema map[string]interface{})

type Config

+ Validator ValidatorType

+ type ValidatorType string

+ const ValidatorGo

v0.1.3

Nov 11, 2023

v0.1.2

Nov 10, 2023

Changes in this version

type Config

+ Serializer SerializerType

+ Strategy StrategyType

+ type SerializerType string

+ const SerializerJSON

+ type StrategyType string

+ const StrategyRandom

+ const StrategyRoundRobin

v0.1.1

Nov 10, 2023

Changes in this version

+ var DefaultConfig = Config

+ type Action struct

+ Description string

+ Handler ActionHandler

+ Name string

+ Params ActionParams

+ Settings map[string]interface{}

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

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

+ type ActionParams interface

+ type BrokerContext interface

+ ActionName func() string

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

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

+ Caller func() string

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

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

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

+ EventName func() string

+ Groups func() []string

+ ID func() string

+ IsBroadcast func() bool

+ Logger func() *log.Entry

+ Meta func() Payload

+ Payload func() Payload

+ Publish func(...interface{})

+ RequestID func() string

+ SetTargetNodeID func(targetNodeID string)

+ TargetNodeID func() string

+ UpdateMeta func(Payload)

+ WaitFor func(services ...string) error

+ type BrokerContextFunc func() BrokerContext

+ type BrokerDelegates struct

+ ActionDelegate ActionDelegateFunc

+ BroadcastEvent EmitEventFunc

+ BrokerContext BrokerContextFunc

+ Bus BusFunc

+ Config Config

+ EmitEvent EmitEventFunc

+ HandleRemoteEvent EmitEventFunc

+ InstanceID InstanceIDFunc

+ IsStarted isStartedFunc

+ LocalNode LocalNodeFunc

+ Logger LoggerFunc

+ MiddlewareHandler MiddlewareHandlerFunc

+ MultActionDelegate MultActionDelegateFunc

+ PublishServices PublishServicesFunc

+ ServiceForAction ServiceForActionFunc

+ WaitFor WaitForFunc

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

+ LogLevel LogLevelType

+ MCallTimeout time.Duration

+ MaxCallLevel int

+ Metrics bool

+ MetricsRate float32

+ Middlewares []Middlewares

+ Namespace string

+ NeighboursCheckTimeout time.Duration

+ OfflineCheckFrequency time.Duration

+ OfflineTimeout time.Duration

+ RequestTimeout time.Duration

+ RetryPolicy RetryPolicy

+ Services map[string]interface{}

+ Started func()

+ Stopped func()

+ StrategyFactory StrategyFactoryFunc

+ 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 ...Options) 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

+ Meta func() Payload

+ Payload func() 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 InstanceIDFunc func() string

+ type LifecycleFunc func(BrokerContext, ServiceSchema)

+ type LocalNodeFunc func() Node

+ type LogFormatType string

+ const LogFormatJSON

+ const LogFormatText

+ type LogLevelType string

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelFatal

+ const LogLevelInfo

+ const LogLevelTrace

+ const LogLevelWarn

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

+ 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

+ Available func()

+ 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(id string, info map[string]interface{}) bool

+ type ObjectSchema struct

+ Source interface{}

+ type Options struct

+ Meta Payload

+ NodeID string

+ type Payload interface

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

+ AddItem func(value interface{}) Payload

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

+ Array func() []Payload

+ At func(index int) Payload

+ Bool func() bool

+ BoolArray func() []bool

+ Bson func() bson.M

+ BsonArray func() bson.A

+ ByteArray func() []byte

+ Error func() error

+ ErrorPayload func() Payload

+ 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, defaultValue ...interface{}) 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{}

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

+ Only func(path string) Payload

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

+ Remove func(fields ...string) Payload

+ Sort func(field string) Payload

+ String func() string

+ StringArray func() []string

+ Time func() time.Time

+ TimeArray func() []time.Time

+ Uint func() uint64

+ UintArray func() []uint64

+ Value func() interface{}

+ ValueArray func() []interface{}

+ type PublishServicesFunc 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 StrategyFactoryFunc func() interface

+ type TransporterFactoryFunc func() interface

+ type WaitForFunc func(...string) error

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