node

package
v1.18.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 12, 2025 License: AGPL-3.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Audit added in v1.13.0

type Audit struct {
	db.WithDatabase
	util.DialerHelper
	NodeURL   storj.NodeURL `reuired:"" help:"Node address"`
	Keys      string        `required:"" help:"the satellite identity directory"`
	PieceFile string        `required:"" help:"CSV file with piece information"`
}

func (*Audit) Run added in v1.13.0

func (a *Audit) Run() error

type Checkin

type Checkin struct {
	util.DialerHelper
	URL             string `arg:""`
	ExternalAddress string
}

func (*Checkin) Run

func (c *Checkin) Run() error

type Convert

type Convert struct {
	NodeID     storj.NodeID
	Input      string `arg:""`
	Conversion int
}

func (Convert) Run

func (c Convert) Run() error

convert rootPieceId,index,... file to pieceId,...

type Enrich added in v1.3.0

type Enrich struct {
	db.WithDatabase
	File string `arg:""`
}

func (Enrich) Run added in v1.3.0

func (i Enrich) Run() error

type Export

type Export struct {
	MaxmindDB string
}

func (Export) Run

func (c Export) Run() error

type GeoIP

type GeoIP struct {
	GetDatabase string `arg:""`
	IP          string `arg:""`
}

func (GeoIP) Run

func (g GeoIP) Run() error

type Info

type Info struct {
	db.WithDatabase
	NodeID   storj.NodeID `arg:""`
	Selector string
}

func (Info) Run

func (i Info) Run() error

type Node

type Node struct {
	Report Report `cmd:""`

	PricingModel PricingModel `cmd:"" help:"Get pricing model from satellite (sn->satellite RPC)"`
	Checkin      Checkin      `cmd:"" help:"node checking rpc call (sn->satellite RPC)"`
	Usage        Usage        `cmd:"" help:"calls the info endpoint of the satellite in the name of the storagenode (sn->satellite RPC)"`
	Time         Time         `cmd:"" help:"Get time of the satellite (sn->satellite)"`
	Paystub      Paystub      `cmd:"" help:"Get paystub from satellite (sn->satellite RPC)"`
	Stats        Stats        `cmd:"" help:"Get stats from satellite (sn->satellite RPC)"`

	Enrich Enrich `cmd:"" help:"enrich node information with metadata from the satellite"`

	Export      Export      `cmd:""`
	UnsentOrder UnsentOrder `cmd:"" help:"parse unsent order archive"`

	PieceList      PieceList      `cmd:"" help:"generate list of pieces for one node"`
	PieceListCheck PieceListCheck `cmd:"" help:"check the generated list based on a real blobstore"`
	GeoIP          GeoIP          `cmd:"" help:"opens and prints out maxmind GeoIP database"`
	Convert        Convert        `cmd:""`
	Info           Info           `cmd:"" help:"information for one node"`
	Audit          Audit          `cmd:"" help:"audit pieces from CSV file by downloading and checking checksums"`
}

type NodeRecord

type NodeRecord struct {
	NodeID     storj.NodeID
	Address    string
	LastIPPort string
	Country    location.CountryCode
	UpdatedAt  time.Time
}

type Paystub

type Paystub struct {
	URL    string `arg:""`
	Period string `arg:""`
	util.DialerHelper
}

func (Paystub) Run

func (g Paystub) Run() error

type PieceList

type PieceList struct {
	Aliases []int32 `arg:""`
	Limit   int64
	// contains filtered or unexported fields
}

func (*PieceList) Run

func (p *PieceList) Run() error

type PieceListCheck

type PieceListCheck struct {
	File              string `arg:""`
	PieceExpirationDB string
	NodeID            storj.NodeID
	Verbose           bool
}

func (*PieceListCheck) Run

func (p *PieceListCheck) Run() error

type PricingModel added in v1.3.0

type PricingModel struct {
	util.DialerHelper
	URL string `arg:""`
}

func (PricingModel) Run added in v1.3.0

func (g PricingModel) Run() error

type Report

type Report struct {
	NodeFile string `arg:""`
}

type Stat

type Stat map[string]int

func (Stat) Increment

func (s Stat) Increment(group string)

func (Stat) Summary

func (s Stat) Summary()

type Stats added in v1.15.0

type Stats struct {
	URL string `arg:""`
	util.DialerHelper
}

func (Stats) Run added in v1.15.0

func (p Stats) Run() error

type Time added in v1.15.0

type Time struct {
	URL string `arg:""`
	util.DialerHelper
}

func (Time) Run added in v1.15.0

func (p Time) Run() error

type UnsentOrder

type UnsentOrder struct {
	File           string `arg:""`
	EncryptionKeys string
}

func (UnsentOrder) Run

func (c UnsentOrder) Run() error

type Usage

type Usage struct {
	util.DialerHelper
	SatelliteID storj.NodeURL `arg:""`
}

func (Usage) Run

func (u Usage) Run() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL