Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ErrEOF = event.ErrEOF
Functions ¶
This section is empty.
Types ¶
type BlobEventReader ¶
type BlobEventReader struct {
Client *blob.Client
ContentType string
// contains filtered or unexported fields
}
BlobEventReader reads usage events from a blob client.
func (*BlobEventReader) Close ¶
func (r *BlobEventReader) Close() error
func (*BlobEventReader) Read ¶
func (r *BlobEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
type ListBlobsOptionsIterator ¶
type ListBlobsOptionsIterator struct {
Account string
Iter *usagetime.WindowIterator
}
ListBlobsOptionsIterator iterates through slices of ListBlobsFlatOptions for each window of time in a time range. Must be initialized with NewListBlobOptions().
func NewListBlobsOptionsIterator ¶
func NewListBlobsOptionsIterator(account string, tr usagetime.Range, window time.Duration) (*ListBlobsOptionsIterator, error)
NewListBlobsOptionsIterator returns an initialized *ListBlobOptionsIterator.
func (*ListBlobsOptionsIterator) More ¶
func (i *ListBlobsOptionsIterator) More() bool
More() returns true if Next() has more to return.
func (*ListBlobsOptionsIterator) Next ¶
func (i *ListBlobsOptionsIterator) Next() ([]container.ListBlobsFlatOptions, usagetime.Range, error)
Next() returns a []container.ListBlobsFlatOptions covering the next window of time, as well as a time range marking the window.
type ListBlobsResponseEventReader ¶
type ListBlobsResponseEventReader struct {
Client *container.Client
Response *container.ListBlobsFlatResponse
// contains filtered or unexported fields
}
ListBlobsResponseEventReader reads usage events from a blob list response.
func (*ListBlobsResponseEventReader) Close ¶
func (r *ListBlobsResponseEventReader) Close() error
func (*ListBlobsResponseEventReader) Read ¶
func (r *ListBlobsResponseEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
type PagerEventReader ¶
type PagerEventReader struct {
Client *container.Client
Pager *runtime.Pager[container.ListBlobsFlatResponse]
// contains filtered or unexported fields
}
PagerEventReader reads usage events from a pager for blob list responses.
func (*PagerEventReader) Close ¶
func (r *PagerEventReader) Close() error
func (*PagerEventReader) Read ¶
func (r *PagerEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
type WindowIterator ¶
type WindowIterator struct {
Iter *ListBlobsOptionsIterator
Client *container.Client
}
WindowIterator iterates through readers for windows of usage events from an Azure blob storage container. Must be initialized with NewWindowIterator().
func NewWindowIterator ¶
func NewWindowIterator(cli *container.Client, account string, tr usagetime.Range, window time.Duration) (*WindowIterator, error)
NewWindowIterator returns an initialized *WindowIterator.
func (*WindowIterator) More ¶
func (i *WindowIterator) More() bool
Source Files