Documentation
¶
Index ¶
- type MemoryTransporter
- func (transporter *MemoryTransporter) Connect() chan error
- func (transporter *MemoryTransporter) Disconnect() chan error
- func (transporter *MemoryTransporter) Publish(command, nodeID string, message moleculer.Payload)
- func (transporter *MemoryTransporter) SetNodeID(nodeID string)
- func (transporter *MemoryTransporter) SetPrefix(prefix string)
- func (transporter *MemoryTransporter) SetSerializer(serializer serializer.Serializer)
- func (transporter *MemoryTransporter) Subscribe(command string, nodeID string, handler transit.TransportHandler)
- type SharedMemory
- type Subscription
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MemoryTransporter ¶
type MemoryTransporter struct {
// contains filtered or unexported fields
}
func Create ¶
func Create(logger *log.Entry, memory *SharedMemory) MemoryTransporter
func (*MemoryTransporter) Connect ¶
func (transporter *MemoryTransporter) Connect() chan error
func (*MemoryTransporter) Disconnect ¶
func (transporter *MemoryTransporter) Disconnect() chan error
func (*MemoryTransporter) Publish ¶
func (transporter *MemoryTransporter) Publish(command, nodeID string, message moleculer.Payload)
func (*MemoryTransporter) SetNodeID ¶
func (transporter *MemoryTransporter) SetNodeID(nodeID string)
func (*MemoryTransporter) SetPrefix ¶
func (transporter *MemoryTransporter) SetPrefix(prefix string)
func (*MemoryTransporter) SetSerializer ¶
func (transporter *MemoryTransporter) SetSerializer(serializer serializer.Serializer)
func (*MemoryTransporter) Subscribe ¶
func (transporter *MemoryTransporter) Subscribe(command string, nodeID string, handler transit.TransportHandler)
type SharedMemory ¶
type SharedMemory struct {
// contains filtered or unexported fields
}
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.