pubsub

Aug 30, 2025

Changes in this version

type DiscoveryService

+ func (ds *DiscoveryService) StartTopicDiscovery(ctx context.Context, databaseName, topic string) error

+ func (ds *DiscoveryService) StopTopicDiscovery(topic string)

Jul 17, 2025

Changes in this version

+ type DB struct

+ func Connect(ctx context.Context, config common.Config) (*DB, error)

+ func (db *DB) ConnectedPeers() []*peer.AddrInfo

+ func (db *DB) Disconnect(ctx context.Context) error

+ func (db *DB) GetHost() host.Host

+ func (db *DB) IsReady() bool

+ func (db *DB) Publish(ctx context.Context, topic string, value interface{}) (common.Event, error)

+ func (db *DB) Subscribe(ctx context.Context, topic string, handler common.PubSubHandler) error

+ func (db *DB) Unsubscribe(ctx context.Context, topic string) error

+ type DatabaseInstance struct

+ type DiscoveryService struct

+ func NewDiscoveryService(host host.Host, dht *dual.DHT, logger common.Logger) *DiscoveryService

+ func (ds *DiscoveryService) GetConnectedPeers() []peer.AddrInfo

+ func (ds *DiscoveryService) GetDHTStats() map[string]interface{}

+ func (ds *DiscoveryService) StartDiscovery(ctx context.Context, databaseName string) error

+ type P2PInfrastructure struct

+ func (infra *P2PInfrastructure) IsReady() bool

+ type TopicSubscription struct