Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

util

package

Go to main page

Versions in this module

v1

v1.4.0

Mar 7, 2025

v1.3.0

Feb 28, 2025

Changes in this version

+ func NodeInfo(res []nodeselection.NodeAttribute, node nodeselection.SelectedNode) string

+ func ParseAttributes(attr []string) (res []nodeselection.NodeAttribute, err error)

v1.2.0

Dec 4, 2024

v1.1.0

Nov 27, 2024

v1.0.0

Nov 12, 2024

Changes in this version

+ var Certificate []byte

+ var Key []byte

+ func DownloadPiece(ctx context.Context, client pb.DRPCReplaySafePiecestoreClient, ...) (downloaded int64, chunks int, err error)

+ func ForEachNodeCSV(file string, cb func(node storj.NodeURL) error) error

+ func GetDialer(ctx context.Context, pooled bool, forceQuic bool) (rpc.Dialer, error)

+ func GetDialerForIdentity(ctx context.Context, ident *identity.FullIdentity, pooled bool, forceQuic bool) (rpc.Dialer, error)

+ func Measure(f func() error) (time.Duration, error)

+ func NewTracedConnection(conn drpc.Conn) drpc.Conn

+ func ParseSegmentPosition(i string) (uuid.UUID, metabase.SegmentPosition, error)

+ func ParseUUID(id string) (uuid.UUID, error)

+ func PrintHistogram(nodes []*nodeselection.SelectedNode, selector nodeselection.NodeAttribute)

+ func RunLoop(n int, verbose bool, do func() error) (durationMs int64, err error)

+ type Dialer func(ctx context.Context, nodeURL storj.NodeURL) (_ *rpc.Conn, err error)

+ type DialerHelper struct

+ IdentityDir string

+ Noise bool

+ Pooled bool

+ Quic bool

+ func NewDialerHelper(flagSet *flag.FlagSet) *DialerHelper

+ func (d *DialerHelper) Connect(ctx context.Context, nodeURL storj.NodeURL) (*rpc.Conn, error)

+ func (d *DialerHelper) CreateDialer() (Dialer, error)

+ func (d *DialerHelper) CreateRPCDialer() (rpc.Dialer, error)

+ type DownloadRequest struct

+ PieceID storj.PieceID

+ SatelliteID storj.NodeID

+ Size int64

+ Storagenode storj.NodeURL

+ type KeySigner struct

+ Action pb.PieceAction

+ TTL time.Duration

+ func NewKeySigner() (*KeySigner, error)

+ func NewKeySignerFromDir(keysDir string) (*KeySigner, error)

+ func NewKeySignerFromFullIdentity(id *identity.FullIdentity, action pb.PieceAction) *KeySigner

+ func (d *KeySigner) CreateOrderLimit(ctx context.Context, pieceID storj.PieceID, size int64, sn storj.NodeID) (limit *pb.OrderLimit, pk storj.PiecePrivateKey, serial storj.SerialNumber, ...)

+ func (d *KeySigner) GetSatelliteID() storj.NodeID

+ type Loop struct

+ Sample int

+ Verbose bool

+ func (l *Loop) Run(do func() error) (durationMs int64, err error)

+ type OrderLimitCreator interface

+ CreateOrderLimit func(ctx context.Context, pieceID storj.PieceID, size int64, satellite storj.NodeID, ...) (limit *pb.OrderLimit, pk storj.PiecePrivateKey, serial storj.SerialNumber, ...)

+ type Progres struct

+ func (o *Progres) Counter() int64

+ func (o *Progres) Increment()

+ type TracedConnection struct

+ Conn drpc.Conn

+ func (t *TracedConnection) Close() error

+ func (t *TracedConnection) Closed() <-chan struct{}

+ func (t *TracedConnection) Invoke(ctx context.Context, rpc string, enc drpc.Encoding, in, out drpc.Message) (err error)

+ func (t *TracedConnection) NewStream(ctx context.Context, rpc string, enc drpc.Encoding) (drpc.Stream, error)

+ type TracedStream struct

+ func (t *TracedStream) Close() error

+ func (t *TracedStream) CloseSend() error

+ func (t *TracedStream) Context() context.Context

+ func (t *TracedStream) MsgRecv(msg drpc.Message, enc drpc.Encoding) (err error)

+ func (t *TracedStream) MsgSend(msg drpc.Message, enc drpc.Encoding) (err error)

+ type WithKeySigner struct

+ SignerIdentity string

+ TTL time.Duration

+ func (w *WithKeySigner) CreateOrderLimit(ctx context.Context, pieceID storj.PieceID, size int64, sn storj.NodeID) (limit *pb.OrderLimit, pk storj.PiecePrivateKey, serial storj.SerialNumber, ...)

+ func (w *WithKeySigner) Init(action pb.PieceAction) (err error)