repo

Documentation

Index

• Variables
• type NodesRepo
  • func New(rdb *sql.DB, wdb *sql.DB) *NodesRepo
  • func (r *NodesRepo) GetNodeByPublicKey(ctx context.Context, pk *dht.PublicKey) (*models.Node, error)
  • func (r *NodesRepo) GetNodeCount(ctx context.Context) (int64, error)
  • func (r *NodesRepo) GetNodesWithStaleBootstrapInfo(ctx context.Context) ([]*models.Node, error)
  • func (r *NodesRepo) GetResponsiveDHTNodes(ctx context.Context) ([]*dht.Node, error)
  • func (r *NodesRepo) GetUnresponsiveDHTNodes(ctx context.Context, retryDelay time.Duration) ([]*dht.Node, error)
  • func (r *NodesRepo) HasNodeByPublicKey(ctx context.Context, pk *dht.PublicKey) (bool, error)
  • func (r *NodesRepo) PingDHTNode(ctx context.Context, node *dht.Node) error
  • func (r *NodesRepo) PongDHTNode(ctx context.Context, node *dht.Node) error
  • func (r *NodesRepo) TrackDHTNode(ctx context.Context, node *dht.Node) (*models.Node, error)
  • func (r *NodesRepo) UpdateNodeInfo(ctx context.Context, addr *net.UDPAddr, motd string, version uint32) error
  • func (r *NodesRepo) UpdateNodeInfoRequestTime(ctx context.Context, addrReqTimes map[int64]time.Time) error

Variables

var ErrNotFound = fmt.Errorf("not found: %w", sql.ErrNoRows)

Types

type NodesRepo

type NodesRepo struct {
	// contains filtered or unexported fields
}

func New

func New(rdb *sql.DB, wdb *sql.DB) *NodesRepo

func (*NodesRepo) GetNodeByPublicKey

func (r *NodesRepo) GetNodeByPublicKey(ctx context.Context, pk *dht.PublicKey) (*models.Node, error)

func (*NodesRepo) GetNodeCount

func (r *NodesRepo) GetNodeCount(ctx context.Context) (int64, error)

func (*NodesRepo) GetNodesWithStaleBootstrapInfo

func (r *NodesRepo) GetNodesWithStaleBootstrapInfo(ctx context.Context) ([]*models.Node, error)

func (*NodesRepo) GetResponsiveDHTNodes

func (r *NodesRepo) GetResponsiveDHTNodes(ctx context.Context) ([]*dht.Node, error)

func (*NodesRepo) GetUnresponsiveDHTNodes

func (r *NodesRepo) GetUnresponsiveDHTNodes(ctx context.Context, retryDelay time.Duration) ([]*dht.Node, error)

func (*NodesRepo) HasNodeByPublicKey

func (r *NodesRepo) HasNodeByPublicKey(ctx context.Context, pk *dht.PublicKey) (bool, error)

func (*NodesRepo) PingDHTNode

func (r *NodesRepo) PingDHTNode(ctx context.Context, node *dht.Node) error

func (*NodesRepo) PongDHTNode

func (r *NodesRepo) PongDHTNode(ctx context.Context, node *dht.Node) error

func (*NodesRepo) TrackDHTNode

func (r *NodesRepo) TrackDHTNode(ctx context.Context, node *dht.Node) (*models.Node, error)

func (*NodesRepo) UpdateNodeInfo

func (r *NodesRepo) UpdateNodeInfo(ctx context.Context, addr *net.UDPAddr, motd string, version uint32) error

func (*NodesRepo) UpdateNodeInfoRequestTime

func (r *NodesRepo) UpdateNodeInfoRequestTime(ctx context.Context, addrReqTimes map[int64]time.Time) error