moleculer-go/moleculer

package transit

import (
    "github.com/moleculer-go/moleculer"
    "github.com/moleculer-go/moleculer/serializer"
)

type TransportHandler func(moleculer.Payload)

type ValidateMsgFunc func(moleculer.Payload) bool

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 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)
}