Versions in this module Expand all Collapse all v0 v0.3.0 May 23, 2024 Changes in this version + const IpBytePadSize + const ProcessStatusPopulateAddr + const ProcessStatusPopulateAddrInputs + const ProcessStatusPopulateP2sh + const SyncStatusComplete + func GetCountPeerConnections() (uint64, error) + func GetCountPeers() (uint64, error) + func GetTopics() []db.Object + func GetTopicsSorted() []db.Object + func LogProcessError(processError *ProcessError) error + type FoundPeer struct + FoundIp []byte + FoundPort uint16 + Ip []byte + Port uint16 + func GetFoundPeers(shard uint32, startId []byte, ip []byte, port uint16) ([]*FoundPeer, error) + func (p *FoundPeer) Deserialize([]byte) + func (p *FoundPeer) GetShardSource() uint + func (p *FoundPeer) GetTopic() string + func (p *FoundPeer) GetUid() []byte + func (p *FoundPeer) Serialize() []byte + func (p *FoundPeer) SetUid(uid []byte) + type IpPort struct + Ip []byte + Port uint16 + type Message struct + Created time.Time + Id uint + Message string + func GetMessage(id uint) (*Message, error) + func (t *Message) Deserialize(data []byte) + func (t *Message) GetShardSource() uint + func (t *Message) GetTopic() string + func (t *Message) GetUid() []byte + func (t *Message) Serialize() []byte + func (t *Message) SetUid(uid []byte) + type Peer struct + Ip []byte + Port uint16 + Services uint64 + func GetNextPeer(shard uint32, startId []byte) (*Peer, error) + func GetPeers(shard uint32, startId []byte) ([]*Peer, error) + func (p *Peer) Deserialize(data []byte) + func (p *Peer) GetShardSource() uint + func (p *Peer) GetTopic() string + func (p *Peer) GetUid() []byte + func (p *Peer) Serialize() []byte + func (p *Peer) SetUid(uid []byte) + type PeerConnection struct + Ip []byte + Port uint16 + Status PeerConnectionStatus + Time time.Time + func GetPeerConnectionLast(ip []byte, port uint16) (*PeerConnection, error) + func GetPeerConnectionLasts(ipPorts []IpPort) ([]*PeerConnection, error) + func GetPeerConnections(request PeerConnectionsRequest) ([]*PeerConnection, error) + func (p *PeerConnection) Deserialize(data []byte) + func (p *PeerConnection) GetShardSource() uint + func (p *PeerConnection) GetTopic() string + func (p *PeerConnection) GetUid() []byte + func (p *PeerConnection) Serialize() []byte + func (p *PeerConnection) SetUid(uid []byte) + type PeerConnectionStatus int + const PeerConnectionStatusFail + const PeerConnectionStatusSuccess + func (s PeerConnectionStatus) String() string + type PeerConnectionsRequest struct + Ip []byte + Max uint32 + Port uint32 + Shard uint32 + StartId []byte + func (r PeerConnectionsRequest) GetShard() uint32 + type PeerFound struct + FinderIp []byte + FinderPort uint16 + Ip []byte + Port uint16 + func GetPeerFounds(shard uint32, startId []byte) ([]*PeerFound, error) + func (p *PeerFound) Deserialize([]byte) + func (p *PeerFound) GetShardSource() uint + func (p *PeerFound) GetTopic() string + func (p *PeerFound) GetUid() []byte + func (p *PeerFound) Serialize() []byte + func (p *PeerFound) SetUid(uid []byte) + type ProcessError struct + Error string + TxHash [32]byte + func (e *ProcessError) Deserialize(data []byte) + func (e *ProcessError) GetShardSource() uint + func (e *ProcessError) GetTopic() string + func (e *ProcessError) GetUid() []byte + func (e *ProcessError) Serialize() []byte + func (e *ProcessError) SetUid(uid []byte) + type ProcessStatus struct + Name string + Shard uint + Status []byte + func GetProcessStatus(shard uint, name string) (*ProcessStatus, error) + func NewProcessStatus(shard uint, name string) *ProcessStatus + func (s *ProcessStatus) Deserialize(data []byte) + func (s *ProcessStatus) GetShardSource() uint + func (s *ProcessStatus) GetTopic() string + func (s *ProcessStatus) GetUid() []byte + func (s *ProcessStatus) Save() error + func (s *ProcessStatus) Serialize() []byte + func (s *ProcessStatus) SetUid(uid []byte) + type SyncStatus struct + Height int64 + Name string + func GetSyncStatus(name string) (*SyncStatus, error) + func (s *SyncStatus) Deserialize(data []byte) + func (s *SyncStatus) GetShardSource() uint + func (s *SyncStatus) GetTopic() string + func (s *SyncStatus) GetUid() []byte + func (s *SyncStatus) Serialize() []byte + func (s *SyncStatus) SetUid(uid []byte) v0.2.0-alpha.0 Feb 23, 2023 v0.1.0 Dec 31, 2021
Go to main page