memory

package
v0.1.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 24, 2023 License: MIT Imports: 7 Imported by: 0

Documentation

Index

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 nucleo.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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL