transit

Documentation

Index

• type Transit
• type Transport
• type TransportHandler
• type ValidateMsgFunc

Types

type Transit

type Transit interface {
	Emit(moleculer.BrokerContext)
	Request(moleculer.BrokerContext) chan moleculer.Payload
	Connect(moleculer.Registry) chan error
	Disconnect() chan error
	DiscoverNode(nodeID string)

	//DiscoverNodes checks if there are neighbours and return true if any are found ;).
	DiscoverNodes() chan bool
	SendHeartbeat()
}

type Transport

type Transport interface {
	Connect(registry moleculer.Registry) chan error
	Disconnect() chan error
	Subscribe(command, nodeID string, handler TransportHandler)
	Publish(command, nodeID string, message moleculer.Payload)

	SetPrefix(prefix string)
	SetNodeID(nodeID string)
	SetSerializer(serializer serializer.Serializer)

	// GetMetrics returns transport-specific metrics (optional)
	GetMetrics() map[string]interface{}
}

type TransportHandler

type TransportHandler func(moleculer.Payload)

type ValidateMsgFunc

type ValidateMsgFunc func(moleculer.Payload) bool