Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrEOF = event.ErrEOF
Functions ¶
Types ¶
type ObjectHandleEventReader ¶
type ObjectHandleEventReader struct {
Object *storage.ObjectHandle
Attrs *storage.ObjectAttrs
// contains filtered or unexported fields
}
func (*ObjectHandleEventReader) Close ¶
func (r *ObjectHandleEventReader) Close() error
func (*ObjectHandleEventReader) Read ¶
func (r *ObjectHandleEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
type ObjectIteratorEventReader ¶
type ObjectIteratorEventReader struct {
Bucket *storage.BucketHandle
Iterator *storage.ObjectIterator
// contains filtered or unexported fields
}
func (*ObjectIteratorEventReader) Close ¶
func (r *ObjectIteratorEventReader) Close() error
func (*ObjectIteratorEventReader) Read ¶
func (r *ObjectIteratorEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
type QueryEventReader ¶
type QueryEventReader struct {
Bucket *storage.BucketHandle
Query *storage.Query
// contains filtered or unexported fields
}
func (*QueryEventReader) Close ¶
func (r *QueryEventReader) Close() error
func (*QueryEventReader) Read ¶
func (r *QueryEventReader) Read(ctx context.Context) (model.MXPGVKEvent, error)
type QueryIterator ¶
type QueryIterator struct {
Account string
Iter *usagetime.WindowIterator
}
QueryIterator iterates through queries for usage data for an Upbound account across a range of time. Each query covers a window of time within the time range. Must be initialized with NewUsageQueryIterator().
func NewQueryIterator ¶
func NewQueryIterator(account string, tr usagetime.Range, window time.Duration) (*QueryIterator, error)
NewQueryIterator() returns an initialized *UsageQueryIterator. The start of the time range is inclusive and the end is exclusive to the hour. The time range and window are truncated to the hour.
func (*QueryIterator) More ¶
func (i *QueryIterator) More() bool
More() returns true if Next() has more queries to return.
type WindowIterator ¶
type WindowIterator struct {
Iter *QueryIterator
Bucket *storage.BucketHandle
}
WindowIterator iterates through readers for windows of usage events from an Azure blob storage container. Must be initialized with NewWindowIterator().
func NewWindowIterator ¶
func NewWindowIterator(bkt *storage.BucketHandle, 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
Click to show internal directories.
Click to hide internal directories.