|
| | Dht (std::unique_ptr< net::DatagramSocket > &&sock, const Config &config, const Sp< Logger > &l={}) |
| |
| | Dht (std::unique_ptr< net::DatagramSocket > &&sock, const Config &config, const Logger &l={}) |
| |
| const InfoHash & | getNodeId () const override |
| |
| NodeStatus | updateStatus (sa_family_t af) override |
| |
| NodeStatus | getStatus (sa_family_t af) const override |
| |
| NodeStatus | getStatus () const override |
| |
| net::DatagramSocket * | getSocket () const override |
| |
| void | shutdown (ShutdownCallback cb, bool stop=false) override |
| |
| bool | isRunning (sa_family_t af=0) const override |
| |
| virtual void | registerType (const ValueType &type) override |
| |
| const ValueType & | getType (ValueType::Id type_id) const override |
| |
| void | addBootstrap (const std::string &host, const std::string &service) override |
| |
| void | clearBootstrap () override |
| |
| void | insertNode (const InfoHash &id, const SockAddr &) override |
| |
| void | insertNode (const NodeExport &n) override |
| |
| void | pingNode (SockAddr, DoneCallbackSimple &&cb={}) override |
| |
| time_point | periodic (const uint8_t *buf, size_t buflen, SockAddr, const time_point &now) override |
| |
| time_point | periodic (const uint8_t *buf, size_t buflen, const sockaddr *from, socklen_t fromlen, const time_point &now) override |
| |
| virtual void | get (const InfoHash &key, GetCallback cb, DoneCallback donecb={}, Value::Filter &&f={}, Where &&w={}) override |
| |
| virtual void | get (const InfoHash &key, GetCallback cb, DoneCallbackSimple donecb={}, Value::Filter &&f={}, Where &&w={}) override |
| |
| virtual void | get (const InfoHash &key, GetCallbackSimple cb, DoneCallback donecb={}, Value::Filter &&f={}, Where &&w={}) override |
| |
| virtual void | get (const InfoHash &key, GetCallbackSimple cb, DoneCallbackSimple donecb, Value::Filter &&f={}, Where &&w={}) override |
| |
| virtual void | query (const InfoHash &key, QueryCallback cb, DoneCallback done_cb={}, Query &&q={}) override |
| |
| virtual void | query (const InfoHash &key, QueryCallback cb, DoneCallbackSimple done_cb={}, Query &&q={}) override |
| |
| std::vector< Sp< Value > > | getLocal (const InfoHash &key, const Value::Filter &f={}) const override |
| |
| Sp< Value > | getLocalById (const InfoHash &key, Value::Id vid) const override |
| |
| void | put (const InfoHash &key, Sp< Value >, DoneCallback cb=nullptr, time_point created=time_point::max(), bool permanent=false) override |
| |
| void | put (const InfoHash &key, const Sp< Value > &v, DoneCallbackSimple cb, time_point created=time_point::max(), bool permanent=false) override |
| |
| void | put (const InfoHash &key, Value &&v, DoneCallback cb=nullptr, time_point created=time_point::max(), bool permanent=false) override |
| |
| void | put (const InfoHash &key, Value &&v, DoneCallbackSimple cb, time_point created=time_point::max(), bool permanent=false) override |
| |
| std::vector< Sp< Value > > | getPut (const InfoHash &) const override |
| |
| Sp< Value > | getPut (const InfoHash &, const Value::Id &) const override |
| |
| bool | cancelPut (const InfoHash &, const Value::Id &) override |
| |
| size_t | listen (const InfoHash &, ValueCallback, Value::Filter={}, Where={}) override |
| |
| size_t | listen (const InfoHash &key, GetCallback cb, Value::Filter f={}, Where w={}) override |
| |
| size_t | listen (const InfoHash &key, GetCallbackSimple cb, Value::Filter f={}, Where w={}) override |
| |
| bool | cancelListen (const InfoHash &, size_t token) override |
| |
| void | connectivityChanged (sa_family_t) override |
| |
| void | connectivityChanged () override |
| |
| std::vector< NodeExport > | exportNodes () const override |
| |
| std::vector< ValuesExport > | exportValues () const override |
| |
| void | importValues (const std::vector< ValuesExport > &) override |
| |
|
void | saveState (const std::string &path) const |
| |
|
void | loadState (const std::string &path) |
| |
| NodeStats | getNodesStats (sa_family_t af) const override |
| |
| std::string | getStorageLog () const override |
| |
| std::string | getStorageLog (const InfoHash &) const override |
| |
| std::string | getRoutingTablesLog (sa_family_t) const override |
| |
| std::string | getSearchesLog (sa_family_t) const override |
| |
| std::string | getSearchLog (const InfoHash &, sa_family_t af=AF_UNSPEC) const override |
| |
| void | dumpTables () const override |
| |
| std::vector< unsigned > | getNodeMessageStats (bool in=false) override |
| |
| void | setStorageLimit (size_t limit=DEFAULT_STORAGE_LIMIT) override |
| |
| size_t | getStorageLimit () const override |
| |
| std::pair< size_t, size_t > | getStoreSize () const override |
| |
| std::vector< SockAddr > | getPublicAddress (sa_family_t family=0) override |
| |
| void | pushNotificationReceived (const std::map< std::string, std::string > &) override |
| |
| void | resubscribe (unsigned) |
| |
| | DhtInterface (const Logger &l) |
| |
| | DhtInterface (const std::shared_ptr< Logger > &l) |
| |
| virtual NodeStatus | updateStatus (sa_family_t af) |
| |
| virtual NodeStatus | getStatus (sa_family_t af) const =0 |
| |
|
virtual NodeStatus | getStatus () const =0 |
| |
| void | addOnConnectedCallback (std::function< void()> cb) |
| |
| virtual net::DatagramSocket * | getSocket () const |
| |
| virtual const InfoHash & | getNodeId () const =0 |
| |
| virtual void | shutdown (ShutdownCallback cb, bool stop=false)=0 |
| |
| virtual bool | isRunning (sa_family_t af=0) const =0 |
| |
|
virtual void | registerType (const ValueType &type)=0 |
| |
|
virtual const ValueType & | getType (ValueType::Id type_id) const =0 |
| |
| virtual void | addBootstrap (const std::string &, const std::string &) |
| |
| virtual void | clearBootstrap () |
| |
| virtual void | insertNode (const InfoHash &id, const SockAddr &)=0 |
| |
|
virtual void | insertNode (const NodeExport &n)=0 |
| |
|
virtual void | pingNode (SockAddr, DoneCallbackSimple &&cb={})=0 |
| |
|
virtual time_point | periodic (const uint8_t *buf, size_t buflen, SockAddr, const time_point &now)=0 |
| |
|
virtual time_point | periodic (const uint8_t *buf, size_t buflen, const sockaddr *from, socklen_t fromlen, const time_point &now)=0 |
| |
| virtual void | get (const InfoHash &key, GetCallback cb, DoneCallback donecb={}, Value::Filter &&f={}, Where &&w={})=0 |
| |
|
virtual void | get (const InfoHash &key, GetCallback cb, DoneCallbackSimple donecb={}, Value::Filter &&f={}, Where &&w={})=0 |
| |
|
virtual void | get (const InfoHash &key, GetCallbackSimple cb, DoneCallback donecb={}, Value::Filter &&f={}, Where &&w={})=0 |
| |
|
virtual void | get (const InfoHash &key, GetCallbackSimple cb, DoneCallbackSimple donecb, Value::Filter &&f={}, Where &&w={})=0 |
| |
| virtual void | query (const InfoHash &key, QueryCallback cb, DoneCallback done_cb={}, Query &&q={})=0 |
| |
|
virtual void | query (const InfoHash &key, QueryCallback cb, DoneCallbackSimple done_cb={}, Query &&q={})=0 |
| |
| virtual std::vector< Sp< Value > > | getLocal (const InfoHash &key, const Value::Filter &f={}) const =0 |
| |
| virtual Sp< Value > | getLocalById (const InfoHash &key, Value::Id vid) const =0 |
| |
| virtual void | put (const InfoHash &key, Sp< Value >, DoneCallback cb=nullptr, time_point created=time_point::max(), bool permanent=false)=0 |
| |
|
virtual void | put (const InfoHash &key, const Sp< Value > &v, DoneCallbackSimple cb, time_point created=time_point::max(), bool permanent=false)=0 |
| |
|
virtual void | put (const InfoHash &key, Value &&v, DoneCallback cb=nullptr, time_point created=time_point::max(), bool permanent=false)=0 |
| |
|
virtual void | put (const InfoHash &key, Value &&v, DoneCallbackSimple cb, time_point created=time_point::max(), bool permanent=false)=0 |
| |
| virtual std::vector< Sp< Value > > | getPut (const InfoHash &) const =0 |
| |
| virtual Sp< Value > | getPut (const InfoHash &, const Value::Id &) const =0 |
| |
| virtual bool | cancelPut (const InfoHash &, const Value::Id &)=0 |
| |
| virtual size_t | listen (const InfoHash &, GetCallback, Value::Filter={}, Where w={})=0 |
| |
|
virtual size_t | listen (const InfoHash &key, GetCallbackSimple cb, Value::Filter f={}, Where w={})=0 |
| |
| virtual size_t | listen (const InfoHash &, ValueCallback, Value::Filter={}, Where w={})=0 |
| |
|
virtual bool | cancelListen (const InfoHash &, size_t token)=0 |
| |
| virtual void | connectivityChanged (sa_family_t)=0 |
| |
|
virtual void | connectivityChanged ()=0 |
| |
| virtual std::vector< NodeExport > | exportNodes () const =0 |
| |
|
virtual std::vector< ValuesExport > | exportValues () const =0 |
| |
|
virtual void | importValues (const std::vector< ValuesExport > &)=0 |
| |
| virtual NodeStats | getNodesStats (sa_family_t af) const =0 |
| |
|
virtual std::string | getStorageLog () const =0 |
| |
|
virtual std::string | getStorageLog (const InfoHash &) const =0 |
| |
|
virtual std::string | getRoutingTablesLog (sa_family_t) const =0 |
| |
|
virtual std::string | getSearchesLog (sa_family_t) const =0 |
| |
|
virtual std::string | getSearchLog (const InfoHash &, sa_family_t af=AF_UNSPEC) const =0 |
| |
|
virtual void | dumpTables () const =0 |
| |
|
virtual std::vector< unsigned > | getNodeMessageStats (bool in=false)=0 |
| |
| virtual void | setStorageLimit (size_t limit=DEFAULT_STORAGE_LIMIT)=0 |
| |
|
virtual size_t | getStorageLimit () const =0 |
| |
| virtual std::pair< size_t, size_t > | getStoreSize () const =0 |
| |
| virtual std::vector< SockAddr > | getPublicAddress (sa_family_t family=0)=0 |
| |
| virtual void | setLoggers (LogMethod error={}, LogMethod warn={}, LogMethod debug={}) |
| |
| virtual void | setLogger (const Logger &l) |
| |
| virtual void | setLogger (const std::shared_ptr< Logger > &l) |
| |
| virtual void | setLogFilter (const InfoHash &f) |
| |
| virtual void | setPushNotificationToken (const std::string &) |
| |
| virtual void | pushNotificationReceived (const std::map< std::string, std::string > &data)=0 |
| |