iterator

type Args struct {
	// Client interfaces are obtained from BuildClients.
	Clients

	// Emitter is an interface used to return metadata to the invoker.
	Emitter IteratorEmitter

	// Specify the namespace of the VolumeSnapshot objects.
	Namespace string

	// SnapshotName identifies a VolumeSnaphot.
	SnapshotName string

	// PrevSnapshotID is the CSI handle of a VolumeSnapshot, set in
	// the Status.SnapshotHandle field of its associated
	// VolumeSnapshotContent object.
	//
	// The field is optional, and if specified will result in
	// enumeration of the changed blocks between the VolumeSnapshot
	// identified by it and that identified by the SnapshotName field.
	//
	// If both PrevSnapshotID and PrevSnapshotName are specified then
	// the latter is ignored.
	// If neither are specified then the allocated blocks of the VolumeSnapshot
	// identified by SnapshotName will be enumerated.
	PrevSnapshotID string

	// PrevSnapshotName is optional, and if specified will result in
	// enumeration of the changed blocks between the VolumeSnapshot
	// identified by it and that identified by the SnapshotName field.
	//
	// If both PrevSnapshotID and PrevSnapshotName are specified then
	// the latter is ignored.
	// If neither are specified then the allocated blocks of the VolumeSnapshot
	// identified by SnapshotName will be enumerated.
	//
	// If PrevSnapshotName is specified and PrevSnapshotID is not specified
	// then the VolumeSnapshotContent object associated with the named
	// VolumeSnapshot object will be used to obtain its CSI handle.
	PrevSnapshotName string

	// StartingOffset is the initial byte offset.
	StartingOffset int64

	// MaxResults is the number of tuples to return in each record.
	// If 0 then the CSI driver decides the value.
	MaxResults int32

	// CSIDriver specifies the name of the CSI driver and is used to
	// load the associated SnapshotMetadataService CR.
	// The field is optional. If not specified then it
	// will be fetched from the VolumeSnapshotContent of
	// the VolumeSnapshot specified by the SnapshotName field.
	CSIDriver string

	// Specify the ServiceAccount object used to construct a security token
	// with the audience string from the SnapshotMetadataService CR.
	// If either of the following fields are unspecified, the default for the given client will be used.
	SANamespace string
	SAName      string

	// TokenExpirySecs specifies the time in seconds after which the
	// security token will expire.
	// If unspecified then the value of DefaultTokenExpirySeconds is used.
	TokenExpirySecs int64
}

type Clients struct {
	KubeClient     kubernetes.Interface
	SnapshotClient snapshot.Interface
	SmsCRClient    smsCR.Interface
}

type IteratorEmitter interface {
	// SnapshotMetadataIteratorRecord is invoked for each record received
	// from the gRPC stream.
	SnapshotMetadataIteratorRecord(recordNumber int, metadata IteratorMetadata) error

	// SnapshotMetadataIteratorDone is called prior to termination as long as
	// no error was encountered.
	SnapshotMetadataIteratorDone(numberRecords int) error
}

type IteratorMetadata struct {
	BlockMetadataType   api.BlockMetadataType `json:"block_metadata_type"`
	VolumeCapacityBytes int64                 `json:"volume_capacity_bytes"`
	BlockMetadata       []*api.BlockMetadata  `json:"block_metadata"`
}

type JSONEmitter struct {
	Writer io.Writer
	// contains filtered or unexported fields
}

type TableEmitter struct {
	Writer io.Writer
}

type VerifierEmitter struct {
	// SourceDevice contains the source device file descriptor.
	SourceDevice *os.File

	// TargetDevice contains the target device file descriptor.
	TargetDevice *os.File
}