Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel interface { // Did returns the DID of the channel. Did() string // Read returns a list of all peers subscribed to the channel topic. Read() []peer.ID // Publish publishes the given message to the channel topic. Publish(obj *ot.ObjectDoc) error // Listen subscribes to the beam topic and returns a channel that will // receive events. Listen(opChan chan *ct.ChannelMessage) // Close closes the channel. Close() error }
Channel is a pubsub based Key-Value store for Libp2p nodes.
type Option ¶
type Option func(*options)
Option is a function that modifies the beam options.
func WithCapacity ¶
WithCapacity sets the capacity of the beam store.
Click to show internal directories.
Click to hide internal directories.