pubsub

README

p2pdb-pubsub

decentralized,distributed,peer-to-peer database.

Documentation

Index

• Constants
• type DataMessage
• type PubSub
  • func (p2pdbPubSub *PubSub) GetType() string
  • func (p2pdbPubSub *PubSub) InitPubSub(Type string, Host host.Host) PubSub
  • func (p2pdbPubSub *PubSub) Pub(message DataMessage)
  • func (p2pdbPubSub *PubSub) SetHost(Host host.Host)
  • func (p2pdbPubSub *PubSub) SetType(Type string)
  • func (p2pdbPubSub *PubSub) StartNewSubscribeService(sub *libpubsub.Subscription)
• type PubSubInterface
• type SubHandler

Constants

const GlobalTopic string = ("p2pdb")

Types

type DataMessage

type DataMessage struct {
	Type string
	Data interface{}
}

type PubSub

type PubSub struct {
	Host       host.Host
	Topic      *libpubsub.Topic
	Type       string
	SubHandler SubHandler
	// contains filtered or unexported fields
}

func (*PubSub) GetType

func (p2pdbPubSub *PubSub) GetType() string

func (*PubSub) InitPubSub

func (p2pdbPubSub *PubSub) InitPubSub(Type string, Host host.Host) PubSub

func (*PubSub) Pub

func (p2pdbPubSub *PubSub) Pub(message DataMessage)

func (*PubSub) SetHost

func (p2pdbPubSub *PubSub) SetHost(Host host.Host)

func (*PubSub) SetType

func (p2pdbPubSub *PubSub) SetType(Type string)

func (*PubSub) StartNewSubscribeService

func (p2pdbPubSub *PubSub) StartNewSubscribeService(sub *libpubsub.Subscription)

type PubSubInterface

type PubSubInterface interface {
	InitPubSub()
	GetType() string
	SetType(Type string)
	Pub(message DataMessage)
	Sub() (*libpubsub.Subscription, *libpubsub.Topic, error)
	// contains filtered or unexported methods
}

type SubHandler

type SubHandler interface {
	SubHandler(DataMessage)
}