Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrCDCIteratorIsStopped = errors.New("CDC iterator is stopped")
View Source
var ErrSnapshotIteratorIsStopped = errors.New("snapshot iterator is stopped")
View Source
var ErrUnsupportedIterator = errors.New("unsupported iterator")
Functions ¶
This section is empty.
Types ¶
type CDCIterator ¶
type CDCIterator struct {
// contains filtered or unexported fields
}
func NewCDCIterator ¶
func NewCDCIterator( pollingPeriod time.Duration, client *azblob.ContainerClient, from time.Time, maxResults int32, ) (*CDCIterator, error)
func (*CDCIterator) Stop ¶
func (w *CDCIterator) Stop()
type CombinedIterator ¶
type CombinedIterator struct {
// contains filtered or unexported fields
}
func NewCombinedIterator ¶
func NewCombinedIterator( pollingPeriod time.Duration, client *azblob.ContainerClient, maxResults int32, p position.Position, ) (c *CombinedIterator, err error)
func (*CombinedIterator) Stop ¶
func (c *CombinedIterator) Stop()
type Iterator ¶
type Iterator interface {
// HasNext indicates whether there is new sdk.Record available (`true`) or not (`false`)
HasNext(ctx context.Context) bool
// Next returns new sdk.Record while reading the container or error when operation failed
Next(ctx context.Context) (sdk.Record, error)
// Stop informs the iterator to stop processing new records.
// All currently ongoing operations should be gracefully shut down.
Stop()
}
type SnapshotIterator ¶
type SnapshotIterator struct {
// contains filtered or unexported fields
}
func NewSnapshotIterator ¶
func NewSnapshotIterator( client *azblob.ContainerClient, p position.Position, maxResults int32, ) (*SnapshotIterator, error)
func (*SnapshotIterator) Stop ¶
func (w *SnapshotIterator) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.