memory

Documentation

Index

• type MemoryTransporter
  • func Create(logger *log.Entry, memory *SharedMemory) MemoryTransporter
  • func (transporter *MemoryTransporter) Connect(registry moleculer.Registry) 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

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(registry moleculer.Registry) 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
}