broker

package

v0.0.7 Latest Latest Go to latest Published: Mar 11, 2024 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type ServiceBroker struct {
	// contains filtered or unexported fields
}

func New(userConfig ...*moleculer.Config) *ServiceBroker

New : returns a valid broker based on environment configuration this is usually called when creating a broker to starting the service(s)

func (broker *ServiceBroker) Broadcast(event string, params interface{}, groups ...string)

func (broker *ServiceBroker) Call(actionName string, params interface{}, opts ...moleculer.Options) chan moleculer.Payload

Call : invoke a service action and return a channel which will eventualy deliver the results ;)

func (broker *ServiceBroker) Emit(event string, params interface{}, groups ...string)

func (broker *ServiceBroker) GetLogger(name string, value string) *log.Entry

func (broker *ServiceBroker) IsStarted() bool

func (broker *ServiceBroker) KnowAction(action string) bool

func (broker *ServiceBroker) LocalBus() *bus.Emitter

GetLocalBus : return the service broker local bus (Event Emitter)

func (broker *ServiceBroker) LocalNode() moleculer.Node

func (broker *ServiceBroker) MCall(callMaps map[string]map[string]interface{}) chan map[string]moleculer.Payload

MCall perform multiple calls and return all results together in a nice map indexed by name.

func (broker *ServiceBroker) Publish(services ...interface{})

Publish : for each service schema it will validate and create a service instance in the broker.

func (broker *ServiceBroker) Start()

func (broker *ServiceBroker) Stop()

func (broker *ServiceBroker) WaitFor(services ...string) error

WaitFor : wait for all services to be available

func (broker *ServiceBroker) WaitForActions(actions ...string) error

WaitForActions : wait for all actions to be available

func (broker *ServiceBroker) WaitForNodes(nodes ...string) error

WaitForNodes : wait for all nodes to be available