Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

iterator

package

Go to main page

Versions in this module

v0

v0.2.0

Oct 28, 2025

Changes in this version

+ var ErrContentsDoNotMatch = errors.New("source and target device contents do not match")

+ var ErrFailedToSeek = errors.New("failed to seek")

type Args

+ PrevSnapshotID string

+ type VerifierEmitter struct

+ SourceDevice *os.File

+ TargetDevice *os.File

+ func (verifierEmitter *VerifierEmitter) SnapshotMetadataIteratorDone(_ int) error

+ func (verifierEmitter *VerifierEmitter) SnapshotMetadataIteratorRecord(_ int, metadata IteratorMetadata) error

v0.1.0

Jan 29, 2025

Changes in this version

+ const DefaultTokenExpirySeconds

+ const K8sServiceAccountUserNamePrefix

+ var ErrCACert = errors.New("failed to add the SnapshotMetadataService CR CA certificate")

+ var ErrCancelled = errors.New("enumeration cancelled")

+ var ErrInvalidArgs = errors.New("invalid argument")

+ func GetSnapshotMetadata(ctx context.Context, args Args) error

+ type Args struct

+ CSIDriver string

+ Emitter IteratorEmitter

+ MaxResults int32

+ Namespace string

+ PrevSnapshotName string

+ SAName string

+ SANamespace string

+ SnapshotName string

+ StartingOffset int64

+ TokenExpirySecs int64

+ func (a Args) Validate() error

+ type Clients struct

+ KubeClient kubernetes.Interface

+ SmsCRClient smsCR.Interface

+ SnapshotClient snapshot.Interface

+ func BuildClients(config *rest.Config) (Clients, error)

+ func (c Clients) Validate() error

+ type IteratorEmitter interface

+ SnapshotMetadataIteratorDone func(numberRecords int)

+ SnapshotMetadataIteratorRecord func(recordNumber int, metadata IteratorMetadata) bool

+ type IteratorMetadata struct

+ BlockMetadata []*api.BlockMetadata

+ BlockMetadataType api.BlockMetadataType

+ VolumeCapacityBytes int64

+ type JSONEmitter struct

+ Writer io.Writer

+ func (e *JSONEmitter) SnapshotMetadataIteratorDone(_ int)

+ func (e *JSONEmitter) SnapshotMetadataIteratorRecord(recordNumber int, metadata IteratorMetadata) bool

+ type TableEmitter struct

+ Writer io.Writer

+ func (e *TableEmitter) SnapshotMetadataIteratorDone(_ int)

+ func (e *TableEmitter) SnapshotMetadataIteratorRecord(recordNumber int, metadata IteratorMetadata) bool